Home
last modified time | relevance | path

Searched refs:data (Results 176 – 200 of 208) sorted by path

123456789

/unit/src/python/
H A Dnxt_python_asgi.h40 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 Dnxt_python_asgi_http.c136 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 Dnxt_python_asgi_lifespan.c328 ctx_data = ctx->data; in nxt_py_asgi_lifespan_shutdown()
H A Dnxt_python_asgi_websocket.c164 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 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/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/test/
H A Dnxt_cq_test.c306 link->work.data = wi; in worker_create()
H A Dnxt_http_parse_test.c43 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 Dnxt_lvlhsh_test.c12 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 Dnxt_rbtree1.h20 u_char data; member
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/src/wasm-wasi-component/src/
H A Dlib.rs102 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 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()
H A Dnxt_wasm.c85 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 Dnxt_wasm.h81 uint8_t data[]; member
/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/test/java/mirror/
H A Dapp.java26 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 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/python/targets/
H A Dwsgi.py12 data = f"{env.get('SCRIPT_NAME', 'No Script Name')} {env['PATH_INFO']}"
14 return [data.encode('utf-8')]
/unit/test/python/upload/
H A Dwsgi.py22 data = filename.encode() + form['file'].file.read()
26 [('Content-Type', 'text/plain'), ('Content-Length', str(len(data)))],
29 return data
/unit/test/
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'
H A Dtest_java_websockets.py46 data = frame['data']
48 data = frame['data'].decode('utf-8')
52 assert data == payload, 'payload'
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_proxy.py68 data = b''
71 data += part
74 return data
84 data = recvall(connection).decode()
88 m = re.search(r'X-Len: (\d+)', data)

123456789