Landing Recent QUIC changes until 8/28/2015 18:03 UTC.

remoting/protocol/quic_channel_factory.cc

 // Copyright 2015 The Chromium Authors. All rights reserved.
 // Use of this source code is governed by a BSD-style license that can be
 // found in the LICENSE file.
 
 #include "remoting/protocol/quic_channel_factory.h"
 
 #include <vector>
 
 #include "base/bind.h"
 #include "base/location.h"
 #include "base/single_thread_task_runner.h"
 #include "base/stl_util.h"
 #include "base/thread_task_runner_handle.h"
 #include "net/base/io_buffer.h"
 #include "net/base/net_errors.h"
 #include "net/quic/crypto/crypto_framer.h"
 #include "net/quic/crypto/crypto_handshake_message.h"
 #include "net/quic/crypto/crypto_protocol.h"
 #include "net/quic/crypto/quic_random.h"
 #include "net/quic/p2p/quic_p2p_crypto_config.h"
 #include "net/quic/p2p/quic_p2p_session.h"
 #include "net/quic/p2p/quic_p2p_stream.h"
 #include "net/quic/quic_clock.h"
 #include "net/quic/quic_connection_helper.h"
 #include "net/quic/quic_default_packet_writer.h"
+#include "net/quic/quic_protocol.h"
 #include "net/socket/stream_socket.h"
 #include "remoting/base/constants.h"
 #include "remoting/protocol/datagram_channel_factory.h"
 #include "remoting/protocol/p2p_datagram_socket.h"
 #include "remoting/protocol/quic_channel.h"
 
 namespace remoting {
 namespace protocol {
 
 namespace {
@@ skipping 34 matching lines @@
 
     return net::WriteResult(status, result);
   }
   bool IsWriteBlockedDataBuffered() const override {
     // P2PDatagramSocket::Send() method buffer the data until the Send is
     // unblocked.
     return true;
   }
   bool IsWriteBlocked() const override { return write_blocked_; }
   void SetWritable() override { write_blocked_ = false; }
+  net::QuicByteCount GetMaxPacketSize(const net::IPEndPoint& peer_address) const
+      override {
+    return net::kMaxPacketSize;
+  }
 
  private:
   void OnSendComplete(int result){
     DCHECK_NE(result, net::ERR_IO_PENDING);
     write_blocked_ = false;
     if (result < 0) {
       connection_->OnWriteError(result);
     }
     connection_->OnCanWrite();
   }
@@ skipping 437 matching lines @@
 void QuicChannelFactory::CancelChannelCreation(const std::string& name) {
   core_->CancelChannelCreation(name);
 }
 
 net::QuicP2PSession* QuicChannelFactory::GetP2PSessionForTests() {
   return core_->quic_session_.get();
 }
 
 }  // namespace protocol
 }  // namespace remoting