/external/jetty/src/java/org/eclipse/jetty/continuation/ |
H A D | Servlet3Continuation.java | 45 private final ServletRequest _request; field in class:Servlet3Continuation 59 _request=request; 142 return _initial&&_request.getDispatcherType()!=DispatcherType.ASYNC; 154 return _request.isAsyncStarted(); 188 _context=_request.startAsync(); 201 _context=_request.startAsync(); 221 return _request.getAttribute(name); 230 _request.removeAttribute(name); 239 _request.setAttribute(name,attribute);
|
H A D | FauxContinuation.java | 51 private final ServletRequest _request; field in class:FauxContinuation 65 _request=request; 472 return _request.getAttribute(name); 481 _request.removeAttribute(name); 490 _request.setAttribute(name,attribute);
|
H A D | Jetty6Continuation.java | 45 private final ServletRequest _request; field in class:Jetty6Continuation 65 _request=request; 94 return _request.getAttribute(name); 103 _request.removeAttribute(name); 112 _request.setAttribute(name,attribute);
|
/external/jetty/src/java/org/eclipse/jetty/server/ |
H A D | AbstractHttpConnection.java | 115 protected final Request _request; field in class:AbstractHttpConnection 162 _request = new Request(this); 180 _request = request; 305 return _request; 416 _request.recycle(); 451 boolean was_continuation=_request._async.isContinuation(); 452 boolean handling=_request._async.handling() && server!=null && server.isRunning(); 455 _request.setHandled(false); 475 if (info==null && !_request.getMethod().equals(HttpMethods.CONNECT)) 480 _request [all...] |
H A D | AsyncHttpConnection.java | 76 if (_request._async.isAsync()) 78 if (_request._async.isDispatchable()) 86 if (_generator.isCommitted() && !_generator.isComplete() && !_endp.isOutputShutdown() && !_request.getAsyncContinuation().isAsyncStarted()) 125 Connection switched=(Connection)_request.getAttribute("org.eclipse.jetty.io.Connection"); 149 if (!complete && _request.getAsyncContinuation().isAsyncStarted()) 164 if (!_request.getAsyncContinuation().isAsyncStarted()) 196 if (_generator.isIdle() && !_request.getAsyncContinuation().isSuspended())
|
H A D | BlockingHttpConnection.java | 107 Connection switched=(Connection)_request.getAttribute("org.eclipse.jetty.io.Connection"); 121 if (_endp.isInputShutdown() && _generator.isIdle() && !_request.getAsyncContinuation().isSuspended())
|
/external/xmlrpcpp/src/ |
H A D | XmlRpcServerConnection.cpp | 125 _request = bp; 148 if (int(_request.length()) < _contentLength) { 150 if ( ! XmlRpcSocket::nbRead(this->getfd(), _request, &eof)) { 156 if (int(_request.length()) < _contentLength) { 166 XmlRpcUtil::log(3, "XmlRpcServerConnection::readRequest read %d bytes.", _request.length()); 167 //XmlRpcUtil::log(5, "XmlRpcServerConnection::readRequest:\n%s\n", _request.c_str()); 197 _request = ""; 235 XmlRpcUtil::log(5, "XmlRpcServerConnection::parseRequest:\n%s\n", _request.c_str()); 237 std::string methodName = XmlRpcUtil::parseTag(METHODNAME_TAG, _request, &offset); 239 if (methodName.size() > 0 && XmlRpcUtil::findTag(PARAMS_TAG, _request, [all...] |
H A D | XmlRpcClient.cpp | 231 _request = header + body; 261 XmlRpcUtil::log(5, "XmlRpcClient::writeRequest (attempt %d):\n%s\n", _sendAttempts+1, _request.c_str()); 264 if ( ! XmlRpcSocket::nbWrite(this->getfd(), _request, &_bytesWritten)) { 269 XmlRpcUtil::log(3, "XmlRpcClient::writeRequest: wrote %d of %d bytes.", _bytesWritten, _request.length()); 272 if (_bytesWritten == int(_request.length())) {
|
H A D | XmlRpcClient.h | 95 std::string _request; member in class:XmlRpc::XmlRpcClient
|
H A D | XmlRpcServerConnection.h | 89 std::string _request; member in class:XmlRpc::XmlRpcServerConnection
|
/external/chromium-trace/catapult/third_party/webtest/webtest/ |
H A D | utils.py | 100 self._request = request 112 return self._request.url 119 self._request.headers[key] = header 122 return key in self._request.headers 125 return self._request.scheme 134 return self._request.headers.items()
|
/external/autotest/frontend/afe/ |
H A D | resources.py | 100 self._request, self.instance.atomic_group) 157 accessible_hosts = HostCollection(self._request) 267 platform_rep = (Label.from_optional_instance(self._request, 281 locked_by = (User.from_optional_instance(self._request, 286 queue_entries = QueueEntryCollection(self._request) 288 health_tasks = HealthTaskCollection(self._request) 527 self._request.REQUEST) 554 request_dict = self._request.REQUEST 566 entry = Host.from_uri_args(self._request, hostname) 569 entry = Label.from_uri_args(self._request, label_nam [all...] |
/external/jetty/src/java/org/eclipse/jetty/http/gzip/ |
H A D | CompressedResponseWrapper.java | 47 protected HttpServletRequest _request; field in class:CompressedResponseWrapper 59 _request = request; 90 return _request; 421 _compressedStream=newCompressedStream(_request,(HttpServletResponse)getResponse()); 444 _compressedStream=newCompressedStream(_request,(HttpServletResponse)getResponse()); 485 protected abstract AbstractCompressedStream newCompressedStream(HttpServletRequest _request, HttpServletResponse response) throws IOException; argument
|
/external/autotest/frontend/shared/ |
H A D | resource_lib.py | 43 self._request = request 64 if self._request.method.upper() not in self._permitted_methods: 67 handler = getattr(self, self._request.method.lower()) 157 return self._request.build_absolute_uri(path) 165 my_root = self._request.build_absolute_uri('/') 178 return resource_class.from_uri_args(self._request, **kwargs) 212 content_type = self._request.META.get('CONTENT_TYPE', 214 raw_data = self._request.raw_post_data 413 return self.entry_class(self._request, instance) 528 super(Relationship, self).__init__(some_entry._request) [all...] |
H A D | rest_client.py | 155 def _request(self, method, query_parameters=None, encoded_body=None): member in class:Resource 201 response = self._request('GET', 228 response = self._request('PUT', encoded_body=self._representation()) 234 response = self._request('DELETE') 241 response = self._request('POST', encoded_body=request_dict)
|
/external/autotest/scheduler/ |
H A D | rdb_requests.py | 112 __slots__ = set(['_request_args', '_request']) 125 self._request = self.template(**kwargs) 136 return self._request
|
H A D | rdb_testing_utils.py | 343 parent_job_id=parent_job_id)._request
|
/external/autotest/frontend/tko/ |
H A D | resources.py | 55 'test_results': TestResultCollection(self._request).link(),
|
H A D | csv_encoder.py | 8 self._request = request 34 self._request['method'])
|
/external/chromium-trace/catapult/third_party/mapreduce/mapreduce/ |
H A D | base_handler.py | 265 self._request = request 275 return getattr(self._request, name)
|
/external/chromium-trace/catapult/third_party/webapp2/ |
H A D | webapp2.py | 1727 def uri_for(_name, _request=None, *args, **kwargs): 1732 request = _request or get_request() 1796 _body=None, _request=None, _response=None, *args, **kwargs): 1812 uri = uri_for(_name, _request=_request, *args, **kwargs) 1814 body=_body, request=_request, response=_response)
|
/external/chromium-trace/catapult/third_party/gsutil/third_party/httplib2/python3/httplib2/ |
H A D | __init__.py | 1017 def _request(self, conn, host, absolute_uri, request_uri, method, body, headers, redirections, cachekey): member in class:Http 1242 (response, new_content) = self._request(conn, authority, uri, request_uri, method, body, headers, redirections, cachekey) 1272 (response, content) = self._request(conn, authority, uri, request_uri, method, body, headers, redirections, cachekey)
|
/external/chromium-trace/catapult/third_party/gsutil/gslib/ |
H A D | gcs_json_media.py | 380 download_http._request = types.MethodType(OverrideRequest, download_http)
|
/external/chromium-trace/catapult/third_party/apiclient/googleapiclient/ |
H A D | http.py | 509 self._request = request 543 http = self._request.http
|
/external/chromium-trace/catapult/third_party/gsutil/third_party/httplib2/python2/httplib2/ |
H A D | __init__.py | 1308 def _request(self, conn, host, absolute_uri, request_uri, method, body, headers, redirections, cachekey): member in class:Http 1540 (response, new_content) = self._request(conn, authority, uri, request_uri, method, body, headers, redirections, cachekey) 1570 (response, content) = self._request(conn, authority, uri, request_uri, method, body, headers, redirections, cachekey)
|