/frameworks/support/volley/src/com/android/volley/toolbox/ |
H A D | BasicNetwork.java | 83 public NetworkResponse performRequest(Request<?> request) throws VolleyError { argument 92 addCacheHeaders(headers, request.getCacheEntry()); 93 httpResponse = mHttpStack.performRequest(request, headers); 100 request.getCacheEntry().data, responseHeaders, true); 104 // if the request is slow, log it. 106 logSlowRequests(requestLifetime, request, responseContents, statusLine); 114 attemptRetryOnException("socket", request, new TimeoutError()); 116 attemptRetryOnException("connection", request, new TimeoutError()); 118 throw new RuntimeException("Bad URL " + request.getUrl(), e); 127 VolleyLog.e("Unexpected response code %d for %s", statusCode, request 149 logSlowRequests(long requestLifetime, Request<?> request, byte[] responseContents, StatusLine statusLine) argument 164 attemptRetryOnException(String logPrefix, Request<?> request, VolleyError exception) argument [all...] |
H A D | HttpClientStack.java | 40 * An HttpStack that performs request over an {@link HttpClient}. 65 public HttpResponse performRequest(Request<?> request, Map<String, String> additionalHeaders) argument 68 byte[] postBody = request.getPostBody(); 70 HttpPost postRequest = new HttpPost(request.getUrl()); 71 postRequest.addHeader("Content-Type", request.getPostBodyContentType()); 77 httpRequest = new HttpGet(request.getUrl()); 80 addHeaders(httpRequest, request.getHeaders()); 83 int timeoutMs = request.getTimeoutMs(); 92 * Called before the request is executed using the underlying HttpClient. 94 * <p>Overwrite in subclasses to augment the request 96 onPrepareRequest(HttpUriRequest request) argument [all...] |
H A D | HurlStack.java | 65 * @param urlRewriter Rewriter to use for request URLs 72 public HttpResponse performRequest(Request<?> request, Map<String, String> additionalHeaders) argument 74 String url = request.getUrl(); 76 map.putAll(request.getHeaders()); 86 HttpURLConnection connection = openConnection(parsedUrl, request); 90 handlePost(connection, request); 138 private HttpURLConnection openConnection(URL url, Request<?> request) throws IOException { argument 141 int timeoutMs = request.getTimeoutMs(); 149 private void handlePost(HttpURLConnection connection, Request<?> request) argument 151 byte[] postBody = request [all...] |
H A D | HttpStack.java | 32 * Performs an HTTP request with the given parameters. 34 * <p>A GET request is sent if request.getPostBody() == null. A POST request is sent otherwise, 35 * and the Content-Type header is set to request.getPostBodyContentType().</p> 37 * @param request the request to perform 42 public HttpResponse performRequest(Request<?> request, Map<String, String> additionalHeaders) argument
|
/frameworks/base/obex/javax/obex/ |
H A D | ServerSession.java | 129 * Received a request type that is not recognized so I am 151 * Handles a ABORT request from a client. This method will read the rest of 152 * the request from the client. Assuming the request is valid, it will 155 * request, this method will create a reply message to send to the server. 161 HeaderSet request = new HeaderSet(); 172 code = mListener.onAbort(request, reply); 173 Log.v(TAG, "onAbort request handler return value- " + code); 180 * Handles a PUT request from a client. This method will provide a 181 * <code>ServerOperation</code> object to the request handle [all...] |
/frameworks/base/voip/java/com/android/server/sip/ |
H A D | SipHelper.java | 200 Request request = (caller == callee) 205 mSipProvider.getNewClientTransaction(request); 216 Request request = createRequest(Request.REGISTER, userProfile, tag); 220 request.addHeader(createWildcardContactHeader()); 222 request.addHeader(createContactHeader(userProfile)); 224 request.addHeader(mHeaderFactory.createExpiresHeader(expiry)); 227 mSipProvider.getNewClientTransaction(request); 248 Request request = mMessageFactory.createRequest(requestURI, 253 request.addHeader(userAgentHeader); 254 return request; [all...] |
/frameworks/av/media/mtp/ |
H A D | MtpEventPacket.h | 37 // read our buffer with the given request 38 int read(struct usb_request *request);
|
H A D | MtpRequestPacket.h | 40 int write(struct usb_request *request);
|
H A D | MtpResponsePacket.h | 37 // read our buffer with the given request 38 int read(struct usb_request *request);
|
H A D | MtpDataPacket.cpp | 378 int MtpDataPacket::read(struct usb_request *request) { 380 request->buffer = mBuffer; 381 request->buffer_length = mBufferSize; 382 int length = transfer(request); 388 request->buffer = mBuffer + length; 389 request->buffer_length = totalLength - length; 390 int ret = transfer(request); 404 int MtpDataPacket::readData(struct usb_request *request, void* buffer, int length) { 407 request->buffer = (char *)buffer + read; 408 request [all...] |
/frameworks/av/media/libstagefright/chromium_http/ |
H A D | support.cpp | 247 net::URLRequest *request, const GURL &new_url, bool *defer_redirect) { 252 net::URLRequest *request, net::AuthChallengeInfo *auth_info) { 255 inherited::OnAuthRequired(request, auth_info); 259 net::URLRequest *request, net::SSLCertRequestInfo *cert_request_info) { 262 inherited::OnCertificateRequested(request, cert_request_info); 266 net::URLRequest *request, int cert_error, net::X509Certificate *cert) { 269 inherited::OnSSLCertificateError(request, cert_error, cert); 272 void SfDelegate::OnGetCookies(net::URLRequest *request, bool blocked_by_policy) { argument 277 net::URLRequest *request, 284 void SfDelegate::OnResponseStarted(net::URLRequest *request) { argument 246 OnReceivedRedirect( net::URLRequest *request, const GURL &new_url, bool *defer_redirect) argument 251 OnAuthRequired( net::URLRequest *request, net::AuthChallengeInfo *auth_info) argument 258 OnCertificateRequested( net::URLRequest *request, net::SSLCertRequestInfo *cert_request_info) argument 265 OnSSLCertificateError( net::URLRequest *request, int cert_error, net::X509Certificate *cert) argument 276 OnSetCookie( net::URLRequest *request, const std::string &cookie_line, const net::CookieOptions &options, bool blocked_by_policy) argument 333 OnReadCompleted(net::URLRequest *request, int bytes_read) argument 370 readMore(net::URLRequest *request) argument [all...] |
H A D | support.h | 100 net::URLRequest *request, const GURL &new_url, bool *defer_redirect); 103 net::URLRequest *request, net::AuthChallengeInfo *auth_info); 106 net::URLRequest *request, net::SSLCertRequestInfo *cert_request_info); 109 net::URLRequest *request, int cert_error, net::X509Certificate *cert); 111 virtual void OnGetCookies(net::URLRequest *request, bool blocked_by_policy); 114 net::URLRequest *request, 119 virtual void OnResponseStarted(net::URLRequest *request); 121 virtual void OnReadCompleted(net::URLRequest *request, int bytes_read); 138 void readMore(net::URLRequest *request);
|
/frameworks/support/volley/tests/src/com/android/volley/ |
H A D | RequestQueueTest.java | 59 MockRequest request = new MockRequest(); 61 request.setCacheKey(String.valueOf(i)); 62 request.setPriority(priority); 63 requests.add(request); 75 for (Request<?> request : makeRequests(requestsToMake)) { 76 queue.add(request); 89 // Enqueue 2 requests with the same cache key. The first request takes 1.5s. Assert that the 90 // second request is only handled after the first one has been parsed and delivered. 154 public NetworkResponse performRequest(Request<?> request) { argument 155 Priority thisPriority = request [all...] |
H A D | CacheDispatcherTest.java | 63 // A cancelled request should not be processed at all. 72 // A cache miss does not post a response and puts the request on the network queue. 78 Request request = mNetworkQueue.take(); 79 assertNull(request.getCacheEntry()); 101 Request request = mNetworkQueue.take(); 102 assertSame(entry, request.getCacheEntry()); 113 Request request = mNetworkQueue.take(); 114 assertSame(entry, request.getCacheEntry());
|
/frameworks/av/media/libstagefright/rtsp/ |
H A D | MyHandler.h | 358 ALOGI("connection request completed with result %d (%s)", 362 AString request; local 363 request = "DESCRIBE "; 364 request.append(mSessionURL); 365 request.append(" RTSP/1.0\r\n"); 366 request.append("Accept: application/sdp\r\n"); 367 request.append("\r\n"); 370 mConn->sendRequest(request.c_str(), reply); 411 AString request; local 412 request 605 AString request = "PLAY "; local 666 AString request; local 742 AString request; local 905 AString request = "PAUSE "; local 939 AString request = "PLAY "; local 1286 AString request = "SETUP "; local [all...] |
/frameworks/compile/mclinker/unittests/ |
H A D | MemoryAreaTest.cpp | 55 MemoryRegion* region = area->request(3, 2); 69 MemoryRegion* region = area->request(3, 4); 79 region = area->request(5, 2); 93 MemoryRegion* region = area->request(0, 4096) ; 107 MemoryRegion* region = area->request(0, 4096) ; 113 region = area->request(4000, 4) ; 130 MemoryRegion* region1 = area->request(0, 4096) ; 131 MemoryRegion* region2 = area->request(512, 1024) ; 139 region1 = area->request(0, 1024) ;
|
/frameworks/base/core/tests/coretests/src/android/app/ |
H A D | DownloadManagerFunctionalTest.java | 76 Request request = new Request(uri); 77 request.setTitle(DEFAULT_FILENAME); 79 long dlRequest = mDownloadManager.enqueue(request); 158 Request request = new Request(uri); 161 request.setDestinationUri(localUri); 163 long dlRequest = mDownloadManager.enqueue(request); 196 Request request = new Request(uri); 199 request.setDestinationUri(localUri); 201 long dlRequest = mDownloadManager.enqueue(request); 227 Request request [all...] |
/frameworks/base/core/java/android/ddm/ |
H A D | DdmHandleHello.java | 79 public Chunk handleChunk(Chunk request) { argument 81 Log.v("ddm-heap", "Handling " + name(request.type) + " chunk"); 82 int type = request.type; 85 return handleHELO(request); 87 return handleFEAT(request); 97 private Chunk handleHELO(Chunk request) { argument 102 * Process the request. 104 ByteBuffer in = wrapChunk(request); 145 * Handle request for list of supported features. 147 private Chunk handleFEAT(Chunk request) { argument [all...] |
/frameworks/base/core/tests/coretests/src/android/os/ |
H A D | BroadcasterTest.java | 44 b.request(MESSAGE_A, h, MESSAGE_B); 79 b.request(MESSAGE_A, mHandlers[i], MESSAGE_B + i); 112 * 2 handlers request the same message, with different translations 121 * 1000 handlers request the same message, with different translations 130 * Two handlers request different messages, with translations, sending 142 b.request(MESSAGE_A, h1, MESSAGE_C); 143 b.request(MESSAGE_B, h2, MESSAGE_D); 165 * Two handlers request different messages, with translations, sending 177 b.request(MESSAGE_A, h1, MESSAGE_C); 178 b.request(MESSAGE_ [all...] |
/frameworks/support/volley/tests/src/com/android/volley/mock/ |
H A D | MockNetwork.java | 46 public NetworkResponse performRequest(Request<?> request) throws VolleyError { argument 54 requestHandled = request;
|
H A D | MockHttpClient.java | 56 public HttpResponse execute(HttpUriRequest request, HttpContext context) { argument 57 requestExecuted = request; 70 public HttpResponse execute(HttpUriRequest request) { argument 75 public HttpResponse execute(HttpHost target, HttpRequest request) { argument 85 public HttpResponse execute(HttpHost target, HttpRequest request, HttpContext context) { argument
|
/frameworks/base/media/tests/MediaFrameworkTest/src/com/android/mediaframeworktest/functional/ |
H A D | MediaPlayerInvokeTest.java | 63 Parcel request = mPlayer.newRequest(); 67 request.writeInt(val); 68 mPlayer.invoke(request, reply);
|
/frameworks/base/tests/TtsTests/src/com/android/speech/tts/ |
H A D | MockableTextToSpeechService.java | 58 protected void onSynthesizeText(SynthesisRequest request, SynthesisCallback callback) { argument 59 sDelegate.onSynthesizeText(request, callback); 71 void onSynthesizeText(SynthesisRequest request, SynthesisCallback callback); argument
|
/frameworks/base/core/tests/hosttests/test-apps/DownloadManagerTestApp/src/com/android/frameworks/downloadmanagertests/ |
H A D | DownloadManagerTestApp.java | 142 Request request = new Request(remoteUri); 144 dlRequest = mDownloadManager.enqueue(request); 235 Request request = new Request(remoteUri); 236 request.setMimeType("application/vnd.android.package-archive"); 238 dlRequest = mDownloadManager.enqueue(request); 283 Request request = new Request(remoteUri); 288 request.setDestinationUri(localUri); 290 request.setAllowedNetworkTypes(Request.NETWORK_MOBILE | Request.NETWORK_WIFI); 292 dlRequest = mDownloadManager.enqueue(request); 357 Request request [all...] |
/frameworks/native/libs/utils/ |
H A D | Looper.cpp | 162 int ident = response.request.ident; 164 int fd = response.request.fd; 166 void* data = response.request.data; 313 if (response.request.ident == ALOOPER_POLL_CALLBACK) { 314 int fd = response.request.fd; 316 void* data = response.request.data; 319 this, response.request.callback.get(), fd, events, data); 321 int callbackResult = response.request.callback->handleEvent(fd, events, data); 327 response.request.callback.clear(); 389 void Looper::pushResponse(int events, const Request& request) { argument 427 Request request; local [all...] |