Searched defs:thr (Results 1 - 25 of 33) sorted by relevance

12

/external/valgrind/main/drd/tests/
H A Dpth_create_glibc_2_0.c28 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 Dhg_lock_n_thread.c48 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 Dhg_errors.c295 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 Dbar_trivial.c38 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 Dtc17_sembar.c190 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 Dtsan_sync_test.cc29 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 Dtsan_mman_test.cc49 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 Dtsan_symbolize.cc27 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 Dtsan_rtl_mutex.cc23 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 Dtsan_fd.cc57 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 Dtsan_interface_java.cc43 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 Dtsan_mman.cc76 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 Dtsan_rtl_thread.cc27 , 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 Dtsan_sync.cc51 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 Dtsan_interface_ann.cc32 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 Dtsan_rtl.cc164 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 Dtsan_interface_atomic.cc36 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 Dtsan_rtl_report.cc231 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 Dtsan_interceptors.cc128 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 Dtsan_test_util_linux.cc54 pthread_t thr; local
55 pthread_create(&thr, 0, BeforeInitThread, 0);
56 pthread_join(thr, 0);
/external/valgrind/main/none/tests/
H A Dthread-exits.c40 static void *thr(void *v) function
72 ret = pthread_create(&t, NULL, thr, NULL);
/external/aac/libSBRdec/src/
H A Dpsbitdec.cpp383 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 Dtsan_go.cc82 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 Dmfqe.c149 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 DChannelManager.java558 public void registerThread(IChannelWorkerThread thr) throws IOException argument
564 listenerThreads.add(thr);

Completed in 418 milliseconds

12