Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(1946)

Unified Diff: blimp/net/blimp_message_pump.cc

Issue 2632803002: Remove all blimp network code. (Closed)
Patch Set: merge from origin/master for good measure Created 3 years, 11 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View side-by-side diff with in-line comments
Download patch
« no previous file with comments | « blimp/net/blimp_message_pump.h ('k') | blimp/net/blimp_message_pump_unittest.cc » ('j') | no next file with comments »
Expand Comments ('e') | Collapse Comments ('c') | Show Comments Hide Comments ('s')
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
« no previous file with comments | « blimp/net/blimp_message_pump.h ('k') | blimp/net/blimp_message_pump_unittest.cc » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698