Passed

org.gecko.util.PushstreamPerformanceTest.test2StreamsOptimizedMeasure

Standard Output

1619529269817 pub message-100[47]
1619529271338 sub message-102[47][205] took 1443ms
1619529272921 pub message-200[36]
1619529275551 sub message-199[46][373] took 2666ms
1619529276082 pub message-300[12]
1619529279121 pub message-400[45]
1619529279958 sub message-301[24][281] took 3852ms
1619529282289 pub message-500[33]
1619529284323 sub message-400[45][333] took 5202ms
1619529288526 sub message-500[33][316] took 6237ms
MultiThreaded 8x buffer 100 fixed 10 test took 21604ms request time is: 149
...[truncated 1788 chars]...
-100[23]
1619529366226 sub message-101[41][212] took -1ms
1619529371076 pub message-200[60]
1619529371471 sub message-200[60][395] took -1ms
1619529375906 pub message-300[21]
1619529376309 sub message-303[87][236] took -1ms
1619529381437 pub message-400[36]
1619529381798 sub message-399[49][397] took -1ms
1619529387303 pub message-500[10]
MultiThreaded 8x buffer 100 fixed on full 10 test took 27296ms request time is: 26808, worker time is: 177228
1619529387736 sub message-499[35][443] took -1ms

Standard Error

Apr 27, 2021 1:14:29 PM org.gecko.util.pushstreams.policy.FixedGradePushbackPolicy pushback
INFO: [stream] Buffersize: 100 , remaining elements: 70, remaining fill grade: 20
Apr 27, 2021 1:14:32 PM org.gecko.util.pushstreams.policy.FixedGradePushbackPolicy pushback
INFO: [stream] Buffersize: 100 , remaining elements: 44, remaining fill grade: 20
Apr 27, 2021 1:14:36 PM org.gecko.util.pushstreams.policy.FixedGradePushbackPolicy pushback
INFO: [stream] Backpressure: 5 , remaining: 19, remaining fi
...[truncated 4755 chars]...
cko.util.pushstreams.policy.GradualBreakingQueuePolicy doOffer
INFO: [source] Buffersize: 100 , remaining elements: 20, remaining fill grade: 20
Apr 27, 2021 1:15:24 PM org.gecko.util.pushstreams.policy.GradualBreakingQueuePolicy doOffer
INFO: [source] Breaking offer for: 0 ms, remaining elements: 20, remaining fill grade: 20
Apr 27, 2021 1:15:28 PM org.gecko.util.pushstreams.policy.FixedGradePushbackPolicy pushback
INFO: [stream] Buffersize: 100 , remaining elements: 0, remaining fill grade: 0