Passed

org.gecko.core.pushstream.PushstreamPerformanceTest.testOptimized02

Standard Output

1603824452146 pub message-100[31]
1603824453643 sub message-100[31][316] took 1493ms
1603824455127 pub message-200[46]
1603824457883 sub message-201[11][364] took 2744ms
1603824457932 pub message-300[13]
1603824460837 pub message-400[12]
1603824462142 sub message-299[34][370] took 4223ms
1603824464402 pub message-500[18]
1603824466434 sub message-402[32][263] took 5550ms
1603824470893 sub message-500[18][282] took 6491ms
MultiThreaded 8x buffer 100 fixed 10 test took 21751ms request time is: 144
...[truncated 1787 chars]...
-100[16]
1603824548249 sub message-100[16][417] took -1ms
1603824553643 pub message-200[21]
1603824554028 sub message-203[44][223] took -1ms
1603824559256 pub message-300[91]
1603824559717 sub message-303[52][298] took -1ms
1603824564881 pub message-400[10]
1603824565219 sub message-400[10][338] took -1ms
1603824570137 pub message-500[86]
1603824570416 sub message-500[86][279] took -1ms
MultiThreaded 8x buffer 100 fixed on full 10 test took 27652ms request time is: 27309, worker time is: 172327

Standard Error

Oct 27, 2020 6:47:32 PM org.gecko.core.pushstream.policy.FixedGradePushbackPolicy pushback
INFO: [stream] Buffersize: 100 , remaining elements: 74, remaining fill grade: 20
Oct 27, 2020 6:47:35 PM org.gecko.core.pushstream.policy.FixedGradePushbackPolicy pushback
INFO: [stream] Buffersize: 100 , remaining elements: 45, remaining fill grade: 20
Oct 27, 2020 6:47:37 PM org.gecko.core.pushstream.policy.FixedGradePushbackPolicy pushback
INFO: [stream] Buffersize: 100 , remaining elements: 14, remain
...[truncated 2305 chars]...
gecko.core.pushstream.policy.GradualBreakingQueuePolicy doOffer
INFO: [source] Buffersize: 100 , remaining elements: 14, remaining fill grade: 20
Oct 27, 2020 6:48:26 PM org.gecko.core.pushstream.policy.GradualBreakingQueuePolicy doOffer
INFO: [source] Breaking offer for: 12 ms, remaining elements: 14, remaining fill grade: 20
Oct 27, 2020 6:48:30 PM org.gecko.core.pushstream.policy.FixedGradePushbackPolicy pushback
INFO: [stream] Buffersize: 100 , remaining elements: 0, remaining fill grade: 0