Home
last modified time | relevance | path

Searched refs:send (Results 1 – 25 of 39) sorted by path

12

/unit/
H A DCHANGES623 *) 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/src/java/nginx/unit/websocket/
H A DLocalStrings.properties89 …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 Dwebsocket_connection.js516 WebSocketConnection.prototype.send = function(data, cb) { method in WebSocketConnection
/unit/src/
H A Dnxt_conn.c38 .send = nxt_event_conn_io_send,
H A Dnxt_conn.h83 ssize_t (*send)(nxt_conn_t *c, void *buf, member
H A Dnxt_conn_write.c351 n = send(sb->socket, buf, size, 0); in nxt_conn_io_send()
505 n = send(c->socket.fd, buf, size, 0); in nxt_event_conn_io_send()
H A Dnxt_cyassl.c280 n = thr->engine->event->io->send(c, (u_char *) buf, size); in nxt_cyassl_io_send()
H A Dnxt_epoll_engine.c117 .send = nxt_event_conn_io_send,
H A Dnxt_gnutls.c382 n = thr->engine->event->io->send(c, (u_char *) buf, size); in nxt_gnutls_push()
H A Dnxt_h1proto.c139 .send = nxt_h1p_request_send,
H A Dnxt_http.h262 void (*send)(nxt_task_t *task, nxt_http_request_t *r, nxt_buf_t *out); member
H A Dnxt_http_request.c709 nxt_http_proto[r->protocol].send(task, r, out); in nxt_http_request_send()
H A Dnxt_kqueue_engine.c133 .send = nxt_event_conn_io_send,
H A Dnxt_linux_sendfile.c148 n = send(c->socket.fd, buf, size, flags); in nxt_linux_send()
H A Dnxt_sendbuf.c258 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 Dnxt_python_asgi.c415 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 Dnxt_python_asgi_lifespan.c112 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/test/node/loader/es_modules_websocket/
H A Dapp.mjs22 connection.send(message.utf8Data);
24 connection.send(message.binaryData);
/unit/test/node/loader/es_modules_websocket_indirect/
H A Dmodule.mjs22 connection.send(message.utf8Data);
24 connection.send(message.binaryData);
/unit/test/node/websockets/mirror/
H A Dapp.js20 connection.send(message.utf8Data);
22 connection.send(message.binaryData);
/unit/test/node/websockets/mirror_fragmentation/
H A Dapp.js17 connection.send(message.utf8Data);
/unit/test/python/204_no_content/
H A Dasgi.py1 async def application(scope, receive, send): argument
4 await send(
/unit/test/python/delayed/
H A Dasgi.py4 async def application(scope, receive, send): argument
32 await send(
46 await send(
/unit/test/python/empty/
H A Dasgi.py1 async def application(scope, receive, send): argument
4 await send(
/unit/test/python/legacy/
H A Dasgi.py7 async def app_http(receive, send): argument
8 await send(

12