Home
last modified time | relevance | path

Searched refs:data (Results 126 – 150 of 208) sorted by path

123456789

/unit/src/
H A Dnxt_murmur_hash.h11 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 Dnxt_openssl.c83 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 Dnxt_php_sapi.c84 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 Dnxt_poll_engine.c63 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 Dnxt_pollset_engine.c472 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 Dnxt_port.c23 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 Dnxt_port.h56 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 Dnxt_port_hash.c18 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 Dnxt_port_memory.c21 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 Dnxt_port_queue.h21 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 Dnxt_port_rpc.c24 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 Dnxt_port_rpc.h12 nxt_port_recv_msg_t *msg, void *data);
18 nxt_pid_t peer, void *data);
H A Dnxt_port_socket.c23 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 Dnxt_process.c52 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 Dnxt_process.h126 nxt_process_data_t data; member
139 nxt_process_data_t *data);
H A Dnxt_queue.c54 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 Dnxt_queue.h200 const nxt_queue_link_t *), const void *data);
H A Dnxt_router.c204 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 Dnxt_router.h253 void nxt_router_conf_apply(nxt_task_t *task, void *obj, void *data);
H A Dnxt_router_access_log.c30 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 Dnxt_runtime.c22 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 Dnxt_runtime.h23 void *data; member
143 void nxt_stream_connection_init(nxt_task_t *task, void *obj, void *data);
H A Dnxt_script.c34 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 Dnxt_script.h13 nxt_script_t *nxt_script_new(nxt_task_t *task, nxt_str_t *name, u_char *data,
H A Dnxt_select_engine.c21 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()

123456789