tests/libtest/lib504.c

   1 /*****************************************************************************
   2  *                                  _   _ ____  _
   3  *  Project                     ___| | | |  _ \| |
   4  *                             / __| | | | |_) | |
   5  *                            | (__| |_| |  _ <| |___
   6  *                             \___|\___/|_| \_\_____|
   7  *
   8  */
   9
  10 #include "test.h"
  11
  12 #include <sys/types.h>
  13
  14 #include "testutil.h"
  15 #include "memdebug.h"
  16
  17 #define MAIN_LOOP_HANG_TIMEOUT     90 * 1000
  18 #define MULTI_PERFORM_HANG_TIMEOUT 60 * 1000
  19
  20 /*
  21  * Source code in here hugely as reported in bug report 651464 by
  22  * Christopher R. Palmer.
  23  *
  24  * Use multi interface to get document over proxy with bad port number.
  25  * This caused the interface to "hang" in libcurl 7.10.2.
  26  */
  27 int test(char *URL)
  28 {
  29   CURL *c;
  30   int res = 0;
  31   CURLM *m = NULL;
  32   fd_set rd, wr, exc;
  33   CURLMcode ret;
  34   char done = FALSE;
  35   int running;
  36   int max_fd;
  37   int rc;
  38   struct timeval ml_start;
  39   struct timeval mp_start;
  40   char ml_timedout = FALSE;
  41   char mp_timedout = FALSE;
  42
  43   if (curl_global_init(CURL_GLOBAL_ALL) != CURLE_OK) {
  44     fprintf(stderr, "curl_global_init() failed\n");
  45     return TEST_ERR_MAJOR_BAD;
  46   }
  47
  48   if ((c = curl_easy_init()) == NULL) {
  49     fprintf(stderr, "curl_easy_init() failed\n");
  50     curl_global_cleanup();
  51     return TEST_ERR_MAJOR_BAD;
  52   }
  53
  54   /* The point here is that there must not be anything running on the given
  55      proxy port */
  56   if (libtest_arg2)
  57     test_setopt(c, CURLOPT_PROXY, libtest_arg2);
  58   test_setopt(c, CURLOPT_URL, URL);
  59   test_setopt(c, CURLOPT_VERBOSE, 1L);
  60
  61   if ((m = curl_multi_init()) == NULL) {
  62     fprintf(stderr, "curl_multi_init() failed\n");
  63     curl_easy_cleanup(c);
  64     curl_global_cleanup();
  65     return TEST_ERR_MAJOR_BAD;
  66   }
  67
  68   if ((ret = curl_multi_add_handle(m, c)) != CURLM_OK) {
  69     fprintf(stderr, "curl_multi_add_handle() failed, "
  70             "with code %d\n", ret);
  71     curl_multi_cleanup(m);
  72     curl_easy_cleanup(c);
  73     curl_global_cleanup();
  74     return TEST_ERR_MAJOR_BAD;
  75   }
  76
  77   ml_timedout = FALSE;
  78   ml_start = tutil_tvnow();
  79
  80   while (!done) {
  81     struct timeval interval;
  82
  83     interval.tv_sec = 1;
  84     interval.tv_usec = 0;
  85
  86     if (tutil_tvdiff(tutil_tvnow(), ml_start) >
  87         MAIN_LOOP_HANG_TIMEOUT) {
  88       ml_timedout = TRUE;
  89       break;
  90     }
  91     mp_timedout = FALSE;
  92     mp_start = tutil_tvnow();
  93
  94     fprintf(stderr, "curl_multi_perform()\n");
  95
  96     ret = CURLM_CALL_MULTI_PERFORM;
  97
  98     while (ret == CURLM_CALL_MULTI_PERFORM) {
  99       ret = curl_multi_perform(m, &running);
 100       if (tutil_tvdiff(tutil_tvnow(), mp_start) >
 101           MULTI_PERFORM_HANG_TIMEOUT) {
 102         mp_timedout = TRUE;
 103         break;
 104       }
 105     }
 106     if (mp_timedout)
 107       break;
 108
 109     if(!running) {
 110       /* This is where this code is expected to reach */
 111       int numleft;
 112       CURLMsg *msg = curl_multi_info_read(m, &numleft);
 113       fprintf(stderr, "Expected: not running\n");
 114       if(msg && !numleft)
 115         res = 100; /* this is where we should be */
 116       else
 117         res = 99; /* not correct */
 118       break;
 119     }
 120     fprintf(stderr, "running == %d, ret == %d\n", running, ret);
 121
 122     if (ret != CURLM_OK) {
 123       res = 2;
 124       break;
 125     }
 126
 127     FD_ZERO(&rd);
 128     FD_ZERO(&wr);
 129     FD_ZERO(&exc);
 130     max_fd = 0;
 131
 132     fprintf(stderr, "curl_multi_fdset()\n");
 133     if (curl_multi_fdset(m, &rd, &wr, &exc, &max_fd) != CURLM_OK) {
 134       fprintf(stderr, "unexpected failured of fdset.\n");
 135       res = 3;
 136       break;
 137     }
 138     rc = select_test(max_fd+1, &rd, &wr, &exc, &interval);
 139     fprintf(stderr, "select returned %d\n", rc);
 140   }
 141
 142   if (ml_timedout || mp_timedout) {
 143     if (ml_timedout) fprintf(stderr, "ml_timedout\n");
 144     if (mp_timedout) fprintf(stderr, "mp_timedout\n");
 145     fprintf(stderr, "ABORTING TEST, since it seems "
 146             "that it would have run forever.\n");
 147     res = TEST_ERR_RUNS_FOREVER;
 148   }
 149
 150 test_cleanup:
 151
 152   if(m) {
 153     curl_multi_remove_handle(m, c);
 154     curl_multi_cleanup(m);
 155   }
 156   curl_easy_cleanup(c);
 157   curl_global_cleanup();
 158
 159   return res;
 160 }
 161