Passed

org.gecko.core.pushstream.PushstreamPerformanceTest.test2StreamsOptimizedMeasure

Standard Output

1588087758466 pub message-100[22]
1588087760222 sub message-98[36][445] took 1805ms
1588087761364 pub message-200[15]
1588087764437 sub message-199[23][469] took 3088ms
1588087764508 pub message-300[36]
1588087767426 pub message-400[17]
1588087768886 sub message-299[19][413] took 4414ms
1588087771239 pub message-500[25]
1588087773227 sub message-398[20][472] took 5832ms
1588087777742 sub message-500[25][472] took 6503ms
MultiThreaded 8x buffer 100 fixed 10 test took 22247ms request time is: 1482
...[truncated 1784 chars]...
-100[22]
1588087855456 sub message-103[39][311] took -1ms
1588087860460 pub message-200[35]
1588087860871 sub message-197[64][496] took -1ms
1588087866230 pub message-300[97]
1588087866550 sub message-303[33][213] took -1ms
1588087871573 pub message-400[73]
1588087871982 sub message-401[76][333] took -1ms
1588087876609 pub message-500[24]
MultiThreaded 8x buffer 100 fixed on full 10 test took 27681ms request time is: 27178, worker time is: 176184
1588087877046 sub message-500[24][437] took -1ms

Standard Error

Apr 28, 2020 3:29:18 PM org.gecko.core.pushstream.policy.FixedGradePushbackPolicy pushback
INFO: [stream] Buffersize: 100 , remaining elements: 66, remaining fill grade: 20
Apr 28, 2020 3:29:21 PM org.gecko.core.pushstream.policy.FixedGradePushbackPolicy pushback
INFO: [stream] Buffersize: 100 , remaining elements: 34, remaining fill grade: 20
Apr 28, 2020 3:29:23 PM org.gecko.core.pushstream.policy.FixedGradePushbackPolicy pushback
INFO: [stream] Backpressure: 5 , remaining: 19, remaining fill 
...[truncated 4869 chars]...
0:12 PM org.gecko.core.pushstream.policy.FixedGradePushbackPolicy pushback
INFO: [stream] Buffersize: 100 , remaining elements: 0, remaining fill grade: 0
Apr 28, 2020 3:30:13 PM org.gecko.core.pushstream.policy.GradualBreakingQueuePolicy doOffer
INFO: [source] Buffersize: 100 , remaining elements: 29, remaining fill grade: 20
Apr 28, 2020 3:30:17 PM org.gecko.core.pushstream.policy.FixedGradePushbackPolicy pushback
INFO: [stream] Buffersize: 100 , remaining elements: 0, remaining fill grade: 0