Home
last modified time | relevance | path

Searched refs:buffers (Results 1 – 10 of 10) sorted by relevance

/unit/src/
H A Dnxt_stream_source.c46 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 Dnxt_http_source.c60 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 Dnxt_fastcgi_source.c127 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 Dnxt_h1proto.h44 nxt_buf_t *buffers; member
H A Dnxt_buf_filter.c282 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 Dnxt_upstream_source.h62 nxt_buf_pool_t buffers; member
H A Dnxt_buf_filter.h64 nxt_buf_pool_t buffers; member
H A Dnxt_h1proto.c727 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 DWsRemoteEndpointImplServer.java48 private volatile ByteBuffer[] buffers = null; field in WsRemoteEndpointImplServer
65 ByteBuffer... buffers) { in doWrite() argument
124 buffers = null; in clearHandler()
/unit/
H A DCHANGES848 *) Bugfix: HTTP large header buffers allocation and deallocation fixed;