Refactor BlimpConnection to TCPConnection

blimp/net/stream_packet_reader.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 "blimp/net/stream_packet_reader.h"
 
 #include <iostream>
 
 #include "base/callback_helpers.h"
 #include "base/location.h"
@@ skipping 20 matching lines @@
       out << "PAYLOAD";
       break;
     case StreamPacketReader::ReadState::IDLE:
       out << "IDLE";
       break;
   }
   return out;
 }
 
 StreamPacketReader::StreamPacketReader(net::StreamSocket* socket)
-    : read_state_(ReadState::IDLE), socket_(socket), weak_factory_(this) {
+    : read_state_(ReadState::IDLE),
+      socket_(socket),
+      payload_size_(0),
+      weak_factory_(this) {
   DCHECK(socket_);
   header_buffer_ = new net::GrowableIOBuffer;
   header_buffer_->SetCapacity(kPacketHeaderSizeBytes);
 }
 
 StreamPacketReader::~StreamPacketReader() {}
 
 void StreamPacketReader::ReadPacket(
     const scoped_refptr<net::GrowableIOBuffer>& buf,
     const net::CompletionCallback& callback) {
@@ skipping 94 matching lines @@
 
 void StreamPacketReader::OnReadComplete(int result) {
   DCHECK_NE(net::ERR_IO_PENDING, result);
 
   if (result == 0 /* EOF */) {
     payload_buffer_ = nullptr;
     base::ResetAndReturn(&callback_).Run(net::ERR_CONNECTION_CLOSED);
     return;
   }
 
-  // If the read was succesful, then process the result.
+  // If the read was successful, then process the result.
   if (result > 0) {
     result = DoReadLoop(result);
   }
 
   // If all reading completed, either successfully or by error, inform the
   // caller.
   if (result != net::ERR_IO_PENDING) {
     payload_buffer_ = nullptr;
     base::ResetAndReturn(&callback_).Run(result);
   }
 }
 
 int StreamPacketReader::DoRead(net::IOBuffer* buf, int buf_len) {
   int result = socket_->Read(buf, buf_len,
                              base::Bind(&StreamPacketReader::OnReadComplete,
                                         weak_factory_.GetWeakPtr()));
   return (result != 0 ? result : net::ERR_CONNECTION_CLOSED);
 }
 
 }  // namespace blimp