X-Git-Url: http://git.megacz.com/?a=blobdiff_plain;f=rts%2FTrace.c;h=f2f9e815498b66d3422047366b31307a93e810c0;hb=26f4bfc82f2b2359259578e9c54d476fc2de650f;hp=eee3554ca137eff33ab35538364d3c58f18c4e67;hpb=a5288c551349a0adab0d931a429b10a096d9444d;p=ghc-hetmet.git diff --git a/rts/Trace.c b/rts/Trace.c index eee3554..f2f9e81 100644 --- a/rts/Trace.c +++ b/rts/Trace.c @@ -9,22 +9,46 @@ // external headers #include "Rts.h" -#ifdef TRACING - // internal headers #include "Trace.h" + +#ifdef TRACING + #include "GetTime.h" #include "Stats.h" #include "eventlog/EventLog.h" #include "Threads.h" #include "Printer.h" -StgWord32 classes_enabled; // not static due to inline funcs +#ifdef DEBUG +// debugging flags, set with +RTS -D +int DEBUG_sched; +int DEBUG_interp; +int DEBUG_weak; +int DEBUG_gccafs; +int DEBUG_gc; +int DEBUG_block_alloc; +int DEBUG_sanity; +int DEBUG_stable; +int DEBUG_stm; +int DEBUG_prof; +int DEBUG_gran; +int DEBUG_par; +int DEBUG_linker; +int DEBUG_squeeze; +int DEBUG_hpc; +int DEBUG_sparks; +#endif + +// events +int TRACE_sched; #ifdef THREADED_RTS static Mutex trace_utx; #endif +static rtsBool eventlog_enabled; + /* --------------------------------------------------------------------------- Starting up / shuttting down the tracing facilities --------------------------------------------------------------------------- */ @@ -37,10 +61,9 @@ void initTracing (void) #ifdef DEBUG #define DEBUG_FLAG(name, class) \ - if (RtsFlags.DebugFlags.name) classes_enabled |= class; + class = RtsFlags.DebugFlags.name ? 1 : 0; DEBUG_FLAG(scheduler, DEBUG_sched); - DEBUG_FLAG(scheduler, TRACE_sched); // -Ds enabled all sched events DEBUG_FLAG(interpreter, DEBUG_interp); DEBUG_FLAG(weak, DEBUG_weak); @@ -57,22 +80,38 @@ void initTracing (void) DEBUG_FLAG(sparks, DEBUG_sparks); #endif -#define TRACE_FLAG(name, class) \ - if (RtsFlags.TraceFlags.name) classes_enabled |= class; + // -Ds turns on scheduler tracing too + TRACE_sched = + RtsFlags.TraceFlags.scheduler || + RtsFlags.DebugFlags.scheduler; - TRACE_FLAG(scheduler, TRACE_sched); + eventlog_enabled = RtsFlags.TraceFlags.tracing == TRACE_EVENTLOG; - initEventLogging(); + if (eventlog_enabled) { + initEventLogging(); + } } void endTracing (void) { - endEventLogging(); + if (eventlog_enabled) { + endEventLogging(); + } } void freeTracing (void) { - freeEventLogging(); + if (eventlog_enabled) { + freeEventLogging(); + } +} + +void resetTracing (void) +{ + if (eventlog_enabled) { + abortEventLogging(); // abort eventlog inherited from parent + initEventLogging(); // child starts its own eventlog + } } /* --------------------------------------------------------------------------- @@ -98,54 +137,72 @@ static char *thread_stop_reasons[] = { [ThreadYielding] = "yielding", [ThreadBlocked] = "blocked", [ThreadFinished] = "finished", - [THREAD_SUSPENDED_FOREIGN_CALL] = "suspended while making a foreign call" + [THREAD_SUSPENDED_FOREIGN_CALL] = "suspended while making a foreign call", + [6 + BlockedOnMVar] = "blocked on an MVar", + [6 + BlockedOnBlackHole] = "blocked on a black hole", + [6 + BlockedOnRead] = "blocked on a read operation", + [6 + BlockedOnWrite] = "blocked on a write operation", + [6 + BlockedOnDelay] = "blocked on a delay operation", + [6 + BlockedOnSTM] = "blocked on STM", + [6 + BlockedOnDoProc] = "blocked on asyncDoProc", + [6 + BlockedOnCCall] = "blocked on a foreign call", + [6 + BlockedOnCCall_Interruptible] = "blocked on a foreign call (interruptible)", + [6 + BlockedOnMsgThrowTo] = "blocked on throwTo", + [6 + ThreadMigrating] = "migrating" }; #endif #ifdef DEBUG static void traceSchedEvent_stderr (Capability *cap, EventTypeNum tag, StgTSO *tso, - StgWord64 other STG_UNUSED) + StgWord info1 STG_UNUSED, + StgWord info2 STG_UNUSED) { ACQUIRE_LOCK(&trace_utx); tracePreface(); switch (tag) { case EVENT_CREATE_THREAD: // (cap, thread) - debugBelch("cap %d: created thread %ld\n", cap->no, tso->id); + debugBelch("cap %d: created thread %lu\n", + cap->no, (lnat)tso->id); break; case EVENT_RUN_THREAD: // (cap, thread) - debugBelch("cap %d: running thread %ld (%s)\n", cap->no, - tso->id, what_next_strs[tso->what_next]); + debugBelch("cap %d: running thread %lu (%s)\n", + cap->no, (lnat)tso->id, what_next_strs[tso->what_next]); break; case EVENT_THREAD_RUNNABLE: // (cap, thread) - debugBelch("cap %d: thread %ld appended to run queue\n", - cap->no, tso->id); + debugBelch("cap %d: thread %lu appended to run queue\n", + cap->no, (lnat)tso->id); break; case EVENT_RUN_SPARK: // (cap, thread) - debugBelch("cap %d: thread %ld running a spark\n", - cap->no, tso->id); + debugBelch("cap %d: thread %lu running a spark\n", + cap->no, (lnat)tso->id); break; case EVENT_CREATE_SPARK_THREAD: // (cap, spark_thread) - debugBelch("cap %d: creating spark thread %ld\n", - cap->no, (long)other); + debugBelch("cap %d: creating spark thread %lu\n", + cap->no, (long)info1); break; case EVENT_MIGRATE_THREAD: // (cap, thread, new_cap) - debugBelch("cap %d: thread %ld migrating to cap %d\n", - cap->no, tso->id, (int)other); + debugBelch("cap %d: thread %lu migrating to cap %d\n", + cap->no, (lnat)tso->id, (int)info1); break; case EVENT_STEAL_SPARK: // (cap, thread, victim_cap) - debugBelch("cap %d: thread %ld stealing a spark from cap %d\n", - cap->no, tso->id, (int)other); + debugBelch("cap %d: thread %lu stealing a spark from cap %d\n", + cap->no, (lnat)tso->id, (int)info1); break; - case EVENT_THREAD_WAKEUP: // (cap, thread, other_cap) - debugBelch("cap %d: waking up thread %ld on cap %d\n", - cap->no, tso->id, (int)other); + case EVENT_THREAD_WAKEUP: // (cap, thread, info1_cap) + debugBelch("cap %d: waking up thread %lu on cap %d\n", + cap->no, (lnat)tso->id, (int)info1); break; case EVENT_STOP_THREAD: // (cap, thread, status) - debugBelch("cap %d: thread %ld stopped (%s)\n", - cap->no, tso->id, thread_stop_reasons[other]); + if (info1 == 6 + BlockedOnBlackHole) { + debugBelch("cap %d: thread %lu stopped (blocked on black hole owned by thread %lu)\n", + cap->no, (lnat)tso->id, (long)info2); + } else { + debugBelch("cap %d: thread %lu stopped (%s)\n", + cap->no, (lnat)tso->id, thread_stop_reasons[info1]); + } break; case EVENT_SHUTDOWN: // (cap) debugBelch("cap %d: shutting down\n", cap->no); @@ -162,8 +219,18 @@ static void traceSchedEvent_stderr (Capability *cap, EventTypeNum tag, case EVENT_GC_END: // (cap) debugBelch("cap %d: finished GC\n", cap->no); break; + case EVENT_GC_IDLE: // (cap) + debugBelch("cap %d: GC idle\n", cap->no); + break; + case EVENT_GC_WORK: // (cap) + debugBelch("cap %d: GC working\n", cap->no); + break; + case EVENT_GC_DONE: // (cap) + debugBelch("cap %d: GC done\n", cap->no); + break; default: - debugBelch("cap %2d: thread %ld: event %d\n\n", cap->no, tso->id, tag); + debugBelch("cap %d: thread %lu: event %d\n\n", + cap->no, (lnat)tso->id, tag); break; } @@ -172,15 +239,27 @@ static void traceSchedEvent_stderr (Capability *cap, EventTypeNum tag, #endif void traceSchedEvent_ (Capability *cap, EventTypeNum tag, - StgTSO *tso, StgWord64 other) + StgTSO *tso, StgWord info1, StgWord info2) { #ifdef DEBUG - if (RtsFlags.TraceFlags.trace_stderr) { - traceSchedEvent_stderr(cap, tag, tso, other); + if (RtsFlags.TraceFlags.tracing == TRACE_STDERR) { + traceSchedEvent_stderr(cap, tag, tso, info1, info2); } else #endif { - postSchedEvent(cap,tag,tso ? tso->id : 0,other); + postSchedEvent(cap,tag,tso ? tso->id : 0, info1, info2); + } +} + +void traceEvent_ (Capability *cap, EventTypeNum tag) +{ +#ifdef DEBUG + if (RtsFlags.TraceFlags.tracing == TRACE_STDERR) { + traceSchedEvent_stderr(cap, tag, 0, 0, 0); + } else +#endif + { + postEvent(cap,tag); } } @@ -190,7 +269,7 @@ static void traceCap_stderr(Capability *cap, char *msg, va_list ap) ACQUIRE_LOCK(&trace_utx); tracePreface(); - debugBelch("cap %2d: ", cap->no); + debugBelch("cap %d: ", cap->no); vdebugBelch(msg,ap); debugBelch("\n"); @@ -198,16 +277,21 @@ static void traceCap_stderr(Capability *cap, char *msg, va_list ap) } #endif -void traceCap_(Capability *cap, char *msg, va_list ap) +void traceCap_(Capability *cap, char *msg, ...) { + va_list ap; + va_start(ap,msg); + #ifdef DEBUG - if (RtsFlags.TraceFlags.trace_stderr) { + if (RtsFlags.TraceFlags.tracing == TRACE_STDERR) { traceCap_stderr(cap, msg, ap); } else #endif { postCapMsg(cap, msg, ap); } + + va_end(ap); } #ifdef DEBUG @@ -223,22 +307,50 @@ static void trace_stderr(char *msg, va_list ap) } #endif -void trace_(char *msg, va_list ap) +void trace_(char *msg, ...) { + va_list ap; + va_start(ap,msg); + #ifdef DEBUG - if (RtsFlags.TraceFlags.trace_stderr) { + if (RtsFlags.TraceFlags.tracing == TRACE_STDERR) { trace_stderr(msg, ap); } else #endif { postMsg(msg, ap); } + + va_end(ap); +} + +static void traceFormatUserMsg(Capability *cap, char *msg, ...) +{ + va_list ap; + va_start(ap,msg); + +#ifdef DEBUG + if (RtsFlags.TraceFlags.tracing == TRACE_STDERR) { + traceCap_stderr(cap, msg, ap); + } else +#endif + { + if (eventlog_enabled) { + postUserMsg(cap, msg, ap); + } + } + dtraceUserMsg(cap->no, msg); +} + +void traceUserMsg(Capability *cap, char *msg) +{ + traceFormatUserMsg(cap, "%s", msg); } void traceThreadStatus_ (StgTSO *tso USED_IF_DEBUG) { #ifdef DEBUG - if (RtsFlags.TraceFlags.trace_stderr) { + if (RtsFlags.TraceFlags.tracing == TRACE_STDERR) { printThreadStatus(tso); } else #endif @@ -268,3 +380,15 @@ void traceEnd (void) #endif /* DEBUG */ #endif /* TRACING */ + +// If DTRACE is enabled, but neither DEBUG nor TRACING, we need a C land +// wrapper for the user-msg probe (as we can't expand that in PrimOps.cmm) +// +#if !defined(DEBUG) && !defined(TRACING) && defined(DTRACE) + +void dtraceUserMsgWrapper(Capability *cap, char *msg) +{ + dtraceUserMsg(cap->no, msg); +} + +#endif /* !defined(DEBUG) && !defined(TRACING) && defined(DTRACE) */