| /unit/src/ |
| H A D | nxt_http_request.c | 709 nxt_http_proto[r->protocol].send(task, r, out); in nxt_http_request_send()
|
| H A D | nxt_http.h | 262 void (*send)(nxt_task_t *task, nxt_http_request_t *r, nxt_buf_t *out); member
|
| H A D | nxt_h1proto.c | 139 .send = nxt_h1p_request_send,
|
| H A D | nxt_conn.h | 83 ssize_t (*send)(nxt_conn_t *c, void *buf, member
|
| H A D | nxt_gnutls.c | 382 n = thr->engine->event->io->send(c, (u_char *) buf, size); in nxt_gnutls_push()
|
| /unit/src/python/ |
| H A D | nxt_python_asgi.c | 415 PyObject *scope, *res, *task, *receive, *send, *done, *asgi; in nxt_py_asgi_request_handler() local
442 send = PyObject_GetAttrString(asgi, "send"); in nxt_py_asgi_request_handler()
472 scope, receive, send, NULL); in nxt_py_asgi_request_handler()
499 res = PyObject_CallFunctionObjArgs(stage2, receive, send, NULL); in nxt_py_asgi_request_handler()
555 Py_DECREF(send); in nxt_py_asgi_request_handler()
|
| H A D | nxt_python_asgi_lifespan.c | 112 PyObject *scope, *res, *py_task, *receive, *send, *done; in nxt_py_asgi_lifespan_target_startup() local
136 send = PyObject_GetAttrString((PyObject *) lifespan, "send"); in nxt_py_asgi_lifespan_target_startup()
176 scope, receive, send, NULL); in nxt_py_asgi_lifespan_target_startup()
206 res = PyObject_CallFunctionObjArgs(stage2, receive, send, NULL); in nxt_py_asgi_lifespan_target_startup()
269 Py_DECREF(send); in nxt_py_asgi_lifespan_target_startup()
|
| /unit/ |
| H A D | CHANGES | 623 *) Bugfix: some Perl applications might have failed to send the response
662 application attempted to send header twice.
718 producing "last message send failed: Resource temporarily
|
| /unit/test/python/204_no_content/ |
| H A D | asgi.py | 1 async def application(scope, receive, send): argument
4 await send(
|
| /unit/test/python/threads/ |
| H A D | asgi.py | 5 async def application(scope, receive, send): argument
20 await send(
|
| /unit/test/python/threading/ |
| H A D | asgi.py | 29 async def application(scope, receive, send): argument
35 await send(
|
| /unit/test/node/loader/es_modules_websocket_indirect/ |
| H A D | module.mjs | 22 connection.send(message.utf8Data);
24 connection.send(message.binaryData);
|
| /unit/test/node/loader/es_modules_websocket/ |
| H A D | app.mjs | 22 connection.send(message.utf8Data);
24 connection.send(message.binaryData);
|
| /unit/test/python/lifespan/empty/ |
| H A D | asgi.py | 4 async def handler(prefix, scope, receive, send): argument
14 await send({'type': 'lifespan.startup.complete'})
17 await send({'type': 'lifespan.shutdown.complete'})
21 await send(
30 async def application(scope, receive, send): argument
31 return await handler('', scope, receive, send)
34 async def application2(scope, receive, send): argument
35 return await handler('app2_', scope, receive, send)
|
| /unit/test/python/targets/ |
| H A D | asgi.py | 1 async def application_201(scope, receive, send): argument
4 await send(
13 async def application_200(scope, receive, send): argument
16 await send(
31 async def legacy_app_http_200(receive, send): argument
32 await send(
41 def legacy_application_201(scope, receive=None, send=None): argument
47 async def legacy_app_http_201(receive, send): argument
48 await send(
|
| /unit/test/node/websockets/mirror/ |
| H A D | app.js | 20 connection.send(message.utf8Data);
22 connection.send(message.binaryData);
|
| /unit/test/node/websockets/mirror_fragmentation/ |
| H A D | app.js | 17 connection.send(message.utf8Data);
|
| /unit/test/python/websockets/mirror/ |
| H A D | asgi.py | 1 async def application(scope, receive, send): argument
6 await send({'type': 'websocket.accept'})
9 await send(
|
| /unit/test/python/websockets/subprotocol/ |
| H A D | asgi.py | 1 async def application(scope, receive, send): argument
9 await send(
20 await send(
|
| /unit/test/python/variables/ |
| H A D | asgi.py | 1 async def application(scope, receive, send): argument
20 await send(
39 await send({'type': 'http.response.body', 'body': body})
|
| /unit/test/python/query_string/ |
| H A D | asgi.py | 1 async def application(scope, receive, send): argument
4 await send(
|
| /unit/test/python/server_port/ |
| H A D | asgi.py | 1 async def application(scope, receive, send): argument
4 await send(
|
| /unit/test/python/legacy_force/ |
| H A D | asgi.py | 1 def application(scope, receive=None, send=None): argument
4 if receive == None and send == None:
8 return app_http(receive, send)
11 async def app_http(receive, send): argument
12 await send(
|
| /unit/test/python/mirror/ |
| H A D | asgi.py | 1 async def application(scope, receive, send): argument
11 await send(
19 await send({'type': 'http.response.body', 'body': body})
|
| /unit/test/python/legacy/ |
| H A D | asgi.py | 7 async def app_http(receive, send): argument
8 await send(
|