| /system/webservd/libwebserv/ |
| request_utils.cc | 20 #include <libwebserv/request.h>
28 std::unique_ptr<Request> request; member in struct:libwebserv::__anon73688::RequestDataContainer
42 container->success_callback.Run(std::move(container->request),
51 container->error_callback.Run(std::move(container->request),
57 void GetRequestData(std::unique_ptr<Request> request,
62 auto in_stream = request->GetDataStream();
65 container->request = std::move(request);
[all...] |
| /system/webservd/test-client/ |
| main.cc | 45 using libwebserv::Request;
62 void HandleRequest(std::unique_ptr<Request> /* request */,
|
| /external/guava/guava-tests/test/com/google/common/util/concurrent/ |
| TestThread.java | 61 private final SynchronousQueue<Request> requestQueue = new SynchronousQueue<Request>();
188 * @throws TimeoutException if this thread does not accept the request within a resonable amount
193 new Request(methodName, arguments), TIMEOUT_MILLIS, TimeUnit.MILLISECONDS)) {
238 Request request = requestQueue.take(); local
241 result = invokeMethod(request.methodName, request.arguments);
246 new Response(request.methodName, null, exception.getTargetException()));
249 responseQueue.put(new Response(request.methodName, null, throwable))
[all...] |
| /external/okhttp/okhttp-ws/src/main/java/com/squareup/okhttp/ws/ |
| WebSocketCall.java | 22 import com.squareup.okhttp.Request;
44 * Prepares the {@code request} to create a web socket at some point in the future.
46 public static WebSocketCall create(OkHttpClient client, Request request) {
47 return new WebSocketCall(client, request);
50 private final Request request; field in class:WebSocketCall
55 WebSocketCall(OkHttpClient client, Request request) {
56 this(client, request, new SecureRandom())
[all...] |
| /frameworks/volley/src/test/java/com/android/volley/ |
| RequestQueueIntegrationTest.java | 19 import com.android.volley.Request.Priority;
62 // Enqueue 2 requests with different cache keys, and different priorities. The second, higher priority request
64 // Assert that first request is only handled after the first one has been parsed and delivered.
80 //delay only for higher request
106 // Enqueue 2 requests with the same cache key. The first request takes 20ms. Assert that the
107 // second request is only handled after the first one has been parsed and delivered.
108 Request req1 = new MockRequest();
109 Request req2 = new MockRequest();
139 * Needs to be an integration test because relies on Request -> dispatcher -> RequestQueue interaction
143 Request request = new MockRequest() local
171 Request request = new MockRequest(); local
194 Request request = new MockRequest(); local
[all...] |
| /external/valgrind/coregrind/m_syswrap/ |
| syswrap-darwin.c | 782 // we must always honour the resync request.
[all...] |
| /external/nist-sip/java/gov/nist/javax/sip/stack/ |
| SIPClientTransaction.java | 67 import javax.sip.message.Request;
127 * |Request from TU
128 * |send request
130 * send request +-----------+
300 // once with an outstanding request.
397 * Send a request message through this transaction and onto the client.
399 * @param messageToSend Request to process and send.
404 // Message typecast as a request
421 // If this is the first request for this transaction,
425 // If this is a TU-generated ACK request,
[all...] |
| SIPServerTransaction.java | 60 import javax.sip.message.Request;
121 * Request received
134 * Request V 1xx from TU |
145 * | Request V |
417 // to the source of the original request
510 // Only one outstanding request for a given server tx.
566 if ((method.equals(Request.INVITE) || !isTerminated())) {
592 if (method.equals(Request.CANCEL)) {
596 transactionMatches = this.getMethod().equals(Request.CANCEL)
619 // a CANCEL request, which is not deeme
[all...] |
| /external/okhttp/okhttp-android-support/src/test/java/com/squareup/okhttp/internal/huc/ |
| JavaApiConverterTest.java | 22 import com.squareup.okhttp.Request;
105 Request request = new Request.Builder().url(uri.toURL()).build(); local
119 Response response = JavaApiConverter.createOkResponseForCacheGet(request, cacheResponse);
120 Request cacheRequest = response.request();
121 assertEquals(request.httpUrl(), cacheRequest.httpUrl());
122 assertEquals(request.method(), cacheRequest.method());
123 assertEquals(0, request.headers().size())
137 Request request = new Request.Builder().url(uri.toURL()).build(); local
165 Request request = new Request.Builder().url(uri.toURL()).build(); local
225 Request request = JavaApiConverter.createOkRequest(uri, "POST", javaRequestHeaders); local
238 Request request = JavaApiConverter.createOkRequest(uri, "POST", javaRequestHeaders); local
257 Request request = JavaApiConverter.createOkRequest(uri, "POST", javaRequestHeaders); local
[all...] |
| /external/nist-sip/java/gov/nist/javax/sip/ |
| DialogFilter.java | 68 import javax.sip.message.Request;
103 * Send back a Request Pending response.
119 if (sipRequest.getMethod().equals(Request.INVITE)) {
132 * Send a BAD REQUEST response.
149 if (sipRequest.getMethod().equals(Request.INVITE)) {
180 if (sipRequest.getMethod().equals(Request.INVITE)) {
234 sipResponse.setReasonPhrase("Request out of order");
255 * Process a request. Check for various conditions in the dialog that can result in the
258 * @exception SIPServerException is thrown when there is an error processing the request.
264 "PROCESSING INCOMING REQUEST " + sipRequest + " transactionChannel =
[all...] |
| /external/okhttp/okhttp/src/main/java/com/squareup/okhttp/ |
| Connection.java | 51 * used for multiple HTTP request/response exchanges. Connections may be direct
59 * which isn't so much a connection as a single request/response exchange.
152 void connect(int connectTimeout, int readTimeout, int writeTimeout, Request request,
172 connectSocket(connectTimeout, readTimeout, writeTimeout, request,
194 Request request, ConnectionSpecSelector connectionSpecSelector) throws IOException {
199 connectTls(readTimeout, writeTimeout, request, connectionSpecSelector);
212 private void connectTls(int readTimeout, int writeTimeout, Request request,
368 request, connectionSpecs, client.getRetryOnConnectionFailure()); local
[all...] |
| Request.java | 25 * An HTTP request. Instances of this class are immutable if their {@link #body}
28 public final class Request {
39 private Request(Builder builder) {
111 return "Request{method="
132 private Builder(Request request) {
133 this.url = request.url;
134 this.method = request.method;
135 this.body = request.body;
136 this.tag = request.tag
[all...] |
| /prebuilts/gdb/darwin-x86/lib/python2.7/test/ |
| test_urllib2.py | 9 from urllib2 import Request, OpenerDirector
12 # Request
53 The Request.headers dictionary is not a documented interface. It should
71 >>> Request(url, headers={"Spam-eggs": "blah"}).headers["Spam-eggs"]
73 >>> Request(url, headers={"spam-EggS": "blah"}).headers["Spam-eggs"]
76 Currently, Request(url, "Spam-eggs").headers["Spam-Eggs"] raises KeyError,
89 >>> r = Request(url, headers={"Spam-eggs": "blah"})
252 def add_cookie_header(self, request):
253 self.ach_req = request
254 def extract_cookies(self, response, request)
297 def request(self, method, url, body=None, headers=None): member in class:MockHTTPClass
[all...] |
| /prebuilts/gdb/linux-x86/lib/python2.7/test/ |
| test_urllib2.py | 9 from urllib2 import Request, OpenerDirector
12 # Request
53 The Request.headers dictionary is not a documented interface. It should
71 >>> Request(url, headers={"Spam-eggs": "blah"}).headers["Spam-eggs"]
73 >>> Request(url, headers={"spam-EggS": "blah"}).headers["Spam-eggs"]
76 Currently, Request(url, "Spam-eggs").headers["Spam-Eggs"] raises KeyError,
89 >>> r = Request(url, headers={"Spam-eggs": "blah"})
252 def add_cookie_header(self, request):
253 self.ach_req = request
254 def extract_cookies(self, response, request)
297 def request(self, method, url, body=None, headers=None): member in class:MockHTTPClass
[all...] |
| /prebuilts/python/darwin-x86/2.7.5/lib/python2.7/test/ |
| test_urllib2.py | 9 from urllib2 import Request, OpenerDirector
12 # Request
53 The Request.headers dictionary is not a documented interface. It should
71 >>> Request(url, headers={"Spam-eggs": "blah"}).headers["Spam-eggs"]
73 >>> Request(url, headers={"spam-EggS": "blah"}).headers["Spam-eggs"]
76 Currently, Request(url, "Spam-eggs").headers["Spam-Eggs"] raises KeyError,
89 >>> r = Request(url, headers={"Spam-eggs": "blah"})
252 def add_cookie_header(self, request):
253 self.ach_req = request
254 def extract_cookies(self, response, request)
297 def request(self, method, url, body=None, headers=None): member in class:MockHTTPClass
[all...] |
| /prebuilts/python/linux-x86/2.7.5/lib/python2.7/test/ |
| test_urllib2.py | 9 from urllib2 import Request, OpenerDirector
12 # Request
53 The Request.headers dictionary is not a documented interface. It should
71 >>> Request(url, headers={"Spam-eggs": "blah"}).headers["Spam-eggs"]
73 >>> Request(url, headers={"spam-EggS": "blah"}).headers["Spam-eggs"]
76 Currently, Request(url, "Spam-eggs").headers["Spam-Eggs"] raises KeyError,
89 >>> r = Request(url, headers={"Spam-eggs": "blah"})
252 def add_cookie_header(self, request):
253 self.ach_req = request
254 def extract_cookies(self, response, request)
297 def request(self, method, url, body=None, headers=None): member in class:MockHTTPClass
[all...] |
| /external/chromium-trace/catapult/third_party/webapp2/tests/ |
| extras_auth_test.py | 30 req = webapp2.Request.blank('/')
34 a = auth.Auth(request=req)
35 session_store = sessions.get_store(request=req)
66 req = webapp2.Request.blank('/', headers=[('Cookie', cookies)])
69 a = auth.Auth(request=req)
106 req = webapp2.Request.blank('/')
109 a = auth.get_auth(request=req)
110 session_store = sessions.get_store(request=req)
143 req = webapp2.Request.blank('/')
160 req = webapp2.Request.blank('/'
[all...] |
| /external/webrtc/webrtc/p2p/stunprober/ |
| stunprober.cc | 44 // Each Request maps to a request and response.
45 struct Request {
46 // Actual time the STUN bind request was sent.
51 // Server reflexive address from STUN response for this given request.
69 // expected to be completed immediately. Otherwise, it'll skip this request
79 const std::vector<Request*>& requests() { return requests_; }
87 Request* GetRequestByAddress(const rtc::IPAddress& ip);
98 std::vector<Request*> requests_;
134 requests_.push_back(new Request());
135 Request& request = *(requests_.back()); local
207 Request* request = GetRequestByAddress(addr.ipaddr()); local
[all...] |
| /external/okhttp/okhttp-apache/src/main/java/com/squareup/okhttp/apache/ |
| OkApacheClient.java | 6 import com.squareup.okhttp.Request;
42 private static Request transformRequest(HttpRequest request) {
43 Request.Builder builder = new Request.Builder();
45 RequestLine requestLine = request.getRequestLine();
50 for (Header header : request.getAllHeaders()) {
60 if (request instanceof HttpEntityEnclosingRequest) {
61 HttpEntity entity = ((HttpEntityEnclosingRequest) request).getEntity();
156 @Override public HttpResponse execute(HttpUriRequest request) throws IOException
[all...] |
| /frameworks/volley/src/main/java/com/android/volley/toolbox/ |
| HttpClientStack.java | 20 import com.android.volley.Request;
21 import com.android.volley.Request.Method;
48 * An HttpStack that performs request over an {@link HttpClient}.
75 public HttpResponse performRequest(Request<?> request, Map<String, String> additionalHeaders)
77 HttpUriRequest httpRequest = createHttpRequest(request, additionalHeaders);
79 addHeaders(httpRequest, request.getHeaders());
82 int timeoutMs = request.getTimeoutMs();
91 * Creates the appropriate subclass of HttpUriRequest for passed in request.
94 /* protected */ static HttpUriRequest createHttpRequest(Request<?> request
[all...] |
| /system/weaved/buffet/ |
| webserv_client.cc | 21 #include <libwebserv/request.h>
34 class RequestImpl : public HttpServer::Request {
36 explicit RequestImpl(std::unique_ptr<libwebserv::Request> request,
38 : request_{std::move(request)}, response_{std::move(response)} {}
41 // HttpServer::Request implementation.
82 std::unique_ptr<libwebserv::Request> request_;
144 std::unique_ptr<libwebserv::Request> request,
146 std::unique_ptr<Request> weave_request
[all...] |
| /packages/apps/ContactsCommon/src/com/android/contacts/common/ |
| ContactPhotoManager.java | 121 * draw a letter tile avatar based on the request parameters defined in the
128 // Cache and return the letter tile drawable that is created by a null request,
140 * Given a {@link DefaultImageRequest}, returns an Uri that can be used to request a
145 * @param request A {@link DefaultImageRequest} object with the fields configured
149 * used to request a default contact image, drawn as a letter tile using the
152 public static Uri getDefaultAvatarUriForContact(DefaultImageRequest request) {
154 if (request != null) {
155 if (!TextUtils.isEmpty(request.displayName)) {
156 builder.appendQueryParameter(DISPLAY_NAME_PARAM_KEY, request.displayName);
158 if (!TextUtils.isEmpty(request.identifier))
228 final DefaultImageRequest request = new DefaultImageRequest( local
860 DefaultImageRequest request = getDefaultImageRequestFromUri(uri); local
978 getDrawableForBitmap(mContext.getResources(), cachedBitmap, request)); local
1223 Request request = Request.createFromUri(photoUri, smallerExtent, false \/* darkTheme *\/, local
1254 Request request = iterator.next(); local
1706 final DefaultImageRequest request; local
[all...] |
| /external/bouncycastle/bcpkix/src/main/java/org/bouncycastle/cert/ocsp/ |
| OCSPReqBuilder.java | 13 import org.bouncycastle.asn1.ocsp.Request;
42 public Request toRequest()
45 return new Request(certId.toASN1Primitive(), extensions);
50 * Add a request for the given CertificateID.
63 * Add a request with extensions
66 * @param singleRequestExtensions the extensions to attach to the request
123 throw new OCSPException("exception creating Request", e);
135 throw new OCSPException("requestorName must be specified if request is signed.");
176 * Generate an unsigned request
|
| /external/glide/library/src/main/java/com/bumptech/glide/request/ |
| RequestFutureTarget.java | 1 package com.bumptech.glide.request;
6 import com.bumptech.glide.request.animation.GlideAnimation;
7 import com.bumptech.glide.request.target.SizeReadyCallback;
49 private Request request; field in class:RequestFutureTarget
136 public void setRequest(Request request) {
137 this.request = request;
144 public Request getRequest()
[all...] |
| /external/jetty/src/java/org/eclipse/jetty/server/handler/ |
| RequestLogHandler.java | 31 import org.eclipse.jetty.server.Request;
57 public void handle(String target, final Request baseRequest, HttpServletRequest request, final HttpServletResponse response)
68 super.handle(target, baseRequest, request, response);
72 if (_requestLog != null && baseRequest.getDispatcherType().equals(DispatcherType.REQUEST))
100 //are we changing the request log impl?
116 //if we're already started, then start our request log
187 public void log(Request request, Response response)
|
