| /external/chromium_org/net/url_request/ |
| data_protocol_handler.cc | 15 URLRequest* request, NetworkDelegate* network_delegate) const {
16 return new URLRequestDataJob(request, network_delegate);
|
| ftp_protocol_handler.cc | 29 URLRequest* request, NetworkDelegate* network_delegate) const {
30 int port = request->url().IntPort();
31 if (request->url().has_port() &&
33 return new URLRequestErrorJob(request, network_delegate, ERR_UNSAFE_PORT);
36 return new URLRequestFtpJob(request,
|
| file_protocol_handler.cc | 20 URLRequest* request, NetworkDelegate* network_delegate) const {
22 const bool is_file = FileURLToFilePath(request->url(), &file_path);
26 !network_delegate->CanAccessFile(*request, file_path)) {
27 return new URLRequestErrorJob(request, network_delegate, ERR_ACCESS_DENIED);
39 return new URLRequestFileDirJob(request, network_delegate, file_path);
42 // Use a regular file request job for all non-directories (including invalid
44 return new URLRequestFileJob(request, network_delegate, file_path);
|
| /packages/apps/ContactsCommon/src/com/android/contacts/common/vcard/ |
| VCardImportExportListener.java | 24 void onImportProcessed(ImportRequest request, int jobId, int sequence);
25 void onImportParsed(ImportRequest request, int jobId, VCardEntry entry, int currentCount,
27 void onImportFinished(ImportRequest request, int jobId, Uri uri);
28 void onImportFailed(ImportRequest request);
29 void onImportCanceled(ImportRequest request, int jobId);
31 void onExportProcessed(ExportRequest request, int jobId);
32 void onExportFailed(ExportRequest request);
34 void onCancelRequest(CancelRequest request, int type);
|
| /external/kernel-headers/original/linux/ |
| elevator.h | 4 typedef int (elevator_merge_fn) (request_queue_t *, struct request **,
7 typedef void (elevator_merge_req_fn) (request_queue_t *, struct request *, struct request *);
9 typedef void (elevator_merged_fn) (request_queue_t *, struct request *);
13 typedef void (elevator_add_req_fn) (request_queue_t *, struct request *);
15 typedef struct request *(elevator_request_list_fn) (request_queue_t *, struct request *);
16 typedef void (elevator_completed_req_fn) (request_queue_t *, struct request *);
19 typedef int (elevator_set_req_fn) (request_queue_t *, struct request *, struct bio *, gfp_t);
20 typedef void (elevator_put_req_fn) (request_queue_t *, struct request *);
[all...] |
| /packages/apps/Gallery2/src/com/android/gallery3d/filtershow/pipeline/ |
| RenderingRequestTask.java | 31 static class Render implements Request {
32 RenderingRequest request; field in class:RenderingRequestTask.Render
36 RenderingRequest request; field in class:RenderingRequestTask.RenderResult
53 public void postRenderingRequest(RenderingRequest request) {
58 render.request = request;
63 public Result doInBackground(Request message) {
64 RenderingRequest request = ((Render) message).request; local
66 if (request.getType() == RenderingRequest.GEOMETRY_RENDERING)
83 RenderingRequest request = ((RenderResult) message).request; local
[all...] |
| /frameworks/volley/src/com/android/volley/ |
| NetworkDispatcher.java | 36 private final BlockingQueue<Request> mQueue;
55 public NetworkDispatcher(BlockingQueue<Request> queue,
76 Request request; local
79 // Take a request from the queue.
80 request = mQueue.take();
90 request.addMarker("network-queue-take");
92 // If the request was cancelled already, do not perform the
93 // network request.
94 if (request.isCanceled())
[all...] |
| CacheDispatcher.java | 38 private final BlockingQueue<Request> mCacheQueue;
41 private final BlockingQueue<Request> mNetworkQueue;
62 BlockingQueue<Request> cacheQueue, BlockingQueue<Request> networkQueue,
89 // Get a request from the cache triage queue, blocking until
91 final Request request = mCacheQueue.take(); local
92 request.addMarker("cache-queue-take");
94 // If the request has been canceled, don't bother dispatching it.
95 if (request.isCanceled())
[all...] |
| /frameworks/base/core/jni/ |
| android_hardware_UsbRequest.cpp | 62 struct usb_request* request = usb_request_new(device, &desc); local
63 if (request)
64 env->SetIntField(thiz, field_context, (int)request);
65 return (request != NULL);
72 struct usb_request* request = get_request_from_object(env, thiz); local
73 if (request) {
74 usb_request_free(request);
83 struct usb_request* request = get_request_from_object(env, thiz); local
84 if (!request) {
85 ALOGE("request is closed in native_queue")
121 struct usb_request* request = get_request_from_object(env, thiz); local
140 struct usb_request* request = get_request_from_object(env, thiz); local
170 struct usb_request* request = get_request_from_object(env, thiz); local
183 struct usb_request* request = get_request_from_object(env, thiz); local
[all...] |
| /external/chromium_org/third_party/WebKit/Source/web/ |
| UserMediaClientImpl.cpp | 50 void UserMediaClientImpl::requestUserMedia(PassRefPtr<UserMediaRequest> request)
53 m_client->requestUserMedia(request);
56 void UserMediaClientImpl::cancelUserMediaRequest(UserMediaRequest* request)
59 m_client->cancelUserMediaRequest(WebUserMediaRequest(request));
|
| /external/smack/src/org/jivesoftware/smackx/filetransfer/ |
| FileTransferListener.java | 30 * A request to send a file has been recieved from another user.
32 * @param request
33 * The request from the other user.
35 public void fileTransferRequest(final FileTransferRequest request);
|
| /external/chromium/net/base/ |
| network_delegate.h | 38 int NotifyBeforeURLRequest(URLRequest* request,
44 void NotifyResponseStarted(URLRequest* request);
45 void NotifyReadCompleted(URLRequest* request, int bytes_read);
46 void NotifyURLRequestDestroyed(URLRequest* request);
48 // Returns a URLRequestJob that will be used to handle the request if
51 // so that we can perform Delegate-dependent request handling from the static
54 URLRequestJob* MaybeCreateURLRequestJob(URLRequest* request);
61 // Called before a request is sent. Allows the delegate to rewrite the URL
63 // time, but will have no effect if the request has already been cancelled or
65 // the request or ERR_IO_PENDING if the result is not ready yet
[all...] |
| /external/chromium-trace/trace-viewer/third_party/pywebsocket/src/example/ |
| echo_wsh.py | 34 def web_socket_do_extra_handshake(request):
35 # This example handler accepts any request. See origin_check_wsh.py for how
41 def web_socket_transfer_data(request):
43 line = request.ws_stream.receive_message()
47 request.ws_stream.send_message(line, binary=False)
51 request.ws_stream.send_message(line, binary=True)
|
| /external/chromium-trace/trace-viewer/third_party/pywebsocket/src/test/ |
| test_handshake_draft75.py | 134 ( # HTTP request
388 request = _create_request(_GOOD_REQUEST)
389 request.connection.get_memorized_lines = _create_get_memorized_lines(
391 requests.append(request)
399 request = _create_request(_GOOD_REQUEST)
400 handshaker = handshake.Handshaker(request,
404 request.connection.written_data())
405 self.assertEqual('/demo', request.ws_resource)
406 self.assertEqual('http://example.com', request.ws_origin)
407 self.assertEqual('ws://example.com/demo', request.ws_location
[all...] |
| /external/chromium_org/chrome/browser/history/ |
| history_backend_android.cc | 12 scoped_refptr<InsertRequest> request,
14 if (request->canceled())
21 request->ForwardResult(request->handle(), id != 0, id);
25 scoped_refptr<QueryRequest> request,
30 if (request->canceled())
38 request->ForwardResult(request->handle(), statement, statement);
42 scoped_refptr<UpdateRequest> request,
46 if (request->canceled()
[all...] |
| /external/chromium_org/chrome/browser/history/android/ |
| android_history_provider_service.cc | 29 QueryRequest* request = new QueryRequest(callback); local
30 AddRequest(request, consumer);
35 &HistoryBackend::QueryHistoryAndBookmarks, NULL, request,
38 request->ForwardResultAsync(request->handle(), false, 0);
40 return request->handle();
50 UpdateRequest* request = new UpdateRequest(callback); local
51 AddRequest(request, consumer);
56 &HistoryBackend::UpdateHistoryAndBookmarks, NULL, request, row,
59 request->ForwardResultAsync(request->handle(), false, 0)
70 DeleteRequest* request = new DeleteRequest(callback); local
89 InsertRequest* request = new InsertRequest(callback); local
108 DeleteRequest* request = new DeleteRequest(callback); local
129 MoveStatementRequest* request = new MoveStatementRequest(callback); local
160 InsertRequest* request = new InsertRequest(callback); local
180 UpdateRequest* request = new UpdateRequest(callback); local
200 DeleteRequest* request = new DeleteRequest(callback); local
222 QueryRequest* request = new QueryRequest(callback); local
[all...] |
| /external/chromium_org/net/test/embedded_test_server/ |
| http_request_unittest.cc | 15 // Process request in chunks to check if the parser deals with border cases.
30 // Content data and another request in the same chunk (possible in http/1.1).
34 // Fetch the first request and validate it.
36 scoped_ptr<HttpRequest> request = parser.GetRequest(); local
37 EXPECT_EQ("/foobar.html", request->relative_url);
38 EXPECT_EQ(METHOD_POST, request->method);
39 EXPECT_EQ("1234567890", request->content);
40 ASSERT_EQ(3u, request->headers.size());
42 EXPECT_EQ(1u, request->headers.count("Host"));
43 EXPECT_EQ(1u, request->headers.count("Multi-line-header"))
63 scoped_ptr<HttpRequest> request = parser.GetRequest(); local
76 scoped_ptr<HttpRequest> request = parser.GetRequest(); local
[all...] |
| /external/chromium_org/net/base/ |
| network_delegate.cc | 14 URLRequest* request, const CompletionCallback& callback,
17 DCHECK(request);
19 return OnBeforeURLRequest(request, callback, new_url);
23 URLRequest* request, const CompletionCallback& callback,
28 return OnBeforeSendHeaders(request, callback, headers);
31 void NetworkDelegate::NotifySendHeaders(URLRequest* request,
34 OnSendHeaders(request, headers);
38 URLRequest* request,
45 return OnHeadersReceived(request, callback, original_response_headers,
49 void NetworkDelegate::NotifyResponseStarted(URLRequest* request) {
[all...] |
| /external/apache-http/src/org/apache/http/protocol/ |
| RequestContent.java | 46 * A request interceptor that decides about the transport encoding.
60 public void process(final HttpRequest request, final HttpContext context)
62 if (request == null) {
63 throw new IllegalArgumentException("HTTP request may not be null");
65 if (request instanceof HttpEntityEnclosingRequest) {
66 if (request.containsHeader(HTTP.TRANSFER_ENCODING)) {
69 if (request.containsHeader(HTTP.CONTENT_LEN)) {
72 ProtocolVersion ver = request.getRequestLine().getProtocolVersion();
73 HttpEntity entity = ((HttpEntityEnclosingRequest)request).getEntity();
75 request.addHeader(HTTP.CONTENT_LEN, "0")
[all...] |
| /external/chromium_org/webkit/browser/appcache/ |
| appcache_interceptor.cc | 22 net::URLRequest* request, AppCacheRequestHandler* handler) {
23 request->SetUserData(GetInstance(), handler); // request takes ownership
27 net::URLRequest* request) {
29 request->GetUserData(GetInstance()));
33 net::URLRequest* request, AppCacheService* service, int process_id,
48 // Create a handler for this request and associate it with the request.
50 host->CreateRequestHandler(request, resource_type);
52 SetHandler(request, handler)
[all...] |
| /development/ndk/sources/android/libportable/arch-x86/ |
| ioctl.c | 26 static inline int x86_change_request(int request)
28 if (request == FIOQSIZE_PORTABLE)
31 return request;
35 int WRAP(ioctl)(int fd, int request, ...)
40 va_start(ap, request);
44 return __ioctl(fd, x86_change_request(request), arg);
|
| /external/chromium_org/chrome/common/extensions/docs/server2/ |
| app_engine_handler.py | 7 from servlet import Request
14 request = Request(self.request.path,
15 self.request.url[:-len(self.request.path)],
16 self.request.headers)
17 response = Handler(request).Get()
|
| /frameworks/volley/tests/src/com/android/volley/toolbox/ |
| HurlStackTest.java | 19 import com.android.volley.Request.Method;
39 TestRequest.DeprecatedGet request = new TestRequest.DeprecatedGet(); local
40 assertEquals(request.getMethod(), Method.DEPRECATED_GET_OR_POST);
42 HurlStack.setConnectionParametersForRequest(mMockConnection, request);
48 TestRequest.DeprecatedPost request = new TestRequest.DeprecatedPost(); local
49 assertEquals(request.getMethod(), Method.DEPRECATED_GET_OR_POST);
51 HurlStack.setConnectionParametersForRequest(mMockConnection, request);
57 TestRequest.Get request = new TestRequest.Get(); local
58 assertEquals(request.getMethod(), Method.GET);
60 HurlStack.setConnectionParametersForRequest(mMockConnection, request);
66 TestRequest.Post request = new TestRequest.Post(); local
75 TestRequest.PostWithBody request = new TestRequest.PostWithBody(); local
84 TestRequest.Put request = new TestRequest.Put(); local
93 TestRequest.PutWithBody request = new TestRequest.PutWithBody(); local
102 TestRequest.Delete request = new TestRequest.Delete(); local
[all...] |
| /external/chromium/net/url_request/ |
| https_prober.cc | 43 void HTTPSProber::OnAuthRequired(URLRequest* request,
45 Success(request);
48 void HTTPSProber::OnSSLCertificateError(URLRequest* request,
51 request->ContinueDespiteLastError();
54 void HTTPSProber::OnResponseStarted(URLRequest* request) {
55 if (request->status().status() == URLRequestStatus::SUCCESS) {
56 Success(request);
58 Failure(request);
62 void HTTPSProber::OnReadCompleted(URLRequest* request, int bytes_read) {
72 void HTTPSProber::Success(URLRequest* request) {
[all...] |
| /external/chromium_org/chrome/browser/google_apis/ |
| request_sender.cc | 34 AuthenticatedRequestInterface* request) {
37 in_flight_requests_.insert(request);
40 // of the requests to request sender.
44 request->GetWeakPtr());
51 request->GetWeakPtr()));
53 request->Start(auth_service_->access_token(),
63 const base::WeakPtr<AuthenticatedRequestInterface>& request,
68 // Do nothing if the request is canceled during authentication.
69 if (!request.get())
74 StartRequestWithRetry(request.get())
[all...] |
