Passed

org.gecko.util.PushstreamPerformanceTest.test2StreamsOptimizedMeasure

Standard Output

1619705224747 pub message-100[15]
1619705226618 sub message-99[45][480] took 1887ms
1619705227571 pub message-200[32]
1619705230485 pub message-300[12]
1619705230858 sub message-200[32][220] took 3287ms
1619705233565 pub message-400[42]
1619705235182 sub message-298[16][393] took 4737ms
1619705237549 pub message-500[21]
1619705239486 sub message-405[45][196] took 5759ms
1619705243646 sub message-500[21][429] took 6097ms
MultiThreaded 8x buffer 100 fixed 10 test took 21752ms request time is: 1444
...[truncated 1787 chars]...
-100[73]
1619705322321 sub message-101[16][400] took -1ms
1619705326965 pub message-200[15]
1619705327393 sub message-200[15][427] took -1ms
1619705332361 pub message-300[12]
1619705332769 sub message-298[80][439] took -1ms
1619705337988 pub message-400[53]
1619705338397 sub message-400[53][409] took -1ms
1619705343405 pub message-500[54]
MultiThreaded 8x buffer 100 fixed on full 10 test took 27108ms request time is: 26693, worker time is: 174177
1619705343764 sub message-499[19][386] took -1ms

Standard Error

Apr 29, 2021 2:07:04 PM org.gecko.util.pushstreams.policy.FixedGradePushbackPolicy pushback
INFO: [stream] Buffersize: 100 , remaining elements: 68, remaining fill grade: 20
Apr 29, 2021 2:07:07 PM org.gecko.util.pushstreams.policy.FixedGradePushbackPolicy pushback
INFO: [stream] Buffersize: 100 , remaining elements: 31, remaining fill grade: 20
Apr 29, 2021 2:07:08 PM org.gecko.util.pushstreams.policy.FixedGradePushbackPolicy pushback
INFO: [stream] Backpressure: 5 , remaining: 19, remaining fi
...[truncated 5751 chars]...
cko.util.pushstreams.policy.GradualBreakingQueuePolicy doOffer
INFO: [source] Buffersize: 100 , remaining elements: 16, remaining fill grade: 20
Apr 29, 2021 2:08:00 PM org.gecko.util.pushstreams.policy.GradualBreakingQueuePolicy doOffer
INFO: [source] Breaking offer for: 8 ms, remaining elements: 16, remaining fill grade: 20
Apr 29, 2021 2:08:03 PM org.gecko.util.pushstreams.policy.FixedGradePushbackPolicy pushback
INFO: [stream] Buffersize: 100 , remaining elements: 0, remaining fill grade: 0