Searched defs:dispatcher (Results 101 - 125 of 179) sorted by relevance

12345678

/external/chromium_org/mojo/system/
H A Dremote_message_pipe_unittest.cc523 // We'll try to pass this dispatcher.
524 scoped_refptr<MessagePipeDispatcher> dispatcher(
527 dispatcher->Init(local_mp, 0);
539 test::DispatcherTryStartTransport(dispatcher.get()));
552 // |dispatcher| should have been closed. This is |DCHECK()|ed when the
553 // |dispatcher| is destroyed.
554 EXPECT_TRUE(dispatcher->HasOneRef());
555 dispatcher = nullptr;
588 dispatcher = static_cast<MessagePipeDispatcher*>(read_dispatchers[0].get());
593 dispatcher
695 scoped_refptr<SharedBufferDispatcher> dispatcher; local
[all...]
H A Dtransport_data.cc39 // handle table entry and serialized dispatcher data.
73 // The offset to the start of the serialized dispatcher data.
85 if (Dispatcher* dispatcher = (*dispatchers)[i].get()) {
89 dispatcher, channel, &max_size, &max_platform_handles);
118 // about clearing padding or unused space (e.g., if a dispatcher fails to
136 Dispatcher* dispatcher = (*dispatchers)[i].get(); local
137 if (!dispatcher) {
151 dispatcher,
156 handle_table[i].type = static_cast<int32_t>(dispatcher->GetType());
279 "Message contains invalid serialized dispatcher";
[all...]
/external/chromium_org/net/base/
H A Dprioritized_dispatcher_unittest.cc34 // to the dispatcher. Note that finishing order of jobs does not matter.
37 TestJob(PrioritizedDispatcher* dispatcher, argument
41 : dispatcher_(dispatcher),
559 // New dispatcher.
/external/chromium_org/net/quic/
H A Dquic_dispatcher.cc27 explicit DeleteSessionsAlarm(QuicDispatcher* dispatcher) argument
28 : dispatcher_(dispatcher) {
42 explicit QuicFramerVisitor(QuicDispatcher* dispatcher) argument
43 : dispatcher_(dispatcher),
165 QuicDispatcher* dispatcher)
166 : dispatcher_(dispatcher) {}
164 PacketWriterFactoryAdapter( QuicDispatcher* dispatcher) argument
/external/chromium_org/net/tools/quic/
H A Dquic_dispatcher.cc31 explicit DeleteSessionsAlarm(QuicDispatcher* dispatcher) argument
32 : dispatcher_(dispatcher) {
47 explicit QuicFramerVisitor(QuicDispatcher* dispatcher) argument
48 : dispatcher_(dispatcher),
170 QuicDispatcher* dispatcher)
171 : dispatcher_(dispatcher) {}
169 PacketWriterFactoryAdapter( QuicDispatcher* dispatcher) argument
H A Dquic_dispatcher_test.cc64 // A Connection class which unregisters the session from the dispatcher
71 QuicDispatcher* dispatcher)
73 dispatcher_(dispatcher) {}
83 QuicSession* CreateSession(QuicDispatcher* dispatcher, argument
88 new MockServerConnection(connection_id, dispatcher);
205 // dispatcher takes the ownership of time_wait_list_manager.
248 // dispatcher takes the ownership of time_wait_list_manager.
70 MockServerConnection(QuicConnectionId connection_id, QuicDispatcher* dispatcher) argument
/external/chromium_org/ppapi/nacl_irt/
H A Dppapi_dispatcher.cc191 proxy::PluginDispatcher* dispatcher = local
197 if (!dispatcher->InitPluginWithChannel(this, base::kNullProcessId,
199 delete dispatcher;
202 // From here, the dispatcher will manage its own lifetime according to the
213 // The first parameter should be a plugin dispatcher ID.
220 std::map<uint32, proxy::PluginDispatcher*>::iterator dispatcher = local
222 if (dispatcher != plugin_dispatchers_.end())
223 dispatcher->second->OnMessageReceived(msg);
/external/chromium_org/ppapi/proxy/
H A Dhost_dispatcher.cc113 HostDispatcher* dispatcher) {
116 (*g_instance_to_dispatcher)[instance] = dispatcher;
151 // Prevent the dispatcher from going away during sync calls. Scenarios
154 // destroys the plugin module and in turn the dispatcher.
174 // Prevent the dispatcher from going away during a message handler. This must
279 ScopedModuleReference::ScopedModuleReference(Dispatcher* dispatcher) argument
281 if (!dispatcher->IsPlugin()) {
282 dispatcher_ = static_cast<HostDispatcher*>(dispatcher);
112 SetForInstance(PP_Instance instance, HostDispatcher* dispatcher) argument
H A Dplugin_globals.cc118 PluginDispatcher* dispatcher = PluginDispatcher::GetForInstance(instance); local
119 if (dispatcher)
120 return dispatcher->GetInstanceAPI();
126 PluginDispatcher* dispatcher = PluginDispatcher::GetForInstance(instance); local
127 if (dispatcher)
128 return dispatcher->GetResourceCreationAPI();
159 // the same as "send to everybody" which is what the dispatcher implements
H A Dppb_audio_proxy.cc130 PPB_Audio_Proxy::PPB_Audio_Proxy(Dispatcher* dispatcher) argument
131 : InterfaceProxy(dispatcher),
144 PluginDispatcher* dispatcher = PluginDispatcher::GetForInstance(instance_id); local
145 if (!dispatcher)
156 dispatcher->Send(new PpapiHostMsg_PPBAudio_Create(
230 dispatcher()->local_get_interface()(PPB_CORE_INTERFACE));
267 dispatcher()->Send(new PpapiMsg_PPBAudio_NotifyAudioStreamCreated(
288 *foreign_socket_handle = dispatcher()->ShareHandleWithRemote(
301 *foreign_shared_memory_handle = dispatcher()->ShareHandleWithRemote(
H A Dppb_message_loop_proxy.cc212 PluginDispatcher* dispatcher = PluginDispatcher::GetForInstance(instance); local
213 if (!dispatcher)
271 PPB_MessageLoop_Proxy::PPB_MessageLoop_Proxy(Dispatcher* dispatcher) argument
272 : InterfaceProxy(dispatcher) {
H A Dppb_testing_proxy.cc69 PluginDispatcher* dispatcher = PluginDispatcher::GetForInstance(instance_id); local
70 if (!dispatcher)
74 dispatcher->Send(new PpapiHostMsg_PPBTesting_GetLiveObjectsForInstance(
85 PluginDispatcher* dispatcher = PluginDispatcher::GetForInstance(instance_id); local
86 if (!dispatcher)
93 dispatcher->Send(new PpapiHostMsg_PPBTesting_SimulateInputEvent(
122 PluginDispatcher* dispatcher = PluginDispatcher::GetForInstance(instance); local
123 if (!dispatcher)
125 dispatcher->Send(
150 PPB_Testing_Proxy::PPB_Testing_Proxy(Dispatcher* dispatcher) argument
[all...]
H A Dppb_var_deprecated_proxy.cc35 // exception is set, returns NULL. Otherwise, computes the dispatcher for the
47 // Get the dispatcher for the object.
48 PluginDispatcher* dispatcher = local
51 if (dispatcher)
52 return dispatcher;
55 // The object is invalid. This means we can't figure out which dispatcher
70 Dispatcher* dispatcher = CheckExceptionAndGetDispatcher(var, exception); local
71 if (!dispatcher)
74 ReceiveSerializedException se(dispatcher, exception);
77 dispatcher
89 Dispatcher* dispatcher = CheckExceptionAndGetDispatcher(var, exception); local
108 Dispatcher* dispatcher = CheckExceptionAndGetDispatcher(var, exception); local
128 Dispatcher* dispatcher = CheckExceptionAndGetDispatcher(var, exception); local
151 Dispatcher* dispatcher = CheckExceptionAndGetDispatcher(var, exception); local
169 Dispatcher* dispatcher = CheckExceptionAndGetDispatcher(var, exception); local
189 Dispatcher* dispatcher = CheckExceptionAndGetDispatcher(object, exception); local
213 Dispatcher* dispatcher = CheckExceptionAndGetDispatcher(object, exception); local
235 Dispatcher* dispatcher = CheckExceptionAndGetDispatcher(var, NULL); local
254 Dispatcher* dispatcher = PluginDispatcher::GetForInstance(instance); local
281 PPB_Var_Deprecated_Proxy( Dispatcher* dispatcher) argument
[all...]
H A Dppb_video_decoder_proxy.cc151 PPB_VideoDecoder_Proxy::PPB_VideoDecoder_Proxy(Dispatcher* dispatcher) argument
152 : InterfaceProxy(dispatcher),
160 if (!dispatcher()->permissions().HasPermission(PERMISSION_DEV))
189 PluginDispatcher* dispatcher = PluginDispatcher::GetForInstance(instance); local
192 if (!dispatcher)
195 if (!dispatcher->preferences().is_accelerated_video_decode_enabled)
206 dispatcher->Send(new PpapiHostMsg_PPBVideoDecoder_Create(
285 dispatcher()->Send(new PpapiMsg_PPBVideoDecoder_EndOfBitstreamACK(
291 dispatcher()->Send(new PpapiMsg_PPBVideoDecoder_FlushACK(
297 dispatcher()
[all...]
H A Dvideo_capture_resource.cc24 PluginDispatcher* dispatcher)
31 dispatcher->local_get_interface()(PPP_VIDEO_CAPTURE_DEV_INTERFACE));
21 VideoCaptureResource( Connection connection, PP_Instance instance, PluginDispatcher* dispatcher) argument
/external/chromium_org/sandbox/win/src/
H A Dsharedmem_ipc_server.cc26 Dispatcher* dispatcher)
32 call_dispatcher_(dispatcher) {
119 service_context->dispatcher = call_dispatcher_;
244 Dispatcher* dispatcher = service_context->dispatcher; local
245 DCHECK(dispatcher);
250 handler = dispatcher->OnMessageReady(&ipc_params, &callback_generic);
254 // Ask the IPC dispatcher if she can service this IPC.
22 SharedMemIPCServer(HANDLE target_process, DWORD target_process_id, HANDLE target_job, ThreadProvider* thread_provider, Dispatcher* dispatcher) argument
/external/chromium_org/third_party/webrtc/base/
H A Dmacsocketserver.cc58 Dispatcher* dispatcher = signal_dispatcher(); local
64 if (!dispatcher && (dispatcher = signal_dispatcher())) {
70 dispatcher->GetDescriptor(),
/external/chromium_org/ui/base/test/
H A Dui_controls_internal_win.cc56 // If a hook is installed, this is the dispatcher.
82 // Installs dispatcher as the current hook.
83 void InstallHook(InputDispatcher* dispatcher, bool key_hook) { argument
85 current_dispatcher_ = dispatcher;
100 void UninstallHook(InputDispatcher* dispatcher) { argument
101 if (current_dispatcher_ == dispatcher) {
184 scoped_refptr<InputDispatcher> dispatcher(
197 if (dispatcher.get())
198 dispatcher->AddRef();
252 if (dispatcher
[all...]
/external/chromium_org/ui/base/x/
H A Dselection_requestor.cc65 PlatformEventDispatcher* dispatcher)
69 dispatcher_(dispatcher),
63 SelectionRequestor(XDisplay* x_display, XID x_window, PlatformEventDispatcher* dispatcher) argument
/external/chromium_org/ui/views/controls/menu/
H A Dmenu_controller_unittest.cc77 base::MessagePumpDispatcher* dispatcher() { function in class:views::__anon17044::TestDispatcherClient
83 base::MessagePumpDispatcher* dispatcher,
91 dispatcher);
96 base::MessagePumpDispatcher* dispatcher) {
98 dispatcher);
202 dispatcher_client_.dispatcher()->Dispatch(msg);
242 // event dispatcher.
95 RunNestedDispatcher(scoped_ptr<base::RunLoop> run_loop, base::MessagePumpDispatcher* dispatcher) argument
/external/mockwebserver/src/main/java/com/google/mockwebserver/
H A DMockWebServer.java93 private Dispatcher dispatcher = new QueueDispatcher(); field in class:MockWebServer
187 * @throws ClassCastException if the default dispatcher has been replaced
191 ((QueueDispatcher) dispatcher).enqueueResponse(response.clone());
269 SocketPolicy socketPolicy = dispatcher.peek().getSocketPolicy();
307 SocketPolicy socketPolicy = dispatcher.peek().getSocketPolicy();
348 SocketPolicy socketPolicy = dispatcher.peek().getSocketPolicy();
368 MockResponse response = dispatcher.dispatch(request);
386 // request. The retry handler may call dispatcher.dispatch(request) before the
388 // Setting workerThreads = 1 ensures that the dispatcher is called for requests in
424 dispatcher
588 setDispatcher(Dispatcher dispatcher) argument
[all...]
/external/chromium_org/base/message_loop/
H A Dmessage_pump_win.cc39 Delegate* delegate, MessagePumpDispatcher* dispatcher) {
42 s.dispatcher = dispatcher;
357 if (state_->dispatcher)
358 action = state_->dispatcher->Dispatch(msg);
38 RunWithDispatcher( Delegate* delegate, MessagePumpDispatcher* dispatcher) argument
/external/chromium_org/content/browser/renderer_host/
H A Dwebsocket_host.cc88 WebSocketEventHandler(WebSocketDispatcherHost* dispatcher,
149 WebSocketDispatcherHost* dispatcher,
152 : dispatcher_(dispatcher),
324 WebSocketDispatcherHost* dispatcher,
326 : dispatcher_(dispatcher),
148 WebSocketEventHandler( WebSocketDispatcherHost* dispatcher, int routing_id, int render_frame_id) argument
323 WebSocketHost(int routing_id, WebSocketDispatcherHost* dispatcher, net::URLRequestContext* url_request_context) argument
/external/chromium_org/content/child/
H A Dweb_url_loader_impl_unittest.cc125 TestWebURLLoaderClient(ResourceDispatcher* dispatcher) argument
126 : loader_(new WebURLLoaderImpl(dispatcher)),
/external/chromium_org/content/ppapi_plugin/
H A Dppapi_thread.cc462 ppapi::proxy::ProxyChannel* dispatcher = NULL; local
472 dispatcher = broker_dispatcher;
482 dispatcher = plugin_dispatcher;
486 delete dispatcher;
495 handle->socket = base::FileDescriptor(dispatcher->TakeRendererFD(), true);
500 // From here, the dispatcher will manage its own lifetime according to the

Completed in 9756 milliseconds

12345678