Passed

org.gecko.util.PushstreamPerformanceTest.test2StreamsOptimized

Standard Output

1619704078638 pub message-100[35]
1619704080029 sub message-102[34][245] took 1321ms
1619704081644 pub message-200[41]
1619704084312 sub message-199[35][355] took 2710ms
1619704084529 pub message-300[10]
1619704087474 pub message-400[24]
1619704089070 sub message-297[49][496] took 4600ms
1619704091423 pub message-500[28]
1619704093355 sub message-402[34][310] took 5812ms
MultiThreaded 8x buffer 100 fixed 10 test took 22000ms request time is: 14856, worker time is: 173666
1619704097577 sub messag
...[truncated 1784 chars]...
e-100[37]
1619704175949 sub message-99[16][309] took -1ms
1619704180753 pub message-200[66]
1619704181047 sub message-202[55][216] took -1ms
1619704186010 pub message-300[76]
1619704186297 sub message-300[76][287] took -1ms
1619704191243 pub message-400[87]
1619704191514 sub message-403[27][191] took -1ms
1619704196440 pub message-500[98]
1619704196875 sub message-500[98][435] took -1ms
MultiThreaded 8x buffer 100 fixed on full 10 test took 27119ms request time is: 26622, worker time is: 172592

Standard Error

Apr 29, 2021 1:47:58 PM org.gecko.util.pushstreams.policy.FixedGradePushbackPolicy pushback
INFO: [stream] Buffersize: 100 , remaining elements: 73, remaining fill grade: 20
Apr 29, 2021 1:48:01 PM org.gecko.util.pushstreams.policy.FixedGradePushbackPolicy pushback
INFO: [stream] Buffersize: 100 , remaining elements: 46, remaining fill grade: 20
Apr 29, 2021 1:48:03 PM org.gecko.util.pushstreams.policy.FixedGradePushbackPolicy pushback
INFO: [stream] Backpressure: 5 , remaining: 19, remaining fi
...[truncated 2122 chars]...
3 PM org.gecko.util.pushstreams.policy.FixedGradePushbackPolicy pushback
INFO: [stream] Buffersize: 100 , remaining elements: 0, remaining fill grade: 0
Apr 29, 2021 1:48:53 PM org.gecko.util.pushstreams.policy.GradualBreakingQueuePolicy doOffer
INFO: [source] Buffersize: 100 , remaining elements: 21, remaining fill grade: 20
Apr 29, 2021 1:48:57 PM org.gecko.util.pushstreams.policy.FixedGradePushbackPolicy pushback
INFO: [stream] Buffersize: 100 , remaining elements: 0, remaining fill grade: 0