Home
last modified time | relevance | path

Searched refs:data (Results 1 – 25 of 204) 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()
600 data = req->data; in nxt_java_Response_getRequest()
928 data = req->data; in nxt_java_Response_reset()
930 if (data->buf != NULL && data->buf->free > data->buf->start) { in nxt_java_Response_reset()
931 data->buf->free = data->buf->start; in nxt_java_Response_reset()
953 data = req->data; in nxt_java_Response_resetBuffer()
955 if (data->buf != NULL && data->buf->free > data->buf->start) { in nxt_java_Response_resetBuffer()
969 data = req->data; in nxt_java_Response_setBufferSize()
975 if (data->buf != NULL && data->buf->free > data->buf->start) { in nxt_java_Response_setBufferSize()
988 && (uint32_t) (data->buf->end - data->buf->start) < data->buf_size) in nxt_java_Response_setBufferSize()
[all …]
H A Dnxt_jni_InputStream.c93 uint8_t *data; in nxt_java_InputStream_readLine() local
99 data = (*env)->GetPrimitiveArrayCritical(env, out, NULL); in nxt_java_InputStream_readLine()
104 res = nxt_unit_request_read(req, data + off, res); in nxt_java_InputStream_readLine()
107 nxt_unit_req_debug(req, "readLine '%.*s'", (int) res, (char *) data + off); in nxt_java_InputStream_readLine()
109 (*env)->ReleasePrimitiveArrayCritical(env, out, data, 0); in nxt_java_InputStream_readLine()
145 uint8_t *data; in nxt_java_InputStream_read() local
151 data = (*env)->GetPrimitiveArrayCritical(env, b, NULL); in nxt_java_InputStream_read()
153 res = nxt_unit_request_read(req, data + off, len); in nxt_java_InputStream_read()
155 nxt_unit_req_debug(req, "read '%.*s'", (int) res, (char *) data + off); in nxt_java_InputStream_read()
157 (*env)->ReleasePrimitiveArrayCritical(env, b, data, 0); in nxt_java_InputStream_read()
/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_http_variables.c20 void *data);
22 void *data);
48 void *data);
239 void *data) in nxt_http_var_request_time() argument
280 void *data) in nxt_http_var_request_uri() argument
320 void *data) in nxt_http_var_remote_addr() argument
392 void *data) in nxt_http_var_request_line() argument
406 void *data) in nxt_http_var_request_id() argument
619 vf = data; in nxt_http_var_arg()
658 vf = data; in nxt_http_var_header()
[all …]
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_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);
62 nxt_job_destroy(nxt_task_t *task, void *data) in nxt_job_destroy() argument
66 job = data; in nxt_job_destroy()
93 mpcl->data = job;
130 handler(job->task, job, job->data); in nxt_job_start()
137 nxt_job_thread_trampoline(nxt_task_t *task, void *obj, void *data) in nxt_job_thread_trampoline() argument
143 handler = (nxt_work_handler_t) data; in nxt_job_thread_trampoline()
151 handler(job->task, job, job->data); in nxt_job_thread_trampoline()
178 handler, job->task, job, job->data); in nxt_job_return()
189 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_fs_mount.c66 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 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_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_router_access_log.c29 void *data);
31 void *data);
37 void *data);
184 ctx = data; in nxt_router_access_log_write_ready()
251 void *data) in nxt_router_access_log_ready() argument
256 tmcf = data; in nxt_router_access_log_ready()
269 void *data) in nxt_router_access_log_error() argument
273 tmcf = data; in nxt_router_access_log_error()
406 mp = b->data; in nxt_router_access_log_reopen_completion()
414 void *data) in nxt_router_access_log_reopen_ready() argument
[all …]
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_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()
556 h1p = data; in nxt_h1p_conn_request_header_parse()
[all …]
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_conn_connect.c14 nxt_conn_sys_socket(nxt_task_t *task, void *obj, void *data) in nxt_conn_sys_socket() argument
30 handler, task, c, data); in nxt_conn_sys_socket()
35 nxt_conn_io_connect(nxt_task_t *task, void *obj, void *data) in nxt_conn_io_connect() argument
73 nxt_work_queue_add(c->write_work_queue, handler, task, c, data); in nxt_conn_io_connect()
122 nxt_conn_connect_test(nxt_task_t *task, void *obj, void *data) in nxt_conn_connect_test() argument
141 task, c, data); in nxt_conn_connect_test()
143 nxt_conn_connect_error(task, c, data); in nxt_conn_connect_test()
149 nxt_conn_connect_error(nxt_task_t *task, void *obj, void *data) in nxt_conn_connect_error() argument
183 nxt_work_queue_add(c->write_work_queue, handler, task, c, data); in nxt_conn_connect_error()
H A Dnxt_kqueue_engine.c89 void *data);
91 void *data);
102 void *data);
104 void *data);
107 void *data);
109 void *data);
594 kev.data = 0; in nxt_kqueue_add_signal()
620 kev.data = 0; in nxt_kqueue_enable_post()
772 data = ev->data; in nxt_kqueue_poll()
803 data = ev->data; in nxt_kqueue_poll()
[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.py65 def apply_mask(self, data, mask): argument
73 data = b''
83 data += sock.recv(bytes - len(data))
88 return data
113 data = b''
119 data = self.apply_mask(data, mask_bits)
135 frame['data'] = data
145 data, argument
155 if isinstance(data, str):
156 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