HomeSort by relevance Sort by last modified time
    Searched full:dispatcher_ (Results 1 - 25 of 75) sorted by null

1 2 3

  /external/chromium_org/base/message_loop/
message_pump_ozone.cc 36 DCHECK(dispatcher_.size() == 0);
37 dispatcher_.insert(dispatcher_.begin(),dispatcher);
42 DCHECK(dispatcher_.size() == 1);
43 dispatcher_.pop_back();
47 if (dispatcher_.size() > 0)
48 return dispatcher_[0]->Dispatch(dev);
56 dispatcher_.push_back(dispatcher);
58 dispatcher_.pop_back();
  /external/chromium_org/net/tools/quic/
quic_dispatcher_test.cc 63 dispatcher_(dispatcher) {
67 dispatcher_->OnConnectionClosed(guid(), QUIC_NO_ERROR);
70 QuicDispatcher* dispatcher_; member in class:net::tools::test::__anon9559::MockServerConnection
93 dispatcher_(config_, crypto_config_, &eps_),
112 dispatcher_.ProcessPacket(
124 TestDispatcher dispatcher_; member in class:net::tools::test::__anon9559::QuicDispatcherTest
133 EXPECT_CALL(dispatcher_, CreateQuicSession(1, _, addr))
135 &dispatcher_, 1, addr, &session1_)));
138 EXPECT_CALL(dispatcher_, CreateQuicSession(2, _, addr))
140 &dispatcher_, 2, addr, &session2_)))
    [all...]
