Merge branch 'main' of ssh://git.rileyk.au:19482/riley/uniproc
This commit is contained in:
@@ -158,7 +158,7 @@ void uniproc_await_processes(const uniproc_process* p, int* return_codes, const
|
|||||||
h[i] = (HANDLE)p[i]._proc_hdl;
|
h[i] = (HANDLE)p[i]._proc_hdl;
|
||||||
num_valid_handles++;
|
num_valid_handles++;
|
||||||
}
|
}
|
||||||
|
if (num_valid_handles == 0) return;
|
||||||
WaitForMultipleObjects(num_valid_handles, h, 1, INFINITE);
|
WaitForMultipleObjects(num_valid_handles, h, 1, INFINITE);
|
||||||
free(h);
|
free(h);
|
||||||
|
|
||||||
@@ -191,6 +191,7 @@ int uniproc_are_processes_finished(const uniproc_process* p, const size_t num_pr
|
|||||||
h[i] = (HANDLE)p[i]._proc_hdl;
|
h[i] = (HANDLE)p[i]._proc_hdl;
|
||||||
num_valid_handles++;
|
num_valid_handles++;
|
||||||
}
|
}
|
||||||
|
if (num_valid_handles == 0) return true;
|
||||||
DWORD ret = WaitForMultipleObjects(num_valid_handles, h, 1, 0);
|
DWORD ret = WaitForMultipleObjects(num_valid_handles, h, 1, 0);
|
||||||
free(h);
|
free(h);
|
||||||
return ret >= WAIT_OBJECT_0 && ret < WAIT_OBJECT_0 + num_valid_handles;
|
return ret >= WAIT_OBJECT_0 && ret < WAIT_OBJECT_0 + num_valid_handles;
|
||||||
@@ -212,6 +213,7 @@ void uniproc_await_any_processes(const uniproc_process* p, const size_t num_proc
|
|||||||
h[i] = (HANDLE)p[i]._proc_hdl;
|
h[i] = (HANDLE)p[i]._proc_hdl;
|
||||||
num_valid_handles++;
|
num_valid_handles++;
|
||||||
}
|
}
|
||||||
|
if (num_valid_handles == 0) return;
|
||||||
WaitForMultipleObjects(num_valid_handles, h, 0, INFINITE);
|
WaitForMultipleObjects(num_valid_handles, h, 0, INFINITE);
|
||||||
free(h);
|
free(h);
|
||||||
}
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user