Lines Matching refs:tid
49 static void thread_append_segment(const DrdThreadId tid, Segment* const sg);
50 static void thread_discard_segment(const DrdThreadId tid, Segment* const sg);
52 const DrdThreadId tid);
53 static Bool thread_conflict_set_up_to_date(const DrdThreadId tid);
153 DrdThreadId DRD_(VgThreadIdToDrdThreadId)(const ThreadId tid)
157 if (tid == VG_INVALID_THREADID)
163 && DRD_(g_threadinfo)[i].vg_threadid == tid)
173 static DrdThreadId DRD_(VgThreadIdToNewDrdThreadId)(const ThreadId tid)
177 tl_assert(DRD_(VgThreadIdToDrdThreadId)(tid) == DRD_INVALID_THREADID);
187 DRD_(g_threadinfo)[i].vg_threadid = tid;
219 DrdThreadId DRD_(PtThreadIdToDrdThreadId)(const PThreadId tid)
223 if (tid != INVALID_POSIX_THREADID)
228 && DRD_(g_threadinfo)[i].pt_threadid == tid)
238 ThreadId DRD_(DrdThreadIdToVgThreadId)(const DrdThreadId tid)
240 tl_assert(0 <= (int)tid && tid < DRD_N_THREADS
241 && tid != DRD_INVALID_THREADID);
243 return (DRD_(g_threadinfo)[tid].vg_thread_exists
244 ? DRD_(g_threadinfo)[tid].vg_threadid
337 static void DRD_(thread_delayed_delete)(const DrdThreadId tid)
341 DRD_(g_threadinfo)[tid].vg_thread_exists = False;
342 DRD_(g_threadinfo)[tid].posix_thread_exists = False;
343 DRD_(g_threadinfo)[tid].deletion_seq = s_deletion_head++;
345 VG_(message)(Vg_DebugMsg, "Adding thread %d to the deletion list\n", tid);
416 void DRD_(thread_set_stack_startup)(const DrdThreadId tid,
419 tl_assert(0 <= (int)tid && tid < DRD_N_THREADS
420 && tid != DRD_INVALID_THREADID);
421 tl_assert(DRD_(g_threadinfo)[tid].stack_min <= stack_startup);
422 tl_assert(stack_startup <= DRD_(g_threadinfo)[tid].stack_max);
423 DRD_(g_threadinfo)[tid].stack_startup = stack_startup;
427 Addr DRD_(thread_get_stack_min)(const DrdThreadId tid)
429 tl_assert(0 <= (int)tid && tid < DRD_N_THREADS
430 && tid != DRD_INVALID_THREADID);
431 return DRD_(g_threadinfo)[tid].stack_min;
438 Addr DRD_(thread_get_stack_min_min)(const DrdThreadId tid)
440 tl_assert(0 <= (int)tid && tid < DRD_N_THREADS
441 && tid != DRD_INVALID_THREADID);
442 return DRD_(g_threadinfo)[tid].stack_min_min;
446 Addr DRD_(thread_get_stack_max)(const DrdThreadId tid)
448 tl_assert(0 <= (int)tid && tid < DRD_N_THREADS
449 && tid != DRD_INVALID_THREADID);
450 return DRD_(g_threadinfo)[tid].stack_max;
454 SizeT DRD_(thread_get_stack_size)(const DrdThreadId tid)
456 tl_assert(0 <= (int)tid && tid < DRD_N_THREADS
457 && tid != DRD_INVALID_THREADID);
458 return DRD_(g_threadinfo)[tid].stack_size;
461 Bool DRD_(thread_get_on_alt_stack)(const DrdThreadId tid)
463 tl_assert(0 <= (int)tid && tid < DRD_N_THREADS
464 && tid != DRD_INVALID_THREADID);
465 return DRD_(g_threadinfo)[tid].on_alt_stack;
468 void DRD_(thread_set_on_alt_stack)(const DrdThreadId tid,
471 tl_assert(0 <= (int)tid && tid < DRD_N_THREADS
472 && tid != DRD_INVALID_THREADID);
474 DRD_(g_threadinfo)[tid].on_alt_stack = on_alt_stack;
489 void DRD_(thread_delete)(const DrdThreadId tid, const Bool detached)
494 tl_assert(DRD_(IsValidDrdThreadId)(tid));
496 tl_assert(DRD_(g_threadinfo)[tid].synchr_nesting >= 0);
497 for (sg = DRD_(g_threadinfo)[tid].sg_last; sg; sg = sg_prev) {
503 DRD_(g_threadinfo)[tid].valid = False;
504 DRD_(g_threadinfo)[tid].vg_thread_exists = False;
505 DRD_(g_threadinfo)[tid].posix_thread_exists = False;
507 DRD_(g_threadinfo)[tid].detached_posix_thread = False;
509 tl_assert(!DRD_(g_threadinfo)[tid].detached_posix_thread);
510 DRD_(g_threadinfo)[tid].sg_first = NULL;
511 DRD_(g_threadinfo)[tid].sg_last = NULL;
513 tl_assert(!DRD_(IsValidDrdThreadId)(tid));
521 void DRD_(thread_finished)(const DrdThreadId tid)
523 tl_assert(0 <= (int)tid && tid < DRD_N_THREADS
524 && tid
526 DRD_(g_threadinfo)[tid].vg_thread_exists = False;
528 if (DRD_(g_threadinfo)[tid].detached_posix_thread)
534 DRD_(g_threadinfo)[tid].stack_min = DRD_(g_threadinfo)[tid].stack_max;
542 DRD_(g_threadinfo)[tid].posix_thread_exists = False;
547 void DRD_(drd_thread_atfork_child)(const DrdThreadId tid)
553 if (i == tid)
562 void DRD_(thread_pre_cancel)(const DrdThreadId tid)
564 tl_assert(0 <= (int)tid && tid < DRD_N_THREADS
565 && tid != DRD_INVALID_THREADID);
566 tl_assert(DRD_(g_threadinfo)[tid].pt_threadid != INVALID_POSIX_THREADID);
570 DRD_(g_drd_running_tid), tid);
580 void DRD_(thread_set_pthreadid)(const DrdThreadId tid, const PThreadId ptid)
582 tl_assert(0 <= (int)tid && tid < DRD_N_THREADS
583 && tid != DRD_INVALID_THREADID);
584 tl_assert(DRD_(g_threadinfo)[tid].pt_threadid == INVALID_POSIX_THREADID
585 || DRD_(g_threadinfo)[tid].pt_threadid == ptid);
587 DRD_(g_threadinfo)[tid].posix_thread_exists = True;
588 DRD_(g_threadinfo)[tid].pt_threadid = ptid;
592 Bool DRD_(thread_get_joinable)(const DrdThreadId tid)
594 tl_assert(0 <= (int)tid && tid < DRD_N_THREADS
595 && tid != DRD_INVALID_THREADID);
596 return ! DRD_(g_threadinfo)[tid].detached_posix_thread;
606 void DRD_(thread_set_joinable)(const DrdThreadId tid, const Bool joinable)
608 tl_assert(0 <= (int)tid && tid < DRD_N_THREADS
609 && tid != DRD_INVALID_THREADID);
611 tl_assert(DRD_(g_threadinfo)[tid].pt_threadid != INVALID_POSIX_THREADID);
613 DRD_(g_threadinfo)[tid].detached_posix_thread = ! joinable;
617 void DRD_(thread_entering_pthread_create)(const DrdThreadId tid)
619 tl_assert(0 <= (int)tid && tid < DRD_N_THREADS
620 && tid != DRD_INVALID_THREADID);
621 tl_assert(DRD_(g_threadinfo)[tid].pt_threadid != INVALID_POSIX_THREADID);
622 tl_assert(DRD_(g_threadinfo)[tid].pthread_create_nesting_level >= 0);
624 DRD_(g_threadinfo)[tid].pthread_create_nesting_level++;
628 void DRD_(thread_left_pthread_create)(const DrdThreadId tid)
630 tl_assert(0 <= (int)tid && tid < DRD_N_THREADS
631 && tid != DRD_INVALID_THREADID);
632 tl_assert(DRD_(g_threadinfo)[tid].pt_threadid != INVALID_POSIX_THREADID);
633 tl_assert(DRD_(g_threadinfo)[tid].pthread_create_nesting_level > 0);
635 DRD_(g_threadinfo)[tid].pthread_create_nesting_level--;
639 const char* DRD_(thread_get_name)(const DrdThreadId tid)
641 tl_assert(0 <= (int)tid && tid < DRD_N_THREADS
642 && tid != DRD_INVALID_THREADID);
644 return DRD_(g_threadinfo)[tid].name;
648 void DRD_(thread_set_name)(const DrdThreadId tid, const char* const name)
650 tl_assert(0 <= (int)tid && tid < DRD_N_THREADS
651 && tid != DRD_INVALID_THREADID);
654 VG_(snprintf)(DRD_(g_threadinfo)[tid].name,
655 sizeof(DRD_(g_threadinfo)[tid].name),
657 tid);
659 VG_(snprintf)(DRD_(g_threadinfo)[tid].name,
660 sizeof(DRD_(g_threadinfo)[tid].name),
662 tid, name);
663 DRD_(g_threadinfo)[tid].name[sizeof(DRD_(g_threadinfo)[tid].name) - 1] = 0;
719 int DRD_(thread_enter_synchr)(const DrdThreadId tid)
721 tl_assert(DRD_(IsValidDrdThreadId)(tid));
722 return DRD_(g_threadinfo)[tid].synchr_nesting++;
729 int DRD_(thread_leave_synchr)(const DrdThreadId tid)
731 tl_assert(DRD_(IsValidDrdThreadId)(tid));
732 tl_assert(DRD_(g_threadinfo)[tid].synchr_nesting >= 1);
733 return --DRD_(g_threadinfo)[tid].synchr_nesting;
737 int DRD_(thread_get_synchr_nesting_count)(const DrdThreadId tid)
739 tl_assert(DRD_(IsValidDrdThreadId)(tid));
740 return DRD_(g_threadinfo)[tid].synchr_nesting;
745 void thread_append_segment(const DrdThreadId tid, Segment* const sg)
747 tl_assert(0 <= (int)tid && tid < DRD_N_THREADS
748 && tid != DRD_INVALID_THREADID);
751 tl_assert(DRD_(sane_ThreadInfo)(&DRD_(g_threadinfo)[tid]));
755 sg->thr_prev = DRD_(g_threadinfo)[tid].sg_last;
757 if (DRD_(g_threadinfo)[tid].sg_last)
758 DRD_(g_threadinfo)[tid].sg_last->thr_next = sg;
759 DRD_(g_threadinfo)[tid].sg_last = sg;
760 if (DRD_(g_threadinfo)[tid].sg_first == NULL)
761 DRD_(g_threadinfo)[tid].sg_first = sg;
764 tl_assert(DRD_(sane_ThreadInfo)(&DRD_(g_threadinfo)[tid]));
773 void thread_discard_segment(const DrdThreadId tid, Segment* const sg)
775 tl_assert(0 <= (int)tid && tid < DRD_N_THREADS
776 && tid != DRD_INVALID_THREADID);
779 tl_assert(DRD_(sane_ThreadInfo)(&DRD_(g_threadinfo)[tid]));
786 if (sg == DRD_(g_threadinfo)[tid].sg_first)
787 DRD_(g_threadinfo)[tid].sg_first = sg->thr_next;
788 if (sg == DRD_(g_threadinfo)[tid].sg_last)
789 DRD_(g_threadinfo)[tid].sg_last = sg->thr_prev;
793 tl_assert(DRD_(sane_ThreadInfo)(&DRD_(g_threadinfo)[tid]));
799 * with thread 'tid'.
801 VectorClock* DRD_(thread_get_vc)(const DrdThreadId tid)
805 tl_assert(0 <= (int)tid && tid < DRD_N_THREADS
806 && tid != DRD_INVALID_THREADID);
807 latest_sg = DRD_(g_threadinfo)[tid].sg_last;
813 * Return the latest segment of thread 'tid' and increment its reference count.
815 void DRD_(thread_get_latest_segment)(Segment** sg, const DrdThreadId tid)
820 tl_assert(0 <= (int)tid && tid < DRD_N_THREADS
821 && tid != DRD_INVALID_THREADID);
822 latest_sg = DRD_(g_threadinfo)[tid].sg_last;
955 static Bool thread_consistent_segment_ordering(const DrdThreadId tid,
1047 void DRD_(thread_new_segment)(const DrdThreadId tid)
1052 tl_assert(0 <= (int)tid && tid < DRD_N_THREADS
1053 && tid != DRD_INVALID_THREADID);
1056 last_sg = DRD_(g_threadinfo)[tid].sg_last;
1057 new_sg = DRD_(sg_new)(tid, tid);
1058 thread_append_segment(tid, new_sg);
1059 if (tid == DRD_(g_drd_running_tid) && last_sg)
1061 DRD_(thread_update_conflict_set)(tid, &last_sg->vc);
1124 * Update the vector clock of the last segment of thread tid with the
1127 static void thread_combine_vc_sync(DrdThreadId tid, const Segment* sg)
1131 tl_assert(0 <= (int)tid && tid < DRD_N_THREADS
1132 && tid != DRD_INVALID_THREADID);
1133 tl_assert(DRD_(g_threadinfo)[tid].sg_first);
1134 tl_assert(DRD_(g_threadinfo)[tid].sg_last);
1138 if (tid != sg->tid) {
1141 DRD_(vc_copy)(&old_vc, DRD_(thread_get_vc)(tid));
1142 DRD_(vc_combine)(DRD_(thread_get_vc)(tid), vc);
1146 str2 = DRD_(vc_aprint)(DRD_(thread_get_vc)(tid));
1147 VG_(message)(Vg_DebugMsg, "thread %d: vc %s -> %s\n", tid, str1, str2);
1154 DRD_(thread_update_conflict_set)(tid, &old_vc);
1159 tl_assert(DRD_(vc_lte)(vc, DRD_(thread_get_vc)(tid)));
1164 * Create a new segment for thread tid and update the vector clock of the last
1166 * function after thread tid had to wait because of thread synchronization
1169 void DRD_(thread_new_segment_and_combine_vc)(DrdThreadId tid, const Segment* sg)
1171 tl_assert(0 <= (int)tid && tid < DRD_N_THREADS
1172 && tid != DRD_INVALID_THREADID);
1176 thread_append_segment(tid, DRD_(sg_new)(tid, tid));
1178 thread_combine_vc_sync(tid, sg);
1204 void DRD_(thread_set_record_loads)(const DrdThreadId tid, const Bool enabled)
1206 tl_assert(0 <= (int)tid && tid < DRD_N_THREADS
1207 && tid != DRD_INVALID_THREADID);
1210 DRD_(g_threadinfo)[tid].is_recording_loads = enabled;
1214 void DRD_(thread_set_record_stores)(const DrdThreadId tid, const Bool enabled)
1216 tl_assert(0 <= (int)tid && tid < DRD_N_THREADS
1217 && tid != DRD_INVALID_THREADID);
1220 DRD_(g_threadinfo)[tid].is_recording_stores = enabled;
1254 static void show_call_stack(const DrdThreadId tid, ExeContext* const callstack)
1256 const ThreadId vg_tid = DRD_(DrdThreadIdToVgThreadId)(tid);
1272 thread_report_conflicting_segments_segment(const DrdThreadId tid,
1280 tl_assert(0 <= (int)tid && tid < DRD_N_THREADS
1281 && tid != DRD_INVALID_THREADID);
1285 if (i != tid) {
1327 void DRD_(thread_report_conflicting_segments)(const DrdThreadId tid,
1334 tl_assert(0 <= (int)tid && tid < DRD_N_THREADS
1335 && tid != DRD_INVALID_THREADID);
1337 for (p = DRD_(g_threadinfo)[tid].sg_first; p; p = p->thr_next) {
1339 thread_report_conflicting_segments_segment(tid, addr, size,
1345 * Verify whether the conflict set for thread tid is up to date. Only perform
1348 static Bool thread_conflict_set_up_to_date(const DrdThreadId tid)
1360 thread_compute_conflict_set(&computed_conflict_set, tid);
1378 * thread tid.
1381 const DrdThreadId tid)
1385 tl_assert(0 <= (int)tid && tid < DRD_N_THREADS
1386 && tid != DRD_INVALID_THREADID);
1387 tl_assert(tid == DRD_(g_drd_running_tid));
1405 str = DRD_(vc_aprint)(DRD_(thread_get_vc)(tid));
1408 tid, str);
1412 p = DRD_(g_threadinfo)[tid].sg_last;
1421 tid, vc);
1426 if (j != tid && DRD_(IsValidDrdThreadId)(j)) {
1464 VG_(message)(Vg_DebugMsg, "[%d] new conflict set:\n", tid);
1466 VG_(message)(Vg_DebugMsg, "[%d] end of new conflict set.\n", tid);
1471 * Update the conflict set after the vector clock of thread tid has been
1475 void DRD_(thread_update_conflict_set)(const DrdThreadId tid,
1482 tl_assert(0 <= (int)tid && tid < DRD_N_THREADS
1483 && tid != DRD_INVALID_THREADID);
1485 tl_assert(tid == DRD_(g_drd_running_tid));
1491 str = DRD_(vc_aprint)(DRD_(thread_get_vc)(tid));
1494 tid, str);
1498 new_vc = DRD_(thread_get_vc)(tid);
1507 if (j == tid || ! DRD_(IsValidDrdThreadId)(j))
1558 p = DRD_(g_threadinfo)[tid].sg_last;
1560 if (j != tid && DRD_(IsValidDrdThreadId)(j)) {
1577 VG_(message)(Vg_DebugMsg, "[%d] updated conflict set:\n", tid);
1579 VG_(message)(Vg_DebugMsg, "[%d] end of updated conflict set.\n", tid);
