Passed

org.gecko.core.pushstream.PushstreamPerformanceTest.test2StreamsOptimizedMeasure

Standard Output

1594126740523 pub message-100[37]
1594126742161 sub message-99[42][452] took 1675ms
1594126743622 pub message-200[43]
1594126746550 sub message-199[42][414] took 2971ms
1594126746655 pub message-300[22]
1594126749685 pub message-400[22]
1594126750886 sub message-300[22][344] took 4231ms
1594126753039 pub message-500[13]
1594126755254 sub message-399[17][482] took 5591ms
1594126759716 sub message-500[13][351] took 6677ms
MultiThreaded 8x buffer 100 fixed 10 test took 22101ms request time is: 1498
...[truncated 1787 chars]...
-100[90]
1594126837926 sub message-100[90][309] took -1ms
1594126843058 pub message-200[36]
1594126843435 sub message-198[54][426] took -1ms
1594126848917 pub message-300[74]
1594126849272 sub message-299[58][429] took -1ms
1594126854491 pub message-400[36]
1594126854867 sub message-401[36][339] took -1ms
1594126860140 pub message-500[42]
1594126860596 sub message-500[42][456] took -1ms
MultiThreaded 8x buffer 100 fixed on full 10 test took 28538ms request time is: 28017, worker time is: 172890

Standard Error

Jul 07, 2020 12:59:00 PM org.gecko.core.pushstream.policy.FixedGradePushbackPolicy pushback
INFO: [stream] Buffersize: 100 , remaining elements: 70, remaining fill grade: 20
Jul 07, 2020 12:59:03 PM org.gecko.core.pushstream.policy.FixedGradePushbackPolicy pushback
INFO: [stream] Buffersize: 100 , remaining elements: 38, remaining fill grade: 20
Jul 07, 2020 12:59:05 PM org.gecko.core.pushstream.policy.FixedGradePushbackPolicy pushback
INFO: [stream] Backpressure: 10 , remaining: 18, remaining f
...[truncated 5253 chars]...
ecko.core.pushstream.policy.GradualBreakingQueuePolicy doOffer
INFO: [source] Buffersize: 100 , remaining elements: 20, remaining fill grade: 20
Jul 07, 2020 12:59:55 PM org.gecko.core.pushstream.policy.GradualBreakingQueuePolicy doOffer
INFO: [source] Breaking offer for: 0 ms, remaining elements: 20, remaining fill grade: 20
Jul 07, 2020 12:59:59 PM org.gecko.core.pushstream.policy.FixedGradePushbackPolicy pushback
INFO: [stream] Buffersize: 100 , remaining elements: 0, remaining fill grade: 0