| /external/jetty/src/java/org/eclipse/jetty/server/ |
| D | AbstractHttpConnection.java | 115 protected final Request _request; field in AbstractHttpConnection
162 _request = new Request(this); in AbstractHttpConnection()
180 _request = request; in AbstractHttpConnection()
305 return _request; in getRequest()
416 _request.recycle(); in reset()
451 boolean was_continuation=_request._async.isContinuation(); in handleRequest()
452 boolean handling=_request._async.handling() && server!=null && server.isRunning(); in handleRequest()
455 _request.setHandled(false); in handleRequest()
475 if (info==null && !_request.getMethod().equals(HttpMethods.CONNECT)) in handleRequest()
480 _request.setRequestURI(""); in handleRequest()
[all …]
|
| D | AsyncHttpConnection.java | 76 if (_request._async.isAsync()) in handle()
78 if (_request._async.isDispatchable()) in handle()
86 …ommitted() && !_generator.isComplete() && !_endp.isOutputShutdown() && !_request.getAsyncContinuat… in handle()
125 … Connection switched=(Connection)_request.getAttribute("org.eclipse.jetty.io.Connection"); in handle()
149 if (!complete && _request.getAsyncContinuation().isAsyncStarted()) in handle()
164 if (!_request.getAsyncContinuation().isAsyncStarted()) in handle()
196 if (_generator.isIdle() && !_request.getAsyncContinuation().isSuspended()) in onInputShutdown()
|
| D | BlockingHttpConnection.java | 107 … Connection switched=(Connection)_request.getAttribute("org.eclipse.jetty.io.Connection"); in handle()
121 …if (_endp.isInputShutdown() && _generator.isIdle() && !_request.getAsyncContinuation().isSuspended… in handle()
|
| /external/jetty/src/java/org/eclipse/jetty/continuation/ |
| D | Servlet3Continuation.java | 45 private final ServletRequest _request; field in Servlet3Continuation
59 _request=request; in Servlet3Continuation()
142 return _initial&&_request.getDispatcherType()!=DispatcherType.ASYNC; in isInitial()
154 return _request.isAsyncStarted(); in isSuspended()
188 _context=_request.startAsync(); in suspend()
201 _context=_request.startAsync(); in suspend()
221 return _request.getAttribute(name); in getAttribute()
230 _request.removeAttribute(name); in removeAttribute()
239 _request.setAttribute(name,attribute); in setAttribute()
|
| D | Jetty6Continuation.java | 45 private final ServletRequest _request; field in Jetty6Continuation
65 _request=request; in Jetty6Continuation()
94 return _request.getAttribute(name); in getAttribute()
103 _request.removeAttribute(name); in removeAttribute()
112 _request.setAttribute(name,attribute); in setAttribute()
|
| D | FauxContinuation.java | 51 private final ServletRequest _request; field in FauxContinuation
65 _request=request; in FauxContinuation()
472 return _request.getAttribute(name); in getAttribute()
481 _request.removeAttribute(name); in removeAttribute()
490 _request.setAttribute(name,attribute); in setAttribute()
|
| /external/xmlrpcpp/src/ |
| D | XmlRpcServerConnection.cpp | 125 _request = bp; in readHeader()
148 if (int(_request.length()) < _contentLength) { in readRequest()
150 if ( ! XmlRpcSocket::nbRead(this->getfd(), _request, &eof)) { in readRequest()
156 if (int(_request.length()) < _contentLength) { in readRequest()
166 XmlRpcUtil::log(3, "XmlRpcServerConnection::readRequest read %d bytes.", _request.length()); in readRequest()
197 _request = ""; in writeResponse()
235 XmlRpcUtil::log(5, "XmlRpcServerConnection::parseRequest:\n%s\n", _request.c_str()); in parseRequest()
237 std::string methodName = XmlRpcUtil::parseTag(METHODNAME_TAG, _request, &offset); in parseRequest()
239 if (methodName.size() > 0 && XmlRpcUtil::findTag(PARAMS_TAG, _request, &offset)) in parseRequest()
242 while (XmlRpcUtil::nextTagIs(PARAM_TAG, _request, &offset)) { in parseRequest()
[all …]
|
| D | XmlRpcClient.cpp | 231 _request = header + body; in generateRequest()
261 …XmlRpcUtil::log(5, "XmlRpcClient::writeRequest (attempt %d):\n%s\n", _sendAttempts+1, _request.c_s… in writeRequest()
264 if ( ! XmlRpcSocket::nbWrite(this->getfd(), _request, &_bytesWritten)) { in writeRequest()
269 …XmlRpcUtil::log(3, "XmlRpcClient::writeRequest: wrote %d of %d bytes.", _bytesWritten, _request.le… in writeRequest()
272 if (_bytesWritten == int(_request.length())) { in writeRequest()
|
| D | XmlRpcClient.h | 95 std::string _request; variable
|
| D | XmlRpcServerConnection.h | 89 std::string _request; variable
|
| /external/autotest/frontend/afe/ |
| 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_name)
[all …]
|
| /external/chromium-trace/catapult/third_party/webtest/webtest/ |
| 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/shared/ |
| 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 …]
|
| D | rest_client.py | 155 def _request(self, method, query_parameters=None, encoded_body=None): member in 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/jetty/src/java/org/eclipse/jetty/http/gzip/ |
| D | CompressedResponseWrapper.java | 47 protected HttpServletRequest _request; field in CompressedResponseWrapper
59 _request = request; in CompressedResponseWrapper()
90 return _request; in getRequest()
421 _compressedStream=newCompressedStream(_request,(HttpServletResponse)getResponse()); in getOutputStream()
444 _compressedStream=newCompressedStream(_request,(HttpServletResponse)getResponse()); in getWriter()
485 …protected abstract AbstractCompressedStream newCompressedStream(HttpServletRequest _request, HttpS… in newCompressedStream() argument
|
| /external/autotest/scheduler/ |
| D | rdb_requests.py | 125 self._request = self.template(**kwargs)
136 return self._request
|
| D | rdb_testing_utils.py | 343 parent_job_id=parent_job_id)._request
|
| /external/autotest/frontend/tko/ |
| D | csv_encoder.py | 8 self._request = request
34 self._request['method'])
|
| D | resources.py | 55 'test_results': TestResultCollection(self._request).link(),
|
| /external/chromium-trace/catapult/third_party/mapreduce/mapreduce/ |
| D | base_handler.py | 265 self._request = request
275 return getattr(self._request, name)
|
| /external/chromium-trace/catapult/third_party/webapp2/ |
| D | webapp2.py | 1727 def uri_for(_name, _request=None, *args, **kwargs): argument
1732 request = _request or get_request()
1796 _body=None, _request=None, _response=None, *args, **kwargs): argument
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/ |
| D | __init__.py | 1017 …def _request(self, conn, host, absolute_uri, request_uri, method, body, headers, redirections, cac… member in Http
1242 …(response, new_content) = self._request(conn, authority, uri, request_uri, method, body, headers, …
1272 …(response, content) = self._request(conn, authority, uri, request_uri, method, body, headers, redi…
|
| /external/chromium-trace/catapult/third_party/gsutil/third_party/httplib2/python2/httplib2/ |
| D | __init__.py | 1308 …def _request(self, conn, host, absolute_uri, request_uri, method, body, headers, redirections, cac… member in Http
1540 …(response, new_content) = self._request(conn, authority, uri, request_uri, method, body, headers, …
1570 …(response, content) = self._request(conn, authority, uri, request_uri, method, body, headers, redi…
|
| /external/chromium-trace/catapult/third_party/apiclient/googleapiclient/ |
| D | http.py | 509 self._request = request
543 http = self._request.http
|
| /external/chromium-trace/catapult/third_party/gsutil/gslib/ |
| D | gcs_json_media.py | 380 download_http._request = types.MethodType(OverrideRequest, download_http)
|