Passed

org.gecko.util.PushstreamPerformanceTest.test2StreamsOptimizedMeasure

Standard Output

1619703812308 pub message-100[17]
1619703813949 sub message-99[31][327] took 1658ms
1619703815211 pub message-200[42]
1619703818167 pub message-300[27]
1619703818319 sub message-200[42][292] took 3108ms
1619703820925 pub message-400[42]
1619703822549 sub message-299[44][343] took 4409ms
1619703824876 pub message-500[27]
1619703826769 sub message-401[45][204] took 5799ms
1619703831263 sub message-498[35][473] took 6465ms
MultiThreaded 8x buffer 100 fixed 10 test took 22037ms request time is: 1448
...[truncated 1784 chars]...
e-100[65]
1619703910377 sub message-99[40][396] took -1ms
1619703915694 pub message-200[10]
1619703916115 sub message-202[60][279] took -1ms
1619703921216 pub message-300[21]
1619703921588 sub message-299[82][393] took -1ms
1619703926567 pub message-400[35]
1619703926929 sub message-398[27][410] took -1ms
1619703931745 pub message-500[64]
1619703932083 sub message-500[64][337] took -1ms
MultiThreaded 8x buffer 100 fixed on full 10 test took 27808ms request time is: 27417, worker time is: 177643

Standard Error

Apr 29, 2021 1:43:32 PM org.gecko.util.pushstreams.policy.FixedGradePushbackPolicy pushback
INFO: [stream] Buffersize: 100 , remaining elements: 69, remaining fill grade: 20
Apr 29, 2021 1:43:35 PM org.gecko.util.pushstreams.policy.FixedGradePushbackPolicy pushback
INFO: [stream] Buffersize: 100 , remaining elements: 33, remaining fill grade: 20
Apr 29, 2021 1:43:36 PM org.gecko.util.pushstreams.policy.FixedGradePushbackPolicy pushback
INFO: [stream] Backpressure: 10 , remaining: 18, remaining f
...[truncated 5603 chars]...
cko.util.pushstreams.policy.GradualBreakingQueuePolicy doOffer
INFO: [source] Buffersize: 100 , remaining elements: 17, remaining fill grade: 20
Apr 29, 2021 1:44:27 PM org.gecko.util.pushstreams.policy.GradualBreakingQueuePolicy doOffer
INFO: [source] Breaking offer for: 4 ms, remaining elements: 18, remaining fill grade: 20
Apr 29, 2021 1:44:31 PM org.gecko.util.pushstreams.policy.FixedGradePushbackPolicy pushback
INFO: [stream] Buffersize: 100 , remaining elements: 0, remaining fill grade: 0