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

Unified Diff: third_party/mojo/src/mojo/public/cpp/bindings/lib/router.h

Issue 1410053006: Move third_party/mojo/src/mojo/public to mojo/public (Closed) Base URL: https://chromium.googlesource.com/chromium/src.git@master
Patch Set: merge 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: third_party/mojo/src/mojo/public/cpp/bindings/lib/router.h
diff --git a/third_party/mojo/src/mojo/public/cpp/bindings/lib/router.h b/third_party/mojo/src/mojo/public/cpp/bindings/lib/router.h
deleted file mode 100644
index 97ce2395392929cea6a0baeb26aecf3e42c6cbde..0000000000000000000000000000000000000000
--- a/third_party/mojo/src/mojo/public/cpp/bindings/lib/router.h
+++ /dev/null
@@ -1,141 +0,0 @@
-// Copyright 2014 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.
-
-#ifndef THIRD_PARTY_MOJO_SRC_MOJO_PUBLIC_CPP_BINDINGS_LIB_ROUTER_H_
-#define THIRD_PARTY_MOJO_SRC_MOJO_PUBLIC_CPP_BINDINGS_LIB_ROUTER_H_
-
-#include <map>
-
-#include "third_party/mojo/src/mojo/public/cpp/bindings/callback.h"
-#include "third_party/mojo/src/mojo/public/cpp/bindings/lib/connector.h"
-#include "third_party/mojo/src/mojo/public/cpp/bindings/lib/filter_chain.h"
-#include "third_party/mojo/src/mojo/public/cpp/bindings/lib/shared_data.h"
-#include "third_party/mojo/src/mojo/public/cpp/bindings/lib/thread_checker.h"
-#include "third_party/mojo/src/mojo/public/cpp/environment/environment.h"
-#include "third_party/mojo/src/mojo/public/cpp/environment/logging.h"
-
-namespace mojo {
-namespace internal {
-
-class Router : public MessageReceiverWithResponder {
- public:
- Router(ScopedMessagePipeHandle message_pipe,
- FilterChain filters,
- const MojoAsyncWaiter* waiter = Environment::GetDefaultAsyncWaiter());
- ~Router() override;
-
- // Sets the receiver to handle messages read from the message pipe that do
- // not have the kMessageIsResponse flag set.
- void set_incoming_receiver(MessageReceiverWithResponderStatus* receiver) {
- incoming_receiver_ = receiver;
- }
-
- // Sets the error handler to receive notifications when an error is
- // encountered while reading from the pipe or waiting to read from the pipe.
- void set_connection_error_handler(const Closure& error_handler) {
- connector_.set_connection_error_handler(error_handler);
- }
-
- // Returns true if an error was encountered while reading from the pipe or
- // waiting to read from the pipe.
- bool encountered_error() const {
- MOJO_DCHECK(thread_checker_.CalledOnValidThread());
- return connector_.encountered_error();
- }
-
- // Is the router bound to a MessagePipe handle?
- bool is_valid() const {
- MOJO_DCHECK(thread_checker_.CalledOnValidThread());
- return connector_.is_valid();
- }
-
- // Please note that this method shouldn't be called unless it results from an
- // explicit request of the user of bindings (e.g., the user sets an
- // InterfacePtr to null or closes a Binding).
- void CloseMessagePipe() {
- MOJO_DCHECK(thread_checker_.CalledOnValidThread());
- connector_.CloseMessagePipe();
- }
-
- ScopedMessagePipeHandle PassMessagePipe() {
- MOJO_DCHECK(thread_checker_.CalledOnValidThread());
- return connector_.PassMessagePipe();
- }
-
- void RaiseError() {
- MOJO_DCHECK(thread_checker_.CalledOnValidThread());
- connector_.RaiseError();
- }
-
- // MessageReceiver implementation:
- bool Accept(Message* message) override;
- bool AcceptWithResponder(Message* message,
- MessageReceiver* responder) override;
-
- // Blocks the current thread until the first incoming method call, i.e.,
- // either a call to a client method or a callback method, or |deadline|.
- bool WaitForIncomingMessage(MojoDeadline deadline) {
- MOJO_DCHECK(thread_checker_.CalledOnValidThread());
- return connector_.WaitForIncomingMessage(deadline);
- }
-
- // See Binding for details of pause/resume.
- void PauseIncomingMethodCallProcessing() {
- MOJO_DCHECK(thread_checker_.CalledOnValidThread());
- connector_.PauseIncomingMethodCallProcessing();
- }
- void ResumeIncomingMethodCallProcessing() {
- MOJO_DCHECK(thread_checker_.CalledOnValidThread());
- connector_.ResumeIncomingMethodCallProcessing();
- }
-
- // Sets this object to testing mode.
- // In testing mode:
- // - the object is more tolerant of unrecognized response messages;
- // - the connector continues working after seeing errors from its incoming
- // receiver.
- void EnableTestingMode();
-
- MessagePipeHandle handle() const { return connector_.handle(); }
-
- // Returns true if this Router has any pending callbacks.
- bool has_pending_responders() const {
- MOJO_DCHECK(thread_checker_.CalledOnValidThread());
- return !responders_.empty();
- }
-
- private:
- typedef std::map<uint64_t, MessageReceiver*> ResponderMap;
-
- class HandleIncomingMessageThunk : public MessageReceiver {
- public:
- HandleIncomingMessageThunk(Router* router);
- ~HandleIncomingMessageThunk() override;
-
- // MessageReceiver implementation:
- bool Accept(Message* message) override;
-
- private:
- Router* router_;
- };
-
- bool HandleIncomingMessage(Message* message);
-
- HandleIncomingMessageThunk thunk_;
- FilterChain filters_;
- Connector connector_;
- SharedData<Router*> weak_self_;
- MessageReceiverWithResponderStatus* incoming_receiver_;
- // Maps from the id of a response to the MessageReceiver that handles the
- // response.
- ResponderMap responders_;
- uint64_t next_request_id_;
- bool testing_mode_;
- ThreadChecker thread_checker_;
-};
-
-} // namespace internal
-} // namespace mojo
-
-#endif // THIRD_PARTY_MOJO_SRC_MOJO_PUBLIC_CPP_BINDINGS_LIB_ROUTER_H_

Powered by Google App Engine
This is Rietveld 408576698