Lines Matching refs:broker
22 #include "mojo/core/broker.h"
208 // Use the bootstrap channel for the broker and receive the node's channel
209 // synchronously as the first message from the broker.
212 broker_ = std::make_unique<Broker>(
218 // the broker was unable to negotiate a NodeChannel pipe. In this case we
296 // Shared buffer creation failure is fatal, so always use the broker when we
578 // node's inviter or broker (i.e. we don't know its process handle), ask
579 // the broker to relay for us.
580 scoped_refptr<NodeChannel> broker = GetBrokerChannel();
582 if (!GetConfiguration().is_broker_process && broker) {
583 broker->RelayEventMessage(name, std::move(event_message));
593 // Messages containing Mach ports are always routed through the broker, even
594 // if the broker process is the intended recipient.
603 scoped_refptr<NodeChannel> broker = GetBrokerChannel();
604 if (broker) {
605 broker->RelayEventMessage(name, std::move(event_message));
620 // If we don't know who the peer is and we are the broker, we can only assume
623 scoped_refptr<NodeChannel> broker = GetBrokerChannel();
624 if (!broker) {
629 // If we aren't the broker, assume we just need to be introduced and queue
630 // until that can be either confirmed or denied by the broker.
646 broker->RequestIntroduction(name);
703 scoped_refptr<NodeChannel> broker = GetBrokerChannel();
704 if (broker)
705 broker->Broadcast(std::move(channel_message));
748 // receiving an AcceptBrokerClient message from the broker. The inviter will
751 DVLOG(1) << "Broker client " << name_ << " accepting invitation from "
791 // synchronously get a new async broker channel from the broker. For now we do
794 scoped_refptr<NodeChannel> broker = GetBrokerChannel();
795 if (broker) {
796 // Inform the broker of this new client.
797 broker->AddBrokerClient(invitee_name, channel->CloneRemoteProcessHandle());
799 // If we have no broker, either we need to wait for one, or we *are* the
800 // broker.
808 // Yes, we're the broker. We can initialize the client directly.
811 // We aren't the broker, so wait for a broker connection.
842 // The broker must have a working handle to the client process in order to
845 DLOG(ERROR) << "Broker rejecting client with invalid process handle.";
853 DVLOG(1) << "Broker " << name_ << " accepting client " << client_name
869 // This should have come from our own broker.
871 DLOG(ERROR) << "BrokerClientAdded from non-broker node " << from_node;
875 DVLOG(1) << "Client " << client_name << " accepted by broker " << from_node;
908 // It's now possible to add both the broker and the inviter as peers.
909 // Note that the broker and inviter may be the same node.
910 scoped_refptr<NodeChannel> broker;
913 broker = inviter;
916 broker = NodeChannel::Create(
920 AddPeer(broker_name, broker, true /* start_channel */);
933 // Feed the broker any pending invitees of our own.
941 broker->AddBrokerClient(invitee_name,
948 // Have the broker relay any messages we have waiting.
953 broker
959 DVLOG(1) << "Client " << name_ << " accepted by broker " << broker_name;
1065 DVLOG(1) << "Adding new peer " << name << " via broker introduction.";
1103 // The broker should always know which process this came from.
1108 // Only the broker should be asked to relay a message.
1109 LOG(ERROR) << "Non-broker refusing to relay message.";
1131 LOG(ERROR) << "Refusing relayed message from non-broker node.";
