Cast: Deduplicate packets in paced sender and always send older packets first

media/cast/transport/rtp_sender/packet_storage/packet_storage.cc

Index: media/cast/transport/rtp_sender/packet_storage/packet_storage.cc
diff --git a/media/cast/transport/rtp_sender/packet_storage/packet_storage.cc b/media/cast/transport/rtp_sender/packet_storage/packet_storage.cc
index ea766d0868c3398c84a4c7867c0ec0697fdf48fc..daab13db349ae8d4a4002ae2971ea884730e8712 100644
--- a/media/cast/transport/rtp_sender/packet_storage/packet_storage.cc
+++ b/media/cast/transport/rtp_sender/packet_storage/packet_storage.cc
@@ -38,8 +38,6 @@ void PacketStorage::CleanupOldPackets(base::TimeTicks now) {
     // We should always find the packet.
     DCHECK(store_it != stored_packets_.end()) << "Invalid state";
     time_to_packet_map_.erase(time_it);
-    // Save the pointer.
-    PacketRef storted_packet = store_it->second;
     stored_packets_.erase(store_it);
     time_it = time_to_packet_map_.begin();
   }
@@ -55,8 +53,6 @@ void PacketStorage::CleanupOldPackets(base::TimeTicks now) {
     // We should always find the packet.
     DCHECK(store_it != stored_packets_.end()) << "Invalid state";
     time_to_packet_map_.erase(time_it);
-    // Save the pointer.
-    PacketRef storted_packet = store_it->second;
     stored_packets_.erase(store_it);
     time_it = time_to_packet_map_.begin();
   }
@@ -64,6 +60,7 @@ void PacketStorage::CleanupOldPackets(base::TimeTicks now) {
 
 void PacketStorage::StorePacket(uint32 frame_id,
                                 uint16 packet_id,
+                                const PacketKey& key,
                                 PacketRef packet) {
   base::TimeTicks now = clock_->NowTicks();
   CleanupOldPackets(now);
@@ -76,13 +73,13 @@ void PacketStorage::StorePacket(uint32 frame_id,
     DCHECK(false) << "Invalid state";
     return;
   }
-  stored_packets_[index] = packet;
+  stored_packets_[index] = std::make_pair(key, packet);
   time_to_packet_map_.insert(std::make_pair(now, index));
 }
 
 void PacketStorage::GetPackets(
     const MissingFramesAndPacketsMap& missing_frames_and_packets,
-    PacketList* packets_to_resend) {
+    SendPacketVector* packets_to_resend) {
 
   // Iterate over all frames in the list.
   for (MissingFramesAndPacketsMap::const_iterator it =
@@ -114,7 +111,7 @@ void PacketStorage::GetPackets(
 
 bool PacketStorage::GetPacket(uint8 frame_id,
                               uint16 packet_id,
-                              PacketList* packets) {
+                              SendPacketVector* packets) {
   // Internally we only use the 8 LSB of the frame id.
   uint32 index = (static_cast<uint32>(frame_id) << 16) + packet_id;
   PacketMapIterator it = stored_packets_.find(index);
@@ -128,11 +125,14 @@ bool PacketStorage::GetPacket(uint8 frame_id,
   // then we must return a copy of it instead. This should really only happen
   // when rtp_sender.cc is trying to re-send a packet that is already in the
   // queue to sent.
-  if (it->second->HasOneRef()) {
+  if (it->second.second->HasOneRef()) {
     packets->push_back(it->second);
   } else {
-    packets->push_back(make_scoped_refptr(
-        new base::RefCountedData<Packet>(it->second->data)));
+    packets->push_back(
+        make_pair(it->second.first,
+                  make_scoped_refptr(
+                      new base::RefCountedData<Packet>(
+                          it->second.second->data))));
   }
   return true;
 }