Passed

org.gecko.core.pushstream.PushstreamPerformanceTest.testOptimized02

Standard Output

1603824203751 pub message-100[39]
1603824205216 sub message-104[11][261] took 1365ms
1603824206673 pub message-200[43]
1603824209630 pub message-300[15]
1603824209644 sub message-199[34][404] took 3015ms
1603824212847 pub message-400[46]
1603824214104 sub message-303[38][217] took 4354ms
1603824216387 pub message-500[43]
1603824218632 sub message-398[30][503] took 5862ms
1603824223123 sub message-499[44][475] took 6779ms
MultiThreaded 8x buffer 100 fixed 10 test took 22475ms request time is: 151
...[truncated 1788 chars]...
-100[65]
1603824300054 sub message-101[64][207] took -1ms
1603824304997 pub message-200[17]
1603824305379 sub message-201[37][344] took -1ms
1603824310485 pub message-300[88]
1603824310932 sub message-298[17][509] took -1ms
1603824315670 pub message-400[33]
1603824316122 sub message-403[35][218] took -1ms
1603824321113 pub message-500[40]
MultiThreaded 8x buffer 100 fixed on full 10 test took 27128ms request time is: 26564, worker time is: 173627
1603824321610 sub message-500[40][497] took -1ms

Standard Error

Oct 27, 2020 6:43:23 PM org.gecko.core.pushstream.policy.FixedGradePushbackPolicy pushback
INFO: [stream] Buffersize: 100 , remaining elements: 74, remaining fill grade: 20
Oct 27, 2020 6:43:26 PM org.gecko.core.pushstream.policy.FixedGradePushbackPolicy pushback
INFO: [stream] Buffersize: 100 , remaining elements: 42, remaining fill grade: 20
Oct 27, 2020 6:43:29 PM org.gecko.core.pushstream.policy.FixedGradePushbackPolicy pushback
INFO: [stream] Buffersize: 100 , remaining elements: 13, remain
...[truncated 2122 chars]...
.gecko.core.pushstream.policy.GradualBreakingQueuePolicy doOffer
INFO: [source] Buffersize: 100 , remaining elements: 17, remaining fill grade: 20
Oct 27, 2020 6:44:18 PM org.gecko.core.pushstream.policy.GradualBreakingQueuePolicy doOffer
INFO: [source] Breaking offer for: 6 ms, remaining elements: 17, remaining fill grade: 20
Oct 27, 2020 6:44:22 PM org.gecko.core.pushstream.policy.FixedGradePushbackPolicy pushback
INFO: [stream] Buffersize: 100 , remaining elements: 0, remaining fill grade: 0