| /external/smack/src/org/jivesoftware/smackx/workgroup/agent/ |
| OfferListener.java | 35 * the request (resulting in a revocation-by-timeout).
37 * @param request the Offer instance embodying the details of the offer
39 public void offerReceived (Offer request);
|
| /frameworks/av/media/mtp/ |
| MtpRequestPacket.cpp | 50 int MtpRequestPacket::write(struct usb_request *request)
54 request->buffer = mBuffer;
55 request->buffer_length = mPacketSize;
56 return transfer(request);
|
| MtpResponsePacket.cpp | 47 int MtpResponsePacket::read(struct usb_request *request) {
48 request->buffer = mBuffer;
49 request->buffer_length = mBufferSize;
50 int ret = transfer(request);
|
| /external/chromium/chrome/browser/chromeos/ |
| gview_request_interceptor_unittest.cc | 23 explicit GViewURLRequestTestJob(net::URLRequest* request)
24 : net::URLRequestTestJob(request, true) {
31 // interceptor, the mime type of the first request must be one of
33 // is a request for one of the test URLs that point to viewable
64 static net::URLRequestJob* Factory(net::URLRequest* request,
66 return new GViewURLRequestTestJob(request);
111 net::URLRequest request(GURL("http://foo.com/index.html"), &test_delegate_);
112 request.Start();
115 EXPECT_EQ(GURL("http://foo.com/index.html"), request.url());
119 net::URLRequest request(GURL("http://foo.com/file.pdf"), &test_delegate_)
[all...] |
| /packages/apps/Contacts/src/com/android/contacts/list/ |
| ContactsRequest.java | 109 public void copyFrom(ContactsRequest request) {
110 mValid = request.mValid;
111 mActionCode = request.mActionCode;
112 mRedirectIntent = request.mRedirectIntent;
113 mTitle = request.mTitle;
114 mSearchMode = request.mSearchMode;
115 mQueryString = request.mQueryString;
116 mIncludeProfile = request.mIncludeProfile;
117 mLegacyCompatibilityMode = request.mLegacyCompatibilityMode;
118 mDirectorySearchEnabled = request.mDirectorySearchEnabled
[all...] |
| /external/chromium_org/content/browser/renderer_host/media/ |
| media_stream_manager.cc | 58 static bool Requested(const MediaStreamRequest& request,
60 return (request.audio_type == stream_type ||
61 request.video_type == stream_type);
68 const MediaStreamRequest& request)
70 request(request),
76 // Update the request state and notify observers.
87 if (request.video_type != MEDIA_TAB_VIDEO_CAPTURE &&
88 request.audio_type != MEDIA_TAB_AUDIO_CAPTURE &&
103 request.tab_capture_device_id)
116 MediaStreamRequest request; member in class:content::MediaStreamManager::DeviceRequest
195 DeviceRequest* request = new DeviceRequest(NULL, stream_request); local
287 DeviceRequest* request = new DeviceRequest(requester, stream_request); local
398 DeviceRequest* request = new DeviceRequest(requester, stream_request); local
459 DeviceRequest* request = new DeviceRequest(requester, stream_request); local
582 DeviceRequest* request = requests_[label]; local
619 DeviceRequest* request = requests_[label]; local
680 DeviceRequest* request = NULL; local
808 DeviceRequest* request = requests_[*it]; local
926 DeviceRequest* request = request_it->second; local
[all...] |
| /external/chromium_org/content/browser/loader/ |
| resource_scheduler.cc | 32 // Adds |request| to the queue with given |priority|.
33 void Insert(ScheduledResourceRequest* request,
35 DCHECK(!ContainsKey(pointers_, request));
36 NetQueue::Pointer pointer = queue_.Insert(request, priority);
37 pointers_[request] = pointer;
40 // Removes |request| from the queue.
41 void Erase(ScheduledResourceRequest* request) {
42 PointerMap::iterator it = pointers_.find(request);
48 // Returns the highest priority request that's queued, or NULL if none are.
53 // Returns true if |request| is queued
300 ScheduledResourceRequest* request = client->pending_requests.FirstMax(); local
[all...] |
| /external/chromium/chrome/browser/extensions/ |
| extension_protocols.cc | 37 explicit URLRequestResourceBundleJob(net::URLRequest* request,
39 : net::URLRequestSimpleJob(request),
81 bool AllowExtensionResourceLoad(net::URLRequest* request,
85 ResourceDispatcherHost::InfoForRequest(request);
89 LOG(ERROR) << "Allowing load of " << request->url().spec()
91 << "request.";
101 ExtensionCanLoadInIncognito(request->url().host())) {
102 LOG(ERROR) << "Denying load of " << request->url().spec() << " from "
115 net::URLRequest* request,
118 static_cast<ChromeURLRequestContext*>(request->context())
[all...] |
| /external/chromium/chrome/browser/ |
| plugin_download_helper.cc | 46 net::URLRequest* request,
48 net::URLRequest::Delegate::OnAuthRequired(request, auth_info);
53 net::URLRequest* request,
56 net::URLRequest::Delegate::OnSSLCertificateError(request, cert_error, cert);
60 void PluginDownloadUrlHelper::OnResponseStarted(net::URLRequest* request) {
70 OnDownloadCompleted(request);
74 if (!request->status().is_success()) {
75 OnDownloadCompleted(request);
79 if (!request->Read(download_file_buffer_, kDownloadFileBufferSize,
83 if (!request->status().is_io_pending())
[all...] |
| /external/chromium_org/chrome/browser/speech/ |
| speech_recognition_bubble_controller.cc | 48 UIRequest request(REQUEST_CREATE);
49 request.render_process_id = render_process_id;
50 request.render_view_id = render_view_id;
51 request.element_rect = element_rect;
52 ProcessRequestInUiThread(request);
64 UIRequest request(REQUEST_SET_MESSAGE);
65 request.message = text;
66 ProcessRequestInUiThread(request);
76 UIRequest request(REQUEST_SET_INPUT_VOLUME);
77 request.volume = volume
[all...] |
| /frameworks/volley/src/com/android/volley/ |
| RequestQueue.java | 32 * A request dispatch queue with a thread pool of dispatchers.
34 * Calling {@link #add(Request)} will enqueue the given Request for dispatch,
45 * Staging area for requests that already have a duplicate request in flight.
48 * <li>containsKey(cacheKey) indicates that there is a request in flight for the given cache
50 * <li>get(cacheKey) returns waiting requests for the given cache key. The in flight request
54 private final Map<String, Queue<Request>> mWaitingRequests =
55 new HashMap<String, Queue<Request>>();
58 * The set of all requests currently being processed by this RequestQueue. A Request
62 private final Set<Request> mCurrentRequests = new HashSet<Request>()
[all...] |
| /external/chromium_org/net/proxy/ |
| network_delegate_error_observer_unittest.cc | 28 virtual int OnBeforeURLRequest(URLRequest* request,
33 virtual int OnBeforeSendHeaders(URLRequest* request,
38 virtual void OnSendHeaders(URLRequest* request,
41 URLRequest* request,
47 virtual void OnBeforeRedirect(URLRequest* request,
49 virtual void OnResponseStarted(URLRequest* request) OVERRIDE {}
50 virtual void OnRawBytesRead(const URLRequest& request,
52 virtual void OnCompleted(URLRequest* request, bool started) OVERRIDE {}
53 virtual void OnURLRequestDestroyed(URLRequest* request) OVERRIDE {}
60 URLRequest* request,
[all...] |
| proxy_script_fetcher_impl.cc | 89 // The URLRequest's destructor will cancel the outstanding request, and
106 void ProxyScriptFetcherImpl::OnResponseCompleted(URLRequest* request) {
107 DCHECK_EQ(request, cur_request_.get());
109 // Use |result_code_| as the request's error if we have already set it to
111 if (result_code_ == OK && !request->status().is_success())
112 result_code_ = request->status().error();
119 // It is invalid to call Fetch() while a request is already in progress.
157 // Post a task to timeout this request if it takes too long.
166 // Start the request.
181 void ProxyScriptFetcherImpl::OnAuthRequired(URLRequest* request,
[all...] |
| /external/okhttp/src/main/java/com/squareup/okhttp/internal/http/ |
| Job.java | 19 import com.squareup.okhttp.Request;
26 final Request request; field in class:Job
30 public Job(Dispatcher dispatcher, HttpURLConnection connection, Request request,
34 this.request = request;
45 .request(request)
55 for (int i = 0; i < request.headerCount(); i++)
[all...] |
| /external/chromium_org/content/browser/gpu/ |
| browser_gpu_channel_host_factory.cc | 87 CreateRequest* request,
92 request->event.Signal();
105 request));
110 CreateRequest* request, int32 route_id) {
111 request->route_id = route_id;
112 request->event.Signal();
118 CreateRequest request; local
122 &request,
130 request.event.Wait();
131 return request.route_id
[all...] |
| /external/apache-http/src/org/apache/http/protocol/ |
| HttpRequestExecutor.java | 49 * Takes care of request preprocessing and response postprocessing
61 * Create a new request executor.
76 * @param request the request, to obtain the executed method
79 protected boolean canResponseHaveBody(final HttpRequest request,
82 if ("HEAD".equalsIgnoreCase(request.getRequestLine().getMethod())) {
93 * Synchronously send a request and obtain the response.
95 * @param request the request to send. It will be preprocessed.
98 * @return the response to the request, postprocesse
[all...] |
| /frameworks/volley/src/com/android/volley/toolbox/ |
| HttpClientStack.java | 20 import com.android.volley.Request;
21 import com.android.volley.Request.Method;
44 * An HttpStack that performs request over an {@link HttpClient}.
71 public HttpResponse performRequest(Request<?> request, Map<String, String> additionalHeaders)
73 HttpUriRequest httpRequest = createHttpRequest(request, additionalHeaders);
75 addHeaders(httpRequest, request.getHeaders());
78 int timeoutMs = request.getTimeoutMs();
87 * Creates the appropriate subclass of HttpUriRequest for passed in request.
90 /* protected */ static HttpUriRequest createHttpRequest(Request<?> request
[all...] |
| /art/runtime/jdwp/ |
| jdwp_handler.cc | 94 static JdwpError FinishInvoke(JdwpState*, Request& request, ExpandBuf* pReply,
100 int32_t arg_count = request.ReadSigned32("argument count");
111 argTypes[i] = request.ReadTag();
113 argValues[i] = request.ReadValue(width);
117 uint32_t options = request.ReadUnsigned32("InvokeOptions bit flags");
161 static JdwpError VM_Version(JdwpState*, Request&, ExpandBuf* pReply)
185 static JdwpError VM_ClassesBySignature(JdwpState*, Request& request, ExpandBuf* pReply)
187 std::string classDescriptor(request.ReadUtf8String())
[all...] |
| /external/chromium_org/content/test/data/indexeddb/ |
| object_store_test.js | 30 var request = transaction.objectStore('stuff').get(testDate);
31 request.onsuccess = getByDateSuccess;
32 request.onerror = unexpectedErrorCallback;
39 var request = objectStore.get(1);
40 request.onsuccess = recordNotFound;
41 request.onerror = unexpectedSuccessCallback;
52 var request = objectStore.delete(1);
53 request.onsuccess = removeSuccess;
54 request.onerror = unexpectedErrorCallback;
61 var request = objectStore.get(1)
[all...] |
| /external/apache-http/src/org/apache/http/ |
| HttpClientConnection.java | 64 * Sends the request line and all headers over the connection.
65 * @param request the request whose headers to send.
69 void sendRequestHeader(HttpRequest request)
73 * Sends the request entity over the connection.
74 * @param request the request whose entity to send.
78 void sendRequestEntity(HttpEntityEnclosingRequest request)
82 * Receives the request line and headers of the next response available from
|
| /external/apache-http/src/org/apache/http/client/ |
| HttpClient.java | 84 * Executes a request using the default context.
86 * @param request the request to execute
88 * @return the response to the request. This is always a final response,
96 HttpResponse execute(HttpUriRequest request)
102 * Executes a request using the given context.
105 * @param request the request to execute
109 * @return the response to the request. This is always a final response,
117 HttpResponse execute(HttpUriRequest request, HttpContext context
[all...] |
| /external/chromium/chrome/browser/net/ |
| url_request_failed_dns_job.h | 15 explicit URLRequestFailedDnsJob(net::URLRequest* request);
19 static net::URLRequestJob* Factory(net::URLRequest* request,
|
| /external/chromium/net/proxy/ |
| proxy_resolver_mac.h | 26 RequestHandle* request,
29 virtual void CancelRequest(RequestHandle request);
|
| proxy_script_fetcher_impl.cc | 90 // The URLRequest's destructor will cancel the outstanding request, and
107 void ProxyScriptFetcherImpl::OnResponseCompleted(URLRequest* request) {
108 DCHECK_EQ(request, cur_request_.get());
110 // Use |result_code_| as the request's error if we have already set it to
112 if (result_code_ == OK && !request->status().is_success())
113 result_code_ = request->status().os_error();
121 // It is invalid to call Fetch() while a request is already in progress.
156 // Post a task to timeout this request if it takes too long.
163 // Start the request.
178 void ProxyScriptFetcherImpl::OnAuthRequired(URLRequest* request,
[all...] |
| /external/chromium/net/url_request/ |
| url_request_error_job.cc | 14 URLRequestErrorJob::URLRequestErrorJob(URLRequest* request, int error)
15 : URLRequestJob(request),
|
