Home
last modified time | relevance | path

Searched refs:chunk (Results 1 – 11 of 11) sorted by relevance

/unit/src/nodejs/unit-http/
H A Dhttp_server.js236 if (typeof chunk === 'function') {
237 callback = chunk;
238 chunk = null;
245 if (chunk) {
246 if (typeof chunk !== 'string' && !(chunk instanceof Buffer)) {
250 if (typeof chunk === 'string') {
254 chunk = Buffer.from(chunk, encoding);
260 contentLength = chunk.length;
494 if (typeof o.chunk === 'string') {
498 l = o.chunk.length;
[all …]
/unit/src/
H A Dnxt_work_queue.c109 nxt_work_queue_chunk_t *chunk, *next; in nxt_work_queue_cache_destroy() local
111 for (chunk = cache->chunk; chunk; chunk = next) { in nxt_work_queue_cache_destroy()
112 next = chunk->next; in nxt_work_queue_cache_destroy()
113 nxt_free(chunk); in nxt_work_queue_cache_destroy()
124 nxt_work_queue_chunk_t *chunk; in nxt_work_queue_allocate() local
129 chunk = nxt_malloc(size); in nxt_work_queue_allocate()
131 if (nxt_fast_path(chunk != NULL)) { in nxt_work_queue_allocate()
133 chunk->next = cache->chunk; in nxt_work_queue_allocate()
134 cache->chunk = chunk; in nxt_work_queue_allocate()
135 work = &chunk->work; in nxt_work_queue_allocate()
H A Dnxt_port_memory_int.h131 nxt_chunk_id_t chunk; in nxt_port_mmap_get_free_chunk() local
147 chunk = i * FREE_BITS + ffs - 1; in nxt_port_mmap_get_free_chunk()
149 if (nxt_port_mmap_chk_set_chunk_busy(m, chunk)) { in nxt_port_mmap_get_free_chunk()
150 *c = chunk; in nxt_port_mmap_get_free_chunk()
H A Dnxt_mem_zone.c110 #define nxt_mem_zone_set_chunk_free(map, chunk) \ argument
111 map[chunk / 8] &= ~(0x80 >> (chunk & 7))
114 #define nxt_mem_zone_chunk_is_free(map, chunk) \ argument
115 ((map[chunk / 8] & (0x80 >> (chunk & 7))) == 0)
826 uint32_t size, offset, chunk; in nxt_mem_zone_free_chunk() local
838 chunk = offset / size; in nxt_mem_zone_free_chunk()
840 if (nxt_slow_path(offset != chunk * size)) { in nxt_mem_zone_free_chunk()
852 if (nxt_mem_zone_chunk_is_free(map, chunk)) { in nxt_mem_zone_free_chunk()
856 nxt_mem_zone_set_chunk_free(map, chunk); in nxt_mem_zone_free_chunk()
H A Dnxt_mp.c132 #define nxt_mp_chunk_is_free(map, chunk) \ argument
133 ((map & (1 << chunk)) != 0)
136 #define nxt_mp_chunk_set_busy(map, chunk) \ argument
137 map &= ~(1 << chunk)
140 #define nxt_mp_chunk_set_free(map, chunk) \ argument
141 map |= (1 << chunk)
865 nxt_uint_t n, size, chunk; in nxt_mp_chunk_free() local
887 chunk = offset / size; in nxt_mp_chunk_free()
889 if (nxt_slow_path(offset != chunk * size)) { in nxt_mp_chunk_free()
893 if (nxt_slow_path(nxt_mp_chunk_is_free(page->u.map, chunk))) { in nxt_mp_chunk_free()
[all …]
H A Dnxt_work_queue.h58 nxt_work_queue_chunk_t *chunk; member
/unit/test/node/mirror/
H A Dapp.js4 req.on('data', chunk => {
5 body += chunk.toString();
/unit/test/node/post_variables/
H A Dapp.js4 req.on('data', chunk => {
5 body += chunk.toString();
/unit/test/
H A Dtest_proxy_chunked.py66 for chunk in re.split(r'([@#])', req):
67 if chunk == '@' or chunk == '#':
68 if chunk == '#':
72 connection.sendall(chunk.encode())
/unit/test/node/variables/
H A Dapp.js4 req.on('data', chunk => {
5 body += chunk.toString();
/unit/src/ruby/
H A Dnxt_ruby_stream_io.c128 VALUE chunk; in nxt_ruby_stream_io_each() local
135 chunk = nxt_ruby_stream_io_gets(obj); in nxt_ruby_stream_io_each()
137 if (chunk == Qnil) { in nxt_ruby_stream_io_each()
141 rb_yield(chunk); in nxt_ruby_stream_io_each()