Passed

org.gecko.core.pushstream.PushstreamPerformanceTest.test2StreamsOptimizedMeasure

Standard Output

1601460463214 pub message-100[12]
1601460464967 sub message-100[12][303] took 1749ms
1601460466214 pub message-200[48]
1601460469135 pub message-300[27]
1601460469371 sub message-203[18][265] took 3076ms
1601460472313 pub message-400[20]
1601460473754 sub message-302[42][190] took 4551ms
1601460476005 pub message-500[32]
1601460477865 sub message-399[49][402] took 5572ms
1601460482266 sub message-500[32][414] took 6261ms
MultiThreaded 8x buffer 100 fixed 10 test took 21979ms request time is: 150
...[truncated 1736 chars]...
e-499[54][441] took -1ms
1601460560033 pub message-100[13]
1601460560538 sub message-99[19][457] took -1ms
1601460565378 pub message-200[30]
1601460565815 sub message-201[33][404] took -1ms
1601460570623 pub message-300[12]
1601460571010 sub message-301[87][300] took -1ms
1601460576051 pub message-400[75]
1601460576452 sub message-398[63][503] took -1ms
1601460581361 pub message-500[30]
MultiThreaded 8x buffer 100 fixed on full 10 test took 26849ms request time is: 26379, worker time is: 178025

Standard Error

Sep 30, 2020 10:07:43 AM org.gecko.core.pushstream.policy.FixedGradePushbackPolicy pushback
INFO: [stream] Buffersize: 100 , remaining elements: 67, remaining fill grade: 20
Sep 30, 2020 10:07:46 AM org.gecko.core.pushstream.policy.FixedGradePushbackPolicy pushback
INFO: [stream] Buffersize: 100 , remaining elements: 38, remaining fill grade: 20
Sep 30, 2020 10:07:48 AM org.gecko.core.pushstream.policy.FixedGradePushbackPolicy pushback
INFO: [stream] Buffersize: 100 , remaining elements: 11, rem
...[truncated 2323 chars]...
ecko.core.pushstream.policy.GradualBreakingQueuePolicy doOffer
INFO: [source] Buffersize: 100 , remaining elements: 16, remaining fill grade: 20
Sep 30, 2020 10:08:38 AM org.gecko.core.pushstream.policy.GradualBreakingQueuePolicy doOffer
INFO: [source] Breaking offer for: 8 ms, remaining elements: 16, remaining fill grade: 20
Sep 30, 2020 10:08:42 AM org.gecko.core.pushstream.policy.FixedGradePushbackPolicy pushback
INFO: [stream] Buffersize: 100 , remaining elements: 0, remaining fill grade: 0