This commit is contained in:
@@ -192,7 +192,7 @@ func ConsumeInboxFile(messageFilename string) ([]string, []string, string, error
|
|||||||
}
|
}
|
||||||
|
|
||||||
// LongPollAllSerevrJobs checks for messages on a all servers defived in job file
|
// LongPollAllSerevrJobs checks for messages on a all servers defived in job file
|
||||||
func LongPollAllSerevrJobs(storage_path string, jobs []client.RequestsJob, timeout int, longPoll bool) (int, string, error) {
|
func LongPollAllServerJobs(storage_path string, jobs []client.RequestsJob, timeout int, longPoll bool) (int, string, error) {
|
||||||
|
|
||||||
// Channel to collect results
|
// Channel to collect results
|
||||||
resultChan := make(chan int, len(jobs))
|
resultChan := make(chan int, len(jobs))
|
||||||
|
|||||||
Reference in New Issue
Block a user