Home
last modified time | relevance | path

Searched refs:data (Results 26 – 50 of 208) sorted by last modified time

123456789

/unit/src/
H A Dnxt_router.h253 void nxt_router_conf_apply(nxt_task_t *task, void *obj, void *data);
H A Dnxt_http_request.c12 static void nxt_http_request_start(nxt_task_t *task, void *obj, void *data);
25 void *data);
216 uintptr_t data) in nxt_http_request_content_length() argument
308 nxt_http_request_start(nxt_task_t *task, void *obj, void *data) in nxt_http_request_start() argument
544 nxt_http_request_ready(nxt_task_t *task, void *obj, void *data) in nxt_http_request_ready() argument
632 nxt_work_handler_t body_handler, void *data) in nxt_http_request_header_send() argument
761 r = data; in nxt_http_request_mem_buf_completion()
787 nxt_http_request_done(nxt_task_t *task, void *obj, void *data) in nxt_http_request_done() argument
791 r = data; in nxt_http_request_done()
806 proto.any = data; in nxt_http_request_error_handler()
[all …]
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_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_unit.h47 void *data; /* User defined data. */ member
58 void *data; /* User context-specific data. */ member
84 void *data; member
112 void *data; member
165 void *data; /* Opaque pointer to user-defined data. */ member
193 void *data; member
292 nxt_unit_request_info_t *nxt_unit_get_request_info_from_data(void *data);
/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 …]
/unit/test/unit/
H A Dhttp.py182 data = b''
201 data += part
206 return data
310 data = "&".join(
313 return data, 'application/x-www-form-urlencoded'
334 data = value['data'].read()
337 data = value
/unit/test/unit/applications/
H A Dwebsockets.py66 def apply_mask(self, data, mask): argument
74 data = b''
84 data += sock.recv(bytes_len - 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/test/
H A Dtest_tls.py678 data = '0123456789' * 9000
685 'data': io.StringIO(data),
H A Dtest_settings.py277 data = sock.recv(16).decode()
281 data += client.recvall(sock).decode()
285 return data
301 data = req(addr, data_len)
302 assert re.search(r'200 OK', data), 'send timeout status'
303 assert len(data) < data_len, 'send timeout data '
307 data = req(addr, data_len)
308 assert re.search(r'200 OK', data), 'send timeout status 2'
309 assert len(data) > data_len, 'send timeout data 2'
H A Dtest_proxy_chunked.py46 data = b''
54 data += part
59 return data
66 data = recvall(connection).decode()
68 m = re.search('\x0d\x0a\x0d\x0a(.*)', data, re.M | re.S)
H A Dtest_proxy.py68 data = b''
71 data += part
74 return data
84 data = recvall(connection).decode()
88 m = re.search(r'X-Len: (\d+)', data)
H A Dtest_node_websockets.py46 data = frame['data']
48 data = frame['data'].decode('utf-8')
52 assert data == payload, 'payload'
160 data = frame['data'].decode('utf-8')
163 data += frame['data'].decode('utf-8')
165 assert message == data, 'large'
H A Dtest_java_websockets.py46 data = frame['data']
48 data = frame['data'].decode('utf-8')
52 assert data == payload, 'payload'
H A Dtest_asgi_websockets.py49 data = frame['data']
51 data = frame['data'].decode('utf-8')
55 assert data == payload, 'payload'
212 data = frame['data'].decode('utf-8')
215 data += frame['data'].decode('utf-8')
217 assert message == data, 'large'
/unit/
H A DREADME.md103 # curl -X PUT --data-binary @config.json --unix-socket \
/unit/src/ruby/
H A Dnxt_ruby.c30 nxt_process_data_t *data);
275 conf = data->app; in nxt_ruby_start()
366 ruby_unit_init.data = c; in nxt_ruby_start()
643 req = data; in nxt_ruby_request_handler_gvl()
645 rctx = req->ctx->data; in nxt_ruby_request_handler_gvl()
676 rctx = req->ctx->data; in nxt_ruby_rack_app_run()
1116 file = read_info->data; in nxt_ruby_rack_file_read()
1179 ri.read_info.data = &ruby_file; in nxt_ruby_rack_result_body_file_write()
1199 ri = data; in nxt_ruby_response_write_cb()
1243 wi = data; in nxt_ruby_response_write()
[all …]
/unit/src/python/
H A Dnxt_python_wsgi.c55 static void nxt_python_wsgi_ctx_data_free(void *data);
197 obj = nxt_python_create_environ(init->data); in nxt_python_wsgi_init()
267 nxt_python_wsgi_ctx_data_free(void *data) in nxt_python_wsgi_ctx_data_free() argument
271 pctx = data; in nxt_python_wsgi_ctx_data_free()
286 pctx = ctx->data; in nxt_python_wsgi_run()
317 pctx = req->ctx->data; in nxt_python_request_handler()
/unit/test/node/promise_end/
H A Dapp.js11 req.on('data', (data) => {
/unit/test/node/promise_handler/
H A Dapp.js12 req.on('data', (data) => {
13 fs.appendFile(data.toString(), '', function() {});
/unit/test/go/ns_inspect/
H A Dapp.go83 data, _ := ioutil.ReadFile("/proc/self/mountinfo")
84 out.Mounts = string(data)
87 data, err := json.Marshal(out)
95 w.Write(data)
/unit/src/wasm/
H A Dnxt_wasm.h81 uint8_t data[]; member
H A Dnxt_rt_wasmtime.c55 fprintf(stderr, "%.*s\n", (int)error_message.size, error_message.data); in nxt_wasmtime_err_msg()
369 if (fread(wasm.data, file_size, 1, fp) != 1) { in nxt_wasmtime_init()
376 error = wasmtime_module_new(rt_ctx->engine, (uint8_t *)wasm.data, wasm.size, in nxt_wasmtime_init()

123456789