Passed

org.gecko.util.PushstreamPerformanceTest.test2StreamsOptimizedMeasure

Standard Output

1653400236977 pub message-100[46]
1653400238594 sub message-101[12][241] took 1601ms
1653400239737 pub message-200[30]
1653400242608 pub message-300[47]
1653400242976 sub message-199[32][411] took 3269ms
1653400245676 pub message-400[18]
1653400247427 sub message-301[15][384] took 4804ms
1653400249667 pub message-500[46]
1653400251736 sub message-397[19][436] took 6124ms
1653400256238 sub message-500[46][480] took 6570ms
MultiThreaded 8x buffer 100 fixed 10 test took 22186ms request time is: 143
...[truncated 1788 chars]...
-100[34]
1653400334176 sub message-100[34][263] took -1ms
1653400339588 pub message-200[61]
1653400340021 sub message-199[90][494] took -1ms
1653400344977 pub message-300[19]
1653400345441 sub message-301[28][435] took -1ms
1653400350515 pub message-400[43]
1653400350799 sub message-402[27][241] took -1ms
1653400356201 pub message-500[98]
MultiThreaded 8x buffer 100 fixed on full 10 test took 28626ms request time is: 28179, worker time is: 173634
1653400356594 sub message-500[98][392] took -1ms

Standard Error

May 24, 2022 1:50:36 PM org.gecko.util.pushstreams.policy.FixedGradePushbackPolicy pushback
INFO: [stream] Buffersize: 100 , remaining elements: 66, remaining fill grade: 20
May 24, 2022 1:50:39 PM org.gecko.util.pushstreams.policy.FixedGradePushbackPolicy pushback
INFO: [stream] Buffersize: 100 , remaining elements: 34, remaining fill grade: 20
May 24, 2022 1:50:41 PM org.gecko.util.pushstreams.policy.FixedGradePushbackPolicy pushback
INFO: [stream] Buffersize: 100 , remaining elements: 11, rem
...[truncated 1958 chars]...
1 PM org.gecko.util.pushstreams.policy.FixedGradePushbackPolicy pushback
INFO: [stream] Buffersize: 100 , remaining elements: 0, remaining fill grade: 0
May 24, 2022 1:51:32 PM org.gecko.util.pushstreams.policy.GradualBreakingQueuePolicy doOffer
INFO: [source] Buffersize: 100 , remaining elements: 24, remaining fill grade: 20
May 24, 2022 1:51:35 PM org.gecko.util.pushstreams.policy.FixedGradePushbackPolicy pushback
INFO: [stream] Buffersize: 100 , remaining elements: 0, remaining fill grade: 0