Home
last modified time | relevance | path

Searched refs:count (Results 1 – 25 of 38) 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_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_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_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
86 uint32_t count; member
168 uint32_t count; member
220 uint32_t count; member
239 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_log_moderation.h17 nxt_uint_t count; member
H A Dnxt_http_parse.h124 nxt_http_field_proc_t items[], nxt_uint_t count);
126 nxt_http_field_proc_t items[], nxt_uint_t count, nxt_bool_t level);
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);
H A Dnxt_openssl.c43 nxt_uint_t count; member
635 nxt_uint_t count; local
655 count = nxt_conf_array_elements_count_or_1(tickets_conf);
657 if (count == 0) {
664 + count * sizeof(nxt_tls_ticket_t));
669 tickets->count = count;
678 member = nxt_conf_get_array_element_or_itself(tickets_conf, count - i);
700 } while (i < count);
787 } while (++i < tls->conf->tickets->count);
1150 conf->tickets->count * sizeof(nxt_tls_ticket_t));
/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/test/
H A Dtest_ruby_hooks.py10 def wait_cookie(pattern, count): argument
11 return waitforglob(f'{option.temp_dir}/ruby/hooks/cookie_{pattern}', count)
/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/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.py43 def waitforglob(pattern, count=1, timeout=50): argument
50 if n == count:
/unit/src/nodejs/unit-http/
H A Dhttp_server.js72 let count = 0;
75 count = value.length;
82 count = 1;
95 this.headers_len += value_len + (name_len * count);
96 this.headers_count += count;
/unit/src/python/
H A Dnxt_python.h50 nxt_int_t count; member
/unit/src/test/
H A Dnxt_clone_test.c431 nxt_uint_t count, i; in nxt_clone_creds_test() local
461 count = sizeof(testcases)/sizeof(nxt_clone_creds_testcase_t); in nxt_clone_creds_test()
463 for (i = 0; i < count; i++) { in nxt_clone_creds_test()

12