Passed

org.gecko.util.PushstreamPerformanceTest.test2StreamsOptimizedMeasure

Standard Output

1633522422419 pub message-100[38]
1633522424258 sub message-100[38][260] took 1834ms
1633522425489 pub message-200[33]
1633522428454 pub message-300[47]
1633522428993 sub message-201[49][283] took 3454ms
1633522431513 pub message-400[34]
1633522433507 sub message-301[13][277] took 5039ms
1633522435854 pub message-500[33]
1633522437833 sub message-397[21][479] took 6449ms
1633522442294 sub message-498[40][453] took 6529ms
MultiThreaded 8x buffer 100 fixed 10 test took 22862ms request time is: 147
...[truncated 1786 chars]...
e-100[31]
1633522519602 sub message-98[55][483] took -1ms
1633522524796 pub message-200[28]
1633522525169 sub message-198[62][443] took -1ms
1633522530177 pub message-300[60]
1633522530522 sub message-300[60][344] took -1ms
1633522535762 pub message-400[17]
1633522536099 sub message-396[69][454] took -1ms
1633522540937 pub message-500[46]
MultiThreaded 8x buffer 100 fixed on full 10 test took 27144ms request time is: 26715, worker time is: 173328
1633522541315 sub message-500[46][377] took -1ms

Standard Error

Oct 06, 2021 12:13:42 PM org.gecko.util.pushstreams.policy.FixedGradePushbackPolicy pushback
INFO: [stream] Buffersize: 100 , remaining elements: 66, remaining fill grade: 20
Oct 06, 2021 12:13:45 PM org.gecko.util.pushstreams.policy.FixedGradePushbackPolicy pushback
INFO: [stream] Buffersize: 100 , remaining elements: 31, remaining fill grade: 20
Oct 06, 2021 12:13:47 PM org.gecko.util.pushstreams.policy.FixedGradePushbackPolicy pushback
INFO: [stream] Buffersize: 100 , remaining elements: 12, 
...[truncated 2158 chars]...
o.util.pushstreams.policy.GradualBreakingQueuePolicy doOffer
INFO: [source] Buffersize: 100 , remaining elements: 17, remaining fill grade: 20
Oct 06, 2021 12:14:38 PM org.gecko.util.pushstreams.policy.GradualBreakingQueuePolicy doOffer
INFO: [source] Breaking offer for: 6 ms, remaining elements: 18, remaining fill grade: 20
Oct 06, 2021 12:14:41 PM org.gecko.util.pushstreams.policy.FixedGradePushbackPolicy pushback
INFO: [stream] Buffersize: 100 , remaining elements: 0, remaining fill grade: 0