Go to the documentation of this file.
26 #ifndef SURICATA_THREADS_PROFILE_H
27 #define SURICATA_THREADS_PROFILE_H
32 #define PROFILING_MAX_LOCKS 64
63 #define SCMutexLock_profile(mut) ({ \
67 uint64_t mutex_lock_start = UtilCpuGetTicks(); \
68 if (pthread_mutex_trylock((mut)) != 0) { \
69 mutex_lock_contention++; \
71 retl = pthread_mutex_lock(mut); \
73 uint64_t mutex_lock_end = UtilCpuGetTicks(); \
74 mutex_lock_wait_ticks += (uint64_t)(mutex_lock_end - mutex_lock_start); \
76 if (locks_idx < PROFILING_MAX_LOCKS && record_locks) { \
77 locks[locks_idx].file = (char *)__FILE__; \
78 locks[locks_idx].func = (char *)__func__; \
79 locks[locks_idx].line = (int)__LINE__; \
80 locks[locks_idx].type = LOCK_MUTEX; \
81 locks[locks_idx].cont = cont; \
82 locks[locks_idx].ticks = (uint64_t)(mutex_lock_end - mutex_lock_start); \
88 #define SCMutex pthread_mutex_t
89 #define SCMutexAttr pthread_mutexattr_t
90 #define SCMutexInit(mut, mutattr ) pthread_mutex_init(mut, mutattr)
91 #define SCMutexLock(mut) SCMutexLock_profile(mut)
92 #define SCMutexTrylock(mut) pthread_mutex_trylock(mut)
93 #define SCMutexIsLocked(mut) (SCMutexTrylock(mut) == EBUSY)
94 #define SCMutexUnlock(mut) pthread_mutex_unlock(mut)
95 #define SCMutexDestroy pthread_mutex_destroy
96 #define SCMUTEX_INITIALIZER PTHREAD_MUTEX_INITIALIZER
100 #define SCCondT pthread_cond_t
101 #define SCCondInit pthread_cond_init
102 #define SCCondSignal pthread_cond_signal
103 #define SCCondDestroy pthread_cond_destroy
104 #define SCCondWait(cond, mut) pthread_cond_wait(cond, mut)
113 #define SCSpinLock_profile(spin) ({ \
117 uint64_t spin_lock_start = UtilCpuGetTicks(); \
118 if (pthread_spin_trylock((spin)) != 0) { \
119 spin_lock_contention++; \
121 retl = pthread_spin_lock((spin)); \
123 uint64_t spin_lock_end = UtilCpuGetTicks(); \
124 spin_lock_wait_ticks += (uint64_t)(spin_lock_end - spin_lock_start); \
126 if (locks_idx < PROFILING_MAX_LOCKS && record_locks) { \
127 locks[locks_idx].file = (char *)__FILE__; \
128 locks[locks_idx].func = (char *)__func__; \
129 locks[locks_idx].line = (int)__LINE__; \
130 locks[locks_idx].type = LOCK_SPIN; \
131 locks[locks_idx].cont = cont; \
132 locks[locks_idx].ticks = (uint64_t)(spin_lock_end - spin_lock_start); \
138 #define SCSpinlock pthread_spinlock_t
139 #define SCSpinLock(mut) SCSpinLock_profile(mut)
140 #define SCSpinTrylock(spin) pthread_spin_trylock(spin)
141 #define SCSpinUnlock(spin) pthread_spin_unlock(spin)
142 #define SCSpinInit(spin, spin_attr) pthread_spin_init(spin, spin_attr)
143 #define SCSpinDestroy(spin) pthread_spin_destroy(spin)
151 #define SCRWLockWRLock_profile(mut) ({ \
155 uint64_t rww_lock_start = UtilCpuGetTicks(); \
156 if (pthread_rwlock_trywrlock((mut)) != 0) { \
157 rww_lock_contention++; \
159 retl = pthread_rwlock_wrlock(mut); \
161 uint64_t rww_lock_end = UtilCpuGetTicks(); \
162 rww_lock_wait_ticks += (uint64_t)(rww_lock_end - rww_lock_start); \
164 if (locks_idx < PROFILING_MAX_LOCKS && record_locks) { \
165 locks[locks_idx].file = (char *)__FILE__; \
166 locks[locks_idx].func = (char *)__func__; \
167 locks[locks_idx].line = (int)__LINE__; \
168 locks[locks_idx].type = LOCK_RWW; \
169 locks[locks_idx].cont = cont; \
170 locks[locks_idx].ticks = (uint64_t)(rww_lock_end - rww_lock_start); \
180 #define SCRWLockRDLock_profile(mut) ({ \
184 uint64_t rwr_lock_start = UtilCpuGetTicks(); \
185 if (pthread_rwlock_tryrdlock((mut)) != 0) { \
186 rwr_lock_contention++; \
188 retl = pthread_rwlock_rdlock(mut); \
190 uint64_t rwr_lock_end = UtilCpuGetTicks(); \
191 rwr_lock_wait_ticks += (uint64_t)(rwr_lock_end - rwr_lock_start); \
193 if (locks_idx < PROFILING_MAX_LOCKS && record_locks) { \
194 locks[locks_idx].file = (char *)__FILE__; \
195 locks[locks_idx].func = (char *)__func__; \
196 locks[locks_idx].line = (int)__LINE__; \
197 locks[locks_idx].type = LOCK_RWR; \
198 locks[locks_idx].cont = cont; \
199 locks[locks_idx].ticks = (uint64_t)(rwr_lock_end - rwr_lock_start); \
205 #define SCRWLock pthread_rwlock_t
206 #define SCRWLockInit(rwl, rwlattr ) pthread_rwlock_init(rwl, rwlattr)
207 #define SCRWLockWRLock(mut) SCRWLockWRLock_profile(mut)
208 #define SCRWLockRDLock(mut) SCRWLockRDLock_profile(mut)
209 #define SCRWLockTryWRLock(rwl) pthread_rwlock_trywrlock(rwl)
210 #define SCRWLockTryRDLock(rwl) pthread_rwlock_tryrdlock(rwl)
211 #define SCRWLockUnlock(rwl) pthread_rwlock_unlock(rwl)
212 #define SCRWLockDestroy pthread_rwlock_destroy
215 #define SCCtrlMutex pthread_mutex_t
216 #define SCCtrlMutexAttr pthread_mutexattr_t
217 #define SCCtrlMutexInit(mut, mutattr ) pthread_mutex_init(mut, mutattr)
218 #define SCCtrlMutexLock(mut) pthread_mutex_lock(mut)
219 #define SCCtrlMutexTrylock(mut) pthread_mutex_trylock(mut)
220 #define SCCtrlMutexUnlock(mut) pthread_mutex_unlock(mut)
221 #define SCCtrlMutexDestroy pthread_mutex_destroy
224 #define SCCtrlCondT pthread_cond_t
225 #define SCCtrlCondInit pthread_cond_init
226 #define SCCtrlCondSignal pthread_cond_signal
227 #define SCCtrlCondTimedwait pthread_cond_timedwait
228 #define SCCtrlCondWait pthread_cond_wait
229 #define SCCtrlCondDestroy pthread_cond_destroy
thread_local uint64_t spin_lock_cnt
thread_local int record_locks
thread_local uint64_t rwr_lock_cnt
thread_local ProfilingLock locks[PROFILING_MAX_LOCKS]
thread_local uint64_t rww_lock_contention
thread_local uint64_t rwr_lock_contention
thread_local uint64_t spin_lock_wait_ticks
thread_local uint64_t rww_lock_cnt
thread_local uint64_t mutex_lock_contention
thread_local uint64_t spin_lock_contention
thread_local int locks_idx
struct ProfilingLock_ ProfilingLock
thread_local uint64_t rww_lock_wait_ticks
#define PROFILING_MAX_LOCKS
thread_local uint64_t rwr_lock_wait_ticks
thread_local uint64_t mutex_lock_wait_ticks
thread_local uint64_t mutex_lock_cnt