Passed

org.gecko.util.PushstreamPerformanceTest.test2StreamsOptimizedMeasure

Standard Output

1619703543099 pub message-100[47]
1619703544627 sub message-100[47][426] took 1523ms
1619703546048 pub message-200[17]
1619703548772 pub message-300[36]
1619703548936 sub message-200[17][347] took 2888ms
1619703551629 pub message-400[24]
1619703553259 sub message-300[36][317] took 4487ms
1619703555581 pub message-500[15]
1619703557705 sub message-398[41][437] took 6113ms
1619703562046 sub message-498[13][337] took 6547ms
MultiThreaded 8x buffer 100 fixed 10 test took 21993ms request time is: 145
...[truncated 1786 chars]...
e-100[67]
1619703640691 sub message-99[41][507] took -1ms
1619703645853 pub message-200[46]
1619703646168 sub message-202[80][194] took -1ms
1619703651581 pub message-300[49]
1619703651969 sub message-301[41][346] took -1ms
1619703656905 pub message-400[22]
1619703657250 sub message-399[71][367] took -1ms
1619703662429 pub message-500[52]
MultiThreaded 8x buffer 100 fixed on full 10 test took 28048ms request time is: 27626, worker time is: 174254
1619703662791 sub message-497[92][487] took -1ms

Standard Error

Apr 29, 2021 1:39:03 PM org.gecko.util.pushstreams.policy.FixedGradePushbackPolicy pushback
INFO: [stream] Buffersize: 100 , remaining elements: 73, remaining fill grade: 20
Apr 29, 2021 1:39:06 PM org.gecko.util.pushstreams.policy.FixedGradePushbackPolicy pushback
INFO: [stream] Buffersize: 100 , remaining elements: 41, remaining fill grade: 20
Apr 29, 2021 1:39:08 PM org.gecko.util.pushstreams.policy.FixedGradePushbackPolicy pushback
INFO: [stream] Buffersize: 100 , remaining elements: 15, rem
...[truncated 2140 chars]...
cko.util.pushstreams.policy.GradualBreakingQueuePolicy doOffer
INFO: [source] Buffersize: 100 , remaining elements: 16, remaining fill grade: 20
Apr 29, 2021 1:39:58 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 1:40:02 PM org.gecko.util.pushstreams.policy.FixedGradePushbackPolicy pushback
INFO: [stream] Buffersize: 100 , remaining elements: 0, remaining fill grade: 0