Add histogram stats for send delay for a sent video stream.

webrtc/modules/rtp_rtcp/source/rtp_sender.cc

Index: webrtc/modules/rtp_rtcp/source/rtp_sender.cc
diff --git a/webrtc/modules/rtp_rtcp/source/rtp_sender.cc b/webrtc/modules/rtp_rtcp/source/rtp_sender.cc
index dc544fbe69fe01534aae27c20e843c65dd3c0802..a5e275d929e01a13d273c6bfe457d5d8178af6c3 100644
--- a/webrtc/modules/rtp_rtcp/source/rtp_sender.cc
+++ b/webrtc/modules/rtp_rtcp/source/rtp_sender.cc
@@ -119,7 +119,8 @@ RTPSender::RTPSender(
     TransportFeedbackObserver* transport_feedback_observer,
     BitrateStatisticsObserver* bitrate_callback,
     FrameCountObserver* frame_count_observer,
-    SendSideDelayObserver* send_side_delay_observer)
+    SendSideDelayObserver* send_side_delay_observer,
+    SendPacketObserver* send_packet_observer)
     : clock_(clock),
       // TODO(holmer): Remove this conversion when we remove the use of
       // TickTime.
@@ -157,6 +158,7 @@ RTPSender::RTPSender(
       rtp_stats_callback_(NULL),
       frame_count_observer_(frame_count_observer),
       send_side_delay_observer_(send_side_delay_observer),
+      send_packet_observer_(send_packet_observer),
       // RTP variables
       start_timestamp_forced_(false),
       start_timestamp_(0),
@@ -883,9 +885,7 @@ bool RTPSender::TimeToSendPacket(uint16_t sequence_number,
     // Packet cannot be found. Allow sending to continue.
     return true;
   }
-  if (!retransmission && capture_time_ms > 0) {
-    UpdateDelayStatistics(capture_time_ms, clock_->TimeInMilliseconds());
-  }
+
   int rtx;
   {
     CriticalSectionScoped lock(send_critsect_.get());
@@ -944,6 +944,11 @@ bool RTPSender::PrepareAndSendPacket(uint8_t* buffer,
     transport_feedback_observer_->AddPacket(options.packet_id, length, true);
   }
 
+  if (!is_retransmit && !send_over_rtx) {
+    UpdateDelayStatistics(capture_time_ms, now_ms);
+    UpdateOnSendPacket(capture_time_ms, &options.packet_id);
+  }
+
   bool ret = SendPacketToNetwork(buffer_to_send_ptr, length, options);
   if (ret) {
     CriticalSectionScoped lock(send_critsect_.get());
@@ -1063,12 +1068,12 @@ int32_t RTPSender::SendToNetwork(uint8_t* buffer,
     }
     return 0;
   }
-  if (capture_time_ms > 0) {
-    UpdateDelayStatistics(capture_time_ms, now_ms);
-  }
+  PacketOptions options;
+  UpdateDelayStatistics(capture_time_ms, now_ms);
+  UpdateOnSendPacket(capture_time_ms, &options.packet_id);
 
   size_t length = payload_length + rtp_header_length;
-  bool sent = SendPacketToNetwork(buffer, length, PacketOptions());
+  bool sent = SendPacketToNetwork(buffer, length, options);
 
   // Mark the packet as sent in the history even if send failed. Dropping a
   // packet here should be treated as any other packet drop so we should be
@@ -1087,7 +1092,7 @@ int32_t RTPSender::SendToNetwork(uint8_t* buffer,
 }
 
 void RTPSender::UpdateDelayStatistics(int64_t capture_time_ms, int64_t now_ms) {
-  if (!send_side_delay_observer_)
+  if (!send_side_delay_observer_ || capture_time_ms <= 0)
     return;
 
   uint32_t ssrc;
@@ -1119,6 +1124,22 @@ void RTPSender::UpdateDelayStatistics(int64_t capture_time_ms, int64_t now_ms) {
                                                   ssrc);
 }
 
+void RTPSender::UpdateOnSendPacket(int64_t capture_time_ms, int* packet_id) {
+  if (!send_packet_observer_ || !transport_sequence_number_allocator_ ||
+      capture_time_ms <= 0)
+    return;
+
+  uint32_t ssrc;
+  {
+    CriticalSectionScoped lock(send_critsect_.get());
+    ssrc = ssrc_;
+  }
+  if (*packet_id == -1)
+    *packet_id = transport_sequence_number_allocator_->AllocateSequenceNumber();
+
+  send_packet_observer_->OnSendPacket(*packet_id, capture_time_ms, ssrc);
+}
+
 void RTPSender::ProcessBitrate() {
   CriticalSectionScoped cs(send_critsect_.get());
   total_bitrate_sent_.Process();