Lines Matching refs:IPC
61 void SendString(IPC::Sender* sender, const std::string& str) { in SendString()
62 IPC::Message* message = new IPC::Message(0, 2, IPC::Message::PRIORITY_NORMAL); in SendString()
67 void SendValue(IPC::Sender* sender, int32_t value) { in SendValue()
68 IPC::Message* message = new IPC::Message(0, 2, IPC::Message::PRIORITY_NORMAL); in SendValue()
73 class ListenerThatExpectsOK : public IPC::Listener {
80 bool OnMessageReceived(const IPC::Message& message) override { in OnMessageReceived()
97 static void SendOK(IPC::Sender* sender) { SendString(sender, "OK"); } in SendOK()
104 class TestListenerBase : public IPC::Listener {
112 void set_sender(IPC::Sender* sender) { sender_ = sender; } in set_sender()
113 IPC::Sender* sender() const { return sender_; } in sender()
120 IPC::Sender* sender_ = nullptr;
127 : public IPC::TestChannelListener {
132 IPC::TestChannelListener::OnChannelConnected(peer_pid); in OnChannelConnected()
152 IPC::TestChannelListener::SendOneMessage(sender(), "hello from parent"); in TEST_F()
171 IPC::TestChannelListener::SendOneMessage(channel(), "hello from child"); in DEFINE_IPC_CHANNEL_MOJO_TEST_CLIENT()
184 bool OnMessageReceived(const IPC::Message& message) override { return true; } in OnMessageReceived()
197 class ListenerThatQuits : public IPC::Listener {
202 bool OnMessageReceived(const IPC::Message& message) override { return true; } in OnMessageReceived()
237 IPC::TestChannelListener::SendOneMessage(sender(), in TEST_F()
251 class ListenerThatBindsATestStructPasser : public IPC::Listener,
252 public IPC::mojom::TestStructPasser {
256 bool OnMessageReceived(const IPC::Message& message) override { return true; } in OnMessageReceived()
265 CHECK_EQ(interface_name, IPC::mojom::TestStructPasser::Name_); in OnAssociatedInterfaceRequest()
267 IPC::mojom::TestStructPasserAssociatedRequest(std::move(handle))); in OnAssociatedInterfaceRequest()
272 void Pass(IPC::mojom::TestStructPtr) override { NOTREACHED(); } in Pass()
274 mojo::AssociatedBinding<IPC::mojom::TestStructPasser> binding_;
277 class ListenerThatExpectsNoError : public IPC::Listener {
284 bool OnMessageReceived(const IPC::Message& message) override { in OnMessageReceived()
313 IPC::mojom::TestStructPasserAssociatedPtr passer; in DEFINE_IPC_CHANNEL_MOJO_TEST_CLIENT()
378 static void WritePipe(IPC::Message* message, TestingMessagePipe* pipe) { in WritePipe()
384 EXPECT_TRUE(IPC::MojoMessageHelper::WriteMessagePipeTo( in WritePipe()
388 static void WritePipeThenSend(IPC::Sender* sender, TestingMessagePipe* pipe) { in WritePipeThenSend()
389 IPC::Message* message = in WritePipeThenSend()
390 new IPC::Message(0, 2, IPC::Message::PRIORITY_NORMAL); in WritePipeThenSend()
395 static void ReadReceivedPipe(const IPC::Message& message, in ReadReceivedPipe()
399 IPC::MojoMessageHelper::ReadMessagePipeFrom(&message, iter, &pipe)); in ReadReceivedPipe()
415 static void WriteFile(IPC::Message* message, base::File& file) { in WriteFile()
419 message->WriteAttachment(new IPC::internal::PlatformFileAttachment( in WriteFile()
423 static void WriteFileThenSend(IPC::Sender* sender, base::File& file) { in WriteFileThenSend()
424 IPC::Message* message = in WriteFileThenSend()
425 new IPC::Message(0, 2, IPC::Message::PRIORITY_NORMAL); in WriteFileThenSend()
430 static void WriteFileAndPipeThenSend(IPC::Sender* sender, in WriteFileAndPipeThenSend()
433 IPC::Message* message = in WriteFileAndPipeThenSend()
434 new IPC::Message(0, 2, IPC::Message::PRIORITY_NORMAL); in WriteFileAndPipeThenSend()
440 static void ReadReceivedFile(const IPC::Message& message, in ReadReceivedFile()
445 IPC::MessageAttachment::Type::PLATFORM_FILE, in ReadReceivedFile()
446 static_cast<IPC::MessageAttachment*>(attachment.get())->GetType()); in ReadReceivedFile()
448 static_cast<IPC::internal::PlatformFileAttachment*>(attachment.get()) in ReadReceivedFile()
464 bool OnMessageReceived(const IPC::Message& message) override { in OnMessageReceived()
526 bool OnMessageReceived(const IPC::Message& message) override { in OnMessageReceived()
529 EXPECT_TRUE(IPC::ParamTraits<mojo::MessagePipeHandle>::Read(&message, &iter, in OnMessageReceived()
570 std::unique_ptr<IPC::Message> message(new IPC::Message()); in TEST_F()
571 IPC::ParamTraits<mojo::MessagePipeHandle>::Write(message.get(), in TEST_F()
598 std::unique_ptr<IPC::Message> message(new IPC::Message()); in TEST_F()
599 IPC::ParamTraits<mojo::MessagePipeHandle>::Write(message.get(), in TEST_F()
626 ASSERT_FALSE(channel()->Send(new IPC::Message())); in TEST_F()
637 bool OnMessageReceived(const IPC::Message& message) override { return true; } in OnMessageReceived()
657 : public IPC::Listener,
658 public IPC::mojom::SimpleTestDriver {
667 bool OnMessageReceived(const IPC::Message& message) override { in OnMessageReceived()
678 void RegisterInterfaceFactory(IPC::Channel* channel) { in RegisterInterfaceFactory()
702 void BindRequest(IPC::mojom::SimpleTestDriverAssociatedRequest request) { in BindRequest()
711 mojo::AssociatedBinding<IPC::mojom::SimpleTestDriver> binding_;
716 class ListenerSendingAssociatedMessages : public IPC::Listener {
721 bool OnMessageReceived(const IPC::Message& message) override { return true; } in OnMessageReceived()
739 void set_channel(IPC::Channel* channel) { channel_ = channel; } in set_channel()
744 IPC::Channel* channel_ = nullptr;
745 IPC::mojom::SimpleTestDriverAssociatedPtr driver_;
788 void CreateProxy(IPC::Listener* listener) { in CreateProxy()
791 proxy_ = IPC::SyncChannel::Create(listener, io_thread_.task_runner(), in CreateProxy()
797 std::unique_ptr<IPC::ChannelFactory> factory; in RunProxy()
799 factory = IPC::ChannelMojo::CreateServerFactory( in RunProxy()
803 factory = IPC::ChannelMojo::CreateClientFactory( in RunProxy()
810 IPC::ChannelProxy* proxy() { return proxy_.get(); } in proxy()
818 std::unique_ptr<IPC::ChannelProxy> proxy_;
829 void CreateProxy(IPC::Listener* listener) { runner_->CreateProxy(listener); } in CreateProxy()
838 IPC::ChannelProxy* proxy() { return runner_->proxy(); } in proxy()
845 : public IPC::Listener,
846 public IPC::mojom::SimpleTestDriver {
856 bool OnMessageReceived(const IPC::Message& message) override { in OnMessageReceived()
870 DCHECK_EQ(interface_name, IPC::mojom::SimpleTestDriver::Name_); in OnAssociatedInterfaceRequest()
872 IPC::mojom::SimpleTestDriverAssociatedRequest(std::move(handle))); in OnAssociatedInterfaceRequest()
897 void BindRequest(IPC::mojom::SimpleTestDriverAssociatedRequest request) { in BindRequest()
906 mojo::AssociatedBinding<IPC::mojom::SimpleTestDriver> binding_;
933 void CreateProxy(IPC::Listener* listener) { runner_->CreateProxy(listener); } in CreateProxy()
942 void RequestQuitAndWaitForAck(IPC::mojom::SimpleTestDriver* driver) { in RequestQuitAndWaitForAck()
948 IPC::ChannelProxy* proxy() { return runner_->proxy(); } in proxy()
955 class DummyListener : public IPC::Listener {
958 bool OnMessageReceived(const IPC::Message& message) override { return true; } in OnMessageReceived()
970 IPC::mojom::SimpleTestDriverAssociatedPtr driver; in DEFINE_IPC_CHANNEL_MOJO_TEST_CLIENT_WITH_CUSTOM_FIXTURE()
985 : public IPC::Listener,
986 public IPC::mojom::IndirectTestDriver,
987 public IPC::mojom::PingReceiver {
994 bool OnMessageReceived(const IPC::Message& message) override { return true; } in OnMessageReceived()
1000 DCHECK_EQ(interface_name, IPC::mojom::IndirectTestDriver::Name_); in OnAssociatedInterfaceRequest()
1002 IPC::mojom::IndirectTestDriverAssociatedRequest(std::move(handle))); in OnAssociatedInterfaceRequest()
1012 IPC::mojom::PingReceiverAssociatedRequest request) override { in GetPingReceiver()
1022 mojo::AssociatedBinding<IPC::mojom::IndirectTestDriver> driver_binding_;
1023 mojo::AssociatedBinding<IPC::mojom::PingReceiver> ping_receiver_binding_;
1060 IPC::mojom::IndirectTestDriverAssociatedPtr driver; in DEFINE_IPC_CHANNEL_MOJO_TEST_CLIENT_WITH_CUSTOM_FIXTURE()
1061 IPC::mojom::PingReceiverAssociatedPtr ping_receiver; in DEFINE_IPC_CHANNEL_MOJO_TEST_CLIENT_WITH_CUSTOM_FIXTURE()
1073 : public IPC::Listener,
1074 public IPC::mojom::SimpleTestDriver {
1079 void set_sync_sender(IPC::Sender* sync_sender) { sync_sender_ = sync_sender; } in set_sync_sender()
1113 bool OnMessageReceived(const IPC::Message& message) override { in OnMessageReceived()
1117 std::unique_ptr<IPC::Message> reply( in OnMessageReceived()
1118 IPC::SyncMessage::GenerateReply(&message)); in OnMessageReceived()
1129 DCHECK_EQ(interface_name, IPC::mojom::SimpleTestDriver::Name_); in OnAssociatedInterfaceRequest()
1131 IPC::mojom::SimpleTestDriverAssociatedRequest(std::move(handle))); in OnAssociatedInterfaceRequest()
1134 void BindRequest(IPC::mojom::SimpleTestDriverAssociatedRequest request) { in BindRequest()
1139 IPC::Sender* sync_sender_ = nullptr;
1144 mojo::AssociatedBinding<IPC::mojom::SimpleTestDriver> binding_;
1147 class SyncReplyReader : public IPC::MessageReplyDeserializer {
1154 bool SerializeOutputParameters(const IPC::Message& message, in SerializeOutputParameters()
1180 IPC::mojom::SimpleTestClientAssociatedPtr client; in TEST_F()
1195 std::unique_ptr<IPC::SyncMessage> request( in TEST_F()
1196 new IPC::SyncMessage(0, 0, IPC::Message::PRIORITY_NORMAL, in TEST_F()
1207 class SimpleTestClientImpl : public IPC::mojom::SimpleTestClient,
1208 public IPC::Listener {
1212 void set_driver(IPC::mojom::SimpleTestDriver* driver) { driver_ = driver; } in set_driver()
1213 void set_sync_sender(IPC::Sender* sync_sender) { sync_sender_ = sync_sender; } in set_sync_sender()
1229 std::unique_ptr<IPC::SyncMessage> reply(new IPC::SyncMessage( in RequestValue()
1230 0, 0, IPC::Message::PRIORITY_NORMAL, new SyncReplyReader(&response))); in RequestValue()
1244 bool OnMessageReceived(const IPC::Message& message) override { in OnMessageReceived()
1248 std::unique_ptr<IPC::Message> reply( in OnMessageReceived()
1249 IPC::SyncMessage::GenerateReply(&message)); in OnMessageReceived()
1262 DCHECK_EQ(interface_name, IPC::mojom::SimpleTestClient::Name_); in OnAssociatedInterfaceRequest()
1265 IPC::mojom::SimpleTestClientAssociatedRequest(std::move(handle))); in OnAssociatedInterfaceRequest()
1269 mojo::AssociatedBinding<IPC::mojom::SimpleTestClient> binding_;
1270 IPC::Sender* sync_sender_ = nullptr;
1271 IPC::mojom::SimpleTestDriver* driver_ = nullptr;
1284 IPC::mojom::SimpleTestDriverAssociatedPtr driver; in DEFINE_IPC_CHANNEL_MOJO_TEST_CLIENT_WITH_CUSTOM_FIXTURE()
1363 class ExpectValueSequenceListener : public IPC::Listener {
1372 bool OnMessageReceived(const IPC::Message& message) override { in OnMessageReceived()
1416 IPC::mojom::AssociatedInterfaceVendorAssociatedPtr vendor; in TEST_F()
1418 IPC::mojom::SimpleTestDriverAssociatedPtr tester; in TEST_F()
1429 class AssociatedInterfaceDroppingListener : public IPC::Listener {
1433 bool OnMessageReceived(const IPC::Message& message) override { return false; } in OnMessageReceived()
1438 if (interface_name == IPC::mojom::SimpleTestDriver::Name_) in OnAssociatedInterfaceRequest()
1465 bool OnMessageReceived(const IPC::Message& message) override { in OnMessageReceived()
1469 EXPECT_TRUE(IPC::ReadParam(&message, &iter, &shared_memory)); in OnMessageReceived()
1496 IPC::Message* message = new IPC::Message(0, 2, IPC::Message::PRIORITY_NORMAL); in TEST_F()
1497 IPC::WriteParam(message, shmem.handle()); in TEST_F()
1553 bool OnMessageReceived(const IPC::Message& message) override { in OnMessageReceived()
1557 EXPECT_TRUE(IPC::ReadParam(&message, &iter, ®ion)); in OnMessageReceived()
1590 IPC::Message* message = new IPC::Message(0, 2, IPC::Message::PRIORITY_NORMAL); in TYPED_TEST()
1591 IPC::WriteParam(message, region); in TYPED_TEST()
1648 bool OnMessageReceived(const IPC::Message& message) override { in OnMessageReceived()
1696 bool OnMessageReceived(const IPC::Message& message) override { in OnMessageReceived()
1756 bool OnMessageReceived(const IPC::Message& message) override { in OnMessageReceived()
1778 IPC::Channel::SetGlobalPid(kMagicChildId); in DEFINE_IPC_CHANNEL_MOJO_TEST_CLIENT()