dispatcher_ 392 base/message_loop/message_loop.cc if (run_loop_->dispatcher_ && type() == TYPE_UI) { dispatcher_ 394 base/message_loop/message_loop.cc RunWithDispatcher(this, run_loop_->dispatcher_); dispatcher_ 36 base/message_loop/message_pump_ozone.cc DCHECK(dispatcher_.size() == 0); dispatcher_ 37 base/message_loop/message_pump_ozone.cc dispatcher_.insert(dispatcher_.begin(),dispatcher); dispatcher_ 42 base/message_loop/message_pump_ozone.cc DCHECK(dispatcher_.size() == 1); dispatcher_ 43 base/message_loop/message_pump_ozone.cc dispatcher_.pop_back(); dispatcher_ 47 base/message_loop/message_pump_ozone.cc if (dispatcher_.size() > 0) dispatcher_ 48 base/message_loop/message_pump_ozone.cc return dispatcher_[0]->Dispatch(dev); dispatcher_ 55 base/message_loop/message_pump_ozone.cc dispatcher_.push_back(dispatcher); dispatcher_ 57 base/message_loop/message_pump_ozone.cc dispatcher_.pop_back(); dispatcher_ 43 base/message_loop/message_pump_ozone.h std::vector<MessagePumpDispatcher*> dispatcher_; dispatcher_ 25 base/run_loop.cc dispatcher_ = NULL; dispatcher_ 33 base/run_loop.cc dispatcher_(dispatcher), dispatcher_ 97 base/run_loop.h MessagePumpDispatcher* dispatcher_; dispatcher_ 67 chrome/browser/renderer_host/pepper/pepper_extensions_common_message_filter.cc extensions::ExtensionFunctionDispatcher* dispatcher() { return &dispatcher_; } dispatcher_ 73 chrome/browser/renderer_host/pepper/pepper_extensions_common_message_filter.cc extensions::ExtensionFunctionDispatcher dispatcher_; dispatcher_ 81 chrome/renderer/extensions/app_bindings.cc dispatcher_->IsExtensionActive(extension->id()); dispatcher_ 130 chrome/renderer/extensions/app_bindings.cc dispatcher_->extensions()->GetExtensionOrAppByURL( dispatcher_ 173 chrome/renderer/extensions/app_bindings.cc const ExtensionSet* extensions = dispatcher_->extensions(); dispatcher_ 190 chrome/renderer/extensions/app_bindings.cc if (dispatcher_->IsExtensionActive(parent_app->id())) { dispatcher_ 37 chrome/renderer/extensions/app_window_custom_bindings.cc DCHECK(dispatcher_); dispatcher_ 43 chrome/renderer/extensions/app_window_custom_bindings.cc dispatcher_->v8_context_set().GetByV8Context( dispatcher_ 54 chrome/renderer/extensions/app_window_custom_bindings.cc Dispatcher* dispatcher_; dispatcher_ 41 chrome/renderer/extensions/chrome_v8_extension.h Dispatcher* dispatcher() { return dispatcher_; } dispatcher_ 48 chrome/renderer/extensions/chrome_v8_extension.h Dispatcher* dispatcher_; dispatcher_ 254 chrome/renderer/extensions/dispatcher.cc ChromeV8Context* context = dispatcher_->v8_context_set().GetByV8Context( dispatcher_ 260 chrome/renderer/extensions/dispatcher.cc Dispatcher* dispatcher_; dispatcher_ 101 chrome/renderer/extensions/event_bindings.cc if (!dispatcher_->CheckContextAccessToExtensionAPI(event_name, context())) dispatcher_ 162 chrome/renderer/extensions/event_bindings.cc if (!dispatcher_->CheckContextAccessToExtensionAPI(event_name, context())) dispatcher_ 144 chrome/renderer/extensions/extension_helper.cc dispatcher_(dispatcher), dispatcher_ 182 chrome/renderer/extensions/extension_helper.cc dispatcher_->user_script_slave()->InjectScripts( dispatcher_ 197 chrome/renderer/extensions/extension_helper.cc dispatcher_->user_script_slave()->InjectScripts( dispatcher_ 203 chrome/renderer/extensions/extension_helper.cc dispatcher_->DidCreateDocumentElement(frame); dispatcher_ 240 chrome/renderer/extensions/extension_helper.cc dispatcher_->DidMatchCSS( dispatcher_ 250 chrome/renderer/extensions/extension_helper.cc g_schedulers.Get()[frame] = new UserScriptScheduler(frame, dispatcher_); dispatcher_ 257 chrome/renderer/extensions/extension_helper.cc dispatcher_->OnExtensionResponse(request_id, dispatcher_ 268 chrome/renderer/extensions/extension_helper.cc dispatcher_->InvokeModuleSystemMethod( dispatcher_ 280 chrome/renderer/extensions/extension_helper.cc dispatcher_->v8_context_set().GetAll(), dispatcher_ 288 chrome/renderer/extensions/extension_helper.cc MessagingBindings::DeliverMessage(dispatcher_->v8_context_set().GetAll(), dispatcher_ 298 chrome/renderer/extensions/extension_helper.cc dispatcher_->v8_context_set().GetAll(), dispatcher_ 372 chrome/renderer/extensions/extension_helper.cc dispatcher_->v8_context_set().GetByV8Context(script_context); dispatcher_ 57 chrome/renderer/extensions/extension_helper.h Dispatcher* dispatcher() const { return dispatcher_; } dispatcher_ 103 chrome/renderer/extensions/extension_helper.h Dispatcher* dispatcher_; dispatcher_ 31 chrome/renderer/extensions/page_actions_custom_bindings.cc dispatcher_->extensions()->GetByID(extension_id); dispatcher_ 20 chrome/renderer/extensions/renderer_permissions_policy_delegate.cc Dispatcher* dispatcher) : dispatcher_(dispatcher) { dispatcher_ 49 chrome/renderer/extensions/renderer_permissions_policy_delegate.cc if (dispatcher_->IsExtensionActive(extension_misc::kWebStoreAppId)) { dispatcher_ 30 chrome/renderer/extensions/renderer_permissions_policy_delegate.h Dispatcher* dispatcher_; dispatcher_ 43 chrome/renderer/extensions/request_sender.cc : dispatcher_(dispatcher), dispatcher_ 86 chrome/renderer/extensions/request_sender.cc const std::set<std::string>& function_names = dispatcher_->function_names(); dispatcher_ 94 chrome/renderer/extensions/request_sender.cc if (!dispatcher_->CheckContextAccessToExtensionAPI(name, context)) dispatcher_ 96 chrome/renderer/extensions/request_sender.h Dispatcher* dispatcher_; dispatcher_ 124 chrome/renderer/extensions/user_script_scheduler.cc dispatcher_->user_script_slave()->InjectScripts( dispatcher_ 143 chrome/renderer/extensions/user_script_scheduler.cc const Extension* extension = dispatcher_->extensions()->GetByID( dispatcher_ 223 chrome/renderer/extensions/user_script_scheduler.cc dispatcher_->user_script_slave()->GetIsolatedWorldIdForExtension( dispatcher_ 90 chrome/renderer/extensions/user_script_scheduler.h Dispatcher* dispatcher_; dispatcher_ 42 components/domain_reliability/context.cc dispatcher_(dispatcher), dispatcher_ 168 components/domain_reliability/context.cc dispatcher_->ScheduleTask( dispatcher_ 119 components/domain_reliability/context.h DomainReliabilityDispatcher* dispatcher_; dispatcher_ 42 components/domain_reliability/context_unittest.cc : dispatcher_(&time_), dispatcher_ 48 components/domain_reliability/context_unittest.cc &dispatcher_, dispatcher_ 89 components/domain_reliability/context_unittest.cc DomainReliabilityDispatcher dispatcher_; dispatcher_ 18 components/domain_reliability/dispatcher_unittest.cc DomainReliabilityDispatcherTest() : dispatcher_(&time_) {} dispatcher_ 22 components/domain_reliability/dispatcher_unittest.cc DomainReliabilityDispatcher dispatcher_; dispatcher_ 32 components/domain_reliability/dispatcher_unittest.cc dispatcher_.ScheduleTask(callback.callback(), 2 * delay, 3 * delay); dispatcher_ 34 components/domain_reliability/dispatcher_unittest.cc dispatcher_.RunEligibleTasks(); dispatcher_ 42 components/domain_reliability/dispatcher_unittest.cc dispatcher_.ScheduleTask(callback.callback(), 2 * delay, 3 * delay); dispatcher_ 45 components/domain_reliability/dispatcher_unittest.cc dispatcher_.RunEligibleTasks(); dispatcher_ 54 components/domain_reliability/dispatcher_unittest.cc dispatcher_.ScheduleTask(callback.callback(), 2 * delay, 3 * delay); dispatcher_ 62 components/domain_reliability/monitor.cc dispatcher_(time_.get()), dispatcher_ 79 components/domain_reliability/monitor.cc dispatcher_(time_.get()), dispatcher_ 114 components/domain_reliability/monitor.cc &dispatcher_, dispatcher_ 77 components/domain_reliability/monitor.h DomainReliabilityDispatcher dispatcher_; dispatcher_ 107 content/browser/renderer_host/websocket_host.cc WebSocketDispatcherHost* const dispatcher_; dispatcher_ 116 content/browser/renderer_host/websocket_host.cc : dispatcher_(dispatcher), routing_id_(routing_id) {} dispatcher_ 131 content/browser/renderer_host/websocket_host.cc return StateCast(dispatcher_->SendAddChannelResponse( dispatcher_ 143 content/browser/renderer_host/websocket_host.cc return StateCast(dispatcher_->SendFrame( dispatcher_ 151 content/browser/renderer_host/websocket_host.cc return StateCast(dispatcher_->NotifyClosingHandshake(routing_id_)); dispatcher_ 158 content/browser/renderer_host/websocket_host.cc return StateCast(dispatcher_->SendFlowControl(routing_id_, quota)); dispatcher_ 169 content/browser/renderer_host/websocket_host.cc dispatcher_->DoDropChannel(routing_id_, was_clean, code, reason)); dispatcher_ 177 content/browser/renderer_host/websocket_host.cc return StateCast(dispatcher_->NotifyFailure(routing_id_, message)); dispatcher_ 182 content/browser/renderer_host/websocket_host.cc bool should_send = dispatcher_->CanReadRawCookies(); dispatcher_ 200 content/browser/renderer_host/websocket_host.cc return StateCast(dispatcher_->NotifyStartOpeningHandshake(routing_id_, dispatcher_ 206 content/browser/renderer_host/websocket_host.cc bool should_send = dispatcher_->CanReadRawCookies(); dispatcher_ 226 content/browser/renderer_host/websocket_host.cc return StateCast(dispatcher_->NotifyFinishOpeningHandshake(routing_id_, dispatcher_ 51 content/browser/screen_orientation/screen_orientation_dispatcher_host_unittest.cc dispatcher_ = new ScreenOrientationDispatcherHost(); dispatcher_ 52 content/browser/screen_orientation/screen_orientation_dispatcher_host_unittest.cc dispatcher_->SetProviderForTests(provider_); dispatcher_ 57 content/browser/screen_orientation/screen_orientation_dispatcher_host_unittest.cc scoped_refptr<ScreenOrientationDispatcherHost> dispatcher_; dispatcher_ 62 content/browser/screen_orientation/screen_orientation_dispatcher_host_unittest.cc dispatcher_->SetProviderForTests(NULL); dispatcher_ 65 content/browser/screen_orientation/screen_orientation_dispatcher_host_unittest.cc bool message_was_handled = dispatcher_->OnMessageReceived( dispatcher_ 108 content/browser/screen_orientation/screen_orientation_dispatcher_host_unittest.cc message_was_handled = dispatcher_->OnMessageReceived( dispatcher_ 121 content/browser/screen_orientation/screen_orientation_dispatcher_host_unittest.cc bool message_was_handled = dispatcher_->OnMessageReceived( dispatcher_ 119 content/child/indexed_db/webidbcursor_impl_unittest.cc dispatcher_ = dispatcher_ 126 content/child/indexed_db/webidbcursor_impl_unittest.cc scoped_ptr<MockDispatcher> dispatcher_; dispatcher_ 144 content/child/indexed_db/webidbcursor_impl_unittest.cc EXPECT_EQ(dispatcher_->continue_calls(), 0); dispatcher_ 147 content/child/indexed_db/webidbcursor_impl_unittest.cc EXPECT_EQ(++continue_calls, dispatcher_->continue_calls()); dispatcher_ 148 content/child/indexed_db/webidbcursor_impl_unittest.cc EXPECT_EQ(0, dispatcher_->prefetch_calls()); dispatcher_ 162 content/child/indexed_db/webidbcursor_impl_unittest.cc EXPECT_EQ(continue_calls, dispatcher_->continue_calls()); dispatcher_ 163 content/child/indexed_db/webidbcursor_impl_unittest.cc EXPECT_EQ(repetitions + 1, dispatcher_->prefetch_calls()); dispatcher_ 166 content/child/indexed_db/webidbcursor_impl_unittest.cc int prefetch_count = dispatcher_->last_prefetch_count(); dispatcher_ 187 content/child/indexed_db/webidbcursor_impl_unittest.cc EXPECT_EQ(continue_calls, dispatcher_->continue_calls()); dispatcher_ 188 content/child/indexed_db/webidbcursor_impl_unittest.cc EXPECT_EQ(repetitions + 1, dispatcher_->prefetch_calls()); dispatcher_ 196 content/child/indexed_db/webidbcursor_impl_unittest.cc EXPECT_EQ(dispatcher_->destroyed_cursor_id(), dispatcher_ 208 content/child/indexed_db/webidbcursor_impl_unittest.cc EXPECT_EQ(0, dispatcher_->continue_calls()); dispatcher_ 212 content/child/indexed_db/webidbcursor_impl_unittest.cc EXPECT_EQ(0, dispatcher_->prefetch_calls()); dispatcher_ 217 content/child/indexed_db/webidbcursor_impl_unittest.cc EXPECT_EQ(1, dispatcher_->prefetch_calls()); dispatcher_ 219 content/child/indexed_db/webidbcursor_impl_unittest.cc dispatcher_->continue_calls()); dispatcher_ 220 content/child/indexed_db/webidbcursor_impl_unittest.cc EXPECT_EQ(0, dispatcher_->advance_calls()); dispatcher_ 222 content/child/indexed_db/webidbcursor_impl_unittest.cc const int prefetch_count = dispatcher_->last_prefetch_count(); dispatcher_ 258 content/child/indexed_db/webidbcursor_impl_unittest.cc EXPECT_EQ(0, dispatcher_->advance_calls()); dispatcher_ 263 content/child/indexed_db/webidbcursor_impl_unittest.cc EXPECT_EQ(1, dispatcher_->advance_calls()); dispatcher_ 264 content/child/indexed_db/webidbcursor_impl_unittest.cc EXPECT_EQ(1, dispatcher_->prefetch_calls()); dispatcher_ 266 content/child/indexed_db/webidbcursor_impl_unittest.cc dispatcher_->continue_calls()); dispatcher_ 277 content/child/indexed_db/webidbcursor_impl_unittest.cc EXPECT_EQ(dispatcher_->continue_calls(), 0); dispatcher_ 280 content/child/indexed_db/webidbcursor_impl_unittest.cc EXPECT_EQ(++continue_calls, dispatcher_->continue_calls()); dispatcher_ 281 content/child/indexed_db/webidbcursor_impl_unittest.cc EXPECT_EQ(0, dispatcher_->prefetch_calls()); dispatcher_ 286 content/child/indexed_db/webidbcursor_impl_unittest.cc EXPECT_EQ(continue_calls, dispatcher_->continue_calls()); dispatcher_ 287 content/child/indexed_db/webidbcursor_impl_unittest.cc EXPECT_EQ(1, dispatcher_->prefetch_calls()); dispatcher_ 288 content/child/indexed_db/webidbcursor_impl_unittest.cc EXPECT_EQ(0, dispatcher_->reset_calls()); dispatcher_ 294 content/child/indexed_db/webidbcursor_impl_unittest.cc EXPECT_EQ(0, dispatcher_->reset_calls()); dispatcher_ 297 content/child/indexed_db/webidbcursor_impl_unittest.cc int prefetch_count = dispatcher_->last_prefetch_count(); dispatcher_ 304 content/child/indexed_db/webidbcursor_impl_unittest.cc EXPECT_EQ(0, dispatcher_->reset_calls()); dispatcher_ 311 content/child/indexed_db/webidbcursor_impl_unittest.cc EXPECT_EQ(1, dispatcher_->reset_calls()); dispatcher_ 312 content/child/indexed_db/webidbcursor_impl_unittest.cc EXPECT_EQ(1, dispatcher_->last_used_count()); dispatcher_ 91 content/child/resource_dispatcher.cc ResourceDispatcher* dispatcher_; dispatcher_ 113 content/child/resource_dispatcher.cc dispatcher_(dispatcher), dispatcher_ 117 content/child/resource_dispatcher.cc DCHECK(dispatcher_) << "no resource dispatcher"; dispatcher_ 163 content/child/resource_dispatcher.cc dispatcher_->RemovePendingRequest(request_id_); dispatcher_ 166 content/child/resource_dispatcher.cc dispatcher_->message_sender()->Send( dispatcher_ 188 content/child/resource_dispatcher.cc request_id_ = dispatcher_->AddPendingRequest(peer_, dispatcher_ 194 content/child/resource_dispatcher.cc return dispatcher_->message_sender()->Send( dispatcher_ 205 content/child/resource_dispatcher.cc dispatcher_->CancelPendingRequest(request_id_); dispatcher_ 218 content/child/resource_dispatcher.cc dispatcher_->SetDefersLoading(request_id_, value); dispatcher_ 228 content/child/resource_dispatcher.cc dispatcher_->DidChangePriority(routing_id_, request_id_, new_priority); dispatcher_ 245 content/child/resource_dispatcher.cc if (!dispatcher_->message_sender()->Send(msg)) { dispatcher_ 130 content/child/resource_dispatcher_unittest.cc dispatcher_->OnReceivedResponse(request_id, response); dispatcher_ 140 content/child/resource_dispatcher_unittest.cc dispatcher_->OnSetDataBuffer(request_id, dup_handle, dispatcher_ 142 content/child/resource_dispatcher_unittest.cc dispatcher_->OnReceivedData(request_id, 0, test_page_contents_len, dispatcher_ 161 content/child/resource_dispatcher_unittest.cc dispatcher_.reset(new ResourceDispatcher(this)); dispatcher_ 164 content/child/resource_dispatcher_unittest.cc dispatcher_.reset(); dispatcher_ 182 content/child/resource_dispatcher_unittest.cc return dispatcher_->CreateBridge(request_info); dispatcher_ 186 content/child/resource_dispatcher_unittest.cc static scoped_ptr<ResourceDispatcher> dispatcher_; dispatcher_ 190 content/child/resource_dispatcher_unittest.cc scoped_ptr<ResourceDispatcher> ResourceDispatcherTest::dispatcher_; dispatcher_ 251 content/child/resource_dispatcher_unittest.cc dispatcher_->OnMessageReceived( dispatcher_ 260 content/child/resource_dispatcher_unittest.cc dispatcher_->OnMessageReceived( dispatcher_ 262 content/child/resource_dispatcher_unittest.cc dispatcher_->OnMessageReceived(ResourceMsg_DataReceived(0, 0, 100, 100)); dispatcher_ 318 content/child/resource_dispatcher_unittest.cc dispatcher_->SetDefersLoading(0, defer); dispatcher_ 354 content/child/resource_dispatcher_unittest.cc dispatcher_->OnMessageReceived( dispatcher_ 117 content/renderer/media/media_stream_dispatcher_unittest.cc : dispatcher_(new MediaStreamDispatcherUnderTest()), dispatcher_ 127 content/renderer/media/media_stream_dispatcher_unittest.cc int next_ipc_id = dispatcher_->GetNextIpcIdForTest(); dispatcher_ 128 content/renderer/media/media_stream_dispatcher_unittest.cc dispatcher_->GenerateStream(request_id, handler_.get()->AsWeakPtr(), dispatcher_ 159 content/renderer/media/media_stream_dispatcher_unittest.cc dispatcher_->OnMessageReceived(MediaStreamMsg_StreamGenerated( dispatcher_ 167 content/renderer/media/media_stream_dispatcher_unittest.cc EXPECT_EQ(dispatcher_->audio_session_id(label, 0), kAudioSessionId); dispatcher_ 170 content/renderer/media/media_stream_dispatcher_unittest.cc EXPECT_EQ(dispatcher_->video_session_id(label, 0), kVideoSessionId); dispatcher_ 177 content/renderer/media/media_stream_dispatcher_unittest.cc scoped_ptr<MediaStreamDispatcherUnderTest> dispatcher_; dispatcher_ 202 content/renderer/media/media_stream_dispatcher_unittest.cc dispatcher_->StopStreamDevice(handler_->audio_device_); dispatcher_ 203 content/renderer/media/media_stream_dispatcher_unittest.cc EXPECT_EQ(dispatcher_->audio_session_id(label1, 0), dispatcher_ 205 content/renderer/media/media_stream_dispatcher_unittest.cc EXPECT_EQ(dispatcher_->audio_session_id(label2, 0), dispatcher_ 210 content/renderer/media/media_stream_dispatcher_unittest.cc dispatcher_->StopStreamDevice(handler_->video_device_); dispatcher_ 211 content/renderer/media/media_stream_dispatcher_unittest.cc EXPECT_EQ(dispatcher_->video_session_id(label1, 0), dispatcher_ 213 content/renderer/media/media_stream_dispatcher_unittest.cc EXPECT_EQ(dispatcher_->video_session_id(label2, 0), dispatcher_ 402 content/renderer/media/media_stream_dispatcher_unittest.cc dispatcher_->OnMessageReceived( dispatcher_ 407 content/renderer/media/media_stream_dispatcher_unittest.cc EXPECT_EQ(dispatcher_->video_session_id(label, 0), dispatcher_ 18 content/renderer/p2p/host_address_request.cc : dispatcher_(dispatcher), dispatcher_ 59 content/renderer/p2p/host_address_request.cc request_id_ = dispatcher_->RegisterHostAddressRequest(this); dispatcher_ 61 content/renderer/p2p/host_address_request.cc dispatcher_->SendP2PMessage( dispatcher_ 68 content/renderer/p2p/host_address_request.cc dispatcher_->UnregisterHostAddressRequest(request_id_); dispatcher_ 77 content/renderer/p2p/host_address_request.cc dispatcher_->UnregisterHostAddressRequest(request_id_); dispatcher_ 58 content/renderer/p2p/host_address_request.h P2PSocketDispatcher* dispatcher_; dispatcher_ 29 content/renderer/p2p/socket_client_impl.cc : dispatcher_(dispatcher), dispatcher_ 66 content/renderer/p2p/socket_client_impl.cc socket_id_ = dispatcher_->RegisterClient(this); dispatcher_ 67 content/renderer/p2p/socket_client_impl.cc dispatcher_->SendP2PMessage(new P2PHostMsg_CreateSocket( dispatcher_ 87 content/renderer/p2p/socket_client_impl.cc dispatcher_->SendP2PMessage(new P2PHostMsg_Send(socket_id_, address, data, dispatcher_ 109 content/renderer/p2p/socket_client_impl.cc dispatcher_->SendP2PMessage(new P2PHostMsg_SetOption(socket_id_, dispatcher_ 125 content/renderer/p2p/socket_client_impl.cc if (dispatcher_) { dispatcher_ 128 content/renderer/p2p/socket_client_impl.cc dispatcher_->SendP2PMessage(new P2PHostMsg_DestroySocket(socket_id_)); dispatcher_ 130 content/renderer/p2p/socket_client_impl.cc dispatcher_->UnregisterClient(socket_id_); dispatcher_ 168 content/renderer/p2p/socket_client_impl.cc new P2PSocketClientImpl(dispatcher_); dispatcher_ 169 content/renderer/p2p/socket_client_impl.cc new_client->socket_id_ = dispatcher_->RegisterClient(new_client.get()); dispatcher_ 173 content/renderer/p2p/socket_client_impl.cc dispatcher_->SendP2PMessage(new P2PHostMsg_AcceptIncomingTcpConnection( dispatcher_ 245 content/renderer/p2p/socket_client_impl.cc dispatcher_ = NULL; dispatcher_ 107 content/renderer/p2p/socket_client_impl.h P2PSocketDispatcher* dispatcher_; dispatcher_ 48 content/renderer/pepper/host_dispatcher_wrapper.cc dispatcher_.reset(new ppapi::proxy::HostDispatcher( dispatcher_ 51 content/renderer/pepper/host_dispatcher_wrapper.cc if (!dispatcher_->InitHostWithChannel(dispatcher_delegate_.get(), dispatcher_ 56 content/renderer/pepper/host_dispatcher_wrapper.cc dispatcher_.reset(); dispatcher_ 60 content/renderer/pepper/host_dispatcher_wrapper.cc dispatcher_->channel()->SetRestrictDispatchChannelGroup( dispatcher_ 66 content/renderer/pepper/host_dispatcher_wrapper.cc return dispatcher_->GetProxiedInterface(name); dispatcher_ 70 content/renderer/pepper/host_dispatcher_wrapper.cc ppapi::proxy::HostDispatcher::SetForInstance(instance, dispatcher_.get()); dispatcher_ 55 content/renderer/pepper/host_dispatcher_wrapper.h ppapi::proxy::HostDispatcher* dispatcher() { return dispatcher_.get(); } dispatcher_ 70 content/renderer/pepper/host_dispatcher_wrapper.h scoped_ptr<ppapi::proxy::HostDispatcher> dispatcher_; dispatcher_ 69 content/renderer/pepper/pepper_broker.cc dispatcher_.reset( dispatcher_ 72 content/renderer/pepper/pepper_broker.cc if (!dispatcher_->InitBrokerWithChannel(dispatcher_delegate_.get(), dispatcher_ 76 content/renderer/pepper/pepper_broker.cc dispatcher_.reset(); dispatcher_ 80 content/renderer/pepper/pepper_broker.cc dispatcher_->channel()->SetRestrictDispatchChannelGroup( dispatcher_ 90 content/renderer/pepper/pepper_broker.cc dispatcher_->ShareHandleWithRemote(handle, false); dispatcher_ 95 content/renderer/pepper/pepper_broker.cc if (!dispatcher_->Send( dispatcher_ 161 content/renderer/pepper/pepper_broker.cc dispatcher_.reset(dispatcher.release()); dispatcher_ 200 content/renderer/pepper/pepper_broker.cc if (dispatcher_) { dispatcher_ 241 content/renderer/pepper/pepper_broker.cc result = dispatcher_->SendHandleToBroker(client->pp_instance(), dispatcher_ 42 content/renderer/pepper/pepper_broker.h scoped_ptr<ppapi::proxy::BrokerDispatcher> dispatcher_; dispatcher_ 87 content/renderer/pepper/pepper_broker.h scoped_ptr<PepperBrokerDispatcherWrapper> dispatcher_; dispatcher_ 175 content/renderer/pepper/renderer_ppapi_host_impl.cc if (dispatcher_) dispatcher_ 176 content/renderer/pepper/renderer_ppapi_host_impl.cc return dispatcher_->channel()->peer_pid(); dispatcher_ 218 content/renderer/pepper/renderer_ppapi_host_impl.cc if (!dispatcher_) { dispatcher_ 227 content/renderer/pepper/renderer_ppapi_host_impl.cc return dispatcher_->ShareHandleWithRemote(handle, should_close_source); dispatcher_ 123 content/renderer/pepper/renderer_ppapi_host_impl.h ppapi::proxy::HostDispatcher* dispatcher_; dispatcher_ 56 content/renderer/screen_orientation/screen_orientation_dispatcher_unittest.cc dispatcher_.reset(new ScreenOrientationDispatcher(render_thread_.get())); dispatcher_ 57 content/renderer/screen_orientation/screen_orientation_dispatcher_unittest.cc dispatcher_->setListener(listener_.get()); dispatcher_ 62 content/renderer/screen_orientation/screen_orientation_dispatcher_unittest.cc scoped_ptr<ScreenOrientationDispatcher> dispatcher_; dispatcher_ 66 content/renderer/screen_orientation/screen_orientation_dispatcher_unittest.cc EXPECT_TRUE(render_thread_->observers().HasObserver(dispatcher_.get())); dispatcher_ 76 content/renderer/screen_orientation/screen_orientation_dispatcher_unittest.cc dispatcher_->setListener(NULL); dispatcher_ 321 extensions/browser/extension_function.h dispatcher_ = dispatcher; dispatcher_ 324 extensions/browser/extension_function.h return dispatcher_.get(); dispatcher_ 345 extensions/browser/extension_function.h base::WeakPtr<extensions::ExtensionFunctionDispatcher> dispatcher_; dispatcher_ 149 extensions/browser/extension_function_dispatcher.cc dispatcher_(dispatcher), dispatcher_ 164 extensions/browser/extension_function_dispatcher.cc if (dispatcher_.get()) { dispatcher_ 165 extensions/browser/extension_function_dispatcher.cc dispatcher_->ui_thread_response_callback_wrappers_ dispatcher_ 190 extensions/browser/extension_function_dispatcher.cc base::WeakPtr<ExtensionFunctionDispatcher> dispatcher_; dispatcher_ 58 media/audio/audio_manager_base.cc : dispatcher_(dispatcher) {} dispatcher_ 65 media/audio/audio_manager_base.cc return (dispatcher_->input_params == dispatcher_in->input_params && dispatcher_ 66 media/audio/audio_manager_base.cc dispatcher_->output_params == dispatcher_in->output_params && dispatcher_ 67 media/audio/audio_manager_base.cc dispatcher_->output_device_id == dispatcher_in->output_device_id); dispatcher_ 71 media/audio/audio_manager_base.cc const DispatcherParams* dispatcher_; dispatcher_ 15 media/audio/audio_output_proxy.cc : dispatcher_(dispatcher), dispatcher_ 29 media/audio/audio_output_proxy.cc if (!dispatcher_->OpenStream()) { dispatcher_ 46 media/audio/audio_output_proxy.cc if (!dispatcher_->StartStream(callback, this)) { dispatcher_ 59 media/audio/audio_output_proxy.cc dispatcher_->StopStream(this); dispatcher_ 66 media/audio/audio_output_proxy.cc dispatcher_->StreamVolumeSet(this, volume); dispatcher_ 82 media/audio/audio_output_proxy.cc dispatcher_->CloseStream(this); dispatcher_ 54 media/audio/audio_output_proxy.h scoped_refptr<AudioOutputDispatcher> dispatcher_; dispatcher_ 177 media/audio/audio_output_resampler.cc dispatcher_ = new AudioOutputDispatcherImpl( dispatcher_ 184 media/audio/audio_output_resampler.cc if (dispatcher_->OpenStream()) { dispatcher_ 215 media/audio/audio_output_resampler.cc if (dispatcher_->OpenStream()) { dispatcher_ 230 media/audio/audio_output_resampler.cc if (dispatcher_->OpenStream()) { dispatcher_ 253 media/audio/audio_output_resampler.cc bool result = dispatcher_->StartStream(resampler_callback, stream_proxy); dispatcher_ 262 media/audio/audio_output_resampler.cc dispatcher_->StreamVolumeSet(stream_proxy, volume); dispatcher_ 267 media/audio/audio_output_resampler.cc dispatcher_->StopStream(stream_proxy); dispatcher_ 279 media/audio/audio_output_resampler.cc dispatcher_->CloseStream(stream_proxy); dispatcher_ 297 media/audio/audio_output_resampler.cc dispatcher_->Shutdown(); dispatcher_ 309 media/audio/audio_output_resampler.cc dispatcher_->StopStream(it->first); dispatcher_ 310 media/audio/audio_output_resampler.cc dispatcher_->CloseStream(it->first); dispatcher_ 314 media/audio/audio_output_resampler.cc dispatcher_->CloseStreamsForWedgeFix(); dispatcher_ 323 media/audio/audio_output_resampler.cc dispatcher_->OpenStream(); dispatcher_ 328 media/audio/audio_output_resampler.cc dispatcher_->StartStream(it->second, it->first); dispatcher_ 70 media/audio/audio_output_resampler.h scoped_refptr<AudioOutputDispatcher> dispatcher_; dispatcher_ 443 mojo/system/dispatcher.cc DCHECK(dispatcher_); dispatcher_ 444 mojo/system/dispatcher.cc dispatcher_->lock_.Release(); dispatcher_ 445 mojo/system/dispatcher.cc dispatcher_ = NULL; dispatcher_ 310 mojo/system/dispatcher.h DispatcherTransport() : dispatcher_(NULL) {} dispatcher_ 314 mojo/system/dispatcher.h Dispatcher::Type GetType() const { return dispatcher_->GetType(); } dispatcher_ 315 mojo/system/dispatcher.h bool IsBusy() const { return dispatcher_->IsBusyNoLock(); } dispatcher_ 316 mojo/system/dispatcher.h void Close() { dispatcher_->CloseNoLock(); } dispatcher_ 318 mojo/system/dispatcher.h return dispatcher_->CreateEquivalentDispatcherAndCloseNoLock(); dispatcher_ 321 mojo/system/dispatcher.h bool is_valid() const { return !!dispatcher_; } dispatcher_ 324 mojo/system/dispatcher.h Dispatcher* dispatcher() { return dispatcher_; } dispatcher_ 330 mojo/system/dispatcher.h : dispatcher_(dispatcher) {} dispatcher_ 332 mojo/system/dispatcher.h Dispatcher* dispatcher_; dispatcher_ 121 mojo/system/dispatcher_unittest.cc dispatcher_(dispatcher), dispatcher_ 138 mojo/system/dispatcher_unittest.cc MojoResult r = dispatcher_->Close(); dispatcher_ 145 mojo/system/dispatcher_unittest.cc dispatcher_->WriteMessage(NULL, 0, NULL, dispatcher_ 150 mojo/system/dispatcher_unittest.cc dispatcher_->ReadMessage(NULL, NULL, NULL, NULL, dispatcher_ 155 mojo/system/dispatcher_unittest.cc dispatcher_->WriteData(NULL, NULL, dispatcher_ 160 mojo/system/dispatcher_unittest.cc dispatcher_->BeginWriteData(NULL, NULL, dispatcher_ 165 mojo/system/dispatcher_unittest.cc dispatcher_->EndWriteData(0)); dispatcher_ 169 mojo/system/dispatcher_unittest.cc dispatcher_->ReadData(NULL, NULL, MOJO_READ_DATA_FLAG_NONE)); dispatcher_ 173 mojo/system/dispatcher_unittest.cc dispatcher_->BeginReadData(NULL, NULL, dispatcher_ 178 mojo/system/dispatcher_unittest.cc dispatcher_->EndReadData(0)); dispatcher_ 183 mojo/system/dispatcher_unittest.cc dispatcher_->DuplicateBufferHandle(NULL, &unused)); dispatcher_ 189 mojo/system/dispatcher_unittest.cc dispatcher_->MapBuffer(0u, 0u, MOJO_MAP_BUFFER_FLAG_NONE, dispatcher_ 194 mojo/system/dispatcher_unittest.cc MojoResult r = dispatcher_->AddWaiter(&waiter_, dispatcher_ 201 mojo/system/dispatcher_unittest.cc dispatcher_->RemoveWaiter(&waiter_); dispatcher_ 209 mojo/system/dispatcher_unittest.cc dispatcher_->RemoveWaiter(&waiter_); dispatcher_ 213 mojo/system/dispatcher_unittest.cc const scoped_refptr<Dispatcher> dispatcher_; dispatcher_ 33 mojo/system/waiter_test_utils.cc dispatcher_(dispatcher), dispatcher_ 50 mojo/system/waiter_test_utils.cc *result_out_ = dispatcher_->AddWaiter(&waiter_, dispatcher_ 58 mojo/system/waiter_test_utils.cc dispatcher_->RemoveWaiter(&waiter_); dispatcher_ 79 mojo/system/waiter_test_utils.h const scoped_refptr<Dispatcher> dispatcher_; dispatcher_ 41 net/base/prioritized_dispatcher_unittest.cc : dispatcher_(dispatcher), dispatcher_ 58 net/base/prioritized_dispatcher_unittest.cc size_t num_queued = dispatcher_->num_queued_jobs(); dispatcher_ 59 net/base/prioritized_dispatcher_unittest.cc size_t num_running = dispatcher_->num_running_jobs(); dispatcher_ 62 net/base/prioritized_dispatcher_unittest.cc handle_ = dispatcher_->Add(this, priority_); dispatcher_ 64 net/base/prioritized_dispatcher_unittest.cc handle_ = dispatcher_->AddAtHead(this, priority_); dispatcher_ 68 net/base/prioritized_dispatcher_unittest.cc EXPECT_EQ(num_queued, dispatcher_->num_queued_jobs()); dispatcher_ 70 net/base/prioritized_dispatcher_unittest.cc EXPECT_EQ(num_running + 1, dispatcher_->num_running_jobs()); dispatcher_ 75 net/base/prioritized_dispatcher_unittest.cc EXPECT_EQ(num_running, dispatcher_->num_running_jobs()); dispatcher_ 82 net/base/prioritized_dispatcher_unittest.cc size_t num_queued = dispatcher_->num_queued_jobs(); dispatcher_ 83 net/base/prioritized_dispatcher_unittest.cc size_t num_running = dispatcher_->num_running_jobs(); dispatcher_ 85 net/base/prioritized_dispatcher_unittest.cc handle_ = dispatcher_->ChangePriority(handle_, priority); dispatcher_ 89 net/base/prioritized_dispatcher_unittest.cc EXPECT_EQ(num_queued - 1, dispatcher_->num_queued_jobs()); dispatcher_ 90 net/base/prioritized_dispatcher_unittest.cc EXPECT_EQ(num_running + 1, dispatcher_->num_running_jobs()); dispatcher_ 95 net/base/prioritized_dispatcher_unittest.cc EXPECT_EQ(num_queued, dispatcher_->num_queued_jobs()); dispatcher_ 96 net/base/prioritized_dispatcher_unittest.cc EXPECT_EQ(num_running, dispatcher_->num_running_jobs()); dispatcher_ 103 net/base/prioritized_dispatcher_unittest.cc size_t num_queued = dispatcher_->num_queued_jobs(); dispatcher_ 105 net/base/prioritized_dispatcher_unittest.cc dispatcher_->Cancel(handle_); dispatcher_ 107 net/base/prioritized_dispatcher_unittest.cc EXPECT_EQ(num_queued - 1, dispatcher_->num_queued_jobs()); dispatcher_ 116 net/base/prioritized_dispatcher_unittest.cc dispatcher_->OnJobFinished(); dispatcher_ 128 net/base/prioritized_dispatcher_unittest.cc PrioritizedDispatcher* dispatcher_; dispatcher_ 141 net/base/prioritized_dispatcher_unittest.cc dispatcher_.reset(new PrioritizedDispatcher(limits)); dispatcher_ 145 net/base/prioritized_dispatcher_unittest.cc TestJob* job = new TestJob(dispatcher_.get(), data, priority, &log_); dispatcher_ 152 net/base/prioritized_dispatcher_unittest.cc TestJob* job = new TestJob(dispatcher_.get(), data, priority, &log_); dispatcher_ 159 net/base/prioritized_dispatcher_unittest.cc EXPECT_EQ(0u, dispatcher_->num_queued_jobs()); dispatcher_ 160 net/base/prioritized_dispatcher_unittest.cc EXPECT_EQ(0u, dispatcher_->num_running_jobs()); dispatcher_ 166 net/base/prioritized_dispatcher_unittest.cc scoped_ptr<PrioritizedDispatcher> dispatcher_; dispatcher_ 178 net/base/prioritized_dispatcher_unittest.cc PrioritizedDispatcher::Limits retrieved_limits = dispatcher_->GetLimits(); dispatcher_ 194 net/base/prioritized_dispatcher_unittest.cc retrieved_limits = dispatcher_->GetLimits(); dispatcher_ 294 net/base/prioritized_dispatcher_unittest.cc EXPECT_EQ(5u, dispatcher_->num_running_jobs()); dispatcher_ 295 net/base/prioritized_dispatcher_unittest.cc EXPECT_EQ(3u, dispatcher_->num_queued_jobs()); dispatcher_ 391 net/base/prioritized_dispatcher_unittest.cc EXPECT_EQ(job_b, dispatcher_->EvictOldestLowest()); dispatcher_ 392 net/base/prioritized_dispatcher_unittest.cc EXPECT_EQ(job_d, dispatcher_->EvictOldestLowest()); dispatcher_ 407 net/base/prioritized_dispatcher_unittest.cc EXPECT_TRUE(dispatcher_->EvictOldestLowest() == NULL); dispatcher_ 414 net/base/prioritized_dispatcher_unittest.cc dispatcher_->SetLimitsToZero(); dispatcher_ 419 net/base/prioritized_dispatcher_unittest.cc EXPECT_EQ(0u, dispatcher_->num_running_jobs()); dispatcher_ 420 net/base/prioritized_dispatcher_unittest.cc EXPECT_EQ(3u, dispatcher_->num_queued_jobs()); dispatcher_ 422 net/base/prioritized_dispatcher_unittest.cc dispatcher_->SetLimits(limits); dispatcher_ 423 net/base/prioritized_dispatcher_unittest.cc EXPECT_EQ(2u, dispatcher_->num_running_jobs()); dispatcher_ 424 net/base/prioritized_dispatcher_unittest.cc EXPECT_EQ(1u, dispatcher_->num_queued_jobs()); dispatcher_ 448 net/base/prioritized_dispatcher_unittest.cc EXPECT_EQ(2u, dispatcher_->num_running_jobs()); dispatcher_ 449 net/base/prioritized_dispatcher_unittest.cc EXPECT_EQ(3u, dispatcher_->num_queued_jobs()); dispatcher_ 453 net/base/prioritized_dispatcher_unittest.cc dispatcher_->SetLimits(PrioritizedDispatcher::Limits(NUM_PRIORITIES, 1)); dispatcher_ 455 net/base/prioritized_dispatcher_unittest.cc EXPECT_EQ(2u, dispatcher_->num_running_jobs()); dispatcher_ 456 net/base/prioritized_dispatcher_unittest.cc EXPECT_EQ(3u, dispatcher_->num_queued_jobs()); dispatcher_ 461 net/base/prioritized_dispatcher_unittest.cc EXPECT_EQ(1u, dispatcher_->num_running_jobs()); dispatcher_ 462 net/base/prioritized_dispatcher_unittest.cc EXPECT_EQ(3u, dispatcher_->num_queued_jobs()); dispatcher_ 466 net/base/prioritized_dispatcher_unittest.cc EXPECT_EQ(1u, dispatcher_->num_running_jobs()); dispatcher_ 467 net/base/prioritized_dispatcher_unittest.cc EXPECT_EQ(2u, dispatcher_->num_queued_jobs()); dispatcher_ 470 net/base/prioritized_dispatcher_unittest.cc dispatcher_->SetLimits(initial_limits); dispatcher_ 489 net/base/prioritized_dispatcher_unittest.cc dispatcher_->SetLimitsToZero(); dispatcher_ 504 net/base/prioritized_dispatcher_unittest.cc dispatcher_->SetLimits(limits); dispatcher_ 520 net/base/prioritized_dispatcher_unittest.cc dispatcher_->SetLimitsToZero(); dispatcher_ 535 net/base/prioritized_dispatcher_unittest.cc EXPECT_DEBUG_DEATH(dispatcher_->Cancel(PrioritizedDispatcher::Handle()), ""); dispatcher_ 545 net/base/prioritized_dispatcher_unittest.cc dispatcher_->Cancel(handle); dispatcher_ 546 net/base/prioritized_dispatcher_unittest.cc EXPECT_DEBUG_DEATH(dispatcher_->Cancel(handle), ""); dispatcher_ 563 net/base/prioritized_dispatcher_unittest.cc EXPECT_DEBUG_DEATH(dispatcher_->Cancel(handle), ""); dispatcher_ 1261 net/dns/host_resolver_impl.cc handle = resolver_->dispatcher_.Add(this, priority()); dispatcher_ 1263 net/dns/host_resolver_impl.cc handle = resolver_->dispatcher_.AddAtHead(this, priority()); dispatcher_ 1402 net/dns/host_resolver_impl.cc resolver_->dispatcher_.Cancel(handle_); dispatcher_ 1405 net/dns/host_resolver_impl.cc resolver_->dispatcher_.OnJobFinished(); dispatcher_ 1415 net/dns/host_resolver_impl.cc handle_ = resolver_->dispatcher_.ChangePriority(handle_, priority()); dispatcher_ 1662 net/dns/host_resolver_impl.cc resolver_->dispatcher_.OnJobFinished(); dispatcher_ 1664 net/dns/host_resolver_impl.cc resolver_->dispatcher_.Cancel(handle_); dispatcher_ 1796 net/dns/host_resolver_impl.cc dispatcher_(job_limits), dispatcher_ 1811 net/dns/host_resolver_impl.cc DCHECK_GE(dispatcher_.num_priorities(), static_cast<size_t>(NUM_PRIORITIES)); dispatcher_ 1845 net/dns/host_resolver_impl.cc dispatcher_.SetLimitsToZero(); dispatcher_ 1855 net/dns/host_resolver_impl.cc DCHECK_EQ(0u, dispatcher_.num_queued_jobs()); dispatcher_ 1903 net/dns/host_resolver_impl.cc if (dispatcher_.num_queued_jobs() > max_queued_jobs_) { dispatcher_ 1904 net/dns/host_resolver_impl.cc Job* evicted = static_cast<Job*>(dispatcher_.EvictOldestLowest()); dispatcher_ 2206 net/dns/host_resolver_impl.cc PrioritizedDispatcher::Limits limits = dispatcher_.GetLimits(); dispatcher_ 2207 net/dns/host_resolver_impl.cc dispatcher_.SetLimits( dispatcher_ 2220 net/dns/host_resolver_impl.cc dispatcher_.SetLimits(limits); dispatcher_ 2227 net/dns/host_resolver_impl.cc PrioritizedDispatcher::Limits limits = dispatcher_.GetLimits(); dispatcher_ 2228 net/dns/host_resolver_impl.cc dispatcher_.SetLimits( dispatcher_ 2233 net/dns/host_resolver_impl.cc dispatcher_.SetLimits(limits); dispatcher_ 241 net/dns/host_resolver_impl.h return dispatcher_.num_running_jobs(); dispatcher_ 251 net/dns/host_resolver_impl.h PrioritizedDispatcher dispatcher_; dispatcher_ 125 net/tools/quic/end_to_end_test.cc : dispatcher_(dispatcher) {} dispatcher_ 127 net/tools/quic/end_to_end_test.cc virtual void OnCanWrite() OVERRIDE { dispatcher_->OnCanWrite(); } dispatcher_ 129 net/tools/quic/end_to_end_test.cc QuicDispatcher* dispatcher_; dispatcher_ 30 net/tools/quic/quic_dispatcher.cc : dispatcher_(dispatcher) { dispatcher_ 35 net/tools/quic/quic_dispatcher.cc dispatcher_->DeleteSessions(); dispatcher_ 40 net/tools/quic/quic_dispatcher.cc QuicDispatcher* dispatcher_; dispatcher_ 46 net/tools/quic/quic_dispatcher.cc : dispatcher_(dispatcher) {} dispatcher_ 52 net/tools/quic/quic_dispatcher.cc return dispatcher_->OnUnauthenticatedPublicHeader(header); dispatcher_ 56 net/tools/quic/quic_dispatcher.cc dispatcher_->OnUnauthenticatedHeader(header); dispatcher_ 137 net/tools/quic/quic_dispatcher.cc QuicDispatcher* dispatcher_; dispatcher_ 77 net/tools/quic/quic_dispatcher_test.cc dispatcher_->OnConnectionClosed(connection_id(), QUIC_NO_ERROR); dispatcher_ 80 net/tools/quic/quic_dispatcher_test.cc QuicDispatcher* dispatcher_; dispatcher_ 104 net/tools/quic/quic_dispatcher_test.cc dispatcher_(config_, crypto_config_, &eps_), dispatcher_ 107 net/tools/quic/quic_dispatcher_test.cc dispatcher_.Initialize(1); dispatcher_ 127 net/tools/quic/quic_dispatcher_test.cc dispatcher_.ProcessPacket(server_address_, client_address, *packet.get()); dispatcher_ 139 net/tools/quic/quic_dispatcher_test.cc TestDispatcher dispatcher_; dispatcher_ 151 net/tools/quic/quic_dispatcher_test.cc EXPECT_CALL(dispatcher_, CreateQuicSession(1, _, client_address)) dispatcher_ 153 net/tools/quic/quic_dispatcher_test.cc &dispatcher_, 1, client_address, &session1_))); dispatcher_ 155 net/tools/quic/quic_dispatcher_test.cc EXPECT_EQ(client_address, dispatcher_.current_client_address()); dispatcher_ 156 net/tools/quic/quic_dispatcher_test.cc EXPECT_EQ(server_address_, dispatcher_.current_server_address()); dispatcher_ 159 net/tools/quic/quic_dispatcher_test.cc EXPECT_CALL(dispatcher_, CreateQuicSession(2, _, client_address)) dispatcher_ 161 net/tools/quic/quic_dispatcher_test.cc &dispatcher_, 2, client_address, &session2_))); dispatcher_ 174 net/tools/quic/quic_dispatcher_test.cc EXPECT_CALL(dispatcher_, CreateQuicSession(_, _, client_address)) dispatcher_ 176 net/tools/quic/quic_dispatcher_test.cc &dispatcher_, 1, client_address, &session1_))); dispatcher_ 183 net/tools/quic/quic_dispatcher_test.cc dispatcher_.Shutdown(); dispatcher_ 203 net/tools/quic/quic_dispatcher_test.cc QuicDispatcherPeer::GetWriter(&dispatcher_), &dispatcher_, &eps_); dispatcher_ 205 net/tools/quic/quic_dispatcher_test.cc QuicDispatcherPeer::SetTimeWaitListManager(&dispatcher_, dispatcher_ 210 net/tools/quic/quic_dispatcher_test.cc EXPECT_CALL(dispatcher_, CreateQuicSession(connection_id, _, client_address)) dispatcher_ 212 net/tools/quic/quic_dispatcher_test.cc &dispatcher_, connection_id, client_address, &session1_))); dispatcher_ 233 net/tools/quic/quic_dispatcher_test.cc dispatcher_.ProcessPacket(IPEndPoint(), client_address, *encrypted); dispatcher_ 246 net/tools/quic/quic_dispatcher_test.cc QuicDispatcherPeer::GetWriter(&dispatcher_), &dispatcher_, &eps_); dispatcher_ 248 net/tools/quic/quic_dispatcher_test.cc QuicDispatcherPeer::SetTimeWaitListManager(&dispatcher_, dispatcher_ 255 net/tools/quic/quic_dispatcher_test.cc EXPECT_CALL(dispatcher_, CreateQuicSession(_, _, _)).Times(0); dispatcher_ 332 net/tools/quic/quic_dispatcher_test.cc QuicDispatcherPeer::UseWriter(&dispatcher_, writer_); dispatcher_ 336 net/tools/quic/quic_dispatcher_test.cc EXPECT_CALL(dispatcher_, CreateQuicSession(_, _, client_address)) dispatcher_ 338 net/tools/quic/quic_dispatcher_test.cc &dispatcher_, 1, client_address, &session1_))); dispatcher_ 341 net/tools/quic/quic_dispatcher_test.cc EXPECT_CALL(dispatcher_, CreateQuicSession(_, _, client_address)) dispatcher_ 343 net/tools/quic/quic_dispatcher_test.cc &dispatcher_, 2, client_address, &session2_))); dispatcher_ 346 net/tools/quic/quic_dispatcher_test.cc blocked_list_ = dispatcher_.write_blocked_list(); dispatcher_ 352 net/tools/quic/quic_dispatcher_test.cc dispatcher_.Shutdown(); dispatcher_ 361 net/tools/quic/quic_dispatcher_test.cc dispatcher_.OnWriteBlocked(connection2()); dispatcher_ 371 net/tools/quic/quic_dispatcher_test.cc dispatcher_.OnCanWrite(); dispatcher_ 375 net/tools/quic/quic_dispatcher_test.cc dispatcher_.OnWriteBlocked(connection1()); dispatcher_ 377 net/tools/quic/quic_dispatcher_test.cc dispatcher_.OnCanWrite(); dispatcher_ 381 net/tools/quic/quic_dispatcher_test.cc dispatcher_.OnCanWrite(); dispatcher_ 382 net/tools/quic/quic_dispatcher_test.cc EXPECT_FALSE(dispatcher_.HasPendingWrites()); dispatcher_ 389 net/tools/quic/quic_dispatcher_test.cc dispatcher_.OnWriteBlocked(connection1()); dispatcher_ 390 net/tools/quic/quic_dispatcher_test.cc dispatcher_.OnWriteBlocked(connection2()); dispatcher_ 393 net/tools/quic/quic_dispatcher_test.cc dispatcher_.OnCanWrite(); dispatcher_ 397 net/tools/quic/quic_dispatcher_test.cc dispatcher_.OnWriteBlocked(connection2()); dispatcher_ 398 net/tools/quic/quic_dispatcher_test.cc dispatcher_.OnWriteBlocked(connection1()); dispatcher_ 401 net/tools/quic/quic_dispatcher_test.cc dispatcher_.OnCanWrite(); dispatcher_ 407 net/tools/quic/quic_dispatcher_test.cc dispatcher_.OnWriteBlocked(connection1()); dispatcher_ 410 net/tools/quic/quic_dispatcher_test.cc dispatcher_.OnCanWrite(); dispatcher_ 414 net/tools/quic/quic_dispatcher_test.cc dispatcher_.OnWriteBlocked(connection1()); dispatcher_ 415 net/tools/quic/quic_dispatcher_test.cc dispatcher_.OnWriteBlocked(connection2()); dispatcher_ 418 net/tools/quic/quic_dispatcher_test.cc dispatcher_.OnCanWrite(); dispatcher_ 422 net/tools/quic/quic_dispatcher_test.cc dispatcher_.OnWriteBlocked(connection1()); dispatcher_ 424 net/tools/quic/quic_dispatcher_test.cc dispatcher_.OnWriteBlocked(connection1()); dispatcher_ 426 net/tools/quic/quic_dispatcher_test.cc dispatcher_.OnCanWrite(); dispatcher_ 432 net/tools/quic/quic_dispatcher_test.cc dispatcher_.OnWriteBlocked(connection1()); dispatcher_ 433 net/tools/quic/quic_dispatcher_test.cc dispatcher_.OnWriteBlocked(connection1()); dispatcher_ 436 net/tools/quic/quic_dispatcher_test.cc dispatcher_.OnCanWrite(); dispatcher_ 440 net/tools/quic/quic_dispatcher_test.cc dispatcher_.OnWriteBlocked(connection1()); dispatcher_ 441 net/tools/quic/quic_dispatcher_test.cc dispatcher_.OnWriteBlocked(connection1()); dispatcher_ 443 net/tools/quic/quic_dispatcher_test.cc dispatcher_.OnCanWrite(); dispatcher_ 450 net/tools/quic/quic_dispatcher_test.cc dispatcher_.OnWriteBlocked(connection1()); dispatcher_ 451 net/tools/quic/quic_dispatcher_test.cc dispatcher_.OnWriteBlocked(connection2()); dispatcher_ 455 net/tools/quic/quic_dispatcher_test.cc dispatcher_.OnCanWrite(); dispatcher_ 459 net/tools/quic/quic_dispatcher_test.cc dispatcher_.OnCanWrite(); dispatcher_ 467 net/tools/quic/quic_dispatcher_test.cc dispatcher_.OnWriteBlocked(connection1()); dispatcher_ 468 net/tools/quic/quic_dispatcher_test.cc dispatcher_.OnWriteBlocked(connection2()); dispatcher_ 472 net/tools/quic/quic_dispatcher_test.cc dispatcher_.OnCanWrite(); dispatcher_ 473 net/tools/quic/quic_dispatcher_test.cc EXPECT_TRUE(dispatcher_.HasPendingWrites()); dispatcher_ 477 net/tools/quic/quic_dispatcher_test.cc dispatcher_.OnCanWrite(); dispatcher_ 478 net/tools/quic/quic_dispatcher_test.cc EXPECT_FALSE(dispatcher_.HasPendingWrites()); dispatcher_ 485 net/tools/quic/quic_dispatcher_test.cc dispatcher_.OnWriteBlocked(connection1()); dispatcher_ 486 net/tools/quic/quic_dispatcher_test.cc dispatcher_.OnWriteBlocked(connection2()); dispatcher_ 490 net/tools/quic/quic_dispatcher_test.cc dispatcher_.OnCanWrite(); dispatcher_ 491 net/tools/quic/quic_dispatcher_test.cc EXPECT_TRUE(dispatcher_.HasPendingWrites()); dispatcher_ 495 net/tools/quic/quic_dispatcher_test.cc dispatcher_.OnCanWrite(); dispatcher_ 496 net/tools/quic/quic_dispatcher_test.cc EXPECT_FALSE(dispatcher_.HasPendingWrites()); dispatcher_ 175 net/tools/quic/quic_server.cc dispatcher_.reset(new QuicDispatcher( dispatcher_ 181 net/tools/quic/quic_server.cc dispatcher_->Initialize(fd_); dispatcher_ 193 net/tools/quic/quic_server.cc dispatcher_->Shutdown(); dispatcher_ 208 net/tools/quic/quic_server.cc fd_, port_, dispatcher_.get(), dispatcher_ 213 net/tools/quic/quic_server.cc dispatcher_->OnCanWrite(); dispatcher_ 214 net/tools/quic/quic_server.cc if (dispatcher_->HasPendingWrites()) { dispatcher_ 91 net/tools/quic/quic_server.h scoped_ptr<QuicDispatcher> dispatcher_; dispatcher_ 25 net/tools/quic/quic_server_test.cc dispatcher_.Initialize(1234); dispatcher_ 30 net/tools/quic/quic_server_test.cc dispatcher_.ProcessPacket(server_addr, client_addr, packet); dispatcher_ 37 net/tools/quic/quic_server_test.cc MockQuicDispatcher dispatcher_; dispatcher_ 55 net/tools/quic/quic_server_test.cc EXPECT_CALL(dispatcher_, ProcessPacket(_, _, _)).Times(1); dispatcher_ 28 net/tools/quic/test_tools/quic_server_peer.cc return server->dispatcher_.get(); dispatcher_ 268 ppapi/proxy/host_dispatcher.cc : dispatcher_(NULL) { dispatcher_ 270 ppapi/proxy/host_dispatcher.cc dispatcher_ = static_cast<HostDispatcher*>(dispatcher); dispatcher_ 271 ppapi/proxy/host_dispatcher.cc dispatcher_->ppb_proxy()->AddRefModule(dispatcher_->pp_module()); dispatcher_ 276 ppapi/proxy/host_dispatcher.cc if (dispatcher_) dispatcher_ 277 ppapi/proxy/host_dispatcher.cc dispatcher_->ppb_proxy()->ReleaseModule(dispatcher_->pp_module()); dispatcher_ 152 ppapi/proxy/host_dispatcher.h HostDispatcher* dispatcher_; dispatcher_ 14 ppapi/proxy/interface_proxy.cc : dispatcher_(dispatcher) { dispatcher_ 21 ppapi/proxy/interface_proxy.cc return dispatcher_->Send(msg); dispatcher_ 29 ppapi/proxy/interface_proxy.h Dispatcher* dispatcher() const { return dispatcher_; } dispatcher_ 43 ppapi/proxy/interface_proxy.h Dispatcher* dispatcher_; dispatcher_ 36 ppapi/proxy/plugin_var_serialization_rules.cc return dispatcher_.get() ? var_tracker_->TrackObjectWithNoReference( dispatcher_ 37 ppapi/proxy/plugin_var_serialization_rules.cc var, dispatcher_.get()) dispatcher_ 71 ppapi/proxy/plugin_var_serialization_rules.cc return dispatcher_.get() dispatcher_ 72 ppapi/proxy/plugin_var_serialization_rules.cc ? var_tracker_->ReceiveObjectPassRef(var, dispatcher_.get()) dispatcher_ 108 ppapi/proxy/plugin_var_serialization_rules.cc if (dispatcher_.get()) dispatcher_ 109 ppapi/proxy/plugin_var_serialization_rules.cc var_tracker_->ReleaseHostObject(dispatcher_.get(), var); dispatcher_ 46 ppapi/proxy/plugin_var_serialization_rules.h base::WeakPtr<PluginDispatcher> dispatcher_; dispatcher_ 16 ppapi/proxy/proxy_object_var.cc : dispatcher_(dispatcher), dispatcher_ 32 ppapi/proxy/proxy_object_var.h proxy::PluginDispatcher* dispatcher() const { return dispatcher_; } dispatcher_ 42 ppapi/proxy/proxy_object_var.h void clear_dispatcher() { dispatcher_ = NULL; } dispatcher_ 45 ppapi/proxy/proxy_object_var.h proxy::PluginDispatcher* dispatcher_; dispatcher_ 267 ppapi/proxy/serialized_var.cc : dispatcher_(dispatcher), dispatcher_ 285 ppapi/proxy/serialized_var.cc (*output_)[i] = converted.Return(dispatcher_); dispatcher_ 409 ppapi/proxy/serialized_var.cc dispatcher_ = dispatcher; dispatcher_ 419 ppapi/proxy/serialized_var.cc : dispatcher_(NULL), dispatcher_ 426 ppapi/proxy/serialized_var.cc DCHECK(dispatcher_); dispatcher_ 436 ppapi/proxy/serialized_var.cc *out.OutParam(dispatcher_) = array_[i]; dispatcher_ 446 ppapi/proxy/serialized_var.cc DCHECK(!dispatcher_); // Should only be called once. dispatcher_ 447 ppapi/proxy/serialized_var.cc dispatcher_ = dispatcher; dispatcher_ 336 ppapi/proxy/serialized_var.h Dispatcher* dispatcher_; dispatcher_ 457 ppapi/proxy/serialized_var.h Dispatcher* dispatcher_; dispatcher_ 472 ppapi/proxy/serialized_var.h Dispatcher* dispatcher_; dispatcher_ 676 ppapi/utility/completion_callback_factory.h dispatcher_(dispatcher) { dispatcher_ 682 ppapi/utility/completion_callback_factory.h delete dispatcher_; dispatcher_ 685 ppapi/utility/completion_callback_factory.h Dispatcher* dispatcher() { return dispatcher_; } dispatcher_ 694 ppapi/utility/completion_callback_factory.h (*self->dispatcher_)(object, result); dispatcher_ 702 ppapi/utility/completion_callback_factory.h Dispatcher* dispatcher_; // We own this pointer. dispatcher_ 356 ui/aura/gestures/gesture_recognizer_unittest.cc dispatcher_(dispatcher), dispatcher_ 387 ui/aura/gestures/gesture_recognizer_unittest.cc dispatcher_->ProcessedTouchEvent(event.get(), window_, dispatcher_ 394 ui/aura/gestures/gesture_recognizer_unittest.cc WindowEventDispatcher* dispatcher_; dispatcher_ 751 ui/aura/window_event_dispatcher_unittest.cc : dispatcher_(dispatcher), dispatcher_ 762 ui/aura/window_event_dispatcher_unittest.cc dispatcher_->HoldPointerMoves(); dispatcher_ 765 ui/aura/window_event_dispatcher_unittest.cc dispatcher_->ReleasePointerMoves(); dispatcher_ 770 ui/aura/window_event_dispatcher_unittest.cc WindowEventDispatcher* dispatcher_; dispatcher_ 240 ui/aura/window_tree_host.cc dispatcher_.reset(); dispatcher_ 267 ui/aura/window_tree_host.cc dispatcher_.reset(new WindowEventDispatcher(this)); dispatcher_ 65 ui/aura/window_tree_host.h const WindowEventDispatcher* dispatcher() const { return dispatcher_.get(); } dispatcher_ 207 ui/aura/window_tree_host.h scoped_ptr<WindowEventDispatcher> dispatcher_; dispatcher_ 110 ui/display/chromeos/x11/native_display_event_dispatcher_x11_unittest.cc scoped_ptr<NativeDisplayEventDispatcherX11> dispatcher_; dispatcher_ 120 ui/display/chromeos/x11/native_display_event_dispatcher_x11_unittest.cc dispatcher_(new NativeDisplayEventDispatcherX11(helper_delegate_.get(), dispatcher_ 124 ui/display/chromeos/x11/native_display_event_dispatcher_x11_unittest.cc dispatcher_->SetTickClockForTest( dispatcher_ 134 ui/display/chromeos/x11/native_display_event_dispatcher_x11_unittest.cc dispatcher_->Dispatch(reinterpret_cast<const base::NativeEvent>(&event)); dispatcher_ 150 ui/display/chromeos/x11/native_display_event_dispatcher_x11_unittest.cc dispatcher_->Dispatch(reinterpret_cast<const base::NativeEvent>(&event)); dispatcher_ 34 ui/events/event_dispatcher.cc : dispatcher_(NULL) { dispatcher_ 38 ui/events/event_dispatcher.cc if (dispatcher_) dispatcher_ 39 ui/events/event_dispatcher.cc dispatcher_->OnDispatcherDelegateDestroyed(); dispatcher_ 43 ui/events/event_dispatcher.cc return dispatcher_ ? dispatcher_->current_event() : NULL; dispatcher_ 82 ui/events/event_dispatcher.cc EventDispatcher* old_dispatcher = dispatcher_; dispatcher_ 84 ui/events/event_dispatcher.cc dispatcher_ = &dispatcher; dispatcher_ 87 ui/events/event_dispatcher.cc dispatcher_ = old_dispatcher; dispatcher_ 67 ui/events/event_dispatcher.h EventDispatcher* dispatcher_; dispatcher_ 192 win8/metro_driver/metro_driver_win7.cc dispatcher_ = mswr::Make<CoreDispacherEmulation>(); dispatcher_ 223 win8/metro_driver/metro_driver_win7.cc return dispatcher_.CopyTo(value); dispatcher_ 505 win8/metro_driver/metro_driver_win7.cc mswr::ComPtr<winui::Core::ICoreDispatcher> dispatcher_;