Home
last modified time | relevance | path

Searched refs:sb (Results 1 – 16 of 16) sorted by relevance

/unit/src/
H A Dnxt_conn_write.c46 sb.error = 0; in nxt_conn_io_write()
47 sb.sent = 0; in nxt_conn_io_write()
48 sb.size = 0; in nxt_conn_io_write()
49 sb.buf = b; in nxt_conn_io_write()
54 sb.ready = 1; in nxt_conn_io_write()
55 sb.sync = 0; in nxt_conn_io_write()
78 sb.buf = b; in nxt_conn_io_write()
191 b = sb->buf; in nxt_conn_io_sendfile()
436 sb.buf = b; in nxt_event_conn_io_sendbuf()
439 sb.sync = 0; in nxt_event_conn_io_sendbuf()
[all …]
H A Dnxt_hpux_sendfile.c44 sb.buf = b; in nxt_hpux_event_conn_io_sendfile()
45 sb.iobuf = iov; in nxt_hpux_event_conn_io_sendfile()
46 sb.nmax = NXT_IOBUF_MAX; in nxt_hpux_event_conn_io_sendfile()
47 sb.sync = 0; in nxt_hpux_event_conn_io_sendfile()
48 sb.size = 0; in nxt_hpux_event_conn_io_sendfile()
49 sb.limit = limit; in nxt_hpux_event_conn_io_sendfile()
53 if (nhd == 0 && sb.sync) { in nxt_hpux_event_conn_io_sendfile()
57 if (nhd > 1 || sb.buf == NULL || !nxt_buf_is_file(sb.buf)) { in nxt_hpux_event_conn_io_sendfile()
61 fb = sb.buf; in nxt_hpux_event_conn_io_sendfile()
69 sb.iobuf = &iov[1]; in nxt_hpux_event_conn_io_sendfile()
[all …]
H A Dnxt_aix_send_file.c28 sb.buf = b; in nxt_aix_event_conn_io_send_file()
29 sb.iobuf = hd; in nxt_aix_event_conn_io_send_file()
30 sb.nmax = NXT_IOBUF_MAX; in nxt_aix_event_conn_io_send_file()
31 sb.sync = 0; in nxt_aix_event_conn_io_send_file()
32 sb.size = 0; in nxt_aix_event_conn_io_send_file()
33 sb.limit = limit; in nxt_aix_event_conn_io_send_file()
37 if (nhd == 0 && sb.sync) { in nxt_aix_event_conn_io_send_file()
41 if (nhd > 1 || sb.buf == NULL || !nxt_buf_is_file(sb.buf)) { in nxt_aix_event_conn_io_send_file()
45 fb = sb.buf; in nxt_aix_event_conn_io_send_file()
53 sb.iobuf = &tr; in nxt_aix_event_conn_io_send_file()
[all …]
H A Dnxt_macosx_sendfile.c41 sb.buf = b; in nxt_macosx_event_conn_io_sendfile()
42 sb.iobuf = hd; in nxt_macosx_event_conn_io_sendfile()
43 sb.nmax = NXT_IOBUF_MAX; in nxt_macosx_event_conn_io_sendfile()
44 sb.sync = 0; in nxt_macosx_event_conn_io_sendfile()
45 sb.size = 0; in nxt_macosx_event_conn_io_sendfile()
46 sb.limit = limit; in nxt_macosx_event_conn_io_sendfile()
50 if (nhd == 0 && sb.sync) { in nxt_macosx_event_conn_io_sendfile()
54 if (sb.buf == NULL || !nxt_buf_is_file(sb.buf)) { in nxt_macosx_event_conn_io_sendfile()
58 hd_size = sb.size; in nxt_macosx_event_conn_io_sendfile()
59 fb = sb.buf; in nxt_macosx_event_conn_io_sendfile()
[all …]
H A Dnxt_freebsd_sendfile.c44 nxt_sendbuf_coalesce_t sb; in nxt_freebsd_event_conn_io_sendfile() local
46 sb.buf = b; in nxt_freebsd_event_conn_io_sendfile()
47 sb.iobuf = hd; in nxt_freebsd_event_conn_io_sendfile()
48 sb.nmax = NXT_IOBUF_MAX; in nxt_freebsd_event_conn_io_sendfile()
49 sb.sync = 0; in nxt_freebsd_event_conn_io_sendfile()
50 sb.size = 0; in nxt_freebsd_event_conn_io_sendfile()
51 sb.limit = limit; in nxt_freebsd_event_conn_io_sendfile()
55 if (nhd == 0 && sb.sync) { in nxt_freebsd_event_conn_io_sendfile()
59 if (sb.buf == NULL || !nxt_buf_is_file(sb.buf)) { in nxt_freebsd_event_conn_io_sendfile()
63 fb = sb.buf; in nxt_freebsd_event_conn_io_sendfile()
[all …]
H A Dnxt_sendbuf.c25 total = sb->size; in nxt_sendbuf_mem_coalesce0()
29 for (b = sb->buf; b != NULL && total < sb->limit; b = b->next) { in nxt_sendbuf_mem_coalesce0()
81 sb->buf = b; in nxt_sendbuf_mem_coalesce0()
95 total = sb->size; in nxt_sendbuf_mem_coalesce()
99 for (b = sb->buf; b != NULL && total < sb->limit; b = b->next) { in nxt_sendbuf_mem_coalesce()
155 sb->buf = b; in nxt_sendbuf_mem_coalesce()
156 sb->size = total; in nxt_sendbuf_mem_coalesce()
157 sb->niov = n; in nxt_sendbuf_mem_coalesce()
171 b = sb->buf; in nxt_sendbuf_file_coalesce()
174 total = sb->size; in nxt_sendbuf_file_coalesce()
[all …]
H A Dnxt_linux_sendfile.c56 nxt_sendbuf_coalesce_t sb; in nxt_linux_event_conn_io_sendfile() local
58 sb.buf = b; in nxt_linux_event_conn_io_sendfile()
59 sb.iobuf = iov; in nxt_linux_event_conn_io_sendfile()
60 sb.nmax = NXT_IOBUF_MAX; in nxt_linux_event_conn_io_sendfile()
61 sb.sync = 0; in nxt_linux_event_conn_io_sendfile()
62 sb.size = 0; in nxt_linux_event_conn_io_sendfile()
63 sb.limit = limit; in nxt_linux_event_conn_io_sendfile()
67 if (niov == 0 && sb.sync) { in nxt_linux_event_conn_io_sendfile()
71 fb = (sb.buf != NULL && nxt_buf_is_file(sb.buf)) ? sb.buf : NULL; in nxt_linux_event_conn_io_sendfile()
197 msg.msg_iov = sb->iobuf; in nxt_linux_sendmsg()
[all …]
H A Dnxt_event_conn_job_sendfile.c45 nxt_sendbuf_coalesce_t sb; in nxt_event_conn_job_sendfile_start() local
68 sb.buf = c->write; in nxt_event_conn_job_sendfile_start()
69 sb.iobuf = &b; in nxt_event_conn_job_sendfile_start()
70 sb.nmax = 1; in nxt_event_conn_job_sendfile_start()
71 sb.sync = 0; in nxt_event_conn_job_sendfile_start()
72 sb.size = 0; in nxt_event_conn_job_sendfile_start()
73 sb.limit = jbs->limit; in nxt_event_conn_job_sendfile_start()
75 if (nxt_sendbuf_mem_coalesce(c->socket.task, &sb) != 0 || !sb.sync) { in nxt_event_conn_job_sendfile_start()
H A Dnxt_sendbuf.h110 nxt_uint_t nxt_sendbuf_mem_coalesce0(nxt_task_t *task, nxt_sendbuf_t *sb,
113 nxt_sendbuf_coalesce_t *sb);
114 size_t nxt_sendbuf_file_coalesce(nxt_sendbuf_coalesce_t *sb);
H A Dnxt_port_socket.c379 nxt_sendbuf_coalesce_t sb; in nxt_port_write_handler() local
407 sb.buf = msg->buf; in nxt_port_write_handler()
408 sb.iobuf = &iov[1]; in nxt_port_write_handler()
410 sb.sync = 0; in nxt_port_write_handler()
411 sb.last = 0; in nxt_port_write_handler()
412 sb.size = 0; in nxt_port_write_handler()
413 sb.limit = port->max_size; in nxt_port_write_handler()
415 sb.limit_reached = 0; in nxt_port_write_handler()
416 sb.nmax_reached = 0; in nxt_port_write_handler()
430 plain_size = sb.size; in nxt_port_write_handler()
[all …]
H A Dnxt_port_memory.c712 nxt_port_send_msg_t *msg, nxt_sendbuf_coalesce_t *sb, void *mmsg_buf) in nxt_port_mmap_write() argument
722 "via shared memory", sb->size, port->pid); in nxt_port_mmap_write()
724 bsize = sb->niov * sizeof(nxt_port_mmap_msg_t); in nxt_port_mmap_write()
729 for (i = 0; i < sb->niov; i++, mmap_msg++) { in nxt_port_mmap_write()
732 while (bmem && sb->iobuf[i].iov_base != bmem->mem.pos) { in nxt_port_mmap_write()
748 mmap_msg->size = sb->iobuf[i].iov_len; in nxt_port_mmap_write()
755 sb->iobuf[0].iov_base = mmsg_buf; in nxt_port_mmap_write()
756 sb->iobuf[0].iov_len = bsize; in nxt_port_mmap_write()
757 sb->niov = 1; in nxt_port_mmap_write()
758 sb->size = bsize; in nxt_port_mmap_write()
H A Dnxt_conn.h67 nxt_sendbuf_t *sb);
253 ssize_t nxt_conn_io_sendbuf(nxt_task_t *task, nxt_sendbuf_t *sb);
254 ssize_t nxt_conn_io_writev(nxt_task_t *task, nxt_sendbuf_t *sb,
256 ssize_t nxt_conn_io_send(nxt_task_t *task, nxt_sendbuf_t *sb, void *buf,
H A Dnxt_port_memory.h35 nxt_port_send_msg_t *msg, nxt_sendbuf_coalesce_t *sb, void *mmsg_buf);
H A Dnxt_openssl.c95 static ssize_t nxt_openssl_conn_io_send(nxt_task_t *task, nxt_sendbuf_t *sb,
1367 nxt_openssl_conn_io_sendbuf(nxt_task_t *task, nxt_sendbuf_t *sb) argument
1372 niov = nxt_sendbuf_mem_coalesce0(task, sb, &iov, 1);
1374 if (niov == 0 && sb->sync) {
1383 nxt_openssl_conn_io_send(nxt_task_t *task, nxt_sendbuf_t *sb, void *buf, argument
1392 tls = sb->tls;
1399 sb->socket, buf, size, ret, err);
1406 c->socket.write_ready = sb->ready;
1410 sb->ready = c->socket.write_ready;
1413 sb->error = c->socket.error;
[all …]
/unit/src/java/nginx/unit/websocket/server/
H A DUpgradeUtil.java223 private static void append(StringBuilder sb, Extension extension) { in append() argument
228 sb.append(extension.getName()); in append()
231 sb.append(';'); in append()
232 sb.append(p.getName()); in append()
234 sb.append('='); in append()
235 sb.append(p.getValue()); in append()
/unit/src/java/nginx/unit/websocket/
H A DWsWebSocketContainer.java874 StringBuilder sb = new StringBuilder(); in readLine() local
879 sb.append(c); in readLine()
885 return sb.toString(); in readLine()