Passed

org.gecko.util.PushstreamPerformanceTest.test2StreamsOptimized

Standard Output

1619690266106 pub message-100[38]
1619690268026 sub message-97[28][508] took 1999ms
1619690269171 pub message-200[14]
1619690272028 pub message-300[41]
1619690272331 sub message-197[42][475] took 3230ms
1619690275082 pub message-400[45]
1619690276654 sub message-303[10][202] took 4530ms
1619690278986 pub message-500[34]
1619690280988 sub message-402[13][210] took 5846ms
1619690285731 sub message-500[34][476] took 6745ms
MultiThreaded 8x buffer 100 fixed 10 test took 22546ms request time is: 1459
...[truncated 1787 chars]...
-100[92]
1619690364534 sub message-102[58][201] took -1ms
1619690369534 pub message-200[91]
1619690369819 sub message-198[30][399] took -1ms
1619690375153 pub message-300[45]
1619690375489 sub message-301[78][258] took -1ms
1619690380574 pub message-400[94]
1619690380885 sub message-397[72][426] took -1ms
1619690386129 pub message-500[79]
MultiThreaded 8x buffer 100 fixed on full 10 test took 27773ms request time is: 27360, worker time is: 175818
1619690386492 sub message-500[79][362] took -1ms

Standard Error

Apr 29, 2021 9:57:46 AM org.gecko.util.pushstreams.policy.FixedGradePushbackPolicy pushback
INFO: [stream] Buffersize: 100 , remaining elements: 67, remaining fill grade: 20
Apr 29, 2021 9:57:49 AM org.gecko.util.pushstreams.policy.FixedGradePushbackPolicy pushback
INFO: [stream] Buffersize: 100 , remaining elements: 36, remaining fill grade: 20
Apr 29, 2021 9:57:51 AM org.gecko.util.pushstreams.policy.FixedGradePushbackPolicy pushback
INFO: [stream] Buffersize: 100 , remaining elements: 13, rem
...[truncated 2324 chars]...
ko.util.pushstreams.policy.GradualBreakingQueuePolicy doOffer
INFO: [source] Buffersize: 100 , remaining elements: 14, remaining fill grade: 20
Apr 29, 2021 9:58:41 AM org.gecko.util.pushstreams.policy.GradualBreakingQueuePolicy doOffer
INFO: [source] Breaking offer for: 12 ms, remaining elements: 14, remaining fill grade: 20
Apr 29, 2021 9:58:45 AM org.gecko.util.pushstreams.policy.FixedGradePushbackPolicy pushback
INFO: [stream] Buffersize: 100 , remaining elements: 0, remaining fill grade: 0