Home
last modified time | relevance | path

Searched refs:count (Results 1 – 25 of 41) sorted by relevance

12

/unit/src/
H A Dnxt_semaphore.c35 nxt_sem_init(nxt_sem_t *sem, nxt_uint_t count) in nxt_sem_init() argument
37 if (sem_init(sem, 0, count) == 0) { in nxt_sem_init()
172 nxt_sem_init(nxt_sem_t *sem, nxt_uint_t count) in nxt_sem_init() argument
177 sem->count = count; in nxt_sem_init()
207 sem->count++; in nxt_sem_post()
226 while (sem->count == 0) { in nxt_sem_wait()
235 sem->count--; in nxt_sem_wait()
H A Dnxt_log_moderation.c30 n = mod->count++; in nxt_log_moderate_allow()
36 mod->count = 1; in nxt_log_moderate_allow()
87 n = mod->count; in nxt_log_moderate_timer_handler()
88 mod->count = 0; in nxt_log_moderate_timer_handler()
H A Dnxt_conf.c259 value->u.object->count = count; in nxt_conf_create_object()
374 value->u.array->count = count; in nxt_conf_create_array()
1021 count = src->u.array->count; in nxt_conf_copy_array()
1039 dst->u.array->count = count; in nxt_conf_copy_array()
1122 count = src->u.object->count; in nxt_conf_copy_object()
1141 dst->u.object->count = count; in nxt_conf_copy_object()
1502 count = 0; in nxt_conf_json_parse_object()
1534 count++; in nxt_conf_json_parse_object()
1637 object->count = count; in nxt_conf_json_parse_object()
1730 count = 0; in nxt_conf_json_parse_array()
[all …]
H A Dnxt_semaphore.h18 nxt_atomic_t count; member
26 NXT_EXPORT nxt_int_t nxt_sem_init(nxt_sem_t *sem, nxt_uint_t count);
H A Dnxt_spinlock.c35 nxt_thread_spin_init(nxt_uint_t ncpu, nxt_uint_t count) in nxt_thread_spin_init() argument
41 nxt_spinlock_count = count; in nxt_thread_spin_init()
H A Dnxt_mem_zone.c43 uint32_t count; member
555 page->u.count = 0; in nxt_mem_zone_alloc_small()
698 page[0].u.count = pages; in nxt_mem_zone_alloc_pages()
773 nxt_uint_t count; in nxt_mem_zone_free() local
796 count = page->u.count; in nxt_mem_zone_free()
901 nxt_uint_t count) in nxt_mem_zone_free_pages() argument
908 page->u.count = 0; in nxt_mem_zone_free_pages()
923 count += next_block->size; in nxt_mem_zone_free_pages()
936 count += prev_block->size; in nxt_mem_zone_free_pages()
939 prev_block->size = count; in nxt_mem_zone_free_pages()
[all …]
H A Dnxt_clang.h143 int count; in nxt_popcount() local
145 for (count = 0; x != 0; count++) { in nxt_popcount()
149 return count; in nxt_popcount()
H A Dnxt_router.h42 uint32_t count; member
82 uint32_t count; member
164 uint32_t count; member
212 uint32_t count; member
231 uint32_t count; member
H A Dnxt_random.c113 r->count = 400000; in nxt_random_stir()
145 r->count--; in nxt_random()
147 if (r->count <= 0) { in nxt_random()
189 r.count = 400000; in nxt_random_test()
H A Dnxt_cert.c24 nxt_uint_t count; member
234 if (cert->count == nalloc) { in nxt_cert_bio()
259 if (cert->count == 0) { in nxt_cert_bio()
310 for (i = 0; i != cert->count; i++) { in nxt_cert_destroy()
561 for (i = 0; i < cert->count; i++) { in nxt_cert_details()
658 nxt_uint_t i, n, count; in nxt_cert_name_details() local
674 count = 0; in nxt_cert_name_details()
685 count++; in nxt_cert_name_details()
701 count++; in nxt_cert_name_details()
744 nxt_uint_t i, n, count; in nxt_cert_alt_names_details() local
[all …]
H A Dnxt_spinlock.h13 NXT_EXPORT void nxt_thread_spin_init(nxt_uint_t ncpu, nxt_uint_t count);
H A Dnxt_random.h15 int32_t count; member
H A Dnxt_file_cache.c139 node->count++; in nxt_file_cache_query_locked()
414 node->count = 1;
423 if (node->count != 0) {
461 node->count--; in nxt_cache_node_release_locked()
463 if (node->count != 0) { in nxt_cache_node_release_locked()
H A Dnxt_log_moderation.h17 nxt_uint_t count; member
H A Dnxt_http_parse.h123 nxt_http_field_proc_t items[], nxt_uint_t count);
125 nxt_http_field_proc_t items[], nxt_uint_t count, nxt_bool_t level);
H A Dnxt_cache.c185 node->count++; in nxt_cache_query_locked()
245 node->count++; in nxt_cache_node_hold()
421 node->count = 1; in nxt_cache_update()
446 if (node->count != 0) { in nxt_cache_update()
519 node->count--; in nxt_cache_release_locked()
521 if (node->count != 0) { in nxt_cache_release_locked()
H A Dnxt_listen_socket.h21 uint32_t count; member
H A Dnxt_conf.h127 nxt_conf_value_t *nxt_conf_create_object(nxt_mp_t *mp, nxt_uint_t count);
141 nxt_conf_value_t *nxt_conf_create_array(nxt_mp_t *mp, nxt_uint_t count);
/unit/src/java/nginx/unit/websocket/server/
H A DWsWriteTimeout.java37 private final AtomicInteger count = new AtomicInteger(0); field in WsWriteTimeout
87 int newCount = count.incrementAndGet(); in register()
98 int newCount = count.decrementAndGet(); in unregister()
/unit/src/perl/
H A Dnxt_perl_psgi_layer.c29 void *vbuf, Size_t count);
31 const void *vbuf, Size_t count);
179 nxt_perl_psgi_layer_stream_read(pTHX_ PerlIO *f, void *vbuf, Size_t count) in nxt_perl_psgi_layer_stream_read() argument
199 return arg->io_tab->read(PERL_GET_CONTEXT, arg, vbuf, count); in nxt_perl_psgi_layer_stream_read()
205 const void *vbuf, Size_t count) in nxt_perl_psgi_layer_stream_write() argument
214 return arg->io_tab->write(PERL_GET_CONTEXT, arg, vbuf, count); in nxt_perl_psgi_layer_stream_write()
/unit/test/
H A Dtest_ruby_hooks.py9 def _wait_cookie(self, pattern, count): argument
11 option.temp_dir + '/ruby/hooks/cookie_' + pattern, count
/unit/src/java/nginx/unit/websocket/
H A DAsyncChannelGroupUtil.java129 private static AtomicInteger count = new AtomicInteger(0); field in AsyncChannelGroupUtil.AsyncIOThreadFactory.NewThreadPrivilegedAction
140 t.setName("WebSocketClient-AsyncIO-" + count.incrementAndGet()); in run()
/unit/test/unit/
H A Dutils.py37 def waitforglob(pattern, count=1, timeout=50): argument
44 if n == count:
/unit/src/nodejs/unit-http/
H A Dhttp_server.js63 let count = 0;
66 count = value.length;
73 count = 1;
86 this.headers_len += value_len + (name_len * count);
87 this.headers_count += count;
/unit/src/python/
H A Dnxt_python.h48 nxt_int_t count; member

12