This commit is contained in:
manojampalam 2016-04-13 22:05:57 -07:00
parent 4ae341b1e3
commit 87dee940d1

View File

@ -123,6 +123,7 @@ void agent_shutdown() {
agent_sm_process_action_queue(); agent_sm_process_action_queue();
while (list != NULL) while (list != NULL)
Sleep(100); Sleep(100);
CloseHandle(ioc_port);
} }
HANDLE iocp_workers[4]; HANDLE iocp_workers[4];
@ -132,8 +133,10 @@ DWORD WINAPI iocp_work(LPVOID lpParam) {
struct agent_connection* con; struct agent_connection* con;
OVERLAPPED *p_ol; OVERLAPPED *p_ol;
while (1) { while (1) {
GetQueuedCompletionStatus(ioc_port, &bytes, &(ULONG_PTR)con, &p_ol, INFINITE); if (GetQueuedCompletionStatus(ioc_port, &bytes, &(ULONG_PTR)con, &p_ol, INFINITE) == FALSE)
return 0;
agent_connection_on_io(con, bytes, p_ol); agent_connection_on_io(con, bytes, p_ol);
} }
} }