/unit/src/python/ |
H A D | nxt_python_asgi.h | 40 nxt_py_asgi_enum_header_cb cb, void *data); 42 PyObject *nxt_py_asgi_calc_size(void *data, int i, PyObject *n, PyObject *v); 43 PyObject *nxt_py_asgi_add_field(void *data, int i, PyObject *n, PyObject *v);
|
H A D | nxt_python_asgi_http.c | 136 ctx_data = req->ctx->data; in nxt_py_asgi_http_receive() 408 ctx_data = http->req->ctx->data; in nxt_py_asgi_http_response_body() 537 http = req->data; in nxt_py_asgi_http_data_handler() 642 http = req->data; in nxt_py_asgi_http_close_handler()
|
H A D | nxt_python_asgi_lifespan.c | 328 ctx_data = ctx->data; in nxt_py_asgi_lifespan_shutdown()
|
H A D | nxt_python_asgi_websocket.c | 164 ctx_data = ws->req->ctx->data; in nxt_py_asgi_websocket_receive() 497 ws = frame->req->data; in nxt_py_asgi_websocket_handler() 682 ws = frame->req->data; in nxt_py_asgi_websocket_suspend_frame() 792 data = NULL; in nxt_py_asgi_websocket_pop_msg() 799 if (nxt_slow_path(data == NULL)) { in nxt_py_asgi_websocket_pop_msg() 827 data = PyLong_FromLong(code); in nxt_py_asgi_websocket_pop_msg() 828 if (nxt_slow_path(data == NULL)) { in nxt_py_asgi_websocket_pop_msg() 902 Py_DECREF(data); in nxt_py_asgi_websocket_pop_msg() 910 Py_DECREF(data); in nxt_py_asgi_websocket_pop_msg() 916 Py_DECREF(data); in nxt_py_asgi_websocket_pop_msg() [all …]
|
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/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/test/ |
H A D | nxt_cq_test.c | 306 link->work.data = wi; in worker_create()
|
H A D | nxt_http_parse_test.c | 43 nxt_http_parse_test_data_t *data, 46 nxt_http_parse_test_data_t data; member 55 nxt_http_parse_test_data_t *data, 58 nxt_http_parse_test_data_t *data, nxt_str_t *request, nxt_log_t *log); 62 uintptr_t data); 576 && test->handler(&rp, &test->data, &test->request, thr->log) in nxt_http_parse_test() 717 nxt_http_parse_test_data_t *data, nxt_str_t *request, nxt_log_t *log) in nxt_http_parse_test_request_line() argument 721 nxt_http_parse_test_request_line_t *test = &data->request_line; in nxt_http_parse_test_request_line() 803 if (rc != data->fields.result) { in nxt_http_parse_test_fields() 807 request, rc, data->fields.result); in nxt_http_parse_test_fields() [all …]
|
H A D | nxt_lvlhsh_test.c | 12 nxt_lvlhsh_test_key_test(nxt_lvlhsh_query_t *lhq, void *data) in nxt_lvlhsh_test_key_test() argument 14 if (*(uintptr_t *) lhq->key.start == (uintptr_t) data) { in nxt_lvlhsh_test_key_test()
|
H A D | nxt_rbtree1.h | 20 u_char data; member
|
H A D | nxt_unit_websocket_chat.c | 53 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/src/wasm-wasi-component/src/ |
H A D | lib.rs | 102 data: *mut bindings::nxt_process_data_t, in start() 111 let conf = (*data).app; in start() 243 let data = StoreState { in handle() 267 let mut store = Store::new(&self.engine, data); in handle() 424 Some(data) => { in send_response_body() 425 info.response_write(&data); in send_response_body() 518 fn response_write(&mut self, data: &[u8]) { in response_write() 522 data.as_ptr().cast(), in response_write() 523 data.len(), in response_write()
|
/unit/src/wasm/ |
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()
|
H A D | nxt_wasm.h | 81 uint8_t data[]; member
|
/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/test/java/mirror/ |
H A D | app.java | 26 String data = buffer.toString(); in doPost() local 28 String dataLength = Integer.toString(data.length()); in doPost() 34 out.print(data); in doPost()
|
/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/python/targets/ |
H A D | wsgi.py | 12 data = f"{env.get('SCRIPT_NAME', 'No Script Name')} {env['PATH_INFO']}" 14 return [data.encode('utf-8')]
|
/unit/test/python/upload/ |
H A D | wsgi.py | 22 data = filename.encode() + form['file'].file.read() 26 [('Content-Type', 'text/plain'), ('Content-Length', str(len(data)))], 29 return data
|
/unit/test/ |
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'
|
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_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_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)
|