Home
last modified time | relevance | path

Searched refs:buf_size (Results 1 – 13 of 13) sorted by relevance

/unit/src/test/
H A Dnxt_unit_websocket_chat.c50 int buf_size; in ws_chat_request_handler() local
83 buf_size = snprintf(buf, sizeof(buf), "Guest #%d has joined.", data->id); in ws_chat_request_handler()
85 ws_chat_broadcast(buf, buf_size); in ws_chat_request_handler()
163 int buf_size; in ws_chat_websocket_handler() local
173 buf_size = snprintf(buf, sizeof(buf), "Guest #%d: ", data->id); in ws_chat_websocket_handler()
175 buf_size += nxt_unit_websocket_read(ws, buf + buf_size, in ws_chat_websocket_handler()
179 ws_chat_broadcast(buf, buf_size); in ws_chat_websocket_handler()
188 int buf_size; in ws_chat_close_handler() local
193 buf_size = snprintf(buf, sizeof(buf), "Guest #%d has disconnected.", in ws_chat_close_handler()
199 ws_chat_broadcast(buf, buf_size); in ws_chat_close_handler()
H A Dnxt_unit_websocket_echo.c58 static size_t buf_size = 0; in ws_echo_websocket_handler() local
61 if (buf_size < ws->content_length) { in ws_echo_websocket_handler()
63 buf_size = ws->content_length; in ws_echo_websocket_handler()
/unit/go/
H A Dnxt_cgo_lib.c14 const void *buf, size_t buf_size, const void *oob, size_t oob_size);
16 void *buf, size_t buf_size, void *oob, size_t *oob_size);
52 const void *buf, size_t buf_size, const void *oob, size_t oob_size) in nxt_cgo_port_send() argument
55 (void *) buf, buf_size, (void *) oob, oob_size); in nxt_cgo_port_send()
61 void *buf, size_t buf_size, void *oob, size_t *oob_size) in nxt_cgo_port_recv() argument
64 buf, buf_size, oob, oob_size); in nxt_cgo_port_recv()
H A Dport.go143 func nxt_go_port_send(pid C.int, id C.int, buf unsafe.Pointer, buf_size C.int,
158 n, oobn, err := p.snd.WriteMsgUnix(GoBytes(buf, buf_size),
171 func nxt_go_port_recv(pid C.int, id C.int, buf unsafe.Pointer, buf_size C.int,
186 n, oobn, _, _, err := p.rcv.ReadMsgUnix(GoBytes(buf, buf_size),
/unit/src/java/
H A Dnxt_jni_OutputStream.c98 if ((uint32_t) (buf->free - buf->start) >= data->buf_size) { in nxt_java_OutputStream_writeByte()
158 size = data->buf_size == 0 ? nxt_unit_buf_min() : data->buf_size; in nxt_java_OutputStream_req_buf()
205 if ((uint32_t) (buf->free - buf->start) >= data->buf_size) { in nxt_java_OutputStream_write()
H A Dnxt_jni.h32 uint32_t buf_size; member
H A Dnxt_jni_Response.c970 if (data->buf_size == (uint32_t) size) { in nxt_java_Response_setBufferSize()
980 data->buf_size = size; in nxt_java_Response_setBufferSize()
982 if (data->buf_size > nxt_unit_buf_max()) { in nxt_java_Response_setBufferSize()
983 data->buf_size = nxt_unit_buf_max(); in nxt_java_Response_setBufferSize()
987 && (uint32_t) (data->buf->end - data->buf->start) < data->buf_size) in nxt_java_Response_setBufferSize()
1005 return data->buf_size; in nxt_java_Response_getBufferSize()
/unit/src/
H A Dnxt_unit.h153 const void *buf, size_t buf_size,
158 void *buf, size_t buf_size, void *oob, size_t *oob_size);
192 uint32_t buf_size; member
H A Dnxt_unit.c2016 uint32_t buf_size; in nxt_unit_response_init() local
2039 buf_size = sizeof(nxt_unit_response_t) in nxt_unit_response_init()
2118 buf_size = sizeof(nxt_unit_response_t) in nxt_unit_response_realloc()
2929 if (nxt_slow_path(buf_size == 0)) { in nxt_unit_response_write_nb()
2959 uint32_t buf_size; in nxt_unit_response_write_cb() local
3019 buf_size = nxt_min(read_info->buf_size, PORT_MMAP_DATA_SIZE); in nxt_unit_response_write_cb()
3022 buf_size, buf_size, in nxt_unit_response_write_cb()
3334 buf_size = 10 + payload_len; in nxt_unit_websocket_sendv()
3349 buf_size -= buf->end - buf->start; in nxt_unit_websocket_sendv()
5940 return buf_size; in nxt_unit_port_send()
[all …]
H A Dnxt_java.c516 data->buf_size = 32 * 1024; /* from Jetty */ in nxt_java_request_handler()
/unit/src/python/
H A Dnxt_python_asgi_websocket.c423 Py_ssize_t buf_size; in nxt_py_asgi_websocket_send_frame() local
470 buf_size = PyBytes_GET_SIZE(bytes); in nxt_py_asgi_websocket_send_frame()
474 buf = PyUnicode_AsUTF8AndSize(text, &buf_size); in nxt_py_asgi_websocket_send_frame()
478 rc = nxt_unit_websocket_send(ws->req, opcode, 1, buf, buf_size); in nxt_py_asgi_websocket_send_frame()
/unit/src/perl/
H A Dnxt_perl_psgi.c994 read_info.buf_size = 8192; in nxt_perl_psgi_result_body_fh()
/unit/src/ruby/
H A Dnxt_ruby.c1135 ri.read_info.buf_size = ruby_file.rest; in nxt_ruby_rack_result_body_file_write()