30 #include "mojo/public/cpp/bindings/associated_receiver.h"
31 #include "mojo/public/cpp/bindings/associated_remote.h"
32 #include "mojo/public/cpp/bindings/generic_pending_associated_receiver.h"
33 #include "mojo/public/cpp/bindings/pending_associated_receiver.h"
34 #include "mojo/public/cpp/bindings/thread_safe_proxy.h"
35 #include "mojo/public/cpp/system/platform_handle.h"
44       mojo::ScopedMessagePipeHandle handle,  in MojoChannelFactory()
66   mojo::ScopedMessagePipeHandle handle_;
72 class ThreadSafeChannelProxy : public mojo::ThreadSafeProxy {
74   using Forwarder = base::RepeatingCallback<void(mojo::Message)>;
79       mojo::AssociatedGroupController& group_controller)  in ThreadSafeChannelProxy()
84   // mojo::ThreadSafeProxy:
85   void SendMessage(mojo::Message& message) override {  in SendMessage()
92       mojo::Message& message,  in SendMessageWithResponder()
93       std::unique_ptr<mojo::MessageReceiver> responder) override {  in SendMessageWithResponder()
103   const raw_ref<mojo::AssociatedGroupController, DanglingUntriaged>
125     mojo::ScopedMessagePipeHandle handle,  in Create()
136     mojo::ScopedMessagePipeHandle handle,  in CreateServerFactory()
146     mojo::ScopedMessagePipeHandle handle,  in CreateClientFactory()
155     mojo::ScopedMessagePipeHandle handle,  in ChannelMojo()
166 void ChannelMojo::ForwardMessage(mojo::Message message) {  in ForwardMessage()
182   mojo::PendingAssociatedRemote<mojom::Channel> sender;  in Connect()
183   mojo::PendingAssociatedReceiver<mojom::Channel> receiver;  in Connect()
242     mojo::GenericPendingAssociatedReceiver receiver) {  in OnAssociatedInterfaceRequest()
278   // With Mojo, there's no OnFileCanReadWithoutBlocking, but we expect the  in Send()
286 std::unique_ptr<mojo::ThreadSafeForwarder<mojom::Channel>>
288   return std::make_unique<mojo::ThreadSafeForwarder<mojom::Channel>>(  in CreateThreadSafeChannel()
315     absl::optional<std::vector<mojo::native::SerializedHandlePtr>>* handles) {  in ReadFromMessageAttachmentSet()
322   std::vector<mojo::native::SerializedHandlePtr> output_handles;  in ReadFromMessageAttachmentSet()
327     auto serialized_handle = mojo::native::SerializedHandle::New();  in ReadFromMessageAttachmentSet()
330         mojo::ConvertTo<mojo::native::SerializedHandleType>(  in ReadFromMessageAttachmentSet()
344     absl::optional<std::vector<mojo::native::SerializedHandlePtr>> handles,  in WriteToMessageAttachmentSet()
353             mojo::ConvertTo<MessageAttachment::Type>(handle->type));  in WriteToMessageAttachmentSet()
363       LOG(ERROR) << "Failed to add new Mojo handle.";  in WriteToMessageAttachmentSet()
379     mojo::GenericPendingAssociatedReceiver receiver) {  in GetRemoteAssociatedInterface()
391     mojo::AssociateWithDisconnectedPipe(receiver.PassHandle());  in GetRemoteAssociatedInterface()