/unit/src/ |
H A D | nxt_buf.h | 116 #define nxt_buf_is_mem(b) \ argument 120 #define nxt_buf_is_file(b) \ argument 123 #define nxt_buf_set_file(b) \ argument 126 #define nxt_buf_clear_file(b) \ argument 130 #define nxt_buf_is_mmap(b) \ argument 133 #define nxt_buf_set_mmap(b) \ argument 136 #define nxt_buf_clear_mmap(b) \ argument 140 #define nxt_buf_is_port_mmap(b) \ argument 143 #define nxt_buf_set_port_mmap(b) \ argument 248 nxt_buf_cpy(nxt_buf_t *b, const void *src, size_t length) in nxt_buf_cpy() [all …]
|
H A D | nxt_buf_pool.c | 13 nxt_buf_t *b; in nxt_buf_pool_mem_alloc() local 53 nxt_buf_t *b; in nxt_buf_pool_file_alloc() local 93 nxt_buf_t *b; in nxt_buf_pool_mmap_alloc() local 132 nxt_buf_pool_free(nxt_buf_pool_t *bp, nxt_buf_t *b) in nxt_buf_pool_free() 175 nxt_buf_t *b, *n; in nxt_buf_pool_destroy() local
|
H A D | nxt_buf.c | 33 nxt_buf_t *b; in nxt_buf_mem_alloc() local 59 nxt_buf_t *b; in nxt_buf_mem_ts_alloc() local 98 nxt_buf_t *b; in nxt_buf_file_alloc() local 125 nxt_buf_t *b; in nxt_buf_mmap_alloc() local 145 nxt_buf_t *b; in nxt_buf_sync_alloc() local 166 nxt_buf_t *b, **prev; in nxt_buf_chain_add() local 179 nxt_buf_chain_length(nxt_buf_t *b) in nxt_buf_chain_length() 201 nxt_buf_t *b, *next, *parent; in nxt_buf_completion() local 243 nxt_buf_t *b; in nxt_buf_ts_handle() local 274 nxt_buf_t *b, *next, *parent; in nxt_buf_ts_completion() local [all …]
|
H A D | nxt_sendbuf.c | 22 nxt_buf_t *b; in nxt_sendbuf_mem_coalesce0() local 92 nxt_buf_t *b; in nxt_sendbuf_mem_coalesce() local 169 nxt_buf_t *b; in nxt_sendbuf_file_coalesce() local 211 nxt_sendbuf_copy_coalesce(nxt_conn_t *c, nxt_buf_mem_t *bm, nxt_buf_t *b, in nxt_sendbuf_copy_coalesce() 295 nxt_sendbuf_copy(nxt_buf_mem_t *bm, nxt_buf_t *b, size_t *copied) in nxt_sendbuf_copy() 331 nxt_sendbuf_update(nxt_buf_t *b, size_t sent) in nxt_sendbuf_update() 381 nxt_sendbuf_completion(nxt_task_t *task, nxt_work_queue_t *wq, nxt_buf_t *b) in nxt_sendbuf_completion() 397 nxt_sendbuf_drain(nxt_task_t *task, nxt_work_queue_t *wq, nxt_buf_t *b) in nxt_sendbuf_drain() 409 nxt_buf_t *b, *next, **last, *rest, **last_rest; in nxt_sendbuf_coalesce_completion() local
|
H A D | nxt_websocket.c | 12 nxt_ntoh16(const uint8_t *b) in nxt_ntoh16() 19 nxt_hton16(uint8_t *b, uint16_t v) in nxt_hton16() 27 nxt_ntoh64(const uint8_t *b) in nxt_ntoh64() 41 nxt_hton64(uint8_t *b, uint64_t v) in nxt_hton64()
|
H A D | nxt_buf_filter.c | 24 nxt_buf_filter_add(nxt_task_t *task, nxt_buf_filter_t *f, nxt_buf_t *b) in nxt_buf_filter_add() 36 nxt_buf_t *b; in nxt_buf_filter() local 176 nxt_buf_t *b; in nxt_buf_filter_nobuf() local 259 nxt_buf_t *b; in nxt_buf_filter_file_read() local 334 nxt_buf_t *b; in nxt_buf_filter_file_job_completion() local 402 nxt_buf_t *fb, *b; in nxt_buf_filter_buf_completion() local
|
H A D | nxt_recvbuf.c | 16 nxt_buf_t *b; in nxt_recvbuf_mem_coalesce() local 59 nxt_recvbuf_update(nxt_buf_t *b, size_t sent) in nxt_recvbuf_update()
|
H A D | nxt_sha1.c | 125 #define F1(b, c, d) (((b) & (c)) | ((~(b)) & (d))) argument 126 #define F2(b, c, d) ((b) ^ (c) ^ (d)) argument 127 #define F3(b, c, d) (((b) & (c)) | ((b) & (d)) | ((c) & (d))) argument 129 #define STEP(f, a, b, c, d, e, w, t) \ argument 158 uint32_t a, b, c, d, e, temp; in nxt_sha1_body() local
|
H A D | nxt_event_conn_job_sendfile.c | 43 nxt_iobuf_t b; in nxt_event_conn_job_sendfile_start() local 99 nxt_buf_t *b; in nxt_event_conn_job_sendfile_handler() local 166 nxt_buf_t *b; in nxt_event_conn_job_sendfile_return() local 239 nxt_buf_t *b) in nxt_event_conn_job_sendfile_completion()
|
H A D | nxt_http_source.c | 136 nxt_buf_t *b, *req, **prev; in nxt_http_source_request_create() local 190 nxt_buf_t *b; in nxt_http_source_status_filter() local 263 nxt_buf_t *b; in nxt_http_source_header_filter() local 431 nxt_buf_t *b; in nxt_http_source_header_ready() local 500 nxt_buf_t *b; in nxt_http_source_chunk_filter() local 551 nxt_buf_t *b, *in; in nxt_http_source_body_filter() local 579 nxt_buf_t *b) in nxt_http_source_sync_buffer()
|
H A D | nxt_http_chunk_parse.c | 33 nxt_buf_t *b, *out, *next, **tail; in nxt_http_chunk_parse() local 204 nxt_buf_t *b; in nxt_http_chunk_buffer() local 252 nxt_buf_t *b, *next, *parent; in nxt_http_chunk_buf_completion() local
|
H A D | nxt_fastcgi_source.c | 200 nxt_buf_t *b, *req, **prev; in nxt_fastcgi_request_create() local 390 nxt_buf_t *b, *in; in nxt_fastcgi_source_record_filter() local 466 nxt_buf_t *b; in nxt_fastcgi_source_header_filter() local 525 nxt_buf_t *b) in nxt_fastcgi_source_sync_buffer() 655 nxt_fastcgi_source_header_ready(nxt_fastcgi_source_t *fs, nxt_buf_t *b) in nxt_fastcgi_source_header_ready() 684 nxt_buf_t *b, *in; in nxt_fastcgi_source_body_filter() local 713 nxt_buf_t *b; in nxt_fastcgi_source_last_buf() local
|
H A D | nxt_stream_source.c | 169 nxt_buf_t *b; in nxt_stream_source_read_ready() local 243 nxt_buf_t *b; in nxt_stream_source_read_done() local 290 nxt_buf_t *b, *in, *head, **prev; in nxt_stream_source_process_buffers() local 345 nxt_buf_t *b, *parent; in nxt_stream_source_buf_completion() local 419 nxt_buf_t *b; in nxt_stream_source_closed() local
|
H A D | nxt_solaris_sendfilev.c | 25 nxt_solaris_event_conn_io_sendfilev(nxt_event_conn_t *c, nxt_buf_t *b, in nxt_solaris_event_conn_io_sendfilev() 90 nxt_solaris_buf_coalesce(nxt_buf_t *b, sendfilevec_t *sfv, int32_t *nsfv, in nxt_solaris_buf_coalesce()
|
H A D | nxt_port_socket.c | 162 nxt_buf_t *b) in nxt_port_socket_write2() 253 nxt_port_can_enqueue_buf(nxt_buf_t *b) in nxt_port_can_enqueue_buf() 270 nxt_buf_t *b) in nxt_port_enqueue_buf() 618 nxt_port_buf_completion(nxt_task_t *task, nxt_work_queue_t *wq, nxt_buf_t *b, in nxt_port_buf_completion() 734 nxt_buf_t *b; in nxt_port_read_handler() local 815 nxt_buf_t *b; in nxt_port_queue_read_handler() local 1174 nxt_buf_t *b, *orig_b, *next; in nxt_port_read_msg_process() local 1307 nxt_buf_t *b; in nxt_port_buf_alloc() local 1328 nxt_port_buf_free(nxt_port_t *port, nxt_buf_t *b) in nxt_port_buf_free() 1339 nxt_buf_t *b, *next; in nxt_port_error_handler() local
|
H A D | nxt_fastcgi_record_parse.c | 25 nxt_buf_t *b, *nb, **tail[2]; in nxt_fastcgi_record_parse() local 254 nxt_buf_t *b; in nxt_fastcgi_buffer() local
|
H A D | nxt_port_memory.c | 122 nxt_buf_t *b, *next; in nxt_port_mmap_buf_completion() local 633 nxt_buf_t *b; in nxt_port_mmap_tracking_read() local 677 nxt_buf_t *b; in nxt_port_mmap_get_buf() local 729 nxt_port_mmap_increase_buf(nxt_task_t *task, nxt_buf_t *b, size_t size, in nxt_port_mmap_increase_buf() 799 nxt_buf_t *b; in nxt_port_mmap_get_incoming_buf() local 898 nxt_buf_t *b, **pb; in nxt_port_mmap_read() local 935 nxt_port_mmap_get_method(nxt_task_t *task, nxt_port_t *port, nxt_buf_t *b) in nxt_port_mmap_get_method()
|
H A D | nxt_aix_send_file.c | 17 nxt_aix_event_conn_io_send_file(nxt_event_conn_t *c, nxt_buf_t *b, size_t limit) in nxt_aix_event_conn_io_send_file()
|
H A D | nxt_conn_proxy.c | 146 nxt_buf_t *b; in nxt_conn_proxy_client_buffer_alloc() local 295 nxt_buf_t *b; in nxt_conn_proxy_peer_read() local 433 nxt_conn_proxy_write_add(nxt_conn_t *c, nxt_buf_t *b) in nxt_conn_proxy_write_add() 624 nxt_conn_proxy_read_add(nxt_conn_t *c, nxt_buf_t *b) in nxt_conn_proxy_read_add() 704 nxt_buf_t *b; in nxt_conn_proxy_close() local 854 nxt_buf_t *b; in nxt_conn_proxy_shutdown() local
|
H A D | nxt_sha1.h | 14 uint32_t a, b, c, d, e; member
|
H A D | nxt_conn_write.c | 20 nxt_buf_t *b; in nxt_conn_io_write() local 188 nxt_buf_t *b; in nxt_conn_io_sendfile() local 430 nxt_event_conn_io_sendbuf(nxt_conn_t *c, nxt_buf_t *b, size_t limit) in nxt_event_conn_io_sendbuf()
|
/unit/src/java/nginx/unit/ |
H A D | OutputStream.java | 17 public void write(int b) throws IOException in write() 22 private static native void write(long req_info_ptr, int b); in write() 26 public void write(byte b[], int off, int len) throws IOException in write() 40 private static native void write(long req_info_ptr, byte b[], int off, int len); in write()
|
H A D | InputStream.java | 18 public int readLine(byte[] b, int off, int len) throws IOException { in readLine() 26 private static native int readLine(long req_info_ptr, byte[] b, int off, int len); in readLine() 61 public int read(byte b[], int off, int len) throws IOException { in read() 73 private static native int read(long req_info_ptr, byte b[], int off, int len); in read()
|
/unit/src/java/ |
H A D | nxt_jni_OutputStream.c | 82 jint b) in nxt_java_OutputStream_writeByte() 176 jarray b, jint off, jint len) in nxt_java_OutputStream_write()
|
H A D | nxt_jni_InputStream.c | 129 uint8_t b; in nxt_java_InputStream_readByte() local 143 jarray b, jint off, jint len) in nxt_java_InputStream_read()
|