| /external/okhttp/okhttp-tests/src/test/java/com/squareup/okhttp/ |
| D | DispatcherTest.java | 19 Dispatcher dispatcher = new Dispatcher(executor); field in DispatcherTest
20 OkHttpClient client = new OkHttpClient().setDispatcher(dispatcher);
23 dispatcher.setMaxRequests(20); in setUp()
24 dispatcher.setMaxRequestsPerHost(10); in setUp()
29 dispatcher.setMaxRequests(0); in maxRequestsZero()
37 dispatcher.setMaxRequestsPerHost(0); in maxPerHostZero()
49 dispatcher.setMaxRequests(3); in maxRequestsEnforced()
58 dispatcher.setMaxRequestsPerHost(2); in maxPerHostEnforced()
66 dispatcher.setMaxRequests(2); in increasingMaxRequestsPromotesJobsImmediately()
72 dispatcher.setMaxRequests(4); in increasingMaxRequestsPromotesJobsImmediately()
[all …]
|
| /external/autotest/site_utils/rpm_control_system/ |
| D | rpm_dispatcher_unittest.py | 46 self.dispatcher = rpm_dispatcher.RPMDispatcher(FAKE_DISPATCHER_URI,
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)
|
| D | frontend_server.py | 164 dispatcher = xmlrpclib.ServerProxy(
167 if dispatcher.is_up():
314 for rpm, dispatcher in self._rpm_dict.items():
315 if dispatcher == uri_to_unregister:
|
| /external/v8/src/ |
| D | optimizing-compile-dispatcher.cc | 43 OptimizingCompileDispatcher* dispatcher = in CompileTask() local
45 base::LockGuard<base::Mutex> lock_guard(&dispatcher->ref_count_mutex_); in CompileTask()
46 ++dispatcher->ref_count_; in CompileTask()
58 OptimizingCompileDispatcher* dispatcher = in Run() local
63 if (dispatcher->recompilation_delay_ != 0) { in Run()
65 dispatcher->recompilation_delay_)); in Run()
68 dispatcher->CompileNext(dispatcher->NextInput(true)); in Run()
71 base::LockGuard<base::Mutex> lock_guard(&dispatcher->ref_count_mutex_); in Run()
72 if (--dispatcher->ref_count_ == 0) { in Run()
73 dispatcher->ref_count_zero_.NotifyOne(); in Run()
|
| /external/v8/test/mjsunit/compiler/ |
| 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/v8/test/mjsunit/regress/ |
| D | regress-2539.js | 31 var dispatcher = {}; variable
32 dispatcher.func = C;
40 dispatcher.func.apply(this, arguments);
|
| /external/mockwebserver/src/test/java/com/google/mockwebserver/ |
| D | CustomDispatcherTest.java | 40 final Dispatcher dispatcher = new Dispatcher() { in testSimpleDispatch() local
48 mockWebServer.setDispatcher(dispatcher); in testSimpleDispatch()
63 final Dispatcher dispatcher = new Dispatcher() { in testOutOfOrderResponses() local
72 mockWebServer.setDispatcher(dispatcher); in testOutOfOrderResponses()
|
| /external/mockwebserver/src/main/java/com/google/mockwebserver/ |
| D | MockWebServer.java | 93 private Dispatcher dispatcher = new QueueDispatcher(); field in MockWebServer
191 ((QueueDispatcher) dispatcher).enqueueResponse(response.clone()); in enqueue()
269 SocketPolicy socketPolicy = dispatcher.peek().getSocketPolicy(); in play()
307 SocketPolicy socketPolicy = dispatcher.peek().getSocketPolicy(); in serveConnection()
348 SocketPolicy socketPolicy = dispatcher.peek().getSocketPolicy(); in serveConnection()
368 MockResponse response = dispatcher.dispatch(request); in serveConnection()
424 dispatcher.dispatch(request); in dispatchBookkeepingRequest()
471 MockResponse throttlePolicy = dispatcher.peek(); in readRequest()
588 public void setDispatcher(Dispatcher dispatcher) { in setDispatcher() argument
589 if (dispatcher == null) { in setDispatcher()
[all …]
|
| /external/libvncserver/examples/ |
| D | 1instance.c | 78 int dispatch_event(single_instance_struct* str,event_dispatcher dispatcher,int usecs) in dispatch_event() argument
84 dispatcher(buffer); in dispatch_event()
89 int loop_if_server(single_instance_struct* str,event_dispatcher dispatcher) in loop_if_server() argument
94 dispatch_event(str,dispatcher,50); in loop_if_server()
|
| /external/okhttp/mockwebserver/src/test/java/com/squareup/okhttp/mockwebserver/ |
| D | CustomDispatcherTest.java | 40 final Dispatcher dispatcher = new Dispatcher() { in simpleDispatch() local
48 mockWebServer.setDispatcher(dispatcher); in simpleDispatch()
63 final Dispatcher dispatcher = new Dispatcher() { in outOfOrderResponses() local
72 mockWebServer.setDispatcher(dispatcher); in outOfOrderResponses()
|
| /external/guice/extensions/servlet/test/com/google/inject/servlet/ |
| D | ServletPipelineRequestDispatcherTest.java | 116 final RequestDispatcher dispatcher = new ManagedServletPipeline( in testIncludeManagedServlet() local
120 assertNotNull(dispatcher); in testIncludeManagedServlet()
121 dispatcher.include(requestMock, createMock(HttpServletResponse.class)); in testIncludeManagedServlet()
186 final RequestDispatcher dispatcher = new ManagedServletPipeline(injector) in testForwardToManagedServlet() local
189 assertNotNull(dispatcher); in testForwardToManagedServlet()
190 dispatcher.forward(requestMock, mockResponse); in testForwardToManagedServlet()
258 final RequestDispatcher dispatcher = new ManagedServletPipeline(injector) in forwardToManagedServletFailureOnCommittedBuffer() local
261 assertNotNull(dispatcher); in forwardToManagedServletFailureOnCommittedBuffer()
264 dispatcher.forward(mockRequest, mockResponse); in forwardToManagedServletFailureOnCommittedBuffer()
|
| /external/jetty/src/java/org/eclipse/jetty/servlets/ |
| D | ConcatServlet.java | 120 RequestDispatcher dispatcher=_context.getRequestDispatcher(parts[i]); in doGet() local
121 if (dispatcher!=null) in doGet()
122 dispatcher.include(req,resp); in doGet()
|
| /external/webrtc/webrtc/base/ |
| D | physicalsocketserver_unittest.cc | 43 SocketDispatcher* dispatcher = new FakeSocketDispatcher(this); in CreateAsyncSocket() local
44 if (dispatcher->Create(type)) { in CreateAsyncSocket()
45 return dispatcher; in CreateAsyncSocket()
47 delete dispatcher; in CreateAsyncSocket()
53 SocketDispatcher* dispatcher = new FakeSocketDispatcher(this); in CreateAsyncSocket() local
54 if (dispatcher->Create(family, type)) { in CreateAsyncSocket()
55 return dispatcher; in CreateAsyncSocket()
57 delete dispatcher; in CreateAsyncSocket()
|
| D | macsocketserver.cc | 66 Dispatcher* dispatcher = signal_dispatcher(); in SetPosixSignalHandler() local
72 if (!dispatcher && (dispatcher = signal_dispatcher())) { in SetPosixSignalHandler()
78 dispatcher->GetDescriptor(), in SetPosixSignalHandler()
|
| /external/okhttp/okhttp/src/main/java/com/squareup/okhttp/ |
| D | OkHttpClient.java | 174 private Dispatcher dispatcher; field in OkHttpClient
203 dispatcher = new Dispatcher(); in OkHttpClient()
208 this.dispatcher = okHttpClient.dispatcher; in OkHttpClient()
512 public OkHttpClient setDispatcher(Dispatcher dispatcher) { in setDispatcher() argument
513 if (dispatcher == null) throw new IllegalArgumentException("dispatcher == null"); in setDispatcher()
514 this.dispatcher = dispatcher; in setDispatcher()
519 return dispatcher; in getDispatcher()
|
| /external/guice/extensions/servlet/src/com/google/inject/servlet/ |
| D | ManagedFilterPipeline.java | 152 final RequestDispatcher dispatcher = servletPipeline.getRequestDispatcher(path); in withDispatcher()
154 return (null != dispatcher) ? dispatcher : super.getRequestDispatcher(path); in withDispatcher()
|
| /external/okhttp/mockwebserver/src/main/java/com/squareup/okhttp/mockwebserver/ |
| D | MockWebServer.java | 124 private Dispatcher dispatcher = new QueueDispatcher(); field in MockWebServer
305 ((QueueDispatcher) dispatcher).enqueueResponse(response.clone());
385 SocketPolicy socketPolicy = dispatcher.peek().getSocketPolicy();
438 SocketPolicy socketPolicy = dispatcher.peek().getSocketPolicy();
503 SocketPolicy socketPolicy = dispatcher.peek().getSocketPolicy();
523 MockResponse response = dispatcher.dispatch(request);
582 dispatcher.dispatch(new RecordedRequest(null, null, null, -1, null, sequenceNumber, socket));
629 MockResponse policy = dispatcher.peek();
806 public void setDispatcher(Dispatcher dispatcher) {
807 if (dispatcher == null) throw new NullPointerException();
[all …]
|
| /external/autotest/client/common_lib/cros/bluetooth/ |
| D | bluetooth_gatt_server.py | 18 class BluetoothGATTServer(asyncore.dispatcher):
37 asyncore.dispatcher.__init__(self, sock=sock)
|
| /external/libchrome/base/ |
| D | run_loop.cc | 32 RunLoop::RunLoop(MessagePumpDispatcher* dispatcher) in RunLoop() argument
35 dispatcher_(dispatcher), in RunLoop()
|
| /external/parameter-framework/asio-1.10.6/include/asio/detail/ |
| D | wrapped_handler.hpp | 37 bool operator()(Dispatcher& dispatcher, Handler&) const in operator ()()
39 return dispatcher.running_in_this_thread(); in operator ()()
50 wrapped_handler(Dispatcher dispatcher, Handler& handler) in wrapped_handler() argument
51 : dispatcher_(dispatcher), in wrapped_handler()
|
| /external/chromium-trace/catapult/tracing/third_party/components/polymer/ |
| D | polymer.js | 580 var dispatcher = { variable
832 dispatcher.boundHandler = dispatcher.eventHandler.bind(dispatcher);
833 dispatcher.boundGestureTrigger = dispatcher.gestureTrigger.bind(dispatcher);
834 scope.dispatcher = dispatcher;
847 var dep = dispatcher.dependencyMap[g];
849 var recognizer = dispatcher.gestures[dep.index];
851 dispatcher.register(node);
909 var dep = dispatcher.dependencyMap[g];
915 dispatcher.unregister(node);
945 var dispatcher = scope.dispatcher;
[all …]
|
| /external/chromium-trace/catapult/third_party/polymer/components/polymer/ |
| D | polymer.js | 580 var dispatcher = { variable
832 dispatcher.boundHandler = dispatcher.eventHandler.bind(dispatcher);
833 dispatcher.boundGestureTrigger = dispatcher.gestureTrigger.bind(dispatcher);
834 scope.dispatcher = dispatcher;
847 var dep = dispatcher.dependencyMap[g];
849 var recognizer = dispatcher.gestures[dep.index];
851 dispatcher.register(node);
909 var dep = dispatcher.dependencyMap[g];
915 dispatcher.unregister(node);
945 var dispatcher = scope.dispatcher;
[all …]
|
| /external/autotest/scheduler/ |
| D | scheduler_models_unittest.py | 267 dispatcher = self.god.create_mock_class(monitor_db.BaseDispatcher,
270 dispatcher.get_agents_for_entry.expect_call(hqe).and_return([agent])
272 return hqe, dispatcher
278 hqe, dispatcher = self.setup_abort_test(agent_finished=False)
281 hqe.abort(dispatcher)
290 hqe, dispatcher = self.setup_abort_test(agent_finished=True)
292 hqe.abort(dispatcher)
|
| /external/jetty/src/java/org/eclipse/jetty/server/handler/ |
| D | ErrorHandler.java | 81 … Dispatcher dispatcher = (Dispatcher) request.getServletContext().getRequestDispatcher(error_page); in handle() local
84 if(dispatcher!=null) in handle()
86 dispatcher.error(request, response); in handle()
|
| /external/chromium-trace/catapult/third_party/webapp2/docs/guide/ |
| D | handlers.rst | 133 default dispatcher implementation, if a handler returns anything that is not
151 this possible. To achieve it, we need to extend the router dispatcher to build
155 dispatcher and a handler that returns a string::
175 And that's all. Now we have a custom dispatcher set using the router method
179 Our custom dispatcher could implement its own URI matching and handler
181 default dispatcher a little bit, wrapping the returned value under certain
188 Following the previous idea of a custom dispatcher, we could go a little
|