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

123

/external/v8/test/mjsunit/regress/
H A Dregress-2539.js31 var dispatcher = {};
32 dispatcher.func = C;
40 dispatcher.func.apply(this, arguments);
/external/autotest/site_utils/rpm_control_system/
H A Drpm_dispatcher_unittest.py16 FAKE_DISPATCHER_URI = 'fake-dispatcher'
46 self.dispatcher = rpm_dispatcher.RPMDispatcher(FAKE_DISPATCHER_URI,
52 Make sure that as a dispatcher is initialized it properly registered
64 controller1 = self.dispatcher._get_rpm_controller(RPM_HOSTNAME)
65 controller2 = self.dispatcher._get_rpm_controller(RPM_HOSTNAME)
75 controller1 = self.dispatcher._get_rpm_controller(DUT_SAME_RPM1)
76 controller2 = self.dispatcher._get_rpm_controller(DUT_DIFFERENT_RPM)
H A Dfrontend_server.py51 forward the requests to an avaliable or already assigned RPM dispatcher
54 Once the dispatcher processes the request it will return the result
61 Used to choose the least loaded dispatcher.
62 @var _entry_dict: Maps dispatcher URI to an entry (list) inside the min
63 heap. If a dispatcher server shuts down this allows us to
67 @var _rpm_dict: Maps rpm hostname's to an already assigned dispatcher
101 to the appropriate dispatcher server.
155 Check to see if we can communicate with any dispatcher servers.
157 Only called in the situation that queuing a request to a dispatcher
160 @return: False if any dispatcher serve
[all...]
/external/okhttp/okhttp-tests/src/test/java/com/squareup/okhttp/
H A DDispatcherTest.java19 Dispatcher dispatcher = new Dispatcher(executor); field in class:DispatcherTest
20 OkHttpClient client = new OkHttpClient().setDispatcher(dispatcher);
23 dispatcher.setMaxRequests(20);
24 dispatcher.setMaxRequestsPerHost(10);
29 dispatcher.setMaxRequests(0);
37 dispatcher.setMaxRequestsPerHost(0);
49 dispatcher.setMaxRequests(3);
58 dispatcher.setMaxRequestsPerHost(2);
66 dispatcher.setMaxRequests(2);
72 dispatcher
[all...]
/external/v8/test/mjsunit/compiler/
H A Dinline-function-apply.js35 var dispatcher = {};
37 dispatcher["const" + argumentsCount] = 0;
38 dispatcher.func = C;
52 var r = "B" + dispatcher.func.apply(this, arguments);
/external/jetty/src/java/org/eclipse/jetty/servlets/
H A DConcatServlet.java120 RequestDispatcher dispatcher=_context.getRequestDispatcher(parts[i]);
121 if (dispatcher!=null)
122 dispatcher.include(req,resp);
/external/libvncserver/examples/
H A D1instance.c78 int dispatch_event(single_instance_struct* str,event_dispatcher dispatcher,int usecs) argument
84 dispatcher(buffer);
89 int loop_if_server(single_instance_struct* str,event_dispatcher dispatcher) argument
94 dispatch_event(str,dispatcher,50);
/external/mockwebserver/src/test/java/com/google/mockwebserver/
H A DCustomDispatcherTest.java40 final Dispatcher dispatcher = new Dispatcher() {
48 mockWebServer.setDispatcher(dispatcher);
52 // Make sure our dispatcher got the request.
63 final Dispatcher dispatcher = new Dispatcher() {
72 mockWebServer.setDispatcher(dispatcher);
/external/okhttp/mockwebserver/src/test/java/com/squareup/okhttp/mockwebserver/
H A DCustomDispatcherTest.java40 final Dispatcher dispatcher = new Dispatcher() {
48 mockWebServer.setDispatcher(dispatcher);
52 // Make sure our dispatcher got the request.
63 final Dispatcher dispatcher = new Dispatcher() {
72 mockWebServer.setDispatcher(dispatcher);
/external/v8/src/
H A Doptimizing-compile-dispatcher.cc5 #include "src/optimizing-compile-dispatcher.h"
43 OptimizingCompileDispatcher* dispatcher = local
45 base::LockGuard<base::Mutex> lock_guard(&dispatcher->ref_count_mutex_);
46 ++dispatcher->ref_count_;
58 OptimizingCompileDispatcher* dispatcher = variable
63 if (dispatcher->recompilation_delay_ != 0) {
65 dispatcher->recompilation_delay_));
68 dispatcher->CompileNext(dispatcher->NextInput(true));
71 base::LockGuard<base::Mutex> lock_guard(&dispatcher
[all...]
/external/autotest/client/common_lib/cros/bluetooth/
H A Dbluetooth_gatt_server.py18 class BluetoothGATTServer(asyncore.dispatcher):
21 This class inherits asyncore.dispatcher to handle I/O on BLE socket.
37 asyncore.dispatcher.__init__(self, sock=sock)
71 from asyncore.dispatcher class.
/external/libchrome/base/
H A Drun_loop.cc32 RunLoop::RunLoop(MessagePumpDispatcher* dispatcher) argument
35 dispatcher_(dispatcher),
H A Drun_loop.h37 explicit RunLoop(MessagePumpDispatcher* dispatcher);
/external/guice/extensions/struts2/example/src/com/google/inject/struts2/example/
H A DExampleListener.java19 import org.apache.struts2.dispatcher.ng.filter.StrutsPrepareAndExecuteFilter;
/external/guice/extensions/servlet/test/com/google/inject/servlet/
H A DServletPipelineRequestDispatcherTest.java116 final RequestDispatcher dispatcher = new ManagedServletPipeline(
120 assertNotNull(dispatcher);
121 dispatcher.include(requestMock, createMock(HttpServletResponse.class));
186 final RequestDispatcher dispatcher = new ManagedServletPipeline(injector)
189 assertNotNull(dispatcher);
190 dispatcher.forward(requestMock, mockResponse);
258 final RequestDispatcher dispatcher = new ManagedServletPipeline(injector)
261 assertNotNull(dispatcher);
264 dispatcher.forward(mockRequest, mockResponse);
/external/okhttp/okhttp/src/main/java/com/squareup/okhttp/
H A DOkHttpClient.java174 private Dispatcher dispatcher; field in class:OkHttpClient
203 dispatcher = new Dispatcher();
208 this.dispatcher = okHttpClient.dispatcher;
509 * Sets the dispatcher used to set policy and execute asynchronous requests.
512 public OkHttpClient setDispatcher(Dispatcher dispatcher) { argument
513 if (dispatcher == null) throw new IllegalArgumentException("dispatcher == null");
514 this.dispatcher = dispatcher;
[all...]
/external/guice/extensions/servlet/src/com/google/inject/servlet/
H A DManagedFilterPipeline.java129 * is not called again). However, we can wrap requests with our own dispatcher to forward the
152 final RequestDispatcher dispatcher = servletPipeline.getRequestDispatcher(path);
154 return (null != dispatcher) ? dispatcher : super.getRequestDispatcher(path);
/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/chromium-trace/catapult/firefighter/default/tracing/third_party/components/polymer/
H A Dpolymer.js580 var dispatcher = {
832 dispatcher.boundHandler = dispatcher.eventHandler.bind(dispatcher);
833 dispatcher.boundGestureTrigger = dispatcher.gestureTrigger.bind(dispatcher);
834 scope.dispatcher = dispatcher;
847 var dep = dispatcher
[all...]
/external/chromium-trace/catapult/third_party/polymer/components/polymer/
H A Dpolymer.js580 var dispatcher = {
832 dispatcher.boundHandler = dispatcher.eventHandler.bind(dispatcher);
833 dispatcher.boundGestureTrigger = dispatcher.gestureTrigger.bind(dispatcher);
834 scope.dispatcher = dispatcher;
847 var dep = dispatcher
[all...]
/external/chromium-trace/catapult/tracing/third_party/components/polymer/
H A Dpolymer.js580 var dispatcher = {
832 dispatcher.boundHandler = dispatcher.eventHandler.bind(dispatcher);
833 dispatcher.boundGestureTrigger = dispatcher.gestureTrigger.bind(dispatcher);
834 scope.dispatcher = dispatcher;
847 var dep = dispatcher
[all...]
/external/webrtc/webrtc/base/
H A Dphysicalsocketserver_unittest.cc43 SocketDispatcher* dispatcher = new FakeSocketDispatcher(this); variable
44 if (dispatcher->Create(type)) {
45 return dispatcher;
47 delete dispatcher;
53 SocketDispatcher* dispatcher = new FakeSocketDispatcher(this); variable
54 if (dispatcher->Create(family, type)) {
55 return dispatcher;
57 delete dispatcher;
/external/guice/extensions/struts2/test/com/google/inject/struts2/
H A DStruts2FactoryTest.java19 import org.apache.struts2.dispatcher.ng.filter.StrutsPrepareAndExecuteFilter;
/external/parameter-framework/asio/include/asio/detail/
H A Dwrapped_handler.hpp37 bool operator()(Dispatcher& dispatcher, Handler&) const argument
39 return dispatcher.running_in_this_thread();
50 wrapped_handler(Dispatcher dispatcher, Handler& handler) argument
51 : dispatcher_(dispatcher),
/external/parameter-framework/asio-1.10.6/include/asio/detail/
H A Dwrapped_handler.hpp37 bool operator()(Dispatcher& dispatcher, Handler&) const argument
39 return dispatcher.running_in_this_thread();
50 wrapped_handler(Dispatcher dispatcher, Handler& handler) argument
51 : dispatcher_(dispatcher),

Completed in 855 milliseconds

123