commit 136e785d9de5500a821b034cbdffe209e73d4b8a
author QUICHE team <quiche-dev@google.com> Mon May 13 14:10:34 2019 -0700
committer Copybara-Service <copybara-worker@google.com> Tue May 14 06:33:29 2019 -0700
tree 676696b2ee0082a37a6a1b7ee466a5a6aa6f8400
parent d5c4a93c45184e0d4758b42029bf16811d7a618a

QRTP: Implement Datagram Transport

1. Add datagram transport interface (for now experimental in media_transport/api, but later will be moved to WebRTC)

2. Implement QuartcDatagramTransport and QuartcDatagramTrasportTest.

3. Add support for datagram fusing

4. Add OnMessageSent notification when datagram was sent (sometimes it is queued if connection is congestion controlled). This notification will be needed to have accurate sent timestamps for WebRTC congestion control.

Full prototype: see cl/241055581

gfe-relnote: n/a (Quartc only)
PiperOrigin-RevId: 248007007
Change-Id: Idfb717b91a251b148b1dc970d0217e28705248ff

quic/quartc/quartc_fakes.h

diff --git a/quic/quartc/quartc_fakes.h b/quic/quartc/quartc_fakes.h
index ddff641..7048a5e 100644
--- a/quic/quartc/quartc_fakes.h
+++ b/quic/quartc/quartc_fakes.h
@@ -79,24 +79,34 @@
     incoming_messages_.emplace_back(message);
   }
 
+  void OnMessageSent(int64_t datagram_id) override {
+    sent_datagram_ids_.push_back(datagram_id);
+  }
+
   void OnCongestionControlChange(QuicBandwidth bandwidth_estimate,
                                  QuicBandwidth pacing_rate,
                                  QuicTime::Delta latest_rtt) override {}
 
-  QuartcStream* last_incoming_stream() { return last_incoming_stream_; }
+  QuartcStream* last_incoming_stream() const { return last_incoming_stream_; }
 
   // Returns all received messages.
-  const std::vector<std::string>& incoming_messages() {
+  const std::vector<std::string>& incoming_messages() const {
     return incoming_messages_;
   }
 
-  bool connected() { return connected_; }
+  // Returns all sent datagram ids in the order sent.
+  const std::vector<int64_t>& sent_datagram_ids() const {
+    return sent_datagram_ids_;
+  }
+
+  bool connected() const { return connected_; }
   QuicTime writable_time() const { return writable_time_; }
   QuicTime crypto_handshake_time() const { return crypto_handshake_time_; }
 
  private:
   QuartcStream* last_incoming_stream_;
   std::vector<std::string> incoming_messages_;
+  std::vector<int64_t> sent_datagram_ids_;
   bool connected_ = true;
   QuartcStream::Delegate* stream_delegate_;
   QuicTime writable_time_ = QuicTime::Zero();