Lines Matching full:broker
22 #include "mojo/edk/system/broker.h"
231 // TODO(amistry): Consider the need for a broker on Windows.
233 // On posix, use the bootstrap channel for the broker and receive the node's
234 // channel synchronously as the first message from the broker.
236 broker_.reset(new Broker(std::move(platform_handle)));
243 // the broker was unable to negotiate a NodeChannel pipe. In this case we
349 // Shared buffer creation failure is fatal, so always use the broker when we
351 // the broker for shared buffer creation even though that process is
591 // node's parent or broker (i.e. we don't know its process handle), ask
592 // the broker to relay for us.
593 scoped_refptr<NodeChannel> broker = GetBrokerChannel();
595 if (broker) {
596 broker->RelayPortsMessage(name, std::move(channel_message));
606 // Messages containing Mach ports are always routed through the broker, even
607 // if the broker process is the intended recipient.
615 scoped_refptr<NodeChannel> broker = GetBrokerChannel();
616 if (broker) {
617 broker->RelayPortsMessage(name, std::move(channel_message));
633 // is the first message queued for the peer, we also ask the broker to
645 scoped_refptr<NodeChannel> broker = GetBrokerChannel();
646 if (!broker) {
650 broker->RequestIntroduction(name);
778 scoped_refptr<NodeChannel> broker = GetBrokerChannel();
779 if (broker)
780 broker->Broadcast(std::move(channel_message));
822 // receiving an AcceptBrokerClient message from the broker. The parent
851 // synchronously get a new async broker channel from the broker. For now we do
854 scoped_refptr<NodeChannel> broker = GetBrokerChannel();
855 if (broker) {
856 // Inform the broker of this new child.
857 broker->AddBrokerClient(child_name, channel->CopyRemoteProcessHandle());
859 // If we have no broker, either we need to wait for one, or we *are* the
860 // broker.
868 // Yes, we're the broker. We can initialize the child directly.
871 // We aren't the broker, so wait for a broker connection.
904 // The broker must have a working handle to the client process in order to
907 DLOG(ERROR) << "Broker rejecting client with invalid process handle.";
917 DVLOG(1) << "Broker " << name_ << " accepting client " << client_name
932 // This should have come from our own broker.
934 DLOG(ERROR) << "BrokerClientAdded from non-broker node " << from_node;
938 DVLOG(1) << "Child " << client_name << " accepted by broker " << from_node;
969 // It's now possible to add both the broker and the parent as peers.
970 // Note that the broker and parent may be the same node.
971 scoped_refptr<NodeChannel> broker;
974 broker = parent;
977 broker = NodeChannel::Create(this, std::move(broker_channel),
979 AddPeer(broker_name, broker, true /* start_channel */);
992 // Feed the broker any pending children of our own.
997 broker->AddBrokerClient(child_name, it->second->CopyRemoteProcessHandle());
1002 // Have the broker relay any messages we have waiting.
1007 broker->RelayPortsMessage(destination, std::move(message_queue.front()));
1013 DVLOG(1) << "Child " << name_ << " accepted by broker " << broker_name;
1151 // Only the broker should be asked to relay a message.
1152 LOG(ERROR) << "Non-broker refusing to relay message.";
1213 LOG(ERROR) << "Refusing relayed message from non-broker node.";
