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

Unified Diff: blimp/net/blimp_message_demultiplexer.cc

Issue 1429193002: Add interfaces for most major Blimp net components. (Closed) Base URL: https://chromium.googlesource.com/chromium/src.git@master
Patch Set: Import multiplexer changes from 1434533005 Created 5 years, 1 month 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
Index: blimp/net/blimp_message_demultiplexer.cc
diff --git a/blimp/net/blimp_message_dispatcher.cc b/blimp/net/blimp_message_demultiplexer.cc
similarity index 61%
rename from blimp/net/blimp_message_dispatcher.cc
rename to blimp/net/blimp_message_demultiplexer.cc
index 8c07c9f3bd566feecc9bf98fb637c6af2bea085d..a380c2b8e378d0e880df87bae1afad721cbd8866 100644
--- a/blimp/net/blimp_message_dispatcher.cc
+++ b/blimp/net/blimp_message_demultiplexer.cc
@@ -2,11 +2,12 @@
// 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_dispatcher.h"
+#include "blimp/net/blimp_message_demultiplexer.h"
#include <string>
#include "base/strings/stringprintf.h"
+#include "net/base/net_errors.h"
namespace blimp {
namespace {
@@ -17,12 +18,12 @@ std::string BlimpMessageToDebugString(const BlimpMessage& message) {
} // namespace
-BlimpMessageDispatcher::BlimpMessageDispatcher() {}
+BlimpMessageDemultiplexer::BlimpMessageDemultiplexer() {}
-BlimpMessageDispatcher::~BlimpMessageDispatcher() {}
+BlimpMessageDemultiplexer::~BlimpMessageDemultiplexer() {}
-void BlimpMessageDispatcher::AddReceiver(BlimpMessage::Type type,
- BlimpMessageReceiver* receiver) {
+void BlimpMessageDemultiplexer::AddProcessor(BlimpMessage::Type type,
+ BlimpMessageProcessor* receiver) {
DCHECK(receiver);
if (feature_receiver_map_.find(type) == feature_receiver_map_.end()) {
feature_receiver_map_.insert(std::make_pair(type, receiver));
@@ -31,15 +32,17 @@ void BlimpMessageDispatcher::AddReceiver(BlimpMessage::Type type,
}
}
-net::Error BlimpMessageDispatcher::OnBlimpMessage(const BlimpMessage& message) {
+void BlimpMessageDemultiplexer::ProcessMessage(
+ const BlimpMessage& message,
+ const net::CompletionCallback& callback) {
auto receiver_iter = feature_receiver_map_.find(message.type());
if (receiver_iter == feature_receiver_map_.end()) {
DLOG(FATAL) << "No registered receiver for "
<< BlimpMessageToDebugString(message) << ".";
- return net::ERR_NOT_IMPLEMENTED;
+ callback.Run(net::ERR_NOT_IMPLEMENTED);
}
- return receiver_iter->second->OnBlimpMessage(message);
+ receiver_iter->second->ProcessMessage(message, callback);
}
} // namespace blimp

Powered by Google App Engine
This is Rietveld 408576698