/unit/src/ |
H A D | nxt_router.h | 253 void nxt_router_conf_apply(nxt_task_t *task, void *obj, void *data);
|
H A D | nxt_http_request.c | 12 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 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_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_unit.h | 47 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 D | unit.cpp | 76 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 D | websocket_connection.js | 518 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 D | http.py | 182 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 D | websockets.py | 66 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 D | test_tls.py | 678 data = '0123456789' * 9000 685 'data': io.StringIO(data),
|
H A D | test_settings.py | 277 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 D | test_proxy_chunked.py | 46 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 D | test_proxy.py | 68 data = b'' 71 data += part 74 return data 84 data = recvall(connection).decode() 88 m = re.search(r'X-Len: (\d+)', data)
|
H A D | test_node_websockets.py | 46 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 D | test_java_websockets.py | 46 data = frame['data'] 48 data = frame['data'].decode('utf-8') 52 assert data == payload, 'payload'
|
H A D | test_asgi_websockets.py | 49 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 D | README.md | 103 # curl -X PUT --data-binary @config.json --unix-socket \
|
/unit/src/ruby/ |
H A D | nxt_ruby.c | 30 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 D | nxt_python_wsgi.c | 55 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 D | app.js | 11 req.on('data', (data) => {
|
/unit/test/node/promise_handler/ |
H A D | app.js | 12 req.on('data', (data) => { 13 fs.appendFile(data.toString(), '', function() {});
|
/unit/test/go/ns_inspect/ |
H A D | app.go | 83 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 D | nxt_wasm.h | 81 uint8_t data[]; member
|
H A D | nxt_rt_wasmtime.c | 55 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()
|