Lines Matching defs:wes
90 we_set_event (struct we_set *wes, int i, event_t event, unsigned int rwflags, void *arg)
92 ASSERT (i >= 0 && i < wes->capacity);
97 wes->events[i] = event->read;
102 wes->events[i] = event->write;
107 wes->esr[i].rwflags = rwflags;
108 wes->esr[i].arg = arg;
112 we_append_event (struct we_set *wes, event_t event, unsigned int rwflags, void *arg)
116 if (wes->n_events < wes->capacity)
118 we_set_event (wes, wes->n_events, event, EVENT_WRITE, arg);
119 ++wes->n_events;
126 if (wes->n_events < wes->capacity)
128 we_set_event (wes, wes->n_events, event, EVENT_READ, arg);
129 ++wes->n_events;
138 we_del_event (struct we_set *wes, event_t event)
141 const int len = wes->n_events;
145 const HANDLE h = wes->events[i];
147 --wes->n_events;
152 wes->events[j] = wes->events[i];
153 wes->esr[j] = wes->esr[i];
161 we_del_index (struct we_set *wes, int index)
164 ASSERT (index >= 0 && index < wes->n_events);
165 for (i = index; i < wes->n_events - 1; ++i)
167 wes->events[i] = wes->events[i+1];
168 wes->esr[i] = wes->esr[i+1];
170 --wes->n_events;
174 we_get_rw_indices (struct we_set *wes, event_t event, int *ri, int *wi)
178 for (i = 0; i < wes->n_events; ++i)
180 const HANDLE h = wes->events[i];
197 struct we_set *wes = (struct we_set *) es;
198 free (wes->events);
199 free (wes->esr);
200 free (wes);
206 struct we_set *wes = (struct we_set *) es;
207 ASSERT (wes->fast);
208 wes->n_events = 0;
214 struct we_set *wes = (struct we_set *) es;
215 ASSERT (!wes->fast);
216 we_del_event (wes, event);
222 struct we_set *wes = (struct we_set *) es;
225 wes->n_events,
230 if (wes->fast)
232 if (!we_append_event (wes, event, rwflags, arg))
241 we_get_rw_indices (wes, event, &ri, &wi);
260 we_del_index (wes, one);
263 we_del_event (wes, event);
273 if (!we_append_event (wes, event, EVENT_READ, arg))
277 we_set_event (wes, one, event, EVENT_READ, arg);
280 we_del_index (wes, wi);
290 if (!we_append_event (wes, event, EVENT_WRITE, arg))
294 we_set_event (wes, one, event, EVENT_WRITE, arg);
297 we_del_index (wes, ri);
307 if (!we_append_event (wes, event, EVENT_READ|EVENT_WRITE, arg))
314 if (!we_append_event (wes, event, EVENT_READ, arg))
319 if (!we_append_event (wes, event, EVENT_WRITE, arg))
344 struct we_set *wes = (struct we_set *) es;
348 dmsg (D_EVENT_WAIT, "WE_WAIT enter n=%d to=%d", wes->n_events, timeout);
353 for (i = 0; i < wes->n_events; ++i)
356 wes->events[i],
357 wes->esr[i].rwflags,
358 (ptr_type)wes->esr[i].arg);
366 (DWORD) wes->n_events,
367 wes->events,
376 if (status >= WSA_WAIT_EVENT_0 && status < WSA_WAIT_EVENT_0 + (DWORD) wes->n_events)
380 for (i = 0; i < wes->n_events; ++i)
384 if (WaitForSingleObject (wes->events[i], 0) == WAIT_OBJECT_0)
386 *out = wes->esr[i];
408 (DWORD) wes->n_events,
409 wes->events,
414 if (outlen >= 1 && status >= WSA_WAIT_EVENT_0 && status < WSA_WAIT_EVENT_0 + (DWORD) wes->n_events)
416 *out = wes->esr[status - WSA_WAIT_EVENT_0];
431 struct we_set *wes;
435 ALLOC_OBJ_CLEAR (wes, struct we_set);
438 wes->func.free = we_free;
439 wes->func.reset = we_reset;
440 wes->func.del = we_del;
441 wes->func.ctl = we_ctl;
442 wes->func.wait = we_wait;
445 wes->fast = true;
446 wes->n_events = 0;
450 wes->capacity = min_int (*maxevents * 2, WSA_MAXIMUM_WAIT_EVENTS);
454 ALLOC_ARRAY_CLEAR (wes->events, HANDLE, wes->capacity);
457 ALLOC_ARRAY_CLEAR (wes->esr, struct event_set_return, wes->capacity);
460 *maxevents, wes->capacity);
462 return (struct event_set *) wes;