Home
last modified time | relevance | path

Searched refs:IPC (Results 1 – 25 of 1540) sorted by relevance

12345678910>>...62

/external/chromium_org/ipc/
Dipc_channel_posix_unittest.cc32 class IPCChannelPosixTestListener : public IPC::Listener {
50 virtual bool OnMessageReceived(const IPC::Message& message) OVERRIDE { in OnMessageReceived()
105 static void SetUpSocket(IPC::ChannelHandle *handle,
106 IPC::Channel::Mode mode);
146 void IPCChannelPosixTest::SetUpSocket(IPC::ChannelHandle *handle, in SetUpSocket()
147 IPC::Channel::Mode mode) { in SetUpSocket()
156 int path_len = snprintf(server_address.sun_path, IPC::kMaxSocketNameLength, in SetUpSocket()
162 if (mode == IPC::Channel::MODE_NAMED_SERVER) { in SetUpSocket()
177 } else if (mode == IPC::Channel::MODE_NAMED_CLIENT) { in SetUpSocket()
204 IPC::ChannelHandle handle(kChannelName); in TEST_F()
[all …]
Dipc_fuzzing_tests.cc41 IPC::Message m(0, 1, IPC::Message::PRIORITY_NORMAL); in TEST()
54 IPC::Message m(0, 1, IPC::Message::PRIORITY_NORMAL); in TEST()
65 IPC::Message m(0, 1, IPC::Message::PRIORITY_NORMAL); in TEST()
78 IPC::Message m(0, 1, IPC::Message::PRIORITY_NORMAL); in TEST()
92 IPC::Message m(0, 1, IPC::Message::PRIORITY_NORMAL); in TEST()
106 IPC::Message m(0, 1, IPC::Message::PRIORITY_NORMAL); in TEST()
116 class SimpleListener : public IPC::Listener {
120 void Init(IPC::Sender* s) { in Init()
124 IPC::Sender* other_;
138 virtual bool OnMessageReceived(const IPC::Message& msg) OVERRIDE { in OnMessageReceived()
[all …]
Dipc_perftests.cc81 class ChannelReflectorListener : public IPC::Listener {
94 void Init(IPC::Channel* channel) { in Init()
99 virtual bool OnMessageReceived(const IPC::Message& message) OVERRIDE { in OnMessageReceived()
125 IPC::Message* msg = new IPC::Message(0, 2, IPC::Message::PRIORITY_NORMAL); in OnMessageReceived()
134 IPC::Channel* channel_;
138 class PerformanceChannelListener : public IPC::Listener {
153 void Init(IPC::Channel* channel) { in Init()
167 virtual bool OnMessageReceived(const IPC::Message& message) OVERRIDE { in OnMessageReceived()
204 IPC::Message* msg = new IPC::Message(0, 2, IPC::Message::PRIORITY_NORMAL); in OnMessageReceived()
213 IPC::Channel* channel_;
[all …]
Dipc_test_base.h46 void CreateChannel(IPC::Listener* listener);
52 void CreateChannelFromChannelHandle(const IPC::ChannelHandle& channel_handle,
53 IPC::Listener* listener);
59 void CreateChannelProxy(IPC::Listener* listener,
75 IPC::Sender* sender() { in sender()
76 return channel_.get() ? static_cast<IPC::Sender*>(channel_.get()) : in sender()
77 static_cast<IPC::Sender*>(channel_proxy_.get()); in sender()
80 IPC::Channel* channel() { return channel_.get(); } in channel()
81 IPC::ChannelProxy* channel_proxy() { return channel_proxy_.get(); } in channel_proxy()
89 scoped_ptr<IPC::Channel> channel_;
[all …]
Dipc_message_unittest.cc35 IPC::Message msg(1, 2, IPC::Message::PRIORITY_NORMAL); in TEST()
36 IPC::WriteParam(&msg, input); in TEST()
40 EXPECT_TRUE(IPC::ReadParam(&msg, &iter, &output)); in TEST()
45 IPC::Message bad_msg(1, 2, IPC::Message::PRIORITY_NORMAL); in TEST()
48 EXPECT_FALSE(IPC::ReadParam(&bad_msg, &iter, &output)); in TEST()
70 IPC::Message msg(1, 2, IPC::Message::PRIORITY_NORMAL); in TEST()
71 IPC::WriteParam(&msg, input); in TEST()
75 EXPECT_TRUE(IPC::ReadParam(&msg, &iter, &output)); in TEST()
80 IPC::Message bad_msg(1, 2, IPC::Message::PRIORITY_NORMAL); in TEST()
83 EXPECT_FALSE(IPC::ReadParam(&bad_msg, &iter, &output)); in TEST()
[all …]
/external/chromium_org/content/common/
Dcommon_param_traits_unittest.cc30 IPC::Message msg(1, 2, IPC::Message::PRIORITY_NORMAL); in TEST()
31 IPC::ParamTraits<GURL>::Write(&msg, input); in TEST()
35 EXPECT_TRUE(IPC::ParamTraits<GURL>::Read(&msg, &iter, &output)); in TEST()
53 IPC::Message msg; in TEST()
57 EXPECT_FALSE(IPC::ParamTraits<GURL>::Read(&msg, &iter, &output)); in TEST()
61 IPC::Message msg(1, 2, IPC::Message::PRIORITY_NORMAL); in TEST()
65 EXPECT_FALSE(IPC::ParamTraits<GURL>::Read(&msg, &iter, &output)); in TEST()
73 IPC::Message msg(1, 2, IPC::Message::PRIORITY_NORMAL); in TEST()
74 IPC::ParamTraits<TestPair>::Write(&msg, input); in TEST()
78 EXPECT_TRUE(IPC::ParamTraits<TestPair>::Read(&msg, &iter, &output)); in TEST()
[all …]
Dmessage_router.h32 class MessageRouter : public IPC::Listener, public IPC::Sender {
38 virtual bool OnControlMessageReceived(const IPC::Message& msg);
41 virtual bool OnMessageReceived(const IPC::Message& msg) OVERRIDE;
46 virtual bool RouteMessage(const IPC::Message& msg);
49 virtual bool Send(IPC::Message* msg) OVERRIDE;
53 bool AddRoute(int32 routing_id, IPC::Listener* listener);
60 IDMap<IPC::Listener> routes_;
/external/chromium_org/ppapi/proxy/
Dresource_message_test_sink.h21 class ResourceMessageTestSink : public IPC::TestSink {
28 virtual bool Send(IPC::Message* msg) OVERRIDE;
32 void SetSyncReplyMessage(IPC::Message* reply_msg);
40 IPC::Message* nested_msg) const;
46 IPC::Message* nested_msg);
50 typedef std::pair<ResourceMessageCallParams, IPC::Message> ResourceCall;
55 typedef std::pair<ResourceMessageReplyParams, IPC::Message> ResourceReply;
60 scoped_ptr<IPC::Message> sync_reply_msg_;
79 class ResourceSyncCallHandler : public IPC::Listener {
84 const IPC::Message& reply_msg);
[all …]
Dresource_message_params.cc43 void ResourceMessageParams::Serialize(IPC::Message* msg) const { in Serialize()
48 bool ResourceMessageParams::Deserialize(const IPC::Message* msg, in Deserialize()
53 void ResourceMessageParams::WriteHeader(IPC::Message* msg) const { in WriteHeader()
54 IPC::ParamTraits<PP_Resource>::Write(msg, pp_resource_); in WriteHeader()
55 IPC::ParamTraits<int32_t>::Write(msg, sequence_); in WriteHeader()
58 void ResourceMessageParams::WriteHandles(IPC::Message* msg) const { in WriteHandles()
59 IPC::ParamTraits<std::vector<SerializedHandle> >::Write(msg, in WriteHandles()
63 bool ResourceMessageParams::ReadHeader(const IPC::Message* msg, in ReadHeader()
67 return IPC::ParamTraits<PP_Resource>::Read(msg, iter, &pp_resource_) && in ReadHeader()
68 IPC::ParamTraits<int32_t>::Read(msg, iter, &sequence_); in ReadHeader()
[all …]
Dplugin_resource.h49 const IPC::Message& msg) OVERRIDE;
60 void SendCreate(Destination dest, const IPC::Message& msg);
71 void Post(Destination dest, const IPC::Message& msg);
101 const IPC::Message& msg,
117 const IPC::Message& msg,
134 int32_t SyncCall(Destination dest, const IPC::Message& msg);
136 int32_t SyncCall(Destination dest, const IPC::Message& msg, A* a);
138 int32_t SyncCall(Destination dest, const IPC::Message& msg, A* a, B* b);
140 int32_t SyncCall(Destination dest, const IPC::Message& msg, A* a, B* b, C* c);
143 Destination dest, const IPC::Message& msg, A* a, B* b, C* c, D* d);
[all …]
Dresource_message_test_sink.cc18 std::vector<std::pair<Params, IPC::Message> >
21 std::vector<std::pair<Params, IPC::Message> > result; in GetAllResourceMessagesMatching()
23 const IPC::Message* msg = sink.GetMessageAt(i); in GetAllResourceMessagesMatching()
28 IPC::Message cur_msg = params.b; in GetAllResourceMessagesMatching()
45 bool ResourceMessageTestSink::Send(IPC::Message* msg) { in Send()
47 scoped_ptr<IPC::MessageReplyDeserializer> reply_deserializer; in Send()
50 static_cast<IPC::SyncMessage*>(msg)->GetReplyDeserializer()); in Send()
51 message_id = IPC::SyncMessage::GetMessageId(*msg); in Send()
53 bool result = IPC::TestSink::Send(msg); // Deletes |msg|. in Send()
56 DCHECK(IPC::SyncMessage::IsMessageReplyTo(*sync_reply_msg_.get(), in Send()
[all …]
Dproxy_channel.h21 namespace IPC {
29 : public IPC::Listener,
30 public IPC::Sender {
48 virtual IPC::PlatformFileForTransit ShareHandleWithRemote(
60 void InitWithTestSink(IPC::TestSink* test_sink);
68 IPC::PlatformFileForTransit ShareHandleWithRemote(
73 virtual bool Send(IPC::Message* msg) OVERRIDE;
79 IPC::SyncChannel* channel() const { in channel()
95 const IPC::ChannelHandle& channel_handle,
114 IPC::TestSink* test_sink_;
[all …]
Dppapi_message_utils.h69 bool UnpackMessage(const IPC::Message& msg, A* a) {
75 return IPC::ReadParam(&msg, &iter, a);
79 bool UnpackMessage(const IPC::Message& msg, A* a, B* b) {
85 return IPC::ReadParam(&msg, &iter, a) && IPC::ReadParam(&msg, &iter, b);
89 bool UnpackMessage(const IPC::Message& msg, A* a, B* b, C* c) {
95 return IPC::ReadParam(&msg, &iter, a) &&
96 IPC::ReadParam(&msg, &iter, b) &&
97 IPC::ReadParam(&msg, &iter, c);
101 bool UnpackMessage(const IPC::Message& msg, A* a, B* b, C* c, D* d) {
107 return IPC::ReadParam(&msg, &iter, a) &&
[all …]
Dplugin_message_filter.h28 class PPAPI_PROXY_EXPORT PluginMessageFilter : public IPC::MessageFilter,
29 public IPC::Sender {
44 virtual void OnFilterAdded(IPC::Sender* sender) OVERRIDE;
46 virtual bool OnMessageReceived(const IPC::Message& message) OVERRIDE;
49 virtual bool Send(IPC::Message* msg) OVERRIDE;
55 const IPC::Message& nested_msg);
60 const IPC::Message& nested_msg);
66 const IPC::Message& nested_msg);
77 IPC::Sender* sender_;
/external/chromium_org/ppapi/host/
Dppapi_host.h42 class PPAPI_HOST_EXPORT PpapiHost : public IPC::Sender, public IPC::Listener {
48 PpapiHost(IPC::Sender* sender, const PpapiPermissions& perms);
54 virtual bool Send(IPC::Message* msg) OVERRIDE;
57 virtual bool OnMessageReceived(const IPC::Message& msg) OVERRIDE;
61 const IPC::Message& msg);
64 void SendUnsolicitedReply(PP_Resource resource, const IPC::Message& msg);
69 const IPC::Message& msg,
76 const IPC::Message& nested_msg);
99 const IPC::Message& nested_msg,
104 const IPC::Message& nested_msg);
[all …]
Dresource_message_filter_unittest.cc52 const IPC::Message& last_handled_msg() const { return last_handled_msg_; } in last_handled_msg()
53 const IPC::Message& last_reply_msg() const { return last_reply_msg_; } in last_reply_msg()
63 const IPC::Message& msg, in OnResourceMessageReceived()
67 context->reply_msg = IPC::Message(0, reply_msg_type_, in OnResourceMessageReceived()
68 IPC::Message::PRIORITY_NORMAL); in OnResourceMessageReceived()
75 const IPC::Message& msg) OVERRIDE { in SendReply()
85 IPC::Message last_handled_msg_;
86 IPC::Message last_reply_msg_;
110 const IPC::Message& last_handled_msg() const { return last_handled_msg_; } in last_handled_msg()
114 const IPC::Message& msg) OVERRIDE { in OverrideTaskRunnerForMessage()
[all …]
/external/chromium_org/content/child/
Ddatabase_util.cc20 IPC::SyncMessageFilter* sync_message_filter) { in DatabaseOpenFile()
21 IPC::PlatformFileForTransit file_handle = in DatabaseOpenFile()
22 IPC::InvalidPlatformFileForTransit(); in DatabaseOpenFile()
24 scoped_refptr<IPC::SyncMessageFilter> filter(sync_message_filter); in DatabaseOpenFile()
28 return IPC::PlatformFileForTransitToPlatformFile(file_handle); in DatabaseOpenFile()
34 IPC::SyncMessageFilter* sync_message_filter) { in DatabaseDeleteFile()
36 scoped_refptr<IPC::SyncMessageFilter> filter(sync_message_filter); in DatabaseDeleteFile()
44 IPC::SyncMessageFilter* sync_message_filter) { in DatabaseGetFileAttributes()
46 scoped_refptr<IPC::SyncMessageFilter> filter(sync_message_filter); in DatabaseGetFileAttributes()
53 IPC::SyncMessageFilter* sync_message_filter) { in DatabaseGetFileSize()
[all …]
/external/chromium_org/components/nacl/browser/
Dnacl_process_host.h29 namespace IPC {
87 IPC::Message* reply_msg,
97 bool Send(IPC::Message* msg);
130 virtual bool OnMessageReceived(const IPC::Message& msg) OVERRIDE;
141 const IPC::ChannelHandle& ppapi_channel_handle,
142 const IPC::ChannelHandle& trusted_channel_handle,
143 const IPC::ChannelHandle& manifest_service_channel_handle);
167 IPC::Message* reply_msg);
169 IPC::Message* reply_msg,
175 IPC::Message* reply_msg);
[all …]
/external/chromium_org/content/renderer/pepper/
Dpepper_in_process_router.cc22 class PepperInProcessRouter::Channel : public IPC::Sender {
24 Channel(const base::Callback<bool(IPC::Message*)>& callback) in Channel()
29 virtual bool Send(IPC::Message* message) OVERRIDE { in Send()
34 base::Callback<bool(IPC::Message*)> callback_;
52 IPC::Sender* PepperInProcessRouter::GetPluginToRendererSender() { in GetPluginToRendererSender()
56 IPC::Sender* PepperInProcessRouter::GetRendererToPluginSender() { in GetRendererToPluginSender()
71 bool PepperInProcessRouter::OnPluginMsgReceived(const IPC::Message& msg) { in OnPluginMsgReceived()
74 IPC::Message nested_msg; in OnPluginMsgReceived()
103 bool PepperInProcessRouter::SendToHost(IPC::Message* msg) { in SendToHost()
104 scoped_ptr<IPC::Message> message(msg); in SendToHost()
[all …]
Dpepper_in_process_router.h13 namespace IPC {
60 IPC::Sender* GetPluginToRendererSender();
61 IPC::Sender* GetRendererToPluginSender();
69 static bool OnPluginMsgReceived(const IPC::Message& msg);
72 bool SendToHost(IPC::Message* msg);
73 bool SendToPlugin(IPC::Message* msg);
74 void DispatchHostMsg(IPC::Message* msg);
75 void DispatchPluginMsg(IPC::Message* msg);
76 bool SendToBrowser(IPC::Message* msg);
93 scoped_ptr<IPC::MessageReplyDeserializer> reply_deserializer_;
/external/chromium_org/content/renderer/input/
Dinput_event_filter.h23 namespace IPC {
39 public IPC::MessageFilter {
41 InputEventFilter(IPC::Listener* main_listener,
63 virtual void OnFilterAdded(IPC::Sender* sender) OVERRIDE;
66 virtual bool OnMessageReceived(const IPC::Message& message) OVERRIDE;
71 void ForwardToMainListener(const IPC::Message& message);
72 void ForwardToHandler(const IPC::Message& message);
73 void SendMessage(scoped_ptr<IPC::Message> message);
74 void SendMessageOnIOThread(scoped_ptr<IPC::Message> message);
77 IPC::Listener* main_listener_;
[all …]
/external/chromium_org/components/nacl/loader/
Dnacl_listener.cc123 void SetUpIPCAdapter(IPC::ChannelHandle* handle, in SetUpIPCAdapter()
175 IPC::PlatformFileForTransit ipc_fd = IPC::InvalidPlatformFileForTransit(); in ResolveFileToken()
183 if (ipc_fd == IPC::InvalidPlatformFileForTransit()) { in ResolveFileToken()
187 IPC::PlatformFileForTransitToPlatformFile(ipc_fd); in ResolveFileToken()
232 bool NaClListener::Send(IPC::Message* msg) { in Send()
247 channel_ = IPC::SyncChannel::Create( in Listen()
249 filter_ = new IPC::SyncMessageFilter(&shutdown_event_); in Listen()
251 channel_->Init(channel_name, IPC::Channel::MODE_CLIENT, true); in Listen()
256 bool NaClListener::OnMessageReceived(const IPC::Message& msg) { in OnMessageReceived()
288 IPC::ChannelHandle browser_handle; in OnStart()
[all …]
/external/chromium_org/chrome/service/
Dservice_ipc_server.h26 class ServiceIPCServer : public IPC::Listener, public IPC::Sender {
28 explicit ServiceIPCServer(const IPC::ChannelHandle& handle);
34 virtual bool Send(IPC::Message* msg) OVERRIDE;
36 IPC::SyncChannel* channel() { return channel_.get(); } in channel()
40 IPC::SyncMessageFilter* sync_message_filter() { in sync_message_filter()
51 virtual bool OnMessageReceived(const IPC::Message& msg) OVERRIDE;
72 IPC::ChannelHandle channel_handle_;
73 scoped_ptr<IPC::SyncChannel> channel_;
78 scoped_refptr<IPC::SyncMessageFilter> sync_message_filter_;
/external/chromium_org/remoting/host/
Ddesktop_process_unittest.cc41 class MockDaemonListener : public IPC::Listener {
46 virtual bool OnMessageReceived(const IPC::Message& message) OVERRIDE;
48 MOCK_METHOD1(OnDesktopAttached, void(IPC::PlatformFileForTransit));
56 class MockNetworkListener : public IPC::Listener {
61 virtual bool OnMessageReceived(const IPC::Message& message) OVERRIDE;
72 bool MockDaemonListener::OnMessageReceived(const IPC::Message& message) { in OnMessageReceived()
84 bool MockNetworkListener::OnMessageReceived(const IPC::Message& message) { in OnMessageReceived()
105 void ConnectNetworkChannel(IPC::PlatformFileForTransit desktop_process);
106 void OnDesktopAttached(IPC::PlatformFileForTransit desktop_process);
141 scoped_ptr<IPC::ChannelProxy> daemon_channel_;
[all …]
/external/chromium_org/content/browser/service_worker/
Dembedded_worker_test_helper.h43 class EmbeddedWorkerTestHelper : public IPC::Sender,
44 public IPC::Listener {
56 virtual bool Send(IPC::Message* message) OVERRIDE;
59 virtual bool OnMessageReceived(const IPC::Message& msg) OVERRIDE;
62 IPC::TestSink* ipc_sink() { return &sink_; } in ipc_sink()
64 IPC::TestSink* inner_ipc_sink() { return &inner_sink_; } in inner_ipc_sink()
84 const IPC::Message& message);
102 void SimulateSend(IPC::Message* message);
112 const IPC::Message& message);
120 IPC::TestSink sink_;
[all …]

12345678910>>...62