Passed

org.gecko.util.PushstreamPerformanceTest.testOptimized02

Standard Output

1619700823026 pub message-100[25]
1619700824774 sub message-98[15][504] took 1790ms
1619700825945 pub message-200[28]
1619700828946 pub message-300[30]
1619700828968 sub message-204[38][199] took 2874ms
1619700831830 pub message-400[20]
1619700833376 sub message-301[40][345] took 4389ms
1619700835744 pub message-500[30]
1619700837738 sub message-395[49][481] took 6021ms
1619700842290 sub message-500[30][420] took 6546ms
MultiThreaded 8x buffer 100 fixed 10 test took 22060ms request time is: 1439
...[truncated 1785 chars]...
-100[37]
1619700920138 sub message-103[36][216] took -1ms
1619700925158 pub message-200[78]
1619700925565 sub message-202[88][224] took -1ms
1619700930513 pub message-300[25]
1619700930878 sub message-301[33][279] took -1ms
1619700936236 pub message-400[15]
1619700936658 sub message-401[94][327] took -1ms
1619700941829 pub message-500[57]
1619700942272 sub message-500[57][442] took -1ms
MultiThreaded 8x buffer 100 fixed on full 10 test took 28095ms request time is: 27588, worker time is: 175275

Standard Error

Apr 29, 2021 12:53:43 PM org.gecko.util.pushstreams.policy.FixedGradePushbackPolicy pushback
INFO: [stream] Buffersize: 100 , remaining elements: 68, remaining fill grade: 20
Apr 29, 2021 12:53:45 PM org.gecko.util.pushstreams.policy.FixedGradePushbackPolicy pushback
INFO: [stream] Buffersize: 100 , remaining elements: 38, remaining fill grade: 20
Apr 29, 2021 12:53:48 PM org.gecko.util.pushstreams.policy.FixedGradePushbackPolicy pushback
INFO: [stream] Backpressure: 25 , remaining: 15, remainin
...[truncated 5122 chars]...
o.util.pushstreams.policy.GradualBreakingQueuePolicy doOffer
INFO: [source] Buffersize: 100 , remaining elements: 17, remaining fill grade: 20
Apr 29, 2021 12:54:38 PM org.gecko.util.pushstreams.policy.GradualBreakingQueuePolicy doOffer
INFO: [source] Breaking offer for: 6 ms, remaining elements: 17, remaining fill grade: 20
Apr 29, 2021 12:54:41 PM org.gecko.util.pushstreams.policy.FixedGradePushbackPolicy pushback
INFO: [stream] Buffersize: 100 , remaining elements: 0, remaining fill grade: 0