| /frameworks/base/core/jni/ |
| D | android_hardware_UsbRequest.cpp | 62 struct usb_request* request = usb_request_new(device, &desc); in android_hardware_UsbRequest_init() local
63 if (request) in android_hardware_UsbRequest_init()
64 env->SetIntField(thiz, field_context, (int)request); in android_hardware_UsbRequest_init()
65 return (request != NULL); in android_hardware_UsbRequest_init()
72 struct usb_request* request = get_request_from_object(env, thiz); in android_hardware_UsbRequest_close() local
73 if (request) { in android_hardware_UsbRequest_close()
74 usb_request_free(request); in android_hardware_UsbRequest_close()
83 struct usb_request* request = get_request_from_object(env, thiz); in android_hardware_UsbRequest_queue_array() local
84 if (!request) { in android_hardware_UsbRequest_queue_array()
90 request->buffer = malloc(length); in android_hardware_UsbRequest_queue_array()
[all …]
|
| /frameworks/support/volley/src/com/android/volley/ |
| D | NetworkDispatcher.java | 71 Request request; in run() local
75 request = mQueue.take(); in run()
85 request.addMarker("network-queue-take"); in run()
89 if (request.isCanceled()) { in run()
90 request.finish("network-discard-cancelled"); in run()
95 NetworkResponse networkResponse = mNetwork.performRequest(request); in run()
96 request.addMarker("network-http-complete"); in run()
100 if (networkResponse.notModified && request.hasHadResponseDelivered()) { in run()
101 request.finish("not-modified"); in run()
106 Response<?> response = request.parseNetworkResponse(networkResponse); in run()
[all …]
|
| D | CacheDispatcher.java | 88 final Request request = mCacheQueue.take(); in run() local
89 request.addMarker("cache-queue-take"); in run()
92 if (request.isCanceled()) { in run()
93 request.finish("cache-discard-canceled"); in run()
98 Cache.Entry entry = mCache.get(request.getCacheKey()); in run()
100 request.addMarker("cache-miss"); in run()
102 mNetworkQueue.put(request); in run()
108 request.addMarker("cache-hit-expired"); in run()
109 request.setCacheEntry(entry); in run()
110 mNetworkQueue.put(request); in run()
[all …]
|
| D | RequestQueue.java | 174 public boolean apply(Request<?> request); in apply() argument
183 for (Request<?> request : mCurrentRequests) { in cancelAll()
184 if (filter.apply(request)) { in cancelAll()
185 request.cancel(); in cancelAll()
201 public boolean apply(Request<?> request) { in cancelAll()
202 return request.getTag() == tag; in cancelAll()
249 for (Request request : pending) { in cancelDrainable()
250 if (request.isDrainable() && request.getSequence() < sequenceNumber) { in cancelDrainable()
251 request.cancel(); in cancelDrainable()
255 queue.add(request); in cancelDrainable()
[all …]
|
| D | ExecutorDelivery.java | 57 public void postResponse(Request<?> request, Response<?> response) { in postResponse() argument
58 postResponse(request, response, null); in postResponse()
62 public void postResponse(Request<?> request, Response<?> response, Runnable runnable) { in postResponse() argument
63 request.markDelivered(); in postResponse()
64 request.addMarker("post-response"); in postResponse()
65 mResponsePoster.execute(new ResponseDeliveryRunnable(request, response, runnable)); in postResponse()
69 public void postError(Request<?> request, VolleyError error) { in postError() argument
70 request.addMarker("post-error"); in postError()
72 mResponsePoster.execute(new ResponseDeliveryRunnable(request, response, null)); in postError()
90 public ResponseDeliveryRunnable(Request request, Response response, Runnable runnable) { in ResponseDeliveryRunnable() argument
[all …]
|
| /frameworks/base/core/java/android/ddm/ |
| D | DdmHandleHeap.java | 79 public Chunk handleChunk(Chunk request) { in handleChunk() argument
81 Log.v("ddm-heap", "Handling " + name(request.type) + " chunk"); in handleChunk()
82 int type = request.type; in handleChunk()
85 return handleHPIF(request); in handleChunk()
87 return handleHPSGNHSG(request, false); in handleChunk()
89 return handleHPDU(request); in handleChunk()
91 return handleHPDS(request); in handleChunk()
93 return handleHPSGNHSG(request, true); in handleChunk()
95 return handleHPGC(request); in handleChunk()
97 return handleREAE(request); in handleChunk()
[all …]
|
| D | DdmHandleProfiling.java | 70 public Chunk handleChunk(Chunk request) { in handleChunk() argument
72 Log.v("ddm-heap", "Handling " + name(request.type) + " chunk"); in handleChunk()
73 int type = request.type; in handleChunk()
76 return handleMPRS(request); in handleChunk()
78 return handleMPRE(request); in handleChunk()
80 return handleMPSS(request); in handleChunk()
82 return handleMPSE(request); in handleChunk()
84 return handleMPRQ(request); in handleChunk()
94 private Chunk handleMPRS(Chunk request) { in handleMPRS() argument
95 ByteBuffer in = wrapChunk(request); in handleMPRS()
[all …]
|
| D | DdmHandleThread.java | 67 public Chunk handleChunk(Chunk request) { in handleChunk() argument
69 Log.v("ddm-thread", "Handling " + name(request.type) + " chunk"); in handleChunk()
70 int type = request.type; in handleChunk()
73 return handleTHEN(request); in handleChunk()
75 return handleTHST(request); in handleChunk()
77 return handleSTKL(request); in handleChunk()
87 private Chunk handleTHEN(Chunk request) { in handleTHEN() argument
88 ByteBuffer in = wrapChunk(request); in handleTHEN()
100 private Chunk handleTHST(Chunk request) { in handleTHST() argument
101 ByteBuffer in = wrapChunk(request); in handleTHST()
[all …]
|
| /frameworks/av/media/libstagefright/rtsp/ |
| D | MyTransmitter.h | 217 AString request; in issueAnnounce() local
218 request.append("ANNOUNCE "); in issueAnnounce()
219 request.append(mStreamURL); in issueAnnounce()
220 request.append(" RTSP/1.0\r\n"); in issueAnnounce()
222 addAuthentication(&request, "ANNOUNCE", mStreamURL.c_str()); in issueAnnounce()
224 request.append("Content-Type: application/sdp\r\n"); in issueAnnounce()
225 request.append("Content-Length: "); in issueAnnounce()
226 request.append(sdp.size()); in issueAnnounce()
227 request.append("\r\n"); in issueAnnounce()
229 request.append("\r\n"); in issueAnnounce()
[all …]
|
| D | MyHandler.h | 362 AString request; in onMessageReceived() local
363 request = "DESCRIBE "; in onMessageReceived()
364 request.append(mSessionURL); in onMessageReceived()
365 request.append(" RTSP/1.0\r\n"); in onMessageReceived()
366 request.append("Accept: application/sdp\r\n"); in onMessageReceived()
367 request.append("\r\n"); in onMessageReceived()
370 mConn->sendRequest(request.c_str(), reply); in onMessageReceived()
411 AString request; in onMessageReceived() local
412 request = "DESCRIBE "; in onMessageReceived()
413 request.append(mSessionURL); in onMessageReceived()
[all …]
|
| D | ARTSPConnection.cpp | 81 const char *request, const sp<AMessage> &reply) { in sendRequest() argument
83 msg->setString("request", request); in sendRequest()
410 AString request; in onSendRequest() local
411 CHECK(msg->findString("request", &request)); in onSendRequest()
415 reply->setString("original-request", request.c_str(), request.size()); in onSendRequest()
417 addAuthentication(&request); in onSendRequest()
418 addUserAgent(&request); in onSendRequest()
421 ssize_t i = request.find("\r\n\r\n"); in onSendRequest()
430 request.insert(cseqHeader, i + 2); in onSendRequest()
432 ALOGV("request: '%s'", request.c_str()); in onSendRequest()
[all …]
|
| /frameworks/base/obex/javax/obex/ |
| D | ServerSession.java | 161 HeaderSet request = new HeaderSet(); in handleAbortRequest() local
172 code = mListener.onAbort(request, reply); in handleAbortRequest()
295 HeaderSet request = new HeaderSet(); in handleSetPathRequest() local
316 ObexHelper.updateHeaderSet(request, headers); in handleSetPathRequest()
318 if (mListener.getConnectionId() != -1 && request.mConnectionID != null) { in handleSetPathRequest()
319 mListener.setConnectionId(ObexHelper.convertToLong(request.mConnectionID)); in handleSetPathRequest()
324 if (request.mAuthResp != null) { in handleSetPathRequest()
325 if (!handleAuthResp(request.mAuthResp)) { in handleSetPathRequest()
328 request.mAuthResp)); in handleSetPathRequest()
330 request.mAuthResp = null; in handleSetPathRequest()
[all …]
|
| /frameworks/base/core/java/android/net/http/ |
| D | AndroidHttpClient.java | 97 public void process(HttpRequest request, HttpContext context) {
207 public static void modifyRequestToAcceptGzipResponse(HttpRequest request) { in modifyRequestToAcceptGzipResponse() argument
208 request.addHeader("Accept-Encoding", "gzip"); in modifyRequestToAcceptGzipResponse()
251 public HttpResponse execute(HttpUriRequest request) throws IOException { in execute() argument
252 return delegate.execute(request); in execute()
255 public HttpResponse execute(HttpUriRequest request, HttpContext context) in execute() argument
257 return delegate.execute(request, context); in execute()
260 public HttpResponse execute(HttpHost target, HttpRequest request) in execute() argument
262 return delegate.execute(target, request); in execute()
265 public HttpResponse execute(HttpHost target, HttpRequest request, in execute() argument
[all …]
|
| /frameworks/av/media/libstagefright/chromium_http/ |
| D | support.cpp | 247 net::URLRequest *request, const GURL &new_url, bool *defer_redirect) { in OnReceivedRedirect() argument
252 net::URLRequest *request, net::AuthChallengeInfo *auth_info) { in OnAuthRequired() argument
255 inherited::OnAuthRequired(request, auth_info); in OnAuthRequired()
259 net::URLRequest *request, net::SSLCertRequestInfo *cert_request_info) { in OnCertificateRequested() argument
262 inherited::OnCertificateRequested(request, cert_request_info); in OnCertificateRequested()
266 net::URLRequest *request, int cert_error, net::X509Certificate *cert) { in OnSSLCertificateError() argument
269 inherited::OnSSLCertificateError(request, cert_error, cert); in OnSSLCertificateError()
272 void SfDelegate::OnGetCookies(net::URLRequest *request, bool blocked_by_policy) { in OnGetCookies() argument
277 net::URLRequest *request, in OnSetCookie() argument
284 void SfDelegate::OnResponseStarted(net::URLRequest *request) { in OnResponseStarted() argument
[all …]
|
| 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/base/core/tests/coretests/src/android/net/http/ |
| D | AbstractProxyTest.java | 79 RecordedRequest request = server.takeRequest(); in testConnectToHttps() local
80 assertEquals("GET /foo HTTP/1.1", request.getRequestLine()); in testConnectToHttps()
121 HttpGet request = new HttpGet("http://android.com/foo"); in testConnectViaProxy() local
122 proxyConfig.configure(server, httpProxyClient, request); in testConnectViaProxy()
124 HttpResponse response = httpProxyClient.execute(request); in testConnectViaProxy()
166 HttpGet request = new HttpGet("https://android.com/foo"); in testConnectViaHttpProxyToHttps() local
167 proxyConfig.configure(server, httpProxyClient, request); in testConnectViaHttpProxyToHttps()
169 HttpResponse response = httpProxyClient.execute(request); in testConnectViaHttpProxyToHttps()
197 HttpGet request = new HttpGet("http://origin.foo/bar"); in testParamPreferredOverSystemProperty() local
198 proxyConfig.configure(server, client, request); in testParamPreferredOverSystemProperty()
[all …]
|
| /frameworks/base/voip/java/com/android/server/sip/ |
| D | SipHelper.java | 200 Request request = (caller == callee) in sendOptions() local
205 mSipProvider.getNewClientTransaction(request); in sendOptions()
216 Request request = createRequest(Request.REGISTER, userProfile, tag); in sendRegister() local
220 request.addHeader(createWildcardContactHeader()); in sendRegister()
222 request.addHeader(createContactHeader(userProfile)); in sendRegister()
224 request.addHeader(mHeaderFactory.createExpiresHeader(expiry)); in sendRegister()
227 mSipProvider.getNewClientTransaction(request); in sendRegister()
248 Request request = mMessageFactory.createRequest(requestURI, in createRequest() local
253 request.addHeader(userAgentHeader); in createRequest()
254 return request; in createRequest()
[all …]
|
| /frameworks/support/volley/src/com/android/volley/toolbox/ |
| D | BasicNetwork.java | 83 public NetworkResponse performRequest(Request<?> request) throws VolleyError { in performRequest() argument
92 addCacheHeaders(headers, request.getCacheEntry()); in performRequest()
93 httpResponse = mHttpStack.performRequest(request, headers); in performRequest()
100 request.getCacheEntry().data, responseHeaders, true); in performRequest()
106 logSlowRequests(requestLifetime, request, responseContents, statusLine); in performRequest()
114 attemptRetryOnException("socket", request, new TimeoutError()); in performRequest()
116 attemptRetryOnException("connection", request, new TimeoutError()); in performRequest()
118 throw new RuntimeException("Bad URL " + request.getUrl(), e); in performRequest()
127 VolleyLog.e("Unexpected response code %d for %s", statusCode, request.getUrl()); in performRequest()
134 request, new AuthFailureError(networkResponse)); in performRequest()
[all …]
|
| /frameworks/av/media/mtp/ |
| D | MtpDataPacket.cpp | 378 int MtpDataPacket::read(struct usb_request *request) { in read() argument
380 request->buffer = mBuffer; in read()
381 request->buffer_length = mBufferSize; in read()
382 int length = transfer(request); in read()
388 request->buffer = mBuffer + length; in read()
389 request->buffer_length = totalLength - length; in read()
390 int ret = transfer(request); in read()
404 int MtpDataPacket::readData(struct usb_request *request, void* buffer, int length) { in readData() argument
407 request->buffer = (char *)buffer + read; in readData()
408 request->buffer_length = length - read; in readData()
[all …]
|
| /frameworks/base/core/tests/coretests/src/android/app/ |
| D | DownloadManagerFunctionalTest.java | 76 Request request = new Request(uri); in doErrorTest() local
77 request.setTitle(DEFAULT_FILENAME); in doErrorTest()
79 long dlRequest = mDownloadManager.enqueue(request); in doErrorTest()
158 Request request = new Request(uri); in testDownloadToExternal_fileExists() local
161 request.setDestinationUri(localUri); in testDownloadToExternal_fileExists()
163 long dlRequest = mDownloadManager.enqueue(request); in testDownloadToExternal_fileExists()
196 Request request = new Request(uri); in testDownloadToExternal() local
199 request.setDestinationUri(localUri); in testDownloadToExternal()
201 long dlRequest = mDownloadManager.enqueue(request); in testDownloadToExternal()
227 Request request = new Request(uri); in testDownloadToProhibitedDirectory() local
[all …]
|
| /frameworks/base/media/java/android/media/ |
| D | MediaPlayer.java | 640 public void invoke(Parcel request, Parcel reply) { in invoke() argument
641 int retcode = native_invoke(request, reply); in invoke()
744 Parcel request = Parcel.obtain(); in setVideoScalingMode() local
747 request.writeInterfaceToken(IMEDIA_PLAYER); in setVideoScalingMode()
748 request.writeInt(INVOKE_ID_SET_VIDEO_SCALE_MODE); in setVideoScalingMode()
749 request.writeInt(mode); in setVideoScalingMode()
750 invoke(request, reply); in setVideoScalingMode()
752 request.recycle(); in setVideoScalingMode()
1241 Parcel request = newRequest(); in setMetadataFilter() local
1247 int capacity = request.dataSize() + 4 * (1 + allow.size() + 1 + block.size()); in setMetadataFilter()
[all …]
|
| /frameworks/base/core/tests/hosttests/test-apps/DownloadManagerTestApp/src/com/android/frameworks/downloadmanagertests/ |
| D | DownloadManagerTestApp.java | 142 Request request = new Request(remoteUri); in initiateDownload() local
144 dlRequest = mDownloadManager.enqueue(request); in initiateDownload()
235 Request request = new Request(remoteUri); in runLargeDownloadOverWiFi() local
236 request.setMimeType("application/vnd.android.package-archive"); in runLargeDownloadOverWiFi()
238 dlRequest = mDownloadManager.enqueue(request); in runLargeDownloadOverWiFi()
283 Request request = new Request(remoteUri); in runDownloadMultipleSwitching() local
288 request.setDestinationUri(localUri); in runDownloadMultipleSwitching()
290 request.setAllowedNetworkTypes(Request.NETWORK_MOBILE | Request.NETWORK_WIFI); in runDownloadMultipleSwitching()
292 dlRequest = mDownloadManager.enqueue(request); in runDownloadMultipleSwitching()
357 Request request = new Request(remoteUri); in runDownloadMultipleWiFiEnableDisable() local
[all …]
|
| /frameworks/base/core/java/android/hardware/usb/ |
| D | UsbDeviceConnection.java | 123 public int controlTransfer(int requestType, int request, int value, in controlTransfer() argument
125 return native_control_request(requestType, request, value, index, buffer, length, timeout); in controlTransfer()
154 UsbRequest request = native_request_wait(); in requestWait() local
155 if (request != null) { in requestWait()
156 request.dequeue(); in requestWait()
158 return request; in requestWait()
177 private native int native_control_request(int requestType, int request, int value, in native_control_request() argument
|
| /frameworks/support/volley/tests/src/com/android/volley/ |
| D | RequestQueueTest.java | 59 MockRequest request = new MockRequest(); in makeRequests() local
61 request.setCacheKey(String.valueOf(i)); in makeRequests()
62 request.setPriority(priority); in makeRequests()
63 requests.add(request); in makeRequests()
75 for (Request<?> request : makeRequests(requestsToMake)) { in testAdd_requestProcessedInCorrectOrder()
76 queue.add(request); in testAdd_requestProcessedInCorrectOrder()
154 public NetworkResponse performRequest(Request<?> request) { in performRequest() argument
155 Priority thisPriority = request.getPriority(); in performRequest()
156 int thisSequence = request.getSequence(); in performRequest()
190 DelayedRequest request = new DelayedRequest(50, parsedBefore, deliveredBefore); in testDrain_suppressesEarlierResponses() local
[all …]
|
| /frameworks/base/media/tests/players/ |
| D | invoke_mock_media_player.cpp | 85 virtual status_t invoke(const Parcel& request, Parcel *reply);
86 virtual status_t setParameter(int key, const Parcel &request) {return OK;} in setParameter() argument
92 void ping(const Parcel& request, Parcel *reply);
98 status_t Player::invoke(const Parcel& request, Parcel *reply) in invoke() argument
102 ping(request, reply); in invoke()
109 void Player::ping(const Parcel& request, Parcel *reply) in ping() argument
111 const size_t len = request.dataAvail(); in ping()
113 reply->setData(static_cast<const uint8_t*>(request.readInplace(len)), len); in ping()
|