Passed

org.gecko.util.PushstreamPerformanceTest.test2StreamsOptimizedMeasure

Standard Output

1619688339495 pub message-100[18]
1619688341288 sub message-104[34][376] took 1643ms
1619688342553 pub message-200[23]
1619688345647 pub message-300[22]
1619688345697 sub message-203[24][262] took 3041ms
1619688348627 pub message-400[20]
1619688350164 sub message-301[24][270] took 4492ms
1619688352530 pub message-500[28]
1619688354615 sub message-404[36][201] took 5897ms
MultiThreaded 8x buffer 100 fixed 10 test took 22547ms request time is: 15074, worker time is: 177153
1619688359012 sub messag
...[truncated 1787 chars]...
e-100[51]
1619688436934 sub message-98[40][491] took -1ms
1619688442161 pub message-200[94]
1619688442476 sub message-197[89][461] took -1ms
1619688447910 pub message-300[56]
1619688448285 sub message-299[66][431] took -1ms
1619688453708 pub message-400[22]
1619688453977 sub message-400[22][238] took -1ms
1619688459276 pub message-500[88]
MultiThreaded 8x buffer 100 fixed on full 10 test took 28521ms request time is: 28069, worker time is: 172916
1619688459675 sub message-500[88][398] took -1ms

Standard Error

Apr 29, 2021 9:25:39 AM org.gecko.util.pushstreams.policy.FixedGradePushbackPolicy pushback
INFO: [stream] Buffersize: 100 , remaining elements: 68, remaining fill grade: 20
Apr 29, 2021 9:25:42 AM org.gecko.util.pushstreams.policy.FixedGradePushbackPolicy pushback
INFO: [stream] Buffersize: 100 , remaining elements: 35, remaining fill grade: 20
Apr 29, 2021 9:25:44 AM org.gecko.util.pushstreams.policy.FixedGradePushbackPolicy pushback
INFO: [stream] Buffersize: 100 , remaining elements: 12, rem
...[truncated 1957 chars]...
4 AM org.gecko.util.pushstreams.policy.FixedGradePushbackPolicy pushback
INFO: [stream] Buffersize: 100 , remaining elements: 0, remaining fill grade: 0
Apr 29, 2021 9:26:35 AM org.gecko.util.pushstreams.policy.GradualBreakingQueuePolicy doOffer
INFO: [source] Buffersize: 100 , remaining elements: 31, remaining fill grade: 20
Apr 29, 2021 9:26:38 AM org.gecko.util.pushstreams.policy.FixedGradePushbackPolicy pushback
INFO: [stream] Buffersize: 100 , remaining elements: 0, remaining fill grade: 0