Passed

org.gecko.util.PushstreamPerformanceTest.test2StreamsOptimized

Standard Output

1619705423041 pub message-100[38]
1619705424435 sub message-101[28][250] took 1362ms
1619705426121 pub message-200[40]
1619705429029 sub message-198[22][505] took 2988ms
1619705429122 pub message-300[25]
1619705431896 pub message-400[11]
1619705433437 sub message-298[42][453] took 4352ms
1619705435916 pub message-500[35]
1619705438011 sub message-401[35][274] took 6079ms
1619705442404 sub message-500[35][335] took 6488ms
MultiThreaded 8x buffer 100 fixed 10 test took 22455ms request time is: 147
...[truncated 1788 chars]...
-100[84]
1619705519069 sub message-104[16][201] took -1ms
1619705523862 pub message-200[93]
1619705524111 sub message-200[93][249] took -1ms
1619705529022 pub message-300[80]
1619705529383 sub message-303[79][216] took -1ms
1619705535009 pub message-400[69]
1619705535312 sub message-399[30][371] took -1ms
1619705540214 pub message-500[10]
MultiThreaded 8x buffer 100 fixed on full 10 test took 27041ms request time is: 26474, worker time is: 171456
1619705540731 sub message-498[19][473] took -1ms

Standard Error

Apr 29, 2021 2:10:23 PM org.gecko.util.pushstreams.policy.FixedGradePushbackPolicy pushback
INFO: [stream] Buffersize: 100 , remaining elements: 72, remaining fill grade: 20
Apr 29, 2021 2:10:26 PM org.gecko.util.pushstreams.policy.FixedGradePushbackPolicy pushback
INFO: [stream] Buffersize: 100 , remaining elements: 44, remaining fill grade: 20
Apr 29, 2021 2:10:28 PM org.gecko.util.pushstreams.policy.FixedGradePushbackPolicy pushback
INFO: [stream] Backpressure: 5 , remaining: 19, remaining fi
...[truncated 4904 chars]...
7 PM org.gecko.util.pushstreams.policy.FixedGradePushbackPolicy pushback
INFO: [stream] Buffersize: 100 , remaining elements: 0, remaining fill grade: 0
Apr 29, 2021 2:11:18 PM org.gecko.util.pushstreams.policy.GradualBreakingQueuePolicy doOffer
INFO: [source] Buffersize: 100 , remaining elements: 23, remaining fill grade: 20
Apr 29, 2021 2:11:21 PM org.gecko.util.pushstreams.policy.FixedGradePushbackPolicy pushback
INFO: [stream] Buffersize: 100 , remaining elements: 0, remaining fill grade: 0