diff options
Diffstat (limited to 'mojo/public/cpp/bindings/lib/router.h')
-rw-r--r-- | mojo/public/cpp/bindings/lib/router.h | 93 |
1 files changed, 0 insertions, 93 deletions
diff --git a/mojo/public/cpp/bindings/lib/router.h b/mojo/public/cpp/bindings/lib/router.h deleted file mode 100644 index 8254bab..0000000 --- a/mojo/public/cpp/bindings/lib/router.h +++ /dev/null @@ -1,93 +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 MOJO_PUBLIC_CPP_BINDINGS_LIB_ROUTER_H_ -#define MOJO_PUBLIC_CPP_BINDINGS_LIB_ROUTER_H_ - -#include <map> - -#include "mojo/public/cpp/bindings/lib/connector.h" -#include "mojo/public/cpp/bindings/lib/filter_chain.h" -#include "mojo/public/cpp/bindings/lib/shared_data.h" -#include "mojo/public/cpp/environment/environment.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(MessageReceiverWithResponder* 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_error_handler(ErrorHandler* error_handler) { - connector_.set_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 { return connector_.encountered_error(); } - - void CloseMessagePipe() { connector_.CloseMessagePipe(); } - - ScopedMessagePipeHandle PassMessagePipe() { - return connector_.PassMessagePipe(); - } - - // MessageReceiver implementation: - bool Accept(Message* message) override; - bool AcceptWithResponder(Message* message, - MessageReceiver* responder) override; - - // Blocks the current thread for the first incoming method call, i.e., either - // a call to a client method or a callback method. - bool WaitForIncomingMessage() { return connector_.WaitForIncomingMessage(); } - - // 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(); - - 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_; - MessageReceiverWithResponder* incoming_receiver_; - ResponderMap responders_; - uint64_t next_request_id_; - bool testing_mode_; -}; - -} // namespace internal -} // namespace mojo - -#endif // MOJO_PUBLIC_CPP_BINDINGS_LIB_ROUTER_H_ |