Port QuicServer to Chrome network stack

net/quic/quic_per_connection_packet_writer.cc

 // Copyright 2014 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 "net/tools/quic/quic_packet_writer_wrapper.h"
+#include "net/quic/quic_per_connection_packet_writer.h"
 
+#include "net/quic/quic_server_packet_writer.h"
 #include "net/quic/quic_types.h"
 
 namespace net {
-namespace tools {
 
-QuicPacketWriterWrapper::QuicPacketWriterWrapper() {}
+QuicPerConnectionPacketWriter::QuicPerConnectionPacketWriter(
+    QuicServerPacketWriter* writer)
+    : weak_factory_(this), writer_(writer) {
+}
 
-QuicPacketWriterWrapper::QuicPacketWriterWrapper(QuicPacketWriter* writer)
-    : writer_(writer) {}
+QuicPerConnectionPacketWriter::~QuicPerConnectionPacketWriter() {
+}
 
-QuicPacketWriterWrapper::~QuicPacketWriterWrapper() {}
-
-WriteResult QuicPacketWriterWrapper::WritePacket(
+WriteResult QuicPerConnectionPacketWriter::WritePacket(
     const char* buffer,
     size_t buf_len,
-    const net::IPAddressNumber& self_address,
-    const net::IPEndPoint& peer_address) {
-  return writer_->WritePacket(buffer, buf_len, self_address, peer_address);
+    const IPAddressNumber& self_address,
+    const IPEndPoint& peer_address) {
+  return writer_->WritePacketWithCallback(
+      buffer,
+      buf_len,
+      self_address,
+      peer_address,
+      base::Bind(&QuicPerConnectionPacketWriter::OnWriteComplete,
+                 weak_factory_.GetWeakPtr()));
 }
 
-bool QuicPacketWriterWrapper::IsWriteBlockedDataBuffered() const {
+bool QuicPerConnectionPacketWriter::IsWriteBlockedDataBuffered() const {
   return writer_->IsWriteBlockedDataBuffered();
 }
 
-bool QuicPacketWriterWrapper::IsWriteBlocked() const {
+bool QuicPerConnectionPacketWriter::IsWriteBlocked() const {
   return writer_->IsWriteBlocked();
 }
 
-void QuicPacketWriterWrapper::SetWritable() {
+void QuicPerConnectionPacketWriter::SetWritable() {
   writer_->SetWritable();
 }
 
-void QuicPacketWriterWrapper::set_writer(QuicPacketWriter* writer) {
-  writer_.reset(writer);
+void QuicPerConnectionPacketWriter::OnWriteComplete(WriteResult result) {
+  connection_->OnPacketSent(result);
 }
 
-QuicPacketWriter* QuicPacketWriterWrapper::release_writer() {
-  return writer_.release();
-}
-
-}  // namespace tools
 }  // namespace net