Home
last modified time | relevance | path

Searched refs:i (Results 1 – 25 of 54) sorted by relevance

123

/libevent-2.1.12/test/
H A Dregress_thread.c112 for (i = 0; i < NUM_ITERATIONS; i++) { in basic_thread()
228 for (i = 0; i < NUM_THREADS; ++i) in thread_basic()
238 for (i = 0; i < NUM_THREADS; ++i) in thread_basic()
313 for (i = 0; i < NUM_THREADS; ++i) { in thread_conditions_simple()
328 for (i = 0; i < NUM_THREADS; ++i) { in thread_conditions_simple()
340 for (i = 0; i < NUM_THREADS; ++i) in thread_conditions_simple()
349 for (i = 0; i < NUM_THREADS; ++i) { in thread_conditions_simple()
425 for (i = 0; i < CB_COUNT; ++i) { in load_deferred_queue()
469 for (i = 0; i < QUEUE_THREAD_COUNT; ++i) in thread_deferred_cb_skew()
538 for (i=0;i<5;++i) { in thread_no_events()
[all …]
H A Dregress_minheap.c46 unsigned i; in check_heap() local
47 for (i = 1; i < heap->n; ++i) { in check_heap()
48 unsigned parent_idx = (i-1)/2; in check_heap()
60 int i; in test_heap_randomized() local
64 for (i = 0; i < 1024; ++i) { in test_heap_randomized()
66 set_random_timeout(inserted[i]); in test_heap_randomized()
67 min_heap_push_(&heap, inserted[i]); in test_heap_randomized()
73 for (i = 0; i < 512; ++i) { in test_heap_randomized()
75 if (0 == (i % 32)) in test_heap_randomized()
90 for (i = 0; i < 1024; ++i) in test_heap_randomized()
[all …]
H A Dbench.c103 long i; in run_once() local
106 for (cp = pipes, i = 0; i < num_pipes; i++, cp += 2) { in run_once()
108 event_del(&events[i]); in run_once()
109 event_assign(&events[i], base, cp[0], EV_READ | EV_PERSIST, read_cb, (void *)(ev_intptr_t) i); in run_once()
110 event_add(&events[i], NULL); in run_once()
118 for (i = 0; i < num_active; i++, fired++) in run_once()
148 int i, c; local
180 for (i = 0; methods[i] != NULL; ++i)
207 for (i = 0; methods[i] != NULL; ++i)
215 for (cp = pipes, i = 0; i < num_pipes; i++, cp += 2) {
[all …]
H A Dtinytest.c366 int i, j; local
372 for (i=0; groups[i].prefix; ++i) {
416 int i, j, n, r; local
417 for (i=0; cfg_aliases && cfg_aliases[i].name; ++i) {
469 int i, j, n=0; local
479 for (i=1; i<c; ++i) {
499 ++i;
500 if (i >= c) {
524 for (i = 0; groups[i].prefix; ++i) {
597 size_t i; local
[all …]
H A Dbench_http.c90 int i; in main() local
107 for (i = 1; i < argc; ++i) { in main()
108 if (*argv[i] != '-') in main()
111 c = argv[i][1]; in main()
113 if ((c == 'p' || c == 'l') && i + 1 >= argc) { in main()
120 if (i+1 >= argc || !argv[i+1]) { in main()
124 port = (int)strtol(argv[i+1], &endptr, 10); in main()
131 if (i+1 >= argc || !argv[i+1]) { in main()
169 int i = 0; in main() local
170 for (i = 0; i < (int)content_len; ++i) in main()
[all …]
H A Dbench_cascade.c83 int i; in run_once() local
95 for (cp = pipes, i = 0; i < num_pipes; i++, cp += 2) { in run_once()
109 for (cp = pipes, i = 0; i < num_pipes; i++, cp += 2) { in run_once()
110 evutil_socket_t fd = i < num_pipes - 1 ? cp[3] : -1; in run_once()
111 event_set(&events[i], cp[0], EV_READ, read_cb, in run_once()
113 event_add(&events[i], &tv_timeout); in run_once()
127 for (cp = pipes, i = 0; i < num_pipes; i++, cp += 2) { in run_once()
128 event_del(&events[i]); in run_once()
145 int i, c; in main() local
175 for (i = 0; i < 25; i++) { in main()
H A Dtest-time.c64 int i, j; in time_cb() local
69 for (i = 0; i < 10; i++) { in time_cb()
86 int i; in main() local
105 for (i = 0; i < NEVENT; i++) { in main()
106 ev[i] = evtimer_new(base, time_cb, event_self_cbarg()); in main()
109 evtimer_add(ev[i], &tv); in main()
112 i = event_base_dispatch(base); in main()
115 i, called, NEVENT); in main()
117 if (i == 1 && called >= NEVENT) { in main()
H A Dtest-ratelim.c331 int i; in test_ratelimiting() local
431 for (i = 0; i < cfg_n_connections; ++i) { in test_ratelimiting()
434 assert(bevs[i]); in test_ratelimiting()
466 for (i = 0; i < cfg_n_connections; ++i) { in test_ratelimiting()
510 for (i=0; i < cfg_n_connections; ++i) { in test_ratelimiting()
589 if (*i + 1 == argc) { in handle_option()
596 argv[*i+1]); in handle_option()
601 argv[*i+1]); in handle_option()
605 ++*i; in handle_option()
630 int i,j; in main() local
[all …]
H A Dregress_dns.c117 for (i = 0; i < count; ++i) { in dns_gethostbyname_cb()
133 for (i = 0; i < count; ++i) in dns_gethostbyname_cb()
896 for (i=0;i<n;++i)
929 for (i=0;i<20;++i) in dns_inflight_test_impl()
937 for (i=0;i<20;++i) { in dns_inflight_test_impl()
2098 for (i = 0; i < 1000; ++i) { in test_getaddrinfo_async_cancel_stress()
2144 for (i = 0; i < 20; ++i) in dns_client_fail_requests_test()
2155 for (i = 0; i < 20; ++i) in dns_client_fail_requests_test()
2189 for (i = 0; i < 20; ++i) in dns_client_fail_requests_getaddrinfo_test()
2200 for (i = 0; i < 20; ++i) in dns_client_fail_requests_getaddrinfo_test()
[all …]
H A Dregress_util.c120 for (i = 0; ipv4_entries[i].addr; ++i) { in regress_ipv4_parse()
167 for (i = 0; ipv6_entries[i].addr; ++i) { in regress_ipv6_parse()
234 for (i = 0; ipv6_entries_scope[i].addr; ++i) { in regress_ipv6_parse_scope()
298 for (i = 0; sa_port_ents[i].parse; ++i) { in regress_sockaddr_port_parse()
409 for (i=0; sa_pred_entries[i].parse; ++i) { in test_evutil_sockaddr_predicates()
951 for (i=0;i<8;++i) { in test_evutil_rand()
976 for (i = 0; i < 10000; ++i) { in test_evutil_rand()
1427 for (i = 0; i < 10; ++i) { in test_evutil_monotonic_res()
1432 for (i = 0; i < 9; ++i) { in test_evutil_monotonic_res()
1467 for (i = 1; i < 10; ++i) { in test_evutil_monotonic_prc()
[all …]
H A Dregress_iocp.c91 count_wait_for(int i, int ms) in count_wait_for() argument
98 while (ms > 0 && count != i) { in count_wait_for()
106 if (count == i) in count_wait_for()
141 int i; in pair_is_in() local
144 for (i=0; i < o->call_count; ++i) { in pair_is_in()
145 if (o->keys[i] == key && o->sizes[i] == n) { in pair_is_in()
244 int i; in test_iocp_evbuffer() local
250 for (i = 0; i < (int)sizeof(junk); ++i) in test_iocp_evbuffer()
251 junk[i] = (char)(i); in test_iocp_evbuffer()
266 for (i=0;i<10;++i) in test_iocp_evbuffer()
H A Dregress.c533 wbuf[i] = i; in test_multiple()
562 wbuf[i] = i; in test_persistent()
810 for (i=0; i<100; ++i) { in test_common_timeout()
843 for (i=0; i<10; ++i) { in test_common_timeout()
853 for (i=0; i<100; ++i) { in test_common_timeout()
2314 for (i=0;i<3;++i) { in test_priority_active_inversion()
3109 for (i = 0; i < MANY; ++i) { in test_many_events()
3126 for (i = 0; i < MANY; ++i) { in test_many_events()
3134 for (i = 0; i < MANY; ++i) { in test_many_events()
3228 for (i = 0; i < 5; ++i) { in test_event_foreach()
[all …]
H A Dtest.sh48 for i in $BACKENDS; do
49 eval "EVENT_NO$i=yes; export EVENT_NO$i"
74 for i in $TESTS; do
75 announce_n " $i: "
76 if $TEST_DIR/$i >>"$TEST_OUTPUT_FILE" ;
180 for i in $backends; do
181 do_test $i
H A Dregress_buffer.c230 for (i = 0; i < 3; ++i) { in test_evbuffer()
263 for (i = 0; i < 3; ++i) { in test_evbuffer()
680 for (i=0; i<512; ++i) in test_evbuffer_reserve2()
682 for (i=512; i<520; ++i) in test_evbuffer_reserve2()
684 for (i=520; i<521; ++i) in test_evbuffer_reserve2()
686 for (i=521; i<921; ++i) in test_evbuffer_reserve2()
690 for (i=0; i<60; ++i) in test_evbuffer_reserve2()
812 for (i = 0; i < avec; ++i) in test_evbuffer_reserve_invalid_last_with_datap()
2421 for (i = 0; i < 16; ++i) { in test_evbuffer_peek()
2677 for (i = 0; i < 4; i++) { in test_evbuffer_add_iovec()
[all …]
/libevent-2.1.12/
H A Darc4random.c106 rs.i = 0; in arc4_init()
116 rs.i--; in arc4_addrandom()
118 rs.i = (rs.i + 1); in arc4_addrandom()
180 unsigned i; in arc4_seed_getrandom() local
192 for (i=0,any_set=0; i<sizeof(buf); ++i) { in arc4_seed_getrandom()
232 for (i=any_set=0; i<sizeof(buf); ++i) { in arc4_seed_sysctl_bsd()
267 for (i=nybbles=0; i<n; ++i) { in arc4_seed_proc_sys_kernel_random_uuid()
318 int i; in arc4_seed_urandom() local
322 for (i = 0; filenames[i]; ++i) { in arc4_seed_urandom()
394 for (i = 0; i < 12*256; i++) in arc4_stir()
[all …]
H A Dpoll.c117 int i, idx; in poll_check_ok() local
120 for (i = 0; i < pop->fd_count; ++i) { in poll_check_ok()
126 for (i = 0; i < pop->nfds; ++i) { in poll_check_ok()
138 int res, i, j, nfds; in poll_dispatch() local
203 if (++i == nfds) in poll_dispatch()
204 i = 0; in poll_dispatch()
235 int i; in poll_add() local
266 if (i >= 0) { in poll_add()
269 i = pop->nfds++; in poll_add()
298 int i; in poll_del() local
[all …]
H A Dbuffer_iocp.c86 int i; in pin_release() local
89 for (i = 0; i < eo->n_buffers; ++i) { in pin_release()
103 unsigned i; in evbuffer_commit_read_() local
115 for (i = 0; remaining > 0 && i < (unsigned)buf->n_buffers; ++i) { in evbuffer_commit_read_()
177 int i; in evbuffer_launch_write_() local
205 for (i=0; i < MAX_WSABUFS && chain; ++i, chain=chain->next) { in evbuffer_launch_write_()
219 ++i; in evbuffer_launch_write_()
224 buf_o->n_buffers = i; in evbuffer_launch_write_()
250 int r = -1, i; in evbuffer_launch_read_() local
275 for (i=0;i<nvecs;++i) { in evbuffer_launch_read_()
[all …]
H A Dwin32select.c151 int i; in do_fd_clear() local
154 i = ent->read_pos_plus1 - 1; in do_fd_clear()
157 i = ent->write_pos_plus1 - 1; in do_fd_clear()
160 if (i < 0) in do_fd_clear()
162 if (--set->fd_count != (unsigned)i) { in do_fd_clear()
172 ent2->read_pos_plus1 = i+1; in do_fd_clear()
174 ent2->write_pos_plus1 = i+1; in do_fd_clear()
284 unsigned j, i; in win32_dispatch() local
339 i = 0; in win32_dispatch()
349 i = 0; in win32_dispatch()
[all …]
H A Dsignal.c137 int i; in evsig_cb() local
160 for (i = 0; i < n; ++i) { in evsig_cb()
161 ev_uint8_t sig = signals[i]; in evsig_cb()
168 for (i = 0; i < NSIG; ++i) { in evsig_cb()
169 if (ncaught[i]) in evsig_cb()
170 evmap_signal_active_(base, i, ncaught[i]); in evsig_cb()
417 int i = 0; in evsig_dealloc_() local
426 for (i = 0; i < NSIG; ++i) { in evsig_dealloc_()
427 if (i < base->sig.sh_old_max && base->sig.sh_old[i] != NULL) in evsig_dealloc_()
428 evsig_restore_handler_(base, i); in evsig_dealloc_()
H A Dkqueue.c208 int i; in kq_build_changes_list() local
211 for (i = 0; i < changelist->n_changes; ++i) { in kq_build_changes_list()
273 int i, n_changes, res; in kq_dispatch() local
334 for (i = 0; i < res; i++) { in kq_dispatch()
337 if (events[i].flags & EV_ERROR) { in kq_dispatch()
338 switch (events[i].data) { in kq_dispatch()
384 if (events[i].udata) { in kq_dispatch()
397 errno = events[i].data; in kq_dispatch()
400 } else if (events[i].filter == EVFILT_READ) { in kq_dispatch()
407 } else if (events[i].filter == EVFILT_USER) { in kq_dispatch()
[all …]
H A Devport.c258 int i, res; in evport_dispatch() local
288 for (i = 0; i < epdp->ed_npending; ++i) { in evport_dispatch()
290 const int fd = epdp->ed_pending[i]; in evport_dispatch()
325 for (i = 0; i < nevents; ++i) { in evport_dispatch()
326 port_event_t *pevt = &pevtlist[i]; in evport_dispatch()
333 epdp->ed_pending[i] = fd; in evport_dispatch()
334 fdi->pending_idx_plus_1 = i + 1; in evport_dispatch()
424 const int i = fdi->pending_idx_plus_1 - 1; in evport_del() local
425 EVUTIL_ASSERT(evpd->ed_pending[i] == fd); in evport_del()
426 evpd->ed_pending[i] = -1; in evport_del()
H A Devent.c556 for (i = 8; environment[i] != '\0'; ++i) in event_is_method_disabled()
676 for (i = 0; eventops[i] && !base->evbase; i++) { in event_base_new_with_config()
818 for (i = 0; i < base->nactivequeues; ++i) { in event_base_free_queues_()
878 for (i = 0; i < base->n_common_timeouts; ++i) { in event_base_free_()
927 for (i = 0; i < base->nactivequeues; ++i) in event_base_free_()
1268 for (i = 0; i < base->nactivequeues; ++i) { in event_base_priority_init()
1504 for (i = 0; i < base->n_common_timeouts; ++i) { in event_base_init_common_timeout()
1778 for (i = 0; i < base->nactivequeues; ++i) { in event_process_active()
2331 for (i = 0; i < n_cbs; ++i) { in event_callback_finalize_many_()
3721 for (i = 0; i < base->nactivequeues; ++i) { in event_base_foreach_event_nolock_()
[all …]
/libevent-2.1.12/sample/
H A Ddns-example.c62 int i; in main_callback() local
63 for (i = 0; i < count; ++i) { in main_callback()
67 printf("%s: %s\n", n, ((char**)addrs)[i]); in main_callback()
80 int i; in gai_callback() local
88 for (i=0; ai; ai = ai->ai_next, ++i) { in gai_callback()
95 printf("[%d] %s: %s\n",i,name,buf); in gai_callback()
101 printf("[%d] %s: %s\n",i,name,buf); in gai_callback()
112 int i, r; in evdns_server_callback() local
116 for (i = 0; i < req->nquestions; ++i) { in evdns_server_callback()
118 if (req->questions[i]->type == EVDNS_TYPE_A && in evdns_server_callback()
[all …]
H A Dhttps-client.c236 int i; in main() local
240 for (i = 1; i < argc; i++) { in main()
242 if (i < argc - 1) { in main()
243 url = argv[i + 1]; in main()
249 if (i < argc - 1) { in main()
250 crt = argv[i + 1]; in main()
258 if (i < argc - 1) { in main()
259 data_file = argv[i + 1]; in main()
265 if (i < argc - 1) { in main()
266 retries = atoi(argv[i + 1]); in main()
[all …]
H A Dle-proxy.c213 int i; in main() local
229 for (i=1; i < argc; ++i) { in main()
230 if (!strcmp(argv[i], "-s")) { in main()
232 } else if (!strcmp(argv[i], "-W")) { in main()
234 } else if (argv[i][0] == '-') { in main()
240 if (i+2 != argc) in main()
245 if (evutil_parse_sockaddr_port(argv[i], in main()
247 int p = atoi(argv[i]); in main()
259 if (evutil_parse_sockaddr_port(argv[i+1], in main()

123