| /external/jetty/src/java/org/eclipse/jetty/servlets/ |
| QoSFilter.java | 68 * avoided if the semaphore is shortly available. If the semaphore cannot be obtained, the request will be suspended
156 public void doFilter(ServletRequest request, ServletResponse response, FilterChain chain)
162 if (request.getAttribute(_suspended)==null)
167 request.setAttribute(_suspended,Boolean.FALSE);
171 request.setAttribute(_suspended,Boolean.TRUE);
172 int priority = getPriority(request);
173 Continuation continuation = ContinuationSupport.getContinuation(request);
184 Boolean suspended=(Boolean)request.getAttribute(_suspended);
188 request.setAttribute(_suspended,Boolean.FALSE);
189 if (request.getAttribute("javax.servlet.resumed")==Boolean.TRUE
[all...] |
| /external/okhttp/samples/guide/src/main/java/com/squareup/okhttp/recipes/ |
| AsynchronousGet.java | 21 import com.squareup.okhttp.Request;
29 Request request = new Request.Builder() local
33 client.newCall(request).enqueue(new Callback() {
34 @Override public void onFailure(Request request, IOException e) {
|
| Authenticate.java | 21 import com.squareup.okhttp.Request;
31 @Override public Request authenticate(Proxy proxy, Response response) {
35 return response.request().newBuilder()
40 @Override public Request authenticateProxy(Proxy proxy, Response response) {
45 Request request = new Request.Builder() local
49 Response response = client.newCall(request).execute();
|
| CacheResponse.java | 20 import com.squareup.okhttp.Request;
37 Request request = new Request.Builder() local
41 Response response1 = client.newCall(request).execute();
49 Response response2 = client.newCall(request).execute();
|
| CheckHandshake.java | 21 import com.squareup.okhttp.Request;
40 return chain.proceed(chain.request());
51 Request request = new Request.Builder() local
55 Response response = client.newCall(request).execute();
|
| PerCallSettings.java | 19 import com.squareup.okhttp.Request;
28 Request request = new Request.Builder() local
33 OkHttpClient cloned = client.clone(); // Clone to make a customized OkHttp for this request.
36 Response response = cloned.newCall(request).execute();
43 OkHttpClient cloned = client.clone(); // Clone to make a customized OkHttp for this request.
46 Response response = cloned.newCall(request).execute();
|
| RewriteResponseCacheControl.java | 21 import com.squareup.okhttp.Request;
30 Response originalResponse = chain.proceed(chain.request());
49 System.out.println(" Request: " + i);
51 Request request = new Request.Builder() local
56 // Force this request's response to be written to the cache. This way, subsequent responses
65 Response response = client.newCall(request).execute();
|
| /external/valgrind/memcheck/tests/ |
| varinfo1.stderr.exp | 1 Uninitialised byte(s) found during client check request
8 Uninitialised byte(s) found during client check request
14 Uninitialised byte(s) found during client check request
20 Uninitialised byte(s) found during client check request
26 Uninitialised byte(s) found during client check request
32 Uninitialised byte(s) found during client check request
|
| /frameworks/base/core/java/android/service/restrictions/ |
| RestrictionsReceiver.java | 45 * An asynchronous permission request made by an application for an operation that requires
47 * Provider should transfer the request to the administrator and deliver back a response, when
51 * If the request bundle contains the key {@link RestrictionsManager#REQUEST_KEY_NEW_REQUEST},
52 * then a new request must be sent. Otherwise the provider can look up any previous response
56 * @param requestType the type of request, which determines the content and presentation of
57 * the request data.
58 * @param request the request data bundle containing at a minimum a request id.
65 String packageName, String requestType, String requestId, PersistableBundle request);
80 PersistableBundle request = (PersistableBundle) local
[all...] |
| /frameworks/base/media/tests/MediaFrameworkTest/src/com/android/mediaframeworktest/functional/ |
| MediaPlayerInvokeTest.java | 63 Parcel request = mPlayer.newRequest(); local
67 request.writeInt(val);
68 mPlayer.invoke(request, reply);
|
| /frameworks/base/tests/TtsTests/src/com/android/speech/tts/ |
| MockableTextToSpeechService.java | 60 protected void onSynthesizeText(SynthesisRequest request, SynthesisCallback callback) {
61 sDelegate.onSynthesizeText(request, callback);
73 void onSynthesizeText(SynthesisRequest request, SynthesisCallback callback);
|
| /hardware/broadcom/wlan/bcmdhd/wifi_hal/ |
| wifi_logger.cpp | 129 int createRingRequest(WifiRequest& request) {
130 int result = request.create(GOOGLE_OUI, LOGGER_START_LOGGING);
132 ALOGE("Failed to create start ring logger request; result = %d", result);
136 nlattr *data = request.attr_start(NL80211_ATTR_VENDOR_DATA);
138 result = request.put_u32(LOGGER_ATTRIBUTE_LOG_LEVEL, mVerboseLevel);
143 result = request.put_u32(LOGGER_ATTRIBUTE_RING_FLAGS, mFlags);
148 result = request.put_u32(LOGGER_ATTRIBUTE_LOG_TIME_INTVAL, mMaxIntervalSec);
153 result = request.put_u32(LOGGER_ATTRIBUTE_LOG_MIN_DATA_SIZE, mMinDataSize);
158 result = request.put_string(LOGGER_ATTRIBUTE_RING_NAME, mRingName);
163 request.attr_end(data)
[all...] |
| /packages/apps/Browser/src/com/android/browser/ |
| DownloadHandler.java | 56 * @param privateBrowsing If the request is coming from a private browsing tab.
140 * @param privateBrowsing If the request is coming from a private browsing tab.
188 final DownloadManager.Request request; local
190 request = new DownloadManager.Request(uri);
195 request.setMimeType(mimetype);
199 request.setDestinationInExternalPublicDir(Environment.DIRECTORY_DOWNLOADS, filename);
210 request.allowScanningByMediaScanner();
211 request.setDescription(webAddress.getHost())
[all...] |
| /packages/apps/Dialer/tests/src/com/android/dialer/calllog/ |
| CallLogAdapterTest.java | 96 // There is one request for contact details.
99 TestContactInfoCache.Request request = mAdapter.getContactInfoCache().requests.get(0); local
101 assertEquals(TEST_NUMBER, request.number);
103 assertEquals(TEST_COUNTRY_ISO, request.countryIso);
104 // Since there is nothing in the cache, it is an immediate request.
105 assertTrue("should be immediate", request.immediate);
115 // There is one request for contact details.
118 TestContactInfoCache.Request request = mAdapter.getContactInfoCache().requests.get(0) local
137 TestContactInfoCache.Request request = mAdapter.getContactInfoCache().requests.get(0); local
169 TestContactInfoCache.Request request = mAdapter.getContactInfoCache().requests.get(0); local
[all...] |
| /system/core/gatekeeperd/tests/ |
| gatekeeper_test.cpp | 42 EnrollRequest request(0, NULL, &password, NULL);
44 gatekeeper.Enroll(request, response);
59 EnrollRequest request(0, NULL, &password, NULL);
61 gatekeeper.Enroll(request, &response);
77 VerifyRequest request(0, 1, &enroll_response.enrolled_password_handle,
81 gatekeeper.Verify(request, &response);
115 VerifyRequest request(0, 0, &enroll_response.enrolled_password_handle,
118 gatekeeper.Verify(request, &response);
163 VerifyRequest request(0, 0, &enroll_response.enrolled_password_handle,
166 gatekeeper.Verify(request, &response)
[all...] |
| /external/jetty/src/java/org/eclipse/jetty/security/ |
| SecurityHandler.java | 39 import org.eclipse.jetty.server.Request;
52 * Select and apply an {@link Authenticator} to a request.
310 //if current request is authenticated, then as we have just created the session, mark it as secure, as it has not yet been returned to a user
314 Request request = connection.getRequest();
315 if (request == null)
318 if (request.isSecure())
400 protected boolean checkSecurity(Request request)
402 switch(request.getDispatcherType()
[all...] |
| /external/okhttp/okhttp-apache/src/test/java/com/squareup/okhttp/apache/ |
| OkApacheClientTest.java | 49 HttpGet request = new HttpGet(server.getUrl("/").toURI()); local
50 HttpResponse response = client.execute(request);
59 HttpGet request = new HttpGet(server.getUrl("/").toURI()); local
60 HttpResponse response = client.execute(request);
68 HttpGet request = new HttpGet(server.getUrl("/").toURI()); local
69 HttpResponse response = client.execute(request);
99 RecordedRequest request = server.takeRequest(); local
100 assertEquals("Hello, world!", request.getBody().readUtf8());
101 assertEquals(request.getHeader("Content-Length"), "13");
112 RecordedRequest request = server.takeRequest() local
126 RecordedRequest request = server.takeRequest(); local
164 HttpGet request = new HttpGet(server.getUrl("\/").toURI()); local
174 HttpGet request = new HttpGet(server.getUrl("\/").toURI()); local
221 HttpGet request = new HttpGet(server.getUrl("\/").toURI()); local
[all...] |
| /frameworks/av/media/libstagefright/rtsp/ |
| MyHandler.h | 453 ALOGI("connection request completed with result %d (%s)",
457 AString request; local
458 request = "DESCRIBE ";
459 request.append(mSessionURL);
460 request.append(" RTSP/1.0\r\n");
461 request.append("Accept: application/sdp\r\n");
462 request.append("\r\n");
465 mConn->sendRequest(request.c_str(), reply);
607 ALOGI("SDP connection request completed with result %d (%s)",
769 AString request = "PLAY " local
832 AString request; local
911 AString request; local
1077 AString request = "PAUSE "; local
1114 AString request = "PLAY "; local
1199 AString request = "PAUSE "; local
1256 AString request = "PLAY "; local
1635 AString request = "SETUP "; local
[all...] |
| /external/chromium-trace/trace-viewer/third_party/webapp2/webapp2_extras/ |
| sessions.py | 238 """A session provider for a single request.
241 even using different backends in the same request, through the method
245 the session store and save all sessions at the end of a request::
253 # Get a session store for this request.
254 self.session_store = sessions.get_store(request=self.request)
257 # Dispatch the request.
295 def __init__(self, request, config=None):
298 :param request:
299 A :class:`webapp2.Request` instance
[all...] |
| /external/okhttp/okhttp-tests/src/test/java/com/squareup/okhttp/internal/http/ |
| HeadersTest.java | 20 import com.squareup.okhttp.Request;
44 Request request = new Request.Builder().url("http://square.com/").build(); local
46 SpdyTransport.readNameValueBlock(headerBlock, Protocol.SPDY_3).request(request).build();
72 Request request = new Request.Builder().url("http://square.com/").build(); local
74 SpdyTransport.readNameValueBlock(headerBlock, Protocol.SPDY_3).request(request).build()
86 Request request = new Request.Builder().url("http:\/\/square.com\/").build(); local
96 Request request = new Request.Builder() local
118 Request request = new Request.Builder() local
133 Request request = new Request.Builder() local
[all...] |
| /external/wpa_supplicant_8/hostapd/ |
| wps-ap-nfc.py | 66 if "FAIL" in wpas.request("WPS_NFC_TAG_READ " + str(message).encode("hex")):
75 ret = wpas.request("WPS_NFC_CONFIG_TOKEN NDEF")
85 ret = wpas.request("WPS_NFC_TOKEN NDEF")
95 ret = wpas.request("NFC_GET_HANDOVER_SEL NDEF WPS-CR")
105 return wpas.request("NFC_REPORT_HANDOVER RESP WPS " +
116 # override to avoid parser error in request/response.pretty() in nfcpy
118 def _process_request(self, request):
119 summary("received handover request {}".format(request.type))
121 if not request.type == 'urn:nfc:wkt:Hr'
[all...] |
| /packages/services/Telephony/sip/src/com/android/services/telephony/sip/ |
| SipConnectionService.java | 68 final ConnectionRequest request) {
69 if (VERBOSE) log("onCreateOutgoingConnection, request: " + request);
71 Bundle extras = request.getExtras();
78 PhoneAccountHandle accountHandle = request.getAccountHandle();
86 connection.setAddress(request.getAddress(), TelecomManager.PRESENTATION_ALLOWED);
123 createConnectionForProfile(profile, request);
143 ConnectionRequest request) {
144 if (VERBOSE) log("onCreateIncomingConnection, request: " + request);
[all...] |
| /system/gatekeeper/ |
| gatekeeper.cpp | 23 void GateKeeper::Enroll(const EnrollRequest &request, EnrollResponse *response) {
26 if (!request.provided_password.buffer.get()) {
32 uint32_t uid = request.user_id;
34 if (request.password_handle.buffer.get() == NULL) {
39 reinterpret_cast<password_handle_t *>(request.password_handle.buffer.get());
70 if (!DoVerify(pw_handle, request.enrolled_password)) {
93 salt, user_id, flags, HANDLE_VERSION, request.provided_password.buffer.get(),
94 request.provided_password.length)) {
102 void GateKeeper::Verify(const VerifyRequest &request, VerifyResponse *response) {
105 if (!request.provided_password.buffer.get() || !request.password_handle.buffer.get())
[all...] |
| /external/chromium-trace/trace-viewer/third_party/webapp2/ |
| webapp2.py | 102 408: 'Request Time-out',
103 414: 'Request-URI Too Large',
114 class Request(webob.Request):
115 """Abstraction for an HTTP request.
131 #: A dictionary to register objects used during the request lifetime.
139 """Constructs a Request object from a WSGI environment.
155 super(Request, self).__init__(environ, *args, **kwargs)
172 the first value with the given name given in the request. If it
178 'Please use the Request.get_all() method instead.'
500 request = None variable in class:RequestHandler
1459 request = None variable in class:WSGIApplication
[all...] |
| /external/v8/src/ |
| d8.js | 261 // Converts a text command to a JSON request.
272 // If the very first character is a { assume that a JSON request have been
273 // entered as a command. Converting that to a JSON request is trivial.
283 cmd_line = 'break'; // Not in debugger mode, break with a frame request.
491 this.type = 'request';
523 // Create a JSON request for the evaluation command.
532 // Build a lookup request.
533 var request = this.createRequest('lookup');
534 request.arguments = {};
535 request.arguments.handles = [ lookup_handle ]
[all...] |
