Makes QuicChromiumPacketWriter use the delegate for interacting with the connection.

net/quic/chromium/quic_chromium_client_session.h

 // Copyright (c) 2012 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.
 //
 // A client specific QuicSession subclass.  This class owns the underlying
 // QuicConnection and QuicConnectionHelper objects.  The connection stores
 // a non-owning pointer to the helper so this session needs to ensure that
 // the helper outlives the connection.
 
 #ifndef NET_QUIC_QUIC_CHROMIUM_CLIENT_SESSION_H_
@@ skipping 38 matching lines @@
 using TokenBindingSignatureMap =
     base::MRUCache<std::string, std::vector<uint8_t>>;
 
 namespace test {
 class QuicChromiumClientSessionPeer;
 }  // namespace test
 
 class NET_EXPORT_PRIVATE QuicChromiumClientSession
     : public QuicClientSessionBase,
       public QuicChromiumPacketReader::Visitor,
-      public QuicChromiumPacketWriter::WriteErrorObserver {
+      public QuicChromiumPacketWriter::Delegate {
  public:
   // Reasons to disable QUIC, that is under certain pathological
   // connection errors.  Note: these values must be kept in sync with
   // the corresponding values of QuicDisabledReason in:
   // tools/metrics/histograms/histograms.xml
   enum QuicDisabledReason {
     QUIC_DISABLED_NOT = 0,  // default, not disabled
     QUIC_DISABLED_PUBLIC_RESET_POST_HANDSHAKE = 1,
     QUIC_DISABLED_TIMEOUT_WITH_OPEN_STREAMS = 2,
     QUIC_DISABLED_BAD_PACKET_LOSS_RATE = 3,
@@ skipping 81 matching lines @@
   // will be added to the stream requets queue and will
   // be completed asynchronously.
   // TODO(rch): remove |stream| from this and use setter on |request|
   // and fix in spdy too.
   int TryCreateStream(StreamRequest* request,
                       QuicChromiumClientStream** stream);
 
   // Cancels the pending stream creation request.
   void CancelRequest(StreamRequest* request);
 
-  // QuicChromiumPacketWriter::WriteErrorObserver override.
-  int OnWriteError(int error_code,
-                   scoped_refptr<StringIOBuffer> last_packet) override;
+  // QuicChromiumPacketWriter::Delegate override.
+  int HandleWriteError(int error_code,
+                       scoped_refptr<StringIOBuffer> last_packet) override;
+  void OnWriteError(int error_code) override;
+  void OnWriteUnblocked() override;
 
   // QuicSpdySession methods:
   void OnHeadersHeadOfLineBlocking(QuicTime::Delta delta) override;
 
   // QuicSession methods:
   void OnStreamFrame(const QuicStreamFrame& frame) override;
   QuicChromiumClientStream* CreateOutgoingDynamicStream(
       SpdyPriority priority) override;
   QuicCryptoClientStream* GetCryptoStream() override;
   void CloseStream(QuicStreamId stream_id) override;
@@ skipping 194 matching lines @@
   int error_code_from_rewrite_;
   bool use_error_code_from_rewrite_;
   base::WeakPtrFactory<QuicChromiumClientSession> weak_factory_;
 
   DISALLOW_COPY_AND_ASSIGN(QuicChromiumClientSession);
 };
 
 }  // namespace net
 
 #endif  // NET_QUIC_QUIC_CHROMIUM_CLIENT_SESSION_H_