summaryrefslogtreecommitdiffstats
path: root/media/cast/test/end2end_unittest.cc
diff options
context:
space:
mode:
Diffstat (limited to 'media/cast/test/end2end_unittest.cc')
-rw-r--r--media/cast/test/end2end_unittest.cc33
1 files changed, 10 insertions, 23 deletions
diff --git a/media/cast/test/end2end_unittest.cc b/media/cast/test/end2end_unittest.cc
index 88b6e34..4271a7e 100644
--- a/media/cast/test/end2end_unittest.cc
+++ b/media/cast/test/end2end_unittest.cc
@@ -90,33 +90,20 @@ class LoopBackTransport : public transport::PacketSender {
DCHECK(cast_environment_->CurrentlyOn(CastEnvironment::MAIN));
if (!send_packets_) return false;
+ if (drop_packets_belonging_to_odd_frames_) {
+ uint32 frame_id = packet[13];
+ if (frame_id % 2 == 1) return true;
+ }
+
uint8* packet_copy = new uint8[packet.size()];
memcpy(packet_copy, packet.data(), packet.size());
- packet_receiver_->ReceivedPacket(packet_copy, packet.size(),
- base::Bind(transport::PacketReceiver::DeletePacket, packet_copy));
- return true;
- }
- virtual bool SendPackets(const PacketList& packets) OVERRIDE {
- DCHECK(packet_receiver_);
- DCHECK(cast_environment_->CurrentlyOn(CastEnvironment::MAIN));
- if (!send_packets_) return false;
-
- for (size_t i = 0; i < packets.size(); ++i) {
- const Packet& packet = packets[i];
- if (drop_packets_belonging_to_odd_frames_) {
- uint32 frame_id = packet[13];
- if (frame_id % 2 == 1) continue;
- }
- uint8* packet_copy = new uint8[packet.size()];
- memcpy(packet_copy, packet.data(), packet.size());
- if (reset_reference_frame_id_) {
- // Reset the is_reference bit in the cast header.
- packet_copy[kCommonRtpHeaderLength] &= kCastReferenceFrameIdBitReset;
- }
- packet_receiver_->ReceivedPacket(packet_copy, packet.size(),
- base::Bind(transport::PacketReceiver::DeletePacket, packet_copy));
+ if (reset_reference_frame_id_) {
+ // Reset the is_reference bit in the cast header.
+ packet_copy[kCommonRtpHeaderLength] &= kCastReferenceFrameIdBitReset;
}
+ packet_receiver_->ReceivedPacket(packet_copy, packet.size(),
+ base::Bind(transport::PacketReceiver::DeletePacket, packet_copy));
return true;
}