Passed

org.gecko.core.pushstream.PushstreamPerformanceTest.testOptimized02

Standard Output

1594489101180 pub message-100[33]
1594489102982 sub message-104[36][229] took 1656ms
1594489104208 pub message-200[11]
1594489107199 sub message-199[45][402] took 3002ms
1594489107254 pub message-300[25]
1594489110333 pub message-400[42]
1594489111495 sub message-296[46][419] took 4354ms
1594489113866 pub message-500[31]
1594489115954 sub message-398[33][488] took 5677ms
1594489120169 sub message-495[29][493] took 6510ms
MultiThreaded 8x buffer 100 fixed 10 test took 21947ms request time is: 149
...[truncated 1785 chars]...
e-100[36]
1594489198360 sub message-98[45][360] took -1ms
1594489203092 pub message-200[75]
1594489203451 sub message-197[22][473] took -1ms
1594489208534 pub message-300[76]
1594489208828 sub message-301[12][282] took -1ms
1594489214054 pub message-400[53]
1594489214437 sub message-398[85][489] took -1ms
1594489219267 pub message-500[57]
1594489219585 sub message-500[57][318] took -1ms
MultiThreaded 8x buffer 100 fixed on full 10 test took 26963ms request time is: 26578, worker time is: 176245

Standard Error

Jul 11, 2020 5:38:21 PM org.gecko.core.pushstream.policy.FixedGradePushbackPolicy pushback
INFO: [stream] Buffersize: 100 , remaining elements: 67, remaining fill grade: 20
Jul 11, 2020 5:38:24 PM org.gecko.core.pushstream.policy.FixedGradePushbackPolicy pushback
INFO: [stream] Buffersize: 100 , remaining elements: 37, remaining fill grade: 20
Jul 11, 2020 5:38:25 PM org.gecko.core.pushstream.policy.FixedGradePushbackPolicy pushback
INFO: [stream] Backpressure: 5 , remaining: 19, remaining fill 
...[truncated 2287 chars]...
gecko.core.pushstream.policy.GradualBreakingQueuePolicy doOffer
INFO: [source] Buffersize: 100 , remaining elements: 15, remaining fill grade: 20
Jul 11, 2020 5:39:16 PM org.gecko.core.pushstream.policy.GradualBreakingQueuePolicy doOffer
INFO: [source] Breaking offer for: 10 ms, remaining elements: 15, remaining fill grade: 20
Jul 11, 2020 5:39:20 PM org.gecko.core.pushstream.policy.FixedGradePushbackPolicy pushback
INFO: [stream] Buffersize: 100 , remaining elements: 0, remaining fill grade: 0