Passed

org.gecko.util.PushstreamPerformanceTest.test2StreamsOptimized

Standard Output

1633342421488 pub message-100[10]
1633342423080 sub message-102[31][267] took 1518ms
1633342424472 pub message-200[42]
1633342427473 pub message-300[38]
1633342427535 sub message-197[40][475] took 3186ms
1633342430396 pub message-400[25]
1633342431860 sub message-297[15][426] took 4478ms
1633342434270 pub message-500[36]
1633342436187 sub message-394[39][509] took 5984ms
1633342440682 sub message-500[36][396] took 6411ms
MultiThreaded 8x buffer 100 fixed 10 test took 22173ms request time is: 144
...[truncated 1786 chars]...
e-100[85]
1633342518831 sub message-98[29][410] took -1ms
1633342524258 pub message-200[67]
1633342524492 sub message-199[61][301] took -1ms
1633342530004 pub message-300[99]
1633342530243 sub message-299[92][338] took -1ms
1633342535776 pub message-400[46]
1633342536214 sub message-400[46][438] took -1ms
1633342541361 pub message-500[58]
MultiThreaded 8x buffer 100 fixed on full 10 test took 28864ms request time is: 28356, worker time is: 172446
1633342541811 sub message-500[58][449] took -1ms

Standard Error

Oct 04, 2021 10:13:41 AM org.gecko.util.pushstreams.policy.FixedGradePushbackPolicy pushback
INFO: [stream] Buffersize: 100 , remaining elements: 71, remaining fill grade: 20
Oct 04, 2021 10:13:44 AM org.gecko.util.pushstreams.policy.FixedGradePushbackPolicy pushback
INFO: [stream] Buffersize: 100 , remaining elements: 40, remaining fill grade: 20
Oct 04, 2021 10:13:46 AM org.gecko.util.pushstreams.policy.FixedGradePushbackPolicy pushback
INFO: [stream] Backpressure: 5 , remaining: 19, remaining
...[truncated 5642 chars]...
.util.pushstreams.policy.GradualBreakingQueuePolicy doOffer
INFO: [source] Buffersize: 100 , remaining elements: 14, remaining fill grade: 20
Oct 04, 2021 10:14:36 AM org.gecko.util.pushstreams.policy.GradualBreakingQueuePolicy doOffer
INFO: [source] Breaking offer for: 12 ms, remaining elements: 14, remaining fill grade: 20
Oct 04, 2021 10:14:40 AM org.gecko.util.pushstreams.policy.FixedGradePushbackPolicy pushback
INFO: [stream] Buffersize: 100 , remaining elements: 0, remaining fill grade: 0