Passed

org.gecko.util.PushstreamPerformanceTest.test2StreamsOptimized

Standard Output

1619704992746 pub message-100[22]
1619704994276 sub message-105[34][266] took 1352ms
1619704995578 pub message-200[38]
1619704998553 pub message-300[40]
1619704998651 sub message-199[27][328] took 3111ms
1619705001648 pub message-400[22]
1619705002847 sub message-300[40][240] took 4294ms
1619705005326 pub message-500[21]
1619705007373 sub message-396[20][504] took 5833ms
1619705011616 sub message-499[20][341] took 6340ms
MultiThreaded 8x buffer 100 fixed 10 test took 21758ms request time is: 147
...[truncated 1786 chars]...
-100[32]
1619705089116 sub message-100[32][348] took -1ms
1619705094006 pub message-200[15]
1619705094492 sub message-202[11][388] took -1ms
1619705099534 pub message-300[84]
1619705099921 sub message-300[84][387] took -1ms
1619705104622 pub message-400[89]
1619705104938 sub message-402[40][205] took -1ms
1619705109627 pub message-500[58]
MultiThreaded 8x buffer 100 fixed on full 10 test took 26637ms request time is: 26172, worker time is: 180553
1619705110030 sub message-500[58][403] took -1ms

Standard Error

Apr 29, 2021 2:03:12 PM org.gecko.util.pushstreams.policy.FixedGradePushbackPolicy pushback
INFO: [stream] Buffersize: 100 , remaining elements: 72, remaining fill grade: 20
Apr 29, 2021 2:03:15 PM org.gecko.util.pushstreams.policy.FixedGradePushbackPolicy pushback
INFO: [stream] Buffersize: 100 , remaining elements: 39, remaining fill grade: 20
Apr 29, 2021 2:03:17 PM org.gecko.util.pushstreams.policy.FixedGradePushbackPolicy pushback
INFO: [stream] Backpressure: 5 , remaining: 19, remaining fi
...[truncated 2122 chars]...
6 PM org.gecko.util.pushstreams.policy.FixedGradePushbackPolicy pushback
INFO: [stream] Buffersize: 100 , remaining elements: 0, remaining fill grade: 0
Apr 29, 2021 2:04:07 PM org.gecko.util.pushstreams.policy.GradualBreakingQueuePolicy doOffer
INFO: [source] Buffersize: 100 , remaining elements: 25, remaining fill grade: 20
Apr 29, 2021 2:04:11 PM org.gecko.util.pushstreams.policy.FixedGradePushbackPolicy pushback
INFO: [stream] Buffersize: 100 , remaining elements: 0, remaining fill grade: 0