/external/chromium_org/mojo/system/ |
H A D | remote_message_pipe_unittest.cc | 523 // 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 D | transport_data.cc | 39 // 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 D | prioritized_dispatcher_unittest.cc | 34 // 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 D | quic_dispatcher.cc | 27 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 D | quic_dispatcher.cc | 31 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 D | quic_dispatcher_test.cc | 64 // 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 D | ppapi_dispatcher.cc | 191 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 D | host_dispatcher.cc | 113 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 D | plugin_globals.cc | 118 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 D | ppb_audio_proxy.cc | 130 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 D | ppb_message_loop_proxy.cc | 212 PluginDispatcher* dispatcher = PluginDispatcher::GetForInstance(instance); local 213 if (!dispatcher) 271 PPB_MessageLoop_Proxy::PPB_MessageLoop_Proxy(Dispatcher* dispatcher) argument 272 : InterfaceProxy(dispatcher) {
|
H A D | ppb_testing_proxy.cc | 69 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 D | ppb_var_deprecated_proxy.cc | 35 // 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 D | ppb_video_decoder_proxy.cc | 151 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 D | video_capture_resource.cc | 24 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 D | sharedmem_ipc_server.cc | 26 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 D | macsocketserver.cc | 58 Dispatcher* dispatcher = signal_dispatcher(); local 64 if (!dispatcher && (dispatcher = signal_dispatcher())) { 70 dispatcher->GetDescriptor(),
|
/external/chromium_org/ui/base/test/ |
H A D | ui_controls_internal_win.cc | 56 // 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 D | selection_requestor.cc | 65 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 D | menu_controller_unittest.cc | 77 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 D | MockWebServer.java | 93 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 D | message_pump_win.cc | 39 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 D | websocket_host.cc | 88 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 D | web_url_loader_impl_unittest.cc | 125 TestWebURLLoaderClient(ResourceDispatcher* dispatcher) argument 126 : loader_(new WebURLLoaderImpl(dispatcher)),
|
/external/chromium_org/content/ppapi_plugin/ |
H A D | ppapi_thread.cc | 462 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
|