| /frameworks/volley/tests/src/com/android/volley/ |
| RequestQueueTest.java | 19 import com.android.volley.Request.Priority;
54 Request.Priority[] allPriorities = Request.Priority.values();
59 MockRequest request = new MockRequest(); local
60 Request.Priority priority = allPriorities[random.nextInt(allPriorities.length)];
61 request.setCacheKey(String.valueOf(i));
62 request.setPriority(priority);
63 requests.add(request);
75 for (Request<?> request : makeRequests(requestsToMake))
[all...] |
| /packages/apps/Calendar/src/com/android/calendar/ |
| EventLoader.java | 147 // Check if we are still the most recent request.
185 // Wait for the next request
186 LoadRequest request = mQueue.take(); local
189 // skip all but the most recent request.
191 // Let the request know that it was skipped
192 request.skipRequest(mEventLoader);
194 // Skip to the next request
195 request = mQueue.take();
198 if (request instanceof ShutdownRequest) {
201 request.processRequest(mEventLoader)
248 LoadEventsRequest request = new LoadEventsRequest(id, startDay, numDays, local
275 LoadEventDaysRequest request = new LoadEventDaysRequest(startDay, numDays, local
[all...] |
| /packages/apps/ContactsCommon/src/com/android/contacts/common/vcard/ |
| VCardService.java | 48 * This Service creates one ImportRequest/ExportRequest object (as Runnable) per request and push
49 * it to {@link ExecutorService} with single thread executor. The executor handles each request
205 for (ImportRequest request : requests) {
206 uris.add(request.uri.toString());
207 displayNames.add(request.displayName);
210 String.format("received multiple import request (uri: %s, displayName: %s)",
215 ImportRequest request = requests.get(i); local
217 if (tryExecute(new ImportProcessor(this, listener, request, mCurrentJobId))) {
219 listener.onImportProcessed(request, mCurrentJobId, i);
224 listener.onImportFailed(request);
[all...] |
| /external/mockwebserver/src/main/java/com/google/mockwebserver/ |
| MockWebServer.java | 58 * replays them upon request in sequence.
101 * @param path the request path, such as "/".
143 * Awaits the next HTTP request, removes it, and returns it. Callers should
144 * use this to verify the request sent was as intended.
160 * Scripts {@code response} to be returned to a request made in sequence.
161 * The first request is served by the first enqueued response; the second
162 * request by the second enqueued response; and so on.
295 logger.warning("MockWebServer connection didn't make a request");
321 * Reads a request and writes its response. Returns true if a request
381 RecordedRequest request = new RecordedRequest(null, null, null, -1, null, sequenceNumber, local
392 String request; local
[all...] |
| /packages/services/Telephony/src/com/android/phone/ |
| PhoneInterfaceManager.java | 78 * A request object for use with {@link MainThreadHandler}. Requesters should wait() on the
79 * request after sending. The main thread will notify the request when it is complete.
82 /** The argument to use for the request */
84 /** The result of the request that is run on the main thread */
98 * request.
101 * note that request.result must be set to something non-null for the calling thread to
107 MainThreadRequest request; local
113 request = (MainThreadRequest) msg.obj;
114 request.result = Boolean.valueOf
191 MainThreadRequest request = new MainThreadRequest(argument); local
[all...] |
| /frameworks/av/services/camera/libcameraservice/device3/ |
| Camera3Device.cpp | 174 /** Start up request queue thread */
179 SET_ERR_L("Unable to start request queue thread: %s (%d)",
244 // HAL may be in a bad state, so waiting for request thread
346 lines = String8(" Last request sent:\n");
376 status_t Camera3Device::capture(CameraMetadata &request) {
382 // TODO: take ownership of the request
402 sp<CaptureRequest> newRequest = setUpRequestLocked(request);
404 CLOGE("Can't create capture request");
415 ALOGV("Camera %d: Capture request enqueued", mId);
421 status_t Camera3Device::setStreamingRequest(const CameraMetadata &request) {
1417 InFlightRequest &request = mInFlightMap.editValueAt(idx); local
1788 camera3_capture_request_t request = camera3_capture_request_t(); local
[all...] |
| /external/chromium_org/content/renderer/ |
| render_frame_impl.cc | 256 const WebKit::WebURLRequest& request,
258 loadURLExternally(frame, request, policy, WebString());
263 const WebKit::WebURLRequest& request,
266 Referrer referrer(RenderViewImpl::GetReferrerFromRequest(frame, request));
268 Send(new ViewHostMsg_DownloadUrl(GetRoutingID(), request.url(), referrer,
271 render_view_->OpenURL(frame, request.url(), referrer, policy);
278 const WebKit::WebURLRequest& request,
283 frame, extra_data, request, type, default_policy, is_redirect);
288 const WebKit::WebURLRequest& request,
293 frame, request, type, default_policy, is_redirect)
[all...] |
| /external/chromium_org/net/spdy/ |
| spdy_http_stream_unittest.cc | 38 // request sent on a connection.
171 HttpRequestInfo request; local
172 request.method = "GET";
173 request.url = GURL("http://www.google.com/");
185 http_stream->InitializeStream(&request, DEFAULT_PRIORITY,
344 HttpRequestInfo request; local
345 request.method = "POST";
346 request.url = GURL("http://www.google.com/");
347 request.upload_data_stream = &upload_stream;
358 http_stream.InitializeStream(&request, DEFAULT_PRIORITY
415 HttpRequestInfo request; local
505 HttpRequestInfo request; local
644 HttpRequestInfo request; local
722 HttpRequestInfo request; local
851 HttpRequestInfo request; local
[all...] |
| /frameworks/av/media/libstagefright/rtsp/ |
| ARTSPConnection.cpp | 84 const char *request, const sp<AMessage> &reply) {
86 msg->setString("request", request);
418 AString request; local
419 CHECK(msg->findString("request", &request));
421 // Just in case we need to re-issue the request with proper authentication
423 reply->setString("original-request", request.c_str(), request.size())
747 AString request; local
[all...] |
| /external/chromium_org/content/browser/loader/ |
| resource_loader.cc | 38 void PopulateResourceResponse(net::URLRequest* request,
40 response->head.error_code = request->status().error();
41 response->head.request_time = request->request_time();
42 response->head.response_time = request->response_time();
43 response->head.headers = request->response_headers();
44 request->GetCharset(&response->head.charset);
45 response->head.content_length = request->GetExpectedContentSize();
46 request->GetMimeType(&response->head.mime_type);
47 net::HttpResponseInfo response_info = request->response_info();
53 response->head.was_fetched_via_proxy = request->was_fetched_via_proxy()
[all...] |
| /external/chromium_org/v8/test/mjsunit/ |
| debug-continue.js | 36 var base_request = '"seq":0,"type":"request","command":"continue"'
51 // Generate request with the supplied arguments
52 var request;
54 request = '{' + base_request + ',"arguments":' + arguments + '}';
56 request = '{' + base_request + '}'
58 var response = safeEval(dcp.processDebugJSONRequest(request));
60 assertTrue(response.success, request + ' -> ' + response.message);
61 assertTrue(response.running, request + ' -> expected running');
63 assertFalse(response.success, request + ' -> ' + response.message);
64 assertFalse(response.running, request + ' -> expected not running')
[all...] |
| debug-references.js | 36 var base_request = '"seq":0,"type":"request","command":"references"'
48 // Generate request with the supplied arguments.
49 var request;
51 request = '{' + base_request + ',"arguments":' + arguments + '}';
53 request = '{' + base_request + '}'
56 // Process the request and check expectation.
57 var response = safeEval(dcp.processDebugJSONRequest(request));
59 assertTrue(response.success, request + ' -> ' + response.message);
67 assertFalse(response.success, request + ' -> ' + response.message);
69 assertEquals(response.running, dcp.isRunning(), request + ' -> expected not running')
[all...] |
| /external/v8/test/mjsunit/ |
| debug-continue.js | 36 var base_request = '"seq":0,"type":"request","command":"continue"'
51 // Generate request with the supplied arguments
52 var request;
54 request = '{' + base_request + ',"arguments":' + arguments + '}';
56 request = '{' + base_request + '}'
58 var response = safeEval(dcp.processDebugJSONRequest(request));
60 assertTrue(response.success, request + ' -> ' + response.message);
61 assertTrue(response.running, request + ' -> expected running');
63 assertFalse(response.success, request + ' -> ' + response.message);
64 assertFalse(response.running, request + ' -> expected not running')
[all...] |
| debug-references.js | 36 var base_request = '"seq":0,"type":"request","command":"references"'
48 // Generate request with the supplied arguments.
49 var request;
51 request = '{' + base_request + ',"arguments":' + arguments + '}';
53 request = '{' + base_request + '}'
56 // Process the request and check expectation.
57 var response = safeEval(dcp.processDebugJSONRequest(request));
59 assertTrue(response.success, request + ' -> ' + response.message);
67 assertFalse(response.success, request + ' -> ' + response.message);
69 assertEquals(response.running, dcp.isRunning(), request + ' -> expected not running')
[all...] |
| /external/chromium_org/net/quic/ |
| quic_stream_factory.cc | 183 int QuicStreamRequest::Request(
272 QuicStreamRequest* request) {
274 request->set_stream(CreateIfSessionExists(host_port_proxy_pair, net_log));
280 active_requests_[request] = job;
281 job_requests_map_[job].insert(request);
291 active_requests_[request] = job.get();
292 job_requests_map_[job.get()].insert(request);
297 request->set_stream(CreateIfSessionExists(host_port_proxy_pair, net_log));
314 QuicStreamRequest* request = *it; local
316 active_requests_.erase(request);
[all...] |
| /external/chromium_org/third_party/libjingle/source/talk/media/base/ |
| videoadapter.cc | 321 CoordinatedVideoAdapter::AdaptRequest request,
323 switch (request) {
338 // Find the adaptation request of the cpu based on the load. Return UPGRADE if
354 // A remote view request for a new resolution.
368 LOG(LS_INFO) << "VAdapt View Request: "
375 // A Bandwidth GD request for new resolution
377 int width, int height, AdaptRequest request) {
383 if (KEEP != request) {
389 // Update the encoder desired format based on the request.
391 StepPixelCount(request, &encoder_desired_num_pixels_)
431 AdaptRequest request = FindCpuRequest(current_cpus, max_cpus, local
[all...] |
| /external/chromium_org/webkit/browser/blob/ |
| blob_url_request_job_unittest.cc | 59 virtual void OnResponseStarted(net::URLRequest* request) OVERRIDE {
60 if (request->status().is_success()) {
61 EXPECT_TRUE(request->response_headers());
62 ReadSome(request); variable
68 virtual void OnReadCompleted(net::URLRequest* request,
71 ReceiveData(request, bytes_read);
79 void ReadSome(net::URLRequest* request) {
80 if (!request->is_pending()) {
86 if (!request->Read(received_data_.get(), kBufferSize, &bytes_read)) {
87 if (!request->status().is_io_pending())
[all...] |
| /external/chromium_org/cloud_print/gcp20/prototype/ |
| privet_http_server.cc | 46 // Returns |true| if |request| should be GET method.
47 bool IsGetMethod(const std::string& request) {
48 return request == "/privet/info"/* ||
49 request == "/privet/accesstoken" ||
50 request == "/privet/capabilities" ||
51 request == "/privet/printer/jobstate"*/;
54 // Returns |true| if |request| should be POST method.
55 bool IsPostMethod(const std::string& request) {
56 return request == "/privet/register"/* ||
57 request == "/privet/printer/createjob" |
[all...] |
| /external/chromium_org/chrome/browser/signin/ |
| oauth2_token_service_unittest.cc | 36 virtual void OnGetTokenFailure(const OAuth2TokenService::Request* request,
38 TestingOAuth2TokenServiceConsumer::OnGetTokenFailure(request, error);
44 scoped_ptr<OAuth2TokenService::Request> request_;
94 scoped_ptr<OAuth2TokenService::Request> request(
104 scoped_ptr<OAuth2TokenService::Request> request(
122 scoped_ptr<OAuth2TokenService::Request> request(
[all...] |
| /device/generic/goldfish/camera/ |
| EmulatedCamera3.h | 100 virtual status_t processCaptureRequest(camera3_capture_request *request);
135 /** Template request settings provision */
143 camera3_capture_request_t *request);
|
| /external/chromium/chrome/browser/chromeos/ |
| version_loader.h | 82 // Calls ParseVersion to get the version # and notifies request.
85 void GetVersion(scoped_refptr<GetVersionRequest> request,
88 // Calls ParseFirmware to get the firmware # and notifies request.
90 void GetFirmware(scoped_refptr<GetFirmwareRequest> request);
|
| /external/chromium/chrome/browser/history/ |
| top_sites_backend.h | 62 // Schedules a request that does nothing on the DB thread, but then notifies
64 // finished processing a request.
81 scoped_refptr<GetMostVisitedThumbnailsRequest> request);
94 // Notifies the request.
95 void DoEmptyRequestOnDBThread(scoped_refptr<EmptyRequestRequest> request);
|
| /external/chromium/chrome/browser/printing/ |
| print_dialog_cloud_uitest.cc | 65 explicit SimpleTestJob(net::URLRequest* request)
66 : net::URLRequestTestJob(request, test_headers(),
150 virtual void OnResponseCompleted(net::URLRequest* request) {
216 net::URLRequestJob* PrintDialogCloudTest::Factory(net::URLRequest* request,
219 request->set_delegate(TestController::GetInstance()->delegate());
220 if (request &&
221 (request->url() == TestController::GetInstance()->expected_url())) {
224 return new SimpleTestJob(request);
|
| /external/chromium/chrome/browser/sessions/ |
| session_backend.h | 69 scoped_refptr<BaseSessionService::InternalGetCommandsRequest> request);
88 scoped_refptr<BaseSessionService::InternalGetCommandsRequest> request);
|
| /external/chromium/chrome/browser/ssl/ |
| ssl_add_cert_handler.cc | 17 SSLAddCertHandler::SSLAddCertHandler(net::URLRequest* request,
25 ResourceDispatcherHost::InfoForRequest(request);
|
