Lines Matching refs:u

94     engine->u.eventport.fd = -1;  in nxt_eventport_create()
95 engine->u.eventport.mchanges = mchanges; in nxt_eventport_create()
96 engine->u.eventport.mevents = mevents; in nxt_eventport_create()
103 engine->u.eventport.changes = changes; in nxt_eventport_create()
105 engine->u.eventport.events = nxt_malloc(sizeof(port_event_t) * mevents); in nxt_eventport_create()
106 if (engine->u.eventport.events == NULL) { in nxt_eventport_create()
110 engine->u.eventport.fd = port_create(); in nxt_eventport_create()
111 if (engine->u.eventport.fd == -1) { in nxt_eventport_create()
116 nxt_debug(&engine->task, "port_create(): %d", engine->u.eventport.fd); in nxt_eventport_create()
119 engine->u.eventport.signal_handler = engine->signals->handler; in nxt_eventport_create()
137 port = engine->u.eventport.fd; in nxt_eventport_free()
146 nxt_free(engine->u.eventport.events); in nxt_eventport_free()
148 nxt_memzero(&engine->u.eventport, sizeof(nxt_eventport_engine_t)); in nxt_eventport_free()
234 engine->u.eventport.fd, ev->fd, events, ev); in nxt_eventport_enable_event()
236 if (engine->u.eventport.nchanges >= engine->u.eventport.mchanges) { in nxt_eventport_enable_event()
242 change = &engine->u.eventport.changes[engine->u.eventport.nchanges++]; in nxt_eventport_enable_event()
282 engine->u.eventport.fd, ev->fd); in nxt_eventport_disable_event()
284 if (engine->u.eventport.nchanges >= engine->u.eventport.mchanges) { in nxt_eventport_disable_event()
290 change = &engine->u.eventport.changes[engine->u.eventport.nchanges++]; in nxt_eventport_disable_event()
304 port = engine->u.eventport.fd; in nxt_eventport_commit_changes()
307 port, engine->u.eventport.nchanges); in nxt_eventport_commit_changes()
310 change = engine->u.eventport.changes; in nxt_eventport_commit_changes()
311 end = change + engine->u.eventport.nchanges; in nxt_eventport_commit_changes()
356 engine->u.eventport.nchanges = 0; in nxt_eventport_commit_changes()
429 engine->u.eventport.post_handler = handler; in nxt_eventport_enable_post()
440 port = engine->u.eventport.fd; in nxt_eventport_signal()
462 if (engine->u.eventport.nchanges != 0) { in nxt_eventport_poll()
479 engine->u.eventport.fd, timeout); in nxt_eventport_poll()
489 event = &engine->u.eventport.events[0]; in nxt_eventport_poll()
496 n = port_getn(engine->u.eventport.fd, engine->u.eventport.events, in nxt_eventport_poll()
497 engine->u.eventport.mevents, &nevents, tp); in nxt_eventport_poll()
511 engine->u.eventport.fd, err, nevents); in nxt_eventport_poll()
519 engine->u.eventport.fd, err); in nxt_eventport_poll()
528 engine->u.eventport.fd, nevents); in nxt_eventport_poll()
531 event = &engine->u.eventport.events[i]; in nxt_eventport_poll()
544 engine->u.eventport.fd, ev->fd, events); in nxt_eventport_poll()
596 handler = (signo == 0) ? engine->u.eventport.post_handler in nxt_eventport_poll()
597 : engine->u.eventport.signal_handler; in nxt_eventport_poll()
608 engine->u.eventport.fd, event->portev_events, in nxt_eventport_poll()