/unit/src/ |
H A D | nxt_conn_write.c | 46 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() 198 b = sb->buf; in nxt_conn_io_sendfile() 443 sb.buf = b; in nxt_event_conn_io_sendbuf() 446 sb.sync = 0; in nxt_event_conn_io_sendbuf() [all …]
|
H A D | nxt_hpux_sendfile.c | 44 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 D | nxt_aix_send_file.c | 28 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 D | nxt_macosx_sendfile.c | 41 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 D | nxt_freebsd_sendfile.c | 44 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 D | nxt_sendbuf.c | 25 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 D | nxt_linux_sendfile.c | 56 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 D | nxt_event_conn_job_sendfile.c | 45 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 D | nxt_sendbuf.h | 110 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 D | nxt_port_socket.c | 379 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 D | nxt_port_memory.c | 712 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 D | nxt_conn.h | 67 nxt_sendbuf_t *sb); 254 ssize_t nxt_conn_io_sendbuf(nxt_task_t *task, nxt_sendbuf_t *sb); 255 ssize_t nxt_conn_io_writev(nxt_task_t *task, nxt_sendbuf_t *sb, 257 ssize_t nxt_conn_io_send(nxt_task_t *task, nxt_sendbuf_t *sb, void *buf,
|
H A D | nxt_port_memory.h | 35 nxt_port_send_msg_t *msg, nxt_sendbuf_coalesce_t *sb, void *mmsg_buf);
|
H A D | nxt_openssl.c | 95 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 …]
|
H A D | nxt_php_sapi.c | 1067 struct stat sb; in nxt_php_dynamic_request() local 1081 ret = stat(tpath, &sb); in nxt_php_dynamic_request() 1082 if (ret == 0 && S_ISDIR(sb.st_mode)) { in nxt_php_dynamic_request()
|
/unit/src/java/nginx/unit/websocket/server/ |
H A D | UpgradeUtil.java | 223 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/ |
H A D | SECURITY.txt | 11 Encryption: https://nginx.org/keys/sb.key
|
/unit/src/java/nginx/unit/websocket/ |
H A D | WsWebSocketContainer.java | 874 StringBuilder sb = new StringBuilder(); in readLine() local 879 sb.append(c); in readLine() 885 return sb.toString(); in readLine()
|