Searched refs:dispatcher (Results 1 - 25 of 56) sorted by relevance

123

/external/qemu/android/
H A Dsdk-controller-socket.c295 /* Enumerates SDKCtlSocket I/O dispatcher states. */
297 /* I/O dispatcher expects a packet header. */
299 /* I/O dispatcher expects packet data. */
301 /* I/O dispatcher expects query response header. */
303 /* I/O dispatcher expects query response data. */
307 /* SDKCtlSocket I/O dispatcher descriptor. */
309 /* SDKCtlSocket instance for this dispatcher. */
336 /* I/O dispatcher for the socket. */
486 /* Quick check: the query could be currently handled by the dispatcher. */
488 /* Release the query from dispatcher
1364 SDKCtlIODispatcher* const dispatcher = &sdkctl->io_dispatcher; local
1380 SDKCtlIODispatcher* const dispatcher = &sdkctl->io_dispatcher; local
1410 _on_io_dispatcher_io_failure(SDKCtlIODispatcher* dispatcher, AsyncSocketIO* asio) argument
1429 _on_io_dispatcher_io_cancelled(SDKCtlIODispatcher* dispatcher, AsyncSocketIO* asio) argument
1452 _on_io_dispatcher_packet_header(SDKCtlIODispatcher* dispatcher, AsyncSocketIO* asio) argument
1509 _on_io_dispatcher_packet(SDKCtlIODispatcher* dispatcher, AsyncSocketIO* asio) argument
1531 _on_io_dispatcher_query_reply_header(SDKCtlIODispatcher* dispatcher, AsyncSocketIO* asio) argument
1591 _on_io_dispatcher_query_reply(SDKCtlIODispatcher* dispatcher, AsyncSocketIO* asio) argument
1637 SDKCtlIODispatcher* const dispatcher = (SDKCtlIODispatcher*)io_opaque; local
1735 SDKCtlIODispatcher* const dispatcher = &sdkctl->io_dispatcher; local
[all...]
/external/chromium/chrome/browser/extensions/
H A Dextension_function.cc31 return dispatcher()->GetCurrentBrowser(include_incognito_);
64 if (!dispatcher())
67 dispatcher()->HandleBadMessage(this);
69 dispatcher()->SendResponse(this, success);
H A Dextension_function_dispatcher.h57 explicit Peer(ExtensionFunctionDispatcher* dispatcher) argument
58 : dispatcher_(dispatcher) {}
112 // The profile that this dispatcher is associated with.
115 // The RenderViewHost this dispatcher is associated with.
H A Dextension_test_api.cc31 Source<Profile>(dispatcher()->profile()),
43 Source<Profile>(dispatcher()->profile()),
/external/chromium-trace/trace-viewer/third_party/pywebsocket/src/mod_pywebsocket/handshake/
H A D__init__.py53 def do_handshake(request, dispatcher, allowDraft75=False, strict=False):
58 dispatcher: Dispatcher (dispatch.Dispatcher).
86 ('RFC 6455', hybi.Handshaker(request, dispatcher)))
88 ('HyBi 00', hybi00.Handshaker(request, dispatcher)))
91 ('Hixie 75', draft75.Handshaker(request, dispatcher, strict)))
H A Ddraft75.py79 def __init__(self, request, dispatcher, strict=False):
84 dispatcher: Dispatcher (dispatch.Dispatcher).
96 self._dispatcher = dispatcher
/external/chromium-trace/trace-viewer/third_party/pywebsocket/src/test/
H A Dtest_dispatch.py126 dispatcher = dispatch.Dispatcher(_TEST_HANDLERS_DIR, None)
127 warnings = dispatcher.source_warnings()
148 dispatcher = dispatch.Dispatcher(_TEST_HANDLERS_DIR, None)
152 dispatcher.do_extra_handshake(request) # Must not raise exception.
156 dispatcher.do_extra_handshake(request)
164 dispatcher = dispatch.Dispatcher(_TEST_HANDLERS_DIR, None)
168 dispatcher.do_extra_handshake, request)
171 dispatcher = dispatch.Dispatcher(_TEST_HANDLERS_DIR, None)
176 dispatcher.transfer_data(request)
184 dispatcher
[all...]
H A Dtest_mux.py391 dispatcher = _MuxMockDispatcher()
392 mux_handler = mux._MuxHandler(request, dispatcher)
432 self.assertEqual([], dispatcher.channel_events[1].messages)
433 self.assertEqual(['Hello'], dispatcher.channel_events[2].messages)
434 self.assertEqual(['World'], dispatcher.channel_events[3].messages)
453 dispatcher = _MuxMockDispatcher()
454 mux_handler = mux._MuxHandler(request, dispatcher)
470 self.assertTrue(1 in dispatcher.channel_events)
471 self.assertTrue(not 2 in dispatcher.channel_events)
475 dispatcher
[all...]
/external/chromium/chrome/browser/automation/
H A Dui_controls_win.cc58 // If a hook is installed, this is the dispatcher.
84 // Installs dispatcher as the current hook.
85 void InstallHook(InputDispatcher* dispatcher, bool key_hook) { argument
87 current_dispatcher_ = dispatcher;
102 void UninstallHook(InputDispatcher* dispatcher) { argument
103 if (current_dispatcher_ == dispatcher) {
168 scoped_refptr<InputDispatcher> dispatcher(
181 if (dispatcher.get())
182 dispatcher->AddRef();
236 if (dispatcher
[all...]
/external/jmonkeyengine/engine/src/networking/com/jme3/network/base/
H A DConnectorAdapter.java47 * to the supplied message dispatcher. This is used
66 private MessageListener<Object> dispatcher; field in class:ConnectorAdapter
79 public ConnectorAdapter( Connector connector, MessageListener<Object> dispatcher, argument
84 this.dispatcher = dispatcher;
133 dispatcher.messageReceived( null, m );
H A DDefaultClient.java79 private Redispatch dispatcher = new Redispatch(); field in class:DefaultClient
107 channels.add(new ConnectorAdapter(reliable, dispatcher, dispatcher, true));
109 channels.add(new ConnectorAdapter(fast, dispatcher, dispatcher, false));
362 ConnectorAdapter ca = new ConnectorAdapter(c, dispatcher, dispatcher, true);
/external/chromium/third_party/libjingle/source/talk/base/
H A Dphysicalsocketserver.h91 void Add(Dispatcher* dispatcher);
92 void Remove(Dispatcher* dispatcher);
/external/chromium/base/
H A Dmessage_pump_glib.cc129 Dispatcher* dispatcher; member in struct:base::MessagePumpForUI::RunState
176 Dispatcher* dispatcher) {
188 state.dispatcher = dispatcher;
308 if (state_ && state_->dispatcher) { // state_ may be null during tests.
309 if (!state_->dispatcher->Dispatch(event))
347 return state_ ? state_->dispatcher : NULL;
175 RunWithDispatcher(Delegate* delegate, Dispatcher* dispatcher) argument
H A Dmessage_pump_glib.h57 // Like MessagePump::Run, but GdkEvent objects are routed through dispatcher.
58 virtual void RunWithDispatcher(Delegate* delegate, Dispatcher* dispatcher);
93 // Returns the dispatcher for the current run state (|state_->dispatcher|).
H A Dmessage_pump_win.cc41 Delegate* delegate, Dispatcher* dispatcher) {
44 s.dispatcher = dispatcher;
353 if (state_->dispatcher) {
354 if (!state_->dispatcher->Dispatch(msg))
40 RunWithDispatcher( Delegate* delegate, Dispatcher* dispatcher) argument
H A Dmessage_loop.cc344 if (state_->dispatcher && type() == TYPE_UI) {
346 RunWithDispatcher(this, state_->dispatcher);
645 dispatcher = NULL;
696 void MessageLoopForUI::Run(Dispatcher* dispatcher) { argument
698 state_->dispatcher = dispatcher;
H A Dmessage_pump_win.h76 // Like MessagePump::Run, but MSG objects are routed through dispatcher.
77 void RunWithDispatcher(Delegate* delegate, Dispatcher* dispatcher);
86 Dispatcher* dispatcher; member in struct:base::MessagePumpWin::RunState
/external/jmonkeyengine/engine/src/bullet-native/
H A DjmePhysicsSpace.cpp140 btCollisionDispatcher* dispatcher; local
142 // use the default collision dispatcher. For parallel processing you can use a diffent dispatcher (see Extras/BulletMultiThreaded)
145 dispatcher = new SpuGatheringCollisionDispatcher(dispatchThreads, 4, collisionConfiguration);
146 dispatcher->setDispatcherFlags(btCollisionDispatcher::CD_DISABLE_CONTACTPOOL_DYNAMIC_ALLOCATION);
148 dispatcher = new btCollisionDispatcher(collisionConfiguration);
160 btDiscreteDynamicsWorld* world = new btDiscreteDynamicsWorld(dispatcher, broadphase, solver, collisionConfiguration);
/external/webkit/Source/WebCore/dom/
H A DMouseEvent.cpp165 bool MouseEventDispatchMediator::dispatchEvent(EventDispatcher* dispatcher) const
167 if (dispatcher->node()->disabled()) // Don't even send DOM events for disabled controls..
173 RefPtr<EventTarget> relatedTarget = dispatcher->adjustRelatedTarget(event(), event()->relatedTarget());
176 dispatcher->dispatchEvent(event());
190 dispatcher->dispatchEvent(doubleClickEvent);
H A DEventDispatcher.cpp58 EventDispatcher dispatcher(node);
59 return mediator.dispatchEvent(&dispatcher);
105 EventDispatcher dispatcher(node);
116 dispatcher.dispatchEvent(SimulatedMouseEvent::create(eventNames().mousedownEvent, node->document()->defaultView(), underlyingEvent));
119 dispatcher.dispatchEvent(SimulatedMouseEvent::create(eventNames().mouseupEvent, node->document()->defaultView(), underlyingEvent));
123 dispatcher.dispatchEvent(SimulatedMouseEvent::create(eventNames().clickEvent, node->document()->defaultView(), underlyingEvent));
H A DKeyboardEvent.cpp169 bool KeyboardEventDispatchMediator::dispatchEvent(EventDispatcher* dispatcher) const
172 return EventDispatchMediator::dispatchEvent(dispatcher) && !event()->defaultHandled();
H A DWheelEvent.cpp118 bool WheelEventDispatchMediator::dispatchEvent(EventDispatcher* dispatcher) const
123 return EventDispatchMediator::dispatchEvent(dispatcher) && !event()->defaultHandled();
H A DEvent.cpp311 bool EventDispatchMediator::dispatchEvent(EventDispatcher* dispatcher) const
313 return dispatcher->dispatchEvent(m_event.get());
/external/chromium-trace/trace-viewer/third_party/pywebsocket/src/mod_pywebsocket/
H A Dheaderparserhandler.py165 dispatcher = dispatch.Dispatcher(
168 for warning in dispatcher.source_warnings():
171 return dispatcher
/external/okhttp/src/test/java/com/squareup/okhttp/internal/mockspdyserver/
H A DMockSpdyServer.java56 private QueueDispatcher dispatcher = new QueueDispatcher(); field in class:MockSpdyServer
144 dispatcher.enqueueResponse(response);
195 response = dispatcher.dispatch(request);

Completed in 386 milliseconds

123