X-Git-Url: http://git.megacz.com/?a=blobdiff_plain;f=rts%2FTrace.c;h=7194651339e0d9b7a13abbecb0aaf5fbcc1f7f78;hb=d64900abb0ddc2f2ab52948cc274f2adc864a6dc;hp=0a47ea38608c1b579847529045f9387c9d1aac9d;hpb=a2a67cd520b9841114d69a87a423dabcb3b4368e;p=ghc-hetmet.git diff --git a/rts/Trace.c b/rts/Trace.c index 0a47ea3..7194651 100644 --- a/rts/Trace.c +++ b/rts/Trace.c @@ -6,25 +6,18 @@ * * ---------------------------------------------------------------------------*/ -#ifdef DEBUG - // external headers #include "Rts.h" -#include "rts/Flags.h" + +#ifdef TRACING // internal headers #include "Trace.h" #include "GetTime.h" #include "Stats.h" - -/* - Features we want: - - multiple log message classes - - outpout thread ID & time on each message - - thread-safe - - trace source locations? - - break into the debugger? -*/ +#include "eventlog/EventLog.h" +#include "Threads.h" +#include "Printer.h" StgWord32 classes_enabled; // not static due to inline funcs @@ -32,8 +25,9 @@ StgWord32 classes_enabled; // not static due to inline funcs static Mutex trace_utx; #endif -#define DEBUG_FLAG(name, class) \ - if (RtsFlags.DebugFlags.name) classes_enabled |= class; +/* --------------------------------------------------------------------------- + Starting up / shuttting down the tracing facilities + --------------------------------------------------------------------------- */ void initTracing (void) { @@ -41,7 +35,13 @@ void initTracing (void) initMutex(&trace_utx); #endif +#ifdef DEBUG +#define DEBUG_FLAG(name, class) \ + if (RtsFlags.DebugFlags.name) classes_enabled |= class; + 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); DEBUG_FLAG(gccafs, DEBUG_gccafs); @@ -51,40 +51,206 @@ void initTracing (void) DEBUG_FLAG(stable, DEBUG_stable); DEBUG_FLAG(stm, DEBUG_stm); DEBUG_FLAG(prof, DEBUG_prof); - DEBUG_FLAG(eventlog, DEBUG_eventlog); DEBUG_FLAG(linker, DEBUG_linker); DEBUG_FLAG(squeeze, DEBUG_squeeze); DEBUG_FLAG(hpc, DEBUG_hpc); + DEBUG_FLAG(sparks, DEBUG_sparks); +#endif + +#define TRACE_FLAG(name, class) \ + if (RtsFlags.TraceFlags.name) classes_enabled |= class; + + TRACE_FLAG(scheduler, TRACE_sched); + + initEventLogging(); +} + +void endTracing (void) +{ + endEventLogging(); +} + +void freeTracing (void) +{ + freeEventLogging(); } +/* --------------------------------------------------------------------------- + Emitting trace messages/events + --------------------------------------------------------------------------- */ + +#ifdef DEBUG static void tracePreface (void) { #ifdef THREADED_RTS debugBelch("%12lx: ", (unsigned long)osThreadId()); #endif - if (RtsFlags.DebugFlags.timestamp) { + if (RtsFlags.TraceFlags.timestamp) { debugBelch("%9" FMT_Word64 ": ", stat_getElapsedTime()); } } +#endif + +#ifdef DEBUG +static char *thread_stop_reasons[] = { + [HeapOverflow] = "heap overflow", + [StackOverflow] = "stack overflow", + [ThreadYielding] = "yielding", + [ThreadBlocked] = "blocked", + [ThreadFinished] = "finished", + [THREAD_SUSPENDED_FOREIGN_CALL] = "suspended while making a foreign call" +}; +#endif -void trace (StgWord32 class, const char *str, ...) +#ifdef DEBUG +static void traceSchedEvent_stderr (Capability *cap, EventTypeNum tag, + StgTSO *tso, + StgWord64 other STG_UNUSED) { - va_list ap; - va_start(ap,str); + ACQUIRE_LOCK(&trace_utx); + + tracePreface(); + switch (tag) { + case EVENT_CREATE_THREAD: // (cap, thread) + debugBelch("cap %d: created thread %lu\n", + cap->no, (lnat)tso->id); + break; + case EVENT_RUN_THREAD: // (cap, thread) + 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 %lu appended to run queue\n", + cap->no, (lnat)tso->id); + break; + case EVENT_RUN_SPARK: // (cap, thread) + 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 %lu\n", + cap->no, (long)other); + break; + case EVENT_MIGRATE_THREAD: // (cap, thread, new_cap) + debugBelch("cap %d: thread %lu migrating to cap %d\n", + cap->no, (lnat)tso->id, (int)other); + break; + case EVENT_STEAL_SPARK: // (cap, thread, victim_cap) + debugBelch("cap %d: thread %lu stealing a spark from cap %d\n", + cap->no, (lnat)tso->id, (int)other); + break; + case EVENT_THREAD_WAKEUP: // (cap, thread, other_cap) + debugBelch("cap %d: waking up thread %lu on cap %d\n", + cap->no, (lnat)tso->id, (int)other); + break; + + case EVENT_STOP_THREAD: // (cap, thread, status) + debugBelch("cap %d: thread %lu stopped (%s)\n", + cap->no, (lnat)tso->id, thread_stop_reasons[other]); + break; + case EVENT_SHUTDOWN: // (cap) + debugBelch("cap %d: shutting down\n", cap->no); + break; + case EVENT_REQUEST_SEQ_GC: // (cap) + debugBelch("cap %d: requesting sequential GC\n", cap->no); + break; + case EVENT_REQUEST_PAR_GC: // (cap) + debugBelch("cap %d: requesting parallel GC\n", cap->no); + break; + case EVENT_GC_START: // (cap) + debugBelch("cap %d: starting GC\n", cap->no); + break; + case EVENT_GC_END: // (cap) + debugBelch("cap %d: finished GC\n", cap->no); + break; + default: + debugBelch("cap %2d: thread %lu: event %d\n\n", + cap->no, (lnat)tso->id, tag); + break; + } + + RELEASE_LOCK(&trace_utx); +} +#endif +void traceSchedEvent_ (Capability *cap, EventTypeNum tag, + StgTSO *tso, StgWord64 other) +{ +#ifdef DEBUG + if (RtsFlags.TraceFlags.trace_stderr) { + traceSchedEvent_stderr(cap, tag, tso, other); + } else +#endif + { + postSchedEvent(cap,tag,tso ? tso->id : 0,other); + } +} + +#ifdef DEBUG +static void traceCap_stderr(Capability *cap, char *msg, va_list ap) +{ ACQUIRE_LOCK(&trace_utx); - if ((classes_enabled & class) != 0) { - tracePreface(); - vdebugBelch(str,ap); - debugBelch("\n"); + tracePreface(); + debugBelch("cap %2d: ", cap->no); + vdebugBelch(msg,ap); + debugBelch("\n"); + + RELEASE_LOCK(&trace_utx); +} +#endif + +void traceCap_(Capability *cap, char *msg, va_list ap) +{ +#ifdef DEBUG + if (RtsFlags.TraceFlags.trace_stderr) { + traceCap_stderr(cap, msg, ap); + } else +#endif + { + postCapMsg(cap, msg, ap); } +} + +#ifdef DEBUG +static void trace_stderr(char *msg, va_list ap) +{ + ACQUIRE_LOCK(&trace_utx); + + tracePreface(); + vdebugBelch(msg,ap); + debugBelch("\n"); RELEASE_LOCK(&trace_utx); +} +#endif - va_end(ap); +void trace_(char *msg, va_list ap) +{ +#ifdef DEBUG + if (RtsFlags.TraceFlags.trace_stderr) { + trace_stderr(msg, ap); + } else +#endif + { + postMsg(msg, ap); + } } +void traceThreadStatus_ (StgTSO *tso USED_IF_DEBUG) +{ +#ifdef DEBUG + if (RtsFlags.TraceFlags.trace_stderr) { + printThreadStatus(tso); + } else +#endif + { + /* nothing - no event for this one yet */ + } +} + + +#ifdef DEBUG void traceBegin (const char *str, ...) { va_list ap; @@ -101,5 +267,6 @@ void traceEnd (void) debugBelch("\n"); RELEASE_LOCK(&trace_utx); } +#endif /* DEBUG */ -#endif +#endif /* TRACING */