/external/valgrind/main/drd/tests/ |
H A D | pth_create_glibc_2_0.c | 28 pthread_t thr; local 30 result = (*pthread_create_glibc_2_0)(&thr, 0, thread_func, 0); 36 pthread_join(thr, 0);
|
/external/valgrind/main/helgrind/ |
H A D | hg_lock_n_thread.c | 48 inline Bool HG_(is_sane_Thread) ( Thread* thr ) { 49 return thr != NULL && thr->magic == Thread_MAGIC; 54 Thread* thr; local 57 while (VG_(nextIterBag)( bag, (Word*)&thr, &count )) { 59 if (!HG_(is_sane_Thread)(thr)) return False;
|
H A D | hg_errors.c | 295 Thread* thr; member in struct:__anon15092::__anon15093::__anon15094 316 Thread* thr; /* doing the unlocking */ member in struct:__anon15092::__anon15093::__anon15095 320 Thread* thr; /* doing the unlocking */ member in struct:__anon15092::__anon15093::__anon15096 325 Thread* thr; /* doing the unlocking */ member in struct:__anon15092::__anon15093::__anon15097 329 Thread* thr; member in struct:__anon15092::__anon15093::__anon15098 335 Thread* thr; member in struct:__anon15092::__anon15093::__anon15099 351 Thread* thr; member in struct:__anon15092::__anon15093::__anon15100 396 tl_assert(xe->XE.Race.thr); 400 xe->XE.Race.thr->locksetW, 469 Thr* acc_thr = xe->XE.Race.thr 504 record_error_Race( Thread* thr, Addr data_addr, Int szB, Bool isWrite, Thread* h1_ct, ExeContext* h1_ct_segstart, ExeContext* h1_ct_mbsegendEC ) argument 564 record_error_UnlockUnlocked( Thread* thr, Lock* lk ) argument 582 record_error_UnlockForeign( Thread* thr, Thread* owner, Lock* lk ) argument 602 record_error_UnlockBogus( Thread* thr, Addr lock_ga ) argument 617 record_error_LockOrder( Thread* thr, Addr shouldbe_earlier_ga, Addr shouldbe_later_ga, ExeContext* shouldbe_earlier_ec, ExeContext* shouldbe_later_ec, ExeContext* actual_earlier_ec ) argument 644 record_error_PthAPIerror( Thread* thr, HChar* fnname, Word err, HChar* errstr ) argument 664 record_error_Misc_w_aux( Thread* thr, HChar* errstr, HChar* auxstr, ExeContext* auxctx ) argument 683 record_error_Misc( Thread* thr, HChar* errstr ) argument [all...] |
/external/valgrind/main/helgrind/tests/ |
H A D | bar_trivial.c | 38 pthread_t thr[NTHR]; local 44 r = pthread_create(&thr[i], NULL, child_fn, (void*)i); 49 r = pthread_join(thr[i], NULL);
|
H A D | tc17_sembar.c | 190 pthread_t thr[4]; local 196 res = pthread_create( &thr[i], NULL, child, (void*)(i+2) ); 201 res = pthread_join( thr[i], NULL );
|
/external/compiler-rt/lib/tsan/tests/unit/ |
H A D | tsan_sync_test.cc | 29 ThreadState *thr = cur_thread(); local 39 SyncVar *v = tab.GetOrCreateAndLock(thr, pc, addr, true); 46 SyncVar *v = tab.GetAndRemove(thr, pc, addr); 58 SyncVar *v = tab.GetAndRemove(thr, pc, addr);
|
H A D | tsan_mman_test.cc | 49 ThreadState *thr = cur_thread(); local 51 char *p = (char*)user_alloc(thr, pc, 10); 53 char *p2 = (char*)user_alloc(thr, pc, 20); 56 MBlock *b = user_mblock(thr, p); 59 MBlock *b2 = user_mblock(thr, p2); 64 EXPECT_EQ(b, user_mblock(thr, p + i)); 68 EXPECT_EQ(b2, user_mblock(thr, p2 + i)); 70 user_free(thr, pc, p); 71 user_free(thr, pc, p2); 76 ThreadState *thr local 122 ThreadState *thr = cur_thread(); local 135 ThreadState *thr = cur_thread(); local [all...] |
/external/compiler-rt/lib/tsan/rtl/ |
H A D | tsan_symbolize.cc | 27 ThreadState *thr = cur_thread(); local 28 CHECK(!thr->in_symbolizer); 29 thr->in_symbolizer = true; 33 ThreadState *thr = cur_thread(); local 34 CHECK(thr->in_symbolizer); 35 thr->in_symbolizer = false;
|
H A D | tsan_rtl_mutex.cc | 23 void MutexCreate(ThreadState *thr, uptr pc, uptr addr, argument 26 CHECK_GT(thr->in_rtl, 0); 27 DPrintf("#%d: MutexCreate %zx\n", thr->tid, addr); 28 StatInc(thr, StatMutexCreate); 30 CHECK(!thr->is_freeing); 31 thr->is_freeing = true; 32 MemoryWrite(thr, pc, addr, kSizeLog1); 33 thr->is_freeing = false; 35 SyncVar *s = ctx->synctab.GetOrCreateAndLock(thr, pc, addr, true); 42 void MutexDestroy(ThreadState *thr, upt argument 82 MutexLock(ThreadState *thr, uptr pc, uptr addr) argument 115 MutexUnlock(ThreadState *thr, uptr pc, uptr addr) argument 152 MutexReadLock(ThreadState *thr, uptr pc, uptr addr) argument 173 MutexReadUnlock(ThreadState *thr, uptr pc, uptr addr) argument 195 MutexReadOrWriteUnlock(ThreadState *thr, uptr pc, uptr addr) argument 241 Acquire(ThreadState *thr, uptr pc, uptr addr) argument 252 ThreadState *thr = reinterpret_cast<ThreadState*>(arg); local 260 AcquireGlobal(ThreadState *thr, uptr pc) argument 266 Release(ThreadState *thr, uptr pc, uptr addr) argument 276 ReleaseStore(ThreadState *thr, uptr pc, uptr addr) argument 288 ThreadState *thr = reinterpret_cast<ThreadState*>(arg); local 296 AfterSleep(ThreadState *thr, uptr pc) argument [all...] |
H A D | tsan_fd.cc | 57 static void unref(ThreadState *thr, uptr pc, FdSync *s) { argument 63 SyncVar *v = CTX()->synctab.GetAndRemove(thr, pc, (uptr)s); 71 static FdDesc *fddesc(ThreadState *thr, uptr pc, int fd) { argument 79 MemoryResetRange(thr, (uptr)&fddesc, (uptr)p, size); 89 static void init(ThreadState *thr, uptr pc, int fd, FdSync *s) { argument 90 FdDesc *d = fddesc(thr, pc, fd); 94 unref(thr, pc, d->sync); 98 unref(thr, pc, s); 102 unref(thr, pc, s); 105 d->creation_tid = thr 117 FdOnFork(ThreadState *thr, uptr pc) argument 149 FdAcquire(ThreadState *thr, uptr pc, int fd) argument 158 FdRelease(ThreadState *thr, uptr pc, int fd) argument 167 FdAccess(ThreadState *thr, uptr pc, int fd) argument 173 FdClose(ThreadState *thr, uptr pc, int fd) argument 187 FdFileCreate(ThreadState *thr, uptr pc, int fd) argument 192 FdDup(ThreadState *thr, uptr pc, int oldfd, int newfd) argument 201 FdPipeCreate(ThreadState *thr, uptr pc, int rfd, int wfd) argument 209 FdEventCreate(ThreadState *thr, uptr pc, int fd) argument 214 FdSignalCreate(ThreadState *thr, uptr pc, int fd) argument 219 FdInotifyCreate(ThreadState *thr, uptr pc, int fd) argument 224 FdPollCreate(ThreadState *thr, uptr pc, int fd) argument 229 FdSocketCreate(ThreadState *thr, uptr pc, int fd) argument 235 FdSocketAccept(ThreadState *thr, uptr pc, int fd, int newfd) argument 242 FdSocketConnecting(ThreadState *thr, uptr pc, int fd) argument 248 FdSocketConnect(ThreadState *thr, uptr pc, int fd) argument [all...] |
H A D | tsan_interface_java.cc | 43 ThreadState *thr = cur_thread(); local 47 StatInc(thr, StatSyncDestroyed); 50 thr->mset.Remove(s->GetId()); 76 ScopedJavaFunc(ThreadState *thr, uptr pc) argument 77 : thr_(thr) { 79 FuncEntry(thr, pc); 120 SyncVar* GetJavaSync(ThreadState *thr, uptr pc, uptr addr, argument 126 DPrintf("#%d: GetJavaSync %p->%p\n", thr->tid, addr, b); 131 DPrintf("#%d: found existing sync for %p\n", thr->tid, addr); 136 DPrintf("#%d: creating new sync for %p\n", thr 150 GetAndRemoveJavaSync(ThreadState *thr, uptr pc, uptr addr) argument [all...] |
H A D | tsan_mman.cc | 76 void AllocatorThreadStart(ThreadState *thr) { argument 77 allocator()->InitCache(&thr->alloc_cache); 80 void AllocatorThreadFinish(ThreadState *thr) { argument 81 allocator()->DestroyCache(&thr->alloc_cache); 88 static void SignalUnsafeCall(ThreadState *thr, uptr pc) { argument 89 if (!thr->in_signal_handler || !flags()->report_signal_unsafe) 93 stack.ObtainCurrent(thr, pc); 102 void *user_alloc(ThreadState *thr, uptr pc, uptr sz, uptr align) { argument 103 CHECK_GT(thr->in_rtl, 0); 104 void *p = allocator()->Allocate(&thr 116 user_free(ThreadState *thr, uptr pc, void *p) argument 139 user_realloc(ThreadState *thr, uptr pc, void *p, uptr sz) argument 158 user_alloc_usable_size(ThreadState *thr, uptr pc, void *p) argument 166 user_mblock(ThreadState *thr, void *p) argument 176 ThreadState *thr = cur_thread(); local 184 ThreadState *thr = cur_thread(); local 191 ThreadState *thr = cur_thread(); local 201 ThreadState *thr = cur_thread(); local 258 ThreadState *thr = cur_thread(); local [all...] |
H A D | tsan_rtl_thread.cc | 27 , thr() 50 ThreadState *thr; member in struct:__tsan::OnCreatedArgs 55 thr = 0; 59 args->thr->fast_state.IncrementEpoch(); 61 TraceAddEvent(args->thr, args->thr->fast_state, EventTypeMop, 0); 62 args->thr->clock.set(args->thr->tid, args->thr->fast_state.epoch()); 63 args->thr 83 ThreadState *thr; member in struct:__tsan::OnStartedArgs 166 ThreadFinalize(ThreadState *thr) argument 175 ThreadCount(ThreadState *thr) argument 183 ThreadCreate(ThreadState *thr, uptr pc, uptr uid, bool detached) argument 194 ThreadStart(ThreadState *thr, int tid, uptr os_id) argument 225 ThreadFinish(ThreadState *thr) argument 246 ThreadTid(ThreadState *thr, uptr pc, uptr uid) argument 254 ThreadJoin(ThreadState *thr, uptr pc, int tid) argument 263 ThreadDetach(ThreadState *thr, uptr pc, int tid) argument 271 ThreadSetName(ThreadState *thr, const char *name) argument 276 MemoryAccessRange(ThreadState *thr, uptr pc, uptr addr, uptr size, bool is_write) argument 350 MemoryAccessRangeStep(ThreadState *thr, uptr pc, uptr addr, uptr size, uptr step, bool is_write) argument [all...] |
H A D | tsan_sync.cc | 51 SyncVar* SyncTab::GetOrCreateAndLock(ThreadState *thr, uptr pc, argument 53 return GetAndLock(thr, pc, addr, write_lock, true); 60 SyncVar* SyncTab::Create(ThreadState *thr, uptr pc, uptr addr) { argument 61 StatInc(thr, StatSyncCreated); 66 res->creation_stack_id = CurrentStackId(thr, pc); 71 SyncVar* SyncTab::GetAndLock(ThreadState *thr, uptr pc, argument 75 SyncVar *res = GetJavaSync(thr, pc, addr, write_lock, create); 84 MBlock *b = user_mblock(thr, (void*)addr); 94 res = Create(thr, pc, addr); 128 res = Create(thr, p 140 GetAndRemove(ThreadState *thr, uptr pc, uptr addr) argument 253 ObtainCurrent(ThreadState *thr, uptr toppc) argument [all...] |
H A D | tsan_interface_ann.cc | 32 ScopedAnnotation(ThreadState *thr, const char *aname, const char *f, int l, argument 34 : thr_(thr) 35 , in_rtl_(thr->in_rtl) { 55 ThreadState *thr = cur_thread(); \ 57 StatInc(thr, StatAnnotation); \ 58 StatInc(thr, Stat##typ); \ 59 ScopedAnnotation sa(thr, __FUNCTION__, f, l, \ 192 MutexCreate(thr, pc, m, true, true, false); 197 MutexCreate(thr, pc, m, true, true, true); 202 MutexDestroy(thr, p [all...] |
H A D | tsan_rtl.cc | 164 void Initialize(ThreadState *thr) { argument 214 int tid = ThreadCreate(thr, 0, 0, true); 216 ThreadStart(thr, tid, GetPid()); 217 CHECK_EQ(thr->in_rtl, 1); 228 int Finalize(ThreadState *thr) { argument 233 if (flags()->atexit_sleep_ms > 0 && ThreadCount(thr) > 1) 245 ThreadFinalize(thr); 264 StatAggregate(ctx->stat, thr->stat); 270 u32 CurrentStackId(ThreadState *thr, uptr pc) { argument 271 if (thr 285 TraceSwitch(ThreadState *thr) argument 297 TraceTopPC(ThreadState *thr) argument 338 HandleRace(ThreadState *thr, u64 *shadow_mem, Shadow cur, Shadow old) argument 350 OldIsInSameSynchEpoch(Shadow old, ThreadState *thr) argument 354 HappensBefore(Shadow old, ThreadState *thr) argument 359 MemoryAccessImpl(ThreadState *thr, uptr addr, int kAccessSizeLog, bool kAccessIsWrite, bool kIsAtomic, u64 *shadow_mem, Shadow cur) argument 433 MemoryAccess(ThreadState *thr, uptr pc, uptr addr, int kAccessSizeLog, bool kAccessIsWrite, bool kIsAtomic) argument 471 MemoryRangeSet(ThreadState *thr, uptr pc, uptr addr, uptr size, u64 val) argument 530 MemoryResetRange(ThreadState *thr, uptr pc, uptr addr, uptr size) argument 534 MemoryRangeFreed(ThreadState *thr, uptr pc, uptr addr, uptr size) argument 552 MemoryRangeImitateWrite(ThreadState *thr, uptr pc, uptr addr, uptr size) argument 561 FuncEntry(ThreadState *thr, uptr pc) argument 591 FuncExit(ThreadState *thr) argument 605 IgnoreCtl(ThreadState *thr, bool write, bool begin) argument [all...] |
H A D | tsan_interface_atomic.cc | 36 ThreadState *const thr = cur_thread(); \ 37 AtomicStatInc(thr, sizeof(*a), mo, StatAtomic##func); \ 38 ScopedAtomic sa(thr, callpc, __FUNCTION__); \ 39 return Atomic##func(thr, pc, __VA_ARGS__); \ 44 ScopedAtomic(ThreadState *thr, uptr pc, const char *func) argument 45 : thr_(thr) { 47 ProcessPendingSignals(thr); 75 static void AtomicStatInc(ThreadState *thr, uptr size, morder mo, StatType t) { argument 76 StatInc(thr, StatAtomic); 77 StatInc(thr, 247 AtomicLoad(ThreadState *thr, uptr pc, const volatile T *a, morder mo) argument 267 AtomicStore(ThreadState *thr, uptr pc, volatile T *a, T v, morder mo) argument 291 AtomicRMW(ThreadState *thr, uptr pc, volatile T *a, T v, morder mo) argument 307 AtomicExchange(ThreadState *thr, uptr pc, volatile T *a, T v, morder mo) argument 313 AtomicFetchAdd(ThreadState *thr, uptr pc, volatile T *a, T v, morder mo) argument 319 AtomicFetchSub(ThreadState *thr, uptr pc, volatile T *a, T v, morder mo) argument 325 AtomicFetchAnd(ThreadState *thr, uptr pc, volatile T *a, T v, morder mo) argument 331 AtomicFetchOr(ThreadState *thr, uptr pc, volatile T *a, T v, morder mo) argument 337 AtomicFetchXor(ThreadState *thr, uptr pc, volatile T *a, T v, morder mo) argument 343 AtomicFetchNand(ThreadState *thr, uptr pc, volatile T *a, T v, morder mo) argument 349 AtomicCAS(ThreadState *thr, uptr pc, volatile T *a, T *c, T v, morder mo, morder fmo) argument 371 AtomicCAS(ThreadState *thr, uptr pc, volatile T *a, T c, T v, morder mo, morder fmo) argument 377 AtomicFence(ThreadState *thr, uptr pc, morder mo) argument [all...] |
H A D | tsan_rtl_report.cc | 231 ThreadState *thr = tctx->thr; 232 CHECK(thr); 233 return ((addr >= thr->stk_addr && addr < thr->stk_addr + thr->stk_size) || 234 (addr >= thr->tls_addr && addr < thr->tls_addr + thr->tls_size)); 245 ThreadState *thr 446 HandleRacyStacks(ThreadState *thr, const StackTrace (&traces)[2], uptr addr_min, uptr addr_max) argument 486 AddRacyStacks(ThreadState *thr, const StackTrace (&traces)[2], uptr addr_min, uptr addr_max) argument 576 RaceBetweenAtomicAndFree(ThreadState *thr) argument 589 ReportRace(ThreadState *thr) argument 675 PrintCurrentStack(ThreadState *thr, uptr pc) argument [all...] |
H A D | tsan_interceptors.cc | 128 static SignalContext *SigCtx(ThreadState *thr) { argument 129 SignalContext *ctx = (SignalContext*)thr->signal_ctx; 130 if (ctx == 0 && thr->is_alive) { 133 MemoryResetRange(thr, (uptr)&SigCtx, (uptr)ctx, sizeof(*ctx)); 134 thr->signal_ctx = ctx; 143 ScopedInterceptor(ThreadState *thr, const char *fname, uptr pc); 150 ScopedInterceptor::ScopedInterceptor(ThreadState *thr, const char *fname, argument 152 : thr_(thr) 153 , in_rtl_(thr->in_rtl) { 155 Initialize(thr); 200 BlockingCall(ThreadState *thr) argument 242 atexit(ThreadState *thr, uptr pc, bool is_on_exit, atexit_t f, void *arg) argument 255 exit(ThreadState *thr, uptr pc) argument 295 ThreadState * thr = cur_thread(); local 688 ThreadState *thr = cur_thread(); local 711 ThreadState *thr = cur_thread(); local 1571 ThreadState *thr = cur_thread(); local 1744 ThreadState *thr; member in struct:TsanInterceptorContext 1772 ProcessPendingSignals(ThreadState *thr) argument [all...] |
/external/compiler-rt/lib/tsan/tests/rtl/ |
H A D | tsan_test_util_linux.cc | 54 pthread_t thr; local 55 pthread_create(&thr, 0, BeforeInitThread, 0); 56 pthread_join(thr, 0);
|
/external/valgrind/main/none/tests/ |
H A D | thread-exits.c | 40 static void *thr(void *v) function 72 ret = pthread_create(&t, NULL, thr, NULL);
|
/external/aac/libSBRdec/src/ |
H A D | psbitdec.cpp | 383 UCHAR thr; local 384 thr = (UCHAR)h_ps_d->noSubSamples - (pBsData->noEnv - env); 385 if (pBsData->aEnvStartStop[env] > thr) { 386 pBsData->aEnvStartStop[env] = thr; 389 thr = pBsData->aEnvStartStop[env-1]+1; 390 if (pBsData->aEnvStartStop[env] < thr) { 391 pBsData->aEnvStartStop[env] = thr;
|
/external/compiler-rt/lib/tsan/go/ |
H A D | tsan_go.cc | 82 ThreadState *thr = (ThreadState*)internal_alloc(MBlockThreadContex, local 84 internal_memset(thr, 0, sizeof(*thr)); 85 return thr; 89 ThreadState *thr = AllocGoroutine(); local 90 main_thr = *thrp = thr; 91 thr->in_rtl++; 92 Initialize(thr); 93 thr->in_rtl--; 98 ThreadState *thr local 109 __tsan_read(ThreadState *thr, void *addr, void *pc) argument 113 __tsan_write(ThreadState *thr, void *addr, void *pc) argument 117 __tsan_read_range(ThreadState *thr, void *addr, uptr size, uptr step, void *pc) argument 122 __tsan_write_range(ThreadState *thr, void *addr, uptr size, uptr step, void *pc) argument 127 __tsan_func_enter(ThreadState *thr, void *pc) argument 131 __tsan_func_exit(ThreadState *thr) argument 135 __tsan_malloc(ThreadState *thr, void *p, uptr sz, void *pc) argument 148 ThreadState *thr = AllocGoroutine(); local 158 __tsan_go_end(ThreadState *thr) argument 165 __tsan_acquire(ThreadState *thr, void *addr) argument 171 __tsan_release(ThreadState *thr, void *addr) argument 177 __tsan_release_merge(ThreadState *thr, void *addr) argument 183 __tsan_finalizer_goroutine(ThreadState *thr) argument [all...] |
/external/libvpx/libvpx/vp8/common/ |
H A D | mfqe.c | 149 unsigned int act, actd, sad, usad, vsad, sse, thr, thrsq, actrisk; local 188 /* thr = qdiff/16 + log2(act) + log4(qprev) */ 189 thr = (qdiff >> 4); 190 while (actd >>= 1) thr++; 191 while (qprev >>= 2) thr++; 194 thrsq = thr * thr; 200 if (sad < thr && 203 2 * usad < thr && 2 * vsad < thr [all...] |
/external/ganymed-ssh2/src/main/java/ch/ethz/ssh2/channel/ |
H A D | ChannelManager.java | 558 public void registerThread(IChannelWorkerThread thr) throws IOException argument 564 listenerThreads.add(thr);
|