src/utils/eloop_win.c

13 #include "eloop.h"
71 static struct eloop_data eloop;
76 	os_memset(&eloop, 0, sizeof(eloop));
77 	eloop.num_handles = 1;
78 	eloop.handles = os_malloc(eloop.num_handles *
79 				  sizeof(eloop.handles[0]));
80 	if (eloop.handles == NULL)
83 	eloop.term_event = CreateEvent(NULL, FALSE, FALSE, NULL);
84 	if (eloop.term_event == NULL) {
87 		os_free(eloop.handles);
99 	if (eloop.num_handles > eloop.reader_count + eloop.event_count + 8)
101 	n = os_realloc_array(eloop.handles, eloop.num_handles * 2,
102 			     sizeof(eloop.handles[0]));
105 	eloop.handles = n;
106 	eloop.num_handles *= 2;
131 	tmp = os_realloc_array(eloop.readers, eloop.reader_count + 1,
139 	tmp[eloop.reader_count].sock = sock;
140 	tmp[eloop.reader_count].eloop_data = eloop_data;
141 	tmp[eloop.reader_count].user_data = user_data;
142 	tmp[eloop.reader_count].handler = handler;
143 	tmp[eloop.reader_count].event = event;
144 	eloop.reader_count++;
145 	eloop.readers = tmp;
146 	if (sock > eloop.max_sock)
147 		eloop.max_sock = sock;
148 	eloop.reader_table_changed = 1;
158 	if (eloop.readers == NULL || eloop.reader_count == 0)
161 	for (i = 0; i < eloop.reader_count; i++) {
162 		if (eloop.readers[i].sock == sock)
165 	if (i == eloop.reader_count)
168 	WSAEventSelect(eloop.readers[i].sock, eloop.readers[i].event, 0);
169 	WSACloseEvent(eloop.readers[i].event);
171 	if (i != eloop.reader_count - 1) {
172 		os_memmove(&eloop.readers[i], &eloop.readers[i + 1],
173 			   (eloop.reader_count - i - 1) *
176 	eloop.reader_count--;
177 	eloop.reader_table_changed = 1;
194 	tmp = os_realloc_array(eloop.events, eloop.event_count + 1,
199 	tmp[eloop.event_count].eloop_data = eloop_data;
200 	tmp[eloop.event_count].user_data = user_data;
201 	tmp[eloop.event_count].handler = handler;
202 	tmp[eloop.event_count].event = h;
203 	eloop.event_count++;
204 	eloop.events = tmp;
215 	if (eloop.events == NULL || eloop.event_count == 0 ||
219 	for (i = 0; i < eloop.event_count; i++) {
220 		if (eloop.events[i].event == h)
223 	if (i == eloop.event_count)
226 	if (i != eloop.event_count - 1) {
227 		os_memmove(&eloop.events[i], &eloop.events[i + 1],
228 			   (eloop.event_count - i - 1) *
231 	eloop.event_count--;
268 	if (eloop.timeout == NULL) {
269 		eloop.timeout = timeout;
274 	tmp = eloop.timeout;
283 		timeout->next = eloop.timeout;
284 		eloop.timeout = timeout;
301 	timeout = eloop.timeout;
311 				eloop.timeout = next;
331 	tmp = eloop.timeout;
351 	eloop.signaled++;
352 	for (i = 0; i < eloop.signal_count; i++) {
353 		if (eloop.signals[i].sig == sig) {
354 			eloop.signals[i].signaled++;
366 	if (eloop.signaled == 0)
368 	eloop.signaled = 0;
370 	if (eloop.pending_terminate) {
371 		eloop.pending_terminate = 0;
374 	for (i = 0; i < eloop.signal_count; i++) {
375 		if (eloop.signals[i].signaled) {
376 			eloop.signals[i].signaled = 0;
377 			eloop.signals[i].handler(eloop.signals[i].sig,
378 						 eloop.signals[i].user_data);
382 	if (eloop.term_signal.signaled) {
383 		eloop.term_signal.signaled = 0;
384 		eloop.term_signal.handler(eloop.term_signal.sig,
385 					  eloop.term_signal.user_data);
395 	tmp = os_realloc_array(eloop.signals, eloop.signal_count + 1,
400 	tmp[eloop.signal_count].sig = sig;
401 	tmp[eloop.signal_count].user_data = user_data;
402 	tmp[eloop.signal_count].handler = handler;
403 	tmp[eloop.signal_count].signaled = 0;
404 	eloop.signal_count++;
405 	eloop.signals = tmp;
419 		eloop.signaled++;
420 		eloop.term_signal.signaled++;
421 		SetEvent(eloop.term_event);
442 	eloop.term_signal.handler = handler;
443 	eloop.term_signal.user_data = user_data;
463 	while (!eloop.terminate &&
464 	       (eloop.timeout || eloop.reader_count > 0 ||
465 		eloop.event_count > 0)) {
467 		if (eloop.timeout) {
469 			if (os_time_before(&now, &eloop.timeout->time))
470 				os_time_sub(&eloop.timeout->time, &now, &tv);
474 		for (i = 0; i < eloop.event_count; i++)
475 			eloop.handles[count++] = eloop.events[i].event;
477 		for (i = 0; i < eloop.reader_count; i++)
478 			eloop.handles[count++] = eloop.readers[i].event;
480 		if (eloop.term_event)
481 			eloop.handles[count++] = eloop.term_event;
483 		if (eloop.timeout)
495 		ret = WaitForMultipleObjects(count, eloop.handles, FALSE,
498 		ret = WaitForMultipleObjectsEx(count, eloop.handles, FALSE,
506 		if (eloop.timeout) {
510 			if (!os_time_before(&now, &eloop.timeout->time)) {
511 				tmp = eloop.timeout;
512 				eloop.timeout = eloop.timeout->next;
536 		       ret < WAIT_OBJECT_0 + eloop.event_count) {
537 			eloop.events[ret].handler(
538 				eloop.events[ret].eloop_data,
539 				eloop.events[ret].user_data);
540 			ret = WaitForMultipleObjects(eloop.event_count,
541 						     eloop.handles, FALSE, 0);
544 		eloop.reader_table_changed = 0;
545 		for (i = 0; i < eloop.reader_count; i++) {
547 			if (WSAEnumNetworkEvents(eloop.readers[i].sock,
548 						 eloop.readers[i].event,
551 				eloop.readers[i].handler(
552 					eloop.readers[i].sock,
553 					eloop.readers[i].eloop_data,
554 					eloop.readers[i].user_data);
555 				if (eloop.reader_table_changed)
565 	eloop.terminate = 1;
566 	SetEvent(eloop.term_event);
574 	timeout = eloop.timeout;
580 	os_free(eloop.readers);
581 	os_free(eloop.signals);
582 	if (eloop.term_event)
583 		CloseHandle(eloop.term_event);
584 	os_free(eloop.handles);
585 	eloop.handles = NULL;
586 	os_free(eloop.events);
587 	eloop.events = NULL;
593 	return eloop.terminate;