/unit/src/ |
H A D | nxt_unit.c | 1277 nxt_unit_mmap_buf_t *b; in nxt_unit_process_req_headers() local 1404 nxt_unit_mmap_buf_t *b; in nxt_unit_process_req_body() local 1611 nxt_unit_mmap_buf_t *b; in nxt_unit_process_websocket() local 3095 nxt_unit_buf_t *b; in nxt_unit_request_readline_size() local 3198 nxt_unit_buf_read(nxt_unit_buf_t **b, uint64_t *len, void *dst, size_t size) in nxt_unit_buf_read() 3322 const uint8_t *b; in nxt_unit_websocket_sendv() local 3405 uint8_t *b; in nxt_unit_websocket_read() local 3429 char *b; in nxt_unit_websocket_retain() local 4209 nxt_unit_mmap_buf_t *b, **incoming_tail; in nxt_unit_mmap_read() local
|
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_http_static.c | 783 nxt_buf_t *fb, *b, **next, *out; in nxt_http_static_body_handler() local 845 nxt_buf_t *b, *fb, *next; in nxt_http_static_buf_completion() local
|
H A D | nxt_http_request.c | 711 nxt_buf_t *b; in nxt_http_buf_mem() local 730 nxt_buf_t *b, *next; in nxt_http_request_mem_buf_completion() local
|
H A D | nxt_http_parse.c | 126 nxt_http_parse_request(nxt_http_request_parse_t *rp, nxt_buf_mem_t *b) in nxt_http_parse_request() 143 nxt_http_parse_fields(nxt_http_request_parse_t *rp, nxt_buf_mem_t *b) in nxt_http_parse_fields()
|
H A D | nxt_router.c | 401 nxt_buf_t *b; in nxt_router_start_app_process_handler() local 542 nxt_buf_t *b, *next; in nxt_router_msg_cancel() local 2584 nxt_buf_t *b; in nxt_router_listen_socket_rpc_create() local 2814 nxt_buf_t *b; in nxt_router_app_rpc_create() local 3891 nxt_buf_t *b; in nxt_router_access_log_open() local 4021 nxt_buf_t *b; in nxt_router_access_log_reopen_handler() local 4090 nxt_buf_t *b; in nxt_router_access_log_reopen_completion() local 4176 nxt_buf_t *b, *next; in nxt_router_response_ready_handler() local 4364 nxt_buf_t *b; in nxt_router_req_headers_ack_handler() local 5525 nxt_buf_t *b, *buf, *out, **tail; in nxt_router_prepare_msg() local
|
H A D | nxt_h1proto.c | 267 nxt_buf_t *b; in nxt_http_idle_io_read_handler() local 312 nxt_buf_t *b; in nxt_http_conn_test() local 403 nxt_buf_t *b; in nxt_h1p_idle_io_read_handler() local 708 nxt_buf_t *in, *b; in nxt_h1p_header_buffer_test() local 846 nxt_buf_t *in, *b; in nxt_h1p_request_body_read() local 1019 nxt_buf_t *b; in nxt_h1p_conn_request_body_read() local 1397 nxt_buf_t *b, *in, *next; in nxt_h1p_complete_buffers() local 1495 nxt_buf_t *b, **prev, *header, *tail; in nxt_h1p_chunk_create() local 1561 nxt_buf_t *b; in nxt_h1p_request_discard() local 2451 nxt_buf_t *b; in nxt_h1p_peer_io_read_handler() local [all …]
|
H A D | nxt_port_memory.c | 122 nxt_buf_t *b, *next; in nxt_port_mmap_buf_completion() local 546 nxt_buf_t *b; in nxt_port_mmap_get_buf() local 598 nxt_port_mmap_increase_buf(nxt_task_t *task, nxt_buf_t *b, size_t size, in nxt_port_mmap_increase_buf() 668 nxt_buf_t *b; in nxt_port_mmap_get_incoming_buf() local 767 nxt_buf_t *b, **pb; in nxt_port_mmap_read() local 804 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_port.h | 329 nxt_buf_t *b) in nxt_port_socket_write()
|
H A D | nxt_openssl.c | 1332 nxt_openssl_conn_io_recvbuf(nxt_conn_t *c, nxt_buf_t *b)
|
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_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_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_main_process.c | 371 nxt_buf_t *b; in nxt_main_start_process_handler() local 1030 nxt_buf_t *b, *out; in nxt_main_port_socket_handler() local 1280 nxt_buf_t *b; in nxt_main_port_modules_handler() local
|
H A D | nxt_gnutls.c | 472 nxt_buf_t *b; in nxt_gnutls_conn_io_read() local 527 nxt_buf_t *b, size_t limit) in nxt_gnutls_conn_io_write_chunk()
|
H A D | nxt_cert.c | 1067 nxt_buf_t *b; in nxt_cert_store_get() local 1112 nxt_buf_t *b; in nxt_cert_buf_completion() local 1194 nxt_buf_t *b; in nxt_cert_store_delete() local
|
H A D | nxt_port.c | 232 nxt_buf_t *b; in nxt_port_send_port() local 378 nxt_buf_t *b; in nxt_port_change_log_file() local 410 nxt_buf_t *b; in nxt_port_change_log_file_handler() local 441 nxt_buf_t *b; in nxt_port_data_handler() local
|
H A D | nxt_application.c | 160 nxt_buf_t *b; in nxt_discovery_start() local 206 nxt_buf_t *b; in nxt_discovery_modules() local 482 nxt_buf_t *b; in nxt_discovery_completion_handler() local
|
H A D | nxt_java.c | 560 void *b; in nxt_java_websocket_handler() local
|
H A D | nxt_controller.c | 564 nxt_buf_t *b; in nxt_controller_conf_send() local 674 nxt_buf_t *b; in nxt_controller_conn_init() local 736 nxt_buf_t *b; in nxt_controller_conn_read() local 867 nxt_buf_t *b; in nxt_controller_conn_body_read() local 905 nxt_buf_t *b; in nxt_controller_conn_write() local 1758 nxt_buf_t *b; in nxt_controller_process_control() local 1909 nxt_buf_t *b; in nxt_controller_conf_store() local 1960 nxt_buf_t *b, *body; in nxt_controller_response() local
|
H A D | nxt_h1proto_websocket.c | 346 nxt_buf_t *b = nxt_buf_mem_alloc(c->mem_pool, frame_size - size, 0); in nxt_h1p_conn_ws_frame_header_read() local 466 nxt_buf_t *b; in nxt_h1p_ws_io_read_handler() local 649 nxt_buf_t *b, *out, *next; in nxt_h1p_conn_ws_pong() local
|
H A D | nxt_event_engine.c | 682 nxt_buf_t *b; in nxt_event_engine_buf_mem_alloc() local 710 nxt_event_engine_buf_mem_free(nxt_event_engine_t *engine, nxt_buf_t *b) in nxt_event_engine_buf_mem_free() 723 nxt_buf_t *b, *next, *parent; in nxt_event_engine_buf_mem_completion() 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_http_proxy.c | 323 nxt_buf_t *b; in nxt_http_proxy_buf_mem_alloc() local 342 nxt_buf_t *b, *next; in nxt_http_proxy_buf_mem_completion() local 367 nxt_buf_t *b) in nxt_http_proxy_buf_mem_free()
|
/unit/src/java/nginx/unit/websocket/ |
H A D | WsRemoteEndpointImplBase.java | 938 public void write(int b) throws IOException { in write() 952 public void write(byte[] b, int off, int len) throws IOException { in write()
|