[project @ 2000-03-17 10:24:44 by simonmar]
[ghc-hetmet.git] / ghc / rts / Stats.c
index 097b5b9..547ca27 100644 (file)
@@ -1,5 +1,5 @@
 /* -----------------------------------------------------------------------------
- * $Id: Stats.c,v 1.16 1999/11/02 17:19:16 simonmar Exp $
+ * $Id: Stats.c,v 1.20 2000/01/12 15:15:18 simonmar Exp $
  *
  * (c) The GHC Team, 1998-1999
  *
@@ -63,9 +63,11 @@ static double TicksPerSecond   = 0.0;
 
 static double InitUserTime = 0.0;
 static double InitElapsedTime = 0.0;
+static double InitElapsedStamp = 0.0;
 
 static double MutUserTime = 0.0;
 static double MutElapsedTime = 0.0;
+static double MutElapsedStamp = 0.0;
 
 static double ExitUserTime = 0.0;
 static double ExitElapsedTime = 0.0;
@@ -117,7 +119,7 @@ elapsedtime(void)
 
     FT2longlong(kT,kernelTime);
     FT2longlong(uT,userTime);
-    return (((StgDouble)(uT + kT))/TicksPerSecond - ElapsedTimeStart);
+    return (((StgDouble)(uT + kT))/TicksPerSecond);
 }
 
 #else 
@@ -125,6 +127,7 @@ elapsedtime(void)
 double
 elapsedtime(void)
 {
+
 # if ! (defined(HAVE_TIMES) || defined(HAVE_FTIME))
     /* We will #ifdef around the fprintf for machines
        we *know* are unsupported. (WDP 94/05)
@@ -142,13 +145,13 @@ elapsedtime(void)
     struct tms t;
     clock_t r = times(&t);
 
-    return (((double)r)/TicksPerSecond - ElapsedTimeStart);
+    return (((double)r)/TicksPerSecond);
 
 #  else /* HAVE_FTIME */
     struct timeb t;
 
     ftime(&t);
-    return (fabs(t.time + 1e-3*t.millitm - ElapsedTimeStart));
+    return (fabs(t.time + 1e-3*t.millitm));
 
 #  endif /* HAVE_FTIME */
 # endif /* not stumped */
@@ -157,9 +160,15 @@ elapsedtime(void)
 
 /* mut_user_time_during_GC() and mut_user_time()
  *
- * This function can be used to get the current mutator time *during*
- * a GC, i.e. between stat_startGC and stat_endGC.  This is used in
- * the heap profiler for accurately time stamping the heap sample.
+ * The former function can be used to get the current mutator time
+ * *during* a GC, i.e. between stat_startGC and stat_endGC.  This is
+ * used in the heap profiler for accurately time stamping the heap
+ * sample.  
+ *
+ * ATTENTION: mut_user_time_during_GC() relies on GC_start_time being 
+ *           defined in stat_startGC() - to minimise system calls, 
+ *           GC_start_time is, however, only defined when really needed (check
+ *           stat_startGC() for details)
  */
 double
 mut_user_time_during_GC(void)
@@ -294,16 +303,24 @@ void
 end_init(void)
 {
   InitUserTime = usertime();
-  InitElapsedTime = elapsedtime();
+  InitElapsedStamp = elapsedtime(); 
+  InitElapsedTime = InitElapsedStamp - ElapsedTimeStart;
   if (InitElapsedTime < 0.0) {
     InitElapsedTime = 0.0;
   }
 }
 
+/* -----------------------------------------------------------------------------
+   stat_startExit and stat_endExit
+   
+   These two measure the time taken in shutdownHaskell().
+   -------------------------------------------------------------------------- */
+
 void
 stat_startExit(void)
 {
-  MutElapsedTime = elapsedtime() - GCe_tot_time - InitElapsedTime;
+  MutElapsedStamp = elapsedtime(); 
+  MutElapsedTime = MutElapsedStamp - GCe_tot_time - InitElapsedStamp;
   if (MutElapsedTime < 0) { MutElapsedTime = 0; }      /* sometimes -0.00 */
 
   /* for SMP, we don't know the mutator time yet, we have to inspect
@@ -316,6 +333,7 @@ stat_startExit(void)
   MutUserTime = usertime();
 #else
   MutUserTime = usertime() - GC_tot_time - InitUserTime;
+  if (MutUserTime < 0) { MutUserTime = 0; }
 #endif
 }
 
@@ -327,7 +345,7 @@ stat_endExit(void)
 #else
   ExitUserTime = usertime() - MutUserTime - GC_tot_time - InitUserTime;
 #endif
-  ExitElapsedTime = elapsedtime() - MutElapsedTime;
+  ExitElapsedTime = elapsedtime() - MutElapsedStamp;
   if (ExitUserTime < 0.0) {
     ExitUserTime = 0.0;
   }
@@ -342,6 +360,11 @@ stat_endExit(void)
 
 static nat rub_bell = 0;
 
+/*  initialise global variables needed during GC
+ *
+ *  * GC_start_time is read in mut_user_time_during_GC(), which in turn is 
+ *    needed if either PROFILING or DEBUGing is enabled
+ */
 void
 stat_startGC(void)
 {
@@ -358,8 +381,14 @@ stat_startGC(void)
        }
     }
 
