returning workCount and trySend result to improve debugging

Author: lucianoviana

artio-system-tests/src/test/java/uk/co/real_logic/artio/system_tests/SlowConsumerTest.java

@@ -25,6 +25,7 @@
 import org.junit.runner.RunWith;
 import org.junit.runners.Parameterized;
 import org.junit.runners.Parameterized.Parameters;
+
 import uk.co.real_logic.artio.Timing;
 import uk.co.real_logic.artio.builder.Encoder;
 import uk.co.real_logic.artio.builder.LogonEncoder;
@@ -173,16 +174,16 @@ private void sessionBecomesSlow()
         assertTrue(session.isSlowConsumer());
     }
 
-    private void sendMessage()
+    private long sendMessage()
     {
         if (sendMetadata)
         {
             metadata.putInt(0, session.lastSentMsgSeqNum() + 1);
-            session.trySend(testRequest, metadata, 0);
+            return session.trySend(testRequest, metadata, 0);
         }
         else
         {
-            session.trySend(testRequest);
+            return session.trySend(testRequest);
         }
     }
 

artio-system-tests/src/test/java/uk/co/real_logic/artio/system_tests/TestSystem.java

@@ -80,15 +80,17 @@ public TestSystem awaitTimeoutInMs(final long awaitTimeoutInMs)
         return this;
     }
 
-    public void poll()
+    public int poll()
     {
+        int resultInvokeFramer = 0;
         if (scheduler != null)
         {
-            scheduler.invokeFramer();
-            scheduler.invokeFramer();
+            resultInvokeFramer = scheduler.invokeFramer();
         }
-        libraries.forEach((library) -> library.poll(LIBRARY_LIMIT));
+        final int result = resultInvokeFramer + libraries.stream().mapToInt((library) ->
+            library.poll(LIBRARY_LIMIT)).sum();
         operations.forEach(Runnable::run);
+        return result;
     }
 
     public void addOperation(final Runnable operation)