Port QuicServer to Chrome network stack

net/quic/quic_default_packet_writer.h

 // Copyright 2013 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.
 
 #ifndef NET_QUIC_QUIC_DEFAULT_PACKET_WRITER_H_
 #define NET_QUIC_QUIC_DEFAULT_PACKET_WRITER_H_
 
 #include "base/basictypes.h"
 #include "base/memory/weak_ptr.h"
 #include "net/base/ip_endpoint.h"
 #include "net/quic/quic_connection.h"
 #include "net/quic/quic_packet_writer.h"
 #include "net/quic/quic_protocol.h"
 #include "net/udp/datagram_client_socket.h"
 
 namespace net {
 
 struct WriteResult;
 
 // Chrome specific packet writer which uses a DatagramClientSocket for writing
 // data.
 class NET_EXPORT_PRIVATE QuicDefaultPacketWriter : public QuicPacketWriter {
  public:
   QuicDefaultPacketWriter();
   explicit QuicDefaultPacketWriter(DatagramClientSocket* socket);
   virtual ~QuicDefaultPacketWriter();
 
   // QuicPacketWriter
   virtual WriteResult WritePacket(
-      const char* buffer, size_t buf_len,
-      const net::IPAddressNumber& self_address,
-      const net::IPEndPoint& peer_address) OVERRIDE;
+      const char* buffer,
+      size_t buf_len,
+      const IPAddressNumber& self_address,
+      const IPEndPoint& peer_address,
+      base::Callback<void(WriteResult wr)> callback) OVERRIDE;
   virtual bool IsWriteBlockedDataBuffered() const OVERRIDE;
   virtual bool IsWriteBlocked() const OVERRIDE;
   virtual void SetWritable() OVERRIDE;
 
   void OnWriteComplete(int rv);
-  void SetConnection(QuicConnection* connection) {
-    connection_ = connection;
+
+  // Set the writer to notify when writes complete.
+  void SetWriterToUnblock(QuicBlockedWriterInterface* blocked_writer) {
+    blocked_writer_ = blocked_writer;
   }
 
  protected:
   void set_write_blocked(bool is_blocked) {
     write_blocked_ = is_blocked;
   }
 
  private:
   base::WeakPtrFactory<QuicDefaultPacketWriter> weak_factory_;
   DatagramClientSocket* socket_;
-  QuicConnection* connection_;
+
+  // To be notified after every successful write.
+  QuicBlockedWriterInterface* blocked_writer_;
+
+  // To be called after every successful write. May be null.
+  base::Callback<void(WriteResult wr)> callback_;
+
+  // Whether a write is currently in flight.
   bool write_blocked_;
 
   DISALLOW_COPY_AND_ASSIGN(QuicDefaultPacketWriter);
 };
 
 }  // namespace net
 
 #endif  // NET_QUIC_QUIC_DEFAULT_PACKET_WRITER_H_