+#if defined(PROFILING) || defined(DEBUG)
+    GC_start_time = usertime();  /* needed in mut_user_time_during_GC() */
+#endif
+
     if (sf != NULL) {
-       GC_start_time = usertime();
+#if !defined(PROFILING) && !defined(DEBUG)
+        GC_start_time = usertime();
+#endif
        GCe_start_time = elapsedtime();
        if (RtsFlags.GcFlags.giveStats) {
          GC_start_faults = pagefaults();
@@ -379,8 +408,8 @@ stat_endGC(lnat alloc, lnat collect, lnat live, lnat copied, lnat gen)
     if (sf != NULL) {
        double time     = usertime();
        double etime    = elapsedtime();
-       double gc_time  = time-GC_start_time;
-       double gc_etime = etime-GCe_start_time;
+       double gc_time  = time - GC_start_time;
+       double gc_etime = etime - GCe_start_time;
 
        if (RtsFlags.GcFlags.giveStats >= VERBOSE_GC_STATS) {
            nat faults = pagefaults();
@@ -391,7 +420,7 @@ stat_endGC(lnat alloc, lnat collect, lnat live, lnat copied, lnat gen)
                    gc_time, 
                    gc_etime,
                    time,
-                   etime,
+                   etime - ElapsedTimeStart,
                    faults - GC_start_faults,
                    GC_start_faults - GC_end_faults,
                    gen);
@@ -400,19 +429,19 @@ stat_endGC(lnat alloc, lnat collect, lnat live, lnat copied, lnat gen)
            fflush(sf);
        }
 
-       GC_coll_times[gen] += time-GC_start_time;
+       GC_coll_times[gen] += gc_time;
 
        GC_tot_copied += (ullong) copied;
        GC_tot_alloc  += (ullong) alloc;
-       GC_tot_time   += time-GC_start_time;
-       GCe_tot_time  += etime-GCe_start_time;
+       GC_tot_time   += gc_time;
+       GCe_tot_time  += gc_etime;
 
 #ifdef SMP
        {
          nat i;
          pthread_t me = pthread_self();
 
-         for (i = 0; i < RtsFlags.ConcFlags.nNodes; i++) {
+         for (i = 0; i < RtsFlags.ParFlags.nNodes; i++) {
            if (me == task_ids[i].id) {
              task_ids[i].gc_time += gc_time;
              task_ids[i].gc_etime += gc_etime;
@@ -437,6 +466,33 @@ stat_endGC(lnat alloc, lnat collect, lnat live, lnat copied, lnat gen)
 }
 
 /* -----------------------------------------------------------------------------
+   stat_workerStop
+
+   Called under SMP when a worker thread finishes.  We drop the timing
+   stats for this thread into the task_ids struct for that thread.
+   -------------------------------------------------------------------------- */
+
+#ifdef SMP
+void
+stat_workerStop(void)
+{
+  nat i;
+  pthread_t me = pthread_self();
+
+  for (i = 0; i < RtsFlags.ParFlags.nNodes; i++) {
+    if (task_ids[i].id == me) {
+      task_ids[i].mut_time = usertime() - task_ids[i].gc_time;
+      task_ids[i].mut_etime = elapsedtime()
+                                - GCe_tot_time
+                                - task_ids[i].elapsedtimestart;
+      if (task_ids[i].mut_time < 0.0)  { task_ids[i].mut_time = 0.0;  }
+      if (task_ids[i].mut_etime < 0.0) { task_ids[i].mut_etime = 0.0; }
+    }
+  }
+}
+#endif
+
+/* -----------------------------------------------------------------------------
    Called at the end of execution
 
    NOTE: number of allocations is not entirely accurate: it doesn't
@@ -452,7 +508,7 @@ stat_exit(int alloc)
     if (sf != NULL){
        char temp[BIG_STRING_LEN];
        double time = usertime();
-       double etime = elapsedtime();
+       double etime = elapsedtime() - ElapsedTimeStart;
 
        /* avoid divide by zero if time is measured as 0.00 seconds -- SDM */
        if (time  == 0.0)  time = 0.0001;
@@ -496,15 +552,17 @@ stat_exit(int alloc)
        {
          nat i;
          MutUserTime = 0.0;
-         for (i = 0; i < RtsFlags.ConcFlags.nNodes; i++) {
+         for (i = 0; i < RtsFlags.ParFlags.nNodes; i++) {
            MutUserTime += task_ids[i].mut_time;
-           fprintf(sf, "  Task %2d:  MUT time: %6.2fs,  GC time: %6.2fs\n", 
-                   i, task_ids[i].mut_time, task_ids[i].gc_time);
+           fprintf(sf, "  Task %2d:  MUT time: %6.2fs  (%6.2fs elapsed)\n"
+                       "            GC  time: %6.2fs  (%6.2fs elapsed)\n\n", 
+                   i, 
+                   task_ids[i].mut_time, task_ids[i].mut_etime,
+                   task_ids[i].gc_time, task_ids[i].gc_etime);
          }
        }
        time = MutUserTime + GC_tot_time + InitUserTime + ExitUserTime;
        if (MutUserTime < 0) { MutUserTime = 0; }
-       fprintf(sf,"\n");
 #endif
 
        fprintf(sf, "  INIT  time  %6.2fs  (%6.2fs elapsed)\n",