Passed

org.gecko.util.PushstreamPerformanceTest.test2StreamsOptimizedMeasure

Standard Output

1680689619063 pub message-100[21]
1680689620887 sub message-98[18][403] took 1894ms
1680689622083 pub message-200[38]
1680689624950 pub message-300[18]
1680689625275 sub message-195[26][499] took 3332ms
1680689627954 pub message-400[20]
1680689629639 sub message-301[11][460] took 4678ms
1680689631840 pub message-500[47]
1680689633999 sub message-399[35][343] took 6065ms
1680689638168 sub message-495[13][467] took 6549ms
MultiThreaded 8x buffer 100 fixed 10 test took 22010ms request time is: 1466
...[truncated 1785 chars]...
-100[94]
1680689717517 sub message-101[66][215] took -1ms
1680689722726 pub message-200[34]
1680689723029 sub message-197[27][499] took -1ms
1680689728462 pub message-300[95]
1680689728763 sub message-298[72][472] took -1ms
1680689733488 pub message-400[20]
1680689733926 sub message-399[28][458] took -1ms
1680689738887 pub message-500[97]
MultiThreaded 8x buffer 100 fixed on full 10 test took 27864ms request time is: 27295, worker time is: 174234
1680689739386 sub message-500[97][498] took -1ms

Standard Error

Apr 05, 2023 10:13:39 AM org.gecko.util.pushstreams.policy.FixedGradePushbackPolicy pushback
INFO: [stream] Buffersize: 100 , remaining elements: 68, remaining fill grade: 20
Apr 05, 2023 10:13:42 AM org.gecko.util.pushstreams.policy.FixedGradePushbackPolicy pushback
INFO: [stream] Buffersize: 100 , remaining elements: 34, remaining fill grade: 20
Apr 05, 2023 10:13:43 AM org.gecko.util.pushstreams.policy.FixedGradePushbackPolicy pushback
INFO: [stream] Backpressure: 15 , remaining: 17, remainin
...[truncated 5642 chars]...
.util.pushstreams.policy.GradualBreakingQueuePolicy doOffer
INFO: [source] Buffersize: 100 , remaining elements: 13, remaining fill grade: 20
Apr 05, 2023 10:14:34 AM org.gecko.util.pushstreams.policy.GradualBreakingQueuePolicy doOffer
INFO: [source] Breaking offer for: 14 ms, remaining elements: 13, remaining fill grade: 20
Apr 05, 2023 10:14:38 AM org.gecko.util.pushstreams.policy.FixedGradePushbackPolicy pushback
INFO: [stream] Buffersize: 100 , remaining elements: 0, remaining fill grade: 0