/unit/ |
H A D | README.md | 103 # curl -X PUT --data-binary @config.json --unix-socket \
|
H A D | CHANGES | 789 *) Bugfix: Promises on request data in Node.js were not triggered. 904 *) Bugfix: requests with body data might be handled incorrectly in PHP
|
/unit/src/ |
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);
|
H A D | nxt_http_variables.c | 20 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 D | nxt_controller.c | 69 void *data); 71 void *data); 73 void *data); 76 void *data); 78 void *data); 103 void *data); 112 void *data); 300 rt = data; in nxt_controller_cert_cleanup() 538 void *data) in nxt_controller_conf_init_handler() argument 783 r = data; in nxt_controller_conn_read() [all …]
|
H A D | nxt_unit.c | 446 shared_port.data = NULL; in nxt_unit_init() 612 lib->unit.data = init->data; in nxt_unit_create() 671 void *data) in nxt_unit_ctx_init() argument 675 ctx_impl->ctx.data = data; in nxt_unit_ctx_init() 933 read_port->data = NULL; in nxt_unit_read_env() 1228 new_port.data = NULL; in nxt_unit_process_new_port() 1531 port->data = NULL; in nxt_unit_request_check_response_port() 4417 process = data; in nxt_unit_lvlhsh_pid_test() 5327 new_port.data = NULL; in nxt_unit_create_port() 5454 old_port->data = port->data; in nxt_unit_add_port() [all …]
|
H A D | nxt_main_process.c | 42 void *data); 44 void *data); 46 void *data); 48 void *data); 50 void *data); 571 process->data.app = app_conf; in nxt_main_start_process_handler() 824 (int) (uintptr_t) obj, data); in nxt_main_process_sigterm_handler() 838 (int) (uintptr_t) obj, data); in nxt_main_process_sigquit_handler() 960 (int) (uintptr_t) obj, data); in nxt_main_process_sigchld_handler() 1077 (int) (uintptr_t) obj, data); in nxt_main_process_signal_handler() [all …]
|
H A D | nxt_signal_handlers.c | 14 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()
|
/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/unit/ |
H A D | http.py | 184 data = b'' 203 data += part 208 return data 312 data = "&".join( 315 return data, 'application/x-www-form-urlencoded' 336 data = value['data'].read() 339 data = value
|
/unit/test/ |
H A D | test_tls.py | 679 data = '0123456789' * 9000 686 'data': io.StringIO(data),
|
H A D | test_settings.py | 276 data = sock.recv(16).decode() 280 data += client.recvall(sock).decode() 284 return data 300 data = req(addr, data_len) 301 assert re.search(r'200 OK', data), 'send timeout status' 302 assert len(data) < data_len, 'send timeout data ' 306 data = req(addr, data_len) 307 assert re.search(r'200 OK', data), 'send timeout status 2' 308 assert len(data) > data_len, 'send timeout data 2'
|
H A D | test_proxy_chunked.py | 45 data = b'' 53 data += part 58 return data 65 data = recvall(connection).decode() 67 m = re.search('\x0d\x0a\x0d\x0a(.*)', data, re.M | re.S)
|
H A D | test_proxy.py | 67 data = b'' 70 data += part 73 return data 83 data = recvall(connection).decode() 87 m = re.search(r'X-Len: (\d+)', data)
|
/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/docs/ |
H A D | unit-openapi.yaml | 4909 uri: "~^/data/www/.*\\.php(/.*)?$" 4912 share: "/www/data$uri" 5155 # Configuration sections as data types; hugely reliant on each other 6158 description: "Maximum number of seconds to read data from the body of 6198 description: "Maximum number of seconds to transmit data as a
|
/unit/tools/ |
H A D | unitc | 273 …printf "%s" "$(< $EDIT_FILENAME.js)" | $RPC_CMD curl -fX PUT --data-binary @- $UNIT_CTRL$URI 2> /t… 278 …$CONVERT_TO_JSON < $EDIT_FILENAME.yaml | $RPC_CMD curl -X PUT --data-binary @- $UNIT_CTRL$URI 2> /… 282 …cat $EDIT_FILENAME.json | $RPC_CMD curl -X PUT --data-binary @- $UNIT_CTRL$URI 2> /tmp/${0##*/}.$$… 298 …echo $OLD_ARRAY | jq ". |= [$NEW_ELEMENT] + ." | $RPC_CMD curl -X PUT --data-binary @- $UNIT_CTRL$… 308 …cat ${CONF_FILES[@]} | $RPC_CMD curl -X $METHOD --data-binary @- $UNIT_CTRL$URI 2> /tmp/${0##*/}.$…
|
H A D | README.md | 30 * Configuration data is read from stdin. 36 | filename … | Read configuration data consequently from the specified files instead of stdin. 39 | `INSERT` | A _virtual_ HTTP method that prepends data when the URI specifies an existing array. T… 40 | `-f` \| `--format YAML` | Convert configuration data to/from YAML format. The [yq](https://github…
|
/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()
|
H A D | nxt_wasm.c | 85 nxt_unit_response_write(req, (const char *)resp->data, resp->size); in nxt_wasm_do_send_response() 199 nxt_wasm_start(nxt_task_t *task, nxt_process_data_t *data) in nxt_wasm_start() argument 206 conf = data->app; in nxt_wasm_start()
|
/unit/src/java/ |
H A D | nxt_jni_Response.c | 319 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 …]
|