quic_server_test.cc 24 dispatcher_(config_, crypto_config_, 1234, &eps_) {}
29 QuicServer::MaybeDispatchPacket(&dispatcher_, packet,
37 MockQuicDispatcher dispatcher_; member in class:net::tools::test::__anon9564::QuicServerDispatchPacketTest
48 EXPECT_CALL(dispatcher_, ProcessPacket(_, _, _, _, _)).Times(0);
67 EXPECT_CALL(dispatcher_, ProcessPacket(_, _, _, _, _)).Times(1);
  /external/chromium_org/net/base/
prioritized_dispatcher_unittest.cc 41 : dispatcher_(dispatcher),
58 size_t num_queued = dispatcher_->num_queued_jobs();
59 size_t num_running = dispatcher_->num_running_jobs();
62 handle_ = dispatcher_->Add(this, priority_);
64 handle_ = dispatcher_->AddAtHead(this, priority_);
68 EXPECT_EQ(num_queued, dispatcher_->num_queued_jobs());
70 EXPECT_EQ(num_running + 1, dispatcher_->num_running_jobs());
75 EXPECT_EQ(num_running, dispatcher_->num_running_jobs());
82 size_t num_queued = dispatcher_->num_queued_jobs();
83 size_t num_running = dispatcher_->num_running_jobs()
128 PrioritizedDispatcher* dispatcher_; member in class:net::__anon8914::PrioritizedDispatcherTest::TestJob
166 scoped_ptr<PrioritizedDispatcher> dispatcher_; member in class:net::__anon8914::PrioritizedDispatcherTest
    [all...]
  /external/chromium_org/ppapi/proxy/
interface_proxy.cc 14 : dispatcher_(dispatcher) {
21 return dispatcher_->Send(msg);
proxy_object_var.h 32 proxy::PluginDispatcher* dispatcher() const { return dispatcher_; }
42 void clear_dispatcher() { dispatcher_ = NULL; }
45 proxy::PluginDispatcher* dispatcher_; member in class:ppapi::ProxyObjectVar
plugin_var_serialization_rules.cc 21 dispatcher_(dispatcher) {
36 return dispatcher_.get() ? var_tracker_->TrackObjectWithNoReference(
37 var, dispatcher_.get())
71 return dispatcher_.get()
72 ? var_tracker_->ReceiveObjectPassRef(var, dispatcher_.get())
108 if (dispatcher_.get())
109 var_tracker_->ReleaseHostObject(dispatcher_.get(), var);
  /external/chromium_org/content/renderer/p2p/
host_address_request.cc 15 : dispatcher_(dispatcher),
53 request_id_ = dispatcher_->RegisterHostAddressRequest(this);
55 dispatcher_->SendP2PMessage(
62 dispatcher_->UnregisterHostAddressRequest(request_id_);
71 dispatcher_->UnregisterHostAddressRequest(request_id_);
socket_client_impl.cc 40 : dispatcher_(dispatcher),
77 socket_id_ = dispatcher_->RegisterClient(this);
78 dispatcher_->SendP2PMessage(new P2PHostMsg_CreateSocket(
98 dispatcher_->SendP2PMessage(new P2PHostMsg_Send(socket_id_, address, data,
119 if (dispatcher_) {
122 dispatcher_->SendP2PMessage(new P2PHostMsg_DestroySocket(socket_id_));
124 dispatcher_->UnregisterClient(socket_id_);
162 new P2PSocketClientImpl(dispatcher_);
163 new_client->socket_id_ = dispatcher_->RegisterClient(new_client.get());
167 dispatcher_->SendP2PMessage(new P2PHostMsg_AcceptIncomingTcpConnection
    [all...]
  /external/chromium_org/mojo/system/
dispatcher_unittest.cc 111 dispatcher_(dispatcher),
128 MojoResult r = dispatcher_->Close();
135 dispatcher_->WriteMessage(NULL, 0, NULL,
140 dispatcher_->ReadMessage(NULL, NULL, NULL, NULL,
145 dispatcher_->WriteData(NULL, NULL,
150 dispatcher_->BeginWriteData(NULL, NULL,
155 dispatcher_->EndWriteData(0));
159 dispatcher_->ReadData(NULL, NULL, MOJO_READ_DATA_FLAG_NONE));
163 dispatcher_->BeginReadData(NULL, NULL,
168 dispatcher_->EndReadData(0))
190 const scoped_refptr<Dispatcher> dispatcher_; member in class:mojo::system::__anon8754::ThreadSafetyStressThread
    [all...]
waiter_test_utils.cc 33 dispatcher_(dispatcher),
50 *result_out_ = dispatcher_->AddWaiter(&waiter_,
58 dispatcher_->RemoveWaiter(&waiter_);
  /external/chromium_org/content/renderer/pepper/
host_dispatcher_wrapper.cc 48 dispatcher_.reset(new ppapi::proxy::HostDispatcher(
51 if (!dispatcher_->InitHostWithChannel(dispatcher_delegate_.get(),
56 dispatcher_.reset();
60 dispatcher_->channel()->SetRestrictDispatchChannelGroup(
66 return dispatcher_->GetProxiedInterface(name);
70 ppapi::proxy::HostDispatcher::SetForInstance(instance, dispatcher_.get());
pepper_broker.cc 69 dispatcher_.reset(
72 if (!dispatcher_->InitBrokerWithChannel(dispatcher_delegate_.get(),
76 dispatcher_.reset();
80 dispatcher_->channel()->SetRestrictDispatchChannelGroup(
90 dispatcher_->ShareHandleWithRemote(handle, false);
95 if (!dispatcher_->Send(
144 // TODO(ddorwin): Send message disconnect message using dispatcher_.
161 dispatcher_.reset(dispatcher.release());
200 if (dispatcher_) {
241 result = dispatcher_->SendHandleToBroker(client->pp_instance()
    [all...]
  /external/chromium_org/media/audio/
audio_output_proxy.cc 15 : dispatcher_(dispatcher),
29 if (!dispatcher_->OpenStream()) {
46 if (!dispatcher_->StartStream(callback, this)) {
59 dispatcher_->StopStream(this);
66 dispatcher_->StreamVolumeSet(this, volume);
82 dispatcher_->CloseStream(this);
audio_output_resampler.cc 171 dispatcher_ = new AudioOutputDispatcherImpl(
179 if (dispatcher_->OpenStream()) {
210 if (dispatcher_->OpenStream()) {
225 if (dispatcher_->OpenStream()) {
248 bool result = dispatcher_->StartStream(resampler_callback, stream_proxy);
257 dispatcher_->StreamVolumeSet(stream_proxy, volume);
262 dispatcher_->StopStream(stream_proxy);
274 dispatcher_->CloseStream(stream_proxy);
292 dispatcher_->Shutdown();
304 dispatcher_->StopStream(it->first)
    [all...]
audio_output_resampler.h 67 // Used to initialize and reinitialize |dispatcher_|.
71 scoped_refptr<AudioOutputDispatcher> dispatcher_; member in class:media::AudioOutputResampler
84 // Whether any streams have been opened through |dispatcher_|, if so we can't
  /external/chromium_org/ui/events/
event_dispatcher.cc 34 : dispatcher_(NULL) {
38 if (dispatcher_)
39 dispatcher_->OnDispatcherDelegateDestroyed();
43 return dispatcher_ ? dispatcher_->current_event() : NULL;
75 EventDispatcher* old_dispatcher = dispatcher_;
77 dispatcher_ = &dispatcher;
80 dispatcher_ = old_dispatcher;
  /external/chromium_org/chrome/renderer/extensions/
renderer_permissions_policy_delegate.h 30 Dispatcher* dispatcher_; member in class:extensions::RendererPermissionsPolicyDelegate
chrome_v8_extension.h 41 Dispatcher* dispatcher() { return dispatcher_; }
48 Dispatcher* dispatcher_; member in class:extensions::ChromeV8Extension
renderer_permissions_policy_delegate.cc 19 Dispatcher* dispatcher) : dispatcher_(dispatcher) {
47 if (dispatcher_->IsExtensionActive(extension_misc::kWebStoreAppId)) {
extension_helper.cc 144 dispatcher_(dispatcher),
181 dispatcher_->user_script_slave()->InjectScripts(
196 dispatcher_->user_script_slave()->InjectScripts(
202 dispatcher_->DidCreateDocumentElement(frame);
239 dispatcher_->DidMatchCSS(
249 g_schedulers.Get()[frame] = new UserScriptScheduler(frame, dispatcher_);
256 dispatcher_->OnExtensionResponse(request_id,
267 dispatcher_->InvokeModuleSystemMethod(
279 dispatcher_->v8_context_set().GetAll(),
287 MessagingBindings::DeliverMessage(dispatcher_->v8_context_set().GetAll()
    [all...]
app_window_custom_bindings.cc 32 : content::RenderViewObserver(view), dispatcher_(dispatcher) {
37 DCHECK(dispatcher_); variable
43 dispatcher_->v8_context_set().GetByV8Context(
54 Dispatcher* dispatcher_; member in class:extensions::DidCreateDocumentElementObserver
  /external/chromium_org/content/renderer/media/
media_stream_dispatcher_unittest.cc 115 : dispatcher_(new MediaStreamDispatcherUnderTest()),
125 int next_ipc_id = dispatcher_->GetNextIpcIdForTest();
126 dispatcher_->GenerateStream(request_id, handler_.get()->AsWeakPtr(),
157 dispatcher_->OnMessageReceived(MediaStreamMsg_StreamGenerated(
165 EXPECT_EQ(dispatcher_->audio_session_id(label, 0), kAudioSessionId);
168 EXPECT_EQ(dispatcher_->video_session_id(label, 0), kVideoSessionId);
175 scoped_ptr<MediaStreamDispatcherUnderTest> dispatcher_; member in class:content::__anon8173::MediaStreamDispatcherTest
200 dispatcher_->StopStreamDevice(handler_->audio_device_);
201 EXPECT_EQ(dispatcher_->audio_session_id(label1, 0),
203 EXPECT_EQ(dispatcher_->audio_session_id(label2, 0)
    [all...]
  /external/chromium_org/content/child/
resource_dispatcher_unittest.cc 127 dispatcher_->OnReceivedResponse(request_id, response);
137 dispatcher_->OnSetDataBuffer(request_id, dup_handle,
139 dispatcher_->OnReceivedData(request_id, 0, test_page_contents_len,
158 dispatcher_.reset(new ResourceDispatcher(this));
161 dispatcher_.reset();
183 return dispatcher_->CreateBridge(request_info);
187 static scoped_ptr<ResourceDispatcher> dispatcher_; member in class:content::ResourceDispatcherTest
191 scoped_ptr<ResourceDispatcher> ResourceDispatcherTest::dispatcher_; member in class:content::ResourceDispatcherTest
252 dispatcher_->OnMessageReceived(
261 dispatcher_->OnMessageReceived
    [all...]
  /external/chromium_org/content/browser/renderer_host/
websocket_host.cc 97 WebSocketDispatcherHost* const dispatcher_; member in class:content::__anon7918::WebSocketEventHandler
106 : dispatcher_(dispatcher), routing_id_(routing_id) {}
118 return StateCast(dispatcher_->SendAddChannelResponse(
129 return StateCast(dispatcher_->SendFrame(
136 return StateCast(dispatcher_->SendClosing(routing_id_));
142 return StateCast(dispatcher_->SendFlowControl(routing_id_, quota));
150 return StateCast(dispatcher_->DoDropChannel(routing_id_, code, reason));

Completed in 333 milliseconds

1 2 3