Searched refs:buffers (Results 1 – 10 of 10) sorted by relevance
/unit/src/ |
H A D | nxt_stream_source.c | 46 if (nxt_slow_path(!nxt_buf_pool_obtainable(&us->buffers))) { in nxt_stream_source_connect() 49 us->buffers.max, us->buffers.size / 1024); in nxt_stream_source_connect() 53 c = nxt_event_conn_create(us->buffers.mem_pool, thr->log); in nxt_stream_source_connect() 170 nxt_buf_pool_t *buffers; in nxt_stream_source_read_ready() local 182 buffers = &stream->upstream->buffers; in nxt_stream_source_read_ready() 184 ret = nxt_buf_pool_mem_alloc(buffers, 0); in nxt_stream_source_read_ready() 209 c->read = buffers->current; in nxt_stream_source_read_ready() 210 buffers->current = NULL; in nxt_stream_source_read_ready() 374 if (size >= 256 || size >= stream->upstream->buffers.size) { in nxt_stream_source_buf_completion() 391 nxt_buf_free(stream->upstream->buffers.mem_pool, b); in nxt_stream_source_buf_completion() [all …]
|
H A D | nxt_http_source.c | 60 hs->header_in.list = nxt_list_create(us->buffers.mem_pool, 8, in nxt_http_source_handler() 144 ret = nxt_buf_pool_mem_alloc(&hs->upstream->buffers, 0); in nxt_http_source_request_create() 149 b = hs->upstream->buffers.current; in nxt_http_source_request_create() 150 hs->upstream->buffers.current = NULL; in nxt_http_source_request_create() 229 hs->u.header.mem_pool = hs->upstream->buffers.mem_pool; in nxt_http_source_status_filter() 440 nxt_buf_pool_free(&us->buffers, b); in nxt_http_source_header_ready() 443 if (nxt_fast_path(nxt_buf_pool_available(&us->buffers))) { in nxt_http_source_header_ready() 446 hsc = nxt_mp_zalloc(hs->upstream->buffers.mem_pool, in nxt_http_source_header_ready() 462 hsc->parse.mem_pool = hs->upstream->buffers.mem_pool; in nxt_http_source_header_ready() 490 us->buffers.max, us->buffers.size / 1024); in nxt_http_source_header_ready() [all …]
|
H A D | nxt_fastcgi_source.c | 127 fs = nxt_mp_zget(us->buffers.mem_pool, sizeof(nxt_fastcgi_source_t)); in nxt_fastcgi_source_handler() 134 fs->header_in.list = nxt_list_create(us->buffers.mem_pool, 8, in nxt_fastcgi_source_handler() 147 stream = nxt_mp_zget(us->buffers.mem_pool, sizeof(nxt_stream_source_t)); in nxt_fastcgi_source_handler() 171 fs->record.parse.mem_pool = us->buffers.mem_pool; in nxt_fastcgi_source_handler() 182 fs->u.header.mem_pool = fs->upstream->buffers.mem_pool; in nxt_fastcgi_source_handler() 212 ret = nxt_buf_pool_mem_alloc(&fs->upstream->buffers, 0); in nxt_fastcgi_request_create() 217 b = fs->upstream->buffers.current; in nxt_fastcgi_request_create() 218 fs->upstream->buffers.current = NULL; in nxt_fastcgi_request_create() 310 b = nxt_buf_mem_alloc(fs->upstream->buffers.mem_pool, 16, 0); in nxt_fastcgi_request_create() 533 fs->upstream->buffers.max, fs->upstream->buffers.size); in nxt_fastcgi_source_sync_buffer()
|
H A D | nxt_h1proto.h | 44 nxt_buf_t *buffers; member
|
H A D | nxt_buf_filter.c | 282 ret = nxt_buf_pool_mmap_alloc(&ff->buffers, (size_t) size); in nxt_buf_filter_file_read() 285 ret = nxt_buf_pool_file_alloc(&ff->buffers, (size_t) size); in nxt_buf_filter_file_read() 289 b = ff->buffers.current; in nxt_buf_filter_file_read() 419 nxt_buf_pool_free(&f->filter_file->buffers, b); in nxt_buf_filter_buf_completion() 427 nxt_buf_pool_destroy(&f->filter_file->buffers); in nxt_buf_filter_buf_completion()
|
H A D | nxt_upstream_source.h | 62 nxt_buf_pool_t buffers; member
|
H A D | nxt_buf_filter.h | 64 nxt_buf_pool_t buffers; member
|
H A D | nxt_h1proto.c | 727 in->next = h1p->buffers; in nxt_h1p_header_buffer_test() 728 h1p->buffers = in; in nxt_h1p_header_buffer_test() 967 in->next = h1p->buffers; in nxt_h1p_request_body_read() 968 h1p->buffers = in; in nxt_h1p_request_body_read() 1402 b = h1p->buffers; in nxt_h1p_complete_buffers() 1425 h1p->buffers = NULL; in nxt_h1p_complete_buffers()
|
/unit/src/java/nginx/unit/websocket/server/ |
H A D | WsRemoteEndpointImplServer.java | 48 private volatile ByteBuffer[] buffers = null; field in WsRemoteEndpointImplServer 65 ByteBuffer... buffers) { in doWrite() argument 124 buffers = null; in clearHandler()
|
/unit/ |
H A D | CHANGES | 848 *) Bugfix: HTTP large header buffers allocation and deallocation fixed;
|