/unit/src/ |
H A D | nxt_murmur_hash.h | 11 NXT_EXPORT uint32_t nxt_murmur_hash2(const void *data, size_t len); 12 NXT_EXPORT uint32_t nxt_murmur_hash2_uint32(const void *data);
|
H A D | nxt_openssl.c | 83 void *data); 98 void *data); 102 void *data); 965 nxt_openssl_bundle_hash_test(nxt_lvlhsh_query_t *lhq, void *data) argument 969 item = data; 1209 nxt_openssl_conn_handshake(task, c, c->socket.data); 1216 task, c, c->socket.data); 1327 nxt_work_queue_add(wq, handler, task, c, data); 1760 const char *data, *delimiter; local 1768 data = ERR_reason_error_string(err); [all …]
|
H A D | nxt_php_sapi.c | 84 static nxt_int_t nxt_php_start(nxt_task_t *task, nxt_process_data_t *data); 455 nxt_php_start(nxt_task_t *task, nxt_process_data_t *data) in nxt_php_start() argument 467 conf = data->app; in nxt_php_start()
|
H A D | nxt_poll_engine.c | 63 static nxt_int_t nxt_poll_fd_hash_test(nxt_lvlhsh_query_t *lhq, void *data); 369 ev->task, ev, ev->data); in nxt_poll_commit_changes() 426 lhq.data = engine; in nxt_poll_set_add() 471 lhq.data = engine; in nxt_poll_set_delete() 571 ev->error_handler, ev->task, ev, ev->data); in nxt_poll() 614 ev->task, ev, ev->data); in nxt_poll() 626 ev->task, ev, ev->data); in nxt_poll() 644 lhq.data = engine; in nxt_poll_fd_hash_get() 658 nxt_poll_fd_hash_test(nxt_lvlhsh_query_t *lhq, void *data) in nxt_poll_fd_hash_test() argument 663 phe = data; in nxt_poll_fd_hash_test() [all …]
|
H A D | nxt_pollset_engine.c | 472 ev->task, ev, ev->data); in nxt_pollset_change_error() 611 ev->task, ev, ev->data); in nxt_pollset_poll() 620 ev->task, ev, ev->data); in nxt_pollset_poll() 635 ev->task, ev, ev->data); in nxt_pollset_poll()
|
H A D | nxt_port.c | 23 nxt_port_mp_cleanup(nxt_task_t *task, void *obj, void *data) in nxt_port_mp_cleanup() argument 29 mp = data; in nxt_port_mp_cleanup() 166 port->data = (nxt_port_handler_t *) (handlers); in nxt_port_enable() 183 handlers = msg->port->data; in nxt_port_handler() 555 nxt_port_post_handler(nxt_task_t *task, void *obj, void *data) in nxt_port_post_handler() argument 567 handler(task, port, data); in nxt_port_post_handler() 575 nxt_port_post_handler_t handler, void *data) in nxt_port_post() argument 580 handler(task, port, data); in nxt_port_post() 596 pw->work.data = data; in nxt_port_post() 608 nxt_port_release_handler(nxt_task_t *task, nxt_port_t *port, void *data) in nxt_port_release_handler() argument
|
H A D | nxt_port.h | 56 nxt_port_handler_t data; member 114 _NXT_PORT_MSG_DATA = nxt_port_handler_idx(data), 221 void *data; member 261 nxt_port_handler_t *data; member 320 void *data); 368 nxt_port_post_handler_t handler, void *data);
|
H A D | nxt_port_hash.c | 18 nxt_port_hash_test(nxt_lvlhsh_query_t *lhq, void *data) in nxt_port_hash_test() argument 23 port = data; in nxt_port_hash_test()
|
H A D | nxt_port_memory.c | 21 void *data); 118 nxt_port_mmap_buf_completion(nxt_task_t *task, void *obj, void *data) in nxt_port_mmap_buf_completion() argument 128 if (nxt_buf_ts_handle(task, obj, data)) { in nxt_port_mmap_buf_completion() 134 nxt_assert(data == b->parent); in nxt_port_mmap_buf_completion() 136 mmap_handler = data; in nxt_port_mmap_buf_completion() 189 mp = b->data; in nxt_port_mmap_buf_completion() 872 nxt_port_broadcast_shm_ack(nxt_task_t *task, nxt_port_t *port, void *data) in nxt_port_broadcast_shm_ack() argument 876 process = data; in nxt_port_broadcast_shm_ack()
|
H A D | nxt_port_queue.h | 21 uint8_t data[NXT_PORT_QUEUE_MSG_SIZE]; member 65 nxt_memcpy(qi->data, p, size); in nxt_port_queue_send() 92 nxt_memcpy(p, qi->data, qi->size); in nxt_port_queue_recv()
|
H A D | nxt_port_rpc.c | 24 void *data; member 57 nxt_rpc_reg_test(nxt_lvlhsh_query_t *lhq, void *data) in nxt_rpc_reg_test() argument 94 nxt_pid_t peer, void *data) in nxt_port_rpc_register_handler() argument 112 nxt_assert(reg->data == ex); in nxt_port_rpc_register_handler() 114 reg->data = data; in nxt_port_rpc_register_handler() 145 reg->data = reg + 1; in nxt_port_rpc_register_handler_ex() 170 return reg->data; in nxt_port_rpc_register_handler_ex() 181 nxt_assert(reg->data == ex); in nxt_port_rpc_ex_stream() 198 nxt_assert(reg->data == ex); in nxt_port_rpc_ex_set_peer() 344 reg->error_handler(task, msg, reg->data); in nxt_port_rpc_handler() [all …]
|
H A D | nxt_port_rpc.h | 12 nxt_port_recv_msg_t *msg, void *data); 18 nxt_pid_t peer, void *data);
|
H A D | nxt_port_socket.c | 23 static void nxt_port_write_handler(nxt_task_t *task, void *obj, void *data); 33 void *data); 367 nxt_port_write_handler(nxt_task_t *task, void *obj, void *data) in nxt_port_write_handler() argument 390 if (data) { in nxt_port_write_handler() 391 msg = data; in nxt_port_write_handler() 512 if (data != NULL) { in nxt_port_write_handler() 731 nxt_port_read_handler(nxt_task_t *task, void *obj, void *data) in nxt_port_read_handler() argument 1034 nxt_port_lvlhsh_frag_test(nxt_lvlhsh_query_t *lhq, void *data) in nxt_port_lvlhsh_frag_test() argument 1039 fmsg = data; in nxt_port_lvlhsh_frag_test() 1336 nxt_port_error_handler(nxt_task_t *task, void *obj, void *data) in nxt_port_error_handler() argument [all …]
|
H A D | nxt_process.c | 52 void *data); 54 void *data); 60 void *data); 62 nxt_port_recv_msg_t *msg, void *data); 740 ret = init->start(task, &process->data); in nxt_process_do_start() 812 nxt_process_whoami_ok(nxt_task_t *task, nxt_port_recv_msg_t *msg, void *data) in nxt_process_whoami_ok() argument 820 process = data; in nxt_process_whoami_ok() 913 process = data; in nxt_process_created_ok() 931 ret = init->start(task, &process->data); in nxt_process_created_ok() 948 void *data) in nxt_process_created_error() argument [all …]
|
H A D | nxt_process.h | 126 nxt_process_data_t data; member 139 nxt_process_data_t *data);
|
H A D | nxt_queue.c | 54 nxt_int_t (*cmp)(const void *data, const nxt_queue_link_t *, in nxt_queue_sort() argument 55 const nxt_queue_link_t *), const void *data) in nxt_queue_sort() 75 if (cmp(data, prev, link) <= 0) { in nxt_queue_sort()
|
H A D | nxt_queue.h | 200 const nxt_queue_link_t *), const void *data);
|
H A D | nxt_router.c | 204 void *data); 206 void *data); 208 void *data); 210 void *data); 212 void *data); 214 void *data); 216 void *data); 235 void *data); 394 void *data) in nxt_router_start_app_process_handler() argument 406 app = data; in nxt_router_start_app_process_handler() [all …]
|
H A D | nxt_router.h | 253 void nxt_router_conf_apply(nxt_task_t *task, void *obj, void *data);
|
H A D | nxt_router_access_log.c | 30 void *data); 32 void *data); 38 void *data); 209 ctx = data; in nxt_router_access_log_write_ready() 276 void *data) in nxt_router_access_log_ready() argument 281 tmcf = data; in nxt_router_access_log_ready() 294 void *data) in nxt_router_access_log_error() argument 298 tmcf = data; in nxt_router_access_log_error() 431 mp = b->data; in nxt_router_access_log_reopen_completion() 439 void *data) in nxt_router_access_log_reopen_ready() argument [all …]
|
H A D | nxt_runtime.c | 22 static void nxt_runtime_start(nxt_task_t *task, void *obj, void *data); 26 static void nxt_runtime_exit(nxt_task_t *task, void *obj, void *data); 41 void *data); 340 nxt_runtime_start(nxt_task_t *task, void *obj, void *data) in nxt_runtime_start() argument 543 nxt_runtime_exit(nxt_task_t *task, void *obj, void *data) in nxt_runtime_exit() argument 551 engine = data; in nxt_runtime_exit() 730 nxt_runtime_thread_pool_exit(nxt_task_t *task, void *obj, void *data) in nxt_runtime_thread_pool_exit() argument 739 if (data != NULL) { in nxt_runtime_thread_pool_exit() 740 handle = (nxt_thread_handle_t) (uintptr_t) data; in nxt_runtime_thread_pool_exit() 1550 nxt_runtime_lvlhsh_pid_test(nxt_lvlhsh_query_t *lhq, void *data) in nxt_runtime_lvlhsh_pid_test() argument [all …]
|
H A D | nxt_runtime.h | 23 void *data; member 143 void nxt_stream_connection_init(nxt_task_t *task, void *obj, void *data);
|
H A D | nxt_script.c | 34 static void nxt_script_buf_completion(nxt_task_t *task, void *obj, void *data); 49 nxt_script_new(nxt_task_t *task, nxt_str_t *name, u_char *data, size_t size, in nxt_script_new() argument 76 start = data; in nxt_script_new() 95 nxt_memcpy(script->text.start, data, size); in nxt_script_new() 138 nxt_script_info_hash_test(nxt_lvlhsh_query_t *lhq, void *data) in nxt_script_info_hash_test() argument 142 info = data; in nxt_script_info_hash_test() 526 nxt_script_buf_completion(nxt_task_t *task, void *obj, void *data) in nxt_script_buf_completion() argument 532 mp = b->data; in nxt_script_buf_completion()
|
H A D | nxt_script.h | 13 nxt_script_t *nxt_script_new(nxt_task_t *task, nxt_str_t *name, u_char *data,
|
H A D | nxt_select_engine.c | 21 static void nxt_select_error_handler(nxt_task_t *task, void *obj, void *data); 138 ev->task, ev, ev->data); in nxt_select_enable_read() 165 ev->task, ev, ev->data); in nxt_select_enable_write() 182 nxt_select_error_handler(nxt_task_t *task, void *obj, void *data) in nxt_select_error_handler() argument 191 ev->error_handler(task, ev, data); in nxt_select_error_handler() 347 ev->task, ev, ev->data); in nxt_select_poll() 364 ev->task, ev, ev->data); in nxt_select_poll()
|