Lines Matching refs:i
270 uint32_t count = 0, i;
290 for (i = 0; i < 5; i++) {
291 reactor = spdk_reactor_get(i);
293 MOCK_SET(spdk_env_get_current_core, i);
296 CU_ASSERT(count == (i + 1));
507 uint32_t i, events;
512 for (i = 0; i < reactor_count; i++) {
513 reactor = spdk_reactor_get(i);
515 MOCK_SET(spdk_env_get_current_core, i);
541 int i;
551 for (i = 0; i < 3; i++) {
552 spdk_cpuset_set_cpu(&g_reactor_core_mask, i, true);
557 for (i = 0; i < 3; i++) {
559 spdk_cpuset_set_cpu(&cpuset, i, true);
560 thread[i] = spdk_thread_create(NULL, &cpuset);
561 CU_ASSERT(thread[i] != NULL);
562 thread_busy_tsc[i] = 0;
563 thread_idle_tsc[i] = 0;
566 for (i = 0; i < 3; i++) {
567 reactor = spdk_reactor_get(i);
569 MOCK_SET(spdk_env_get_current_core, i);
572 reactor_busy_tsc[i] = 0;
573 reactor_idle_tsc[i] = 0;
587 for (i = 0; i < 3; i++) {
588 spdk_set_thread(thread[i]);
590 reactor = spdk_reactor_get(i);
598 CU_ASSERT(spdk_thread_get_last_tsc(thread[i]) == end_time);
601 thread_busy_tsc[i] = stats.busy_tsc;
603 thread_idle_tsc[i] = stats.idle_tsc;
605 reactor_busy_tsc[i] = reactor->busy_tsc;
607 reactor_idle_tsc[i] = reactor->idle_tsc;
622 for (i = 0; i < 3; i++) {
623 reactor = spdk_reactor_get(i);
628 CU_ASSERT(reactor->busy_tsc == reactor_busy_tsc[i]);
629 CU_ASSERT(reactor->idle_tsc == reactor_idle_tsc[i]);
630 spdk_set_thread(thread[i]);
631 CU_ASSERT(spdk_thread_get_last_tsc(thread[i]) == current_time);
633 CU_ASSERT(stats.busy_tsc == thread_busy_tsc[i]);
634 CU_ASSERT(stats.idle_tsc == thread_idle_tsc[i]);
665 for (i = 0; i < 3; i++) {
666 spdk_set_thread(thread[i]);
673 CU_ASSERT(spdk_thread_get_last_tsc(thread[i]) == current_time);
675 CU_ASSERT(stats.busy_tsc == thread_busy_tsc[i] + busy_time);
676 CU_ASSERT(stats.idle_tsc == thread_idle_tsc[i] + idle_time);;
690 for (i = 0; i < 3; i++) {
691 MOCK_SET(spdk_env_get_current_core, i);
692 reactor = spdk_reactor_get(i);
697 for (i = 0; i < 3; i++) {
698 reactor = spdk_reactor_get(i);
706 for (i = 0; i < 3; i++) {
707 spdk_set_thread(thread[i]);
708 spdk_thread_exit(thread[i]);
710 for (i = 0; i < 3; i++) {
711 reactor = spdk_reactor_get(i);
736 int i;
746 for (i = 0; i < 3; i++) {
747 spdk_cpuset_set_cpu(&g_reactor_core_mask, i, true);
752 for (i = 0; i < 3; i++) {
754 spdk_cpuset_set_cpu(&cpuset, i, true);
755 thread[i] = spdk_thread_create(NULL, &cpuset);
756 CU_ASSERT(thread[i] != NULL);
757 thread_busy_tsc[i] = 0;
758 thread_idle_tsc[i] = 0;
761 for (i = 0; i < 3; i++) {
762 reactor = spdk_reactor_get(i);
764 MOCK_SET(spdk_env_get_current_core, i);
767 reactor_busy_tsc[i] = 0;
768 reactor_idle_tsc[i] = 0;
782 for (i = 0; i < 3; i++) {
783 spdk_set_thread(thread[i]);
785 reactor = spdk_reactor_get(i);
793 CU_ASSERT(spdk_thread_get_last_tsc(thread[i]) == end_time);
796 thread_busy_tsc[i] = stats.busy_tsc;
798 thread_idle_tsc[i] = stats.idle_tsc;
800 reactor_busy_tsc[i] = reactor->busy_tsc;
802 reactor_idle_tsc[i] = reactor->idle_tsc;
819 for (i = 0; i < 3; i++) {
820 reactor = spdk_reactor_get(i);
825 CU_ASSERT(reactor->busy_tsc == reactor_busy_tsc[i]);
826 CU_ASSERT(reactor->idle_tsc == reactor_idle_tsc[i]);
827 spdk_set_thread(thread[i]);
828 CU_ASSERT(spdk_thread_get_last_tsc(thread[i]) == current_time);
830 CU_ASSERT(stats.busy_tsc == thread_busy_tsc[i]);
831 CU_ASSERT(stats.idle_tsc == thread_idle_tsc[i]);
858 for (i = 0; i < 3; i++) {
859 spdk_set_thread(thread[i]);
860 spdk_thread_exit(thread[i]);
862 for (i = 0; i < 3; i++) {
863 reactor = spdk_reactor_get(i);
935 int i;
949 for (i = 0; i < 2; i++) {
950 spdk_cpuset_set_cpu(&g_reactor_core_mask, i, true);
954 for (i = 0; i < 2; i++) {
956 spdk_cpuset_set_cpu(&cpuset, i, true);
957 thread[i] = spdk_thread_create(NULL, &cpuset);
958 CU_ASSERT(thread[i] != NULL);
961 for (i = 0; i < 2; i++) {
962 reactor = spdk_reactor_get(i);
964 MOCK_SET(spdk_env_get_current_core, i);
980 for (i = 0; i < 2; i++) {
981 spdk_set_thread(thread[i]);
983 reactor = spdk_reactor_get(i);
985 MOCK_SET(spdk_env_get_current_core, i);
990 lw_thread = spdk_thread_get_ctx(thread[i]);
1001 for (i = 0; i < 2; i++) {
1002 reactor = spdk_reactor_get(i);
1034 i = _run_events_till_completion(2);
1036 CU_ASSERT(i == 7 || i == 3);
1059 i = _run_events_till_completion(2);
1061 CU_ASSERT(i == 7 || i == 3);
1064 for (i = 0; i < 2; i++) {
1065 reactor = spdk_reactor_get(i);
1076 for (i = 0; i < 2; i++) {
1077 spdk_set_thread(thread[i]);
1078 spdk_thread_exit(thread[i]);
1080 for (i = 0; i < 2; i++) {
1081 reactor = spdk_reactor_get(i);
1179 uint64_t i, busy_count, idle_count, rc;
1200 for (i = 1; i <= 3; i++) {
1201 while (spdk_thread_get_last_tsc(thread) < i * workload.scheduling_period) {
1213 CU_ASSERT(spdk_thread_get_last_tsc(thread) == i * workload.scheduling_period);