Passed

org.gecko.core.pushstream.PushstreamPerformanceTest.testOptimized02

Standard Output

1594324165941 pub message-100[49]
1594324167818 sub message-102[28][249] took 1798ms
1594324169002 pub message-200[15]
1594324171954 pub message-300[10]
1594324172264 sub message-198[17][443] took 3299ms
1594324174917 pub message-400[42]
1594324176759 sub message-298[30][349] took 4828ms
1594324179100 pub message-500[24]
1594324181203 sub message-401[16][321] took 6270ms
1594324185705 sub message-498[10][439] took 6709ms
MultiThreaded 8x buffer 100 fixed 10 test took 22586ms request time is: 146
...[truncated 1784 chars]...
-100[30]
1594324263674 sub message-102[97][207] took -1ms
1594324269453 pub message-200[89]
1594324269720 sub message-201[28][239] took -1ms
1594324274751 pub message-300[68]
1594324275098 sub message-300[68][347] took -1ms
1594324280483 pub message-400[10]
1594324280777 sub message-402[36][247] took -1ms
1594324286080 pub message-500[15]
MultiThreaded 8x buffer 100 fixed on full 10 test took 28497ms request time is: 27988, worker time is: 176148
1594324286523 sub message-499[52][458] took -1ms

Standard Error

Jul 09, 2020 7:49:25 PM org.gecko.core.pushstream.policy.FixedGradePushbackPolicy pushback
INFO: [stream] Buffersize: 100 , remaining elements: 63, remaining fill grade: 20
Jul 09, 2020 7:49:29 PM org.gecko.core.pushstream.policy.FixedGradePushbackPolicy pushback
INFO: [stream] Buffersize: 100 , remaining elements: 34, remaining fill grade: 20
Jul 09, 2020 7:49:30 PM org.gecko.core.pushstream.policy.FixedGradePushbackPolicy pushback
INFO: [stream] Backpressure: 30 , remaining: 14, remaining fill
...[truncated 5729 chars]...
gecko.core.pushstream.policy.GradualBreakingQueuePolicy doOffer
INFO: [source] Buffersize: 100 , remaining elements: 15, remaining fill grade: 20
Jul 09, 2020 7:50:21 PM org.gecko.core.pushstream.policy.GradualBreakingQueuePolicy doOffer
INFO: [source] Breaking offer for: 10 ms, remaining elements: 15, remaining fill grade: 20
Jul 09, 2020 7:50:25 PM org.gecko.core.pushstream.policy.FixedGradePushbackPolicy pushback
INFO: [stream] Buffersize: 100 , remaining elements: 0, remaining fill grade: 0