net/http/failing_http_transaction_factory.cc

   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 #include "net/http/failing_http_transaction_factory.h"
   6
   7 #include "base/bind.h"
   8 #include "base/compiler_specific.h"
   9 #include "base/logging.h"
  10 #include "base/message_loop/message_loop.h"
  11 #include "net/base/load_timing_info.h"
  12 #include "net/base/upload_progress.h"
  13
  14 namespace net {
  15
  16 class AuthCredentials;
  17 class BoundNetLog;
  18 class HttpRequestHeaders;
  19 class IOBuffer;
  20 class X509Certificate;
  21
  22 struct HttpRequestInfo;
  23
  24 namespace {
  25
  26 // A simple class to interpose between the cache and network http layers.
  27 // These transactions can be generated by the FailingHttpTransactionFactory
  28 // to test interactions between cache and network.
  29 class FailingHttpTransaction : public HttpTransaction {
  30  public:
  31   explicit FailingHttpTransaction(Error error);
  32   virtual ~FailingHttpTransaction();
  33
  34   // HttpTransaction
  35   virtual int Start(const HttpRequestInfo* request_info,
  36                     const CompletionCallback& callback,
  37                     const BoundNetLog& net_log) OVERRIDE;
  38   virtual int RestartIgnoringLastError(
  39       const CompletionCallback& callback) OVERRIDE;
  40   virtual int RestartWithCertificate(
  41       X509Certificate* client_cert,
  42       const CompletionCallback& callback) OVERRIDE;
  43   virtual int RestartWithAuth(
  44       const AuthCredentials& credentials,
  45       const CompletionCallback& callback) OVERRIDE;
  46   virtual bool IsReadyToRestartForAuth() OVERRIDE;
  47   virtual int Read(IOBuffer* buf, int buf_len,
  48                    const CompletionCallback& callback) OVERRIDE;
  49   virtual void StopCaching() OVERRIDE;
  50   virtual bool GetFullRequestHeaders(
  51       HttpRequestHeaders* headers) const OVERRIDE;
  52   virtual int64 GetTotalReceivedBytes() const OVERRIDE;
  53   virtual void DoneReading() OVERRIDE;
  54   virtual const HttpResponseInfo* GetResponseInfo() const OVERRIDE;
  55   virtual LoadState GetLoadState() const OVERRIDE;
  56   virtual UploadProgress GetUploadProgress() const OVERRIDE;
  57   virtual void SetQuicServerInfo(
  58       net::QuicServerInfo* quic_server_info) OVERRIDE;
  59   virtual bool GetLoadTimingInfo(
  60       LoadTimingInfo* load_timing_info) const OVERRIDE;
  61   virtual void SetPriority(RequestPriority priority) OVERRIDE;
  62   virtual void SetWebSocketHandshakeStreamCreateHelper(
  63       WebSocketHandshakeStreamBase::CreateHelper* create_helper) OVERRIDE;
  64   virtual void SetBeforeNetworkStartCallback(
  65       const BeforeNetworkStartCallback& callback) OVERRIDE;
  66   virtual void SetBeforeProxyHeadersSentCallback(
  67       const BeforeProxyHeadersSentCallback& callback) OVERRIDE;
  68   virtual int ResumeNetworkStart() OVERRIDE;
  69
  70  private:
  71   Error error_;
  72 };
  73
  74 FailingHttpTransaction::FailingHttpTransaction(Error error) : error_(error) {
  75   DCHECK_LT(error, OK);
  76 }
  77
  78 FailingHttpTransaction::~FailingHttpTransaction() {}
  79
  80 int FailingHttpTransaction::Start(const HttpRequestInfo* request_info,
  81                                   const CompletionCallback& callback,
  82                                   const BoundNetLog& net_log)  {
  83   base::MessageLoop::current()->PostTask(
  84       FROM_HERE, base::Bind(callback, error_));
  85   return ERR_IO_PENDING;
  86 }
  87
  88 int FailingHttpTransaction::RestartIgnoringLastError(
  89     const CompletionCallback& callback)  {
  90   return ERR_FAILED;
  91 }
  92
  93 int FailingHttpTransaction::RestartWithCertificate(
  94     X509Certificate* client_cert,
  95     const CompletionCallback& callback)  {
  96   return ERR_FAILED;
  97 }
  98
  99 int FailingHttpTransaction::RestartWithAuth(
 100     const AuthCredentials& credentials,
 101     const CompletionCallback& callback)  {
 102   return ERR_FAILED;
 103 }
 104
 105 bool FailingHttpTransaction::IsReadyToRestartForAuth()  {
 106   return false;
 107 }
 108
 109 int FailingHttpTransaction::Read(IOBuffer* buf, int buf_len,
 110                                  const CompletionCallback& callback)  {
 111   NOTREACHED();
 112   return ERR_FAILED;
 113 }
 114
 115 void FailingHttpTransaction::StopCaching()  {}
 116
 117 bool FailingHttpTransaction::GetFullRequestHeaders(
 118     HttpRequestHeaders* headers) const  {
 119   return false;
 120 }
 121
 122 int64 FailingHttpTransaction::GetTotalReceivedBytes() const  {
 123   return 0;
 124 }
 125
 126 void FailingHttpTransaction::DoneReading()  {
 127   NOTREACHED();
 128 }
 129
 130 const HttpResponseInfo* FailingHttpTransaction::GetResponseInfo() const  {
 131   return NULL;
 132 }
 133
 134 LoadState FailingHttpTransaction::GetLoadState() const  {
 135   return LOAD_STATE_IDLE;
 136 }
 137
 138 UploadProgress FailingHttpTransaction::GetUploadProgress() const  {
 139   return UploadProgress();
 140 }
 141
 142 void FailingHttpTransaction::SetQuicServerInfo(
 143     net::QuicServerInfo* quic_server_info) {}
 144
 145 bool FailingHttpTransaction::GetLoadTimingInfo(
 146     LoadTimingInfo* load_timing_info) const  {
 147   return false;
 148 }
 149
 150 void FailingHttpTransaction::SetPriority(RequestPriority priority)  {}
 151
 152 void FailingHttpTransaction::SetWebSocketHandshakeStreamCreateHelper(
 153     WebSocketHandshakeStreamBase::CreateHelper* create_helper)  {
 154   NOTREACHED();
 155 }
 156
 157 void FailingHttpTransaction::SetBeforeNetworkStartCallback(
 158     const BeforeNetworkStartCallback& callback)  {
 159 }
 160
 161 void FailingHttpTransaction::SetBeforeProxyHeadersSentCallback(
 162     const BeforeProxyHeadersSentCallback& callback)  {
 163 }
 164
 165 int FailingHttpTransaction::ResumeNetworkStart()  {
 166   NOTREACHED();
 167   return ERR_FAILED;
 168 }
 169
 170 }  // namespace
 171
 172 FailingHttpTransactionFactory::FailingHttpTransactionFactory(
 173     HttpNetworkSession* session,
 174     Error error) : session_(session), error_(error) {
 175   DCHECK_LT(error, OK);
 176 }
 177
 178 FailingHttpTransactionFactory::~FailingHttpTransactionFactory() {}
 179
 180 // HttpTransactionFactory:
 181 int FailingHttpTransactionFactory::CreateTransaction(
 182     RequestPriority priority,
 183     scoped_ptr<HttpTransaction>* trans) {
 184   trans->reset(new FailingHttpTransaction(error_));
 185   return OK;
 186 }
 187
 188 HttpCache* FailingHttpTransactionFactory::GetCache() {
 189   return NULL;
 190 }
 191
 192 HttpNetworkSession* FailingHttpTransactionFactory::GetSession() {
 193   return session_;
 194 }
 195
 196 }  // namespace net
 197