/external/chromium_org/chrome/browser/chromeos/settings/ |
device_oauth2_token_service.cc | 30 PendingRequest(const base::WeakPtr<RequestImpl>& request, 34 : request(request), 39 const base::WeakPtr<RequestImpl> request; member in struct:chromeos::DeviceOAuth2TokenService::PendingRequest 172 RequestImpl* request, 180 // If this is the first request for a token, start validation. 185 // Add a pending request that will be satisfied once validation completes. 187 request->AsWeakPtr(), client_id, client_secret, scopes)); 190 FailRequest(request, GoogleServiceAuthError::USER_NOT_SIGNED_UP); 193 FailRequest(request, GoogleServiceAuthError::INVALID_GAIA_CREDENTIALS) [all...] |
/external/chromium_org/third_party/WebKit/Source/platform/network/ |
ResourceRequest.cpp | 36 OwnPtr<ResourceRequest> request = adoptPtr(new ResourceRequest()); local 37 request->setURL(data->m_url); 38 request->setCachePolicy(data->m_cachePolicy); 39 request->setTimeoutInterval(data->m_timeoutInterval); 40 request->setFirstPartyForCookies(data->m_firstPartyForCookies); 41 request->setHTTPMethod(AtomicString(data->m_httpMethod)); 42 request->setPriority(data->m_priority, data->m_intraPriorityValue); 44 request->m_httpHeaderFields.adopt(data->m_httpHeaders.release()); 46 request->setHTTPBody(data->m_httpBody); 47 request->setAllowStoredCredentials(data->m_allowStoredCredentials) [all...] |
/external/apache-http/src/org/apache/http/impl/conn/ |
ProxySelectorRoutePlanner.java | 119 HttpRequest request, 123 if (request == null) { 125 ("Request must not be null."); 130 ConnRouteParams.getForcedRoute(request.getParams()); 143 ConnRouteParams.getLocalAddress(request.getParams()); 146 // If the client or request explicitly specifies a proxy (or no 148 HttpHost proxy = (HttpHost) request.getParams().getParameter(ConnRoutePNames.DEFAULT_PROXY); 150 proxy = determineProxy(target, request, context); 176 * @param request the request to be sent, never <code>null</code [all...] |
/external/chromium_org/chrome/browser/component_updater/ |
component_updater_utils.cc | 48 std::string request( 50 "<request protocol=\"3.0\" "); 53 base::StringAppendF(&request, "%s ", additional_attributes.c_str()); 57 &request, 75 base::StringAppendF(&request, " wow64=\"1\""); 77 base::StringAppendF(&request, ">"); 80 base::StringAppendF(&request, 86 &request, 92 // The actual payload of the request. 93 base::StringAppendF(&request, "%s</request>", request_body.c_str()) [all...] |
/external/chromium_org/chrome/browser/extensions/api/web_request/ |
web_request_permissions_unittest.cc | 35 // This extension has Web Request permissions, but no host permission. 37 // This extension has Web Request permissions, and *.com a host permission. 102 net::TestURLRequest request( 105 WebRequestPermissions::HideRequest(extension_info_map_.get(), &request)) 111 net::TestURLRequest request( 114 WebRequestPermissions::HideRequest(extension_info_map_.get(), &request)) 120 // Normally this request is not protected: 157 net::TestURLRequest request( 163 request.url(), 169 request.url() [all...] |
/external/chromium_org/chrome/browser/resources/cryptotoken/ |
requestqueue.js | 11 * Represents a queued request. Once given a token, call complete() once the 12 * request is processed (or dropped.) 17 /** Completes (or cancels) this queued request. */ 21 * @param {!RequestQueue} queue The queue for this request. 23 * this request. 24 * @param {RequestToken} opt_prev Previous request in the same queue. 25 * @param {RequestToken} opt_next Next request in the same queue. 42 /** Completes (or cancels) this queued request. */ 113 * Completes this token's request, and begins the next queued request, if on [all...] |
/external/chromium_org/google_apis/drive/ |
gdata_wapi_requests_unittest.cc | 49 // Handles a request for fetching a resource feed. 51 const net::test_server::HttpRequest& request) { 52 http_request_ = request; 54 const GURL absolute_url = test_server_.GetURL(request.relative_url); 72 // Check if this is an authorization request for an app. 74 if (request.method == net::test_server::METHOD_PUT && 75 request.content.find("<docs:authorizedApp>") != std::string::npos) { 92 // The incoming HTTP request is saved so tests can verify the request 106 GetResourceEntryRequest* request = new GetResourceEntryRequest local 136 GetResourceEntryRequest* request = new GetResourceEntryRequest( local [all...] |
/external/chromium_org/mojo/public/cpp/bindings/tests/ |
router_unittest.cc | 138 Message request; local 139 AllocRequestMessage(1, "hello", &request); 142 router0.AcceptWithResponder(&request, new MessageAccumulator(&message_queue)); 162 Message request; local 163 AllocRequestMessage(1, "hello", &request); 166 router0.AcceptWithResponder(&request, new MessageAccumulator(&message_queue)); 187 Message request; local 188 AllocRequestMessage(1, "hello", &request); 191 router0.AcceptWithResponder(&request,
|
/external/chromium_org/remoting/jingle_glue/ |
iq_sender.cc | 52 scoped_ptr<IqRequest> request(new IqRequest(this, callback, addressee)); 54 requests_[id] = request.get(); 55 return request.Pass(); 65 void IqSender::RemoveRequest(IqRequest* request) { 70 if (cur->second == request) { 109 IqRequest* request = it->second; local 111 if (request->addressee_ != from) { 114 << " Original JID: " << request->addressee_; 119 request->OnResponse(stanza);
|
/external/chromium_org/third_party/WebKit/Source/core/html/imports/ |
HTMLImportsController.cpp | 104 HTMLImportChild* HTMLImportsController::load(HTMLImport* parent, HTMLImportChildClient* client, FetchRequest request) 106 ASSERT(!request.url().isEmpty() && request.url().isValid()); 109 if (HTMLImportChild* childToShareWith = root()->find(request.url())) { 112 HTMLImportChild* child = createChild(request.url(), loader, parent, client); 117 bool sameOriginRequest = master()->securityOrigin()->canRequest(request.url()); 118 request.setCrossOriginAccessControl( 121 ResourcePtr<RawResource> resource = parent->document()->fetcher()->fetchImport(request); 126 HTMLImportChild* child = createChild(request.url(), loader, parent, client);
|
/external/chromium_org/third_party/protobuf/python/google/protobuf/ |
service_reflection.py | 144 rpc_controller, request, callback): 146 rpc_controller, request, callback) 157 rpc_controller, request, callback): 164 request: Request protocol message. 171 return method(rpc_controller, request, callback) 174 """Returns the class of the request protocol message. 178 request protocol message class. 215 return lambda inst, rpc_controller, request, callback: ( 266 return (lambda inst, rpc_controller, request, callback=None [all...] |
/external/protobuf/python/google/protobuf/ |
service_reflection.py | 144 rpc_controller, request, callback): 146 rpc_controller, request, callback) 157 rpc_controller, request, callback): 164 request: Request protocol message. 171 return method(rpc_controller, request, callback) 174 """Returns the class of the request protocol message. 178 request protocol message class. 215 return lambda inst, rpc_controller, request, callback: ( 266 return (lambda inst, rpc_controller, request, callback=None [all...] |
/hardware/libhardware/modules/camera/ |
Camera.cpp | 319 ALOGE("%s:%d: Invalid template request type: %d", __func__, mId, type); 325 int Camera::processCaptureRequest(camera3_capture_request_t *request) 329 ALOGV("%s:%d: request=%p", __func__, mId, request); 332 if (request == NULL) { 333 ALOGE("%s:%d: NULL request recieved", __func__, mId); 337 ALOGV("%s:%d: Request Frame:%d Settings:%p", __func__, mId, 338 request->frame_number, request->settings); 341 if (request->settings == NULL) [all...] |
/libcore/luni/src/test/java/libcore/io/ |
OsTest.java | 79 byte[] request = new byte[256]; 80 int requestLength = Libcore.os.read(clientFd, request, 0, request.length); 82 String s = new String(request, "UTF-8"); 101 byte[] request = string.getBytes("UTF-8"); 102 assertEquals(request.length, Libcore.os.write(clientFd, request, 0, request.length)); 104 byte[] response = new byte[request.length];
|
/packages/apps/Browser/src/com/android/browser/ |
FetchUrlMimeType.java | 51 private DownloadManager.Request mRequest; 56 public FetchUrlMimeType(Context context, DownloadManager.Request request, 59 mRequest = request; 81 HttpHead request = new HttpHead(mUri); local 84 request.addHeader("Cookie", mCookies); 91 response = client.execute(request); 110 if (request != null) { 111 request.abort(); 114 if (request != null) [all...] |
/packages/providers/DownloadProvider/tests/public_api_access/src/com/android/providers/downloads/public_api_access_tests/ |
PublicApiAccessTest.java | 143 // first try a minimal request 144 DownloadManager.Request request = new DownloadManager.Request(Uri.parse("http://localhost/path")); local 145 mManager.enqueue(request); 148 request.setAllowedNetworkTypes(DownloadManager.Request.NETWORK_WIFI); 149 request.setAllowedOverRoaming(false); 150 request.setTitle("test"); 151 request.setDescription("test") [all...] |
/external/chromium_org/chrome/browser/extensions/ |
url_request_util.cc | 43 // A request for an extension resource in a Chrome .pak file. These are used 47 URLRequestResourceBundleJob(net::URLRequest* request, 53 : net::URLRequestSimpleJob(request, network_delegate), 135 bool AllowCrossRendererResourceLoad(net::URLRequest* request, 140 content::ResourceRequestInfo::ForRequest(request); 143 if (extension_info_map->worker_process_map().Contains(request->url().host(), 155 std::string resource_path = request->url().path(); 161 // If the request is for navigations outside of webviews, then it should be 171 // don't have it, allow the request handling to continue with the rest of the 181 request->url().path().empty() ? std::string( [all...] |
/external/chromium_org/components/cronet/android/sample/src/org/chromium/cronet_sample_apk/ |
CronetSampleActivity.java | 73 Log.i(TAG, "****** Request Complete, status code is " 98 public void onResponseStarted(HttpUrlRequest request) { 100 + request.getContentLength()); 104 public void onRequestComplete(HttpUrlRequest request) { 105 Log.i(TAG, "****** Request Complete, status code is " 110 final String url = request.getUrl(); 111 final CharSequence text = "Completed " + request.getUrl() + " (" 112 + request.getHttpStatusCode() + ")"; 113 mHttpStatusCode = request.getHttpStatusCode(); 209 private void applyCommandLineToRequest(UrlRequest request) { 227 HttpUrlRequest request = mRequestFactory.createRequest( local 239 UrlRequest request = new SampleRequest(mRequestContext, url, local [all...] |
/external/chromium_org/components/cronet/android/ |
url_request_context_peer.cc | 34 virtual int OnBeforeURLRequest(net::URLRequest* request, 40 virtual int OnBeforeSendHeaders(net::URLRequest* request, 46 virtual void OnSendHeaders(net::URLRequest* request, 50 net::URLRequest* request, 58 virtual void OnBeforeRedirect(net::URLRequest* request, 61 virtual void OnResponseStarted(net::URLRequest* request) OVERRIDE {} 63 virtual void OnRawBytesRead(const net::URLRequest& request, 66 virtual void OnCompleted(net::URLRequest* request, bool started) OVERRIDE {} 68 virtual void OnURLRequestDestroyed(net::URLRequest* request) OVERRIDE {} 74 net::URLRequest* request, [all...] |
/external/chromium_org/third_party/WebKit/Source/modules/indexeddb/ |
IDBIndex.cpp | 107 IDBRequest* request = IDBRequest::create(scriptState, IDBAny::create(this), m_transaction.get()); local 108 request->setCursorDetails(IndexedDB::CursorKeyAndValue, direction); 109 backendDB()->openCursor(m_transaction->id(), m_objectStore->id(), m_metadata.id, keyRange, direction, false, blink::WebIDBTaskTypeNormal, WebIDBCallbacksImpl::create(request).leakPtr()); 110 return request; 138 IDBRequest* request = IDBRequest::create(scriptState, IDBAny::create(this), m_transaction.get()); local 139 backendDB()->count(m_transaction->id(), m_objectStore->id(), m_metadata.id, keyRange, WebIDBCallbacksImpl::create(request).leakPtr()); 140 return request; 170 IDBRequest* request = IDBRequest::create(scriptState, IDBAny::create(this), m_transaction.get()); local 171 request->setCursorDetails(IndexedDB::CursorKeyOnly, direction); 172 backendDB()->openCursor(m_transaction->id(), m_objectStore->id(), m_metadata.id, keyRange, direction, true, blink::WebIDBTaskTypeNormal, WebIDBCallbacksImpl::create(request).leakPtr()) 215 IDBRequest* request = IDBRequest::create(scriptState, IDBAny::create(this), m_transaction.get()); local [all...] |
/external/smack/src/org/jivesoftware/smackx/pubsub/ |
LeafNode.java | 69 PubSub request = createPubsubPacket(Type.GET, new GetItemsRequest(getId()));
local 71 PubSub result = (PubSub)SyncPacketSend.getReply(con, request);
90 PubSub request = createPubsubPacket(Type.GET, new GetItemsRequest(getId(), subscriptionId));
local 92 PubSub result = (PubSub)SyncPacketSend.getReply(con, request);
119 PubSub request = createPubsubPacket(Type.GET, new ItemsExtension(ItemsExtension.ItemsElementType.items, getId(), itemList));
local 121 PubSub result = (PubSub)SyncPacketSend.getReply(con, request);
138 PubSub request = createPubsubPacket(Type.GET, new GetItemsRequest(getId(), maxItems));
local 140 PubSub result = (PubSub)SyncPacketSend.getReply(con, request);
160 PubSub request = createPubsubPacket(Type.GET, new GetItemsRequest(getId(), subscriptionId, maxItems));
local 162 PubSub result = (PubSub)SyncPacketSend.getReply(con, request);
313 PubSub request = createPubsubPacket(Type.SET, new NodeExtension(PubSubElementType.PURGE_OWNER, getId()), PubSubElementType.PURGE_OWNER.getNamespace()); local 349 PubSub request = createPubsubPacket(Type.SET, new ItemsExtension(ItemsExtension.ItemsElementType.retract, getId(), items)); local [all...] |
/external/chromium_org/chrome/browser/ui/website_settings/ |
permission_bubble_manager.cc | 103 void PermissionBubbleManager::AddRequest(PermissionBubbleRequest* request) { 105 // TODO(gbillock): is there a race between an early request on a 110 // any request for which GetVisibleURL != GetLastCommittedURL. 113 request->GetRequestingHostname().GetOrigin() == request_url_.GetOrigin(); 115 // Don't re-add an existing request or one with a duplicate text request. 117 if (ExistingRequest(request, requests_, &same_object) || 118 ExistingRequest(request, queued_requests_, &same_object) || 119 ExistingRequest(request, queued_frame_requests_, &same_object)) { 121 request->RequestFinished() [all...] |
/external/chromium_org/net/socket/ |
client_socket_pool_base.cc | 26 // disabled, sockets are closed next time a socket request is made. 130 ClientSocketPoolBaseHelper::Request::Request( 147 ClientSocketPoolBaseHelper::Request::~Request() {} 221 // |this| must have a request that is actually stalled on the global socket 222 // limit. To find such a request, look for a group that has more requests 225 // |max_sockets_per_group_|, then the request is stalled on the group limit, 259 scoped_ptr<const Request> request) { 526 scoped_ptr<const Request> request = local 887 scoped_ptr<const Request> request = group->PopNextPendingRequest(); local 904 scoped_ptr<const Request> request = group->PopNextPendingRequest(); local 964 scoped_ptr<const Request> request = group->PopNextPendingRequest(); local 1040 scoped_ptr<const Request> request = group->PopNextPendingRequest(); local 1311 scoped_ptr<const Request> request = RemovePendingRequest(pointer); local [all...] |
/external/chromium_org/third_party/WebKit/Source/core/loader/ |
NavigationScheduler.cpp | 110 FrameLoadRequest request(m_originDocument.get(), ResourceRequest(KURL(ParsedURLString, m_url), m_referrer), "_self"); 111 request.setLockBackForwardList(lockBackForwardList()); 112 request.setClientRedirect(ClientRedirect); 113 frame->loader().load(request); variable 139 FrameLoadRequest request(originDocument(), ResourceRequest(KURL(ParsedURLString, url()), referrer()), "_self"); 140 request.setLockBackForwardList(lockBackForwardList()); 141 if (equalIgnoringFragmentIdentifier(frame->document()->url(), request.resourceRequest().url())) 142 request.resourceRequest().setCachePolicy(ReloadIgnoringCacheData); 143 request.setClientRedirect(ClientRedirect); 144 frame->loader().load(request); variable 167 frame->loader().load(request); variable [all...] |
/external/robolectric/src/main/java/com/xtremelabs/robolectric/tester/org/apache/http/ |
FakeHttpLayer.java | 44 public HttpResponse getResponse(HttpRequest request) { 73 * @param requestMatcher Request matcher 110 throw new RuntimeException("Unexpected call to execute, no pending responses are available. See Robolectric.addPendingResponse(). Request was: " + 214 public boolean matches(HttpRequest request) { 215 return requestMatcher.matches(request); 243 public boolean matches(HttpRequest request) { 244 return request.getRequestLine().getMethod().equals(method) && 245 request.getRequestLine().getUri().equals(uri); 257 public boolean matches(HttpRequest request) { 258 return request.getRequestLine().getUri().equals(uri) [all...] |