| /external/chromium_org/net/data/websocket/ |
| echo-with-no-extension_wsh.py | 8 def web_socket_do_extra_handshake(request):
9 request.ws_extension_processors = []
12 def web_socket_transfer_data(request):
14 line = request.ws_stream.receive_message()
18 request.ws_stream.send_message(line, binary=False)
22 request.ws_stream.send_message(line, binary=True)
|
| close-with-split-packet_wsh.py | 15 def web_socket_transfer_data(request):
17 request.ws_stream.receive_message()
20 def web_socket_passive_closing_handshake(request):
23 request.connection.write(packet[:1])
24 request.connection.write(packet[1:])
|
| /frameworks/volley/src/com/android/volley/ |
| NetworkDispatcher.java | 36 private final BlockingQueue<Request<?>> mQueue;
55 public NetworkDispatcher(BlockingQueue<Request<?>> queue,
74 private void addTrafficStatsTag(Request<?> request) {
75 // Tag the request (if API >= 14)
77 TrafficStats.setThreadStatsTag(request.getTrafficStatsTag());
84 Request<?> request; local
87 // Take a request from the queue.
88 request = mQueue.take()
[all...] |
| CacheDispatcher.java | 37 private final BlockingQueue<Request<?>> mCacheQueue;
40 private final BlockingQueue<Request<?>> mNetworkQueue;
61 BlockingQueue<Request<?>> cacheQueue, BlockingQueue<Request<?>> networkQueue,
88 // Get a request from the cache triage queue, blocking until
90 final Request<?> request = mCacheQueue.take(); local
91 request.addMarker("cache-queue-take");
93 // If the request has been canceled, don't bother dispatching it.
94 if (request.isCanceled())
[all...] |
| /external/chromium_org/android_webview/native/permission/ |
| permission_request_handler_client.h | 17 virtual void OnPermissionRequest(AwPermissionRequest* request) = 0;
18 virtual void OnPermissionRequestCanceled(AwPermissionRequest* request) = 0;
|
| /external/chromium_org/third_party/WebKit/Source/web/ |
| UserMediaClientImpl.cpp | 50 void UserMediaClientImpl::requestUserMedia(PassRefPtrWillBeRawPtr<UserMediaRequest> request)
53 m_client->requestUserMedia(request);
56 void UserMediaClientImpl::cancelUserMediaRequest(UserMediaRequest* request)
59 m_client->cancelUserMediaRequest(WebUserMediaRequest(request));
62 void UserMediaClientImpl::requestMediaDevices(PassRefPtrWillBeRawPtr<WebCore::MediaDevicesRequest> request)
65 m_client->requestMediaDevices(request);
68 void UserMediaClientImpl::cancelMediaDevicesRequest(WebCore::MediaDevicesRequest* request)
71 m_client->cancelMediaDevicesRequest(WebMediaDevicesRequest(request));
|
| /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/chromium_org/third_party/WebKit/Tools/RebaselineLogServer/ |
| main_unittest.py | 50 request = webapp2.Request.blank('/updatelog')
51 request.method = 'POST'
52 request.POST[main.LOG_PARAM] = 'data to log'
53 request.POST[main.NEW_ENTRY_PARAM] = 'on'
54 request.POST[main.NO_NEEDS_REBASELINE_PARAM] = 'off'
56 response = request.get_response(main.app)
60 response = request.get_response(main.app)
64 request = webapp2.Request.blank('/updatelog'
[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...] |
| /external/okhttp/okcurl/src/test/java/com/squareup/okhttp/curl/ |
| MainTest.java | 18 import com.squareup.okhttp.Request;
29 Request request = fromArgs("http://example.com").createRequest(); local
30 assertEquals("GET", request.method());
31 assertEquals("http://example.com", request.urlString());
32 assertNull(request.body());
36 Request request = fromArgs("-X", "PUT", "http://example.com").createRequest(); local
37 assertEquals("PUT", request.method());
38 assertEquals("http://example.com", request.urlString())
43 Request request = fromArgs("-d", "foo", "http:\/\/example.com").createRequest(); local
52 Request request = fromArgs("-d", "foo", "-X", "PUT", "http:\/\/example.com").createRequest(); local
61 Request request = fromArgs("-d", "foo", "-H", "Content-Type: application\/json", local
71 Request request = fromArgs("-e", "foo", "http:\/\/example.com").createRequest(); local
79 Request request = fromArgs("-A", "foo", "http:\/\/example.com").createRequest(); local
[all...] |
| /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_org/cc/resources/ |
| ui_resource_request.cc | 18 UIResourceRequest::UIResourceRequest(const UIResourceRequest& request) {
19 (*this) = request;
23 const UIResourceRequest& request) {
24 type_ = request.type_;
25 id_ = request.id_;
26 if (request.bitmap_) {
27 bitmap_ = make_scoped_ptr(new UIResourceBitmap(*request.bitmap_.get()));
|
| /external/chromium_org/net/base/ |
| network_delegate.h | 60 int NotifyBeforeURLRequest(URLRequest* request,
63 int NotifyBeforeSendHeaders(URLRequest* request,
66 void NotifySendHeaders(URLRequest* request,
69 URLRequest* request,
74 void NotifyBeforeRedirect(URLRequest* request,
76 void NotifyResponseStarted(URLRequest* request);
77 void NotifyRawBytesRead(const URLRequest& request, int bytes_read);
78 void NotifyCompleted(URLRequest* request, bool started);
79 void NotifyURLRequestDestroyed(URLRequest* request);
81 AuthRequiredResponse NotifyAuthRequired(URLRequest* request,
[all...] |
| /external/glide/library/src/main/java/com/bumptech/glide/request/target/ |
| BaseTarget.java | 1 package com.bumptech.glide.request.target;
7 import com.bumptech.glide.request.Request;
23 private Request request; field in class:BaseTarget
26 public void setRequest(Request request) {
27 this.request = request;
31 public Request getRequest()
[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_org/net/url_request/ |
| 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 | 25 URLRequest* request, NetworkDelegate* network_delegate) const {
27 const bool is_file = FileURLToFilePath(request->url(), &file_path);
31 !network_delegate->CanAccessFile(*request, file_path)) {
32 return new URLRequestErrorJob(request, network_delegate, ERR_ACCESS_DENIED);
44 return new URLRequestFileDirJob(request, network_delegate, file_path);
47 // Use a regular file request job for all non-directories (including invalid
49 return new URLRequestFileJob(request, network_delegate, file_path,
|
| /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...] |
| /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
111 TestRequest.Head request = new TestRequest.Head(); local
120 TestRequest.Options request = new TestRequest.Options(); local
129 TestRequest.Trace request = new TestRequest.Trace(); local
138 TestRequest.Patch request = new TestRequest.Patch(); local
147 TestRequest.PatchWithBody request = new TestRequest.PatchWithBody(); local
[all...] |
| /external/chromium_org/content/public/browser/ |
| resource_request_details.cc | 14 ResourceRequestDetails::ResourceRequestDetails(const net::URLRequest* request,
16 : url(request->url()),
17 original_url(request->original_url()),
18 method(request->method()),
19 referrer(request->referrer()),
20 has_upload(request->has_upload()),
21 load_flags(request->load_flags()),
22 status(request->status()),
24 ssl_cert_status(request->ssl_info().cert_status),
25 socket_address(request->GetSocketAddress())
[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/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...] |
| /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/google_apis/drive/ |
| request_sender.cc | 35 AuthenticatedRequestInterface* request) {
38 in_flight_requests_.insert(request);
41 // of the requests to request sender.
45 request->GetWeakPtr());
52 request->GetWeakPtr()));
54 request->Start(auth_service_->access_token(),
64 const base::WeakPtr<AuthenticatedRequestInterface>& request,
69 // Do nothing if the request is canceled during authentication.
70 if (!request.get())
75 StartRequestWithRetry(request.get())
[all...] |
