Passed

org.gecko.util.PushstreamPerformanceTest.test2StreamsOptimizedMeasure

Standard Output

1653398470090 pub message-100[35]
1653398471997 sub message-99[37][451] took 1942ms
1653398473079 pub message-200[11]
1653398476156 pub message-300[18]
1653398476431 sub message-204[13][301] took 3270ms
1653398479024 pub message-400[17]
1653398480702 sub message-299[49][318] took 4564ms
1653398483167 pub message-500[40]
1653398485178 sub message-402[35][202] took 6109ms
MultiThreaded 8x buffer 100 fixed 10 test took 22566ms request time is: 14728, worker time is: 177854
1653398489872 sub message
...[truncated 1784 chars]...
-100[26]
1653398567702 sub message-100[26][207] took -1ms
1653398573160 pub message-200[87]
1653398573519 sub message-198[55][505] took -1ms
1653398578780 pub message-300[79]
1653398579158 sub message-300[79][377] took -1ms
1653398584233 pub message-400[88]
1653398584601 sub message-403[54][192] took -1ms
1653398590154 pub message-500[44]
MultiThreaded 8x buffer 100 fixed on full 10 test took 28809ms request time is: 28341, worker time is: 172736
1653398590572 sub message-500[44][417] took -1ms

Standard Error

May 24, 2022 1:21:10 PM org.gecko.util.pushstreams.policy.FixedGradePushbackPolicy pushback
INFO: [stream] Buffersize: 100 , remaining elements: 63, remaining fill grade: 20
May 24, 2022 1:21:13 PM org.gecko.util.pushstreams.policy.FixedGradePushbackPolicy pushback
INFO: [stream] Buffersize: 100 , remaining elements: 35, remaining fill grade: 20
May 24, 2022 1:21:14 PM org.gecko.util.pushstreams.policy.FixedGradePushbackPolicy pushback
INFO: [stream] Backpressure: 15 , remaining: 17, remaining f
...[truncated 5421 chars]...
ko.util.pushstreams.policy.GradualBreakingQueuePolicy doOffer
INFO: [source] Buffersize: 100 , remaining elements: 15, remaining fill grade: 20
May 24, 2022 1:22:06 PM org.gecko.util.pushstreams.policy.GradualBreakingQueuePolicy doOffer
INFO: [source] Breaking offer for: 10 ms, remaining elements: 15, remaining fill grade: 20
May 24, 2022 1:22:09 PM org.gecko.util.pushstreams.policy.FixedGradePushbackPolicy pushback
INFO: [stream] Buffersize: 100 , remaining elements: 0, remaining fill grade: 0