Lines Matching full:mojo
37 #include "mojo/public/cpp/bindings/associated_group.h"
38 #include "mojo/public/cpp/bindings/associated_group_controller.h"
39 #include "mojo/public/cpp/bindings/connector.h"
40 #include "mojo/public/cpp/bindings/interface_endpoint_client.h"
41 #include "mojo/public/cpp/bindings/interface_endpoint_controller.h"
42 #include "mojo/public/cpp/bindings/interface_id.h"
43 #include "mojo/public/cpp/bindings/message.h"
44 #include "mojo/public/cpp/bindings/message_header_validator.h"
45 #include "mojo/public/cpp/bindings/mojo_buildflags.h"
46 #include "mojo/public/cpp/bindings/pipe_control_message_handler.h"
47 #include "mojo/public/cpp/bindings/pipe_control_message_handler_delegate.h"
48 #include "mojo/public/cpp/bindings/pipe_control_message_proxy.h"
49 #include "mojo/public/cpp/bindings/sequence_local_sync_event_watcher.h"
50 #include "mojo/public/cpp/bindings/tracing_helpers.h"
108 MessageMemoryDumpInfo(const mojo::Message& message) in MessageMemoryDumpInfo()
128 : public mojo::AssociatedGroupController,
129 public mojo::MessageReceiver,
130 public mojo::PipeControlMessageHandlerDelegate {
146 dispatcher_.SetValidator(std::make_unique<mojo::MessageHeaderValidator>( in ChannelAssociatedGroupController()
190 std::vector<mojo::Message> outgoing_messages; in FlushOutgoingMessages()
200 void Bind(mojo::ScopedMessagePipeHandle handle, in Bind()
201 mojo::PendingAssociatedRemote<mojom::Channel>* sender, in Bind()
202 mojo::PendingAssociatedReceiver<mojom::Channel>* receiver) { in Bind()
203 connector_ = std::make_unique<mojo::Connector>( in Bind()
204 std::move(handle), mojo::Connector::SINGLE_THREADED_SEND, in Bind()
220 mojo::InterfaceId sender_id, receiver_id; in Bind()
222 sender_id = 1 | mojo::kInterfaceIdNamespaceMask; in Bind()
226 receiver_id = 1 | mojo::kInterfaceIdNamespaceMask; in Bind()
239 mojo::ScopedInterfaceEndpointHandle sender_handle = in Bind()
241 mojo::ScopedInterfaceEndpointHandle receiver_handle = in Bind()
244 *sender = mojo::PendingAssociatedRemote<mojom::Channel>( in Bind()
246 *receiver = mojo::PendingAssociatedReceiver<mojom::Channel>( in Bind()
264 // mojo::AssociatedGroupController:
265 mojo::InterfaceId AssociateInterface( in AssociateInterface()
266 mojo::ScopedInterfaceEndpointHandle handle_to_send) override { in AssociateInterface()
268 return mojo::kInvalidInterfaceId; in AssociateInterface()
274 if (next_interface_id_ >= mojo::kInterfaceIdNamespaceMask) in AssociateInterface()
278 id |= mojo::kInterfaceIdNamespaceMask; in AssociateInterface()
304 mojo::ScopedInterfaceEndpointHandle CreateLocalEndpointHandle( in CreateLocalEndpointHandle()
305 mojo::InterfaceId id) override { in CreateLocalEndpointHandle()
306 if (!mojo::IsValidInterfaceId(id)) in CreateLocalEndpointHandle()
307 return mojo::ScopedInterfaceEndpointHandle(); in CreateLocalEndpointHandle()
312 if (!mojo::IsPrimaryInterfaceId(id) && in CreateLocalEndpointHandle()
314 mojo::HasInterfaceIdNamespaceBitSet(id)) { in CreateLocalEndpointHandle()
315 return mojo::ScopedInterfaceEndpointHandle(); in CreateLocalEndpointHandle()
327 return mojo::ScopedInterfaceEndpointHandle(); in CreateLocalEndpointHandle()
335 mojo::InterfaceId id, in CloseEndpointHandle()
336 const absl::optional<mojo::DisconnectReason>& reason) override { in CloseEndpointHandle()
337 if (!mojo::IsValidInterfaceId(id)) in CloseEndpointHandle()
348 if (!mojo::IsPrimaryInterfaceId(id) || reason) in CloseEndpointHandle()
352 mojo::InterfaceEndpointController* AttachEndpointClient( in AttachEndpointClient()
353 const mojo::ScopedInterfaceEndpointHandle& handle, in AttachEndpointClient()
354 mojo::InterfaceEndpointClient* client, in AttachEndpointClient()
356 const mojo::InterfaceId id = handle.id(); in AttachEndpointClient()
358 DCHECK(mojo::IsValidInterfaceId(id)); in AttachEndpointClient()
374 const mojo::ScopedInterfaceEndpointHandle& handle) override { in DetachEndpointClient()
375 const mojo::InterfaceId id = handle.id(); in DetachEndpointClient()
377 DCHECK(mojo::IsValidInterfaceId(id)); in DetachEndpointClient()
429 mojo::Message message) in MessageWrapper()
460 mojo::Message& value() { return value_; } in value()
464 mojo::Message value_;
468 public mojo::InterfaceEndpointController {
470 Endpoint(ChannelAssociatedGroupController* controller, mojo::InterfaceId id) in Endpoint()
476 mojo::InterfaceId id() const { return id_; } in id()
508 const absl::optional<mojo::DisconnectReason>& disconnect_reason() const { in disconnect_reason()
513 const absl::optional<mojo::DisconnectReason>& disconnect_reason) { in set_disconnect_reason()
523 mojo::InterfaceEndpointClient* client() const { in client()
528 void AttachClient(mojo::InterfaceEndpointClient* client, in AttachClient()
581 // mojo::InterfaceEndpointController:
582 bool SendMessage(mojo::Message* message) override { in SendMessage()
674 mojo::InterfaceEndpointClient* client = client_; in OnSyncMessageEventReady()
705 sync_watcher_ = std::make_unique<mojo::SequenceLocalSyncEventWatcher>( in EnsureSyncWatcherExists()
742 const mojo::InterfaceId id_;
748 absl::optional<mojo::DisconnectReason> disconnect_reason_;
749 raw_ptr<mojo::InterfaceEndpointClient> client_ = nullptr;
751 std::unique_ptr<mojo::SequenceLocalSyncEventWatcher> sync_watcher_;
769 bool Accept(mojo::Message* message) override { in Accept()
801 bool SendMessage(mojo::Message* message) { in SendMessage()
825 void SendMessageOnPrimaryThread(mojo::Message message) { in SendMessageOnPrimaryThread()
864 mojo::InterfaceEndpointClient* client = endpoint->client(); in NotifyEndpointOfError()
865 absl::optional<mojo::DisconnectReason> reason( in NotifyEndpointOfError()
883 void NotifyEndpointOfErrorOnEndpointThread(mojo::InterfaceId id, in NotifyEndpointOfErrorOnEndpointThread()
911 Endpoint* FindOrInsertEndpoint(mojo::InterfaceId id, bool* inserted) { in FindOrInsertEndpoint()
925 Endpoint* FindEndpoint(mojo::InterfaceId id) { in FindEndpoint()
931 // mojo::MessageReceiver:
932 bool Accept(mojo::Message* message) override { in Accept()
938 if (mojo::PipeControlMessageHandler::IsPipeControlMessage(message)) in Accept()
941 mojo::InterfaceId id = message->interface_id(); in Accept()
942 if (!mojo::IsValidInterfaceId(id)) in Accept()
950 mojo::InterfaceEndpointClient* client = endpoint->client(); in Accept()
981 if (message->has_flag(mojo::Message::kFlagIsSync)) { in Accept()
1026 void AcceptOnEndpointThread(mojo::Message message) { in AcceptOnEndpointThread()
1030 mojo::InterfaceId id = message.interface_id(); in AcceptOnEndpointThread()
1031 DCHECK(mojo::IsValidInterfaceId(id) && !mojo::IsPrimaryInterfaceId(id)); in AcceptOnEndpointThread()
1038 mojo::InterfaceEndpointClient* client = endpoint->client(); in AcceptOnEndpointThread()
1052 // string defined for each mojo interface. in AcceptOnEndpointThread()
1064 DCHECK(!message.has_flag(mojo::Message::kFlagIsSync)); in AcceptOnEndpointThread()
1076 void AcceptSyncMessage(mojo::InterfaceId interface_id, uint32_t message_id) { in AcceptSyncMessage()
1087 mojo::InterfaceEndpointClient* client = endpoint->client(); in AcceptSyncMessage()
1097 // string defined for each mojo interface. in AcceptSyncMessage()
1116 // mojo::PipeControlMessageHandlerDelegate:
1118 mojo::InterfaceId id, in OnPeerAssociatedEndpointClosed()
1119 const absl::optional<mojo::DisconnectReason>& reason) override { in OnPeerAssociatedEndpointClosed()
1137 mojo::ScopedMessagePipeHandle flush_pipe) override { in WaitForFlushToComplete()
1150 std::unique_ptr<mojo::Connector> connector_;
1151 mojo::MessageDispatcher dispatcher_;
1152 mojo::PipeControlMessageHandler control_message_handler_;
1156 mojo::PipeControlMessageProxy control_message_proxy_;
1164 std::vector<mojo::Message> outgoing_messages_;
1184 base::StringPrintf("mojo/queued_ipc_channel_message/0x%" PRIxPTR, in OnMemoryDump()
1214 mojo::ScopedMessagePipeHandle handle, in MojoBootstrapImpl()
1229 mojo::PendingAssociatedRemote<mojom::Channel>* sender, in Connect()
1230 mojo::PendingAssociatedReceiver<mojom::Channel>* receiver) override { in Connect()
1248 mojo::AssociatedGroup* GetAssociatedGroup() override { in GetAssociatedGroup()
1253 mojo::AssociatedGroup associated_group_;
1255 mojo::ScopedMessagePipeHandle handle_;
1269 mojo::ScopedMessagePipeHandle handle, in Create()