| Index: blimp/net/blimp_message_pump.cc | 
| diff --git a/blimp/net/blimp_message_pump.cc b/blimp/net/blimp_message_pump.cc | 
| deleted file mode 100644 | 
| index cc53d1f0b0ed2f0f54f3882ac0983191c629125a..0000000000000000000000000000000000000000 | 
| --- a/blimp/net/blimp_message_pump.cc | 
| +++ /dev/null | 
| @@ -1,86 +0,0 @@ | 
| -// 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/blimp_message_pump.h" | 
| - | 
| -#include "base/macros.h" | 
| -#include "blimp/common/logging.h" | 
| -#include "blimp/common/proto/blimp_message.pb.h" | 
| -#include "blimp/net/blimp_message_processor.h" | 
| -#include "blimp/net/common.h" | 
| -#include "blimp/net/connection_error_observer.h" | 
| -#include "blimp/net/packet_reader.h" | 
| -#include "net/base/io_buffer.h" | 
| -#include "net/base/net_errors.h" | 
| - | 
| -namespace blimp { | 
| - | 
| -BlimpMessagePump::BlimpMessagePump(PacketReader* reader) | 
| -    : reader_(reader), buffer_(new net::GrowableIOBuffer), weak_factory_(this) { | 
| -  DCHECK(reader_); | 
| -  buffer_->SetCapacity(kMaxPacketPayloadSizeBytes); | 
| -} | 
| - | 
| -BlimpMessagePump::~BlimpMessagePump() {} | 
| - | 
| -void BlimpMessagePump::SetMessageProcessor(BlimpMessageProcessor* processor) { | 
| -  DVLOG(1) << "SetMessageProcessor, processor=" << processor; | 
| -  if (processor && !processor_) { | 
| -    processor_ = processor; | 
| -    ReadNextPacket(); | 
| -  } else { | 
| -    // Don't allow |processor_| to be cleared while there's a read inflight. | 
| -    if (processor) { | 
| -      DCHECK(!processor_ || !read_inflight_); | 
| -    } | 
| -    processor_ = processor; | 
| -  } | 
| -} | 
| - | 
| -void BlimpMessagePump::ReadNextPacket() { | 
| -  DVLOG(2) << "ReadNextPacket"; | 
| -  DCHECK(processor_); | 
| -  DCHECK(!read_inflight_); | 
| -  read_inflight_ = true; | 
| -  buffer_->set_offset(0); | 
| -  reader_->ReadPacket(buffer_.get(), | 
| -                      base::Bind(&BlimpMessagePump::OnReadPacketComplete, | 
| -                                 weak_factory_.GetWeakPtr())); | 
| -} | 
| - | 
| -void BlimpMessagePump::OnReadPacketComplete(int result) { | 
| -  DVLOG(2) << "OnReadPacketComplete, result=" << result; | 
| -  DCHECK(read_inflight_); | 
| -  read_inflight_ = false; | 
| -  if (result >= 0) { | 
| -    std::unique_ptr<BlimpMessage> message(new BlimpMessage); | 
| -    if (message->ParseFromArray(buffer_->data(), result)) { | 
| -      VLOG(1) << "Received " << *message; | 
| -      processor_->ProcessMessage( | 
| -          std::move(message), | 
| -          base::Bind(&BlimpMessagePump::OnProcessMessageComplete, | 
| -                     weak_factory_.GetWeakPtr())); | 
| -    } else { | 
| -      result = net::ERR_FAILED; | 
| -    } | 
| -  } | 
| - | 
| -  if (result < 0) { | 
| -    error_observer_->OnConnectionError(result); | 
| -  } | 
| -} | 
| - | 
| -void BlimpMessagePump::OnProcessMessageComplete(int result) { | 
| -  DVLOG(2) << "OnProcessMessageComplete, result=" << result; | 
| - | 
| -  if (result < 0) { | 
| -    error_observer_->OnConnectionError(result); | 
| -    return; | 
| -  } | 
| - | 
| -  if (processor_) | 
| -    ReadNextPacket(); | 
| -} | 
| - | 
| -}  // namespace blimp | 
|  |