Annotation of embedaddon/curl/tests/libtest/lib1507.c, revision 1.1
1.1 ! misho 1: /***************************************************************************
! 2: * _ _ ____ _
! 3: * Project ___| | | | _ \| |
! 4: * / __| | | | |_) | |
! 5: * | (__| |_| | _ <| |___
! 6: * \___|\___/|_| \_\_____|
! 7: *
! 8: * Copyright (C) 1998 - 2020, Daniel Stenberg, <daniel@haxx.se>, et al.
! 9: *
! 10: * This software is licensed as described in the file COPYING, which
! 11: * you should have received as part of this distribution. The terms
! 12: * are also available at https://curl.haxx.se/docs/copyright.html.
! 13: *
! 14: * You may opt to use, copy, modify, merge, publish, distribute and/or sell
! 15: * copies of the Software, and permit persons to whom the Software is
! 16: * furnished to do so, under the terms of the COPYING file.
! 17: *
! 18: * This software is distributed on an "AS IS" basis, WITHOUT WARRANTY OF ANY
! 19: * KIND, either express or implied.
! 20: *
! 21: ***************************************************************************/
! 22: #include "test.h"
! 23:
! 24: #include "testutil.h"
! 25: #include "warnless.h"
! 26: #include "memdebug.h"
! 27:
! 28: /*
! 29: * This is the list of basic details you need to tweak to get things right.
! 30: */
! 31: #define USERNAME "user@example.com"
! 32: #define PASSWORD "123qwerty"
! 33: #define RECIPIENT "<1507-recipient@example.com>"
! 34: #define MAILFROM "<1507-realuser@example.com>"
! 35:
! 36: #define MULTI_PERFORM_HANG_TIMEOUT 60 * 1000
! 37:
! 38: static size_t read_callback(void *ptr, size_t size, size_t nmemb, void *userp)
! 39: {
! 40: (void)ptr;
! 41: (void)size;
! 42: (void)nmemb;
! 43: (void)userp;
! 44: return CURL_READFUNC_ABORT;
! 45: }
! 46:
! 47: int test(char *URL)
! 48: {
! 49: int res = 0;
! 50: CURL *curl = NULL;
! 51: CURLM *mcurl = NULL;
! 52: int still_running = 1;
! 53: struct timeval mp_start;
! 54: struct curl_slist *rcpt_list = NULL;
! 55:
! 56: curl_global_init(CURL_GLOBAL_DEFAULT);
! 57:
! 58: easy_init(curl);
! 59:
! 60: multi_init(mcurl);
! 61:
! 62: rcpt_list = curl_slist_append(rcpt_list, RECIPIENT);
! 63: /* more addresses can be added here
! 64: rcpt_list = curl_slist_append(rcpt_list, "<others@example.com>");
! 65: */
! 66:
! 67: curl_easy_setopt(curl, CURLOPT_URL, URL);
! 68: #if 0
! 69: curl_easy_setopt(curl, CURLOPT_USERNAME, USERNAME);
! 70: curl_easy_setopt(curl, CURLOPT_PASSWORD, PASSWORD);
! 71: #endif
! 72: curl_easy_setopt(curl, CURLOPT_UPLOAD, 1L);
! 73: curl_easy_setopt(curl, CURLOPT_READFUNCTION, read_callback);
! 74: curl_easy_setopt(curl, CURLOPT_MAIL_FROM, MAILFROM);
! 75: curl_easy_setopt(curl, CURLOPT_MAIL_RCPT, rcpt_list);
! 76: curl_easy_setopt(curl, CURLOPT_VERBOSE, 1L);
! 77: multi_add_handle(mcurl, curl);
! 78:
! 79: mp_start = tutil_tvnow();
! 80:
! 81: /* we start some action by calling perform right away */
! 82: curl_multi_perform(mcurl, &still_running);
! 83:
! 84: while(still_running) {
! 85: struct timeval timeout;
! 86: int rc; /* select() return code */
! 87:
! 88: fd_set fdread;
! 89: fd_set fdwrite;
! 90: fd_set fdexcep;
! 91: int maxfd = -1;
! 92:
! 93: long curl_timeo = -1;
! 94:
! 95: FD_ZERO(&fdread);
! 96: FD_ZERO(&fdwrite);
! 97: FD_ZERO(&fdexcep);
! 98:
! 99: /* set a suitable timeout to play around with */
! 100: timeout.tv_sec = 1;
! 101: timeout.tv_usec = 0;
! 102:
! 103: curl_multi_timeout(mcurl, &curl_timeo);
! 104: if(curl_timeo >= 0) {
! 105: timeout.tv_sec = curl_timeo / 1000;
! 106: if(timeout.tv_sec > 1)
! 107: timeout.tv_sec = 1;
! 108: else
! 109: timeout.tv_usec = (curl_timeo % 1000) * 1000;
! 110: }
! 111:
! 112: /* get file descriptors from the transfers */
! 113: curl_multi_fdset(mcurl, &fdread, &fdwrite, &fdexcep, &maxfd);
! 114:
! 115: /* In a real-world program you OF COURSE check the return code of the
! 116: function calls. On success, the value of maxfd is guaranteed to be
! 117: greater or equal than -1. We call select(maxfd + 1, ...), specially in
! 118: case of (maxfd == -1), we call select(0, ...), which is basically equal
! 119: to sleep. */
! 120:
! 121: rc = select(maxfd + 1, &fdread, &fdwrite, &fdexcep, &timeout);
! 122:
! 123: if(tutil_tvdiff(tutil_tvnow(), mp_start) > MULTI_PERFORM_HANG_TIMEOUT) {
! 124: fprintf(stderr, "ABORTING TEST, since it seems "
! 125: "that it would have run forever.\n");
! 126: break;
! 127: }
! 128:
! 129: switch(rc) {
! 130: case -1:
! 131: /* select error */
! 132: break;
! 133: case 0: /* timeout */
! 134: default: /* action */
! 135: curl_multi_perform(mcurl, &still_running);
! 136: break;
! 137: }
! 138: }
! 139:
! 140: test_cleanup:
! 141:
! 142: curl_slist_free_all(rcpt_list);
! 143: curl_multi_remove_handle(mcurl, curl);
! 144: curl_multi_cleanup(mcurl);
! 145: curl_easy_cleanup(curl);
! 146: curl_global_cleanup();
! 147:
! 148: return res;
! 149: }
FreeBSD-CVSweb <freebsd-cvsweb@FreeBSD.org>