Lines Matching refs:i
104 int i = 0; in basic_thread() local
112 for (i = 0; i < NUM_ITERATIONS; i++) { in basic_thread()
172 int i; in thread_basic() local
228 for (i = 0; i < NUM_THREADS; ++i) in thread_basic()
229 THREAD_START(threads[i], basic_thread, base); in thread_basic()
238 for (i = 0; i < NUM_THREADS; ++i) in thread_basic()
239 THREAD_JOIN(threads[i]); in thread_basic()
296 int i; in thread_conditions_simple() local
313 for (i = 0; i < NUM_THREADS; ++i) { in thread_conditions_simple()
314 memset(&alerted[i], 0, sizeof(struct alerted_record)); in thread_conditions_simple()
315 alerted[i].cond = &cond; in thread_conditions_simple()
328 for (i = 0; i < NUM_THREADS; ++i) { in thread_conditions_simple()
329 THREAD_START(threads[i], wait_for_condition, &alerted[i]); in thread_conditions_simple()
340 for (i = 0; i < NUM_THREADS; ++i) in thread_conditions_simple()
341 THREAD_JOIN(threads[i]); in thread_conditions_simple()
349 for (i = 0; i < NUM_THREADS; ++i) { in thread_conditions_simple()
352 if (alerted[i].timed_out) { in thread_conditions_simple()
353 TT_BLATHER(("%d looks like a timeout\n", i)); in thread_conditions_simple()
355 tt_assert(i == 5 || i == 6); in thread_conditions_simple()
356 } else if (evutil_timerisset(&alerted[i].alerted_at)) { in thread_conditions_simple()
358 evutil_timersub(&alerted[i].alerted_at, in thread_conditions_simple()
365 TT_BLATHER(("%d looks like a signal\n", i)); in thread_conditions_simple()
369 TT_BLATHER(("%d looks like a broadcast\n", i)); in thread_conditions_simple()
374 TT_FAIL(("Thread %d never got woken", i)); in thread_conditions_simple()
378 test_timeval_diff_leq(&target_time, &alerted[i].alerted_at, in thread_conditions_simple()
423 size_t i; in load_deferred_queue() local
425 for (i = 0; i < CB_COUNT; ++i) { in load_deferred_queue()
426 event_deferred_cb_init_(&data->cbs[i], 0, deferred_callback, in load_deferred_queue()
428 event_deferred_cb_schedule_(data->queue, &data->cbs[i]); in load_deferred_queue()
444 int i; in start_threads_callback() local
446 for (i = 0; i < QUEUE_THREAD_COUNT; ++i) { in start_threads_callback()
447 THREAD_START(load_threads[i], load_deferred_queue, in start_threads_callback()
448 &deferred_data[i]); in start_threads_callback()
460 int i; in thread_deferred_cb_skew() local
469 for (i = 0; i < QUEUE_THREAD_COUNT; ++i) in thread_deferred_cb_skew()
470 deferred_data[i].queue = base; in thread_deferred_cb_skew()
490 for (i = 0; i < QUEUE_THREAD_COUNT; ++i) in thread_deferred_cb_skew()
491 THREAD_JOIN(load_threads[i]); in thread_deferred_cb_skew()
534 int i; in thread_no_events() local
538 for (i=0;i<5;++i) { in thread_no_events()
539 event_assign(&time_events[i], data->base, in thread_no_events()
540 -1, 0, note_time_cb, ×[i]); in thread_no_events()
549 for (i=0; i<5; ++i) { in thread_no_events()
552 evutil_timersub(×[i], &starttime, &diff); in thread_no_events()
554 TT_BLATHER(("event %d at %.4f seconds", i, sec)); in thread_no_events()