| /external/jetty/src/java/org/eclipse/jetty/continuation/ |
| 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);
|
| 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);
|
| 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/ |
| 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.setRequestURI("")
[all...] |
| 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())
|
| 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/ |
| 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, &offset)
[all...] |
| 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())) {
|
| XmlRpcClient.h | 95 std::string _request; member in class:XmlRpc::XmlRpcClient
|
| XmlRpcServerConnection.h | 89 std::string _request; member in class:XmlRpc::XmlRpcServerConnection
|
| /external/chromium-trace/catapult/third_party/webtest/webtest/ |
| 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/ |
| 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/jetty/src/java/org/eclipse/jetty/http/gzip/ |
| 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;
|
| /external/autotest/frontend/shared/ |
| 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)
|
| 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...] |
| /external/autotest/scheduler/ |
| rdb_requests.py | 112 __slots__ = set(['_request_args', '_request'])
125 self._request = self.template(**kwargs)
136 return self._request
|
| rdb_testing_utils.py | 343 parent_job_id=parent_job_id)._request
|
| /external/autotest/frontend/tko/ |
| resources.py | 55 'test_results': TestResultCollection(self._request).link(),
|
| csv_encoder.py | 8 self._request = request
34 self._request['method'])
|
| /external/chromium-trace/catapult/third_party/mapreduce/mapreduce/ |
| base_handler.py | 265 self._request = request
275 return getattr(self._request, name)
|
| /prebuilts/gdb/darwin-x86/lib/python2.7/plat-mac/ |
| MiniAEFrame.py | 134 def callback_wrapper(self, _request, _reply):
135 _parameters, _attributes = aetools.unpackevent(_request)
|
| /prebuilts/python/darwin-x86/2.7.5/lib/python2.7/plat-mac/ |
| MiniAEFrame.py | 134 def callback_wrapper(self, _request, _reply):
135 _parameters, _attributes = aetools.unpackevent(_request)
|
| /external/chromium-trace/catapult/third_party/webapp2/ |
| webapp2.py | [all...] |
| /external/chromium-trace/catapult/third_party/gsutil/third_party/httplib2/python2/httplib2/ |
| __init__.py | 1308 def _request(self, conn, host, absolute_uri, request_uri, method, body, headers, redirections, cachekey): member in class:Http
[all...] |
| /external/chromium-trace/catapult/third_party/gsutil/third_party/httplib2/python3/httplib2/ |
| __init__.py | 1017 def _request(self, conn, host, absolute_uri, request_uri, method, body, headers, redirections, cachekey): member in class:Http
[all...] |
