Lines Matching refs:event_data
223 accept_connection(struct kevent *event_data, struct runtime_env *env,
237 fd = accept(event_data->ident, NULL, NULL);
272 process_socket_event(struct kevent *event_data, struct runtime_env *env,
284 eof_res = event_data->flags & EV_EOF ? 1 : 0;
288 EV_SET(&eventlist[0], event_data->ident, EVFILT_TIMER, EV_DELETE,
304 qstate = (struct query_state *)event_data->udata;
315 (qstate->kevent_watermark <= (size_t)event_data->data)) ||
317 (qstate->io_buffer_watermark <= (size_t)event_data->data))) {
374 close(event_data->ident);
429 EV_SET(&eventlist[1], event_data->ident,
433 EV_SET(&eventlist[1], event_data->ident,
443 EV_SET(&eventlist[1], event_data->ident,
450 EV_SET(&eventlist[1], event_data->ident,
455 EV_SET(&eventlist[0], event_data->ident, EVFILT_TIMER,
467 process_timer_event(struct kevent *event_data, struct runtime_env *env,
473 qstate = (struct query_state *)event_data->udata;
475 close(event_data->ident);
503 struct kevent *event_data;
504 event_data = &eventlist[0];
506 if ((int)event_data->ident == env->sockfd) {
507 for (i = 0; i < event_data->data; ++i)
508 accept_connection(event_data, env, config);
519 switch (event_data->filter) {
522 process_socket_event(event_data,
526 process_timer_event(event_data,