6 #include <aggregator/StreamAlignerStatus.hpp> 13 status.samples_dropped_late_arriving = 57;
14 status.name =
"TestTask";
16 aggregator::StreamStatus sstatus;
17 sstatus.active =
true;
18 sstatus.name =
"Test";
19 sstatus.buffer_size = 200;
20 sstatus.buffer_fill = 87;
21 sstatus.samples_dropped_buffer_full = 587;
22 sstatus.samples_dropped_late_arriving = 317;
24 status.streams.push_back(sstatus);
25 sstatus.active =
false;
26 status.streams.push_back(sstatus);
27 sstatus.active =
true;
28 status.streams.push_back(sstatus);
34 status.time = status.time + base::Time::fromSeconds( 0.1 );
35 status.streams[2].buffer_fill++;
36 status.streams[2].samples_received++;
37 if(status.streams[2].buffer_fill > status.streams[2].buffer_size)
38 status.streams[2].buffer_fill = 0;
44 aggregator::StreamAlignerStatus status;