Passed

org.gecko.core.pushstream.PushstreamPerformanceTest.testOptimized

Standard Output

1603823590083 pub message-100[46]
1603823591576 sub message-96[14][461] took 1619ms
1603823592997 pub message-200[33]
1603823595838 sub message-199[12][347] took 2874ms
1603823595852 pub message-300[41]
1603823598851 pub message-400[29]
1603823600267 sub message-305[11][207] took 4248ms
1603823602634 pub message-500[48]
1603823604582 sub message-398[11][348] took 5783ms
1603823608883 sub message-500[48][363] took 6249ms
MultiThreaded 8x buffer 100 fixed 10 test took 21907ms request time is: 1470
...[truncated 1784 chars]...
-100[12]
1603823686338 sub message-101[58][310] took -1ms
1603823691541 pub message-200[61]
1603823691974 sub message-203[21][241] took -1ms
1603823696686 pub message-300[56]
1603823697051 sub message-301[61][304] took -1ms
1603823702456 pub message-400[25]
1603823702865 sub message-400[25][409] took -1ms
1603823707736 pub message-500[89]
MultiThreaded 8x buffer 100 fixed on full 10 test took 28114ms request time is: 27691, worker time is: 176090
1603823708092 sub message-499[79][445] took -1ms

Standard Error

Oct 27, 2020 6:33:10 PM org.gecko.core.pushstream.policy.FixedGradePushbackPolicy pushback
INFO: [stream] Buffersize: 100 , remaining elements: 74, remaining fill grade: 20
Oct 27, 2020 6:33:12 PM org.gecko.core.pushstream.policy.FixedGradePushbackPolicy pushback
INFO: [stream] Buffersize: 100 , remaining elements: 40, remaining fill grade: 20
Oct 27, 2020 6:33:15 PM org.gecko.core.pushstream.policy.FixedGradePushbackPolicy pushback
INFO: [stream] Buffersize: 100 , remaining elements: 12, remain
...[truncated 1941 chars]...
4:03 PM org.gecko.core.pushstream.policy.FixedGradePushbackPolicy pushback
INFO: [stream] Buffersize: 100 , remaining elements: 0, remaining fill grade: 0
Oct 27, 2020 6:34:04 PM org.gecko.core.pushstream.policy.GradualBreakingQueuePolicy doOffer
INFO: [source] Buffersize: 100 , remaining elements: 28, remaining fill grade: 20
Oct 27, 2020 6:34:08 PM org.gecko.core.pushstream.policy.FixedGradePushbackPolicy pushback
INFO: [stream] Buffersize: 100 , remaining elements: 0, remaining fill grade: 0