| /external/chromium_org/third_party/WebKit/Tools/Scripts/webkitpy/thirdparty/mod_pywebsocket/ |
| msgutil.py | 33 Note: request.connection.write/read are used in this module, even though
36 request.write/read are not suitable because they don't allow direct raw
53 def close_connection(request):
57 request: mod_python request.
59 request.ws_stream.close_connection()
62 def send_message(request, payload_data, end=True, binary=False):
66 request: mod_python request.
75 request.ws_stream.send_message(payload_data, end, binary
[all...] |
| /external/chromium_org/tools/telemetry/telemetry/core/backends/chrome/ |
| inspector_page.py | 45 request = {
51 self._inspector_backend.SyncRequest(request)
54 request = {
60 res = self._inspector_backend.SyncRequest(request)
67 request = {
70 res = self._inspector_backend.SyncRequest(request, timeout)
101 request = {
107 self._inspector_backend.SyncRequest(request, timeout)
113 request = {
116 res = self._inspector_backend.SyncRequest(request, timeout
[all...] |
| /external/chromium_org/ui/ozone/platform/dri/ |
| dri_buffer.cc | 52 struct drm_mode_create_dumb request; local
53 request.width = info.width();
54 request.height = info.height();
55 request.bpp = info.bytesPerPixel() << 3;
56 request.flags = 0;
58 if (drmIoctl(dri->get_fd(), DRM_IOCTL_MODE_CREATE_DUMB, &request) < 0) {
64 *handle = request.handle;
65 *stride = request.pitch;
68 map_request.handle = request.handle;
72 DestroyDumbBuffer(dri->get_fd(), request.handle)
[all...] |
| /external/chromium_org/android_webview/native/ |
| android_protocol_handler.cc | 49 void MarkRequestAsFailed(net::URLRequest* request) {
50 request->SetUserData(kPreviouslyFailedKey,
54 bool HasRequestPreviouslyFailed(net::URLRequest* request) {
55 return request->GetUserData(kPreviouslyFailedKey) != NULL;
67 virtual void OnInputStreamOpenFailed(net::URLRequest* request,
71 net::URLRequest* request,
76 net::URLRequest* request,
90 net::URLRequest* request,
93 virtual bool ShouldHandleRequest(const net::URLRequest* request) const = 0;
102 const net::URLRequest* request) const OVERRIDE
[all...] |
| /frameworks/volley/src/com/android/volley/toolbox/ |
| HttpClientStack.java | 20 import com.android.volley.Request;
21 import com.android.volley.Request.Method;
48 * An HttpStack that performs request over an {@link HttpClient}.
75 public HttpResponse performRequest(Request<?> request, Map<String, String> additionalHeaders)
77 HttpUriRequest httpRequest = createHttpRequest(request, additionalHeaders);
79 addHeaders(httpRequest, request.getHeaders());
82 int timeoutMs = request.getTimeoutMs();
91 * Creates the appropriate subclass of HttpUriRequest for passed in request.
94 /* protected */ static HttpUriRequest createHttpRequest(Request<?> request
[all...] |
| /external/chromium_org/net/url_request/ |
| url_request_test_util.cc | 196 void TestDelegate::OnReceivedRedirect(URLRequest* request,
199 EXPECT_TRUE(request->is_redirecting());
202 request->GetFullRequestHeaders(&full_request_headers_);
210 request->Cancel();
214 void TestDelegate::OnBeforeNetworkStart(URLRequest* request, bool* defer) {
223 void TestDelegate::OnAuthRequired(URLRequest* request,
227 request->SetAuth(credentials_);
229 request->CancelAuth();
233 void TestDelegate::OnSSLCertificateError(URLRequest* request,
238 // cancel the request
[all...] |
| /external/chromium_org/chrome/browser/renderer_host/ |
| chrome_resource_dispatcher_host_delegate.cc | 173 // If the request was for a prerender, abort the prerender and do not
194 // If there is no longer a WebContents, the request may have raced with tab
195 // closing. Don't fire the external request. (It may have been a prerender.)
219 net::URLRequest* request,
228 // Check for PNaCl pexe request.
230 const net::HttpRequestHeaders& headers = request->extra_request_headers();
243 cus->GetOnDemandUpdater().GetOnDemandResourceThrottle(request, crx_id));
271 // request. Otherwise, do a normal request to warm the cache.
277 // If prefetch is disabled, kill the request
[all...] |
| /external/chromium_org/net/spdy/ |
| hpack_huffman_aggregator_test.cc | 48 static bool IsCrossOrigin(const HttpRequestInfo& request) {
49 return HpackHuffmanAggregator::IsCrossOrigin(request);
80 HttpRequestInfo request; local
81 request.url = GURL("https://www.foo.com/a/page");
84 request.load_flags = LOAD_MAIN_FRAME;
85 EXPECT_FALSE(peer_.IsCrossOrigin(request));
88 request.load_flags = 0;
89 EXPECT_TRUE(peer_.IsCrossOrigin(request));
92 request.load_flags = LOAD_MAIN_FRAME;
93 request.extra_headers.SetHeader(HttpRequestHeaders::kReferer
[all...] |
| /external/chromium_org/sandbox/mac/ |
| mach_message_server.cc | 55 // Allocate the message request and reply buffers.
62 MACH_LOG(ERROR, kr) << "Failed to allocate request buffer.";
88 pid_t MachMessageServer::GetMessageSenderPID(mach_msg_header_t* request) {
89 // Get the PID of the task that sent this request. This requires getting at
93 reinterpret_cast<vm_address_t>(request) +
94 round_msg(request->msgh_size));
110 void MachMessageServer::ForwardMessage(mach_msg_header_t* request,
112 request->msgh_local_port = request->msgh_remote_port;
113 request->msgh_remote_port = destination
141 mach_msg_header_t* request = local
[all...] |
| /external/chromium-trace/trace-viewer/third_party/pywebsocket/src/test/ |
| test_mux.py | 170 def do_extra_handshake(self, request):
173 def _do_echo(self, request, channel_events):
175 message = request.ws_stream.receive_message()
183 request.ws_stream.send_message(message)
185 def _do_ping(self, request, channel_events):
186 request.ws_stream.send_ping('Ping!')
188 def transfer_data(self, request):
189 self.channel_events[request.channel_id] = _ChannelEvent()
193 if request.uri.endswith('echo'):
194 self._do_echo(request,
[all...] |
| /external/mdnsresponder/mDNSShared/ |
| uds_daemon.c | 93 typedef void (*req_termination_fn)(request_state *request);
100 request_state *request; member in struct:registered_record_entry
112 request_state *request; member in struct:service_instance
141 // for each new request. This is because, until we've read the ipc_msg_hdr to find out what the
161 registered_record_entry *reg_recs; // list of registrations for a connection-oriented request
345 // We also set req->terminate to a bogus value so we know if abort_request() gets called again for this request
358 mDNSlocal reply_state *create_reply(const reply_op_t op, const size_t datalen, request_state *const request)
379 reply->mhdr->client_context = request->hdr.client_context;
385 // Append a reply to the list in a request object
386 // If our request is sharing a connection, then we append our reply_state onto the primary's lis
888 request_state *request = re->request; local
1529 request_state *request; local
1828 request_state *request; local
3092 request_state *request = question->QuestionContext; local
3253 request_state *request = (request_state *)n->clientContext; local
3917 request_state *request = NewRequest(); local
[all...] |
| /external/chromium_org/chrome/browser/metrics/ |
| tracking_synchronizer.cc | 40 // The "RequestContext" structure describes an individual request received
96 RequestContext* request = new RequestContext( local
98 outstanding_requests_.Get()[sequence_number] = request;
100 return request;
113 RequestContext* request = it->second;
114 DCHECK_EQ(sequence_number, request->sequence_number_);
115 return request;
129 RequestContext* request = it->second;
130 DCHECK_EQ(sequence_number, request->sequence_number_);
131 bool received_process_group_count = request->received_process_group_count_
225 RequestContext* request = RequestContext::GetRequestContext(sequence_number); local
248 RequestContext* request = local
272 RequestContext* request = RequestContext::GetRequestContext(sequence_number); local
[all...] |
| /external/chromium_org/chrome/test/chromedriver/server/ |
| http_handler_unittest.cc | 41 net::HttpServerRequestInfo request; local
42 request.method = "get";
43 request.path = "base/path";
44 request.data = "body";
46 handler.Handle(request, base::Bind(&OnResponse, &response));
52 net::HttpServerRequestInfo request; local
53 request.method = "get";
54 request.path = "/path";
56 handler.Handle(request, base::Bind(&OnResponse, &response));
66 net::HttpServerRequestInfo request; local
85 net::HttpServerRequestInfo request; local
99 net::HttpServerRequestInfo request; local
111 net::HttpServerRequestInfo request; local
[all...] |
| /external/chromium_org/content/shell/renderer/test_runner/ |
| 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_description))
[all...] |
| /hardware/broadcom/wlan/bcmdhd/wifi_hal/ |
| rtt.cpp | 113 int createSetupRequest(WifiRequest& request) {
114 int result = request.create(GOOGLE_OUI, RTT_SUBCMD_SET_CONFIG);
119 nlattr *data = request.attr_start(NL80211_ATTR_VENDOR_DATA);
120 result = request.put_u8(RTT_ATTRIBUTE_TARGET_CNT, numRttParams);
124 nlattr *rtt_config = request.attr_start(RTT_ATTRIBUTE_TARGET_INFO);
127 nlattr *attr2 = request.attr_start(i);
132 result = request.put_addr(RTT_ATTRIBUTE_TARGET_MAC, rttParams[i].addr);
136 result = request.put_u8(RTT_ATTRIBUTE_TARGET_TYPE, rttParams[i].type);
140 result = request.put_u8(RTT_ATTRIBUTE_TARGET_PEER, rttParams[i].peer);
144 result = request.put(RTT_ATTRIBUTE_TARGET_CHAN, &rttParams[i].channel
[all...] |
| /external/apache-http/src/org/apache/http/ |
| HttpRequestInterceptor.java | 40 * Processes a request.
41 * Provides the ability to process a request before it is sent
55 * Processes a request.
56 * On the client side, this step is performed before the request is
60 * @param request the request to preprocess
61 * @param context the context for the request
66 void process(HttpRequest request, HttpContext context)
|
| /external/apache-http/src/org/apache/http/client/protocol/ |
| RequestDefaultHeaders.java | 45 * Request interceptor that adds default request headers.
59 public void process(final HttpRequest request, final HttpContext context)
61 if (request == null) {
62 throw new IllegalArgumentException("HTTP request may not be null");
65 Collection<?> defHeaders = (Collection<?>) request.getParams().getParameter(
69 request.addHeader((Header) defHeader);
|
| /external/chromium_org/chrome/browser/apps/ |
| app_url_redirector.h | 25 net::URLRequest* request,
|
| ephemeral_app_throttle.h | 26 net::URLRequest* request,
|
| /external/chromium_org/chrome/browser/chromeos/dbus/ |
| proxy_resolution_service_provider.cc | 29 class Request {
31 explicit Request(const std::string& source_url)
32 : callback_(base::Bind(&Request::OnCompletion, base::Unretained(this))),
36 virtual ~Request() {}
57 DISALLOW_COPY_AND_ASSIGN(Request);
68 for (std::set<Request*>::iterator iter = all_requests_.begin();
70 Request* request = *iter; local
71 LOG(WARNING) << "Pending request for " << request->source_url_
85 Request* request = new Request(source_url); variable
[all...] |
| /external/chromium_org/chrome/browser/feedback/system_logs/log_sources/ |
| chrome_internal_log_source.h | 19 virtual void Fetch(const SysLogsSourceCallback& request) OVERRIDE;
|
| /external/chromium_org/chrome/browser/net/spdyproxy/ |
| proxy_advisor.cc | 47 // request.
97 void ProxyAdvisor::OnResponseStarted(net::URLRequest* request) {
98 const net::URLRequestStatus& status(request->status());
103 } else if (request->GetResponseCode() != net::HTTP_OK) {
104 DLOG(WARNING) << "Proxy advisory status: " << request->GetResponseCode();
106 RequestComplete(request);
109 void ProxyAdvisor::OnReadCompleted(net::URLRequest* request, int bytes_read) {
131 scoped_ptr<net::URLRequest> request = context->CreateRequest( local
133 request->set_method("HEAD");
134 request->SetExtraRequestHeaderByName
[all...] |
| /external/chromium_org/chrome/browser/search/ |
| iframe_source_unittest.cc | 99 net::URLRequest* request = local
105 content::ResourceRequestInfo::AllocateForTesting(request,
113 return request;
159 scoped_ptr<net::URLRequest> request; local
160 request.reset(MockRequest("http://test/loader.js", true,
162 EXPECT_FALSE(source()->ShouldServiceRequest(request.get()));
163 request.reset(MockRequest("chrome-search://bogus/valid.js", true,
165 EXPECT_FALSE(source()->ShouldServiceRequest(request.get()));
166 request.reset(MockRequest("chrome-search://test/bogus.js", true,
168 EXPECT_FALSE(source()->ShouldServiceRequest(request.get()))
[all...] |
| /external/chromium_org/chrome/browser/ui/ |
| media_utils.h | 19 const content::MediaStreamRequest& request,
|
| /external/chromium_org/chrome/common/extensions/docs/examples/extensions/mappy/ |
| popup.js | 10 var request = new XMLHttpRequest();
12 request.open('GET', url, true);
14 request.onreadystatechange = function (e) {
15 console.log(request, e);
16 if (request.readyState == 4) {
17 if (request.status == 200) {
18 var json = JSON.parse(request.responseText);
36 request.send(null);
|
