// Copyright 2016 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_CORE_BROKER_HOST_H_ #define MOJO_CORE_BROKER_HOST_H_ #include #include #include "base/process/process.h" #include "base/process/process_handle.h" #include "base/strings/string_piece.h" #include "base/task/current_thread.h" #include "build/build_config.h" #include "mojo/core/channel.h" #include "mojo/core/connection_params.h" #include "mojo/core/embedder/process_error_callback.h" #include "mojo/core/platform_handle_in_transit.h" #include "mojo/public/cpp/platform/platform_handle.h" namespace mojo { namespace core { // The BrokerHost is a channel to a broker client process, servicing synchronous // IPCs issued by the client. class BrokerHost : public Channel::Delegate, public base::CurrentThread::DestructionObserver { public: BrokerHost(base::Process client_process, ConnectionParams connection_params, const ProcessErrorCallback& process_error_callback); BrokerHost(const BrokerHost&) = delete; BrokerHost& operator=(const BrokerHost&) = delete; // Send |handle| to the client, to be used to establish a NodeChannel to us. bool SendChannel(PlatformHandle handle); #if BUILDFLAG(IS_WIN) // Sends a named channel to the client. Like above, but for named pipes. void SendNamedChannel(base::WStringPiece pipe_name); #endif private: ~BrokerHost() override; bool PrepareHandlesForClient(std::vector* handles); // Channel::Delegate: void OnChannelMessage(const void* payload, size_t payload_size, std::vector handles) override; void OnChannelError(Channel::Error error) override; // base::CurrentThread::DestructionObserver: void WillDestroyCurrentMessageLoop() override; void OnBufferRequest(uint32_t num_bytes); const ProcessErrorCallback process_error_callback_; #if BUILDFLAG(IS_WIN) base::Process client_process_; #endif scoped_refptr channel_; }; } // namespace core } // namespace mojo #endif // MOJO_CORE_BROKER_HOST_H_