/unit/ |
H A D | CHANGES | 812 *) Bugfix: some Perl applications might have failed to send the response 851 application attempted to send header twice. 907 producing "last message send failed: Resource temporarily
|
/unit/docs/ |
H A D | unit-openapi.yaml | 3512 Unit's [response send timeout]
|
/unit/src/java/nginx/unit/websocket/ |
H A D | LocalStrings.properties | 89 …nd=Messages may not be sent concurrently even when using the asynchronous send messages. The clien… 95 wsRemoteEndpoint.sendInterrupt=The current thread was interrupted while waiting for a blocking send… 96 wsRemoteEndpoint.tooMuchData=Ping or pong may not send more than 125 bytes 114 wsSession.sendCloseFail=Failed to send close message for session [{0}] to remote endpoint
|
/unit/src/nodejs/unit-http/ |
H A D | websocket_connection.js | 516 WebSocketConnection.prototype.send = function(data, cb) { method in WebSocketConnection
|
/unit/src/ |
H A D | nxt_conn.c | 38 .send = nxt_event_conn_io_send,
|
H A D | nxt_conn.h | 83 ssize_t (*send)(nxt_conn_t *c, void *buf, member
|
H A D | nxt_conn_write.c | 358 n = send(sb->socket, buf, size, 0); in nxt_conn_io_send() 512 n = send(c->socket.fd, buf, size, 0); in nxt_event_conn_io_send()
|
H A D | nxt_cyassl.c | 280 n = thr->engine->event->io->send(c, (u_char *) buf, size); in nxt_cyassl_io_send()
|
H A D | nxt_epoll_engine.c | 117 .send = nxt_event_conn_io_send,
|
H A D | nxt_gnutls.c | 382 n = thr->engine->event->io->send(c, (u_char *) buf, size); in nxt_gnutls_push()
|
H A D | nxt_h1proto.c | 139 .send = nxt_h1p_request_send,
|
H A D | nxt_http.h | 270 void (*send)(nxt_task_t *task, nxt_http_request_t *r, nxt_buf_t *out); member
|
H A D | nxt_http_request.c | 730 nxt_http_proto[r->protocol].send(task, r, out); in nxt_http_request_send()
|
H A D | nxt_kqueue_engine.c | 133 .send = nxt_event_conn_io_send,
|
H A D | nxt_linux_sendfile.c | 148 n = send(c->socket.fd, buf, size, flags); in nxt_linux_send()
|
H A D | nxt_sendbuf.c | 258 n = c->io->send(c, bm->pos, nxt_min(size, limit)); in nxt_sendbuf_copy_coalesce() 284 return c->io->send(c, b->mem.pos, nxt_min(size, limit)); in nxt_sendbuf_copy_coalesce()
|
/unit/src/python/ |
H A D | nxt_python_asgi.c | 452 PyObject *scope, *res, *task, *receive, *send, *done, *asgi; in nxt_py_asgi_request_handler() local 480 send = PyObject_GetAttrString(asgi, "send"); in nxt_py_asgi_request_handler() 481 if (nxt_slow_path(send == NULL)) { in nxt_py_asgi_request_handler() 536 scope, receive, send, NULL); in nxt_py_asgi_request_handler() 563 res = PyObject_CallFunctionObjArgs(stage2, receive, send, NULL); in nxt_py_asgi_request_handler() 618 Py_DECREF(send); in nxt_py_asgi_request_handler()
|
H A D | nxt_python_asgi_lifespan.c | 137 PyObject *scope, *res, *py_task, *receive, *send, *done; in nxt_py_asgi_lifespan_target_startup() local 161 send = PyObject_GetAttrString((PyObject *) lifespan, "send"); in nxt_py_asgi_lifespan_target_startup() 218 scope, receive, send, NULL); in nxt_py_asgi_lifespan_target_startup() 248 res = PyObject_CallFunctionObjArgs(stage2, receive, send, NULL); in nxt_py_asgi_lifespan_target_startup() 311 Py_DECREF(send); in nxt_py_asgi_lifespan_target_startup()
|
/unit/test/node/loader/es_modules_websocket/ |
H A D | app.mjs | 22 connection.send(message.utf8Data); 24 connection.send(message.binaryData);
|
/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/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/204_no_content/ |
H A D | asgi.py | 1 async def application(scope, receive, send): argument 4 await send(
|
/unit/test/python/body_bytearray/ |
H A D | asgi.py | 1 async def application(scope, receive, send): argument 12 await send( 20 await send({'type': 'http.response.body', 'body': body})
|
/unit/test/python/delayed/ |
H A D | asgi.py | 4 async def application(scope, receive, send): argument 32 await send( 48 await send(
|