Home
last modified time | relevance | path

Searched refs:data (Results 1 – 25 of 201) sorted by relevance

123456789

/unit/src/java/
H A Dnxt_jni_OutputStream.c89 data = req->data; in nxt_java_OutputStream_writeByte()
110 data = req->data; in nxt_java_OutputStream_flush_buf()
130 if (data->buf != NULL) { in nxt_java_OutputStream_flush_buf()
136 data->buf = NULL; in nxt_java_OutputStream_flush_buf()
154 data = req->data; in nxt_java_OutputStream_req_buf()
155 buf = data->buf; in nxt_java_OutputStream_req_buf()
158 size = data->buf_size == 0 ? nxt_unit_buf_min() : data->buf_size; in nxt_java_OutputStream_req_buf()
167 data->buf = buf; in nxt_java_OutputStream_req_buf()
186 data = req->data; in nxt_java_OutputStream_write()
224 data = req->data; in nxt_java_OutputStream_flush()
[all …]
H A Dnxt_jni_Response.c319 data = req->data; in nxt_java_get_response_info()
599 data = req->data; in nxt_java_Response_getRequest()
927 data = req->data; in nxt_java_Response_reset()
929 if (data->buf != NULL && data->buf->free > data->buf->start) { in nxt_java_Response_reset()
930 data->buf->free = data->buf->start; in nxt_java_Response_reset()
952 data = req->data; in nxt_java_Response_resetBuffer()
954 if (data->buf != NULL && data->buf->free > data->buf->start) { in nxt_java_Response_resetBuffer()
968 data = req->data; in nxt_java_Response_setBufferSize()
974 if (data->buf != NULL && data->buf->free > data->buf->start) { in nxt_java_Response_setBufferSize()
987 && (uint32_t) (data->buf->end - data->buf->start) < data->buf_size) in nxt_java_Response_setBufferSize()
[all …]
/unit/src/
H A Dnxt_signal_handlers.c14 static void nxt_signal_handler(nxt_task_t *task, void *obj, void *data);
15 static void nxt_signal_sigterm_handler(nxt_task_t *task, void *obj, void *data);
16 static void nxt_signal_sigquit_handler(nxt_task_t *task, void *obj, void *data);
32 nxt_signal_handler(nxt_task_t *task, void *obj, void *data) in nxt_signal_handler() argument
35 (int) (uintptr_t) obj, data); in nxt_signal_handler()
47 nxt_signal_sigterm_handler(nxt_task_t *task, void *obj, void *data) in nxt_signal_sigterm_handler() argument
50 (int) (uintptr_t) obj, data); in nxt_signal_sigterm_handler()
59 nxt_signal_sigquit_handler(nxt_task_t *task, void *obj, void *data) in nxt_signal_sigquit_handler() argument
62 (int) (uintptr_t) obj, data); in nxt_signal_sigquit_handler()
H A Dnxt_conn_proxy.c11 void *data);
13 void *data);
17 void *data);
19 void *data);
25 void *data);
27 void *data);
34 void *data);
36 void *data);
85 peer->socket.data = client->socket.data; in nxt_conn_proxy_create()
151 p = data; in nxt_conn_proxy_client_buffer_alloc()
[all …]
H A Dnxt_stream_source.c11 void *data);
13 void *data);
15 void *data);
19 void *data);
21 void *data);
98 stream = data; in nxt_stream_source_connected()
175 stream = data; in nxt_stream_source_read_ready()
249 stream = data; in nxt_stream_source_read_done()
349 parent = data; in nxt_stream_source_buf_completion()
400 stream = data; in nxt_stream_source_refused()
[all …]
H A Dnxt_thread.c10 static void *nxt_thread_trampoline(void *data);
11 static void nxt_thread_time_cleanup(void *data);
16 static void nxt_thread_key_dtor(void *data);
70 nxt_thread_key_dtor(void *data) in nxt_thread_key_dtor() argument
74 nxt_free(data); in nxt_thread_key_dtor()
102 nxt_thread_trampoline(void *data) in nxt_thread_trampoline() argument
108 link = data; in nxt_thread_trampoline()
117 data = link->work.data; in nxt_thread_trampoline()
126 start(data); in nxt_thread_trampoline()
170 nxt_thread_time_cleanup(void *data) in nxt_thread_time_cleanup() argument
[all …]
H A Dnxt_job.c12 void *data);
60 nxt_job_destroy(nxt_task_t *task, void *data) in nxt_job_destroy() argument
64 job = data; in nxt_job_destroy()
91 mpcl->data = job;
128 handler(job->task, job, job->data); in nxt_job_start()
135 nxt_job_thread_trampoline(nxt_task_t *task, void *obj, void *data) in nxt_job_thread_trampoline() argument
141 handler = (nxt_work_handler_t) data; in nxt_job_thread_trampoline()
149 handler(job->task, job, job->data); in nxt_job_thread_trampoline()
176 handler, job->task, job, job->data); in nxt_job_return()
187 handler = (nxt_work_handler_t) data; in nxt_job_thread_return_handler()
[all …]
H A Dnxt_conn_close.c10 static void nxt_conn_shutdown_handler(nxt_task_t *task, void *obj, void *data);
11 static void nxt_conn_close_handler(nxt_task_t *task, void *obj, void *data);
13 void *data);
15 void *data);
75 nxt_conn_shutdown_handler(nxt_task_t *task, void *obj, void *data) in nxt_conn_shutdown_handler() argument
81 engine = data; in nxt_conn_shutdown_handler()
95 nxt_conn_close_handler(nxt_task_t *task, void *obj, void *data) in nxt_conn_close_handler() argument
102 engine = data; in nxt_conn_close_handler()
129 task, c, c->socket.data); in nxt_conn_close_handler()
166 task, c, c->socket.data); in nxt_conn_close_timer_handler()
[all …]
H A Dnxt_java.c35 nxt_process_data_t *data);
216 app_conf = data->app; in nxt_java_start()
484 env = req->ctx->data; in nxt_java_request_handler()
485 data = req->data; in nxt_java_request_handler()
517 data->jreq = jreq; in nxt_java_request_handler()
518 data->jresp = jresp; in nxt_java_request_handler()
519 data->buf = NULL; in nxt_java_request_handler()
541 data->buf = NULL; in nxt_java_request_handler()
566 data = ws->req->data; in nxt_java_websocket_handler()
599 data = req->data; in nxt_java_close_handler()
[all …]
H A Dnxt_websocket.c55 nxt_websocket_frame_header_size(const void *data) in nxt_websocket_frame_header_size() argument
61 h = data; in nxt_websocket_frame_header_size()
81 nxt_websocket_frame_payload_len(const void *data) in nxt_websocket_frame_payload_len() argument
86 h = data; in nxt_websocket_frame_payload_len()
100 nxt_websocket_frame_init(void *data, uint64_t payload_len) in nxt_websocket_frame_init() argument
105 h = data; in nxt_websocket_frame_init()
106 p = data; in nxt_websocket_frame_init()
H A Dnxt_mem_pool_cleanup.c10 static void nxt_mem_pool_file_cleanup_handler(nxt_task_t *task, void *data);
22 mpcl->data = file; in nxt_mem_pool_file_cleanup()
30 nxt_mem_pool_file_cleanup_handler(nxt_task_t *task, void *data) in nxt_mem_pool_file_cleanup_handler() argument
34 file = data; in nxt_mem_pool_file_cleanup_handler()
H A Dnxt_router_access_log.c29 void *data);
31 void *data);
37 void *data);
181 ctx = data; in nxt_router_access_log_write_ready()
248 void *data) in nxt_router_access_log_ready() argument
253 tmcf = data; in nxt_router_access_log_ready()
266 void *data) in nxt_router_access_log_error() argument
270 tmcf = data; in nxt_router_access_log_error()
403 mp = b->data; in nxt_router_access_log_reopen_completion()
411 void *data) in nxt_router_access_log_reopen_ready() argument
[all …]
H A Dnxt_buf.c42 b->data = mp; in nxt_buf_mem_alloc()
71 b->data = mp; in nxt_buf_mem_ts_alloc()
89 ts->work.data = b->parent; in nxt_buf_mem_ts_alloc()
107 b->data = mp; in nxt_buf_file_alloc()
130 b->data = mp; in nxt_buf_mmap_alloc()
150 b->data = mp; in nxt_buf_sync_alloc()
207 nxt_assert(data == b->parent); in nxt_buf_completion()
212 mp = b->data; in nxt_buf_completion()
259 ts->work.data = data; in nxt_buf_ts_handle()
284 nxt_assert(data == b->parent); in nxt_buf_ts_completion()
[all …]
H A Dnxt_djb_hash.c11 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 Dnxt_upstream_source.c11 void *data);
33 lhq.key.data = (u_char *) unv->name; in nxt_upstream_header_hash_add()
51 nxt_upstream_header_hash_test(nxt_lvlhsh_query_t *lhq, void *data) in nxt_upstream_header_hash_test() argument
55 unv = data; in nxt_upstream_header_hash_test()
58 && nxt_memcasecmp(lhq->key.data, unv->name, unv->len) == 0) in nxt_upstream_header_hash_test()
H A Dnxt_http_proxy.c31 void *data);
203 nxt_http_proxy_header_send(nxt_task_t *task, void *obj, void *data) in nxt_http_proxy_header_send() argument
209 peer = data; in nxt_http_proxy_header_send()
225 nxt_http_proxy_header_sent(nxt_task_t *task, void *obj, void *data) in nxt_http_proxy_header_sent() argument
231 peer = data; in nxt_http_proxy_header_sent()
254 peer = data; in nxt_http_proxy_header_read()
293 nxt_http_proxy_send_body(nxt_task_t *task, void *obj, void *data) in nxt_http_proxy_send_body() argument
300 peer = data; in nxt_http_proxy_send_body()
347 r = data; in nxt_http_proxy_buf_mem_completion()
376 nxt_http_proxy_error(nxt_task_t *task, void *obj, void *data) in nxt_http_proxy_error() argument
[all …]
H A Dnxt_cache.c101 node = data; in nxt_cache_lvlhsh_test()
142 lhq.key.data = q->key_data; in nxt_cache_query()
426 lhq.key.data = node->key_data; in nxt_cache_update()
464 u_char *p, *data; in nxt_cache_release() local
489 data = nxt_malloc(size); in nxt_cache_release()
491 if (data == NULL) { in nxt_cache_release()
497 p = data; in nxt_cache_release()
501 if (p != data) { in nxt_cache_release()
502 nxt_memcpy(data, p, size); in nxt_cache_release()
595 cache->free(cache->data, node); in nxt_cache_node_free()
[all …]
H A Dnxt_stream_module.c14 void *data);
18 nxt_stream_connection_init(nxt_task_t *task, void *obj, void *data) in nxt_stream_connection_init() argument
33 up->data = c; in nxt_stream_connection_init()
63 c = up->data; in nxt_stream_connection_peer()
76 p->client->socket.data = p; in nxt_stream_connection_peer()
77 p->peer->socket.data = p; in nxt_stream_connection_peer()
122 nxt_stream_connection_close(nxt_task_t *task, void *obj, void *data) in nxt_stream_connection_close() argument
H A Dnxt_work_queue.c161 nxt_task_t *task, void *obj, void *data) in nxt_work_queue_add() argument
177 work->data = data; in nxt_work_queue_add()
198 void **data) in nxt_work_queue_pop() argument
217 *data = work->data; in nxt_work_queue_pop()
218 nxt_prefetch(*data); in nxt_work_queue_pop()
251 void **obj, void **data) in nxt_locked_work_queue_pop() argument
268 *data = work->data; in nxt_locked_work_queue_pop()
269 nxt_prefetch(*data); in nxt_locked_work_queue_pop()
307 work->obj, work->data); in nxt_locked_work_queue_move()
H A Dnxt_websocket.h15 NXT_EXPORT size_t nxt_websocket_frame_header_size(const void *data);
16 NXT_EXPORT uint64_t nxt_websocket_frame_payload_len(const void *data);
17 NXT_EXPORT void *nxt_websocket_frame_init(void *data, uint64_t payload_len);
H A Dnxt_h1proto.c29 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()
555 h1p = data; in nxt_h1p_conn_request_header_parse()
[all …]
/unit/src/test/
H A Dnxt_unit_websocket_chat.c53 ws_chat_request_data_t *data; in ws_chat_request_handler() local
74 data = req->data; in ws_chat_request_handler()
77 data->id = ws_chat_next_id++; in ws_chat_request_handler()
144 ws_chat_request_data_t *data; in ws_chat_broadcast() local
151 req = nxt_unit_get_request_info_from_data(data); in ws_chat_broadcast()
165 ws_chat_request_data_t *data; in ws_chat_websocket_handler() local
171 data = ws->req->data; in ws_chat_websocket_handler()
190 ws_chat_request_data_t *data; in ws_chat_close_handler() local
192 data = req->data; in ws_chat_close_handler()
194 data->id); in ws_chat_close_handler()
[all …]
/unit/test/unit/applications/
H A Dwebsockets.py66 def apply_mask(self, data, mask): argument
74 data = b''
84 data += sock.recv(bytes - len(data))
89 return data
114 data = b''
120 data = self.apply_mask(data, mask_bits)
136 frame['data'] = data
146 data, argument
156 if isinstance(data, str):
157 data = data.encode('utf-8')
[all …]
/unit/src/nodejs/unit-http/
H A Dunit.cpp76 timer.data = this; in process_port_msg()
124 port_data_t *data; in timer_callback() local
126 data = get(handle); in timer_callback()
129 if (data->stopped) { in timer_callback()
140 port_data_t *data; in delete_data() local
142 data = get(handle); in delete_data()
145 delete data; in delete_data()
511 port->data = data; in add_port()
514 data->poll.data = data; in add_port()
527 data = (port_data_t *) port->data; in remove_port()
[all …]
H A Dwebsocket_connection.js518 if (Buffer.isBuffer(data)) {
519 this.sendBytes(data, cb);
522 this.sendUTF(data, cb);
530 data = bufferFromString(data.toString(), 'utf8');
535 frame.binaryPayload = data;
542 if (!Buffer.isBuffer(data)) {
548 frame.binaryPayload = data;
560 if (data) {
562 data = bufferFromString(data.toString(), 'utf8');
564 if (data.length > 125) {
[all …]

123456789