Home
last modified time | relevance | path

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

12

/unit/
H A DCHANGES812 *) 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 Dunit-openapi.yaml3512 Unit's [response send timeout]
/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.c358 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 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.h270 void (*send)(nxt_task_t *task, nxt_http_request_t *r, nxt_buf_t *out); member
H A Dnxt_http_request.c730 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.c452 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 Dnxt_python_asgi_lifespan.c137 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 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/body_bytearray/
H A Dasgi.py1 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 Dasgi.py4 async def application(scope, receive, send): argument
32 await send(
48 await send(

12