/external/chromium-trace/trace-viewer/third_party/pywebsocket/src/test/ |
H A D | test_dispatch.py | 122 'def web_socket_do_extra_handshake(request):pass\n' 123 'def web_socket_transfer_data(request):pass\n')) 149 request = mock.MockRequest() 150 request.ws_resource = '/origin_check' 151 request.ws_origin = 'http://example.com' 152 dispatcher.do_extra_handshake(request) # Must not raise exception. 154 request.ws_origin = 'http://bad.example.com' 156 dispatcher.do_extra_handshake(request) 165 request = mock.MockRequest() 166 request [all...] |
H A D | test_handshake_hybi08.py | 79 def _create_handshaker(request): 80 handshaker = Handshaker(request, mock.MockDispatcher()) 111 do_extra_handshake to reject the request. 115 raise HandshakeAbortedException('An exception to reject the request') 123 AbortedByUserException in do_extra_handshake to reject the request. 128 'request') 147 request = _create_request(_create_good_request_def()) 149 handshaker = Handshaker(request, dispatcher) 155 _EXPECTED_RESPONSE, request.connection.written_data()) 156 self.assertEqual('/demo', request [all...] |
/external/chromium_org/chrome/browser/extensions/api/identity/ |
H A D | identity_mint_queue.cc | 34 IdentityMintRequestQueue::Request* request) { 36 "identity", "IdentityMintRequestQueue", request, "type", type); 38 request_queue.push_back(request); 39 // If this is the first request, start it now. RequestComplete will start 48 IdentityMintRequestQueue::Request* request) { 51 request, 55 CHECK_EQ(request_queue.front(), request); 63 IdentityMintRequestQueue::Request* request) { 66 request, 69 GetRequestQueueMap(MINT_TYPE_INTERACTIVE)[key].remove(request); 31 RequestStart( IdentityMintRequestQueue::MintType type, const ExtensionTokenKey& key, IdentityMintRequestQueue::Request* request) argument 45 RequestComplete( IdentityMintRequestQueue::MintType type, const ExtensionTokenKey& key, IdentityMintRequestQueue::Request* request) argument 61 RequestCancel( const ExtensionTokenKey& key, IdentityMintRequestQueue::Request* request) argument [all...] |
/external/chromium_org/content/browser/service_worker/ |
H A D | service_worker_request_handler.cc | 34 net::URLRequest* request, 37 ServiceWorkerRequestHandler::GetHandler(request); 40 return handler->MaybeCreateJob(request, network_delegate); 57 net::URLRequest* request, 65 if (!request->url().SchemeIsHTTPOrHTTPS() || 66 !IsMethodSupportedForServiceWroker(request->method())) { 82 provider_host->SetDocumentUrl(net::SimplifyUrlForRequest(request->url())); 92 request->SetUserData(&kUserDataKey, handler.release()); 96 net::URLRequest* request) { 98 request 56 InitializeHandler( net::URLRequest* request, ServiceWorkerContextWrapper* context_wrapper, storage::BlobStorageContext* blob_storage_context, int process_id, int provider_id, bool skip_service_worker, ResourceType resource_type, scoped_refptr<ResourceRequestBody> body) argument 95 GetHandler( net::URLRequest* request) argument [all...] |
/external/chromium_org/ppapi/tests/ |
H A D | test_url_loader.cc | 103 * (hoping that there will be another request that could reuse the connection). 193 const pp::URLRequestInfo& request, 198 callback.WaitForResult(loader.Open(request, callback.GetCallback())); 299 pp::URLRequestInfo request(instance_); 300 request.SetURL("/echo"); 301 request.SetMethod(method); 302 request.SetHeaders(header); 304 return OpenUntrusted(request); 309 pp::URLRequestInfo request(instance_); 310 request 192 LoadAndCompareBody( const pp::URLRequestInfo& request, const std::string& expected_body) argument 317 OpenUntrusted(const pp::URLRequestInfo& request) argument 321 OpenTrusted(const pp::URLRequestInfo& request) argument 325 Open(const pp::URLRequestInfo& request, bool trusted) argument [all...] |
/external/chromium_org/google_apis/drive/ |
H A D | request_sender_unittest.cc | 20 // Enum for indicating the reason why a request is finished. 37 // to request another one. 84 // Test the situation that the request has finished. 105 // This request class itself does not return any response at this point. 138 TestRequest* request = new TestRequest(&request_sender_, local 141 base::WeakPtr<AuthenticatedRequestInterface> weak_ptr = request->GetWeakPtr(); 143 base::Closure cancel_closure = request_sender_.StartRequestWithRetry(request); 148 EXPECT_EQ(kTestAccessToken, request->passed_access_token()); 149 request->FinishRequestWithSuccess(); 150 EXPECT_FALSE(weak_ptr); // The request objec 161 TestRequest* request = new TestRequest(&request_sender_, local 181 TestRequest* request = new TestRequest(&request_sender_, local 200 TestRequest* request = new TestRequest(&request_sender_, local 220 TestRequest* request = new TestRequest(&request_sender_, local [all...] |
/external/chromium_org/chrome/browser/net/ |
H A D | resource_prefetch_predictor_observer.cc | 21 // Enum for measuring statistics pertaining to observed request, responses and 54 bool SummarizeResponse(net::URLRequest* request, argument 57 content::ResourceRequestInfo::ForRequest(request); 71 summary->navigation_id.main_frame_url = request->first_party_for_cookies(); 72 summary->navigation_id.creation_time = request->creation_time(); 73 summary->resource_url = request->original_url(); 75 request->GetMimeType(&summary->mime_type); 76 summary->was_cached = request->was_cached(); 105 net::URLRequest* request, 114 if (!ResourcePrefetchPredictor::ShouldRecordRequest(request, resource_typ 104 OnRequestStarted( net::URLRequest* request, content::ResourceType resource_type, int child_id, int frame_id) argument 135 OnRequestRedirected( const GURL& redirect_url, net::URLRequest* request) argument 169 OnResponseStarted( net::URLRequest* request) argument [all...] |
/external/chromium_org/third_party/libaddressinput/chromium/ |
H A D | chrome_metadata_source.cc | 67 std::map<const net::URLFetcher*, Request*>::iterator request = local 69 DCHECK(request != requests_.end()); 74 data->swap(request->second->data); 75 request->second->callback(ok, request->second->key, data.release()); 77 delete request->second; 78 requests_.erase(request); 102 Request* request = new Request(key, fetcher.Pass(), downloaded); local 103 request->fetcher->SaveResponseWithWriter( 105 new UnownedStringWriter(&request [all...] |
/external/chromium_org/chrome/browser/extensions/ |
H A D | extension_protocols_unittest.cc | 128 void StartRequest(net::URLRequest* request, argument 130 content::ResourceRequestInfo::AllocateForTesting(request, 137 request->Start(); 151 // Tests that making a chrome-extension request in an incognito context is 153 // in incognito, and it's either a non-main-frame request or a split-mode 181 // First test a main frame request. 184 // is blocked, we should see ADDRESS_UNREACHABLE. Otherwise, the request 186 scoped_ptr<net::URLRequest> request( 192 StartRequest(request.get(), content::RESOURCE_TYPE_MAIN_FRAME); 193 EXPECT_EQ(net::URLRequestStatus::FAILED, request 226 CheckForContentLengthHeader(net::URLRequest* request) argument [all...] |
/external/chromium-trace/trace-viewer/third_party/pywebsocket/src/mod_pywebsocket/ |
H A D | headerparserhandler.py | 34 function is called to handle WebSocket request. 84 def __init__(self, request=None): 87 if request is not None: 88 self._log_error = request.log_error 115 # TODO(tyoshino): Provide logging methods on request object. When 116 # request is mp_request object (when used together with Apache), the 117 # methods call request.log_error indirectly. When request is 178 def headerparserhandler(request): 179 """Handle request [all...] |
/external/chromium_org/chrome/browser/chromeos/fileapi/ |
H A D | external_file_url_request_job_unittest.cc | 60 net::URLRequest* request, 63 profile_id_, request, network_delegate); 90 virtual void OnReceivedRedirect(net::URLRequest* request, 95 request, redirect_info, defer_redirect); 131 // Create the URL request job factory. 230 scoped_ptr<net::URLRequest> request(url_request_context_->CreateRequest( 235 request->set_method("POST"); // Set non "GET" method. 236 request->Start(); 240 EXPECT_EQ(net::URLRequestStatus::FAILED, request->status().status()); 241 EXPECT_EQ(net::ERR_METHOD_NOT_SUPPORTED, request [all...] |
/external/chromium_org/net/http/ |
H A D | http_vary_data_unittest.cc | 17 net::HttpRequestInfo request; member in struct:__anon9340::TestTransaction 26 request.extra_headers.Clear(); 27 request.extra_headers.AddHeadersFromString(request_headers); 48 EXPECT_FALSE(v.Init(t.request, *t.response.get())); 59 EXPECT_TRUE(v.Init(t1.request, *t1.response.get())); 65 EXPECT_FALSE(v.Init(t2.request, *t2.response.get())); 77 EXPECT_TRUE(v.Init(a.request, *a.response.get())); 79 EXPECT_FALSE(v.MatchesRequest(b.request, *b.response.get())); 90 EXPECT_TRUE(v.Init(a.request, *a.response.get())); 92 EXPECT_FALSE(v.MatchesRequest(b.request, * [all...] |
/external/chromium_org/third_party/WebKit/Tools/Scripts/webkitpy/thirdparty/mod_pywebsocket/ |
H A D | headerparserhandler.py | 34 function is called to handle WebSocket request. 85 def __init__(self, request=None): 88 if request is not None: 89 self._log_error = request.log_error 116 # TODO(tyoshino): Provide logging methods on request object. When 117 # request is mp_request object (when used together with Apache), the 118 # methods call request.log_error indirectly. When request is 181 def headerparserhandler(request): 182 """Handle request [all...] |
/external/apache-http/src/org/apache/http/protocol/ |
H A D | RequestExpectContinue.java | 46 * A request interceptor that enables the expect-continue handshake. 65 public void process(final HttpRequest request, final HttpContext context) argument 67 if (request == null) { 68 throw new IllegalArgumentException("HTTP request may not be null"); 70 if (request instanceof HttpEntityEnclosingRequest) { 71 HttpEntity entity = ((HttpEntityEnclosingRequest)request).getEntity(); 72 // Do not send the expect header if request body is known to be empty 74 ProtocolVersion ver = request.getRequestLine().getProtocolVersion(); 75 if (HttpProtocolParams.useExpectContinue(request.getParams()) 77 request [all...] |
/external/chromium_org/chrome/browser/apps/ |
H A D | ephemeral_app_throttle.cc | 67 net::URLRequest* request, 73 if (request->method() != "GET" || !request->url().SchemeIsHTTPOrHTTPS()) 81 if (request->referrer().find("https://www.google.com") == std::string::npos) 90 if (request->url().spec().find( 94 std::string app_id(request->url().ExtractFileName()); 99 request, 66 MaybeCreateThrottleForLaunch( net::URLRequest* request, ProfileIOData* profile_io_data) argument
|
/external/chromium_org/content/public/browser/ |
H A D | resource_dispatcher_host_delegate.cc | 20 net::URLRequest* request, 28 net::URLRequest* request, 41 net::URLRequest* request) { 58 net::URLRequest* request, 66 net::URLRequest* request, 71 net::URLRequest* request, 79 net::URLRequest* request, 19 RequestBeginning( net::URLRequest* request, ResourceContext* resource_context, AppCacheService* appcache_service, ResourceType resource_type, ScopedVector<ResourceThrottle>* throttles) argument 27 DownloadStarting( net::URLRequest* request, ResourceContext* resource_context, int child_id, int route_id, int request_id, bool is_content_initiated, bool must_download, ScopedVector<ResourceThrottle>* throttles) argument 39 CreateLoginDelegate( net::AuthChallengeInfo* auth_info, net::URLRequest* request) argument 57 ShouldInterceptResourceAsStream( net::URLRequest* request, const std::string& mime_type, GURL* origin, std::string* payload) argument 65 OnStreamCreated( net::URLRequest* request, scoped_ptr<content::StreamHandle> stream) argument 70 OnResponseStarted( net::URLRequest* request, ResourceContext* resource_context, ResourceResponse* response, IPC::Sender* sender) argument 77 OnRequestRedirected( const GURL& redirect_url, net::URLRequest* request, ResourceContext* resource_context, ResourceResponse* response) argument
|
/external/chromium_org/content/shell/renderer/test_runner/ |
H A D | mock_webrtc_peer_connection_handler.cc | 31 const WebRTCSessionDescriptionRequest& request, 34 request_(request), 49 const WebRTCSessionDescriptionRequest& request) 51 request_(request) {} 63 const blink::WebRTCStatsRequest& request, 66 request_(request), 80 const WebRTCVoidRequest& request, 83 request_(request), 175 const WebRTCSessionDescriptionRequest& request, 184 this, request, session_descriptio 29 RTCSessionDescriptionRequestSuccededTask( MockWebRTCPeerConnectionHandler* object, const WebRTCSessionDescriptionRequest& request, const WebRTCSessionDescription& result) argument 47 RTCSessionDescriptionRequestFailedTask( MockWebRTCPeerConnectionHandler* object, const WebRTCSessionDescriptionRequest& request) argument 62 RTCStatsRequestSucceededTask(MockWebRTCPeerConnectionHandler* object, const blink::WebRTCStatsRequest& request, const blink::WebRTCStatsResponse& response) argument 79 RTCVoidRequestTask(MockWebRTCPeerConnectionHandler* object, const WebRTCVoidRequest& request, bool succeeded) argument 174 createOffer( const WebRTCSessionDescriptionRequest& request, const WebMediaConstraints& constraints) argument 190 createOffer( const WebRTCSessionDescriptionRequest& request, const blink::WebRTCOfferOptions& options) argument 197 createAnswer( const WebRTCSessionDescriptionRequest& request, const WebMediaConstraints& constraints) argument 211 setLocalDescription( const WebRTCVoidRequest& request, const WebRTCSessionDescription& local_description) argument 223 setRemoteDescription( const WebRTCVoidRequest& request, const WebRTCSessionDescription& remote_description) argument 255 addICECandidate( const WebRTCVoidRequest& request, const WebRTCICECandidate& ice_candidate) argument 277 getStats( const WebRTCStatsRequest& request) argument [all...] |
/external/chromium_org/net/proxy/ |
H A D | proxy_script_fetcher_impl.h | 27 // specified request context. 34 // Note that while a request is in progress, we will be holding a reference 45 void OnResponseCompleted(URLRequest* request); 54 virtual void OnAuthRequired(URLRequest* request, 56 virtual void OnSSLCertificateError(URLRequest* request, 59 virtual void OnResponseStarted(URLRequest* request) OVERRIDE; 60 virtual void OnReadCompleted(URLRequest* request, int num_bytes) OVERRIDE; 66 void ReadBody(URLRequest* request); 70 bool ConsumeBytesRead(URLRequest* request, int num_bytes); 72 // Called once the request ha [all...] |
/external/chromium_org/sandbox/mac/ |
H A D | xpc_message_server_unittest.cc | 54 bool Initialize(void (^demux_block)(IPCMessage request)) { argument 71 virtual void DemuxMessage(IPCMessage request) OVERRIDE { 72 demux_block_(request); variable 80 void (^demux_block_)(IPCMessage request); member in class:sandbox::BlockDemuxer 98 ASSERT_TRUE(fixture.Initialize(^(IPCMessage request) { 99 value = xpc_dictionary_get_uint64(request.xpc, "test_value"); 100 server->SendReply(server->CreateReply(request)); 103 xpc_object_t request = xpc_dictionary_create(NULL, NULL, 0); member in namespace:sandbox 104 xpc_dictionary_set_uint64(request, "test_value", 42); 107 EXPECT_EQ(0, xpc_pipe_routine(fixture.pipe(), request, 122 xpc_object_t request = xpc_dictionary_create(NULL, NULL, 0); variable 128 xpc_release(request); variable [all...] |
/external/chromium_org/tools/sheriffing/ |
H A D | statuspageinfo.js | 16 /** Send and parse an asynchronous request to get a repo status JSON. */ 24 var request = new XMLHttpRequest(); 25 request.open('GET', this.jsonUrl, true); 26 request.onreadystatechange = function() { 27 if (request.readyState == 4 && request.status == 200) { 31 var statusPageJson = JSON.parse(request.responseText); 37 request.send(null);
|
/external/chromium_org/v8/test/mjsunit/ |
H A D | 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 [all...] |
/external/okhttp/okhttp/src/main/java/com/squareup/okhttp/internal/http/ |
H A D | RequestLine.java | 12 * Returns the request status line, like "GET / HTTP/1.1". This is exposed 16 static String get(Request request, Proxy.Type proxyType, int httpMinorVersion) { argument 18 result.append(request.method()); 21 if (includeAuthorityInRequestLine(request, proxyType)) { 22 result.append(request.url()); 24 result.append(requestPath(request.url())); 33 * Returns true if the request line should contain the full URL with host 37 private static boolean includeAuthorityInRequestLine(Request request, Proxy.Type proxyType) { argument 38 return !request.isHttps() && proxyType == Proxy.Type.HTTP; 42 * Returns the path to request, lik [all...] |
H A D | ResponseCacheAdapter.java | 48 public Response get(Request request) throws IOException { argument 49 CacheResponse javaResponse = getJavaCachedResponse(request); 53 return JavaApiConverter.createOkResponse(request, javaResponse); 58 URI uri = response.request().uri(); 64 public boolean maybeRemove(Request request) throws IOException { argument 96 private CacheResponse getJavaCachedResponse(Request request) throws IOException { argument 97 Map<String, List<String>> headers = JavaApiConverter.extractJavaHeaders(request); 98 return delegate.get(request.uri(), request.method(), headers);
|
/external/chromium_org/net/url_request/ |
H A D | url_request_test_util.cc | 188 void TestDelegate::OnReceivedRedirect(URLRequest* request, argument 191 EXPECT_TRUE(request->is_redirecting()); 194 request->GetFullRequestHeaders(&full_request_headers_); 202 request->Cancel(); 206 void TestDelegate::OnBeforeNetworkStart(URLRequest* request, bool* defer) { argument 215 void TestDelegate::OnAuthRequired(URLRequest* request, argument 219 request->SetAuth(credentials_); 221 request->CancelAuth(); 225 void TestDelegate::OnSSLCertificateError(URLRequest* request, argument 230 // cancel the request 239 OnResponseStarted(URLRequest* request) argument 266 OnReadCompleted(URLRequest* request, int bytes_read) argument 302 OnResponseCompleted(URLRequest* request) argument 358 OnBeforeURLRequest( URLRequest* request, const CompletionCallback& callback, GURL* new_url) argument 377 OnBeforeSendHeaders( URLRequest* request, const CompletionCallback& callback, HttpRequestHeaders* headers) argument 393 OnBeforeSendProxyHeaders( net::URLRequest* request, const net::ProxyInfo& proxy_info, net::HttpRequestHeaders* headers) argument 401 OnSendHeaders( URLRequest* request, const HttpRequestHeaders& headers) argument 414 OnHeadersReceived( URLRequest* request, const CompletionCallback& callback, const HttpResponseHeaders* original_response_headers, scoped_refptr<HttpResponseHeaders>* override_response_headers, GURL* allowed_unsafe_redirect_url) argument 452 OnBeforeRedirect(URLRequest* request, const GURL& new_location) argument 476 OnResponseStarted(URLRequest* request) argument 494 OnRawBytesRead(const URLRequest& request, int bytes_read) argument 498 OnCompleted(URLRequest* request, bool started) argument 523 OnURLRequestDestroyed(URLRequest* request) argument 537 OnAuthRequired( URLRequest* request, const AuthChallengeInfo& auth_info, const AuthCallback& callback, AuthCredentials* credentials) argument 563 OnCanGetCookies(const URLRequest& request, const CookieList& cookie_list) argument 576 OnCanSetCookie(const URLRequest& request, const std::string& cookie_line, CookieOptions* options) argument 592 OnCanAccessFile(const URLRequest& request, const base::FilePath& path) const argument 608 OnCancelURLRequestWithPolicyViolatingReferrerHeader( const URLRequest& request, const GURL& target_url, const GURL& referrer_url) const argument 638 MaybeCreateJob( URLRequest* request, NetworkDelegate* network_delegate) const argument [all...] |
/external/chromium_org/extensions/shell/browser/ |
H A D | media_capture_util.cc | 37 const content::MediaStreamRequest& request, 41 DCHECK(request.audio_type == content::MEDIA_DEVICE_AUDIO_CAPTURE || 42 request.video_type == content::MEDIA_DEVICE_VIDEO_CAPTURE); 46 if (request.audio_type == content::MEDIA_DEVICE_AUDIO_CAPTURE) { 47 VerifyMediaAccessPermission(request.audio_type, extension); 50 request.requested_audio_device_id); 55 if (request.video_type == content::MEDIA_DEVICE_VIDEO_CAPTURE) { 56 VerifyMediaAccessPermission(request.video_type, extension); 59 request.requested_video_device_id); 79 << "Audio capture request bu 36 GrantMediaStreamRequest(content::WebContents* web_contents, const content::MediaStreamRequest& request, const content::MediaResponseCallback& callback, const Extension* extension) argument [all...] |