components/cronet/android/cronet_url_request_adapter.h

   1 // Copyright 2014 The Chromium Authors. All rights reserved.
   2 // Use of this source code is governed by a BSD-style license that can be
   3 // found in the LICENSE file.
   4
   5 #ifndef COMPONENTS_CRONET_ANDROID_CRONET_URL_REQUEST_ADAPTER_H_
   6 #define COMPONENTS_CRONET_ANDROID_CRONET_URL_REQUEST_ADAPTER_H_
   7
   8 #include <jni.h>
   9 #include <string>
  10
  11 #include "base/android/jni_android.h"
  12 #include "base/android/jni_string.h"
  13 #include "base/android/scoped_java_ref.h"
  14 #include "base/callback.h"
  15 #include "base/location.h"
  16 #include "base/macros.h"
  17 #include "base/memory/ref_counted.h"
  18 #include "base/memory/scoped_ptr.h"
  19 #include "net/base/request_priority.h"
  20 #include "net/url_request/url_request.h"
  21 #include "url/gurl.h"
  22
  23 namespace base {
  24 class SingleThreadTaskRunner;
  25 }  // namespace base
  26
  27 namespace net {
  28 class HttpRequestHeaders;
  29 class HttpResponseHeaders;
  30 class UploadDataStream;
  31 }  // namespace net
  32
  33 namespace cronet {
  34
  35 class CronetURLRequestContextAdapter;
  36
  37 bool CronetUrlRequestAdapterRegisterJni(JNIEnv* env);
  38
  39 // An adapter from Java CronetUrlRequest object to net::URLRequest.
  40 // Created and configured from a Java thread. Start, ReadData, and Destroy are
  41 // posted to network thread and all callbacks into the Java CronetUrlRequest are
  42 // done on the network thread. Java CronetUrlRequest is expected to initiate the
  43 // next step like FollowDeferredRedirect, ReadData or Destroy. Public methods
  44 // can be called on any thread except PopulateResponseHeaders and Get* methods,
  45 // which can only be called on the network thread.
  46 class CronetURLRequestAdapter : public net::URLRequest::Delegate {
  47  public:
  48   CronetURLRequestAdapter(CronetURLRequestContextAdapter* context,
  49                           JNIEnv* env,
  50                           jobject jurl_request,
  51                           const GURL& url,
  52                           net::RequestPriority priority);
  53   ~CronetURLRequestAdapter() override;
  54
  55   // Methods called prior to Start are never called on network thread.
  56
  57   // Sets the request method GET, POST etc.
  58   jboolean SetHttpMethod(JNIEnv* env, jobject jcaller, jstring jmethod);
  59
  60   // Adds a header to the request before it starts.
  61   jboolean AddRequestHeader(JNIEnv* env,
  62                             jobject jcaller,
  63                             jstring jname,
  64                             jstring jvalue);
  65
  66   // Bypasses cache. If context is not set up to use cache, this call has no
  67   // effect.
  68   void DisableCache(JNIEnv* env, jobject jcaller);
  69
  70   // Adds a request body to the request before it starts.
  71   void SetUpload(scoped_ptr<net::UploadDataStream> upload);
  72
  73   // Starts the request.
  74   void Start(JNIEnv* env, jobject jcaller);
  75
  76   void GetStatus(JNIEnv* env, jobject jcaller, jobject jstatus_listener) const;
  77
  78   // Follows redirect.
  79   void FollowDeferredRedirect(JNIEnv* env, jobject jcaller);
  80
  81   // Reads more data.
  82   jboolean ReadData(JNIEnv* env, jobject jcaller,
  83                     jobject jbyte_buffer,
  84                     jint jposition,
  85                     jint jcapacity);
  86
  87   // Releases all resources for the request and deletes the object itself.
  88   void Destroy(JNIEnv* env, jobject jcaller);
  89
  90   // Populate response headers on network thread.
  91   void PopulateResponseHeaders(JNIEnv* env,
  92                                jobject jcaller,
  93                                jobject jheaders_list);
  94
  95   // When called during a OnRedirect or OnResponseStarted callback, these
  96   // methods return the corresponding response information. These methods
  97   // can only be called on the network thread.
  98
  99   // Gets http status text from the response headers.
 100   base::android::ScopedJavaLocalRef<jstring> GetHttpStatusText(
 101       JNIEnv* env,
 102       jobject jcaller) const;
 103
 104   // Gets NPN or ALPN Negotiated Protocol (if any) from HttpResponseInfo.
 105   base::android::ScopedJavaLocalRef<jstring> GetNegotiatedProtocol(
 106       JNIEnv* env,
 107       jobject jcaller) const;
 108
 109   // Returns the host and port of the proxy server, if one was used.
 110   base::android::ScopedJavaLocalRef<jstring> GetProxyServer(
 111       JNIEnv* env,
 112       jobject jcaller) const;
 113
 114   // Returns true if response is coming from the cache.
 115   jboolean GetWasCached(JNIEnv* env, jobject jcaller) const;
 116
 117   // net::URLRequest::Delegate implementations:
 118
 119   void OnReceivedRedirect(net::URLRequest* request,
 120                           const net::RedirectInfo& redirect_info,
 121                           bool* defer_redirect) override;
 122   void OnResponseStarted(net::URLRequest* request) override;
 123   void OnReadCompleted(net::URLRequest* request, int bytes_read) override;
 124
 125  private:
 126   class IOBufferWithByteBuffer;
 127
 128   void StartOnNetworkThread();
 129   void GetStatusOnNetworkThread(
 130       const base::android::ScopedJavaGlobalRef<jobject>& jstatus_listener_ref)
 131       const;
 132   void FollowDeferredRedirectOnNetworkThread();
 133   void ReadDataOnNetworkThread(
 134       scoped_refptr<IOBufferWithByteBuffer> read_buffer,
 135       int buffer_size);
 136   void DestroyOnNetworkThread();
 137
 138   // Checks status of the request_adapter, return false if |is_success()| is
 139   // true, otherwise report error and cancel request_adapter.
 140   bool MaybeReportError(net::URLRequest* request) const;
 141
 142   CronetURLRequestContextAdapter* context_;
 143
 144   // Java object that owns this CronetURLRequestContextAdapter.
 145   base::android::ScopedJavaGlobalRef<jobject> owner_;
 146
 147   const GURL initial_url_;
 148   const net::RequestPriority initial_priority_;
 149   std::string initial_method_;
 150   int load_flags_;
 151   net::HttpRequestHeaders initial_request_headers_;
 152   scoped_ptr<net::UploadDataStream> upload_;
 153
 154   scoped_refptr<IOBufferWithByteBuffer> read_buffer_;
 155   scoped_ptr<net::URLRequest> url_request_;
 156
 157   DISALLOW_COPY_AND_ASSIGN(CronetURLRequestAdapter);
 158 };
 159
 160 }  // namespace cronet
 161
 162 #endif  // COMPONENTS_CRONET_ANDROID_CRONET_URL_REQUEST_ADAPTER_H_