Passed

org.gecko.core.pushstream.PushstreamPerformanceTest.testOptimized02

Standard Output

1602072700349 pub message-100[39]
1602072702295 sub message-104[19][208] took 1847ms
1602072703296 pub message-200[20]
1602072706116 pub message-300[32]
1602072706713 sub message-202[23][271] took 3370ms
1602072709097 pub message-400[38]
1602072711065 sub message-300[32][236] took 4948ms
1602072713368 pub message-500[43]
1602072715471 sub message-404[33][266] took 6214ms
1602072719888 sub message-500[43][434] took 6520ms
MultiThreaded 8x buffer 100 fixed 10 test took 22257ms request time is: 143
...[truncated 1783 chars]...
e-100[59]
1602072798941 sub message-99[29][385] took -1ms
1602072803621 pub message-200[42]
1602072803979 sub message-202[67][269] took -1ms
1602072809239 pub message-300[64]
1602072809605 sub message-298[54][505] took -1ms
1602072814295 pub message-400[10]
1602072814656 sub message-400[10][309] took -1ms
1602072819921 pub message-500[82]
MultiThreaded 8x buffer 100 fixed on full 10 test took 27269ms request time is: 26845, worker time is: 173977
1602072820278 sub message-500[82][357] took -1ms

Standard Error

Oct 07, 2020 12:11:40 PM org.gecko.core.pushstream.policy.FixedGradePushbackPolicy pushback
INFO: [stream] Buffersize: 100 , remaining elements: 64, remaining fill grade: 20
Oct 07, 2020 12:11:43 PM org.gecko.core.pushstream.policy.FixedGradePushbackPolicy pushback
INFO: [stream] Buffersize: 100 , remaining elements: 30, remaining fill grade: 20
Oct 07, 2020 12:11:45 PM org.gecko.core.pushstream.policy.FixedGradePushbackPolicy pushback
INFO: [stream] Buffersize: 100 , remaining elements: 12, rem
...[truncated 2324 chars]...
cko.core.pushstream.policy.GradualBreakingQueuePolicy doOffer
INFO: [source] Buffersize: 100 , remaining elements: 12, remaining fill grade: 20
Oct 07, 2020 12:12:35 PM org.gecko.core.pushstream.policy.GradualBreakingQueuePolicy doOffer
INFO: [source] Breaking offer for: 16 ms, remaining elements: 12, remaining fill grade: 20
Oct 07, 2020 12:12:39 PM org.gecko.core.pushstream.policy.FixedGradePushbackPolicy pushback
INFO: [stream] Buffersize: 100 , remaining elements: 0, remaining fill grade: 0