/unit/src/ |
H A D | nxt_conn_read.c | 24 c->socket.task, c, c->socket.data); in nxt_conn_wait() 38 nxt_conn_io_read(nxt_task_t *task, void *obj, void *data) in nxt_conn_io_read() argument 89 state->ready_handler, task, c, data); in nxt_conn_io_read() 101 handler, task, c, data); in nxt_conn_io_read()
|
H A D | nxt_conn_write.c | 11 void *data); 17 nxt_conn_io_write(nxt_task_t *task, void *obj, void *data) in nxt_conn_io_write() argument 129 task, c, data); in nxt_conn_io_write() 142 task, c, data); in nxt_conn_io_write() 147 nxt_conn_write_timer_handler(nxt_task_t *task, void *obj, void *data) in nxt_conn_write_timer_handler() argument 159 c->io->write(task, c, c->socket.data); in nxt_conn_write_timer_handler()
|
H A D | nxt_controller.c | 69 void *data); 71 void *data); 73 void *data); 76 void *data); 78 void *data); 103 void *data); 112 void *data); 300 rt = data; in nxt_controller_cert_cleanup() 538 void *data) in nxt_controller_conf_init_handler() argument 783 r = data; in nxt_controller_conn_read() [all …]
|
H A D | nxt_cyassl.c | 25 static void nxt_cyassl_session_cleanup(void *data); 31 void *data); 209 mpcl->data = ssltls; in nxt_cyassl_conn_init() 217 nxt_cyassl_conn_handshake(thr, c, c->socket.data); in nxt_cyassl_conn_init() 228 nxt_cyassl_session_cleanup(void *data) in nxt_cyassl_session_cleanup() argument 232 ssltls = data; in nxt_cyassl_session_cleanup() 243 nxt_cyassl_io_recv(CYASSL *ssl, char *buf, int size, void *data) in nxt_cyassl_io_recv() argument 249 c = data; in nxt_cyassl_io_recv() 271 nxt_cyassl_io_send(CYASSL *ssl, char *buf, int size, void *data) in nxt_cyassl_io_send() argument 277 c = data; in nxt_cyassl_io_send() [all …]
|
H A D | nxt_devpoll_engine.c | 487 ev->task, ev, ev->data); in nxt_devpoll_change_error() 627 ev->task, ev, ev->data); in nxt_devpoll_poll() 636 ev->task, ev, ev->data); in nxt_devpoll_poll() 651 ev->task, ev, ev->data); in nxt_devpoll_poll()
|
H A D | nxt_djb_hash.c | 11 nxt_djb_hash(const void *data, size_t len) in nxt_djb_hash() argument 16 p = data; in nxt_djb_hash() 29 nxt_djb_hash_lowcase(const void *data, size_t len) in nxt_djb_hash_lowcase() argument 35 p = data; in nxt_djb_hash_lowcase()
|
H A D | nxt_djb_hash.h | 14 NXT_EXPORT uint32_t nxt_djb_hash(const void *data, size_t len); 15 NXT_EXPORT uint32_t nxt_djb_hash_lowcase(const void *data, size_t len);
|
H A D | nxt_epoll_engine.c | 86 void *data); 93 void *data); 95 void *data); 604 change->event.data.ptr = ev; in nxt_epoll_change() 622 ev = change->event.data.ptr; in nxt_epoll_commit_changes() 659 ev->error_handler(ev->task, ev, data); in nxt_epoll_error_handler() 730 handler = data; in nxt_epoll_signalfd_handler() 786 engine->u.epoll.eventfd.data = engine; in nxt_epoll_enable_post() 815 engine = data; in nxt_epoll_eventfd_handler() 917 ev = event->data.ptr; in nxt_epoll_poll() [all …]
|
H A D | nxt_event_conn_job_sendfile.c | 20 void *data); 22 void *data); 24 void *data); 40 nxt_event_conn_job_sendfile_start(nxt_task_t *task, void *obj, void *data) in nxt_event_conn_job_sendfile_start() argument 61 jbs->job.data = c; in nxt_event_conn_job_sendfile_start() 96 nxt_event_conn_job_sendfile_handler(nxt_task_t *task, void *obj, void *data) in nxt_event_conn_job_sendfile_handler() argument 105 c = data; in nxt_event_conn_job_sendfile_handler() 163 nxt_event_conn_job_sendfile_return(nxt_task_t *task, void *obj, void *data) in nxt_event_conn_job_sendfile_return() argument 172 c = data; in nxt_event_conn_job_sendfile_return() 223 task, c, c->socket.data); in nxt_event_conn_job_sendfile_return() [all …]
|
H A D | nxt_event_engine.c | 28 void *data); 30 void *data); 32 void *data); 34 void *data); 36 void *data); 38 nxt_task_t **task, void **obj, void **data); 467 void **obj, void **data) in nxt_event_engine_queue_pop() argument 511 void *obj, *data; in nxt_event_engine_start() local 542 handler(task, obj, data); in nxt_event_engine_start() 695 b->data = engine; in nxt_event_engine_buf_mem_alloc() [all …]
|
H A D | nxt_event_engine.h | 519 void *data);
|
H A D | nxt_eventport_engine.c | 40 void *data); 346 ev->task, ev, ev->data); in nxt_eventport_commit_changes() 363 nxt_eventport_error_handler(nxt_task_t *task, void *obj, void *data) in nxt_eventport_error_handler() argument 372 ev->error_handler(task, ev, data); in nxt_eventport_error_handler() 548 ev->task, ev, ev->data); in nxt_eventport_poll() 557 ev->task, ev, ev->data); in nxt_eventport_poll() 571 ev->task, ev, ev->data); in nxt_eventport_poll()
|
H A D | nxt_external.c | 12 static nxt_int_t nxt_external_start(nxt_task_t *task, nxt_process_data_t *data); 60 nxt_external_start(nxt_task_t *task, nxt_process_data_t *data) in nxt_external_start() argument 77 conf = data->app; in nxt_external_start()
|
H A D | nxt_fd_event.c | 10 static nxt_int_t nxt_fd_event_hash_test(nxt_lvlhsh_query_t *lhq, void *data); 26 nxt_fd_event_hash_test(nxt_lvlhsh_query_t *lhq, void *data) in nxt_fd_event_hash_test() argument
|
H A D | nxt_fd_event.h | 56 void *data; member
|
H A D | nxt_fiber.c | 12 static void nxt_fiber_switch_handler(nxt_task_t *task, void *obj, void *data); 14 static void nxt_fiber_timer_handler(nxt_task_t *task, void *obj, void *data); 41 nxt_fiber_create(nxt_fiber_start_t start, void *data, size_t stack) in nxt_fiber_create() argument 65 fib->data = data; in nxt_fiber_create() 88 fib->data = data; in nxt_fiber_create() 255 fib->start(fib->data); in nxt_fiber_trampoline() 316 fib->start(fib->data); in nxt_fiber_trampoline() 331 nxt_fiber_switch_handler(nxt_task_t *task, void *obj, void *data) in nxt_fiber_switch_handler() argument 413 nxt_fiber_timer_handler(nxt_task_t *task, void *obj, void *data) in nxt_fiber_timer_handler() argument 450 nxt_fiber_exit(nxt_task_t *task, nxt_fiber_t *next, void *data) in nxt_fiber_exit() argument
|
H A D | nxt_fiber.h | 12 typedef void (*nxt_fiber_start_t)(void *data); 25 void *data; member 49 nxt_int_t nxt_fiber_create(nxt_fiber_start_t start, void *data, size_t stack); 53 void nxt_fiber_exit(nxt_task_t *task, nxt_fiber_t *next, void *data);
|
H A D | nxt_file_event.h | 11 void *data; member
|
H A D | nxt_fs_mount.c | 66 mnt->data); in nxt_fs_mount() 70 mnt->src, mnt->dst, fsname, flags, mnt->data, nxt_errno); in nxt_fs_mount() 84 u_char *data, *p, *end; in nxt_fs_mount() local 153 data = NULL; in nxt_fs_mount() 155 if (mnt->data != NULL) { in nxt_fs_mount() 156 data = (u_char *) nxt_strdup(mnt->data); in nxt_fs_mount() 157 if (nxt_slow_path(data == NULL)) { in nxt_fs_mount() 161 end = data - 1; in nxt_fs_mount() 199 if (data != NULL) { in nxt_fs_mount() 200 free(data); in nxt_fs_mount()
|
H A D | nxt_fs_mount.h | 38 u_char *data; member
|
H A D | nxt_gnutls.c | 36 static void nxt_gnutls_session_cleanup(void *data); 42 static ssize_t nxt_gnutls_vec_push(gnutls_transport_ptr_t data, 52 void *data); 287 mpcl->data = ssltls; in nxt_gnutls_conn_init() 326 nxt_gnutls_conn_handshake(thr, c, c->socket.data); in nxt_gnutls_conn_init() 337 nxt_gnutls_session_cleanup(void *data) in nxt_gnutls_session_cleanup() argument 341 ssltls = data; in nxt_gnutls_session_cleanup() 358 c = data; in nxt_gnutls_pull() 379 c = data; in nxt_gnutls_push() 405 c = data; in nxt_gnutls_vec_push() [all …]
|
H A D | nxt_h1proto.c | 29 void *data); 46 void *data); 60 void *data); 62 void *data); 78 void *data); 80 void *data); 97 void *data); 221 lev = data; in nxt_http_conn_init() 477 h1p = data; in nxt_h1p_conn_request_init() 556 h1p = data; in nxt_h1p_conn_request_header_parse() [all …]
|
H A D | nxt_h1proto_websocket.c | 21 void *data); 32 void *data); 161 nxt_h1p_conn_ws_keepalive(nxt_task_t *task, void *obj, void *data) in nxt_h1p_conn_ws_keepalive() argument 228 h1p = data; in nxt_h1p_conn_ws_frame_header_read() 442 nxt_h1p_conn_ws_error(nxt_task_t *task, void *obj, void *data) in nxt_h1p_conn_ws_error() argument 447 h1p = data; in nxt_h1p_conn_ws_error() 496 nxt_h1p_conn_ws_timeout(nxt_task_t *task, void *obj, void *data) in nxt_h1p_conn_ws_timeout() argument 515 h1p = c->socket.data; in nxt_h1p_conn_ws_timeout() 551 h1p = data; in nxt_h1p_conn_ws_frame_payload_read() 637 r = data; in nxt_h1p_conn_ws_error_sent() [all …]
|
H A D | nxt_http.h | 269 nxt_work_handler_t body_handler, void *data); 324 void nxt_http_conn_init(nxt_task_t *task, void *obj, void *data); 330 nxt_work_handler_t body_handler, void *data); 338 void nxt_http_request_error_handler(nxt_task_t *task, void *obj, void *data); 339 void nxt_http_request_close_handler(nxt_task_t *task, void *obj, void *data); 342 uintptr_t data); 346 uintptr_t data); 415 uintptr_t data); 417 uintptr_t data); 419 uintptr_t data); [all …]
|
H A D | nxt_http_chunk_parse.c | 24 void *data); 249 nxt_http_chunk_buf_completion(nxt_task_t *task, void *obj, void *data) in nxt_http_chunk_buf_completion() argument 258 nxt_assert(data == b->parent); in nxt_http_chunk_buf_completion() 263 mp = b->data; in nxt_http_chunk_buf_completion()
|