/external/chromium_org/mojo/system/ |
H A D | dispatcher.h | 51 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 D | shared_buffer_dispatcher_unittest.cc | 13 #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 D | dispatcher_unittest.cc | 5 #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 D | handle_table.cc | 10 #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 D | multiprocess_message_pipe_unittest.cc | 25 #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 D | ppb_core_proxy.cc | 88 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 D | ppb_flash_message_loop_proxy.cc | 76 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 D | ppp_messaging_proxy_unittest.cc | 50 void CallHandleMessage(Dispatcher* dispatcher, argument 53 dispatcher->Send(new PpapiMsg_PPPMessaging_HandleMessage( 56 SerializedVarSendInputShmem(dispatcher, message, instance)));
|
H A D | interface_list.cc | 166 InterfaceProxy* ProxyFactory(Dispatcher* dispatcher) { argument 167 return new ProxyClass(dispatcher);
|
H A D | message_handler.cc | 38 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 D | ppb_broker_proxy.cc | 114 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 D | ppb_buffer_proxy.cc | 67 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 D | InspectorBaseAgent.cpp | 94 void InspectorAgentRegistry::registerInDispatcher(InspectorBackendDispatcher* dispatcher) argument 97 m_agents[i]->registerInDispatcher(dispatcher);
|
/external/chromium_org/ui/aura/ |
H A D | window_targeter.cc | 131 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 D | Job.java | 42 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 D | workspace_event_handler_unittest.cc | 389 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 D | message_pump_win.h | 30 // 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 D | app_bindings.cc | 20 #include "extensions/renderer/dispatcher.h" 60 AppBindings::AppBindings(Dispatcher* dispatcher, ScriptContext* context) argument 63 dispatcher_(dispatcher) {
|
H A D | chrome_extensions_dispatcher_delegate.cc | 39 #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 D | websocket_dispatcher_host_unittest.cc | 34 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 D | service_worker_provider_context.cc | 26 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 D | web_socket_stream_handle_impl.cc | 91 SocketStreamDispatcher* dispatcher = local 93 bridge_ = dispatcher->CreateBridge(handle_, this);
|
/external/chromium_org/content/renderer/java/ |
H A D | gin_java_bridge_object.cc | 29 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 D | api_test_utils.cc | 90 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 D | request_sender.cc | 10 #include "extensions/renderer/dispatcher.h" 46 RequestSender::RequestSender(Dispatcher* dispatcher) argument 47 : dispatcher_(dispatcher), source_tab_id_(-1) {}
|