| /external/compiler-rt/lib/tsan/rtl/ |
| D | tsan_rtl.h | 337 ThreadState *thr; // currently wired thread, or nullptr
359 struct ThreadState { struct
440 explicit ThreadState(Context *ctx, int tid, int unique_id, u64 epoch, argument
448 ThreadState *cur_thread();
453 INLINE ThreadState *cur_thread() { in cur_thread()
454 return reinterpret_cast<ThreadState *>(&cur_thread_placeholder); in cur_thread()
464 ThreadState *thr;
591 void ObtainCurrentStack(ThreadState *thr, uptr toppc, StackTraceTy *stack) { in ObtainCurrentStack()
607 void ALWAYS_INLINE StatInc(ThreadState *thr, StatType typ, u64 n = 1) {
612 void ALWAYS_INLINE StatSet(ThreadState *thr, StatType typ, u64 n) { in StatSet()
[all …]
|
| D | tsan_fd.h | 42 void FdAcquire(ThreadState *thr, uptr pc, int fd);
43 void FdRelease(ThreadState *thr, uptr pc, int fd);
44 void FdAccess(ThreadState *thr, uptr pc, int fd);
45 void FdClose(ThreadState *thr, uptr pc, int fd, bool write = true);
46 void FdFileCreate(ThreadState *thr, uptr pc, int fd);
47 void FdDup(ThreadState *thr, uptr pc, int oldfd, int newfd, bool write);
48 void FdPipeCreate(ThreadState *thr, uptr pc, int rfd, int wfd);
49 void FdEventCreate(ThreadState *thr, uptr pc, int fd);
50 void FdSignalCreate(ThreadState *thr, uptr pc, int fd);
51 void FdInotifyCreate(ThreadState *thr, uptr pc, int fd);
[all …]
|
| D | tsan_platform_mac.cc | 74 ALIGNED(64) static char main_thread_state[sizeof(ThreadState)];
76 ThreadState *cur_thread() { in cur_thread()
79 return (ThreadState *)&main_thread_state; in cur_thread()
81 ThreadState **fake_tls = (ThreadState **)MemToShadow(thread_identity); in cur_thread()
82 ThreadState *thr = (ThreadState *)SignalSafeGetOrAllocate( in cur_thread()
83 (uptr *)fake_tls, sizeof(ThreadState)); in cur_thread()
97 ThreadState **fake_tls = (ThreadState **)MemToShadow(thread_identity); in cur_thread_finalize()
98 internal_munmap(*fake_tls, sizeof(ThreadState)); in cur_thread_finalize()
136 ThreadState *thr = cur_thread(); in my_pthread_introspection_hook()
139 ThreadState *parent_thread_state = nullptr; // No parent. in my_pthread_introspection_hook()
[all …]
|
| D | tsan_fd.cc | 50 static FdSync *allocsync(ThreadState *thr, uptr pc) { in allocsync()
63 static void unref(ThreadState *thr, uptr pc, FdSync *s) { in unref()
74 static FdDesc *fddesc(ThreadState *thr, uptr pc, int fd) { in fddesc()
94 static void init(ThreadState *thr, uptr pc, int fd, FdSync *s, in init()
128 void FdOnFork(ThreadState *thr, uptr pc) { in FdOnFork()
160 void FdAcquire(ThreadState *thr, uptr pc, int fd) { in FdAcquire()
171 void FdRelease(ThreadState *thr, uptr pc, int fd) { in FdRelease()
182 void FdAccess(ThreadState *thr, uptr pc, int fd) { in FdAccess()
190 void FdClose(ThreadState *thr, uptr pc, int fd, bool write) { in FdClose()
218 void FdFileCreate(ThreadState *thr, uptr pc, int fd) { in FdFileCreate()
[all …]
|
| D | tsan_rtl_thread.cc | 43 ThreadState *caller_thr = static_cast<ThreadState *>(arg); in OnJoined()
49 ThreadState *thr;
76 ThreadState *thr1 = static_cast<ThreadState*>(arg); in OnDetached()
81 ThreadState *thr;
95 new(thr) ThreadState(ctx, tid, unique_id, epoch0, reuse_count, in OnStarted()
138 thr->~ThreadState(); in OnFinished()
185 static void ThreadCheckIgnore(ThreadState *thr) { in ThreadCheckIgnore()
194 static void ThreadCheckIgnore(ThreadState *thr) {} in ThreadCheckIgnore()
197 void ThreadFinalize(ThreadState *thr) { in ThreadFinalize()
215 int ThreadCount(ThreadState *thr) { in ThreadCount()
[all …]
|
| D | tsan_mman.cc | 83 ThreadState *thr = cur_thread(); in ScopedGlobalProcessor()
106 ThreadState *thr = cur_thread(); in ~ScopedGlobalProcessor()
135 static void SignalUnsafeCall(ThreadState *thr, uptr pc) { in SignalUnsafeCall()
149 void *user_alloc(ThreadState *thr, uptr pc, uptr sz, uptr align, bool signal) { in user_alloc()
162 void *user_calloc(ThreadState *thr, uptr pc, uptr size, uptr n) { in user_calloc()
171 void user_free(ThreadState *thr, uptr pc, void *p, bool signal) { in user_free()
180 void OnUserAlloc(ThreadState *thr, uptr pc, uptr p, uptr sz, bool write) { in OnUserAlloc()
189 void OnUserFree(ThreadState *thr, uptr pc, uptr p, bool write) { in OnUserFree()
197 void *user_realloc(ThreadState *thr, uptr pc, void *p, uptr sz) { in user_realloc()
227 ThreadState *thr = cur_thread(); in invoke_malloc_hook()
[all …]
|
| D | tsan_rtl_mutex.cc | 26 void ReportDeadlock(ThreadState *thr, uptr pc, DDReport *r);
29 ThreadState *thr;
32 Callback(ThreadState *thr, uptr pc) in Callback()
43 void DDMutexInit(ThreadState *thr, uptr pc, SyncVar *s) { in DDMutexInit()
49 static void ReportMutexMisuse(ThreadState *thr, uptr pc, ReportType typ, in ReportMutexMisuse()
65 void MutexCreate(ThreadState *thr, uptr pc, uptr addr, in MutexCreate()
84 void MutexDestroy(ThreadState *thr, uptr pc, uptr addr) { in MutexDestroy()
144 void MutexLock(ThreadState *thr, uptr pc, uptr addr, int rec, bool try_lock) { in MutexLock()
189 int MutexUnlock(ThreadState *thr, uptr pc, uptr addr, bool all) { in MutexUnlock()
232 void MutexReadLock(ThreadState *thr, uptr pc, uptr addr, bool trylock) { in MutexReadLock()
[all …]
|
| D | tsan_platform_linux.cc | 353 static ThreadState *dead_thread_state = nullptr;
355 ThreadState *cur_thread() { in cur_thread()
356 ThreadState* thr = (ThreadState*)__get_tls()[TLS_SLOT_TSAN]; in cur_thread()
362 thr = reinterpret_cast<ThreadState*>(__get_tls()[TLS_SLOT_TSAN]); in cur_thread()
364 thr = reinterpret_cast<ThreadState*>(MmapOrDie(sizeof(ThreadState), in cur_thread()
368 dead_thread_state = reinterpret_cast<ThreadState*>( in cur_thread()
369 MmapOrDie(sizeof(ThreadState), "ThreadState")); in cur_thread()
374 CHECK_EQ(0, internal_mprotect(dead_thread_state, sizeof(ThreadState), in cur_thread()
388 ThreadState* thr = (ThreadState*)__get_tls()[TLS_SLOT_TSAN]; in cur_thread_finalize()
391 UnmapOrDie(thr, sizeof(ThreadState)); in cur_thread_finalize()
|
| D | tsan_rtl.cc | 48 THREADLOCAL char cur_thread_placeholder[sizeof(ThreadState)] ALIGNED(64);
110 ThreadState::ThreadState(Context *ctx, int tid, int unique_id, u64 epoch, in ThreadState() function in __tsan::ThreadState
308 void Initialize(ThreadState *thr) { in Initialize()
387 int Finalize(ThreadState *thr) { in Finalize()
438 void ForkBefore(ThreadState *thr, uptr pc) { in ForkBefore()
443 void ForkParentAfter(ThreadState *thr, uptr pc) { in ForkParentAfter()
448 void ForkChildAfter(ThreadState *thr, uptr pc) { in ForkChildAfter()
472 void GrowShadowStack(ThreadState *thr) { in GrowShadowStack()
485 u32 CurrentStackId(ThreadState *thr, uptr pc) { in CurrentStackId()
505 void TraceSwitch(ThreadState *thr) { in TraceSwitch()
[all …]
|
| D | tsan_mman.h | 30 void *user_alloc(ThreadState *thr, uptr pc, uptr sz,
32 void *user_calloc(ThreadState *thr, uptr pc, uptr sz, uptr n);
34 void user_free(ThreadState *thr, uptr pc, void *p, bool signal = true);
35 void *user_realloc(ThreadState *thr, uptr pc, void *p, uptr sz);
36 void *user_alloc_aligned(ThreadState *thr, uptr pc, uptr sz, uptr align);
|
| D | tsan_interface_atomic.cc | 223 static T AtomicLoad(ThreadState *thr, uptr pc, const volatile T *a, in AtomicLoad()
253 static void AtomicStore(ThreadState *thr, uptr pc, volatile T *a, T v, in AtomicStore()
276 static T AtomicRMW(ThreadState *thr, uptr pc, volatile T *a, T v, morder mo) { in AtomicRMW()
333 static T AtomicExchange(ThreadState *thr, uptr pc, volatile T *a, T v, in AtomicExchange()
339 static T AtomicFetchAdd(ThreadState *thr, uptr pc, volatile T *a, T v, in AtomicFetchAdd()
345 static T AtomicFetchSub(ThreadState *thr, uptr pc, volatile T *a, T v, in AtomicFetchSub()
351 static T AtomicFetchAnd(ThreadState *thr, uptr pc, volatile T *a, T v, in AtomicFetchAnd()
357 static T AtomicFetchOr(ThreadState *thr, uptr pc, volatile T *a, T v, in AtomicFetchOr()
363 static T AtomicFetchXor(ThreadState *thr, uptr pc, volatile T *a, T v, in AtomicFetchXor()
369 static T AtomicFetchNand(ThreadState *thr, uptr pc, volatile T *a, T v, in AtomicFetchNand()
[all …]
|
| D | tsan_sync.h | 49 void Init(ThreadState *thr, uptr pc, uptr addr, u64 uid);
74 void AllocBlock(ThreadState *thr, uptr pc, uptr p, uptr sz);
80 SyncVar* GetOrCreateAndLock(ThreadState *thr, uptr pc,
98 SyncVar* GetAndLock(ThreadState *thr, uptr pc, uptr addr, bool write_lock,
|
| D | tsan_interface.h | 167 struct ThreadState;
347 void __tsan_go_atomic32_load(ThreadState *thr, uptr cpc, uptr pc, u8 *a);
349 void __tsan_go_atomic64_load(ThreadState *thr, uptr cpc, uptr pc, u8 *a);
351 void __tsan_go_atomic32_store(ThreadState *thr, uptr cpc, uptr pc, u8 *a);
353 void __tsan_go_atomic64_store(ThreadState *thr, uptr cpc, uptr pc, u8 *a);
355 void __tsan_go_atomic32_fetch_add(ThreadState *thr, uptr cpc, uptr pc, u8 *a);
357 void __tsan_go_atomic64_fetch_add(ThreadState *thr, uptr cpc, uptr pc, u8 *a);
359 void __tsan_go_atomic32_exchange(ThreadState *thr, uptr cpc, uptr pc, u8 *a);
361 void __tsan_go_atomic64_exchange(ThreadState *thr, uptr cpc, uptr pc, u8 *a);
363 void __tsan_go_atomic32_compare_exchange(ThreadState *thr, uptr cpc, uptr pc,
[all …]
|
| D | tsan_interceptors.h | 11 ScopedInterceptor(ThreadState *thr, const char *fname, uptr pc);
16 ThreadState *const thr_;
24 ThreadState *thr = cur_thread(); \
|
| D | tsan_sync.cc | 20 void DDMutexInit(ThreadState *thr, uptr pc, SyncVar *s);
27 void SyncVar::Init(ThreadState *thr, uptr pc, uptr addr, u64 uid) { in Init()
63 void MetaMap::AllocBlock(ThreadState *thr, uptr pc, uptr p, uptr sz) { in AllocBlock()
196 SyncVar* MetaMap::GetOrCreateAndLock(ThreadState *thr, uptr pc, in GetOrCreateAndLock()
205 SyncVar* MetaMap::GetAndLock(ThreadState *thr, uptr pc, in GetAndLock()
|
| D | tsan_interceptors.cc | 241 static ThreadSignalContext *SigCtx(ThreadState *thr) { in SigCtx()
255 ScopedInterceptor::ScopedInterceptor(ThreadState *thr, const char *fname, in ScopedInterceptor()
322 explicit BlockingCall(ThreadState *thr) in BlockingCall()
345 ThreadState *thr;
378 ThreadState *thr = cur_thread(); in at_exit_wrapper()
386 static int setup_at_exit_wrapper(ThreadState *thr, uptr pc, void(*f)(),
407 static int setup_at_exit_wrapper(ThreadState *thr, uptr pc, void(*f)(), in setup_at_exit_wrapper()
423 ThreadState *thr = cur_thread(); in on_exit_wrapper()
449 static void JmpBufGarbageCollect(ThreadState *thr, uptr sp) { in JmpBufGarbageCollect()
461 static void SetJmp(ThreadState *thr, uptr sp, uptr mangled_sp) { in SetJmp()
[all …]
|
| /external/compiler-rt/lib/tsan/go/ |
| D | tsan_go.cc | 113 static ThreadState *main_thr;
128 Processor *ThreadState::proc() { in proc()
134 static ThreadState *AllocGoroutine() { in AllocGoroutine()
135 ThreadState *thr = (ThreadState*)internal_alloc(MBlockThreadContex, in AllocGoroutine()
136 sizeof(ThreadState)); in AllocGoroutine()
141 void __tsan_init(ThreadState **thrp, Processor **procp, in __tsan_init()
144 ThreadState *thr = AllocGoroutine(); in __tsan_init()
153 ThreadState *thr = main_thr; in __tsan_fini()
162 void __tsan_read(ThreadState *thr, void *addr, void *pc) { in __tsan_read()
166 void __tsan_read_pc(ThreadState *thr, void *addr, uptr callpc, uptr pc) { in __tsan_read_pc()
[all …]
|
| /external/v8/src/ |
| D | v8threads.cc | 115 lazily_archived_thread_state_->LinkInto(ThreadState::FREE_LIST); in RestoreThread()
137 ThreadState* state = per_thread->thread_state(); in RestoreThread()
153 state->LinkInto(ThreadState::FREE_LIST); in RestoreThread()
181 ThreadState::ThreadState(ThreadManager* thread_manager) in ThreadState() function in v8::internal::ThreadState
189 ThreadState::~ThreadState() { in ~ThreadState()
194 void ThreadState::AllocateSpace() { in AllocateSpace()
199 void ThreadState::Unlink() { in Unlink()
205 void ThreadState::LinkInto(List list) { in LinkInto()
206 ThreadState* flying_anchor = in LinkInto()
216 ThreadState* ThreadManager::GetFreeThreadState() { in GetFreeThreadState()
[all …]
|
| D | v8threads.h | 16 class ThreadState {
19 ThreadState* Next();
40 explicit ThreadState(ThreadManager* thread_manager);
41 ~ThreadState();
48 ThreadState* next_;
49 ThreadState* previous_;
87 ThreadState* FirstThreadStateInUse();
88 ThreadState* GetFreeThreadState();
94 void DeleteThreadStateList(ThreadState* anchor);
101 ThreadState* lazily_archived_thread_state_;
[all …]
|
| /external/grpc-grpc/src/core/lib/gprpp/ |
| D | fork.cc | 111 class ThreadState { class
113 ThreadState() : awaiting_threads_(false), threads_done_(false), count_(0) { in ThreadState() function in grpc_core::internal::ThreadState
144 ~ThreadState() { in ~ThreadState()
194 thread_state_ = grpc_core::New<internal::ThreadState>(); in GlobalInit()
264 internal::ThreadState* Fork::thread_state_ = nullptr;
|
| D | fork.h | 31 class ThreadState; variable
80 static internal::ThreadState* thread_state_;
|
| /external/compiler-rt/lib/tsan/tests/unit/ |
| D | tsan_mman_test.cc | 38 ThreadState *thr = cur_thread(); in TEST()
52 ThreadState *thr = cur_thread(); in TEST()
97 ThreadState *thr = cur_thread(); in TEST()
110 ThreadState *thr = cur_thread(); in TEST()
144 ThreadState *thr = cur_thread(); in TEST()
|
| D | tsan_sync_test.cc | 20 ThreadState *thr = cur_thread(); in TEST()
35 ThreadState *thr = cur_thread(); in TEST()
52 ThreadState *thr = cur_thread(); in TEST()
75 ThreadState *thr = cur_thread(); in TEST()
112 ThreadState *thr = cur_thread(); in TEST()
|
| /external/grpc-grpc/src/core/lib/iomgr/ |
| D | executor.cc | 102 thd_state_ = static_cast<ThreadState*>( in SetThreading()
103 gpr_zalloc(sizeof(ThreadState) * max_threads_)); in SetThreading()
159 ThreadState* ts = static_cast<ThreadState*>(arg); in ThreadMain()
223 ThreadState* ts = (ThreadState*)gpr_tls_get(&g_this_thread_state); in Enqueue()
231 ThreadState* orig_ts = ts; in Enqueue()
|
| D | executor.h | 38 } ThreadState; typedef
70 ThreadState* thd_state_;
|