1
1

Force only one thread to come out from the

socket engine.

This commit was SVN r13298.
Этот коммит содержится в:
George Bosilca 2007-01-25 07:36:42 +00:00
родитель dcce444ed4
Коммит 5711583bdf
2 изменённых файлов: 5 добавлений и 5 удалений

Просмотреть файл

@ -178,9 +178,9 @@ void CALLBACK win32_socket_event_callback( void* lpParameter, BOOLEAN TimerOrWai
}
if( master->ev_events & OPAL_EV_WRITE ) {
got |= OPAL_EV_WRITE;
/*if( 0 == WSASetEvent(master->base_handle) ) {
if( 0 == WSASetEvent(master->base_handle) ) {
int error = WSAGetLastError();
}*/
}
}
if( got ) {
@ -248,7 +248,7 @@ static int win32_recompute_event( opal_event_t* master )
}
if( INVALID_HANDLE_VALUE == master->registered_handle ) {
if( 0 == RegisterWaitForSingleObject( &master->registered_handle, master->base_handle, win32_socket_event_callback,
(void*)master, INFINITE, WT_EXECUTEINIOTHREAD ) ) {
(void*)master, INFINITE, WT_EXECUTEINWAITTHREAD ) ) {
error = GetLastError();
WSACloseEvent( master->base_handle );
master->base_handle = INVALID_HANDLE_VALUE;
@ -331,7 +331,7 @@ win32_insert(struct win32op *win32op, opal_event_t *ev)
int error = errno;
}
if( 0 == RegisterWaitForSingleObject( &ev->registered_handle, ev->base_handle, win32_file_event_callback,
(void*)ev, INFINITE, WT_EXECUTEINIOTHREAD ) ) {
(void*)ev, INFINITE, WT_EXECUTEINWAITTHREAD ) ) {
error = GetLastError();
}*/
}

Просмотреть файл

@ -819,7 +819,7 @@ orte_wait_cb(pid_t wpid, orte_wait_fn_t callback, void *data)
handle->data = data;
RegisterWaitForSingleObject( &handle->registered_handle, (HANDLE)handle->pid,
trigger_process_detection, (void*)handle, INFINITE, WT_EXECUTEINIOTHREAD);
trigger_process_detection, (void*)handle, INFINITE, WT_EXECUTEINWAITTHREAD);
OPAL_THREAD_UNLOCK(&mutex);