Home | History | Annotate | Download | only in ftp 
      1 // Copyright (c) 2012 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/ftp/ftp_network_transaction.h"
      6 
      7 #include "build/build_config.h"
      8 
      9 #include "base/compiler_specific.h"
     10 #include "base/memory/ref_counted.h"
     11 #include "base/memory/scoped_vector.h"
     12 #include "base/strings/string_util.h"
     13 #include "base/strings/utf_string_conversions.h"
     14 #include "net/base/host_port_pair.h"
     15 #include "net/base/io_buffer.h"
     16 #include "net/base/net_util.h"
     17 #include "net/base/test_completion_callback.h"
     18 #include "net/dns/mock_host_resolver.h"
     19 #include "net/ftp/ftp_network_session.h"
     20 #include "net/ftp/ftp_request_info.h"
     21 #include "net/socket/socket_test_util.h"
     22 #include "testing/gtest/include/gtest/gtest.h"
     23 #include "testing/platform_test.h"
     24 
     25 namespace {
     26 
     27 // Size we use for IOBuffers used to receive data from the test data socket.
     28 const int kBufferSize = 128;
     29 
     30 }  // namespace
     31 
     32 namespace net {
     33 
     34 class FtpSocketDataProvider : public DynamicSocketDataProvider {
     35  public:
     36   enum State {
     37     NONE,
     38     PRE_USER,
     39     PRE_PASSWD,
     40     PRE_SYST,
     41     PRE_PWD,
     42     PRE_TYPE,
     43     PRE_SIZE,
     44     PRE_EPSV,
     45     PRE_PASV,
     46     PRE_LIST,
     47     PRE_RETR,
     48     PRE_RETR_EPSV,
     49     PRE_RETR_PASV,
     50     PRE_CWD_EPSV,
     51     PRE_CWD_PASV,
     52     PRE_CWD,
     53     PRE_QUIT,
     54     PRE_NOPASV,
     55     QUIT
     56   };
     57 
     58   FtpSocketDataProvider()
     59       : failure_injection_state_(NONE),
     60         multiline_welcome_(false),
     61         use_epsv_(true),
     62         data_type_('I') {
     63     Init();
     64   }
     65 
     66   virtual MockWriteResult OnWrite(const std::string& data) OVERRIDE {
     67     if (InjectFault())
     68       return MockWriteResult(ASYNC, data.length());
     69     switch (state()) {
     70       case PRE_USER:
     71         return Verify("USER anonymous\r\n", data, PRE_PASSWD,
     72                       "331 Password needed\r\n");
     73       case PRE_PASSWD:
     74         {
     75           const char* response_one = "230 Welcome\r\n";
     76           const char* response_multi = "230- One\r\n230- Two\r\n230 Three\r\n";
     77           return Verify("PASS chrome (at) example.com\r\n", data, PRE_SYST,
     78                         multiline_welcome_ ? response_multi : response_one);
     79         }
     80       case PRE_SYST:
     81         return Verify("SYST\r\n", data, PRE_PWD, "215 UNIX\r\n");
     82       case PRE_PWD:
     83         return Verify("PWD\r\n", data, PRE_TYPE,
     84                       "257 \"/\" is your current location\r\n");
     85       case PRE_TYPE:
     86         return Verify(std::string("TYPE ") + data_type_ + "\r\n", data,
     87                       use_epsv_ ? PRE_EPSV : PRE_PASV,
     88                       "200 TYPE set successfully\r\n");
     89       case PRE_EPSV:
     90         return Verify("EPSV\r\n", data, PRE_SIZE,
     91                       "227 Entering Extended Passive Mode (|||31744|)\r\n");
     92       case PRE_CWD_EPSV:
     93         return Verify("EPSV\r\n", data, PRE_CWD,
     94                       "227 Entering Extended Passive Mode (|||31744|)\r\n");
     95       case PRE_RETR_EPSV:
     96         return Verify("EPSV\r\n", data, PRE_RETR,
     97                       "227 Entering Extended Passive Mode (|||31744|)\r\n");
     98       case PRE_CWD_PASV:
     99         return Verify("PASV\r\n", data, PRE_CWD,
    100                       "227 Entering Passive Mode 127,0,0,1,123,456\r\n");
    101       case PRE_RETR_PASV:
    102         return Verify("PASV\r\n", data, PRE_RETR,
    103                       "227 Entering Passive Mode 127,0,0,1,123,456\r\n");
    104       case PRE_PASV:
    105         return Verify("PASV\r\n", data, PRE_SIZE,
    106                       "227 Entering Passive Mode 127,0,0,1,123,456\r\n");
    107       case PRE_NOPASV:
    108         // Use unallocated 599 FTP error code to make sure it falls into the
    109         // generic ERR_FTP_FAILED bucket.
    110         return Verify("PASV\r\n", data, PRE_QUIT,
    111                       "599 fail\r\n");
    112       case PRE_QUIT:
    113         return Verify("QUIT\r\n", data, QUIT, "221 Goodbye.\r\n");
    114       default:
    115         NOTREACHED() << "State not handled " << state();
    116         return MockWriteResult(ASYNC, ERR_UNEXPECTED);
    117     }
    118   }
    119 
    120   void InjectFailure(State state, State next_state, const char* response) {
    121     DCHECK_EQ(NONE, failure_injection_state_);
    122     DCHECK_NE(NONE, state);
    123     DCHECK_NE(NONE, next_state);
    124     DCHECK_NE(state, next_state);
    125     failure_injection_state_ = state;
    126     failure_injection_next_state_ = next_state;
    127     fault_response_ = response;
    128   }
    129 
    130   State state() const {
    131     return state_;
    132   }
    133 
    134   virtual void Reset() OVERRIDE {
    135     DynamicSocketDataProvider::Reset();
    136     Init();
    137   }
    138 
    139   void set_multiline_welcome(bool multiline) { multiline_welcome_ = multiline; }
    140 
    141   bool use_epsv() const { return use_epsv_; }
    142   void set_use_epsv(bool use_epsv) { use_epsv_ = use_epsv; }
    143 
    144   void set_data_type(char data_type) { data_type_ = data_type; }
    145 
    146  protected:
    147   void Init() {
    148     state_ = PRE_USER;
    149     SimulateRead("220 host TestFTPd\r\n");
    150   }
    151 
    152   // If protocol fault injection has been requested, adjusts state and mocked
    153   // read and returns true.
    154   bool InjectFault() {
    155     if (state_ != failure_injection_state_)
    156       return false;
    157     SimulateRead(fault_response_);
    158     state_ = failure_injection_next_state_;
    159     return true;
    160   }
    161 
    162   MockWriteResult Verify(const std::string& expected,
    163                          const std::string& data,
    164                          State next_state,
    165                          const char* next_read,
    166                          const size_t next_read_length) {
    167     EXPECT_EQ(expected, data);
    168     if (expected == data) {
    169       state_ = next_state;
    170       SimulateRead(next_read, next_read_length);
    171       return MockWriteResult(ASYNC, data.length());
    172     }
    173     return MockWriteResult(ASYNC, ERR_UNEXPECTED);
    174   }
    175 
    176   MockWriteResult Verify(const std::string& expected,
    177                          const std::string& data,
    178                          State next_state,
    179                          const char* next_read) {
    180     return Verify(expected, data, next_state,
    181                   next_read, std::strlen(next_read));
    182   }
    183 
    184 
    185  private:
    186   State state_;
    187   State failure_injection_state_;
    188   State failure_injection_next_state_;
    189   const char* fault_response_;
    190 
    191   // If true, we will send multiple 230 lines as response after PASS.
    192   bool multiline_welcome_;
    193 
    194   // If true, we will use EPSV command.
    195   bool use_epsv_;
    196 
    197   // Data type to be used for TYPE command.
    198   char data_type_;
    199 
    200   DISALLOW_COPY_AND_ASSIGN(FtpSocketDataProvider);
    201 };
    202 
    203 class FtpSocketDataProviderDirectoryListing : public FtpSocketDataProvider {
    204  public:
    205   FtpSocketDataProviderDirectoryListing() {
    206   }
    207 
    208   virtual MockWriteResult OnWrite(const std::string& data) OVERRIDE {
    209     if (InjectFault())
    210       return MockWriteResult(ASYNC, data.length());
    211     switch (state()) {
    212       case PRE_SIZE:
    213         return Verify("SIZE /\r\n", data,
    214                       use_epsv() ? PRE_CWD_EPSV : PRE_CWD_PASV,
    215                       "550 I can only retrieve regular files\r\n");
    216       case PRE_CWD:
    217         return Verify("CWD /\r\n", data, PRE_LIST, "200 OK\r\n");
    218       case PRE_LIST:
    219         return Verify("LIST -l\r\n", data, PRE_QUIT, "200 OK\r\n");
    220       default:
    221         return FtpSocketDataProvider::OnWrite(data);
    222     }
    223   }
    224 
    225  private:
    226   DISALLOW_COPY_AND_ASSIGN(FtpSocketDataProviderDirectoryListing);
    227 };
    228 
    229 class FtpSocketDataProviderDirectoryListingWithPasvFallback
    230     : public FtpSocketDataProviderDirectoryListing {
    231  public:
    232   FtpSocketDataProviderDirectoryListingWithPasvFallback() {
    233   }
    234 
    235   virtual MockWriteResult OnWrite(const std::string& data) OVERRIDE {
    236     if (InjectFault())
    237       return MockWriteResult(ASYNC, data.length());
    238     switch (state()) {
    239       case PRE_EPSV:
    240         return Verify("EPSV\r\n", data, PRE_PASV,
    241                       "500 no EPSV for you\r\n");
    242       case PRE_SIZE:
    243         return Verify("SIZE /\r\n", data, PRE_CWD_PASV,
    244                       "550 I can only retrieve regular files\r\n");
    245       default:
    246         return FtpSocketDataProviderDirectoryListing::OnWrite(data);
    247     }
    248   }
    249 
    250  private:
    251   DISALLOW_COPY_AND_ASSIGN(
    252       FtpSocketDataProviderDirectoryListingWithPasvFallback);
    253 };
    254 
    255 class FtpSocketDataProviderDirectoryListingZeroSize
    256     : public FtpSocketDataProviderDirectoryListing {
    257  public:
    258   FtpSocketDataProviderDirectoryListingZeroSize() {
    259   }
    260 
    261   virtual MockWriteResult OnWrite(const std::string& data) OVERRIDE {
    262     if (InjectFault())
    263       return MockWriteResult(ASYNC, data.length());
    264     switch (state()) {
    265       case PRE_SIZE:
    266         return Verify("SIZE /\r\n", data, PRE_CWD, "213 0\r\n");
    267       default:
    268         return FtpSocketDataProviderDirectoryListing::OnWrite(data);
    269     }
    270   }
    271 
    272  private:
    273   DISALLOW_COPY_AND_ASSIGN(FtpSocketDataProviderDirectoryListingZeroSize);
    274 };
    275 
    276 class FtpSocketDataProviderVMSDirectoryListing : public FtpSocketDataProvider {
    277  public:
    278   FtpSocketDataProviderVMSDirectoryListing() {
    279   }
    280 
    281   virtual MockWriteResult OnWrite(const std::string& data) OVERRIDE {
    282     if (InjectFault())
    283       return MockWriteResult(ASYNC, data.length());
    284     switch (state()) {
    285       case PRE_SYST:
    286         return Verify("SYST\r\n", data, PRE_PWD, "215 VMS\r\n");
    287       case PRE_PWD:
    288         return Verify("PWD\r\n", data, PRE_TYPE,
    289                       "257 \"ANONYMOUS_ROOT:[000000]\"\r\n");
    290       case PRE_EPSV:
    291         return Verify("EPSV\r\n", data, PRE_PASV, "500 Invalid command\r\n");
    292       case PRE_SIZE:
    293         return Verify("SIZE ANONYMOUS_ROOT:[000000]dir\r\n", data, PRE_CWD_PASV,
    294                       "550 I can only retrieve regular files\r\n");
    295       case PRE_CWD:
    296         return Verify("CWD ANONYMOUS_ROOT:[dir]\r\n", data, PRE_LIST,
    297                       "200 OK\r\n");
    298       case PRE_LIST:
    299         return Verify("LIST *.*;0\r\n", data, PRE_QUIT, "200 OK\r\n");
    300       default:
    301         return FtpSocketDataProvider::OnWrite(data);
    302     }
    303   }
    304 
    305  private:
    306   DISALLOW_COPY_AND_ASSIGN(FtpSocketDataProviderVMSDirectoryListing);
    307 };
    308 
    309 class FtpSocketDataProviderVMSDirectoryListingRootDirectory
    310     : public FtpSocketDataProvider {
    311  public:
    312   FtpSocketDataProviderVMSDirectoryListingRootDirectory() {
    313   }
    314 
    315   virtual MockWriteResult OnWrite(const std::string& data) OVERRIDE {
    316     if (InjectFault())
    317       return MockWriteResult(ASYNC, data.length());
    318     switch (state()) {
    319       case PRE_SYST:
    320         return Verify("SYST\r\n", data, PRE_PWD, "215 VMS\r\n");
    321       case PRE_PWD:
    322         return Verify("PWD\r\n", data, PRE_TYPE,
    323                       "257 \"ANONYMOUS_ROOT:[000000]\"\r\n");
    324       case PRE_EPSV:
    325         return Verify("EPSV\r\n", data, PRE_PASV,
    326                       "500 EPSV command unknown\r\n");
    327       case PRE_SIZE:
    328         return Verify("SIZE ANONYMOUS_ROOT\r\n", data, PRE_CWD_PASV,
    329                       "550 I can only retrieve regular files\r\n");
    330       case PRE_CWD:
    331         return Verify("CWD ANONYMOUS_ROOT:[000000]\r\n", data, PRE_LIST,
    332                       "200 OK\r\n");
    333       case PRE_LIST:
    334         return Verify("LIST *.*;0\r\n", data, PRE_QUIT, "200 OK\r\n");
    335       default:
    336         return FtpSocketDataProvider::OnWrite(data);
    337     }
    338   }
    339 
    340  private:
    341   DISALLOW_COPY_AND_ASSIGN(
    342       FtpSocketDataProviderVMSDirectoryListingRootDirectory);
    343 };
    344 
    345 class FtpSocketDataProviderFileDownloadWithFileTypecode
    346     : public FtpSocketDataProvider {
    347  public:
    348   FtpSocketDataProviderFileDownloadWithFileTypecode() {
    349   }
    350 
    351   virtual MockWriteResult OnWrite(const std::string& data) OVERRIDE {
    352     if (InjectFault())
    353       return MockWriteResult(ASYNC, data.length());
    354     switch (state()) {
    355       case PRE_SIZE:
    356         return Verify("SIZE /file\r\n", data, PRE_RETR,
    357                       "213 18\r\n");
    358       case PRE_RETR:
    359         return Verify("RETR /file\r\n", data, PRE_QUIT, "200 OK\r\n");
    360       default:
    361         return FtpSocketDataProvider::OnWrite(data);
    362     }
    363   }
    364 
    365  private:
    366   DISALLOW_COPY_AND_ASSIGN(FtpSocketDataProviderFileDownloadWithFileTypecode);
    367 };
    368 
    369 class FtpSocketDataProviderFileDownload : public FtpSocketDataProvider {
    370  public:
    371   FtpSocketDataProviderFileDownload() {
    372   }
    373 
    374   virtual MockWriteResult OnWrite(const std::string& data) OVERRIDE {
    375     if (InjectFault())
    376       return MockWriteResult(ASYNC, data.length());
    377     switch (state()) {
    378       case PRE_SIZE:
    379         return Verify("SIZE /file\r\n", data, PRE_CWD,
    380                       "213 18\r\n");
    381       case PRE_CWD:
    382         return Verify("CWD /file\r\n", data,
    383                       use_epsv() ? PRE_RETR_EPSV : PRE_RETR_PASV,
    384                       "550 Not a directory\r\n");
    385       case PRE_RETR:
    386         return Verify("RETR /file\r\n", data, PRE_QUIT, "200 OK\r\n");
    387       default:
    388         return FtpSocketDataProvider::OnWrite(data);
    389     }
    390   }
    391 
    392  private:
    393   DISALLOW_COPY_AND_ASSIGN(FtpSocketDataProviderFileDownload);
    394 };
    395 
    396 class FtpSocketDataProviderFileNotFound : public FtpSocketDataProvider {
    397  public:
    398   FtpSocketDataProviderFileNotFound() {
    399   }
    400 
    401   virtual MockWriteResult OnWrite(const std::string& data) OVERRIDE {
    402     if (InjectFault())
    403       return MockWriteResult(ASYNC, data.length());
    404     switch (state()) {
    405       case PRE_SIZE:
    406         return Verify("SIZE /file\r\n", data,
    407                       use_epsv() ? PRE_CWD_EPSV : PRE_CWD_PASV,
    408                       "550 File Not Found\r\n");
    409       case PRE_CWD:
    410         return Verify("CWD /file\r\n", data,
    411                       use_epsv() ? PRE_RETR_EPSV : PRE_RETR_PASV,
    412                       "550 File Not Found\r\n");
    413       case PRE_RETR:
    414         return Verify("RETR /file\r\n", data, PRE_QUIT,
    415                       "550 File Not Found\r\n");
    416       default:
    417         return FtpSocketDataProvider::OnWrite(data);
    418     }
    419   }
    420 
    421  private:
    422   DISALLOW_COPY_AND_ASSIGN(FtpSocketDataProviderFileNotFound);
    423 };
    424 
    425 class FtpSocketDataProviderFileDownloadWithPasvFallback
    426     : public FtpSocketDataProviderFileDownload {
    427  public:
    428   FtpSocketDataProviderFileDownloadWithPasvFallback() {
    429   }
    430 
    431   virtual MockWriteResult OnWrite(const std::string& data) OVERRIDE {
    432     if (InjectFault())
    433       return MockWriteResult(ASYNC, data.length());
    434     switch (state()) {
    435       case PRE_EPSV:
    436         return Verify("EPSV\r\n", data, PRE_PASV,
    437                       "500 No can do\r\n");
    438       case PRE_CWD:
    439         return Verify("CWD /file\r\n", data, PRE_RETR_PASV,
    440                       "550 Not a directory\r\n");
    441       default:
    442         return FtpSocketDataProviderFileDownload::OnWrite(data);
    443     }
    444   }
    445 
    446  private:
    447   DISALLOW_COPY_AND_ASSIGN(FtpSocketDataProviderFileDownloadWithPasvFallback);
    448 };
    449 
    450 class FtpSocketDataProviderFileDownloadZeroSize
    451     : public FtpSocketDataProviderFileDownload {
    452  public:
    453   FtpSocketDataProviderFileDownloadZeroSize() {
    454   }
    455 
    456   virtual MockWriteResult OnWrite(const std::string& data) OVERRIDE {
    457     if (InjectFault())
    458       return MockWriteResult(ASYNC, data.length());
    459     switch (state()) {
    460       case PRE_SIZE:
    461         return Verify("SIZE /file\r\n", data, PRE_CWD,
    462                       "213 0\r\n");
    463       case PRE_CWD:
    464         return Verify("CWD /file\r\n", data,
    465                       use_epsv() ? PRE_RETR_EPSV : PRE_RETR_PASV,
    466                       "550 not a directory\r\n");
    467       default:
    468         return FtpSocketDataProviderFileDownload::OnWrite(data);
    469     }
    470   }
    471 
    472  private:
    473   DISALLOW_COPY_AND_ASSIGN(FtpSocketDataProviderFileDownloadZeroSize);
    474 };
    475 
    476 class FtpSocketDataProviderFileDownloadCWD451
    477     : public FtpSocketDataProviderFileDownload {
    478  public:
    479   FtpSocketDataProviderFileDownloadCWD451() {
    480   }
    481 
    482   virtual MockWriteResult OnWrite(const std::string& data) OVERRIDE {
    483     if (InjectFault())
    484       return MockWriteResult(ASYNC, data.length());
    485     switch (state()) {
    486       case PRE_CWD:
    487         return Verify("CWD /file\r\n", data,
    488                       use_epsv() ? PRE_RETR_EPSV : PRE_RETR_PASV,
    489                       "451 not a directory\r\n");
    490       default:
    491         return FtpSocketDataProviderFileDownload::OnWrite(data);
    492     }
    493   }
    494 
    495  private:
    496   DISALLOW_COPY_AND_ASSIGN(FtpSocketDataProviderFileDownloadCWD451);
    497 };
    498 
    499 class FtpSocketDataProviderVMSFileDownload : public FtpSocketDataProvider {
    500  public:
    501   FtpSocketDataProviderVMSFileDownload() {
    502   }
    503 
    504   virtual MockWriteResult OnWrite(const std::string& data) OVERRIDE {
    505     if (InjectFault())
    506       return MockWriteResult(ASYNC, data.length());
    507     switch (state()) {
    508       case PRE_SYST:
    509         return Verify("SYST\r\n", data, PRE_PWD, "215 VMS\r\n");
    510       case PRE_PWD:
    511         return Verify("PWD\r\n", data, PRE_TYPE,
    512                       "257 \"ANONYMOUS_ROOT:[000000]\"\r\n");
    513       case PRE_EPSV:
    514         return Verify("EPSV\r\n", data, PRE_PASV,
    515                       "500 EPSV command unknown\r\n");
    516       case PRE_SIZE:
    517         return Verify("SIZE ANONYMOUS_ROOT:[000000]file\r\n", data, PRE_CWD,
    518                       "213 18\r\n");
    519       case PRE_CWD:
    520         return Verify("CWD ANONYMOUS_ROOT:[file]\r\n", data, PRE_RETR_PASV,
    521                       "550 Not a directory\r\n");
    522       case PRE_RETR:
    523         return Verify("RETR ANONYMOUS_ROOT:[000000]file\r\n", data, PRE_QUIT,
    524                       "200 OK\r\n");
    525       default:
    526         return FtpSocketDataProvider::OnWrite(data);
    527     }
    528   }
    529 
    530  private:
    531   DISALLOW_COPY_AND_ASSIGN(FtpSocketDataProviderVMSFileDownload);
    532 };
    533 
    534 class FtpSocketDataProviderEscaping : public FtpSocketDataProviderFileDownload {
    535  public:
    536   FtpSocketDataProviderEscaping() {
    537   }
    538 
    539   virtual MockWriteResult OnWrite(const std::string& data) OVERRIDE {
    540     if (InjectFault())
    541       return MockWriteResult(ASYNC, data.length());
    542     switch (state()) {
    543       case PRE_SIZE:
    544         return Verify("SIZE / !\"#$%y\200\201\r\n", data, PRE_CWD,
    545                       "213 18\r\n");
    546       case PRE_CWD:
    547         return Verify("CWD / !\"#$%y\200\201\r\n", data,
    548                       use_epsv() ? PRE_RETR_EPSV : PRE_RETR_PASV,
    549                       "550 Not a directory\r\n");
    550       case PRE_RETR:
    551         return Verify("RETR / !\"#$%y\200\201\r\n", data, PRE_QUIT,
    552                       "200 OK\r\n");
    553       default:
    554         return FtpSocketDataProviderFileDownload::OnWrite(data);
    555     }
    556   }
    557 
    558  private:
    559   DISALLOW_COPY_AND_ASSIGN(FtpSocketDataProviderEscaping);
    560 };
    561 
    562 class FtpSocketDataProviderFileDownloadTransferStarting
    563     : public FtpSocketDataProviderFileDownload {
    564  public:
    565   FtpSocketDataProviderFileDownloadTransferStarting() {
    566   }
    567 
    568   virtual MockWriteResult OnWrite(const std::string& data) OVERRIDE {
    569     if (InjectFault())
    570       return MockWriteResult(ASYNC, data.length());
    571     switch (state()) {
    572       case PRE_RETR:
    573         return Verify("RETR /file\r\n", data, PRE_QUIT,
    574                       "125-Data connection already open.\r\n"
    575                       "125  Transfer starting.\r\n"
    576                       "226 Transfer complete.\r\n");
    577       default:
    578         return FtpSocketDataProviderFileDownload::OnWrite(data);
    579     }
    580   }
    581 
    582  private:
    583   DISALLOW_COPY_AND_ASSIGN(FtpSocketDataProviderFileDownloadTransferStarting);
    584 };
    585 
    586 class FtpSocketDataProviderDirectoryListingTransferStarting
    587     : public FtpSocketDataProviderDirectoryListing {
    588  public:
    589   FtpSocketDataProviderDirectoryListingTransferStarting() {
    590   }
    591 
    592   virtual MockWriteResult OnWrite(const std::string& data) OVERRIDE {
    593     if (InjectFault())
    594       return MockWriteResult(ASYNC, data.length());
    595     switch (state()) {
    596       case PRE_LIST:
    597         return Verify("LIST -l\r\n", data, PRE_QUIT,
    598                       "125-Data connection already open.\r\n"
    599                       "125  Transfer starting.\r\n"
    600                       "226 Transfer complete.\r\n");
    601       default:
    602         return FtpSocketDataProviderDirectoryListing::OnWrite(data);
    603     }
    604   }
    605 
    606  private:
    607   DISALLOW_COPY_AND_ASSIGN(
    608       FtpSocketDataProviderDirectoryListingTransferStarting);
    609 };
    610 
    611 class FtpSocketDataProviderFileDownloadInvalidResponse
    612     : public FtpSocketDataProviderFileDownload {
    613  public:
    614   FtpSocketDataProviderFileDownloadInvalidResponse() {
    615   }
    616 
    617   virtual MockWriteResult OnWrite(const std::string& data) OVERRIDE {
    618     if (InjectFault())
    619       return MockWriteResult(ASYNC, data.length());
    620     switch (state()) {
    621       case PRE_SIZE:
    622         // Use unallocated 599 FTP error code to make sure it falls into the
    623         // generic ERR_FTP_FAILED bucket.
    624         return Verify("SIZE /file\r\n", data, PRE_QUIT,
    625                       "599 Evil Response\r\n"
    626                       "599 More Evil\r\n");
    627       default:
    628         return FtpSocketDataProviderFileDownload::OnWrite(data);
    629     }
    630   }
    631 
    632  private:
    633   DISALLOW_COPY_AND_ASSIGN(FtpSocketDataProviderFileDownloadInvalidResponse);
    634 };
    635 
    636 class FtpSocketDataProviderEvilEpsv : public FtpSocketDataProviderFileDownload {
    637  public:
    638   FtpSocketDataProviderEvilEpsv(const char* epsv_response,
    639                                 State expected_state)
    640       : epsv_response_(epsv_response),
    641         epsv_response_length_(std::strlen(epsv_response)),
    642         expected_state_(expected_state) {}
    643 
    644   FtpSocketDataProviderEvilEpsv(const char* epsv_response,
    645                                size_t epsv_response_length,
    646                                State expected_state)
    647       : epsv_response_(epsv_response),
    648         epsv_response_length_(epsv_response_length),
    649         expected_state_(expected_state) {}
    650 
    651   virtual MockWriteResult OnWrite(const std::string& data) OVERRIDE {
    652     if (InjectFault())
    653       return MockWriteResult(ASYNC, data.length());
    654     switch (state()) {
    655       case PRE_EPSV:
    656         return Verify("EPSV\r\n", data, expected_state_,
    657                       epsv_response_, epsv_response_length_);
    658       default:
    659         return FtpSocketDataProviderFileDownload::OnWrite(data);
    660     }
    661   }
    662 
    663  private:
    664   const char* epsv_response_;
    665   const size_t epsv_response_length_;
    666   const State expected_state_;
    667 
    668   DISALLOW_COPY_AND_ASSIGN(FtpSocketDataProviderEvilEpsv);
    669 };
    670 
    671 class FtpSocketDataProviderEvilPasv
    672     : public FtpSocketDataProviderFileDownloadWithPasvFallback {
    673  public:
    674   FtpSocketDataProviderEvilPasv(const char* pasv_response, State expected_state)
    675       : pasv_response_(pasv_response),
    676         expected_state_(expected_state) {
    677   }
    678 
    679   virtual MockWriteResult OnWrite(const std::string& data) OVERRIDE {
    680     if (InjectFault())
    681       return MockWriteResult(ASYNC, data.length());
    682     switch (state()) {
    683       case PRE_PASV:
    684         return Verify("PASV\r\n", data, expected_state_, pasv_response_);
    685       default:
    686         return FtpSocketDataProviderFileDownloadWithPasvFallback::OnWrite(data);
    687     }
    688   }
    689 
    690  private:
    691   const char* pasv_response_;
    692   const State expected_state_;
    693 
    694   DISALLOW_COPY_AND_ASSIGN(FtpSocketDataProviderEvilPasv);
    695 };
    696 
    697 class FtpSocketDataProviderEvilSize : public FtpSocketDataProviderFileDownload {
    698  public:
    699   FtpSocketDataProviderEvilSize(const char* size_response, State expected_state)
    700       : size_response_(size_response),
    701         expected_state_(expected_state) {
    702   }
    703 
    704   virtual MockWriteResult OnWrite(const std::string& data) OVERRIDE {
    705     if (InjectFault())
    706       return MockWriteResult(ASYNC, data.length());
    707     switch (state()) {
    708       case PRE_SIZE:
    709         return Verify("SIZE /file\r\n", data, expected_state_, size_response_);
    710       default:
    711         return FtpSocketDataProviderFileDownload::OnWrite(data);
    712     }
    713   }
    714 
    715  private:
    716   const char* size_response_;
    717   const State expected_state_;
    718 
    719   DISALLOW_COPY_AND_ASSIGN(FtpSocketDataProviderEvilSize);
    720 };
    721 
    722 class FtpSocketDataProviderEvilLogin
    723     : public FtpSocketDataProviderFileDownload {
    724  public:
    725   FtpSocketDataProviderEvilLogin(const char* expected_user,
    726                                 const char* expected_password)
    727       : expected_user_(expected_user),
    728         expected_password_(expected_password) {
    729   }
    730 
    731   virtual MockWriteResult OnWrite(const std::string& data) OVERRIDE {
    732     if (InjectFault())
    733       return MockWriteResult(ASYNC, data.length());
    734     switch (state()) {
    735       case PRE_USER:
    736         return Verify(std::string("USER ") + expected_user_ + "\r\n", data,
    737                       PRE_PASSWD, "331 Password needed\r\n");
    738       case PRE_PASSWD:
    739         return Verify(std::string("PASS ") + expected_password_ + "\r\n", data,
    740                       PRE_SYST, "230 Welcome\r\n");
    741       default:
    742         return FtpSocketDataProviderFileDownload::OnWrite(data);
    743     }
    744   }
    745 
    746  private:
    747   const char* expected_user_;
    748   const char* expected_password_;
    749 
    750   DISALLOW_COPY_AND_ASSIGN(FtpSocketDataProviderEvilLogin);
    751 };
    752 
    753 class FtpSocketDataProviderCloseConnection : public FtpSocketDataProvider {
    754  public:
    755   FtpSocketDataProviderCloseConnection() {
    756   }
    757 
    758   virtual MockWriteResult OnWrite(const std::string& data) OVERRIDE {
    759     if (InjectFault())
    760       return MockWriteResult(ASYNC, data.length());
    761     switch (state()) {
    762       case PRE_USER:
    763         return Verify("USER anonymous\r\n", data,
    764                       PRE_QUIT, "");
    765       default:
    766         return FtpSocketDataProvider::OnWrite(data);
    767     }
    768   }
    769 
    770  private:
    771   DISALLOW_COPY_AND_ASSIGN(FtpSocketDataProviderCloseConnection);
    772 };
    773 
    774 class FtpNetworkTransactionTest
    775     : public PlatformTest,
    776       public ::testing::WithParamInterface<int> {
    777  public:
    778   FtpNetworkTransactionTest()
    779       : host_resolver_(new MockHostResolver),
    780         session_(new FtpNetworkSession(host_resolver_.get())),
    781         transaction_(session_.get(), &mock_socket_factory_) {
    782     scoped_refptr<RuleBasedHostResolverProc> rules(
    783         new RuleBasedHostResolverProc(NULL));
    784     if (GetFamily() == AF_INET) {
    785       rules->AddIPLiteralRule("*", "127.0.0.1", "127.0.0.1");
    786     } else if (GetFamily() == AF_INET6) {
    787       rules->AddIPLiteralRule("*", "::1", "::1");
    788     } else {
    789       NOTREACHED();
    790     }
    791     host_resolver_->set_rules(rules.get());
    792   }
    793 
    794  protected:
    795   // Accessor to make code refactoring-friendly, e.g. when we change the way
    796   // parameters are passed (like more parameters).
    797   int GetFamily() {
    798     return GetParam();
    799   }
    800 
    801   FtpRequestInfo GetRequestInfo(const std::string& url) {
    802     FtpRequestInfo info;
    803     info.url = GURL(url);
    804     return info;
    805   }
    806 
    807   void ExecuteTransaction(FtpSocketDataProvider* ctrl_socket,
    808                           const char* request,
    809                           int data_socket,
    810                           int expected_result) {
    811     // Expect EPSV usage for non-IPv4 control connections.
    812     ctrl_socket->set_use_epsv((GetFamily() != AF_INET));
    813 
    814     mock_socket_factory_.AddSocketDataProvider(ctrl_socket);
    815 
    816     std::string mock_data("mock-data");
    817     MockRead data_reads[] = {
    818       // Usually FTP servers close the data connection after the entire data has
    819       // been received.
    820       MockRead(SYNCHRONOUS, ERR_TEST_PEER_CLOSE_AFTER_NEXT_MOCK_READ),
    821       MockRead(mock_data.c_str()),
    822     };
    823 
    824     ScopedVector<StaticSocketDataProvider> data_sockets;
    825     data_sockets.reserve(data_socket);
    826     for (int i = 0; i < data_socket + 1; i++) {
    827       // We only read from one data socket, other ones are dummy.
    828       if (i == data_socket) {
    829         data_sockets.push_back(new StaticSocketDataProvider(
    830                                    data_reads, arraysize(data_reads), NULL, 0));
    831       } else {
    832         data_sockets.push_back(new StaticSocketDataProvider);
    833       }
    834       mock_socket_factory_.AddSocketDataProvider(data_sockets[i]);
    835     }
    836 
    837     FtpRequestInfo request_info = GetRequestInfo(request);
    838     EXPECT_EQ(LOAD_STATE_IDLE, transaction_.GetLoadState());
    839     ASSERT_EQ(ERR_IO_PENDING,
    840               transaction_.Start(&request_info, callback_.callback(),
    841                                  BoundNetLog()));
    842     EXPECT_NE(LOAD_STATE_IDLE, transaction_.GetLoadState());
    843     ASSERT_EQ(expected_result, callback_.WaitForResult());
    844     if (expected_result == OK) {
    845       scoped_refptr<IOBuffer> io_buffer(new IOBuffer(kBufferSize));
    846       memset(io_buffer->data(), 0, kBufferSize);
    847       ASSERT_EQ(ERR_IO_PENDING,
    848                 transaction_.Read(io_buffer.get(), kBufferSize,
    849                                   callback_.callback()));
    850       ASSERT_EQ(static_cast<int>(mock_data.length()),
    851                 callback_.WaitForResult());
    852       EXPECT_EQ(mock_data, std::string(io_buffer->data(), mock_data.length()));
    853 
    854       // Do another Read to detect that the data socket is now closed.
    855       int rv = transaction_.Read(io_buffer.get(), kBufferSize,
    856                                  callback_.callback());
    857       if (rv == ERR_IO_PENDING) {
    858         EXPECT_EQ(0, callback_.WaitForResult());
    859       } else {
    860         EXPECT_EQ(0, rv);
    861       }
    862     }
    863     EXPECT_EQ(FtpSocketDataProvider::QUIT, ctrl_socket->state());
    864     EXPECT_EQ(LOAD_STATE_IDLE, transaction_.GetLoadState());
    865   }
    866 
    867   void TransactionFailHelper(FtpSocketDataProvider* ctrl_socket,
    868                              const char* request,
    869                              FtpSocketDataProvider::State state,
    870                              FtpSocketDataProvider::State next_state,
    871                              const char* response,
    872                              int expected_result) {
    873     ctrl_socket->InjectFailure(state, next_state, response);
    874     ExecuteTransaction(ctrl_socket, request, 1, expected_result);
    875   }
    876 
    877   scoped_ptr<MockHostResolver> host_resolver_;
    878   scoped_refptr<FtpNetworkSession> session_;
    879   MockClientSocketFactory mock_socket_factory_;
    880   FtpNetworkTransaction transaction_;
    881   TestCompletionCallback callback_;
    882 };
    883 
    884 TEST_P(FtpNetworkTransactionTest, FailedLookup) {
    885   FtpRequestInfo request_info = GetRequestInfo("ftp://badhost");
    886   scoped_refptr<RuleBasedHostResolverProc> rules(
    887       new RuleBasedHostResolverProc(NULL));
    888   rules->AddSimulatedFailure("badhost");
    889   host_resolver_->set_rules(rules.get());
    890 
    891   EXPECT_EQ(LOAD_STATE_IDLE, transaction_.GetLoadState());
    892   ASSERT_EQ(ERR_IO_PENDING,
    893             transaction_.Start(&request_info, callback_.callback(),
    894                                BoundNetLog()));
    895   ASSERT_EQ(ERR_NAME_NOT_RESOLVED, callback_.WaitForResult());
    896   EXPECT_EQ(LOAD_STATE_IDLE, transaction_.GetLoadState());
    897 }
    898 
    899 // Check that when determining the host, the square brackets decorating IPv6
    900 // literals in URLs are stripped.
    901 TEST_P(FtpNetworkTransactionTest, StripBracketsFromIPv6Literals) {
    902   // This test only makes sense for IPv6 connections.
    903   if (GetFamily() != AF_INET6)
    904     return;
    905 
    906   host_resolver_->rules()->AddSimulatedFailure("[::1]");
    907 
    908   // We start a transaction that is expected to fail with ERR_INVALID_RESPONSE.
    909   // The important part of this test is to make sure that we don't fail with
    910   // ERR_NAME_NOT_RESOLVED, since that would mean the decorated hostname
    911   // was used.
    912   FtpSocketDataProviderEvilSize ctrl_socket(
    913       "213 99999999999999999999999999999999\r\n",
    914       FtpSocketDataProvider::PRE_QUIT);
    915   ExecuteTransaction(&ctrl_socket, "ftp://[::1]/file", 1, ERR_INVALID_RESPONSE);
    916 }
    917 
    918 TEST_P(FtpNetworkTransactionTest, DirectoryTransaction) {
    919   FtpSocketDataProviderDirectoryListing ctrl_socket;
    920   ExecuteTransaction(&ctrl_socket, "ftp://host", 1, OK);
    921 
    922   EXPECT_TRUE(transaction_.GetResponseInfo()->is_directory_listing);
    923   EXPECT_EQ(-1, transaction_.GetResponseInfo()->expected_content_size);
    924   EXPECT_EQ((GetFamily() == AF_INET) ? "127.0.0.1" : "::1",
    925             transaction_.GetResponseInfo()->socket_address.host());
    926   EXPECT_EQ(21, transaction_.GetResponseInfo()->socket_address.port());
    927 }
    928 
    929 TEST_P(FtpNetworkTransactionTest, DirectoryTransactionWithPasvFallback) {
    930   FtpSocketDataProviderDirectoryListingWithPasvFallback ctrl_socket;
    931   ExecuteTransaction(&ctrl_socket, "ftp://host", 1, OK);
    932 
    933   EXPECT_TRUE(transaction_.GetResponseInfo()->is_directory_listing);
    934   EXPECT_EQ(-1, transaction_.GetResponseInfo()->expected_content_size);
    935 }
    936 
    937 TEST_P(FtpNetworkTransactionTest, DirectoryTransactionWithTypecode) {
    938   FtpSocketDataProviderDirectoryListing ctrl_socket;
    939   ExecuteTransaction(&ctrl_socket, "ftp://host;type=d", 1, OK);
    940 
    941   EXPECT_TRUE(transaction_.GetResponseInfo()->is_directory_listing);
    942   EXPECT_EQ(-1, transaction_.GetResponseInfo()->expected_content_size);
    943 }
    944 
    945 TEST_P(FtpNetworkTransactionTest, DirectoryTransactionMultilineWelcome) {
    946   FtpSocketDataProviderDirectoryListing ctrl_socket;
    947   ctrl_socket.set_multiline_welcome(true);
    948   ExecuteTransaction(&ctrl_socket, "ftp://host", 1, OK);
    949 }
    950 
    951 TEST_P(FtpNetworkTransactionTest, DirectoryTransactionShortReads2) {
    952   FtpSocketDataProviderDirectoryListing ctrl_socket;
    953   ctrl_socket.set_short_read_limit(2);
    954   ExecuteTransaction(&ctrl_socket, "ftp://host", 1, OK);
    955 }
    956 
    957 TEST_P(FtpNetworkTransactionTest, DirectoryTransactionShortReads5) {
    958   FtpSocketDataProviderDirectoryListing ctrl_socket;
    959   ctrl_socket.set_short_read_limit(5);
    960   ExecuteTransaction(&ctrl_socket, "ftp://host", 1, OK);
    961 }
    962 
    963 TEST_P(FtpNetworkTransactionTest, DirectoryTransactionMultilineWelcomeShort) {
    964   FtpSocketDataProviderDirectoryListing ctrl_socket;
    965   // The client will not consume all three 230 lines. That's good, we want to
    966   // test that scenario.
    967   ctrl_socket.allow_unconsumed_reads(true);
    968   ctrl_socket.set_multiline_welcome(true);
    969   ctrl_socket.set_short_read_limit(5);
    970   ExecuteTransaction(&ctrl_socket, "ftp://host", 1, OK);
    971 }
    972 
    973 // Regression test for http://crbug.com/60555.
    974 TEST_P(FtpNetworkTransactionTest, DirectoryTransactionZeroSize) {
    975   FtpSocketDataProviderDirectoryListingZeroSize ctrl_socket;
    976   ExecuteTransaction(&ctrl_socket, "ftp://host", 0, OK);
    977 }
    978 
    979 TEST_P(FtpNetworkTransactionTest, DirectoryTransactionVMS) {
    980   FtpSocketDataProviderVMSDirectoryListing ctrl_socket;
    981   ExecuteTransaction(&ctrl_socket, "ftp://host/dir", 1, OK);
    982 }
    983 
    984 TEST_P(FtpNetworkTransactionTest, DirectoryTransactionVMSRootDirectory) {
    985   FtpSocketDataProviderVMSDirectoryListingRootDirectory ctrl_socket;
    986   ExecuteTransaction(&ctrl_socket, "ftp://host", 1, OK);
    987 }
    988 
    989 TEST_P(FtpNetworkTransactionTest, DirectoryTransactionTransferStarting) {
    990   FtpSocketDataProviderDirectoryListingTransferStarting ctrl_socket;
    991   ExecuteTransaction(&ctrl_socket, "ftp://host", 1, OK);
    992 }
    993 
    994 TEST_P(FtpNetworkTransactionTest, DownloadTransaction) {
    995   FtpSocketDataProviderFileDownload ctrl_socket;
    996   ExecuteTransaction(&ctrl_socket, "ftp://host/file", 1, OK);
    997 
    998   // We pass an artificial value of 18 as a response to the SIZE command.
    999   EXPECT_EQ(18, transaction_.GetResponseInfo()->expected_content_size);
   1000   EXPECT_EQ((GetFamily() == AF_INET) ? "127.0.0.1" : "::1",
   1001             transaction_.GetResponseInfo()->socket_address.host());
   1002   EXPECT_EQ(21, transaction_.GetResponseInfo()->socket_address.port());
   1003 }
   1004 
   1005 TEST_P(FtpNetworkTransactionTest, DownloadTransactionWithPasvFallback) {
   1006   FtpSocketDataProviderFileDownloadWithPasvFallback ctrl_socket;
   1007   ExecuteTransaction(&ctrl_socket, "ftp://host/file", 1, OK);
   1008 
   1009   // We pass an artificial value of 18 as a response to the SIZE command.
   1010   EXPECT_EQ(18, transaction_.GetResponseInfo()->expected_content_size);
   1011 }
   1012 
   1013 TEST_P(FtpNetworkTransactionTest, DownloadTransactionWithTypecodeA) {
   1014   FtpSocketDataProviderFileDownloadWithFileTypecode ctrl_socket;
   1015   ctrl_socket.set_data_type('A');
   1016   ExecuteTransaction(&ctrl_socket, "ftp://host/file;type=a", 0, OK);
   1017 
   1018   // We pass an artificial value of 18 as a response to the SIZE command.
   1019   EXPECT_EQ(18, transaction_.GetResponseInfo()->expected_content_size);
   1020 }
   1021 
   1022 TEST_P(FtpNetworkTransactionTest, DownloadTransactionWithTypecodeI) {
   1023   FtpSocketDataProviderFileDownloadWithFileTypecode ctrl_socket;
   1024   ExecuteTransaction(&ctrl_socket, "ftp://host/file;type=i", 0, OK);
   1025 
   1026   // We pass an artificial value of 18 as a response to the SIZE command.
   1027   EXPECT_EQ(18, transaction_.GetResponseInfo()->expected_content_size);
   1028 }
   1029 
   1030 TEST_P(FtpNetworkTransactionTest, DownloadTransactionMultilineWelcome) {
   1031   FtpSocketDataProviderFileDownload ctrl_socket;
   1032   ctrl_socket.set_multiline_welcome(true);
   1033   ExecuteTransaction(&ctrl_socket, "ftp://host/file", 1, OK);
   1034 }
   1035 
   1036 TEST_P(FtpNetworkTransactionTest, DownloadTransactionShortReads2) {
   1037   FtpSocketDataProviderFileDownload ctrl_socket;
   1038   ctrl_socket.set_short_read_limit(2);
   1039   ExecuteTransaction(&ctrl_socket, "ftp://host/file", 1, OK);
   1040 }
   1041 
   1042 TEST_P(FtpNetworkTransactionTest, DownloadTransactionShortReads5) {
   1043   FtpSocketDataProviderFileDownload ctrl_socket;
   1044   ctrl_socket.set_short_read_limit(5);
   1045   ExecuteTransaction(&ctrl_socket, "ftp://host/file", 1, OK);
   1046 }
   1047 
   1048 TEST_P(FtpNetworkTransactionTest, DownloadTransactionZeroSize) {
   1049   FtpSocketDataProviderFileDownloadZeroSize ctrl_socket;
   1050   ExecuteTransaction(&ctrl_socket, "ftp://host/file", 1, OK);
   1051 }
   1052 
   1053 TEST_P(FtpNetworkTransactionTest, DownloadTransactionCWD451) {
   1054   FtpSocketDataProviderFileDownloadCWD451 ctrl_socket;
   1055   ExecuteTransaction(&ctrl_socket, "ftp://host/file", 1, OK);
   1056 }
   1057 
   1058 TEST_P(FtpNetworkTransactionTest, DownloadTransactionVMS) {
   1059   FtpSocketDataProviderVMSFileDownload ctrl_socket;
   1060   ExecuteTransaction(&ctrl_socket, "ftp://host/file", 1, OK);
   1061 }
   1062 
   1063 TEST_P(FtpNetworkTransactionTest, DownloadTransactionTransferStarting) {
   1064   FtpSocketDataProviderFileDownloadTransferStarting ctrl_socket;
   1065   ExecuteTransaction(&ctrl_socket, "ftp://host/file", 1, OK);
   1066 }
   1067 
   1068 TEST_P(FtpNetworkTransactionTest, DownloadTransactionInvalidResponse) {
   1069   FtpSocketDataProviderFileDownloadInvalidResponse ctrl_socket;
   1070   ExecuteTransaction(&ctrl_socket, "ftp://host/file", 1, ERR_INVALID_RESPONSE);
   1071 }
   1072 
   1073 TEST_P(FtpNetworkTransactionTest, DownloadTransactionEvilPasvReallyBadFormat) {
   1074   FtpSocketDataProviderEvilPasv ctrl_socket("227 Portscan (127,0,0,\r\n",
   1075                                             FtpSocketDataProvider::PRE_QUIT);
   1076   ExecuteTransaction(&ctrl_socket, "ftp://host/file", 1, ERR_INVALID_RESPONSE);
   1077 }
   1078 
   1079 TEST_P(FtpNetworkTransactionTest, DownloadTransactionEvilPasvUnsafePort1) {
   1080   FtpSocketDataProviderEvilPasv ctrl_socket("227 Portscan (127,0,0,1,0,22)\r\n",
   1081                                             FtpSocketDataProvider::PRE_QUIT);
   1082   ExecuteTransaction(&ctrl_socket, "ftp://host/file", 1, ERR_UNSAFE_PORT);
   1083 }
   1084 
   1085 TEST_P(FtpNetworkTransactionTest, DownloadTransactionEvilPasvUnsafePort2) {
   1086   // Still unsafe. 1 * 256 + 2 = 258, which is < 1024.
   1087   FtpSocketDataProviderEvilPasv ctrl_socket("227 Portscan (127,0,0,1,1,2)\r\n",
   1088                                             FtpSocketDataProvider::PRE_QUIT);
   1089   ExecuteTransaction(&ctrl_socket, "ftp://host/file", 1, ERR_UNSAFE_PORT);
   1090 }
   1091 
   1092 TEST_P(FtpNetworkTransactionTest, DownloadTransactionEvilPasvUnsafePort3) {
   1093   // Still unsafe. 3 * 256 + 4 = 772, which is < 1024.
   1094   FtpSocketDataProviderEvilPasv ctrl_socket("227 Portscan (127,0,0,1,3,4)\r\n",
   1095                                             FtpSocketDataProvider::PRE_QUIT);
   1096   ExecuteTransaction(&ctrl_socket, "ftp://host/file", 1, ERR_UNSAFE_PORT);
   1097 }
   1098 
   1099 TEST_P(FtpNetworkTransactionTest, DownloadTransactionEvilPasvUnsafePort4) {
   1100   // Unsafe. 8 * 256 + 1 = 2049, which is used by nfs.
   1101   FtpSocketDataProviderEvilPasv ctrl_socket("227 Portscan (127,0,0,1,8,1)\r\n",
   1102                                             FtpSocketDataProvider::PRE_QUIT);
   1103   ExecuteTransaction(&ctrl_socket, "ftp://host/file", 1, ERR_UNSAFE_PORT);
   1104 }
   1105 
   1106 TEST_P(FtpNetworkTransactionTest, DownloadTransactionEvilPasvUnsafeHost) {
   1107   FtpSocketDataProviderEvilPasv ctrl_socket(
   1108       "227 Portscan (10,1,2,3,123,456)\r\n", FtpSocketDataProvider::PRE_SIZE);
   1109   ctrl_socket.set_use_epsv(GetFamily() != AF_INET);
   1110   std::string mock_data("mock-data");
   1111   MockRead data_reads[] = {
   1112     MockRead(mock_data.c_str()),
   1113   };
   1114   StaticSocketDataProvider data_socket1;
   1115   StaticSocketDataProvider data_socket2(data_reads, arraysize(data_reads),
   1116                                         NULL, 0);
   1117   mock_socket_factory_.AddSocketDataProvider(&ctrl_socket);
   1118   mock_socket_factory_.AddSocketDataProvider(&data_socket1);
   1119   mock_socket_factory_.AddSocketDataProvider(&data_socket2);
   1120   FtpRequestInfo request_info = GetRequestInfo("ftp://host/file");
   1121 
   1122   // Start the transaction.
   1123   ASSERT_EQ(ERR_IO_PENDING,
   1124             transaction_.Start(&request_info, callback_.callback(),
   1125                                BoundNetLog()));
   1126   ASSERT_EQ(OK, callback_.WaitForResult());
   1127 
   1128   // The transaction fires the callback when we can start reading data. That
   1129   // means that the data socket should be open.
   1130   MockTCPClientSocket* data_socket =
   1131       static_cast<MockTCPClientSocket*>(transaction_.data_socket_.get());
   1132   ASSERT_TRUE(data_socket);
   1133   ASSERT_TRUE(data_socket->IsConnected());
   1134 
   1135   // Even if the PASV response specified some other address, we connect
   1136   // to the address we used for control connection (which could be 127.0.0.1
   1137   // or ::1 depending on whether we use IPv6).
   1138   for (AddressList::const_iterator it = data_socket->addresses().begin();
   1139       it != data_socket->addresses().end(); ++it) {
   1140     EXPECT_NE("10.1.2.3", it->ToStringWithoutPort());
   1141   }
   1142 }
   1143 
   1144 TEST_P(FtpNetworkTransactionTest, DownloadTransactionEvilEpsvReallyBadFormat1) {
   1145   // This test makes no sense for IPv4 connections (we don't use EPSV there).
   1146   if (GetFamily() == AF_INET)
   1147     return;
   1148 
   1149   FtpSocketDataProviderEvilEpsv ctrl_socket("227 Portscan (|||22)\r\n",
   1150                                             FtpSocketDataProvider::PRE_QUIT);
   1151   ExecuteTransaction(&ctrl_socket, "ftp://host/file", 1, ERR_INVALID_RESPONSE);
   1152 }
   1153 
   1154 TEST_P(FtpNetworkTransactionTest, DownloadTransactionEvilEpsvReallyBadFormat2) {
   1155   // This test makes no sense for IPv4 connections (we don't use EPSV there).
   1156   if (GetFamily() == AF_INET)
   1157     return;
   1158 
   1159   FtpSocketDataProviderEvilEpsv ctrl_socket("227 Portscan (||\r\n",
   1160                                             FtpSocketDataProvider::PRE_QUIT);
   1161   ExecuteTransaction(&ctrl_socket, "ftp://host/file", 1, ERR_INVALID_RESPONSE);
   1162 }
   1163 
   1164 TEST_P(FtpNetworkTransactionTest, DownloadTransactionEvilEpsvReallyBadFormat3) {
   1165   // This test makes no sense for IPv4 connections (we don't use EPSV there).
   1166   if (GetFamily() == AF_INET)
   1167     return;
   1168 
   1169   FtpSocketDataProviderEvilEpsv ctrl_socket("227 Portscan\r\n",
   1170                                             FtpSocketDataProvider::PRE_QUIT);
   1171   ExecuteTransaction(&ctrl_socket, "ftp://host/file", 1, ERR_INVALID_RESPONSE);
   1172 }
   1173 
   1174 TEST_P(FtpNetworkTransactionTest, DownloadTransactionEvilEpsvReallyBadFormat4) {
   1175   // This test makes no sense for IPv4 connections (we don't use EPSV there).
   1176   if (GetFamily() == AF_INET)
   1177     return;
   1178 
   1179   FtpSocketDataProviderEvilEpsv ctrl_socket("227 Portscan (||||)\r\n",
   1180                                             FtpSocketDataProvider::PRE_QUIT);
   1181   ExecuteTransaction(&ctrl_socket, "ftp://host/file", 1, ERR_INVALID_RESPONSE);
   1182 }
   1183 
   1184 TEST_P(FtpNetworkTransactionTest, DownloadTransactionEvilEpsvReallyBadFormat5) {
   1185   // This test makes no sense for IPv4 connections (we don't use EPSV there).
   1186   if (GetFamily() == AF_INET)
   1187     return;
   1188 
   1189   const char response[] = "227 Portscan (\0\0\031773\0)\r\n";
   1190   FtpSocketDataProviderEvilEpsv ctrl_socket(response, sizeof(response)-1,
   1191                                             FtpSocketDataProvider::PRE_QUIT);
   1192   ExecuteTransaction(&ctrl_socket, "ftp://host/file", 1, ERR_INVALID_RESPONSE);
   1193 }
   1194 
   1195 TEST_P(FtpNetworkTransactionTest, DownloadTransactionEvilEpsvUnsafePort1) {
   1196   // This test makes no sense for IPv4 connections (we don't use EPSV there).
   1197   if (GetFamily() == AF_INET)
   1198     return;
   1199 
   1200   FtpSocketDataProviderEvilEpsv ctrl_socket("227 Portscan (|||22|)\r\n",
   1201                                             FtpSocketDataProvider::PRE_QUIT);
   1202   ExecuteTransaction(&ctrl_socket, "ftp://host/file", 1, ERR_UNSAFE_PORT);
   1203 }
   1204 
   1205 TEST_P(FtpNetworkTransactionTest, DownloadTransactionEvilEpsvUnsafePort2) {
   1206   // This test makes no sense for IPv4 connections (we don't use EPSV there).
   1207   if (GetFamily() == AF_INET)
   1208     return;
   1209 
   1210   FtpSocketDataProviderEvilEpsv ctrl_socket("227 Portscan (|||258|)\r\n",
   1211                                             FtpSocketDataProvider::PRE_QUIT);
   1212   ExecuteTransaction(&ctrl_socket, "ftp://host/file", 1, ERR_UNSAFE_PORT);
   1213 }
   1214 
   1215 TEST_P(FtpNetworkTransactionTest, DownloadTransactionEvilEpsvUnsafePort3) {
   1216   // This test makes no sense for IPv4 connections (we don't use EPSV there).
   1217   if (GetFamily() == AF_INET)
   1218     return;
   1219 
   1220   FtpSocketDataProviderEvilEpsv ctrl_socket("227 Portscan (|||772|)\r\n",
   1221                                             FtpSocketDataProvider::PRE_QUIT);
   1222   ExecuteTransaction(&ctrl_socket, "ftp://host/file", 1, ERR_UNSAFE_PORT);
   1223 }
   1224 
   1225 TEST_P(FtpNetworkTransactionTest, DownloadTransactionEvilEpsvUnsafePort4) {
   1226   // This test makes no sense for IPv4 connections (we don't use EPSV there).
   1227   if (GetFamily() == AF_INET)
   1228     return;
   1229 
   1230   FtpSocketDataProviderEvilEpsv ctrl_socket("227 Portscan (|||2049|)\r\n",
   1231                                             FtpSocketDataProvider::PRE_QUIT);
   1232   ExecuteTransaction(&ctrl_socket, "ftp://host/file", 1, ERR_UNSAFE_PORT);
   1233 }
   1234 
   1235 TEST_P(FtpNetworkTransactionTest, DownloadTransactionEvilEpsvWeirdSep) {
   1236   // This test makes no sense for IPv4 connections (we don't use EPSV there).
   1237   if (GetFamily() == AF_INET)
   1238     return;
   1239 
   1240   FtpSocketDataProviderEvilEpsv ctrl_socket("227 Portscan ($$$31744$)\r\n",
   1241                                             FtpSocketDataProvider::PRE_SIZE);
   1242   ExecuteTransaction(&ctrl_socket, "ftp://host/file", 1, OK);
   1243 }
   1244 
   1245 TEST_P(FtpNetworkTransactionTest,
   1246        DownloadTransactionEvilEpsvWeirdSepUnsafePort) {
   1247   // This test makes no sense for IPv4 connections (we don't use EPSV there).
   1248   if (GetFamily() == AF_INET)
   1249     return;
   1250 
   1251   FtpSocketDataProviderEvilEpsv ctrl_socket("227 Portscan ($$$317$)\r\n",
   1252                                             FtpSocketDataProvider::PRE_QUIT);
   1253   ExecuteTransaction(&ctrl_socket, "ftp://host/file", 1, ERR_UNSAFE_PORT);
   1254 }
   1255 
   1256 TEST_P(FtpNetworkTransactionTest, DownloadTransactionEvilEpsvIllegalHost) {
   1257   // This test makes no sense for IPv4 connections (we don't use EPSV there).
   1258   if (GetFamily() == AF_INET)
   1259     return;
   1260 
   1261   FtpSocketDataProviderEvilEpsv ctrl_socket("227 Portscan (|2|::1|31744|)\r\n",
   1262                                             FtpSocketDataProvider::PRE_QUIT);
   1263   ExecuteTransaction(&ctrl_socket, "ftp://host/file", 1, ERR_INVALID_RESPONSE);
   1264 }
   1265 
   1266 TEST_P(FtpNetworkTransactionTest, DownloadTransactionEvilLoginBadUsername) {
   1267   FtpSocketDataProviderEvilLogin ctrl_socket("hello%0Aworld", "test");
   1268   ExecuteTransaction(&ctrl_socket, "ftp://hello%0Aworld:test@host/file", 1, OK);
   1269 }
   1270 
   1271 TEST_P(FtpNetworkTransactionTest, DownloadTransactionEvilLoginBadPassword) {
   1272   FtpSocketDataProviderEvilLogin ctrl_socket("test", "hello%0Dworld");
   1273   ExecuteTransaction(&ctrl_socket, "ftp://test:hello%0Dworld@host/file", 1, OK);
   1274 }
   1275 
   1276 TEST_P(FtpNetworkTransactionTest, DownloadTransactionSpaceInLogin) {
   1277   FtpSocketDataProviderEvilLogin ctrl_socket("hello world", "test");
   1278   ExecuteTransaction(&ctrl_socket, "ftp://hello%20world:test@host/file", 1, OK);
   1279 }
   1280 
   1281 TEST_P(FtpNetworkTransactionTest, DownloadTransactionSpaceInPassword) {
   1282   FtpSocketDataProviderEvilLogin ctrl_socket("test", "hello world");
   1283   ExecuteTransaction(&ctrl_socket, "ftp://test:hello%20world@host/file", 1, OK);
   1284 }
   1285 
   1286 TEST_P(FtpNetworkTransactionTest, EvilRestartUser) {
   1287   FtpSocketDataProvider ctrl_socket1;
   1288   ctrl_socket1.InjectFailure(FtpSocketDataProvider::PRE_PASSWD,
   1289                              FtpSocketDataProvider::PRE_QUIT,
   1290                              "530 Login authentication failed\r\n");
   1291   mock_socket_factory_.AddSocketDataProvider(&ctrl_socket1);
   1292 
   1293   FtpRequestInfo request_info = GetRequestInfo("ftp://host/file");
   1294 
   1295   ASSERT_EQ(ERR_IO_PENDING,
   1296             transaction_.Start(&request_info, callback_.callback(),
   1297                                BoundNetLog()));
   1298   ASSERT_EQ(ERR_FTP_FAILED, callback_.WaitForResult());
   1299 
   1300   MockRead ctrl_reads[] = {
   1301     MockRead("220 host TestFTPd\r\n"),
   1302     MockRead("221 Goodbye!\r\n"),
   1303     MockRead(SYNCHRONOUS, OK),
   1304   };
   1305   MockWrite ctrl_writes[] = {
   1306     MockWrite("QUIT\r\n"),
   1307   };
   1308   StaticSocketDataProvider ctrl_socket2(ctrl_reads, arraysize(ctrl_reads),
   1309                                         ctrl_writes, arraysize(ctrl_writes));
   1310   mock_socket_factory_.AddSocketDataProvider(&ctrl_socket2);
   1311   ASSERT_EQ(ERR_IO_PENDING,
   1312             transaction_.RestartWithAuth(
   1313                 AuthCredentials(
   1314                     ASCIIToUTF16("foo\nownz0red"),
   1315                     ASCIIToUTF16("innocent")),
   1316                 callback_.callback()));
   1317   EXPECT_EQ(ERR_MALFORMED_IDENTITY, callback_.WaitForResult());
   1318 }
   1319 
   1320 TEST_P(FtpNetworkTransactionTest, EvilRestartPassword) {
   1321   FtpSocketDataProvider ctrl_socket1;
   1322   ctrl_socket1.InjectFailure(FtpSocketDataProvider::PRE_PASSWD,
   1323                              FtpSocketDataProvider::PRE_QUIT,
   1324                              "530 Login authentication failed\r\n");
   1325   mock_socket_factory_.AddSocketDataProvider(&ctrl_socket1);
   1326 
   1327   FtpRequestInfo request_info = GetRequestInfo("ftp://host/file");
   1328 
   1329   ASSERT_EQ(ERR_IO_PENDING,
   1330             transaction_.Start(&request_info, callback_.callback(),
   1331                                BoundNetLog()));
   1332   ASSERT_EQ(ERR_FTP_FAILED, callback_.WaitForResult());
   1333 
   1334   MockRead ctrl_reads[] = {
   1335     MockRead("220 host TestFTPd\r\n"),
   1336     MockRead("331 User okay, send password\r\n"),
   1337     MockRead("221 Goodbye!\r\n"),
   1338     MockRead(SYNCHRONOUS, OK),
   1339   };
   1340   MockWrite ctrl_writes[] = {
   1341     MockWrite("USER innocent\r\n"),
   1342     MockWrite("QUIT\r\n"),
   1343   };
   1344   StaticSocketDataProvider ctrl_socket2(ctrl_reads, arraysize(ctrl_reads),
   1345                                         ctrl_writes, arraysize(ctrl_writes));
   1346   mock_socket_factory_.AddSocketDataProvider(&ctrl_socket2);
   1347   ASSERT_EQ(ERR_IO_PENDING,
   1348             transaction_.RestartWithAuth(
   1349                 AuthCredentials(ASCIIToUTF16("innocent"),
   1350                                 ASCIIToUTF16("foo\nownz0red")),
   1351                 callback_.callback()));
   1352   EXPECT_EQ(ERR_MALFORMED_IDENTITY, callback_.WaitForResult());
   1353 }
   1354 
   1355 TEST_P(FtpNetworkTransactionTest, Escaping) {
   1356   FtpSocketDataProviderEscaping ctrl_socket;
   1357   ExecuteTransaction(&ctrl_socket, "ftp://host/%20%21%22%23%24%25%79%80%81",
   1358                      1, OK);
   1359 }
   1360 
   1361 // Test for http://crbug.com/23794.
   1362 TEST_P(FtpNetworkTransactionTest, DownloadTransactionEvilSize) {
   1363   // Try to overflow int64 in the response.
   1364   FtpSocketDataProviderEvilSize ctrl_socket(
   1365       "213 99999999999999999999999999999999\r\n",
   1366       FtpSocketDataProvider::PRE_QUIT);
   1367   ExecuteTransaction(&ctrl_socket, "ftp://host/file", 1, ERR_INVALID_RESPONSE);
   1368 }
   1369 
   1370 // Test for http://crbug.com/36360.
   1371 TEST_P(FtpNetworkTransactionTest, DownloadTransactionBigSize) {
   1372   // Pass a valid, but large file size. The transaction should not fail.
   1373   FtpSocketDataProviderEvilSize ctrl_socket(
   1374       "213 3204427776\r\n",
   1375       FtpSocketDataProvider::PRE_CWD);
   1376   ExecuteTransaction(&ctrl_socket, "ftp://host/file", 1, OK);
   1377   EXPECT_EQ(3204427776LL,
   1378             transaction_.GetResponseInfo()->expected_content_size);
   1379 }
   1380 
   1381 // Regression test for http://crbug.com/25023.
   1382 TEST_P(FtpNetworkTransactionTest, CloseConnection) {
   1383   FtpSocketDataProviderCloseConnection ctrl_socket;
   1384   ExecuteTransaction(&ctrl_socket, "ftp://host", 1, ERR_EMPTY_RESPONSE);
   1385 }
   1386 
   1387 TEST_P(FtpNetworkTransactionTest, DirectoryTransactionFailUser) {
   1388   FtpSocketDataProviderDirectoryListing ctrl_socket;
   1389   // Use unallocated 599 FTP error code to make sure it falls into the generic
   1390   // ERR_FTP_FAILED bucket.
   1391   TransactionFailHelper(&ctrl_socket,
   1392                         "ftp://host",
   1393                         FtpSocketDataProvider::PRE_USER,
   1394                         FtpSocketDataProvider::PRE_QUIT,
   1395                         "599 fail\r\n",
   1396                         ERR_FTP_FAILED);
   1397 }
   1398 
   1399 TEST_P(FtpNetworkTransactionTest, DirectoryTransactionFailPass) {
   1400   FtpSocketDataProviderDirectoryListing ctrl_socket;
   1401   TransactionFailHelper(&ctrl_socket,
   1402                         "ftp://host",
   1403                         FtpSocketDataProvider::PRE_PASSWD,
   1404                         FtpSocketDataProvider::PRE_QUIT,
   1405                         "530 Login authentication failed\r\n",
   1406                         ERR_FTP_FAILED);
   1407 }
   1408 
   1409 // Regression test for http://crbug.com/38707.
   1410 TEST_P(FtpNetworkTransactionTest, DirectoryTransactionFailPass503) {
   1411   FtpSocketDataProviderDirectoryListing ctrl_socket;
   1412   TransactionFailHelper(&ctrl_socket,
   1413                         "ftp://host",
   1414                         FtpSocketDataProvider::PRE_PASSWD,
   1415                         FtpSocketDataProvider::PRE_QUIT,
   1416                         "503 Bad sequence of commands\r\n",
   1417                         ERR_FTP_BAD_COMMAND_SEQUENCE);
   1418 }
   1419 
   1420 TEST_P(FtpNetworkTransactionTest, DirectoryTransactionFailSyst) {
   1421   FtpSocketDataProviderDirectoryListing ctrl_socket;
   1422   // Use unallocated 599 FTP error code to make sure it falls into the generic
   1423   // ERR_FTP_FAILED bucket.
   1424   TransactionFailHelper(&ctrl_socket,
   1425                         "ftp://host",
   1426                         FtpSocketDataProvider::PRE_SYST,
   1427                         FtpSocketDataProvider::PRE_PWD,
   1428                         "599 fail\r\n",
   1429                         OK);
   1430 }
   1431 
   1432 TEST_P(FtpNetworkTransactionTest, DirectoryTransactionFailPwd) {
   1433   FtpSocketDataProviderDirectoryListing ctrl_socket;
   1434   // Use unallocated 599 FTP error code to make sure it falls into the generic
   1435   // ERR_FTP_FAILED bucket.
   1436   TransactionFailHelper(&ctrl_socket,
   1437                         "ftp://host",
   1438                         FtpSocketDataProvider::PRE_PWD,
   1439                         FtpSocketDataProvider::PRE_QUIT,
   1440                         "599 fail\r\n",
   1441                         ERR_FTP_FAILED);
   1442 }
   1443 
   1444 TEST_P(FtpNetworkTransactionTest, DirectoryTransactionFailType) {
   1445   FtpSocketDataProviderDirectoryListing ctrl_socket;
   1446   // Use unallocated 599 FTP error code to make sure it falls into the generic
   1447   // ERR_FTP_FAILED bucket.
   1448   TransactionFailHelper(&ctrl_socket,
   1449                         "ftp://host",
   1450                         FtpSocketDataProvider::PRE_TYPE,
   1451                         FtpSocketDataProvider::PRE_QUIT,
   1452                         "599 fail\r\n",
   1453                         ERR_FTP_FAILED);
   1454 }
   1455 
   1456 TEST_P(FtpNetworkTransactionTest, DirectoryTransactionFailEpsv) {
   1457   // This test makes no sense for IPv4 connections (we don't use EPSV there).
   1458   if (GetFamily() == AF_INET)
   1459     return;
   1460 
   1461   FtpSocketDataProviderDirectoryListing ctrl_socket;
   1462   // Use unallocated 599 FTP error code to make sure it falls into the generic
   1463   // ERR_FTP_FAILED bucket.
   1464   TransactionFailHelper(&ctrl_socket,
   1465                         "ftp://host",
   1466                         FtpSocketDataProvider::PRE_EPSV,
   1467                         FtpSocketDataProvider::PRE_NOPASV,
   1468                         "599 fail\r\n",
   1469                         ERR_FTP_FAILED);
   1470 }
   1471 
   1472 TEST_P(FtpNetworkTransactionTest, DirectoryTransactionFailCwd) {
   1473   FtpSocketDataProviderDirectoryListing ctrl_socket;
   1474   // Use unallocated 599 FTP error code to make sure it falls into the generic
   1475   // ERR_FTP_FAILED bucket.
   1476   TransactionFailHelper(&ctrl_socket,
   1477                         "ftp://host",
   1478                         FtpSocketDataProvider::PRE_CWD,
   1479                         FtpSocketDataProvider::PRE_QUIT,
   1480                         "599 fail\r\n",
   1481                         ERR_FTP_FAILED);
   1482 }
   1483 
   1484 TEST_P(FtpNetworkTransactionTest, DirectoryTransactionFailList) {
   1485   FtpSocketDataProviderVMSDirectoryListing ctrl_socket;
   1486   // Use unallocated 599 FTP error code to make sure it falls into the generic
   1487   // ERR_FTP_FAILED bucket.
   1488   TransactionFailHelper(&ctrl_socket,
   1489                         "ftp://host/dir",
   1490                         FtpSocketDataProvider::PRE_LIST,
   1491                         FtpSocketDataProvider::PRE_QUIT,
   1492                         "599 fail\r\n",
   1493                         ERR_FTP_FAILED);
   1494 }
   1495 
   1496 TEST_P(FtpNetworkTransactionTest, DownloadTransactionFailUser) {
   1497   FtpSocketDataProviderFileDownload ctrl_socket;
   1498   // Use unallocated 599 FTP error code to make sure it falls into the generic
   1499   // ERR_FTP_FAILED bucket.
   1500   TransactionFailHelper(&ctrl_socket,
   1501                         "ftp://host/file",
   1502                         FtpSocketDataProvider::PRE_USER,
   1503                         FtpSocketDataProvider::PRE_QUIT,
   1504                         "599 fail\r\n",
   1505                         ERR_FTP_FAILED);
   1506 }
   1507 
   1508 TEST_P(FtpNetworkTransactionTest, DownloadTransactionFailPass) {
   1509   FtpSocketDataProviderFileDownload ctrl_socket;
   1510   TransactionFailHelper(&ctrl_socket,
   1511                         "ftp://host/file",
   1512                         FtpSocketDataProvider::PRE_PASSWD,
   1513                         FtpSocketDataProvider::PRE_QUIT,
   1514                         "530 Login authentication failed\r\n",
   1515                         ERR_FTP_FAILED);
   1516 }
   1517 
   1518 TEST_P(FtpNetworkTransactionTest, DownloadTransactionFailSyst) {
   1519   FtpSocketDataProviderFileDownload ctrl_socket;
   1520   // Use unallocated 599 FTP error code to make sure it falls into the generic
   1521   // ERR_FTP_FAILED bucket.
   1522   TransactionFailHelper(&ctrl_socket,
   1523                         "ftp://host/file",
   1524                         FtpSocketDataProvider::PRE_SYST,
   1525                         FtpSocketDataProvider::PRE_PWD,
   1526                         "599 fail\r\n",
   1527                         OK);
   1528 }
   1529 
   1530 TEST_P(FtpNetworkTransactionTest, DownloadTransactionFailPwd) {
   1531   FtpSocketDataProviderFileDownload ctrl_socket;
   1532   // Use unallocated 599 FTP error code to make sure it falls into the generic
   1533   // ERR_FTP_FAILED bucket.
   1534   TransactionFailHelper(&ctrl_socket,
   1535                         "ftp://host/file",
   1536                         FtpSocketDataProvider::PRE_PWD,
   1537                         FtpSocketDataProvider::PRE_QUIT,
   1538                         "599 fail\r\n",
   1539                         ERR_FTP_FAILED);
   1540 }
   1541 
   1542 TEST_P(FtpNetworkTransactionTest, DownloadTransactionFailType) {
   1543   FtpSocketDataProviderFileDownload ctrl_socket;
   1544   // Use unallocated 599 FTP error code to make sure it falls into the generic
   1545   // ERR_FTP_FAILED bucket.
   1546   TransactionFailHelper(&ctrl_socket,
   1547                         "ftp://host/file",
   1548                         FtpSocketDataProvider::PRE_TYPE,
   1549                         FtpSocketDataProvider::PRE_QUIT,
   1550                         "599 fail\r\n",
   1551                         ERR_FTP_FAILED);
   1552 }
   1553 
   1554 TEST_P(FtpNetworkTransactionTest, DownloadTransactionFailEpsv) {
   1555   // This test makes no sense for IPv4 connections (we don't use EPSV there).
   1556   if (GetFamily() == AF_INET)
   1557     return;
   1558 
   1559   FtpSocketDataProviderFileDownload ctrl_socket;
   1560   // Use unallocated 599 FTP error code to make sure it falls into the generic
   1561   // ERR_FTP_FAILED bucket.
   1562   TransactionFailHelper(&ctrl_socket,
   1563                         "ftp://host/file",
   1564                         FtpSocketDataProvider::PRE_EPSV,
   1565                         FtpSocketDataProvider::PRE_NOPASV,
   1566                         "599 fail\r\n",
   1567                         ERR_FTP_FAILED);
   1568 }
   1569 
   1570 TEST_P(FtpNetworkTransactionTest, DownloadTransactionFailRetr) {
   1571   FtpSocketDataProviderFileDownload ctrl_socket;
   1572   // Use unallocated 599 FTP error code to make sure it falls into the generic
   1573   // ERR_FTP_FAILED bucket.
   1574   TransactionFailHelper(&ctrl_socket,
   1575                         "ftp://host/file",
   1576                         FtpSocketDataProvider::PRE_RETR,
   1577                         FtpSocketDataProvider::PRE_QUIT,
   1578                         "599 fail\r\n",
   1579                         ERR_FTP_FAILED);
   1580 }
   1581 
   1582 TEST_P(FtpNetworkTransactionTest, FileNotFound) {
   1583   FtpSocketDataProviderFileNotFound ctrl_socket;
   1584   ExecuteTransaction(&ctrl_socket, "ftp://host/file", 2, ERR_FTP_FAILED);
   1585 }
   1586 
   1587 // Test for http://crbug.com/38845.
   1588 TEST_P(FtpNetworkTransactionTest, ZeroLengthDirInPWD) {
   1589   FtpSocketDataProviderFileDownload ctrl_socket;
   1590   TransactionFailHelper(&ctrl_socket,
   1591                         "ftp://host/file",
   1592                         FtpSocketDataProvider::PRE_PWD,
   1593                         FtpSocketDataProvider::PRE_TYPE,
   1594                         "257 \"\"\r\n",
   1595                         OK);
   1596 }
   1597 
   1598 INSTANTIATE_TEST_CASE_P(FTP,
   1599                         FtpNetworkTransactionTest,
   1600                         ::testing::Values(AF_INET, AF_INET6));
   1601 
   1602 }  // namespace net
   1603