mirror of
https://github.com/moparisthebest/curl
synced 2024-12-23 00:28:48 -05:00
ed4ce23c23
Although this option should have already been set, the SMTP module can now download information from and send instructional commands to, an SMTP server, requiring the option to be set in order to perform a mail transfer.
169 lines
4.6 KiB
C
169 lines
4.6 KiB
C
/***************************************************************************
|
|
* _ _ ____ _
|
|
* Project ___| | | | _ \| |
|
|
* / __| | | | |_) | |
|
|
* | (__| |_| | _ <| |___
|
|
* \___|\___/|_| \_\_____|
|
|
*
|
|
* Copyright (C) 1998 - 2013, Daniel Stenberg, <daniel@haxx.se>, et al.
|
|
*
|
|
* This software is licensed as described in the file COPYING, which
|
|
* you should have received as part of this distribution. The terms
|
|
* are also available at http://curl.haxx.se/docs/copyright.html.
|
|
*
|
|
* You may opt to use, copy, modify, merge, publish, distribute and/or sell
|
|
* copies of the Software, and permit persons to whom the Software is
|
|
* furnished to do so, under the terms of the COPYING file.
|
|
*
|
|
* This software is distributed on an "AS IS" basis, WITHOUT WARRANTY OF ANY
|
|
* KIND, either express or implied.
|
|
*
|
|
***************************************************************************/
|
|
#include "test.h"
|
|
|
|
#include "testutil.h"
|
|
#include "warnless.h"
|
|
#include "memdebug.h"
|
|
|
|
/*
|
|
* This is the list of basic details you need to tweak to get things right.
|
|
*/
|
|
#define USERNAME "user@example.com"
|
|
#define PASSWORD "123qwerty"
|
|
#define RECIPIENT "<1507-recipient@example.com>"
|
|
#define MAILFROM "<1507-realuser@example.com>"
|
|
|
|
#define MULTI_PERFORM_HANG_TIMEOUT 60 * 1000
|
|
|
|
static size_t read_callback(void *ptr, size_t size, size_t nmemb, void *userp)
|
|
{
|
|
(void)ptr;
|
|
(void)size;
|
|
(void)nmemb;
|
|
(void)userp;
|
|
return CURL_READFUNC_ABORT;
|
|
}
|
|
|
|
static struct timeval tvnow(void)
|
|
{
|
|
/*
|
|
** time() returns the value of time in seconds since the Epoch.
|
|
*/
|
|
struct timeval now;
|
|
now.tv_sec = (long)time(NULL);
|
|
now.tv_usec = 0;
|
|
return now;
|
|
}
|
|
|
|
static long tvdiff(struct timeval newer, struct timeval older)
|
|
{
|
|
return (newer.tv_sec-older.tv_sec)*1000+
|
|
(newer.tv_usec-older.tv_usec)/1000;
|
|
}
|
|
|
|
int test(char *URL)
|
|
{
|
|
CURL *curl;
|
|
CURLM *mcurl;
|
|
int still_running = 1;
|
|
struct timeval mp_start;
|
|
struct curl_slist* rcpt_list = NULL;
|
|
|
|
curl_global_init(CURL_GLOBAL_DEFAULT);
|
|
|
|
curl = curl_easy_init();
|
|
if(!curl)
|
|
return 1;
|
|
|
|
mcurl = curl_multi_init();
|
|
if(!mcurl)
|
|
return 2;
|
|
|
|
rcpt_list = curl_slist_append(rcpt_list, RECIPIENT);
|
|
/* more addresses can be added here
|
|
rcpt_list = curl_slist_append(rcpt_list, "<others@example.com>");
|
|
*/
|
|
|
|
curl_easy_setopt(curl, CURLOPT_URL, URL);
|
|
#if 0
|
|
curl_easy_setopt(curl, CURLOPT_USERNAME, USERNAME);
|
|
curl_easy_setopt(curl, CURLOPT_PASSWORD, PASSWORD);
|
|
#endif
|
|
curl_easy_setopt(curl, CURLOPT_UPLOAD, 1L);
|
|
curl_easy_setopt(curl, CURLOPT_READFUNCTION, read_callback);
|
|
curl_easy_setopt(curl, CURLOPT_MAIL_FROM, MAILFROM);
|
|
curl_easy_setopt(curl, CURLOPT_MAIL_RCPT, rcpt_list);
|
|
curl_easy_setopt(curl, CURLOPT_VERBOSE, 1L);
|
|
curl_multi_add_handle(mcurl, curl);
|
|
|
|
mp_start = tvnow();
|
|
|
|
/* we start some action by calling perform right away */
|
|
curl_multi_perform(mcurl, &still_running);
|
|
|
|
while(still_running) {
|
|
struct timeval timeout;
|
|
int rc; /* select() return code */
|
|
|
|
fd_set fdread;
|
|
fd_set fdwrite;
|
|
fd_set fdexcep;
|
|
int maxfd = -1;
|
|
|
|
long curl_timeo = -1;
|
|
|
|
FD_ZERO(&fdread);
|
|
FD_ZERO(&fdwrite);
|
|
FD_ZERO(&fdexcep);
|
|
|
|
/* set a suitable timeout to play around with */
|
|
timeout.tv_sec = 1;
|
|
timeout.tv_usec = 0;
|
|
|
|
curl_multi_timeout(mcurl, &curl_timeo);
|
|
if(curl_timeo >= 0) {
|
|
timeout.tv_sec = curl_timeo / 1000;
|
|
if(timeout.tv_sec > 1)
|
|
timeout.tv_sec = 1;
|
|
else
|
|
timeout.tv_usec = (curl_timeo % 1000) * 1000;
|
|
}
|
|
|
|
/* get file descriptors from the transfers */
|
|
curl_multi_fdset(mcurl, &fdread, &fdwrite, &fdexcep, &maxfd);
|
|
|
|
/* In a real-world program you OF COURSE check the return code of the
|
|
function calls. On success, the value of maxfd is guaranteed to be
|
|
greater or equal than -1. We call select(maxfd + 1, ...), specially in
|
|
case of (maxfd == -1), we call select(0, ...), which is basically equal
|
|
to sleep. */
|
|
|
|
rc = select(maxfd+1, &fdread, &fdwrite, &fdexcep, &timeout);
|
|
|
|
if (tvdiff(tvnow(), mp_start) > MULTI_PERFORM_HANG_TIMEOUT) {
|
|
fprintf(stderr, "ABORTING TEST, since it seems "
|
|
"that it would have run forever.\n");
|
|
break;
|
|
}
|
|
|
|
switch(rc) {
|
|
case -1:
|
|
/* select error */
|
|
break;
|
|
case 0: /* timeout */
|
|
default: /* action */
|
|
curl_multi_perform(mcurl, &still_running);
|
|
break;
|
|
}
|
|
}
|
|
|
|
curl_slist_free_all(rcpt_list);
|
|
curl_multi_remove_handle(mcurl, curl);
|
|
curl_multi_cleanup(mcurl);
|
|
curl_easy_cleanup(curl);
|
|
curl_global_cleanup();
|
|
return 0;
|
|
}
|
|
|
|
|