Searched defs:dispatcher (Results 1 - 25 of 179) sorted by last modified time

12345678

/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/okhttp/mockwebserver/src/main/java/com/squareup/okhttp/mockwebserver/
H A DMockWebServer.java109 private Dispatcher dispatcher = new QueueDispatcher(); field in class:MockWebServer
223 * @throws ClassCastException if the default dispatcher has been replaced
227 ((QueueDispatcher) dispatcher).enqueueResponse(response.clone());
279 SocketPolicy socketPolicy = dispatcher.peek().getSocketPolicy();
317 SocketPolicy socketPolicy = dispatcher.peek().getSocketPolicy();
376 SocketPolicy socketPolicy = dispatcher.peek().getSocketPolicy();
394 MockResponse response = dispatcher.dispatch(request);
430 dispatcher.dispatch(new RecordedRequest(null, null, null, -1, null, sequenceNumber, socket));
477 MockResponse throttlePolicy = dispatcher.peek();
587 * Sets the dispatcher use
592 setDispatcher(Dispatcher dispatcher) argument
[all...]
/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);
H A DOkHttpClient.java58 private Dispatcher dispatcher; field in class:OkHttpClient
76 dispatcher = new Dispatcher();
296 * Sets the dispatcher used to set policy and execute asynchronous requests.
299 public OkHttpClient setDispatcher(Dispatcher dispatcher) { argument
300 if (dispatcher == null) throw new IllegalArgumentException("dispatcher == null");
301 this.dispatcher = dispatcher;
306 return dispatcher;
433 Job job = new Job(dispatcher, clien
[all...]
/external/okhttp/okhttp-tests/src/test/java/com/squareup/okhttp/
H A DDispatcherTest.java18 Dispatcher dispatcher = new Dispatcher(executor); field in class:DispatcherTest
19 OkHttpClient client = new OkHttpClient().setDispatcher(dispatcher);
22 dispatcher.setMaxRequests(20);
23 dispatcher.setMaxRequestsPerHost(10);
28 dispatcher.setMaxRequests(0);
36 dispatcher.setMaxRequestsPerHost(0);
48 dispatcher.setMaxRequests(3);
57 dispatcher.setMaxRequestsPerHost(2);
65 dispatcher.setMaxRequests(2);
71 dispatcher
[all...]
/external/mockwebserver/src/main/java/com/google/mockwebserver/
H A DMockWebServer.java93 private Dispatcher dispatcher = new QueueDispatcher(); field in class:MockWebServer
187 * @throws ClassCastException if the default dispatcher has been replaced
191 ((QueueDispatcher) dispatcher).enqueueResponse(response.clone());
269 SocketPolicy socketPolicy = dispatcher.peek().getSocketPolicy();
307 SocketPolicy socketPolicy = dispatcher.peek().getSocketPolicy();
348 SocketPolicy socketPolicy = dispatcher.peek().getSocketPolicy();
368 MockResponse response = dispatcher.dispatch(request);
386 // request. The retry handler may call dispatcher.dispatch(request) before the
388 // Setting workerThreads = 1 ensures that the dispatcher is called for requests in
424 dispatcher
588 setDispatcher(Dispatcher dispatcher) argument
[all...]
/external/eclipse-basebuilder/basebuilder-3.6.2/org.eclipse.releng.basebuilder/plugins/
H A Dorg.mortbay.jetty.server_6.1.23.v201004211559.jarMETA-INF/MANIFEST.MF META-INF/ECLIPSEF.SF META-INF/ECLIPSEF.RSA META ...
H A Dorg.mortbay.jetty.util_6.1.23.v201004211559.jarMETA-INF/MANIFEST.MF META-INF/ECLIPSEF.SF META-INF/ECLIPSEF.RSA META ...
H A Dorg.eclipse.equinox.util_1.0.200.v20100503.jarMETA-INF/MANIFEST.MF META-INF/ECLIPSEF.SF META-INF/ECLIPSEF.RSA META ...
H A Dorg.eclipse.osgi_3.6.1.R36x_v20100806.jarMETA-INF/MANIFEST.MF META-INF/ECLIPSEF.SF META-INF/ECLIPSEF.RSA META ...
H A Dorg.eclipse.osgi_3.6.2.R36x_v20101103.jarMETA-INF/MANIFEST.MF META-INF/ECLIPSEF.SF META-INF/ECLIPSEF.RSA META ...
/external/eclipse-basebuilder/basebuilder-3.6.2/org.eclipse.releng.basebuilder/plugins/org.eclipse.jdt.debug_3.6.1.v20100715_r361/
H A Djdimodel.jarMETA-INF/MANIFEST.MF META-INF/ECLIPSEF.SF META-INF/ECLIPSEF.RSA META ...
/external/chromium_org/third_party/webrtc/base/
H A Dmacsocketserver.cc58 Dispatcher* dispatcher = signal_dispatcher(); local
64 if (!dispatcher && (dispatcher = signal_dispatcher())) {
70 dispatcher->GetDescriptor(),
/external/chromium_org/third_party/WebKit/Source/modules/indexeddb/
H A DIDBPendingTransactionMonitor.cpp93 void registerTarget(IDBDisposerDispatcher& dispatcher, Target& target) argument
96 m_disposerMap.add(&target, Disposer<IDBDisposerDispatcher, Target>::create(dispatcher, target));
99 void unregisterTarget(IDBDisposerDispatcher& dispatcher, Target& target) argument
/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);
H A DInspectorTimelineAgent.cpp401 TraceEventDispatcher* dispatcher = TraceEventDispatcher::instance(); local
402 dispatcher->addListener(InstrumentationEvents::BeginFrame, TRACE_EVENT_PHASE_INSTANT, InspectorTimelineAgentTraceEventListener::create(this, &InspectorTimelineAgent::onBeginImplSideFrame), m_client);
403 dispatcher->addListener(InstrumentationEvents::PaintSetup, TRACE_EVENT_PHASE_BEGIN, InspectorTimelineAgentTraceEventListener::create(this, &InspectorTimelineAgent::onPaintSetupBegin), m_client);
404 dispatcher->addListener(InstrumentationEvents::PaintSetup, TRACE_EVENT_PHASE_END, InspectorTimelineAgentTraceEventListener::create(this, &InspectorTimelineAgent::onPaintSetupEnd), m_client);
405 dispatcher->addListener(InstrumentationEvents::RasterTask, TRACE_EVENT_PHASE_BEGIN, InspectorTimelineAgentTraceEventListener::create(this, &InspectorTimelineAgent::onRasterTaskBegin), m_client);
406 dispatcher->addListener(InstrumentationEvents::RasterTask, TRACE_EVENT_PHASE_END, InspectorTimelineAgentTraceEventListener::create(this, &InspectorTimelineAgent::onRasterTaskEnd), m_client);
407 dispatcher->addListener(InstrumentationEvents::Layer, TRACE_EVENT_PHASE_DELETE_OBJECT, InspectorTimelineAgentTraceEventListener::create(this, &InspectorTimelineAgent::onLayerDeleted), m_client);
408 dispatcher->addListener(InstrumentationEvents::RequestMainThreadFrame, TRACE_EVENT_PHASE_INSTANT, InspectorTimelineAgentTraceEventListener::create(this, &InspectorTimelineAgent::onRequestMainThreadFrame), m_client);
409 dispatcher->addListener(InstrumentationEvents::ActivateLayerTree, TRACE_EVENT_PHASE_INSTANT, InspectorTimelineAgentTraceEventListener::create(this, &InspectorTimelineAgent::onActivateLayerTree), m_client);
410 dispatcher
[all...]
/external/chromium_org/ui/aura/gestures/
H A Dgesture_recognizer_unittest.cc337 explicit QueueTouchEventDelegate(WindowEventDispatcher* dispatcher) argument
339 dispatcher_(dispatcher),
492 void SendScrollEvents(ui::EventProcessor* dispatcher, argument
510 ui::EventDispatchDetails details = dispatcher->OnEventFromSource(&move);
516 void SendScrollEvent(ui::EventProcessor* dispatcher, argument
525 ui::EventDispatchDetails details = dispatcher->OnEventFromSource(&move);
1701 new QueueTouchEventDelegate(host()->dispatcher()));
2267 new QueueTouchEventDelegate(host()->dispatcher()));
2294 new QueueTouchEventDelegate(host()->dispatcher()));
2945 new QueueTouchEventDelegate(host()->dispatcher()));
[all...]
/external/chromium_org/ui/aura/test/
H A Dwindow_event_dispatcher_test_api.cc13 WindowEventDispatcher* dispatcher) : dispatcher_(dispatcher) {
12 WindowEventDispatcherTestApi( WindowEventDispatcher* dispatcher) argument
/external/chromium_org/ui/aura/
H A Dwindow_event_dispatcher_unittest.cc145 host()->dispatcher()->RepostEvent(event);
639 host()->dispatcher()->RepostEvent(press_event);
660 host()->dispatcher()->HoldPointerMoves();
691 host()->dispatcher()->ReleasePointerMoves();
699 host()->dispatcher()->HoldPointerMoves();
701 host()->dispatcher()->ReleasePointerMoves();
711 host()->dispatcher()->HoldPointerMoves();
713 host()->dispatcher()->ReleasePointerMoves();
724 host()->dispatcher()->HoldPointerMoves();
731 host()->dispatcher()
812 HoldPointerOnScrollHandler(WindowEventDispatcher* dispatcher, EventFilterRecorder* filter) argument
1911 RepostEventHelper(WindowEventDispatcher* dispatcher, scoped_ptr<ui::MouseEvent> event) argument
2295 AsyncWindowDelegate(WindowEventDispatcher* dispatcher) argument
[all...]
H A Dwindow_targeter.cc131 WindowEventDispatcher* dispatcher = root_window->GetHost()->dispatcher(); local
132 if (dispatcher->mouse_pressed_handler())
133 return dispatcher->mouse_pressed_handler();
H A Dwindow_tree_host.h65 WindowEventDispatcher* dispatcher() { function in class:aura::WindowTreeHost
67 const_cast<const WindowTreeHost*>(this)->dispatcher());
69 const WindowEventDispatcher* dispatcher() const { return dispatcher_.get(); } function in class:aura::WindowTreeHost
/external/chromium_org/ui/base/test/
H A Dui_controls_internal_win.cc56 // If a hook is installed, this is the dispatcher.
82 // Installs dispatcher as the current hook.
83 void InstallHook(InputDispatcher* dispatcher, bool key_hook) { argument
85 current_dispatcher_ = dispatcher;
100 void UninstallHook(InputDispatcher* dispatcher) { argument
101 if (current_dispatcher_ == dispatcher) {
184 scoped_refptr<InputDispatcher> dispatcher(
197 if (dispatcher.get())
198 dispatcher->AddRef();
252 if (dispatcher
[all...]
/external/chromium_org/ui/base/x/
H A Dselection_requestor.cc65 PlatformEventDispatcher* dispatcher)
69 dispatcher_(dispatcher),
63 SelectionRequestor(XDisplay* x_display, XID x_window, PlatformEventDispatcher* dispatcher) argument
/external/chromium_org/ui/events/
H A Devent_dispatcher_unittest.cc132 // Destroys the dispatcher-delegate when it receives any event.
171 // Optionally also destroys the dispatcher.
229 TestEventDispatcher dispatcher; local
261 dispatcher.ProcessEvent(&child, &mouse);
277 dispatcher.ProcessEvent(&child, &mouse);
297 dispatcher.ProcessEvent(&child, &mouse);
311 dispatcher.ProcessEvent(&child, &mouse);
322 TestEventDispatcher dispatcher; local
335 dispatcher.ProcessEvent(&target, &mouse);
344 // Tests that if the dispatcher i
349 TestEventDispatcher* dispatcher = new TestEventDispatcher(); local
376 TestEventDispatcher* dispatcher = new TestEventDispatcher(); local
401 TestEventDispatcher* dispatcher = new TestEventDispatcher(); local
428 TestEventDispatcher* dispatcher = new TestEventDispatcher(); local
455 TestEventDispatcher dispatcher; local
497 TestEventDispatcher dispatcher; local
526 TestEventDispatcher dispatcher; local
554 TestEventDispatcher* dispatcher = new TestEventDispatcher(); local
583 TestEventDispatcher* dispatcher = new TestEventDispatcher(); local
[all...]
H A Devent_handler.cc17 EventDispatcher* dispatcher = dispatchers_.top(); local
19 dispatcher->OnHandlerDestroyed(this);

Completed in 2020 milliseconds

12345678