fix message numbers

smarr · May 10, 2017 · 88eba66 · 88eba66
1 parent ff64e22
commit 88eba66
Show file tree

Hide file tree

Showing 3 changed files with 4 additions and 1 deletion.
diff --git a/src/som/interpreter/actors/Actor.java b/src/som/interpreter/actors/Actor.java
@@ -384,7 +384,7 @@ protected void onTermination(final Throwable exception) {
 
         synchronized (statsLock) {
           numCreatedActors    += createdActors;
-          numCreatedMessages  += createdMessages;
+          numCreatedMessages  += createdMessages - skippedMessages;
           numCreatedPromises  += createdPromises;
           numResolvedPromises += resolvedPromises;
           numRuinedPromises   += erroredPromises;

diff --git a/src/tools/concurrency/TraceBuffer.java b/src/tools/concurrency/TraceBuffer.java
@@ -344,6 +344,7 @@ private void writeMessage(final EventualMessage em, final long sendTS,
       final long execTS) {
 
     if (em instanceof UntracedMessage) {
+      ((TracingActivityThread) Thread.currentThread()).skippedMessages++;
       return;
     }
 

diff --git a/src/tools/concurrency/TracingActivityThread.java b/src/tools/concurrency/TracingActivityThread.java
@@ -21,6 +21,8 @@ public abstract class TracingActivityThread extends ForkJoinWorkerThread
   protected long nextMessageId;
   protected long nextPromiseId;
 
+  public long skippedMessages = 0;
+
   // Used for tracing, accessed by the ExecAllMessages classes
   public long createdMessages;
   public long resolvedPromises;