/external/v8/test/mjsunit/regress/ |
H A D | regress-2539.js | 31 var dispatcher = {}; 32 dispatcher.func = C; 40 dispatcher.func.apply(this, arguments);
|
/external/autotest/site_utils/rpm_control_system/ |
H A D | rpm_dispatcher_unittest.py | 16 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 D | frontend_server.py | 51 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 D | DispatcherTest.java | 19 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 D | inline-function-apply.js | 35 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 D | ConcatServlet.java | 120 RequestDispatcher dispatcher=_context.getRequestDispatcher(parts[i]); 121 if (dispatcher!=null) 122 dispatcher.include(req,resp);
|
/external/libvncserver/examples/ |
H A D | 1instance.c | 78 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 D | CustomDispatcherTest.java | 40 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 D | CustomDispatcherTest.java | 40 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 D | optimizing-compile-dispatcher.cc | 5 #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 D | bluetooth_gatt_server.py | 18 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 D | run_loop.cc | 32 RunLoop::RunLoop(MessagePumpDispatcher* dispatcher) argument 35 dispatcher_(dispatcher),
|
H A D | run_loop.h | 37 explicit RunLoop(MessagePumpDispatcher* dispatcher);
|
/external/guice/extensions/struts2/example/src/com/google/inject/struts2/example/ |
H A D | ExampleListener.java | 19 import org.apache.struts2.dispatcher.ng.filter.StrutsPrepareAndExecuteFilter;
|
/external/guice/extensions/servlet/test/com/google/inject/servlet/ |
H A D | ServletPipelineRequestDispatcherTest.java | 116 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 D | OkHttpClient.java | 174 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 D | ManagedFilterPipeline.java | 129 * 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 D | MockWebServer.java | 93 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 D | polymer.js | 580 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 D | polymer.js | 580 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 D | polymer.js | 580 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 D | physicalsocketserver_unittest.cc | 43 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 D | Struts2FactoryTest.java | 19 import org.apache.struts2.dispatcher.ng.filter.StrutsPrepareAndExecuteFilter;
|
/external/parameter-framework/asio/include/asio/detail/ |
H A D | wrapped_handler.hpp | 37 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 D | wrapped_handler.hpp | 37 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),
|