Wire up transport sequence number / send time callbacks to webrtc via libjingle.

webrtc/p2p/base/port.cc

 /*
  *  Copyright 2004 The WebRTC Project Authors. All rights reserved.
  *
  *  Use of this source code is governed by a BSD-style license
  *  that can be found in the LICENSE file in the root of the source
  *  tree. An additional intellectual property rights grant can be found
  *  in the file PATENTS.  All contributing project authors may
  *  be found in the AUTHORS file in the root of the source tree.
  */
 
@@ skipping 294 matching lines @@
     // because we then get back responses for them, which this code correctly
     // does not handle.
     if (msg->type() != STUN_BINDING_RESPONSE) {
       LOG_J(LS_ERROR, this) << "Received unexpected STUN message type ("
                             << msg->type() << ") from unknown address ("
                             << addr.ToSensitiveString() << ")";
     }
   }
 }
 
+void Port::OnPacketSent(const rtc::SocketAddress& addr,
+                        const rtc::SentPacket& sent_packet) {
+  Connection* connection = GetConnection(addr);
+  if (connection != nullptr)
+    connection->OnPacketSent(sent_packet);

[pthatcher1, 2015/10/05 18:30:14]

{}s please

[pthatcher1, 2015/10/05 18:30:14]

Do we really need to know which connection it went out on?  Can we just put
OnPacketSent on the Port and avoid doing a map lookup for every packet?

[stefan-webrtc, 2015/10/06 13:00:19]

I think this is a good idea, now that I begin understand how these things are
connected. :)

Just to be sure, you are saying I should send a signal from Port(Interface) via
P2PTransportChannel and from there up to webrtc?

[pthatcher1, 2015/10/06 20:23:55]

Yes.

[stefan-webrtc, 2015/10/07 16:55:25]

Done.

+}
+
 void Port::OnReadyToSend() {
   AddressMap::iterator iter = connections_.begin();
   for (; iter != connections_.end(); ++iter) {
     iter->second->OnReadyToSend();
   }
 }
 
 size_t Port::AddPrflxCandidate(const Candidate& local) {
   candidates_.push_back(local);
   return (candidates_.size() - 1);
@@ skipping 651 matching lines @@
         ReceivedPing();
         break;
 
       default:
         ASSERT(false);
         break;
     }
   }
 }
 
+void Connection::OnPacketSent(const rtc::SentPacket& sent_packet) {
+  SignalSentPacket(this, sent_packet);
+}
+
 void Connection::OnReadyToSend() {
   if (write_state_ == STATE_WRITABLE) {
     SignalReadyToSend(this);
   }
 }
 
 void Connection::Prune() {
   if (!pruned_ || active()) {
     LOG_J(LS_VERBOSE, this) << "Connection pruned";
     pruned_ = true;
@@ skipping 415 matching lines @@
     ASSERT(sent < 0);
     error_ = port_->GetError();
     sent_packets_discarded_++;
   } else {
     send_rate_tracker_.AddSamples(sent);
   }
   return sent;
 }
 
 }  // namespace cricket