aboutsummaryrefslogtreecommitdiff
path: root/drd/drd_clientreq.c
diff options
context:
space:
mode:
authorbart <bart@a5019735-40e9-0310-863c-91ae7b9d1cf9>2009-03-26 19:07:15 +0000
committerbart <bart@a5019735-40e9-0310-863c-91ae7b9d1cf9>2009-03-26 19:07:15 +0000
commitbedfd237fbdc80d0c917cfcb85a94b5561c92633 (patch)
treeca3765f5de096ac686cb53fa0bc47585b031c373 /drd/drd_clientreq.c
parentcd7bfdf7393ca23803c4097b540e214b3aca01c4 (diff)
downloadvalgrind-bedfd237fbdc80d0c917cfcb85a94b5561c92633.tar.gz
- Reindented code such that it uses three spaces for indentation instead
of two. The indentation of the DRD source code is now consistent with the other Valgrind source files. - Added emacs mode line with indentation settings. git-svn-id: svn://svn.valgrind.org/valgrind/trunk@9496 a5019735-40e9-0310-863c-91ae7b9d1cf9
Diffstat (limited to 'drd/drd_clientreq.c')
-rw-r--r--drd/drd_clientreq.c663
1 files changed, 332 insertions, 331 deletions
diff --git a/drd/drd_clientreq.c b/drd/drd_clientreq.c
index 57a51393f..2aceffe28 100644
--- a/drd/drd_clientreq.c
+++ b/drd/drd_clientreq.c
@@ -1,3 +1,4 @@
+/* -*- mode: C; c-basic-offset: 3; -*- */
/*
This file is part of drd, a thread error detector.
@@ -56,7 +57,7 @@ static Addr DRD_(highest_used_stack_address)(const ThreadId vg_tid);
*/
void DRD_(clientreq_init)(void)
{
- VG_(needs_client_requests)(DRD_(handle_client_request));
+ VG_(needs_client_requests)(DRD_(handle_client_request));
}
/**
@@ -66,322 +67,322 @@ void DRD_(clientreq_init)(void)
static
Bool DRD_(handle_client_request)(ThreadId vg_tid, UWord* arg, UWord* ret)
{
- UWord result = 0;
- const DrdThreadId drd_tid = DRD_(thread_get_running_tid)();
+ UWord result = 0;
+ const DrdThreadId drd_tid = DRD_(thread_get_running_tid)();
- tl_assert(vg_tid == VG_(get_running_tid()));
- tl_assert(DRD_(VgThreadIdToDrdThreadId)(vg_tid) == drd_tid);
+ tl_assert(vg_tid == VG_(get_running_tid()));
+ tl_assert(DRD_(VgThreadIdToDrdThreadId)(vg_tid) == drd_tid);
- switch (arg[0])
- {
- case VG_USERREQ__DRD_GET_VALGRIND_THREAD_ID:
- result = vg_tid;
- break;
+ switch (arg[0])
+ {
+ case VG_USERREQ__DRD_GET_VALGRIND_THREAD_ID:
+ result = vg_tid;
+ break;
- case VG_USERREQ__DRD_GET_DRD_THREAD_ID:
- result = drd_tid;
- break;
+ case VG_USERREQ__DRD_GET_DRD_THREAD_ID:
+ result = drd_tid;
+ break;
- case VG_USERREQ__DRD_START_SUPPRESSION:
- DRD_(start_suppression)(arg[1], arg[1] + arg[2], "client");
- break;
+ case VG_USERREQ__DRD_START_SUPPRESSION:
+ DRD_(start_suppression)(arg[1], arg[1] + arg[2], "client");
+ break;
- case VG_USERREQ__DRD_FINISH_SUPPRESSION:
- DRD_(finish_suppression)(arg[1], arg[1] + arg[2]);
- break;
+ case VG_USERREQ__DRD_FINISH_SUPPRESSION:
+ DRD_(finish_suppression)(arg[1], arg[1] + arg[2]);
+ break;
- case VG_USERREQ__DRD_SUPPRESS_CURRENT_STACK:
- {
- const Addr topmost_sp = DRD_(highest_used_stack_address)(vg_tid);
+ case VG_USERREQ__DRD_SUPPRESS_CURRENT_STACK:
+ {
+ const Addr topmost_sp = DRD_(highest_used_stack_address)(vg_tid);
#if 0
- UInt nframes;
- const UInt n_ips = 20;
- Addr ips[n_ips], sps[n_ips], fps[n_ips];
- Char desc[128];
- unsigned i;
-
- nframes = VG_(get_StackTrace)(vg_tid, ips, n_ips, sps, fps, 0);
-
- VG_(message)(Vg_DebugMsg, "thread %d/%d", vg_tid, drd_tid);
- for (i = 0; i < nframes; i++)
- {
- VG_(describe_IP)(ips[i], desc, sizeof(desc));
- VG_(message)(Vg_DebugMsg, "[%2d] sp 0x%09lx fp 0x%09lx ip %s",
- i, sps[i], fps[i], desc);
- }
+ UInt nframes;
+ const UInt n_ips = 20;
+ Addr ips[n_ips], sps[n_ips], fps[n_ips];
+ Char desc[128];
+ unsigned i;
+
+ nframes = VG_(get_StackTrace)(vg_tid, ips, n_ips, sps, fps, 0);
+
+ VG_(message)(Vg_DebugMsg, "thread %d/%d", vg_tid, drd_tid);
+ for (i = 0; i < nframes; i++)
+ {
+ VG_(describe_IP)(ips[i], desc, sizeof(desc));
+ VG_(message)(Vg_DebugMsg, "[%2d] sp 0x%09lx fp 0x%09lx ip %s",
+ i, sps[i], fps[i], desc);
+ }
#endif
- DRD_(thread_set_stack_startup)(drd_tid, VG_(get_SP)(vg_tid));
- DRD_(start_suppression)(topmost_sp, VG_(thread_get_stack_max)(vg_tid),
- "stack top");
- break;
- }
-
- case VG_USERREQ__DRD_START_NEW_SEGMENT:
- DRD_(thread_new_segment)(DRD_(PtThreadIdToDrdThreadId)(arg[1]));
- break;
-
- case VG_USERREQ__DRD_START_TRACE_ADDR:
- DRD_(start_tracing_address_range)(arg[1], arg[1] + arg[2]);
- break;
-
- case VG_USERREQ__DRD_STOP_TRACE_ADDR:
- DRD_(stop_tracing_address_range)(arg[1], arg[1] + arg[2]);
- break;
-
- case VG_USERREQ__DRD_STOP_RECORDING:
- DRD_(thread_stop_recording)(drd_tid);
- break;
-
- case VG_USERREQ__DRD_START_RECORDING:
- DRD_(thread_start_recording)(drd_tid);
- break;
-
- case VG_USERREQ__SET_PTHREADID:
- // pthread_self() returns 0 for programs not linked with libpthread.so.
- if (arg[1] != INVALID_POSIX_THREADID)
- DRD_(thread_set_pthreadid)(drd_tid, arg[1]);
- break;
-
- case VG_USERREQ__SET_JOINABLE:
- DRD_(thread_set_joinable)(DRD_(PtThreadIdToDrdThreadId)(arg[1]),
- (Bool)arg[2]);
- break;
-
- case VG_USERREQ__POST_THREAD_JOIN:
- tl_assert(arg[1]);
- DRD_(thread_post_join)(drd_tid, DRD_(PtThreadIdToDrdThreadId)(arg[1]));
- break;
-
- case VG_USERREQ__PRE_THREAD_CANCEL:
- tl_assert(arg[1]);
- DRD_(thread_pre_cancel)(drd_tid);
- break;
-
- case VG_USERREQ__POST_THREAD_CANCEL:
- tl_assert(arg[1]);
- break;
-
- case VG_USERREQ__PRE_MUTEX_INIT:
- if (DRD_(thread_enter_synchr)(drd_tid) == 0)
- DRD_(mutex_init)(arg[1], arg[2]);
- break;
-
- case VG_USERREQ__POST_MUTEX_INIT:
- DRD_(thread_leave_synchr)(drd_tid);
- break;
-
- case VG_USERREQ__PRE_MUTEX_DESTROY:
- DRD_(thread_enter_synchr)(drd_tid);
- break;
-
- case VG_USERREQ__POST_MUTEX_DESTROY:
- if (DRD_(thread_leave_synchr)(drd_tid) == 0)
- DRD_(mutex_post_destroy)(arg[1]);
- break;
-
- case VG_USERREQ__PRE_MUTEX_LOCK:
- if (DRD_(thread_enter_synchr)(drd_tid) == 0)
- DRD_(mutex_pre_lock)(arg[1], arg[2], arg[3]);
- break;
-
- case VG_USERREQ__POST_MUTEX_LOCK:
- if (DRD_(thread_leave_synchr)(drd_tid) == 0)
- DRD_(mutex_post_lock)(arg[1], arg[2], False/*post_cond_wait*/);
- break;
-
- case VG_USERREQ__PRE_MUTEX_UNLOCK:
- if (DRD_(thread_enter_synchr)(drd_tid) == 0)
- DRD_(mutex_unlock)(arg[1], arg[2]);
- break;
-
- case VG_USERREQ__POST_MUTEX_UNLOCK:
- DRD_(thread_leave_synchr)(drd_tid);
- break;
-
- case VG_USERREQ__PRE_SPIN_INIT_OR_UNLOCK:
- if (DRD_(thread_enter_synchr)(drd_tid) == 0)
- DRD_(spinlock_init_or_unlock)(arg[1]);
- break;
-
- case VG_USERREQ__POST_SPIN_INIT_OR_UNLOCK:
- DRD_(thread_leave_synchr)(drd_tid);
- break;
-
- case VG_USERREQ__PRE_COND_INIT:
- if (DRD_(thread_enter_synchr)(drd_tid) == 0)
- DRD_(cond_pre_init)(arg[1]);
- break;
-
- case VG_USERREQ__POST_COND_INIT:
- DRD_(thread_leave_synchr)(drd_tid);
- break;
-
- case VG_USERREQ__PRE_COND_DESTROY:
- DRD_(thread_enter_synchr)(drd_tid);
- break;
-
- case VG_USERREQ__POST_COND_DESTROY:
- if (DRD_(thread_leave_synchr)(drd_tid) == 0)
- DRD_(cond_post_destroy)(arg[1]);
- break;
-
- case VG_USERREQ__PRE_COND_WAIT:
- if (DRD_(thread_enter_synchr)(drd_tid) == 0)
- {
- const Addr cond = arg[1];
- const Addr mutex = arg[2];
- const MutexT mutex_type = arg[3];
- DRD_(mutex_unlock)(mutex, mutex_type);
- DRD_(cond_pre_wait)(cond, mutex);
- }
- break;
-
- case VG_USERREQ__POST_COND_WAIT:
- if (DRD_(thread_leave_synchr)(drd_tid) == 0)
- {
- const Addr cond = arg[1];
- const Addr mutex = arg[2];
- const Bool took_lock = arg[3];
- DRD_(cond_post_wait)(cond);
- DRD_(mutex_post_lock)(mutex, took_lock, True);
- }
- break;
-
- case VG_USERREQ__PRE_COND_SIGNAL:
- if (DRD_(thread_enter_synchr)(drd_tid) == 0)
- DRD_(cond_pre_signal)(arg[1]);
- break;
-
- case VG_USERREQ__POST_COND_SIGNAL:
- DRD_(thread_leave_synchr)(drd_tid);
- break;
-
- case VG_USERREQ__PRE_COND_BROADCAST:
- if (DRD_(thread_enter_synchr)(drd_tid) == 0)
- DRD_(cond_pre_broadcast)(arg[1]);
- break;
-
- case VG_USERREQ__POST_COND_BROADCAST:
- DRD_(thread_leave_synchr)(drd_tid);
- break;
-
- case VG_USERREQ__PRE_SEM_INIT:
- if (DRD_(thread_enter_synchr)(drd_tid) == 0)
- DRD_(semaphore_init)(arg[1], arg[2], arg[3]);
- break;
-
- case VG_USERREQ__POST_SEM_INIT:
- DRD_(thread_leave_synchr)(drd_tid);
- break;
-
- case VG_USERREQ__PRE_SEM_DESTROY:
- DRD_(thread_enter_synchr)(drd_tid);
- break;
-
- case VG_USERREQ__POST_SEM_DESTROY:
- if (DRD_(thread_leave_synchr)(drd_tid) == 0)
- DRD_(semaphore_destroy)(arg[1]);
- break;
-
- case VG_USERREQ__PRE_SEM_WAIT:
- if (DRD_(thread_enter_synchr)(drd_tid) == 0)
- DRD_(semaphore_pre_wait)(arg[1]);
- break;
-
- case VG_USERREQ__POST_SEM_WAIT:
- if (DRD_(thread_leave_synchr)(drd_tid) == 0)
- DRD_(semaphore_post_wait)(drd_tid, arg[1], arg[2]);
- break;
-
- case VG_USERREQ__PRE_SEM_POST:
- if (DRD_(thread_enter_synchr)(drd_tid) == 0)
- DRD_(semaphore_pre_post)(drd_tid, arg[1]);
- break;
-
- case VG_USERREQ__POST_SEM_POST:
- if (DRD_(thread_leave_synchr)(drd_tid) == 0)
- DRD_(semaphore_post_post)(drd_tid, arg[1], arg[2]);
- break;
-
- case VG_USERREQ__PRE_BARRIER_INIT:
- if (DRD_(thread_enter_synchr)(drd_tid) == 0)
- DRD_(barrier_init)(arg[1], arg[2], arg[3], arg[4]);
- break;
-
- case VG_USERREQ__POST_BARRIER_INIT:
- DRD_(thread_leave_synchr)(drd_tid);
- break;
-
- case VG_USERREQ__PRE_BARRIER_DESTROY:
- DRD_(thread_enter_synchr)(drd_tid);
- break;
-
- case VG_USERREQ__POST_BARRIER_DESTROY:
- if (DRD_(thread_leave_synchr)(drd_tid) == 0)
- DRD_(barrier_destroy)(arg[1], arg[2]);
- break;
-
- case VG_USERREQ__PRE_BARRIER_WAIT:
- if (DRD_(thread_enter_synchr)(drd_tid) == 0)
- DRD_(barrier_pre_wait)(drd_tid, arg[1], arg[2]);
- break;
-
- case VG_USERREQ__POST_BARRIER_WAIT:
- if (DRD_(thread_leave_synchr)(drd_tid) == 0)
- DRD_(barrier_post_wait)(drd_tid, arg[1], arg[2], arg[3], arg[4]);
- break;
-
- case VG_USERREQ__PRE_RWLOCK_INIT:
- DRD_(rwlock_pre_init)(arg[1]);
- break;
-
- case VG_USERREQ__POST_RWLOCK_DESTROY:
- DRD_(rwlock_post_destroy)(arg[1]);
- break;
-
- case VG_USERREQ__PRE_RWLOCK_RDLOCK:
- if (DRD_(thread_enter_synchr)(drd_tid) == 0)
- DRD_(rwlock_pre_rdlock)(arg[1]);
- break;
-
- case VG_USERREQ__POST_RWLOCK_RDLOCK:
- if (DRD_(thread_leave_synchr)(drd_tid) == 0)
- DRD_(rwlock_post_rdlock)(arg[1], arg[2]);
- break;
-
- case VG_USERREQ__PRE_RWLOCK_WRLOCK:
- if (DRD_(thread_enter_synchr)(drd_tid) == 0)
- DRD_(rwlock_pre_wrlock)(arg[1]);
- break;
-
- case VG_USERREQ__POST_RWLOCK_WRLOCK:
- if (DRD_(thread_leave_synchr)(drd_tid) == 0)
- DRD_(rwlock_post_wrlock)(arg[1], arg[2]);
- break;
-
- case VG_USERREQ__PRE_RWLOCK_UNLOCK:
- if (DRD_(thread_enter_synchr)(drd_tid) == 0)
- DRD_(rwlock_pre_unlock)(arg[1]);
- break;
+ DRD_(thread_set_stack_startup)(drd_tid, VG_(get_SP)(vg_tid));
+ DRD_(start_suppression)(topmost_sp, VG_(thread_get_stack_max)(vg_tid),
+ "stack top");
+ break;
+ }
+
+ case VG_USERREQ__DRD_START_NEW_SEGMENT:
+ DRD_(thread_new_segment)(DRD_(PtThreadIdToDrdThreadId)(arg[1]));
+ break;
+
+ case VG_USERREQ__DRD_START_TRACE_ADDR:
+ DRD_(start_tracing_address_range)(arg[1], arg[1] + arg[2]);
+ break;
+
+ case VG_USERREQ__DRD_STOP_TRACE_ADDR:
+ DRD_(stop_tracing_address_range)(arg[1], arg[1] + arg[2]);
+ break;
+
+ case VG_USERREQ__DRD_STOP_RECORDING:
+ DRD_(thread_stop_recording)(drd_tid);
+ break;
+
+ case VG_USERREQ__DRD_START_RECORDING:
+ DRD_(thread_start_recording)(drd_tid);
+ break;
+
+ case VG_USERREQ__SET_PTHREADID:
+ // pthread_self() returns 0 for programs not linked with libpthread.so.
+ if (arg[1] != INVALID_POSIX_THREADID)
+ DRD_(thread_set_pthreadid)(drd_tid, arg[1]);
+ break;
+
+ case VG_USERREQ__SET_JOINABLE:
+ DRD_(thread_set_joinable)(DRD_(PtThreadIdToDrdThreadId)(arg[1]),
+ (Bool)arg[2]);
+ break;
+
+ case VG_USERREQ__POST_THREAD_JOIN:
+ tl_assert(arg[1]);
+ DRD_(thread_post_join)(drd_tid, DRD_(PtThreadIdToDrdThreadId)(arg[1]));
+ break;
+
+ case VG_USERREQ__PRE_THREAD_CANCEL:
+ tl_assert(arg[1]);
+ DRD_(thread_pre_cancel)(drd_tid);
+ break;
+
+ case VG_USERREQ__POST_THREAD_CANCEL:
+ tl_assert(arg[1]);
+ break;
+
+ case VG_USERREQ__PRE_MUTEX_INIT:
+ if (DRD_(thread_enter_synchr)(drd_tid) == 0)
+ DRD_(mutex_init)(arg[1], arg[2]);
+ break;
+
+ case VG_USERREQ__POST_MUTEX_INIT:
+ DRD_(thread_leave_synchr)(drd_tid);
+ break;
+
+ case VG_USERREQ__PRE_MUTEX_DESTROY:
+ DRD_(thread_enter_synchr)(drd_tid);
+ break;
+
+ case VG_USERREQ__POST_MUTEX_DESTROY:
+ if (DRD_(thread_leave_synchr)(drd_tid) == 0)
+ DRD_(mutex_post_destroy)(arg[1]);
+ break;
+
+ case VG_USERREQ__PRE_MUTEX_LOCK:
+ if (DRD_(thread_enter_synchr)(drd_tid) == 0)
+ DRD_(mutex_pre_lock)(arg[1], arg[2], arg[3]);
+ break;
+
+ case VG_USERREQ__POST_MUTEX_LOCK:
+ if (DRD_(thread_leave_synchr)(drd_tid) == 0)
+ DRD_(mutex_post_lock)(arg[1], arg[2], False/*post_cond_wait*/);
+ break;
+
+ case VG_USERREQ__PRE_MUTEX_UNLOCK:
+ if (DRD_(thread_enter_synchr)(drd_tid) == 0)
+ DRD_(mutex_unlock)(arg[1], arg[2]);
+ break;
+
+ case VG_USERREQ__POST_MUTEX_UNLOCK:
+ DRD_(thread_leave_synchr)(drd_tid);
+ break;
+
+ case VG_USERREQ__PRE_SPIN_INIT_OR_UNLOCK:
+ if (DRD_(thread_enter_synchr)(drd_tid) == 0)
+ DRD_(spinlock_init_or_unlock)(arg[1]);
+ break;
+
+ case VG_USERREQ__POST_SPIN_INIT_OR_UNLOCK:
+ DRD_(thread_leave_synchr)(drd_tid);
+ break;
+
+ case VG_USERREQ__PRE_COND_INIT:
+ if (DRD_(thread_enter_synchr)(drd_tid) == 0)
+ DRD_(cond_pre_init)(arg[1]);
+ break;
+
+ case VG_USERREQ__POST_COND_INIT:
+ DRD_(thread_leave_synchr)(drd_tid);
+ break;
+
+ case VG_USERREQ__PRE_COND_DESTROY:
+ DRD_(thread_enter_synchr)(drd_tid);
+ break;
+
+ case VG_USERREQ__POST_COND_DESTROY:
+ if (DRD_(thread_leave_synchr)(drd_tid) == 0)
+ DRD_(cond_post_destroy)(arg[1]);
+ break;
+
+ case VG_USERREQ__PRE_COND_WAIT:
+ if (DRD_(thread_enter_synchr)(drd_tid) == 0)
+ {
+ const Addr cond = arg[1];
+ const Addr mutex = arg[2];
+ const MutexT mutex_type = arg[3];
+ DRD_(mutex_unlock)(mutex, mutex_type);
+ DRD_(cond_pre_wait)(cond, mutex);
+ }
+ break;
+
+ case VG_USERREQ__POST_COND_WAIT:
+ if (DRD_(thread_leave_synchr)(drd_tid) == 0)
+ {
+ const Addr cond = arg[1];
+ const Addr mutex = arg[2];
+ const Bool took_lock = arg[3];
+ DRD_(cond_post_wait)(cond);
+ DRD_(mutex_post_lock)(mutex, took_lock, True);
+ }
+ break;
+
+ case VG_USERREQ__PRE_COND_SIGNAL:
+ if (DRD_(thread_enter_synchr)(drd_tid) == 0)
+ DRD_(cond_pre_signal)(arg[1]);
+ break;
+
+ case VG_USERREQ__POST_COND_SIGNAL:
+ DRD_(thread_leave_synchr)(drd_tid);
+ break;
+
+ case VG_USERREQ__PRE_COND_BROADCAST:
+ if (DRD_(thread_enter_synchr)(drd_tid) == 0)
+ DRD_(cond_pre_broadcast)(arg[1]);
+ break;
+
+ case VG_USERREQ__POST_COND_BROADCAST:
+ DRD_(thread_leave_synchr)(drd_tid);
+ break;
+
+ case VG_USERREQ__PRE_SEM_INIT:
+ if (DRD_(thread_enter_synchr)(drd_tid) == 0)
+ DRD_(semaphore_init)(arg[1], arg[2], arg[3]);
+ break;
+
+ case VG_USERREQ__POST_SEM_INIT:
+ DRD_(thread_leave_synchr)(drd_tid);
+ break;
+
+ case VG_USERREQ__PRE_SEM_DESTROY:
+ DRD_(thread_enter_synchr)(drd_tid);
+ break;
+
+ case VG_USERREQ__POST_SEM_DESTROY:
+ if (DRD_(thread_leave_synchr)(drd_tid) == 0)
+ DRD_(semaphore_destroy)(arg[1]);
+ break;
+
+ case VG_USERREQ__PRE_SEM_WAIT:
+ if (DRD_(thread_enter_synchr)(drd_tid) == 0)
+ DRD_(semaphore_pre_wait)(arg[1]);
+ break;
+
+ case VG_USERREQ__POST_SEM_WAIT:
+ if (DRD_(thread_leave_synchr)(drd_tid) == 0)
+ DRD_(semaphore_post_wait)(drd_tid, arg[1], arg[2]);
+ break;
+
+ case VG_USERREQ__PRE_SEM_POST:
+ if (DRD_(thread_enter_synchr)(drd_tid) == 0)
+ DRD_(semaphore_pre_post)(drd_tid, arg[1]);
+ break;
+
+ case VG_USERREQ__POST_SEM_POST:
+ if (DRD_(thread_leave_synchr)(drd_tid) == 0)
+ DRD_(semaphore_post_post)(drd_tid, arg[1], arg[2]);
+ break;
+
+ case VG_USERREQ__PRE_BARRIER_INIT:
+ if (DRD_(thread_enter_synchr)(drd_tid) == 0)
+ DRD_(barrier_init)(arg[1], arg[2], arg[3], arg[4]);
+ break;
+
+ case VG_USERREQ__POST_BARRIER_INIT:
+ DRD_(thread_leave_synchr)(drd_tid);
+ break;
+
+ case VG_USERREQ__PRE_BARRIER_DESTROY:
+ DRD_(thread_enter_synchr)(drd_tid);
+ break;
+
+ case VG_USERREQ__POST_BARRIER_DESTROY:
+ if (DRD_(thread_leave_synchr)(drd_tid) == 0)
+ DRD_(barrier_destroy)(arg[1], arg[2]);
+ break;
+
+ case VG_USERREQ__PRE_BARRIER_WAIT:
+ if (DRD_(thread_enter_synchr)(drd_tid) == 0)
+ DRD_(barrier_pre_wait)(drd_tid, arg[1], arg[2]);
+ break;
+
+ case VG_USERREQ__POST_BARRIER_WAIT:
+ if (DRD_(thread_leave_synchr)(drd_tid) == 0)
+ DRD_(barrier_post_wait)(drd_tid, arg[1], arg[2], arg[3], arg[4]);
+ break;
+
+ case VG_USERREQ__PRE_RWLOCK_INIT:
+ DRD_(rwlock_pre_init)(arg[1]);
+ break;
+
+ case VG_USERREQ__POST_RWLOCK_DESTROY:
+ DRD_(rwlock_post_destroy)(arg[1]);
+ break;
+
+ case VG_USERREQ__PRE_RWLOCK_RDLOCK:
+ if (DRD_(thread_enter_synchr)(drd_tid) == 0)
+ DRD_(rwlock_pre_rdlock)(arg[1]);
+ break;
+
+ case VG_USERREQ__POST_RWLOCK_RDLOCK:
+ if (DRD_(thread_leave_synchr)(drd_tid) == 0)
+ DRD_(rwlock_post_rdlock)(arg[1], arg[2]);
+ break;
+
+ case VG_USERREQ__PRE_RWLOCK_WRLOCK:
+ if (DRD_(thread_enter_synchr)(drd_tid) == 0)
+ DRD_(rwlock_pre_wrlock)(arg[1]);
+ break;
+
+ case VG_USERREQ__POST_RWLOCK_WRLOCK:
+ if (DRD_(thread_leave_synchr)(drd_tid) == 0)
+ DRD_(rwlock_post_wrlock)(arg[1], arg[2]);
+ break;
+
+ case VG_USERREQ__PRE_RWLOCK_UNLOCK:
+ if (DRD_(thread_enter_synchr)(drd_tid) == 0)
+ DRD_(rwlock_pre_unlock)(arg[1]);
+ break;
- case VG_USERREQ__POST_RWLOCK_UNLOCK:
- DRD_(thread_leave_synchr)(drd_tid);
- break;
-
- case VG_USERREQ__DRD_CLEAN_MEMORY:
- if (arg[2] > 0)
- DRD_(clean_memory)(arg[1], arg[2]);
- break;
-
- default:
- VG_(message)(Vg_DebugMsg, "Unrecognized client request 0x%lx 0x%lx",
- arg[0], arg[1]);
- tl_assert(0);
- return False;
- }
-
- *ret = result;
- return True;
+ case VG_USERREQ__POST_RWLOCK_UNLOCK:
+ DRD_(thread_leave_synchr)(drd_tid);
+ break;
+
+ case VG_USERREQ__DRD_CLEAN_MEMORY:
+ if (arg[2] > 0)
+ DRD_(clean_memory)(arg[1], arg[2]);
+ break;
+
+ default:
+ VG_(message)(Vg_DebugMsg, "Unrecognized client request 0x%lx 0x%lx",
+ arg[0], arg[1]);
+ tl_assert(0);
+ return False;
+ }
+
+ *ret = result;
+ return True;
}
/**
@@ -394,36 +395,36 @@ Bool DRD_(handle_client_request)(ThreadId vg_tid, UWord* arg, UWord* ret)
*/
static Addr DRD_(highest_used_stack_address)(const ThreadId vg_tid)
{
- UInt nframes;
- const UInt n_ips = 10;
- UInt i;
- Addr ips[n_ips], sps[n_ips];
- Addr husa;
+ UInt nframes;
+ const UInt n_ips = 10;
+ UInt i;
+ Addr ips[n_ips], sps[n_ips];
+ Addr husa;
- nframes = VG_(get_StackTrace)(vg_tid, ips, n_ips, sps, 0, 0);
- tl_assert(1 <= nframes && nframes <= n_ips);
+ nframes = VG_(get_StackTrace)(vg_tid, ips, n_ips, sps, 0, 0);
+ tl_assert(1 <= nframes && nframes <= n_ips);
- /* A hack to work around VG_(get_StackTrace)()'s behavior that sometimes */
- /* the topmost stackframes it returns are bogus (this occurs sometimes */
- /* at least on amd64, ppc32 and ppc64). */
+ /* A hack to work around VG_(get_StackTrace)()'s behavior that sometimes */
+ /* the topmost stackframes it returns are bogus (this occurs sometimes */
+ /* at least on amd64, ppc32 and ppc64). */
- husa = sps[0];
+ husa = sps[0];
- tl_assert(VG_(thread_get_stack_max)(vg_tid)
- - VG_(thread_get_stack_size)(vg_tid) <= husa
- && husa < VG_(thread_get_stack_max)(vg_tid));
+ tl_assert(VG_(thread_get_stack_max)(vg_tid)
+ - VG_(thread_get_stack_size)(vg_tid) <= husa
+ && husa < VG_(thread_get_stack_max)(vg_tid));
- for (i = 1; i < nframes; i++)
- {
+ for (i = 1; i < nframes; i++)
+ {
if (sps[i] == 0)
- break;
+ break;
if (husa < sps[i] && sps[i] < VG_(thread_get_stack_max)(vg_tid))
- husa = sps[i];
- }
+ husa = sps[i];
+ }
- tl_assert(VG_(thread_get_stack_max)(vg_tid)
- - VG_(thread_get_stack_size)(vg_tid) <= husa
- && husa < VG_(thread_get_stack_max)(vg_tid));
+ tl_assert(VG_(thread_get_stack_max)(vg_tid)
+ - VG_(thread_get_stack_size)(vg_tid) <= husa
+ && husa < VG_(thread_get_stack_max)(vg_tid));
- return husa;
+ return husa;
}