Lines Matching refs:Packets
163 void RunFor(int64_t time_ms, int64_t time_now_ms, Packets* in_out) {
164 Packets to_process;
175 void FindPacketsToProcess(const FlowIds& flow_ids, Packets* in,
176 Packets* out) {
178 for (Packets::iterator it = in->begin(); it != in->end();) {
183 Packets::iterator next = it;
193 void QueuePackets(Packets* batch, int64_t end_of_batch_time_us) {
198 Packets::iterator it = queue_.begin();
204 Packets to_transfer;
210 Packets queue_;
313 Packets packets;
316 it->RunFor(simulation_interval_ms_, time_now_ms_, &packets);
319 // Verify packets are in order between batches.
320 if (!packets.empty()) {
322 packets.splice(packets.begin(), previous_packets_,
324 ASSERT_TRUE(IsTimeSorted(packets));
325 packets.erase(packets.begin());
327 ASSERT_LE(packets.front().send_time_us(), time_now_ms_ * 1000);
328 ASSERT_LE(packets.back().send_time_us(), time_now_ms_ * 1000);
330 ASSERT_TRUE(IsTimeSorted(packets));
333 for (PacketsConstIt it = packets.begin(); it != packets.end(); ++it) {
