Searched defs:dispatcher (Results 51 - 75 of 179) sorted by relevance

12345678

/external/chromium_org/mojo/system/
H A Ddispatcher.h51 DispatcherTryStartTransport(Dispatcher* dispatcher);
79 // NOTE(vtl): This puts a big lock around each dispatcher (i.e., handle), and
115 // |*new_dispatcher| should be null (and will contain the dispatcher for the
132 // Adds a waiter to this dispatcher. The waiter will be woken up when this
143 // - |MOJO_RESULT_INVALID_ARGUMENT| if the dispatcher has been closed; and
150 // Removes a waiter from this dispatcher. (It is valid to call this multiple
156 // A dispatcher must be put into a special state in order to be sent across a
173 // |dispatcher| until |DispatcherTransport::End()| is called.
174 static DispatcherTransport TryStartTransport(Dispatcher* dispatcher);
182 // issue, and in fact no need to take dispatcher lock
389 Dispatcher* dispatcher() { return dispatcher_; } function in class:mojo::system::DispatcherTransport
394 DispatcherTransport(Dispatcher* dispatcher) argument
[all...]
H A Dshared_buffer_dispatcher_unittest.cc13 #include "mojo/system/dispatcher.h"
117 scoped_refptr<SharedBufferDispatcher> dispatcher; local
123 &dispatcher));
124 ASSERT_TRUE(dispatcher.get());
125 EXPECT_EQ(Dispatcher::kTypeSharedBuffer, dispatcher->GetType());
131 dispatcher->MapBuffer(0, 100, MOJO_MAP_BUFFER_FLAG_NONE, &mapping1));
141 dispatcher->MapBuffer(50, 50, MOJO_MAP_BUFFER_FLAG_NONE, &mapping2));
147 EXPECT_EQ(MOJO_RESULT_OK, dispatcher->Close());
149 // Check that we can still read/write to mappings after the dispatcher has
253 scoped_refptr<SharedBufferDispatcher> dispatcher; local
273 scoped_refptr<SharedBufferDispatcher> dispatcher; local
[all...]
H A Ddispatcher_unittest.cc5 #include "mojo/system/dispatcher.h"
150 scoped_refptr<Dispatcher> dispatcher,
154 dispatcher_(dispatcher),
292 // One of the threads should already have closed the dispatcher.
149 ThreadSafetyStressThread(base::WaitableEvent* event, scoped_refptr<Dispatcher> dispatcher, DispatcherOp op) argument
H A Dhandle_table.cc10 #include "mojo/system/dispatcher.h"
18 HandleTable::Entry::Entry(const scoped_refptr<Dispatcher>& dispatcher) argument
19 : dispatcher(dispatcher), busy(false) {
40 return it->second.dispatcher.get();
45 scoped_refptr<Dispatcher>* dispatcher) {
47 DCHECK(dispatcher);
54 *dispatcher = it->second.dispatcher;
61 const scoped_refptr<Dispatcher>& dispatcher) {
43 GetAndRemoveDispatcher( MojoHandle handle, scoped_refptr<Dispatcher>* dispatcher) argument
60 AddDispatcher( const scoped_refptr<Dispatcher>& dispatcher) argument
187 AddDispatcherNoSizeCheck( const scoped_refptr<Dispatcher>& dispatcher) argument
[all...]
H A Dmultiprocess_message_pipe_unittest.cc25 #include "mojo/system/dispatcher.h"
252 scoped_refptr<SharedBufferDispatcher> dispatcher(
257 CHECK_EQ(dispatcher->MapBuffer(0, 100, MOJO_MAP_BUFFER_FLAG_NONE, &mapping),
267 // We should be able to close the dispatcher now.
268 dispatcher->Close();
324 scoped_refptr<SharedBufferDispatcher> dispatcher; local
330 &dispatcher));
331 ASSERT_TRUE(dispatcher.get());
336 dispatcher->MapBuffer(0, 100, MOJO_MAP_BUFFER_FLAG_NONE, &mapping));
344 test::DispatcherTryStartTransport(dispatcher
[all...]
/external/chromium_org/ppapi/proxy/
H A Dppb_core_proxy.cc88 PPB_Core_Proxy::PPB_Core_Proxy(Dispatcher* dispatcher) argument
89 : InterfaceProxy(dispatcher),
91 if (!dispatcher->IsPlugin()) {
93 dispatcher->local_get_interface()(PPB_CORE_INTERFACE));
H A Dppb_flash_message_loop_proxy.cc76 PPB_Flash_MessageLoop_Proxy::PPB_Flash_MessageLoop_Proxy(Dispatcher* dispatcher) argument
77 : InterfaceProxy(dispatcher) {
86 PluginDispatcher* dispatcher = PluginDispatcher::GetForInstance(instance); local
87 if (!dispatcher)
91 dispatcher->Send(new PpapiHostMsg_PPBFlashMessageLoop_Create(
99 if (!dispatcher()->permissions().HasPermission(PERMISSION_FLASH))
121 if (!dispatcher()->permissions().HasPermission(PERMISSION_FLASH))
133 if (!dispatcher()->permissions().HasPermission(PERMISSION_FLASH))
H A Dppp_messaging_proxy_unittest.cc50 void CallHandleMessage(Dispatcher* dispatcher, argument
53 dispatcher->Send(new PpapiMsg_PPPMessaging_HandleMessage(
56 SerializedVarSendInputShmem(dispatcher, message, instance)));
H A Dinterface_list.cc166 InterfaceProxy* ProxyFactory(Dispatcher* dispatcher) { argument
167 return new ProxyClass(dispatcher);
H A Dmessage_handler.cc38 PluginDispatcher* dispatcher = PluginDispatcher::GetForInstance(instance); local
39 if (!dispatcher)
50 SerializedVarReturnValue::Convert(dispatcher, result),
52 dispatcher->Send(reply_msg.release());
68 PluginDispatcher* dispatcher = PluginDispatcher::GetForInstance(instance); local
69 if (!dispatcher)
81 SerializedVarReturnValue::Convert(dispatcher, return_value),
83 dispatcher->Send(reply_msg.release());
H A Dppb_broker_proxy.cc114 PPB_Broker_Proxy::PPB_Broker_Proxy(Dispatcher* dispatcher) argument
115 : InterfaceProxy(dispatcher),
124 PluginDispatcher* dispatcher = PluginDispatcher::GetForInstance(instance); local
125 if (!dispatcher)
129 dispatcher->Send(new PpapiHostMsg_PPBBroker_Create(
150 if (!dispatcher()->permissions().HasPermission(PERMISSION_PRIVATE))
161 if (!dispatcher()->permissions().HasPermission(PERMISSION_PRIVATE))
210 dispatcher()->ShareHandleWithRemote(IntToPlatformFile(socket_handle),
222 bool success = dispatcher()->Send(new PpapiMsg_PPBBroker_ConnectComplete(
H A Dppb_buffer_proxy.cc67 PPB_Buffer_Proxy::PPB_Buffer_Proxy(Dispatcher* dispatcher) argument
68 : InterfaceProxy(dispatcher) {
77 PluginDispatcher* dispatcher = PluginDispatcher::GetForInstance(instance); local
78 if (!dispatcher)
83 dispatcher->Send(new PpapiHostMsg_PPBBuffer_Create(
117 HostDispatcher* dispatcher = HostDispatcher::GetForInstance(instance); local
118 if (!dispatcher)
120 if (!dispatcher->permissions().HasPermission(ppapi::PERMISSION_DEV))
152 dispatcher->ShareHandleWithRemote(platform_file, false), size);
/external/chromium_org/third_party/WebKit/Source/core/inspector/
H A DInspectorBaseAgent.cpp94 void InspectorAgentRegistry::registerInDispatcher(InspectorBackendDispatcher* dispatcher) argument
97 m_agents[i]->registerInDispatcher(dispatcher);
/external/chromium_org/ui/aura/
H A Dwindow_targeter.cc131 WindowEventDispatcher* dispatcher = root_window->GetHost()->dispatcher(); local
132 if (dispatcher->mouse_pressed_handler())
133 return dispatcher->mouse_pressed_handler();
/external/okhttp/okhttp/src/main/java/com/squareup/okhttp/
H A DJob.java42 private final Dispatcher dispatcher; field in class:Job
53 public Job(Dispatcher dispatcher, OkHttpClient client, Request request, argument
56 this.dispatcher = dispatcher;
87 dispatcher.finished(this);
/external/chromium_org/ash/wm/workspace/
H A Dworkspace_event_handler_unittest.cc389 ui::EventProcessor* dispatcher = root->GetHost()->event_processor(); local
390 ui::EventDispatchDetails details = dispatcher->OnEventFromSource(&press);
396 details = dispatcher->OnEventFromSource(&release);
/external/chromium_org/base/message_loop/
H A Dmessage_pump_win.h30 // Like MessagePump::Run, but MSG objects are routed through dispatcher.
31 void RunWithDispatcher(Delegate* delegate, MessagePumpDispatcher* dispatcher);
40 MessagePumpDispatcher* dispatcher; member in struct:base::MessagePumpWin::RunState
/external/chromium_org/chrome/renderer/extensions/
H A Dapp_bindings.cc20 #include "extensions/renderer/dispatcher.h"
60 AppBindings::AppBindings(Dispatcher* dispatcher, ScriptContext* context) argument
63 dispatcher_(dispatcher) {
H A Dchrome_extensions_dispatcher_delegate.cc39 #include "extensions/renderer/dispatcher.h"
95 extensions::Dispatcher* dispatcher,
104 new extensions::AppBindings(dispatcher, context)));
302 const extensions::Dispatcher* dispatcher,
309 dispatcher->extensions()->GetByID(*it);
316 const extensions::Dispatcher* dispatcher,
332 dispatcher->extensions()->GetByID(extension_id);
94 RegisterNativeHandlers( extensions::Dispatcher* dispatcher, extensions::ModuleSystem* module_system, extensions::ScriptContext* context) argument
301 ClearTabSpecificPermissions( const extensions::Dispatcher* dispatcher, int tab_id, const std::vector<std::string>& extension_ids) argument
315 UpdateTabSpecificPermissions( const extensions::Dispatcher* dispatcher, const GURL& url, int tab_id, const std::string& extension_id, const extensions::URLPatternSet& origin_set) argument
/external/chromium_org/content/browser/renderer_host/
H A Dwebsocket_dispatcher_host_unittest.cc34 WebSocketDispatcherHost* dispatcher,
102 WebSocketDispatcherHost* dispatcher,
105 : WebSocketHost(routing_id, dispatcher, url_request_context),
100 MockWebSocketHost( int routing_id, WebSocketDispatcherHost* dispatcher, net::URLRequestContext* url_request_context, WebSocketDispatcherHostTest* owner) argument
/external/chromium_org/content/child/service_worker/
H A Dservice_worker_provider_context.cc26 ServiceWorkerDispatcher* dispatcher = local
29 DCHECK(dispatcher);
30 dispatcher->AddProviderContext(this);
34 if (ServiceWorkerDispatcher* dispatcher =
36 dispatcher->RemoveProviderContext(this);
/external/chromium_org/content/child/
H A Dweb_socket_stream_handle_impl.cc91 SocketStreamDispatcher* dispatcher = local
93 bridge_ = dispatcher->CreateBridge(handle_, this);
/external/chromium_org/content/renderer/java/
H A Dgin_java_bridge_object.cc29 const base::WeakPtr<GinJavaBridgeDispatcher>& dispatcher,
39 new GinJavaBridgeObject(isolate, dispatcher, object_id);
56 const base::WeakPtr<GinJavaBridgeDispatcher>& dispatcher,
59 blink::mainThreadIsolate(), dispatcher, object_id);
64 const base::WeakPtr<GinJavaBridgeDispatcher>& dispatcher,
67 dispatcher_(dispatcher),
27 InjectNamed( blink::WebFrame* frame, const base::WeakPtr<GinJavaBridgeDispatcher>& dispatcher, const std::string& object_name, GinJavaBridgeDispatcher::ObjectID object_id) argument
55 InjectAnonymous( const base::WeakPtr<GinJavaBridgeDispatcher>& dispatcher, GinJavaBridgeDispatcher::ObjectID object_id) argument
62 GinJavaBridgeObject( v8::Isolate* isolate, const base::WeakPtr<GinJavaBridgeDispatcher>& dispatcher, GinJavaBridgeDispatcher::ObjectID object_id) argument
/external/chromium_org/extensions/browser/
H A Dapi_test_utils.cc90 scoped_ptr<extensions::ExtensionFunctionDispatcher> dispatcher) {
92 function, args, context, dispatcher.Pass(), NONE);
99 scoped_ptr<extensions::ExtensionFunctionDispatcher> dispatcher,
104 RunFunction(function, args, context, dispatcher.Pass(), flags);
128 scoped_ptr<ExtensionFunctionDispatcher> dispatcher(
132 function, args, context, dispatcher.Pass(), flags);
146 scoped_ptr<ExtensionFunctionDispatcher> dispatcher(
151 RunFunction(function, args, context, dispatcher.Pass(), flags);
160 scoped_ptr<ExtensionFunctionDispatcher> dispatcher(
162 return RunFunction(function, args, context, dispatcher
86 RunFunctionWithDelegateAndReturnSingleResult( UIThreadExtensionFunction* function, const std::string& args, content::BrowserContext* context, scoped_ptr<extensions::ExtensionFunctionDispatcher> dispatcher) argument
95 RunFunctionWithDelegateAndReturnSingleResult( UIThreadExtensionFunction* function, const std::string& args, content::BrowserContext* context, scoped_ptr<extensions::ExtensionFunctionDispatcher> dispatcher, RunFunctionFlags flags) argument
165 RunFunction(UIThreadExtensionFunction* function, const std::string& args, content::BrowserContext* context, scoped_ptr<extensions::ExtensionFunctionDispatcher> dispatcher, RunFunctionFlags flags) argument
177 RunFunction(UIThreadExtensionFunction* function, scoped_ptr<base::ListValue> args, content::BrowserContext* context, scoped_ptr<extensions::ExtensionFunctionDispatcher> dispatcher, RunFunctionFlags flags) argument
[all...]
/external/chromium_org/extensions/renderer/
H A Drequest_sender.cc10 #include "extensions/renderer/dispatcher.h"
46 RequestSender::RequestSender(Dispatcher* dispatcher) argument
47 : dispatcher_(dispatcher), source_tab_id_(-1) {}

Completed in 4616 milliseconds

12345678