Loading...
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 105 106 107 108 109 110 111 112 113 114 115 116 117 118 119 120 121 122 123 124 125 126 127 128 129 130 131 132 133 134 135 136 137 138 139 140 141 142 143 144 145 146 147 148 149 150 151 152 153 154 155 156 157 158 159 160 161 162 163 164 165 166 167 168 169 170 171 172 173 174 175 176 177 178 179 180 181 182 183 184 185 186 187 188 189 190 191 | /* * Copyright (c) 2017 Intel Corporation. * * SPDX-License-Identifier: Apache-2.0 */ #include <kernel.h> #include <zephyr.h> #include <tc_util.h> #include <ksched.h> #include "timing_info.h" extern char sline[]; K_SEM_DEFINE(sem_bench, 0, 1); K_SEM_DEFINE(sem_bench_1, 0, 1); /* To time thread creation*/ #define STACK_SIZE 500 extern K_THREAD_STACK_DEFINE(my_stack_area, STACK_SIZE); extern K_THREAD_STACK_DEFINE(my_stack_area_0, STACK_SIZE); extern struct k_thread my_thread; extern struct k_thread my_thread_0; /* u64_t thread_yield_start_tsc[1000]; */ /* u64_t thread_yield_end_tsc[1000]; */ u64_t thread_start_time; u64_t thread_end_time; u64_t sem_start_time; u64_t sem_end_time; u64_t sem_give_start_time; u64_t sem_give_end_time; u32_t swap_called; u64_t test_time2; u64_t test_time1; void thread_sem0_test(void *p1, void *p2, void *p3); void thread_sem1_test(void *p1, void *p2, void *p3); void thread_sem0_give_test(void *p1, void *p2, void *p3); void thread_sem1_give_test(void *p1, void *p2, void *p3); k_tid_t sem0_tid; k_tid_t sem1_tid; extern u64_t __common_var_swap_end_tsc; extern u32_t __read_swap_end_tsc_value; void semaphore_bench(void) { /* Thread yield*/ sem0_tid = k_thread_create(&my_thread, my_stack_area, STACK_SIZE, thread_sem0_test, NULL, NULL, NULL, 2 /*priority*/, 0, 0); sem1_tid = k_thread_create(&my_thread_0, my_stack_area_0, STACK_SIZE, thread_sem1_test, NULL, NULL, NULL, 2 /*priority*/, 0, 0); k_sleep(1000); /* u64_t test_time1 = _tsc_read(); */ sem_end_time = (__common_var_swap_end_tsc); u32_t sem_cycles = sem_end_time - sem_start_time; sem0_tid = k_thread_create(&my_thread, my_stack_area, STACK_SIZE, thread_sem0_give_test, NULL, NULL, NULL, 2 /*priority*/, 0, 0); sem1_tid = k_thread_create(&my_thread_0, my_stack_area_0, STACK_SIZE, thread_sem1_give_test, NULL, NULL, NULL, 2 /*priority*/, 0, 0); k_sleep(1000); sem_give_end_time = (__common_var_swap_end_tsc); u32_t sem_give_cycles = sem_give_end_time - sem_give_start_time; /* Semaphore without context switch*/ u32_t sem_give_wo_cxt_start = OS_GET_TIME(); k_sem_give(&sem_bench); u32_t sem_give_wo_cxt_end = OS_GET_TIME(); u32_t sem_give_wo_cxt_cycles = sem_give_wo_cxt_end - sem_give_wo_cxt_start; u32_t sem_take_wo_cxt_start = OS_GET_TIME(); k_sem_take(&sem_bench, 10); u32_t sem_take_wo_cxt_end = OS_GET_TIME(); u32_t sem_take_wo_cxt_cycles = sem_take_wo_cxt_end - sem_take_wo_cxt_start; /* TC_PRINT("test_time1 , %d cycles\n", (u32_t)test_time1); */ /* TC_PRINT("test_time2 , %d cycles\n", (u32_t)test_time2); */ PRINT_F("Semaphore Take with context switch", sem_cycles, SYS_CLOCK_HW_CYCLES_TO_NS(sem_cycles)); PRINT_F("Semaphore Give with context switch", sem_give_cycles, SYS_CLOCK_HW_CYCLES_TO_NS(sem_give_cycles)); PRINT_F("Semaphore Take without context switch", sem_take_wo_cxt_cycles, SYS_CLOCK_HW_CYCLES_TO_NS(sem_take_wo_cxt_cycles)); PRINT_F("Semaphore Give without context switch", sem_give_wo_cxt_cycles, SYS_CLOCK_HW_CYCLES_TO_NS(sem_give_wo_cxt_cycles)); } /******************************************************************************/ K_MUTEX_DEFINE(mutex0); void mutex_bench(void) { u32_t mutex_lock_start_tsc; u32_t mutex_lock_end_tsc; u32_t mutex_lock_diff = 0; u32_t mutex_unlock_start_tsc; u32_t mutex_unlock_end_tsc; u32_t mutex_unlock_diff = 0; for (int i = 0; i < 1000; i++) { mutex_lock_start_tsc = OS_GET_TIME(); k_mutex_lock(&mutex0, 100); mutex_lock_end_tsc = OS_GET_TIME(); mutex_unlock_start_tsc = OS_GET_TIME(); k_mutex_unlock(&mutex0); mutex_unlock_end_tsc = OS_GET_TIME(); mutex_lock_diff += (mutex_lock_end_tsc - mutex_lock_start_tsc); mutex_unlock_diff += (mutex_unlock_end_tsc - mutex_unlock_start_tsc); } PRINT_F("Mutex lock", mutex_lock_diff / 1000, SYS_CLOCK_HW_CYCLES_TO_NS(mutex_lock_diff / 1000)); PRINT_F("Mutex unlock", mutex_unlock_diff / 1000, SYS_CLOCK_HW_CYCLES_TO_NS(mutex_unlock_diff / 1000)); } /******************************************************************************/ void thread_sem1_test(void *p1, void *p2, void *p3) { k_sem_give(&sem_bench); /* sync the 2 threads*/ __read_swap_end_tsc_value = 1; sem_start_time = OS_GET_TIME(); k_sem_take(&sem_bench, 10); } u32_t sem_count; void thread_sem0_test(void *p1, void *p2, void *p3) { k_sem_take(&sem_bench, 10);/* To sync threads */ k_sem_give(&sem_bench); sem_count++; k_thread_abort(sem0_tid); } /******************************************************************************/ void thread_sem1_give_test(void *p1, void *p2, void *p3) { k_sem_give(&sem_bench); /* sync the 2 threads*/ k_sem_take(&sem_bench_1, 1000); /* clear the previous sem_give*/ /* test_time1 = OS_GET_TIME(); */ } void thread_sem0_give_test(void *p1, void *p2, void *p3) { k_sem_take(&sem_bench, 10);/* To sync threads */ /* test_time2 = OS_GET_TIME(); */ /* To make sure that the sem give will cause a swap to occur */ k_thread_priority_set(sem1_tid, 1); __read_swap_end_tsc_value = 1; sem_give_start_time = OS_GET_TIME(); k_sem_give(&sem_bench_1); } |