HomeSort by relevance Sort by last modified time
    Searched refs:Dispatcher (Results 1 - 25 of 84) sorted by null

1 2 3 4

  /external/mockito/cglib-and-asm/src/org/mockito/cglib/proxy/
Dispatcher.java 23 public interface Dispatcher extends Callback {
CallbackInfo.java 57 new CallbackInfo(Dispatcher.class, DispatcherGenerator.INSTANCE),
  /external/mockwebserver/src/main/java/com/google/mockwebserver/
Dispatcher.java 21 public abstract class Dispatcher {
QueueDispatcher.java 23 * Default dispatcher that processes a script of responses. Populate the script by calling
26 public class QueueDispatcher extends Dispatcher {
  /external/okhttp/mockwebserver/src/main/java/com/squareup/okhttp/mockwebserver/
Dispatcher.java 19 public abstract class Dispatcher {
QueueDispatcher.java 23 * Default dispatcher that processes a script of responses. Populate the script
26 public class QueueDispatcher extends Dispatcher {
  /external/parameter-framework/asio-1.10.6/include/asio/detail/
wrapped_handler.hpp 27 template <typename Dispatcher, typename Handler>
28 bool operator()(Dispatcher&, Handler& handler) const
36 template <typename Dispatcher, typename Handler>
37 bool operator()(Dispatcher& dispatcher, Handler&) const
39 return dispatcher.running_in_this_thread();
43 template <typename Dispatcher, typename Handler,
50 wrapped_handler(Dispatcher dispatcher, Handler& handler)
51 : dispatcher_(dispatcher),
    [all...]
  /external/webrtc/webrtc/base/
physicalsocketserver.h 28 // Event constants for the Dispatcher class.
42 class Dispatcher {
44 virtual ~Dispatcher() {}
78 void Add(Dispatcher* dispatcher);
79 void Remove(Dispatcher* dispatcher);
97 Dispatcher* signal_dispatcher();
101 typedef std::vector<Dispatcher*> DispatcherList;
185 class SocketDispatcher : public Dispatcher, public PhysicalSocket
    [all...]
physicalsocketserver.cc 764 class EventDispatcher : public Dispatcher {
930 class PosixSignalDispatcher : public Dispatcher {
999 class FileDispatcher: public Dispatcher, public AsyncFile {
1070 class EventDispatcher : public Dispatcher {
    [all...]
  /external/mockwebserver/src/test/java/com/google/mockwebserver/
CustomDispatcherTest.java 40 final Dispatcher dispatcher = new Dispatcher() { local
48 mockWebServer.setDispatcher(dispatcher);
52 // Make sure our dispatcher got the request.
63 final Dispatcher dispatcher = new Dispatcher() { local
72 mockWebServer.setDispatcher(dispatcher);
  /external/okhttp/mockwebserver/src/test/java/com/squareup/okhttp/mockwebserver/
CustomDispatcherTest.java 40 final Dispatcher dispatcher = new Dispatcher() { local
48 mockWebServer.setDispatcher(dispatcher);
52 // Make sure our dispatcher got the request.
63 final Dispatcher dispatcher = new Dispatcher() { local
72 mockWebServer.setDispatcher(dispatcher);
  /external/jetty/src/java/org/eclipse/jetty/servlet/
JspPropertyGroupServlet.java 29 import org.eclipse.jetty.server.Dispatcher;
108 if (request.getAttribute(Dispatcher.INCLUDE_REQUEST_URI)!=null)
110 servletPath=(String)request.getAttribute(Dispatcher.INCLUDE_SERVLET_PATH);
111 pathInfo=(String)request.getAttribute(Dispatcher.INCLUDE_PATH_INFO);
Invoker.java 36 import org.eclipse.jetty.server.Dispatcher;
119 String servlet_path=(String)request.getAttribute(Dispatcher.INCLUDE_SERVLET_PATH);
124 String path_info = (String)request.getAttribute(Dispatcher.INCLUDE_PATH_INFO);
287 if (name.equals(Dispatcher.INCLUDE_REQUEST_URI))
289 if (name.equals(Dispatcher.INCLUDE_PATH_INFO))
291 if (name.equals(Dispatcher.INCLUDE_SERVLET_PATH))
  /external/okhttp/okhttp/src/main/java/com/squareup/okhttp/
Dispatcher.java 32 * <p>Each dispatcher uses an {@link ExecutorService} to run calls internally. If you
36 public final class Dispatcher {
52 public Dispatcher(ExecutorService executorService) {
56 public Dispatcher() {
62 new SynchronousQueue<Runnable>(), Util.threadFactory("OkHttp Dispatcher", false));
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) {
513 if (dispatcher == null) throw new IllegalArgumentException("dispatcher == null")
    [all...]
  /external/okhttp/benchmarks/src/main/java/com/squareup/okhttp/benchmarks/
OkHttpAsync.java 19 import com.squareup.okhttp.Dispatcher;
52 client.setDispatcher(new Dispatcher(new ThreadPoolExecutor(benchmark.concurrencyLevel,
Benchmark.java 24 import com.squareup.okhttp.mockwebserver.Dispatcher;
170 server.setDispatcher(new Dispatcher() {
  /libcore/benchmarks/src/benchmarks/regression/
URLConnectionBenchmark.java 20 import com.google.mockwebserver.Dispatcher;
41 private static class SingleResponseDispatcher extends Dispatcher {
  /external/opencv3/modules/cudev/include/opencv2/cudev/block/
reduce.hpp 65 block_reduce_detail::Dispatcher<N>::reductor::template reduce<volatile T*, T&, const Op&>(smem, val, tid, op);
77 block_reduce_detail::Dispatcher<N>::reductor::template reduce<
88 block_reduce_key_val_detail::Dispatcher<N>::reductor::template reduce<volatile K*, K&, volatile V*, V&, const Cmp&>(skeys, key, svals, val, tid, cmp);
101 block_reduce_key_val_detail::Dispatcher<N>::reductor::template reduce<volatile K*, K&,
120 block_reduce_key_val_detail::Dispatcher<N>::reductor::template reduce<
  /libcore/luni/src/test/java/org/apache/harmony/luni/tests/internal/net/www/protocol/https/
HttpsURLConnectionTest.java 20 import com.google.mockwebserver.Dispatcher;
135 SingleRequestDispatcher dispatcher = new SingleRequestDispatcher(GET_METHOD, OK_CODE); local
136 MockWebServer webServer = createWebServer(ctx, dispatcher);
146 checkConnectionStateParameters(connection, dispatcher.getLastRequest());
167 SingleRequestDispatcher dispatcher = local
169 MockWebServer webServer = createWebServer(ctx, dispatcher);
213 SingleRequestDispatcher dispatcher = new SingleRequestDispatcher(GET_METHOD, OK_CODE); local
214 MockWebServer webServer = createWebServer(ctx, dispatcher);
226 checkConnectionStateParameters(connection, dispatcher.getLastRequest());
253 SingleRequestDispatcher dispatcher = new SingleRequestDispatcher(GET_METHOD, OK_CODE) local
329 SingleRequestDispatcher dispatcher = new SingleRequestDispatcher(GET_METHOD, OK_CODE); local
362 SingleRequestDispatcher dispatcher = new SingleRequestDispatcher(POST_METHOD, OK_CODE); local
    [all...]
  /external/okhttp/samples/static-server/src/main/java/com/squareup/okhttp/sample/
SampleServer.java 4 import com.squareup.okhttp.mockwebserver.Dispatcher;
22 public class SampleServer extends Dispatcher {
  /external/jetty/src/java/org/eclipse/jetty/server/handler/
ErrorHandler.java 35 import org.eclipse.jetty.server.Dispatcher;
81 Dispatcher dispatcher = (Dispatcher) request.getServletContext().getRequestDispatcher(error_page); local
84 if(dispatcher!=null)
86 dispatcher.error(request, response);
ResourceHandler.java 38 import org.eclipse.jetty.server.Dispatcher;
322 Boolean included = request.getAttribute(Dispatcher.INCLUDE_REQUEST_URI) != null;
325 servletPath = (String)request.getAttribute(Dispatcher.INCLUDE_SERVLET_PATH);
326 pathInfo = (String)request.getAttribute(Dispatcher.INCLUDE_PATH_INFO);
  /external/jetty/src/java/org/eclipse/jetty/server/
Dispatcher.java 47 public class Dispatcher implements RequestDispatcher
72 public Dispatcher(ContextHandler contextHandler, String uri, String pathInContext, String query)
87 public Dispatcher(ContextHandler contextHandler,String name)
346 if (Dispatcher.this._named==null)
465 if (Dispatcher.this._named==null)
  /external/okhttp/okhttp-tests/src/test/java/com/squareup/okhttp/
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)
    [all...]

Completed in 498 milliseconds

1 2 3 4