| /frameworks/volley/tests/src/com/android/volley/mock/ |
| MockResponseDelivery.java | 19 import com.android.volley.Request;
35 public void postResponse(Request<?> request, Response<?> response) {
41 public void postResponse(Request<?> request, Response<?> response, Runnable runnable) {
48 public void postError(Request<?> request, VolleyError error) {
|
| WaitableQueue.java | 20 import com.android.volley.Request;
30 public class WaitableQueue extends PriorityBlockingQueue<Request> {
31 private final Request<?> mStopRequest = new MagicStopRequest();
44 public Request<?> take() throws InterruptedException {
45 Request<?> item = super.take();
53 private static class MagicStopRequest extends Request<Object> {
|
| /external/okhttp/src/test/java/com/squareup/okhttp/ |
| RequestTest.java | 30 Request.Body body = Request.Body.create(contentType, "abc".getBytes(Util.UTF_8));
39 Request.Body body = Request.Body.create(contentType, "\u0800");
47 Request.Body body = Request.Body.create(contentType, "\u0800");
55 Request.Body body = Request.Body.create(contentType, "abc".getBytes(Util.UTF_8));
69 Request.Body body = Request.Body.create(contentType, file)
[all...] |
| /external/chromium_org/chrome/browser/signin/ |
| oauth2_token_service_test_util.h | 26 virtual void OnGetTokenSuccess(const OAuth2TokenService::Request* request,
29 virtual void OnGetTokenFailure(const OAuth2TokenService::Request* request,
|
| profile_oauth2_token_service_request_unittest.cc | 26 virtual void OnGetTokenSuccess(const OAuth2TokenService::Request* request,
29 virtual void OnGetTokenFailure(const OAuth2TokenService::Request* request,
48 const OAuth2TokenService::Request* request,
56 const OAuth2TokenService::Request* request,
64 class Request : public OAuth2TokenService::Request,
142 scoped_ptr<Request> request; local
[all...] |
| ubertoken_fetcher.h | 19 // This class can handle one request at a time.
50 virtual void OnGetTokenSuccess(const OAuth2TokenService::Request* request,
53 virtual void OnGetTokenFailure(const OAuth2TokenService::Request* request,
60 scoped_ptr<OAuth2TokenService::Request> access_token_request_;
|
| /external/chromium_org/chrome/common/extensions/docs/server2/ |
| handler_test.py | 11 from servlet import Request
18 handler = Handler(Request.ForTest('_notreal'))
|
| local_renderer.py | 10 from servlet import Request
22 return RenderServlet(Request.ForTest(path),
|
| /external/junit/src/org/junit/internal/requests/ |
| ClassRequest.java | 5 import org.junit.runner.Request;
8 public class ClassRequest extends Request {
|
| /external/nist-sip/java/javax/sip/ |
| Transaction.java | 4 import javax.sip.message.Request;
16 Request getRequest();
|
| Dialog.java | 8 import javax.sip.message.Request;
63 Request createRequest(String method) throws SipException;
64 Request createAck(long cseq) throws InvalidArgumentException, SipException;
65 Request createPrack(Response relResponse)
73 void sendAck(Request ackRequest) throws SipException;
|
| /frameworks/volley/src/com/android/volley/toolbox/ |
| HttpStack.java | 20 import com.android.volley.Request;
32 * Performs an HTTP request with the given parameters.
34 * <p>A GET request is sent if request.getPostBody() == null. A POST request is sent otherwise,
35 * and the Content-Type header is set to request.getPostBodyContentType().</p>
37 * @param request the request to perform
39 * {@link Request#getHeaders()}
42 public HttpResponse performRequest(Request<?> request, Map<String, String> additionalHeaders
[all...] |
| /external/chromium/net/proxy/ |
| mock_proxy_resolver.cc | 12 MockAsyncProxyResolverBase::Request::Request(
24 void MockAsyncProxyResolverBase::Request::CompleteNow(int rv) {
33 MockAsyncProxyResolverBase::Request::~Request() {}
64 scoped_refptr<Request> request = new Request(this, url, results, callback); local
65 pending_requests_.push_back(request);
68 *request_handle = reinterpret_cast<RequestHandle>(request.get())
75 scoped_refptr<Request> request = reinterpret_cast<Request*>(request_handle); local
[all...] |
| /external/chromium_org/net/proxy/ |
| mock_proxy_resolver.cc | 12 MockAsyncProxyResolverBase::Request::Request(
23 void MockAsyncProxyResolverBase::Request::CompleteNow(int rv) {
32 MockAsyncProxyResolverBase::Request::~Request() {}
59 scoped_refptr<Request> request = new Request(this, url, results, callback); local
60 pending_requests_.push_back(request);
63 *request_handle = reinterpret_cast<RequestHandle>(request.get())
70 scoped_refptr<Request> request = reinterpret_cast<Request*>(request_handle); local
[all...] |
| mock_proxy_resolver.h | 22 // user must call Request::CompleteNow() on a pending request to signal it.
25 class Request : public base::RefCounted<Request> {
27 Request(MockAsyncProxyResolverBase* resolver,
39 friend class base::RefCounted<Request>;
41 virtual ~Request();
71 typedef std::vector<scoped_refptr<Request> > RequestsList;
102 void RemovePendingRequest(Request* request);
[all...] |
| /external/nist-sip/java/gov/nist/javax/sip/parser/ |
| TokenNames.java | 27 import javax.sip.message.Request;
45 public static final String INVITE = Request.INVITE;
46 public static final String ACK = Request.ACK;
47 public static final String BYE = Request.BYE;
48 public static final String SUBSCRIBE = Request.SUBSCRIBE;
49 public static final String NOTIFY = Request.NOTIFY;
50 public static final String OPTIONS = Request.OPTIONS;
51 public static final String REGISTER = Request.REGISTER;
52 public static final String MESSAGE = Request.MESSAGE;
53 public static final String PUBLISH = Request.PUBLISH
[all...] |
| /external/chromium/net/http/ |
| http_stream_factory_impl_request.cc | 15 HttpStreamFactoryImpl::Request::Request(const GURL& url,
32 HttpStreamFactoryImpl::Request::~Request() {
48 void HttpStreamFactoryImpl::Request::SetSpdySessionKey(
58 void HttpStreamFactoryImpl::Request::AttachJob(Job* job) {
64 void HttpStreamFactoryImpl::Request::Complete(
78 void HttpStreamFactoryImpl::Request::OnStreamReady(
109 void HttpStreamFactoryImpl::Request::OnStreamFailed(
134 void HttpStreamFactoryImpl::Request::OnCertificateError
[all...] |
| /external/chromium_org/chrome/browser/predictors/ |
| resource_prefetcher.h | 35 // Denotes the prefetch request for a single subresource.
36 struct Request {
37 explicit Request(const GURL& i_resource_url);
38 Request(const Request& other);
68 typedef ScopedVector<Request> RequestVector;
107 // Starts a net::URLRequest for the input |request|.
108 void SendRequest(Request* request);
110 // Called by |SendRequest| to start the |request|. This is necessary to stu
[all...] |
| resource_prefetcher.cc | 22 ResourcePrefetcher::Request::Request(const GURL& i_resource_url)
28 ResourcePrefetcher::Request::Request(const Request& other)
91 std::list<Request*>::iterator request_it = request_queue_.begin();
121 void ResourcePrefetcher::SendRequest(Request* request) {
122 request->prefetch_status = Request::PREFETCH_STATUS_STARTED
[all...] |
| /external/chromium_org/chrome/browser/extensions/api/identity/ |
| identity_mint_queue.h | 19 // The queue calls StartMintToken on each Request when it reaches the
22 // The queue does not own Requests. Request pointers must be valid
34 class Request {
36 virtual ~Request() {}
51 // Adds a request to the queue specified by the id and scopes.
55 IdentityMintRequestQueue::Request* request);
56 // Removes a request from the queue specified by the id and scopes.
60 IdentityMintRequestQueue::Request* request);
[all...] |
| /external/chromium_org/chrome/browser/policy/cloud/ |
| external_policy_data_updater.h | 28 // This class downloads external policy data. Given a |Request|, data is fetched
36 struct Request {
38 Request();
39 Request(const std::string& url, const std::string& hash, int64 max_size);
41 bool operator==(const Request& other) const;
52 // If the callback returns |true|, the data is accepted and the |Request| is
70 // Fetches the external data specified in the |request|. The |key| is an
71 // opaque identifier. If another request for the same |key| is still pending,
72 // it will be canceled and replaced with the new |request|. The callback will
76 const Request& request
[all...] |
| /frameworks/volley/src/com/android/volley/ |
| ExecutorDelivery.java | 54 public void postResponse(Request<?> request, Response<?> response) {
55 postResponse(request, response, null);
59 public void postResponse(Request<?> request, Response<?> response, Runnable runnable) {
60 request.markDelivered();
61 request.addMarker("post-response");
62 mResponsePoster.execute(new ResponseDeliveryRunnable(request, response, runnable));
66 public void postError(Request<?> request, VolleyError error)
[all...] |
| /external/chromium_org/net/http/ |
| http_stream_factory_impl_request.cc | 16 HttpStreamFactoryImpl::Request::Request(
37 HttpStreamFactoryImpl::Request::~Request() {
54 void HttpStreamFactoryImpl::Request::SetSpdySessionKey(
64 bool HttpStreamFactoryImpl::Request::SetHttpPipeliningKey(
76 void HttpStreamFactoryImpl::Request::AttachJob(Job* job) {
82 void HttpStreamFactoryImpl::Request::Complete(
100 void HttpStreamFactoryImpl::Request::OnStreamReady(
113 void HttpStreamFactoryImpl::Request::OnWebSocketStreamReady
[all...] |
| /external/chromium_org/chrome/browser/chromeos/policy/ |
| user_cloud_policy_token_forwarder.h | 43 virtual void OnGetTokenSuccess(const OAuth2TokenService::Request* request,
46 virtual void OnGetTokenFailure(const OAuth2TokenService::Request* request,
59 scoped_ptr<OAuth2TokenService::Request> request_;
|
| /external/chromium_org/chrome/browser/local_discovery/ |
| privet_confirm_api_flow.h | 45 virtual void OnGetTokenSuccess(const OAuth2TokenService::Request* request,
48 virtual void OnGetTokenFailure(const OAuth2TokenService::Request* request,
53 scoped_ptr<OAuth2TokenService::Request> oauth_request_;
|
