1 /***************************************************************************
3 * Project ___| | | | _ \| |
5 * | (__| |_| | _ <| |___
6 * \___|\___/|_| \_\_____|
8 * Copyright (C) 1998 - 2013, Daniel Stenberg, <daniel@haxx.se>, et al.
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 http://curl.haxx.se/docs/copyright.html.
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.
18 * This software is distributed on an "AS IS" basis, WITHOUT WARRANTY OF ANY
19 * KIND, either express or implied.
21 ***************************************************************************/
23 #include "curl_setup.h"
25 #ifdef HAVE_NETINET_IN_H
26 #include <netinet/in.h>
31 #ifdef HAVE_ARPA_INET_H
32 #include <arpa/inet.h>
37 #ifdef HAVE_SYS_IOCTL_H
38 #include <sys/ioctl.h>
41 #ifdef HAVE_SYS_PARAM_H
42 #include <sys/param.h>
51 #error "We can't compile without socket() support!"
61 #include <stringprep.h>
62 #ifdef HAVE_IDN_FREE_H
65 /* prototype from idn-free.h, not provided by libidn 0.4.5's make install! */
66 void idn_free (void *ptr);
69 /* if idn_free() was not found in this version of libidn use free() instead */
70 #define idn_free(x) (free)(x)
72 #elif defined(USE_WIN32_IDN)
73 /* prototype for curl_win32_idn_to_ascii() */
74 int curl_win32_idn_to_ascii(const char *in, char **out);
75 #endif /* USE_LIBIDN */
92 #include "content_encoding.h"
93 #include "http_digest.h"
94 #include "http_negotiate.h"
98 #include "speedcheck.h"
100 #include "warnless.h"
101 #include "non-ascii.h"
102 #include "inet_pton.h"
104 /* And now for the protocols */
111 #include "curl_ldap.h"
116 #include "inet_ntop.h"
117 #include "curl_ntlm.h"
118 #include "curl_ntlm_wb.h"
120 #include "curl_rtmp.h"
122 #include "http_proxy.h"
124 #include "conncache.h"
125 #include "multihandle.h"
126 #include "pipeline.h"
128 #define _MPRINTF_REPLACE /* use our functions only */
129 #include <curl/mprintf.h>
131 #include "curl_memory.h"
132 /* The last #include file should be: */
133 #include "memdebug.h"
135 /* Local static prototypes */
136 static struct connectdata *
137 find_oldest_idle_connection(struct SessionHandle *data);
138 static struct connectdata *
139 find_oldest_idle_connection_in_bundle(struct SessionHandle *data,
140 struct connectbundle *bundle);
141 static void conn_free(struct connectdata *conn);
142 static void signalPipeClose(struct curl_llist *pipeline, bool pipe_broke);
143 static CURLcode do_init(struct connectdata *conn);
144 static CURLcode parse_url_login(struct SessionHandle *data,
145 struct connectdata *conn,
146 char *user, char *passwd, char *options);
147 static CURLcode parse_login_details(const char *login, const size_t len,
148 char **userptr, char **passwdptr,
154 static const struct Curl_handler * const protocols[] = {
156 #ifndef CURL_DISABLE_HTTP
160 #if defined(USE_SSL) && !defined(CURL_DISABLE_HTTP)
164 #ifndef CURL_DISABLE_FTP
168 #if defined(USE_SSL) && !defined(CURL_DISABLE_FTP)
172 #ifndef CURL_DISABLE_TELNET
173 &Curl_handler_telnet,
176 #ifndef CURL_DISABLE_DICT
180 #ifndef CURL_DISABLE_LDAP
182 #if !defined(CURL_DISABLE_LDAPS) && \
183 ((defined(USE_OPENLDAP) && defined(USE_SSL)) || \
184 (!defined(USE_OPENLDAP) && defined(HAVE_LDAP_SSL)))
189 #ifndef CURL_DISABLE_FILE
193 #ifndef CURL_DISABLE_TFTP
202 #ifndef CURL_DISABLE_IMAP
209 #ifndef CURL_DISABLE_POP3
216 #ifndef CURL_DISABLE_SMTP
223 #ifndef CURL_DISABLE_RTSP
227 #ifndef CURL_DISABLE_GOPHER
228 &Curl_handler_gopher,
235 &Curl_handler_rtmpte,
237 &Curl_handler_rtmpts,
240 (struct Curl_handler *) NULL
244 * Dummy handler for undefined protocol schemes.
247 static const struct Curl_handler Curl_handler_dummy = {
248 "<no protocol>", /* scheme */
249 ZERO_NULL, /* setup_connection */
250 ZERO_NULL, /* do_it */
251 ZERO_NULL, /* done */
252 ZERO_NULL, /* do_more */
253 ZERO_NULL, /* connect_it */
254 ZERO_NULL, /* connecting */
255 ZERO_NULL, /* doing */
256 ZERO_NULL, /* proto_getsock */
257 ZERO_NULL, /* doing_getsock */
258 ZERO_NULL, /* domore_getsock */
259 ZERO_NULL, /* perform_getsock */
260 ZERO_NULL, /* disconnect */
261 ZERO_NULL, /* readwrite */
264 PROTOPT_NONE /* flags */
267 void Curl_freeset(struct SessionHandle *data)
269 /* Free all dynamic strings stored in the data->set substructure. */
271 for(i=(enum dupstring)0; i < STRING_LAST; i++)
272 Curl_safefree(data->set.str[i]);
274 if(data->change.referer_alloc) {
275 Curl_safefree(data->change.referer);
276 data->change.referer_alloc = FALSE;
278 data->change.referer = NULL;
281 static CURLcode setstropt(char **charp, char *s)
283 /* Release the previous storage at `charp' and replace by a dynamic storage
284 copy of `s'. Return CURLE_OK or CURLE_OUT_OF_MEMORY. */
286 Curl_safefree(*charp);
292 return CURLE_OUT_OF_MEMORY;
300 static CURLcode setstropt_userpwd(char *option, char **userp, char **passwdp,
303 CURLcode result = CURLE_OK;
306 char *options = NULL;
308 /* Parse the login details if specified. It not then we treat NULL as a hint
309 to clear the existing data */
311 result = parse_login_details(option, strlen(option),
312 (userp ? &user : NULL),
313 (passwdp ? &passwd : NULL),
314 (optionsp ? &options : NULL));
318 /* Store the username part of option if required */
320 Curl_safefree(*userp);
324 /* Store the password part of option if required */
326 Curl_safefree(*passwdp);
330 /* Store the options part of option if required */
332 Curl_safefree(*optionsp);
340 CURLcode Curl_dupset(struct SessionHandle *dst, struct SessionHandle *src)
342 CURLcode r = CURLE_OK;
345 /* Copy src->set into dst->set first, then deal with the strings
349 /* clear all string pointers first */
350 memset(dst->set.str, 0, STRING_LAST * sizeof(char *));
352 /* duplicate all strings */
353 for(i=(enum dupstring)0; i< STRING_LAST; i++) {
354 r = setstropt(&dst->set.str[i], src->set.str[i]);
359 /* If a failure occurred, freeing has to be performed externally. */
364 * This is the internal function curl_easy_cleanup() calls. This should
365 * cleanup and free all resources associated with this sessionhandle.
367 * NOTE: if we ever add something that attempts to write to a socket or
368 * similar here, we must ignore SIGPIPE first. It is currently only done
369 * when curl_easy_perform() is invoked.
372 CURLcode Curl_close(struct SessionHandle *data)
374 struct Curl_multi *m;
379 Curl_expire(data, 0); /* shut off timers */
384 /* This handle is still part of a multi handle, take care of this first
385 and detach this handle from there. */
386 curl_multi_remove_handle(data->multi, data);
389 /* when curl_easy_perform() is used, it creates its own multi handle to
390 use and this is the one */
391 curl_multi_cleanup(data->multi_easy);
393 /* Destroy the timeout list that is held in the easy handle. It is
394 /normally/ done by curl_multi_remove_handle() but this is "just in
396 if(data->state.timeoutlist) {
397 Curl_llist_destroy(data->state.timeoutlist, NULL);
398 data->state.timeoutlist = NULL;
401 data->magic = 0; /* force a clear AFTER the possibly enforced removal from
402 the multi handle, since that function uses the magic
405 if(data->state.rangestringalloc)
406 free(data->state.range);
408 /* Free the pathbuffer */
409 Curl_safefree(data->state.pathbuffer);
410 data->state.path = NULL;
412 Curl_safefree(data->state.proto.generic);
414 /* Close down all open SSL info and sessions */
415 Curl_ssl_close_all(data);
416 Curl_safefree(data->state.first_host);
417 Curl_safefree(data->state.scratch);
418 Curl_ssl_free_certinfo(data);
420 if(data->change.referer_alloc) {
421 Curl_safefree(data->change.referer);
422 data->change.referer_alloc = FALSE;
424 data->change.referer = NULL;
426 if(data->change.url_alloc) {
427 Curl_safefree(data->change.url);
428 data->change.url_alloc = FALSE;
430 data->change.url = NULL;
432 Curl_safefree(data->state.headerbuff);
434 Curl_flush_cookies(data, 1);
436 Curl_digest_cleanup(data);
438 Curl_safefree(data->info.contenttype);
439 Curl_safefree(data->info.wouldredirect);
441 /* this destroys the channel and we cannot use it anymore after this */
442 Curl_resolver_cleanup(data->state.resolver);
444 Curl_convert_close(data);
446 /* No longer a dirty share, if it exists */
448 Curl_share_lock(data, CURL_LOCK_DATA_SHARE, CURL_LOCK_ACCESS_SINGLE);
449 data->share->dirty--;
450 Curl_share_unlock(data, CURL_LOCK_DATA_SHARE);
459 * Initialize the UserDefined fields within a SessionHandle.
460 * This may be safely called on a new or existing SessionHandle.
462 CURLcode Curl_init_userdefined(struct UserDefined *set)
464 CURLcode res = CURLE_OK;
466 set->out = stdout; /* default output to stdout */
467 set->in = stdin; /* default input from stdin */
468 set->err = stderr; /* default stderr to stderr */
470 /* use fwrite as default function to store output */
471 set->fwrite_func = (curl_write_callback)fwrite;
473 /* use fread as default function to read input */
474 set->fread_func = (curl_read_callback)fread;
475 set->is_fread_set = 0;
476 set->is_fwrite_set = 0;
478 set->seek_func = ZERO_NULL;
479 set->seek_client = ZERO_NULL;
481 /* conversion callbacks for non-ASCII hosts */
482 set->convfromnetwork = ZERO_NULL;
483 set->convtonetwork = ZERO_NULL;
484 set->convfromutf8 = ZERO_NULL;
486 set->infilesize = -1; /* we don't know any size */
487 set->postfieldsize = -1; /* unknown size */
488 set->maxredirs = -1; /* allow any amount by default */
490 set->httpreq = HTTPREQ_GET; /* Default HTTP request */
491 set->rtspreq = RTSPREQ_OPTIONS; /* Default RTSP request */
492 set->ftp_use_epsv = TRUE; /* FTP defaults to EPSV operations */
493 set->ftp_use_eprt = TRUE; /* FTP defaults to EPRT operations */
494 set->ftp_use_pret = FALSE; /* mainly useful for drftpd servers */
495 set->ftp_filemethod = FTPFILE_MULTICWD;
497 set->dns_cache_timeout = 60; /* Timeout every 60 seconds by default */
499 /* Set the default size of the SSL session ID cache */
500 set->ssl.max_ssl_sessions = 5;
502 set->proxyport = CURL_DEFAULT_PROXY_PORT; /* from url.h */
503 set->proxytype = CURLPROXY_HTTP; /* defaults to HTTP proxy */
504 set->httpauth = CURLAUTH_BASIC; /* defaults to basic */
505 set->proxyauth = CURLAUTH_BASIC; /* defaults to basic */
507 /* make libcurl quiet by default: */
508 set->hide_progress = TRUE; /* CURLOPT_NOPROGRESS changes these */
511 * libcurl 7.10 introduced SSL verification *by default*! This needs to be
512 * switched off unless wanted.
514 set->ssl.verifypeer = TRUE;
515 set->ssl.verifyhost = TRUE;
517 set->ssl.authtype = CURL_TLSAUTH_NONE;
519 set->ssh_auth_types = CURLSSH_AUTH_DEFAULT; /* defaults to any auth
521 set->ssl.sessionid = TRUE; /* session ID caching enabled by default */
523 set->new_file_perms = 0644; /* Default permissions */
524 set->new_directory_perms = 0755; /* Default permissions */
526 /* for the *protocols fields we don't use the CURLPROTO_ALL convenience
527 define since we internally only use the lower 16 bits for the passed
528 in bitmask to not conflict with the private bits */
529 set->allowed_protocols = CURLPROTO_ALL;
530 set->redir_protocols =
531 CURLPROTO_ALL & ~(CURLPROTO_FILE|CURLPROTO_SCP); /* not FILE or SCP */
533 #if defined(HAVE_GSSAPI) || defined(USE_WINDOWS_SSPI)
535 * disallow unprotected protection negotiation NEC reference implementation
536 * seem not to follow rfc1961 section 4.3/4.4
538 set->socks5_gssapi_nec = FALSE;
539 /* set default gssapi service name */
540 res = setstropt(&set->str[STRING_SOCKS5_GSSAPI_SERVICE],
541 (char *) CURL_DEFAULT_SOCKS5_GSSAPI_SERVICE);
546 /* This is our preferred CA cert bundle/path since install time */
547 #if defined(CURL_CA_BUNDLE)
548 res = setstropt(&set->str[STRING_SSL_CAFILE], (char *) CURL_CA_BUNDLE);
549 #elif defined(CURL_CA_PATH)
550 res = setstropt(&set->str[STRING_SSL_CAPATH], (char *) CURL_CA_PATH);
553 set->wildcardmatch = FALSE;
554 set->chunk_bgn = ZERO_NULL;
555 set->chunk_end = ZERO_NULL;
557 /* tcp keepalives are disabled by default, but provide reasonable values for
558 * the interval and idle times.
560 set->tcp_keepalive = FALSE;
561 set->tcp_keepintvl = 60;
562 set->tcp_keepidle = 60;
570 * @param curl is a pointer to a sessionhandle pointer that gets set by this
575 CURLcode Curl_open(struct SessionHandle **curl)
577 CURLcode res = CURLE_OK;
578 struct SessionHandle *data;
581 /* Very simple start-up: alloc the struct, init it with zeroes and return */
582 data = calloc(1, sizeof(struct SessionHandle));
584 /* this is a very serious error */
585 DEBUGF(fprintf(stderr, "Error: calloc of SessionHandle failed\n"));
586 return CURLE_OUT_OF_MEMORY;
589 data->magic = CURLEASY_MAGIC_NUMBER;
591 status = Curl_resolver_init(&data->state.resolver);
593 DEBUGF(fprintf(stderr, "Error: resolver_init failed\n"));
598 /* We do some initial setup here, all those fields that can't be just 0 */
600 data->state.headerbuff = malloc(HEADERSIZE);
601 if(!data->state.headerbuff) {
602 DEBUGF(fprintf(stderr, "Error: malloc of headerbuff failed\n"));
603 res = CURLE_OUT_OF_MEMORY;
606 Curl_easy_initHandleData(data);
607 res = Curl_init_userdefined(&data->set);
609 data->state.headersize=HEADERSIZE;
611 Curl_convert_init(data);
613 /* most recent connection is not yet defined */
614 data->state.lastconnect = NULL;
616 data->progress.flags |= PGRS_HIDE;
617 data->state.current_speed = -1; /* init to negative == impossible */
619 data->wildcard.state = CURLWC_INIT;
620 data->wildcard.filelist = NULL;
621 data->set.fnmatch = ZERO_NULL;
622 data->set.maxconnects = DEFAULT_CONNCACHE_SIZE; /* for easy handles */
626 Curl_resolver_cleanup(data->state.resolver);
627 if(data->state.headerbuff)
628 free(data->state.headerbuff);
639 CURLcode Curl_setopt(struct SessionHandle *data, CURLoption option,
643 CURLcode result = CURLE_OK;
645 #ifndef CURL_DISABLE_HTTP
650 case CURLOPT_DNS_CACHE_TIMEOUT:
651 data->set.dns_cache_timeout = va_arg(param, long);
653 case CURLOPT_DNS_USE_GLOBAL_CACHE:
654 /* remember we want this enabled */
655 arg = va_arg(param, long);
656 data->set.global_dns_cache = (0 != arg)?TRUE:FALSE;
658 case CURLOPT_SSL_CIPHER_LIST:
659 /* set a list of cipher we want to use in the SSL connection */
660 result = setstropt(&data->set.str[STRING_SSL_CIPHER_LIST],
661 va_arg(param, char *));
664 case CURLOPT_RANDOM_FILE:
666 * This is the path name to a file that contains random data to seed
667 * the random SSL stuff with. The file is only used for reading.
669 result = setstropt(&data->set.str[STRING_SSL_RANDOM_FILE],
670 va_arg(param, char *));
672 case CURLOPT_EGDSOCKET:
674 * The Entropy Gathering Daemon socket pathname
676 result = setstropt(&data->set.str[STRING_SSL_EGDSOCKET],
677 va_arg(param, char *));
679 case CURLOPT_MAXCONNECTS:
681 * Set the absolute number of maximum simultaneous alive connection that
682 * libcurl is allowed to have.
684 data->set.maxconnects = va_arg(param, long);
686 case CURLOPT_FORBID_REUSE:
688 * When this transfer is done, it must not be left to be reused by a
689 * subsequent transfer but shall be closed immediately.
691 data->set.reuse_forbid = (0 != va_arg(param, long))?TRUE:FALSE;
693 case CURLOPT_FRESH_CONNECT:
695 * This transfer shall not use a previously cached connection but
696 * should be made with a fresh new connect!
698 data->set.reuse_fresh = (0 != va_arg(param, long))?TRUE:FALSE;
700 case CURLOPT_VERBOSE:
702 * Verbose means infof() calls that give a lot of information about
703 * the connection and transfer procedures as well as internal choices.
705 data->set.verbose = (0 != va_arg(param, long))?TRUE:FALSE;
709 * Set to include the header in the general data output stream.
711 data->set.include_header = (0 != va_arg(param, long))?TRUE:FALSE;
713 case CURLOPT_NOPROGRESS:
715 * Shut off the internal supported progress meter
717 data->set.hide_progress = (0 != va_arg(param, long))?TRUE:FALSE;
718 if(data->set.hide_progress)
719 data->progress.flags |= PGRS_HIDE;
721 data->progress.flags &= ~PGRS_HIDE;
725 * Do not include the body part in the output data stream.
727 data->set.opt_no_body = (0 != va_arg(param, long))?TRUE:FALSE;
729 case CURLOPT_FAILONERROR:
731 * Don't output the >=300 error code HTML-page, but instead only
734 data->set.http_fail_on_error = (0 != va_arg(param, long))?TRUE:FALSE;
739 * We want to sent data to the remote host. If this is HTTP, that equals
740 * using the PUT request.
742 data->set.upload = (0 != va_arg(param, long))?TRUE:FALSE;
743 if(data->set.upload) {
744 /* If this is HTTP, PUT is what's needed to "upload" */
745 data->set.httpreq = HTTPREQ_PUT;
746 data->set.opt_no_body = FALSE; /* this is implied */
749 /* In HTTP, the opposite of upload is GET (unless NOBODY is true as
750 then this can be changed to HEAD later on) */
751 data->set.httpreq = HTTPREQ_GET;
753 case CURLOPT_FILETIME:
755 * Try to get the file time of the remote document. The time will
756 * later (possibly) become available using curl_easy_getinfo().
758 data->set.get_filetime = (0 != va_arg(param, long))?TRUE:FALSE;
760 case CURLOPT_FTP_CREATE_MISSING_DIRS:
762 * An FTP option that modifies an upload to create missing directories on
765 switch(va_arg(param, long)) {
767 data->set.ftp_create_missing_dirs = 0;
770 data->set.ftp_create_missing_dirs = 1;
773 data->set.ftp_create_missing_dirs = 2;
776 /* reserve other values for future use */
777 result = CURLE_UNKNOWN_OPTION;
781 case CURLOPT_SERVER_RESPONSE_TIMEOUT:
783 * Option that specifies how quickly an server response must be obtained
784 * before it is considered failure. For pingpong protocols.
786 data->set.server_response_timeout = va_arg( param , long ) * 1000;
788 case CURLOPT_TFTP_BLKSIZE:
790 * TFTP option that specifies the block size to use for data transmission
792 data->set.tftp_blksize = va_arg(param, long);
794 case CURLOPT_DIRLISTONLY:
796 * An option that changes the command to one that asks for a list
797 * only, no file info details.
799 data->set.ftp_list_only = (0 != va_arg(param, long))?TRUE:FALSE;
803 * We want to upload and append to an existing file.
805 data->set.ftp_append = (0 != va_arg(param, long))?TRUE:FALSE;
807 case CURLOPT_FTP_FILEMETHOD:
809 * How do access files over FTP.
811 data->set.ftp_filemethod = (curl_ftpfile)va_arg(param, long);
815 * Parse the $HOME/.netrc file
817 data->set.use_netrc = (enum CURL_NETRC_OPTION)va_arg(param, long);
819 case CURLOPT_NETRC_FILE:
821 * Use this file instead of the $HOME/.netrc file
823 result = setstropt(&data->set.str[STRING_NETRC_FILE],
824 va_arg(param, char *));
826 case CURLOPT_TRANSFERTEXT:
828 * This option was previously named 'FTPASCII'. Renamed to work with
829 * more protocols than merely FTP.
831 * Transfer using ASCII (instead of BINARY).
833 data->set.prefer_ascii = (0 != va_arg(param, long))?TRUE:FALSE;
835 case CURLOPT_TIMECONDITION:
837 * Set HTTP time condition. This must be one of the defines in the
838 * curl/curl.h header file.
840 data->set.timecondition = (curl_TimeCond)va_arg(param, long);
842 case CURLOPT_TIMEVALUE:
844 * This is the value to compare with the remote document with the
845 * method set with CURLOPT_TIMECONDITION
847 data->set.timevalue = (time_t)va_arg(param, long);
849 case CURLOPT_SSLVERSION:
851 * Set explicit SSL version to try to connect with, as some SSL
852 * implementations are lame.
854 data->set.ssl.version = va_arg(param, long);
857 #ifndef CURL_DISABLE_HTTP
858 case CURLOPT_AUTOREFERER:
860 * Switch on automatic referer that gets set if curl follows locations.
862 data->set.http_auto_referer = (0 != va_arg(param, long))?TRUE:FALSE;
865 case CURLOPT_ACCEPT_ENCODING:
867 * String to use at the value of Accept-Encoding header.
869 * If the encoding is set to "" we use an Accept-Encoding header that
870 * encompasses all the encodings we support.
871 * If the encoding is set to NULL we don't send an Accept-Encoding header
872 * and ignore an received Content-Encoding header.
875 argptr = va_arg(param, char *);
876 result = setstropt(&data->set.str[STRING_ENCODING],
877 (argptr && !*argptr)?
878 (char *) ALL_CONTENT_ENCODINGS: argptr);
881 case CURLOPT_TRANSFER_ENCODING:
882 data->set.http_transfer_encoding = (0 != va_arg(param, long))?TRUE:FALSE;
885 case CURLOPT_FOLLOWLOCATION:
887 * Follow Location: header hints on a HTTP-server.
889 data->set.http_follow_location = (0 != va_arg(param, long))?TRUE:FALSE;
892 case CURLOPT_UNRESTRICTED_AUTH:
894 * Send authentication (user+password) when following locations, even when
897 data->set.http_disable_hostname_check_before_authentication =
898 (0 != va_arg(param, long))?TRUE:FALSE;
901 case CURLOPT_MAXREDIRS:
903 * The maximum amount of hops you allow curl to follow Location:
904 * headers. This should mostly be used to detect never-ending loops.
906 data->set.maxredirs = va_arg(param, long);
909 case CURLOPT_POSTREDIR:
912 * Set the behaviour of POST when redirecting
913 * CURL_REDIR_GET_ALL - POST is changed to GET after 301 and 302
914 * CURL_REDIR_POST_301 - POST is kept as POST after 301
915 * CURL_REDIR_POST_302 - POST is kept as POST after 302
916 * CURL_REDIR_POST_303 - POST is kept as POST after 303
917 * CURL_REDIR_POST_ALL - POST is kept as POST after 301, 302 and 303
918 * other - POST is kept as POST after 301 and 302
920 int postRedir = curlx_sltosi(va_arg(param, long));
921 data->set.keep_post = postRedir & CURL_REDIR_POST_ALL;
926 /* Does this option serve a purpose anymore? Yes it does, when
927 CURLOPT_POSTFIELDS isn't used and the POST data is read off the
929 if(va_arg(param, long)) {
930 data->set.httpreq = HTTPREQ_POST;
931 data->set.opt_no_body = FALSE; /* this is implied */
934 data->set.httpreq = HTTPREQ_GET;
937 case CURLOPT_COPYPOSTFIELDS:
939 * A string with POST data. Makes curl HTTP POST. Even if it is NULL.
940 * If needed, CURLOPT_POSTFIELDSIZE must have been set prior to
941 * CURLOPT_COPYPOSTFIELDS and not altered later.
943 argptr = va_arg(param, char *);
945 if(!argptr || data->set.postfieldsize == -1)
946 result = setstropt(&data->set.str[STRING_COPYPOSTFIELDS], argptr);
949 * Check that requested length does not overflow the size_t type.
952 if((data->set.postfieldsize < 0) ||
953 ((sizeof(curl_off_t) != sizeof(size_t)) &&
954 (data->set.postfieldsize > (curl_off_t)((size_t)-1))))
955 result = CURLE_OUT_OF_MEMORY;
959 (void) setstropt(&data->set.str[STRING_COPYPOSTFIELDS], NULL);
961 /* Allocate even when size == 0. This satisfies the need of possible
962 later address compare to detect the COPYPOSTFIELDS mode, and
963 to mark that postfields is used rather than read function or
966 p = malloc((size_t)(data->set.postfieldsize?
967 data->set.postfieldsize:1));
970 result = CURLE_OUT_OF_MEMORY;
972 if(data->set.postfieldsize)
973 memcpy(p, argptr, (size_t)data->set.postfieldsize);
975 data->set.str[STRING_COPYPOSTFIELDS] = p;
980 data->set.postfields = data->set.str[STRING_COPYPOSTFIELDS];
981 data->set.httpreq = HTTPREQ_POST;
984 case CURLOPT_POSTFIELDS:
986 * Like above, but use static data instead of copying it.
988 data->set.postfields = va_arg(param, void *);
989 /* Release old copied data. */
990 (void) setstropt(&data->set.str[STRING_COPYPOSTFIELDS], NULL);
991 data->set.httpreq = HTTPREQ_POST;
994 case CURLOPT_POSTFIELDSIZE:
996 * The size of the POSTFIELD data to prevent libcurl to do strlen() to
997 * figure it out. Enables binary posts.
999 bigsize = va_arg(param, long);
1001 if(data->set.postfieldsize < bigsize &&
1002 data->set.postfields == data->set.str[STRING_COPYPOSTFIELDS]) {
1003 /* Previous CURLOPT_COPYPOSTFIELDS is no longer valid. */
1004 (void) setstropt(&data->set.str[STRING_COPYPOSTFIELDS], NULL);
1005 data->set.postfields = NULL;
1008 data->set.postfieldsize = bigsize;
1011 case CURLOPT_POSTFIELDSIZE_LARGE:
1013 * The size of the POSTFIELD data to prevent libcurl to do strlen() to
1014 * figure it out. Enables binary posts.
1016 bigsize = va_arg(param, curl_off_t);
1018 if(data->set.postfieldsize < bigsize &&
1019 data->set.postfields == data->set.str[STRING_COPYPOSTFIELDS]) {
1020 /* Previous CURLOPT_COPYPOSTFIELDS is no longer valid. */
1021 (void) setstropt(&data->set.str[STRING_COPYPOSTFIELDS], NULL);
1022 data->set.postfields = NULL;
1025 data->set.postfieldsize = bigsize;
1028 case CURLOPT_HTTPPOST:
1030 * Set to make us do HTTP POST
1032 data->set.httppost = va_arg(param, struct curl_httppost *);
1033 data->set.httpreq = HTTPREQ_POST_FORM;
1034 data->set.opt_no_body = FALSE; /* this is implied */
1037 case CURLOPT_REFERER:
1039 * String to set in the HTTP Referer: field.
1041 if(data->change.referer_alloc) {
1042 Curl_safefree(data->change.referer);
1043 data->change.referer_alloc = FALSE;
1045 result = setstropt(&data->set.str[STRING_SET_REFERER],
1046 va_arg(param, char *));
1047 data->change.referer = data->set.str[STRING_SET_REFERER];
1050 case CURLOPT_USERAGENT:
1052 * String to use in the HTTP User-Agent field
1054 result = setstropt(&data->set.str[STRING_USERAGENT],
1055 va_arg(param, char *));
1058 case CURLOPT_HTTPHEADER:
1060 * Set a list with HTTP headers to use (or replace internals with)
1062 data->set.headers = va_arg(param, struct curl_slist *);
1065 case CURLOPT_HTTP200ALIASES:
1067 * Set a list of aliases for HTTP 200 in response header
1069 data->set.http200aliases = va_arg(param, struct curl_slist *);
1072 #if !defined(CURL_DISABLE_COOKIES)
1073 case CURLOPT_COOKIE:
1075 * Cookie string to send to the remote server in the request.
1077 result = setstropt(&data->set.str[STRING_COOKIE],
1078 va_arg(param, char *));
1081 case CURLOPT_COOKIEFILE:
1083 * Set cookie file to read and parse. Can be used multiple times.
1085 argptr = (char *)va_arg(param, void *);
1087 struct curl_slist *cl;
1088 /* append the cookie file name to the list of file names, and deal with
1090 cl = curl_slist_append(data->change.cookielist, argptr);
1092 curl_slist_free_all(data->change.cookielist);
1093 data->change.cookielist = NULL;
1094 return CURLE_OUT_OF_MEMORY;
1096 data->change.cookielist = cl; /* store the list for later use */
1100 case CURLOPT_COOKIEJAR:
1102 * Set cookie file name to dump all cookies to when we're done.
1104 result = setstropt(&data->set.str[STRING_COOKIEJAR],
1105 va_arg(param, char *));
1108 * Activate the cookie parser. This may or may not already
1111 data->cookies = Curl_cookie_init(data, NULL, data->cookies,
1112 data->set.cookiesession);
1115 case CURLOPT_COOKIESESSION:
1117 * Set this option to TRUE to start a new "cookie session". It will
1118 * prevent the forthcoming read-cookies-from-file actions to accept
1119 * cookies that are marked as being session cookies, as they belong to a
1122 * In the original Netscape cookie spec, "session cookies" are cookies
1123 * with no expire date set. RFC2109 describes the same action if no
1124 * 'Max-Age' is set and RFC2965 includes the RFC2109 description and adds
1125 * a 'Discard' action that can enforce the discard even for cookies that
1128 * We run mostly with the original cookie spec, as hardly anyone implements
1131 data->set.cookiesession = (0 != va_arg(param, long))?TRUE:FALSE;
1134 case CURLOPT_COOKIELIST:
1135 argptr = va_arg(param, char *);
1140 if(Curl_raw_equal(argptr, "ALL")) {
1141 /* clear all cookies */
1142 Curl_cookie_clearall(data->cookies);
1145 else if(Curl_raw_equal(argptr, "SESS")) {
1146 /* clear session cookies */
1147 Curl_cookie_clearsess(data->cookies);
1150 else if(Curl_raw_equal(argptr, "FLUSH")) {
1151 /* flush cookies to file */
1152 Curl_flush_cookies(data, 0);
1157 /* if cookie engine was not running, activate it */
1158 data->cookies = Curl_cookie_init(data, NULL, NULL, TRUE);
1160 argptr = strdup(argptr);
1162 result = CURLE_OUT_OF_MEMORY;
1166 if(checkprefix("Set-Cookie:", argptr))
1167 /* HTTP Header format line */
1168 Curl_cookie_add(data, data->cookies, TRUE, argptr + 11, NULL, NULL);
1171 /* Netscape format line */
1172 Curl_cookie_add(data, data->cookies, FALSE, argptr, NULL, NULL);
1176 #endif /* CURL_DISABLE_COOKIES */
1178 case CURLOPT_HTTPGET:
1180 * Set to force us do HTTP GET
1182 if(va_arg(param, long)) {
1183 data->set.httpreq = HTTPREQ_GET;
1184 data->set.upload = FALSE; /* switch off upload */
1185 data->set.opt_no_body = FALSE; /* this is implied */
1189 case CURLOPT_HTTP_VERSION:
1191 * This sets a requested HTTP version to be used. The value is one of
1192 * the listed enums in curl/curl.h.
1194 data->set.httpversion = va_arg(param, long);
1197 case CURLOPT_HTTPAUTH:
1199 * Set HTTP Authentication type BITMASK.
1204 unsigned long auth = va_arg(param, unsigned long);
1206 if(auth == CURLAUTH_NONE) {
1207 data->set.httpauth = auth;
1211 /* the DIGEST_IE bit is only used to set a special marker, for all the
1212 rest we need to handle it as normal DIGEST */
1213 data->state.authhost.iestyle = (auth & CURLAUTH_DIGEST_IE)?TRUE:FALSE;
1215 if(auth & CURLAUTH_DIGEST_IE) {
1216 auth |= CURLAUTH_DIGEST; /* set standard digest bit */
1217 auth &= ~CURLAUTH_DIGEST_IE; /* unset ie digest bit */
1220 /* switch off bits we can't support */
1222 auth &= ~CURLAUTH_NTLM; /* no NTLM support */
1223 auth &= ~CURLAUTH_NTLM_WB; /* no NTLM_WB support */
1224 #elif !defined(NTLM_WB_ENABLED)
1225 auth &= ~CURLAUTH_NTLM_WB; /* no NTLM_WB support */
1227 #ifndef USE_HTTP_NEGOTIATE
1228 auth &= ~CURLAUTH_GSSNEGOTIATE; /* no GSS-Negotiate without GSSAPI or
1232 /* check if any auth bit lower than CURLAUTH_ONLY is still set */
1235 while(bitcheck < 31) {
1236 if(auth & (1UL << bitcheck++)) {
1242 return CURLE_NOT_BUILT_IN; /* no supported types left! */
1244 data->set.httpauth = auth;
1248 #endif /* CURL_DISABLE_HTTP */
1250 case CURLOPT_CUSTOMREQUEST:
1252 * Set a custom string to use as request
1254 result = setstropt(&data->set.str[STRING_CUSTOMREQUEST],
1255 va_arg(param, char *));
1258 data->set.httpreq = HTTPREQ_CUSTOM;
1259 here, we continue as if we were using the already set type
1260 and this just changes the actual request keyword */
1263 #ifndef CURL_DISABLE_PROXY
1264 case CURLOPT_HTTPPROXYTUNNEL:
1266 * Tunnel operations through the proxy instead of normal proxy use
1268 data->set.tunnel_thru_httpproxy = (0 != va_arg(param, long))?TRUE:FALSE;
1271 case CURLOPT_PROXYPORT:
1273 * Explicitly set HTTP proxy port number.
1275 data->set.proxyport = va_arg(param, long);
1278 case CURLOPT_PROXYAUTH:
1280 * Set HTTP Authentication type BITMASK.
1285 unsigned long auth = va_arg(param, unsigned long);
1287 if(auth == CURLAUTH_NONE) {
1288 data->set.proxyauth = auth;
1292 /* the DIGEST_IE bit is only used to set a special marker, for all the
1293 rest we need to handle it as normal DIGEST */
1294 data->state.authproxy.iestyle = (auth & CURLAUTH_DIGEST_IE)?TRUE:FALSE;
1296 if(auth & CURLAUTH_DIGEST_IE) {
1297 auth |= CURLAUTH_DIGEST; /* set standard digest bit */
1298 auth &= ~CURLAUTH_DIGEST_IE; /* unset ie digest bit */
1300 /* switch off bits we can't support */
1302 auth &= ~CURLAUTH_NTLM; /* no NTLM support */
1303 auth &= ~CURLAUTH_NTLM_WB; /* no NTLM_WB support */
1304 #elif !defined(NTLM_WB_ENABLED)
1305 auth &= ~CURLAUTH_NTLM_WB; /* no NTLM_WB support */
1307 #ifndef USE_HTTP_NEGOTIATE
1308 auth &= ~CURLAUTH_GSSNEGOTIATE; /* no GSS-Negotiate without GSSAPI or
1312 /* check if any auth bit lower than CURLAUTH_ONLY is still set */
1315 while(bitcheck < 31) {
1316 if(auth & (1UL << bitcheck++)) {
1322 return CURLE_NOT_BUILT_IN; /* no supported types left! */
1324 data->set.proxyauth = auth;
1330 * Set proxy server:port to use as HTTP proxy.
1332 * If the proxy is set to "" we explicitly say that we don't want to use a
1333 * proxy (even though there might be environment variables saying so).
1335 * Setting it to NULL, means no proxy but allows the environment variables
1338 result = setstropt(&data->set.str[STRING_PROXY],
1339 va_arg(param, char *));
1342 case CURLOPT_PROXYTYPE:
1344 * Set proxy type. HTTP/HTTP_1_0/SOCKS4/SOCKS4a/SOCKS5/SOCKS5_HOSTNAME
1346 data->set.proxytype = (curl_proxytype)va_arg(param, long);
1349 case CURLOPT_PROXY_TRANSFER_MODE:
1351 * set transfer mode (;type=<a|i>) when doing FTP via an HTTP proxy
1353 switch (va_arg(param, long)) {
1355 data->set.proxy_transfer_mode = FALSE;
1358 data->set.proxy_transfer_mode = TRUE;
1361 /* reserve other values for future use */
1362 result = CURLE_UNKNOWN_OPTION;
1366 #endif /* CURL_DISABLE_PROXY */
1368 #if defined(HAVE_GSSAPI) || defined(USE_WINDOWS_SSPI)
1369 case CURLOPT_SOCKS5_GSSAPI_SERVICE:
1371 * Set gssapi service name
1373 result = setstropt(&data->set.str[STRING_SOCKS5_GSSAPI_SERVICE],
1374 va_arg(param, char *));
1377 case CURLOPT_SOCKS5_GSSAPI_NEC:
1379 * set flag for nec socks5 support
1381 data->set.socks5_gssapi_nec = (0 != va_arg(param, long))?TRUE:FALSE;
1385 case CURLOPT_WRITEHEADER:
1387 * Custom pointer to pass the header write callback function
1389 data->set.writeheader = (void *)va_arg(param, void *);
1391 case CURLOPT_ERRORBUFFER:
1393 * Error buffer provided by the caller to get the human readable
1396 data->set.errorbuffer = va_arg(param, char *);
1400 * FILE pointer to write to. Or possibly
1401 * used as argument to the write callback.
1403 data->set.out = va_arg(param, void *);
1405 case CURLOPT_FTPPORT:
1407 * Use FTP PORT, this also specifies which IP address to use
1409 result = setstropt(&data->set.str[STRING_FTPPORT],
1410 va_arg(param, char *));
1411 data->set.ftp_use_port = (NULL != data->set.str[STRING_FTPPORT]) ?
1415 case CURLOPT_FTP_USE_EPRT:
1416 data->set.ftp_use_eprt = (0 != va_arg(param, long))?TRUE:FALSE;
1419 case CURLOPT_FTP_USE_EPSV:
1420 data->set.ftp_use_epsv = (0 != va_arg(param, long))?TRUE:FALSE;
1423 case CURLOPT_FTP_USE_PRET:
1424 data->set.ftp_use_pret = (0 != va_arg(param, long))?TRUE:FALSE;
1427 case CURLOPT_FTP_SSL_CCC:
1428 data->set.ftp_ccc = (curl_ftpccc)va_arg(param, long);
1431 case CURLOPT_FTP_SKIP_PASV_IP:
1433 * Enable or disable FTP_SKIP_PASV_IP, which will disable/enable the
1434 * bypass of the IP address in PASV responses.
1436 data->set.ftp_skip_ip = (0 != va_arg(param, long))?TRUE:FALSE;
1439 case CURLOPT_INFILE:
1441 * FILE pointer to read the file to be uploaded from. Or possibly
1442 * used as argument to the read callback.
1444 data->set.in = va_arg(param, void *);
1446 case CURLOPT_INFILESIZE:
1448 * If known, this should inform curl about the file size of the
1449 * to-be-uploaded file.
1451 data->set.infilesize = va_arg(param, long);
1453 case CURLOPT_INFILESIZE_LARGE:
1455 * If known, this should inform curl about the file size of the
1456 * to-be-uploaded file.
1458 data->set.infilesize = va_arg(param, curl_off_t);
1460 case CURLOPT_LOW_SPEED_LIMIT:
1462 * The low speed limit that if transfers are below this for
1463 * CURLOPT_LOW_SPEED_TIME, the transfer is aborted.
1465 data->set.low_speed_limit=va_arg(param, long);
1467 case CURLOPT_MAX_SEND_SPEED_LARGE:
1469 * When transfer uploads are faster then CURLOPT_MAX_SEND_SPEED_LARGE
1470 * bytes per second the transfer is throttled..
1472 data->set.max_send_speed=va_arg(param, curl_off_t);
1474 case CURLOPT_MAX_RECV_SPEED_LARGE:
1476 * When receiving data faster than CURLOPT_MAX_RECV_SPEED_LARGE bytes per
1477 * second the transfer is throttled..
1479 data->set.max_recv_speed=va_arg(param, curl_off_t);
1481 case CURLOPT_LOW_SPEED_TIME:
1483 * The low speed time that if transfers are below the set
1484 * CURLOPT_LOW_SPEED_LIMIT during this time, the transfer is aborted.
1486 data->set.low_speed_time=va_arg(param, long);
1492 if(data->change.url_alloc) {
1493 /* the already set URL is allocated, free it first! */
1494 Curl_safefree(data->change.url);
1495 data->change.url_alloc = FALSE;
1497 result = setstropt(&data->set.str[STRING_SET_URL],
1498 va_arg(param, char *));
1499 data->change.url = data->set.str[STRING_SET_URL];
1503 * The port number to use when getting the URL
1505 data->set.use_port = va_arg(param, long);
1507 case CURLOPT_TIMEOUT:
1509 * The maximum time you allow curl to use for a single transfer
1512 data->set.timeout = va_arg(param, long) * 1000L;
1515 case CURLOPT_TIMEOUT_MS:
1516 data->set.timeout = va_arg(param, long);
1519 case CURLOPT_CONNECTTIMEOUT:
1521 * The maximum time you allow curl to use to connect.
1523 data->set.connecttimeout = va_arg(param, long) * 1000L;
1526 case CURLOPT_CONNECTTIMEOUT_MS:
1527 data->set.connecttimeout = va_arg(param, long);
1530 case CURLOPT_ACCEPTTIMEOUT_MS:
1532 * The maximum time you allow curl to wait for server connect
1534 data->set.accepttimeout = va_arg(param, long);
1537 case CURLOPT_USERPWD:
1539 * user:password;options to use in the operation
1541 result = setstropt_userpwd(va_arg(param, char *),
1542 &data->set.str[STRING_USERNAME],
1543 &data->set.str[STRING_PASSWORD],
1544 &data->set.str[STRING_OPTIONS]);
1546 case CURLOPT_USERNAME:
1548 * authentication user name to use in the operation
1550 result = setstropt(&data->set.str[STRING_USERNAME],
1551 va_arg(param, char *));
1553 case CURLOPT_PASSWORD:
1555 * authentication password to use in the operation
1557 result = setstropt(&data->set.str[STRING_PASSWORD],
1558 va_arg(param, char *));
1560 case CURLOPT_POSTQUOTE:
1562 * List of RAW FTP commands to use after a transfer
1564 data->set.postquote = va_arg(param, struct curl_slist *);
1566 case CURLOPT_PREQUOTE:
1568 * List of RAW FTP commands to use prior to RETR (Wesley Laxton)
1570 data->set.prequote = va_arg(param, struct curl_slist *);
1574 * List of RAW FTP commands to use before a transfer
1576 data->set.quote = va_arg(param, struct curl_slist *);
1578 case CURLOPT_RESOLVE:
1580 * List of NAME:[address] names to populate the DNS cache with
1581 * Prefix the NAME with dash (-) to _remove_ the name from the cache.
1583 * Names added with this API will remain in the cache until explicitly
1584 * removed or the handle is cleaned up.
1586 * This API can remove any name from the DNS cache, but only entries
1587 * that aren't actually in use right now will be pruned immediately.
1589 data->set.resolve = va_arg(param, struct curl_slist *);
1590 data->change.resolve = data->set.resolve;
1592 case CURLOPT_PROGRESSFUNCTION:
1594 * Progress callback function
1596 data->set.fprogress = va_arg(param, curl_progress_callback);
1597 if(data->set.fprogress)
1598 data->progress.callback = TRUE; /* no longer internal */
1600 data->progress.callback = FALSE; /* NULL enforces internal */
1603 case CURLOPT_PROGRESSDATA:
1605 * Custom client data to pass to the progress callback
1607 data->set.progress_client = va_arg(param, void *);
1610 #ifndef CURL_DISABLE_PROXY
1611 case CURLOPT_PROXYUSERPWD:
1613 * user:password needed to use the proxy
1615 result = setstropt_userpwd(va_arg(param, char *),
1616 &data->set.str[STRING_PROXYUSERNAME],
1617 &data->set.str[STRING_PROXYPASSWORD], NULL);
1619 case CURLOPT_PROXYUSERNAME:
1621 * authentication user name to use in the operation
1623 result = setstropt(&data->set.str[STRING_PROXYUSERNAME],
1624 va_arg(param, char *));
1626 case CURLOPT_PROXYPASSWORD:
1628 * authentication password to use in the operation
1630 result = setstropt(&data->set.str[STRING_PROXYPASSWORD],
1631 va_arg(param, char *));
1633 case CURLOPT_NOPROXY:
1635 * proxy exception list
1637 result = setstropt(&data->set.str[STRING_NOPROXY],
1638 va_arg(param, char *));
1644 * What range of the file you want to transfer
1646 result = setstropt(&data->set.str[STRING_SET_RANGE],
1647 va_arg(param, char *));
1649 case CURLOPT_RESUME_FROM:
1651 * Resume transfer at the give file position
1653 data->set.set_resume_from = va_arg(param, long);
1655 case CURLOPT_RESUME_FROM_LARGE:
1657 * Resume transfer at the give file position
1659 data->set.set_resume_from = va_arg(param, curl_off_t);
1661 case CURLOPT_DEBUGFUNCTION:
1663 * stderr write callback.
1665 data->set.fdebug = va_arg(param, curl_debug_callback);
1667 * if the callback provided is NULL, it'll use the default callback
1670 case CURLOPT_DEBUGDATA:
1672 * Set to a void * that should receive all error writes. This
1673 * defaults to CURLOPT_STDERR for normal operations.
1675 data->set.debugdata = va_arg(param, void *);
1677 case CURLOPT_STDERR:
1679 * Set to a FILE * that should receive all error writes. This
1680 * defaults to stderr for normal operations.
1682 data->set.err = va_arg(param, FILE *);
1684 data->set.err = stderr;
1686 case CURLOPT_HEADERFUNCTION:
1688 * Set header write callback
1690 data->set.fwrite_header = va_arg(param, curl_write_callback);
1692 case CURLOPT_WRITEFUNCTION:
1694 * Set data write callback
1696 data->set.fwrite_func = va_arg(param, curl_write_callback);
1697 if(!data->set.fwrite_func) {
1698 data->set.is_fwrite_set = 0;
1699 /* When set to NULL, reset to our internal default function */
1700 data->set.fwrite_func = (curl_write_callback)fwrite;
1703 data->set.is_fwrite_set = 1;
1705 case CURLOPT_READFUNCTION:
1707 * Read data callback
1709 data->set.fread_func = va_arg(param, curl_read_callback);
1710 if(!data->set.fread_func) {
1711 data->set.is_fread_set = 0;
1712 /* When set to NULL, reset to our internal default function */
1713 data->set.fread_func = (curl_read_callback)fread;
1716 data->set.is_fread_set = 1;
1718 case CURLOPT_SEEKFUNCTION:
1720 * Seek callback. Might be NULL.
1722 data->set.seek_func = va_arg(param, curl_seek_callback);
1724 case CURLOPT_SEEKDATA:
1726 * Seek control callback. Might be NULL.
1728 data->set.seek_client = va_arg(param, void *);
1730 case CURLOPT_CONV_FROM_NETWORK_FUNCTION:
1732 * "Convert from network encoding" callback
1734 data->set.convfromnetwork = va_arg(param, curl_conv_callback);
1736 case CURLOPT_CONV_TO_NETWORK_FUNCTION:
1738 * "Convert to network encoding" callback
1740 data->set.convtonetwork = va_arg(param, curl_conv_callback);
1742 case CURLOPT_CONV_FROM_UTF8_FUNCTION:
1744 * "Convert from UTF-8 encoding" callback
1746 data->set.convfromutf8 = va_arg(param, curl_conv_callback);
1748 case CURLOPT_IOCTLFUNCTION:
1750 * I/O control callback. Might be NULL.
1752 data->set.ioctl_func = va_arg(param, curl_ioctl_callback);
1754 case CURLOPT_IOCTLDATA:
1756 * I/O control data pointer. Might be NULL.
1758 data->set.ioctl_client = va_arg(param, void *);
1760 case CURLOPT_SSLCERT:
1762 * String that holds file name of the SSL certificate to use
1764 result = setstropt(&data->set.str[STRING_CERT],
1765 va_arg(param, char *));
1767 case CURLOPT_SSLCERTTYPE:
1769 * String that holds file type of the SSL certificate to use
1771 result = setstropt(&data->set.str[STRING_CERT_TYPE],
1772 va_arg(param, char *));
1774 case CURLOPT_SSLKEY:
1776 * String that holds file name of the SSL key to use
1778 result = setstropt(&data->set.str[STRING_KEY],
1779 va_arg(param, char *));
1781 case CURLOPT_SSLKEYTYPE:
1783 * String that holds file type of the SSL key to use
1785 result = setstropt(&data->set.str[STRING_KEY_TYPE],
1786 va_arg(param, char *));
1788 case CURLOPT_KEYPASSWD:
1790 * String that holds the SSL or SSH private key password.
1792 result = setstropt(&data->set.str[STRING_KEY_PASSWD],
1793 va_arg(param, char *));
1795 case CURLOPT_SSLENGINE:
1797 * String that holds the SSL crypto engine.
1799 argptr = va_arg(param, char *);
1800 if(argptr && argptr[0])
1801 result = Curl_ssl_set_engine(data, argptr);
1804 case CURLOPT_SSLENGINE_DEFAULT:
1806 * flag to set engine as default.
1808 result = Curl_ssl_set_engine_default(data);
1812 * Kludgy option to enable CRLF conversions. Subject for removal.
1814 data->set.crlf = (0 != va_arg(param, long))?TRUE:FALSE;
1817 case CURLOPT_INTERFACE:
1819 * Set what interface or address/hostname to bind the socket to when
1820 * performing an operation and thus what from-IP your connection will use.
1822 result = setstropt(&data->set.str[STRING_DEVICE],
1823 va_arg(param, char *));
1825 case CURLOPT_LOCALPORT:
1827 * Set what local port to bind the socket to when performing an operation.
1829 data->set.localport = curlx_sltous(va_arg(param, long));
1831 case CURLOPT_LOCALPORTRANGE:
1833 * Set number of local ports to try, starting with CURLOPT_LOCALPORT.
1835 data->set.localportrange = curlx_sltosi(va_arg(param, long));
1837 case CURLOPT_KRBLEVEL:
1839 * A string that defines the kerberos security level.
1841 result = setstropt(&data->set.str[STRING_KRB_LEVEL],
1842 va_arg(param, char *));
1843 data->set.krb = (NULL != data->set.str[STRING_KRB_LEVEL])?TRUE:FALSE;
1845 case CURLOPT_GSSAPI_DELEGATION:
1847 * GSSAPI credential delegation
1849 data->set.gssapi_delegation = va_arg(param, long);
1851 case CURLOPT_SSL_VERIFYPEER:
1853 * Enable peer SSL verifying.
1855 data->set.ssl.verifypeer = (0 != va_arg(param, long))?TRUE:FALSE;
1857 case CURLOPT_SSL_VERIFYHOST:
1859 * Enable verification of the host name in the peer certificate
1861 arg = va_arg(param, long);
1863 /* Obviously people are not reading documentation and too many thought
1864 this argument took a boolean when it wasn't and misused it. We thus ban
1865 1 as a sensible input and we warn about its use. Then we only have the
1866 2 action internally stored as TRUE. */
1869 failf(data, "CURLOPT_SSL_VERIFYHOST no longer supports 1 as value!");
1870 return CURLE_BAD_FUNCTION_ARGUMENT;
1873 data->set.ssl.verifyhost = (0 != arg)?TRUE:FALSE;
1876 /* since these two options are only possible to use on an OpenSSL-
1877 powered libcurl we #ifdef them on this condition so that libcurls
1878 built against other SSL libs will return a proper error when trying
1879 to set this option! */
1880 case CURLOPT_SSL_CTX_FUNCTION:
1882 * Set a SSL_CTX callback
1884 data->set.ssl.fsslctx = va_arg(param, curl_ssl_ctx_callback);
1886 case CURLOPT_SSL_CTX_DATA:
1888 * Set a SSL_CTX callback parameter pointer
1890 data->set.ssl.fsslctxp = va_arg(param, void *);
1892 case CURLOPT_CERTINFO:
1893 data->set.ssl.certinfo = (0 != va_arg(param, long))?TRUE:FALSE;
1896 case CURLOPT_CAINFO:
1898 * Set CA info for SSL connection. Specify file name of the CA certificate
1900 result = setstropt(&data->set.str[STRING_SSL_CAFILE],
1901 va_arg(param, char *));
1903 case CURLOPT_CAPATH:
1905 * Set CA path info for SSL connection. Specify directory name of the CA
1906 * certificates which have been prepared using openssl c_rehash utility.
1908 /* This does not work on windows. */
1909 result = setstropt(&data->set.str[STRING_SSL_CAPATH],
1910 va_arg(param, char *));
1912 case CURLOPT_CRLFILE:
1914 * Set CRL file info for SSL connection. Specify file name of the CRL
1915 * to check certificates revocation
1917 result = setstropt(&data->set.str[STRING_SSL_CRLFILE],
1918 va_arg(param, char *));
1920 case CURLOPT_ISSUERCERT:
1922 * Set Issuer certificate file
1923 * to check certificates issuer
1925 result = setstropt(&data->set.str[STRING_SSL_ISSUERCERT],
1926 va_arg(param, char *));
1928 case CURLOPT_TELNETOPTIONS:
1930 * Set a linked list of telnet options
1932 data->set.telnet_options = va_arg(param, struct curl_slist *);
1935 case CURLOPT_BUFFERSIZE:
1937 * The application kindly asks for a differently sized receive buffer.
1938 * If it seems reasonable, we'll use it.
1940 data->set.buffer_size = va_arg(param, long);
1942 if((data->set.buffer_size> (BUFSIZE -1 )) ||
1943 (data->set.buffer_size < 1))
1944 data->set.buffer_size = 0; /* huge internal default */
1948 case CURLOPT_NOSIGNAL:
1950 * The application asks not to set any signal() or alarm() handlers,
1951 * even when using a timeout.
1953 data->set.no_signal = (0 != va_arg(param, long))?TRUE:FALSE;
1958 struct Curl_share *set;
1959 set = va_arg(param, struct Curl_share *);
1961 /* disconnect from old share, if any */
1963 Curl_share_lock(data, CURL_LOCK_DATA_SHARE, CURL_LOCK_ACCESS_SINGLE);
1965 if(data->dns.hostcachetype == HCACHE_SHARED) {
1966 data->dns.hostcache = NULL;
1967 data->dns.hostcachetype = HCACHE_NONE;
1970 #if !defined(CURL_DISABLE_HTTP) && !defined(CURL_DISABLE_COOKIES)
1971 if(data->share->cookies == data->cookies)
1972 data->cookies = NULL;
1975 if(data->share->sslsession == data->state.session)
1976 data->state.session = NULL;
1978 data->share->dirty--;
1980 Curl_share_unlock(data, CURL_LOCK_DATA_SHARE);
1984 /* use new share if it set */
1988 Curl_share_lock(data, CURL_LOCK_DATA_SHARE, CURL_LOCK_ACCESS_SINGLE);
1990 data->share->dirty++;
1992 if(data->share->hostcache) {
1993 /* use shared host cache */
1994 data->dns.hostcache = data->share->hostcache;
1995 data->dns.hostcachetype = HCACHE_SHARED;
1997 #if !defined(CURL_DISABLE_HTTP) && !defined(CURL_DISABLE_COOKIES)
1998 if(data->share->cookies) {
1999 /* use shared cookie list, first free own one if any */
2001 Curl_cookie_cleanup(data->cookies);
2002 /* enable cookies since we now use a share that uses cookies! */
2003 data->cookies = data->share->cookies;
2005 #endif /* CURL_DISABLE_HTTP */
2006 if(data->share->sslsession) {
2007 data->set.ssl.max_ssl_sessions = data->share->max_ssl_sessions;
2008 data->state.session = data->share->sslsession;
2010 Curl_share_unlock(data, CURL_LOCK_DATA_SHARE);
2013 /* check for host cache not needed,
2014 * it will be done by curl_easy_perform */
2018 case CURLOPT_PRIVATE:
2020 * Set private data pointer.
2022 data->set.private_data = va_arg(param, void *);
2025 case CURLOPT_MAXFILESIZE:
2027 * Set the maximum size of a file to download.
2029 data->set.max_filesize = va_arg(param, long);
2033 case CURLOPT_USE_SSL:
2035 * Make transfers attempt to use SSL/TLS.
2037 data->set.use_ssl = (curl_usessl)va_arg(param, long);
2040 case CURLOPT_SSL_OPTIONS:
2041 arg = va_arg(param, long);
2042 data->set.ssl_enable_beast = arg&CURLSSLOPT_ALLOW_BEAST?TRUE:FALSE;
2046 case CURLOPT_FTPSSLAUTH:
2048 * Set a specific auth for FTP-SSL transfers.
2050 data->set.ftpsslauth = (curl_ftpauth)va_arg(param, long);
2053 case CURLOPT_IPRESOLVE:
2054 data->set.ipver = va_arg(param, long);
2057 case CURLOPT_MAXFILESIZE_LARGE:
2059 * Set the maximum size of a file to download.
2061 data->set.max_filesize = va_arg(param, curl_off_t);
2064 case CURLOPT_TCP_NODELAY:
2066 * Enable or disable TCP_NODELAY, which will disable/enable the Nagle
2069 data->set.tcp_nodelay = (0 != va_arg(param, long))?TRUE:FALSE;
2072 case CURLOPT_FTP_ACCOUNT:
2073 result = setstropt(&data->set.str[STRING_FTP_ACCOUNT],
2074 va_arg(param, char *));
2077 case CURLOPT_IGNORE_CONTENT_LENGTH:
2078 data->set.ignorecl = (0 != va_arg(param, long))?TRUE:FALSE;
2081 case CURLOPT_CONNECT_ONLY:
2083 * No data transfer, set up connection and let application use the socket
2085 data->set.connect_only = (0 != va_arg(param, long))?TRUE:FALSE;
2088 case CURLOPT_FTP_ALTERNATIVE_TO_USER:
2089 result = setstropt(&data->set.str[STRING_FTP_ALTERNATIVE_TO_USER],
2090 va_arg(param, char *));
2093 case CURLOPT_SOCKOPTFUNCTION:
2095 * socket callback function: called after socket() but before connect()
2097 data->set.fsockopt = va_arg(param, curl_sockopt_callback);
2100 case CURLOPT_SOCKOPTDATA:
2102 * socket callback data pointer. Might be NULL.
2104 data->set.sockopt_client = va_arg(param, void *);
2107 case CURLOPT_OPENSOCKETFUNCTION:
2109 * open/create socket callback function: called instead of socket(),
2112 data->set.fopensocket = va_arg(param, curl_opensocket_callback);
2115 case CURLOPT_OPENSOCKETDATA:
2117 * socket callback data pointer. Might be NULL.
2119 data->set.opensocket_client = va_arg(param, void *);
2122 case CURLOPT_CLOSESOCKETFUNCTION:
2124 * close socket callback function: called instead of close()
2125 * when shutting down a connection
2127 data->set.fclosesocket = va_arg(param, curl_closesocket_callback);
2130 case CURLOPT_CLOSESOCKETDATA:
2132 * socket callback data pointer. Might be NULL.
2134 data->set.closesocket_client = va_arg(param, void *);
2137 case CURLOPT_SSL_SESSIONID_CACHE:
2138 data->set.ssl.sessionid = (0 != va_arg(param, long))?TRUE:FALSE;
2142 /* we only include SSH options if explicitly built to support SSH */
2143 case CURLOPT_SSH_AUTH_TYPES:
2144 data->set.ssh_auth_types = va_arg(param, long);
2147 case CURLOPT_SSH_PUBLIC_KEYFILE:
2149 * Use this file instead of the $HOME/.ssh/id_dsa.pub file
2151 result = setstropt(&data->set.str[STRING_SSH_PUBLIC_KEY],
2152 va_arg(param, char *));
2155 case CURLOPT_SSH_PRIVATE_KEYFILE:
2157 * Use this file instead of the $HOME/.ssh/id_dsa file
2159 result = setstropt(&data->set.str[STRING_SSH_PRIVATE_KEY],
2160 va_arg(param, char *));
2162 case CURLOPT_SSH_HOST_PUBLIC_KEY_MD5:
2164 * Option to allow for the MD5 of the host public key to be checked
2165 * for validation purposes.
2167 result = setstropt(&data->set.str[STRING_SSH_HOST_PUBLIC_KEY_MD5],
2168 va_arg(param, char *));
2170 #ifdef HAVE_LIBSSH2_KNOWNHOST_API
2171 case CURLOPT_SSH_KNOWNHOSTS:
2173 * Store the file name to read known hosts from.
2175 result = setstropt(&data->set.str[STRING_SSH_KNOWNHOSTS],
2176 va_arg(param, char *));
2179 case CURLOPT_SSH_KEYFUNCTION:
2180 /* setting to NULL is fine since the ssh.c functions themselves will
2181 then rever to use the internal default */
2182 data->set.ssh_keyfunc = va_arg(param, curl_sshkeycallback);
2185 case CURLOPT_SSH_KEYDATA:
2187 * Custom client data to pass to the SSH keyfunc callback
2189 data->set.ssh_keyfunc_userp = va_arg(param, void *);
2191 #endif /* HAVE_LIBSSH2_KNOWNHOST_API */
2193 #endif /* USE_LIBSSH2 */
2195 case CURLOPT_HTTP_TRANSFER_DECODING:
2197 * disable libcurl transfer encoding is used
2199 data->set.http_te_skip = (0 == va_arg(param, long))?TRUE:FALSE;
2202 case CURLOPT_HTTP_CONTENT_DECODING:
2204 * raw data passed to the application when content encoding is used
2206 data->set.http_ce_skip = (0 == va_arg(param, long))?TRUE:FALSE;
2209 case CURLOPT_NEW_FILE_PERMS:
2211 * Uses these permissions instead of 0644
2213 data->set.new_file_perms = va_arg(param, long);
2216 case CURLOPT_NEW_DIRECTORY_PERMS:
2218 * Uses these permissions instead of 0755
2220 data->set.new_directory_perms = va_arg(param, long);
2223 case CURLOPT_ADDRESS_SCOPE:
2225 * We always get longs when passed plain numericals, but for this value we
2226 * know that an unsigned int will always hold the value so we blindly
2227 * typecast to this type
2229 data->set.scope = curlx_sltoui(va_arg(param, long));
2232 case CURLOPT_PROTOCOLS:
2233 /* set the bitmask for the protocols that are allowed to be used for the
2234 transfer, which thus helps the app which takes URLs from users or other
2235 external inputs and want to restrict what protocol(s) to deal
2236 with. Defaults to CURLPROTO_ALL. */
2237 data->set.allowed_protocols = va_arg(param, long);
2240 case CURLOPT_REDIR_PROTOCOLS:
2241 /* set the bitmask for the protocols that libcurl is allowed to follow to,
2242 as a subset of the CURLOPT_PROTOCOLS ones. That means the protocol needs
2243 to be set in both bitmasks to be allowed to get redirected to. Defaults
2244 to all protocols except FILE and SCP. */
2245 data->set.redir_protocols = va_arg(param, long);
2248 case CURLOPT_MAIL_FROM:
2249 result = setstropt(&data->set.str[STRING_MAIL_FROM],
2250 va_arg(param, char *));
2253 case CURLOPT_MAIL_AUTH:
2254 result = setstropt(&data->set.str[STRING_MAIL_AUTH],
2255 va_arg(param, char *));
2258 case CURLOPT_MAIL_RCPT:
2259 /* get a list of mail recipients */
2260 data->set.mail_rcpt = va_arg(param, struct curl_slist *);
2263 case CURLOPT_RTSP_REQUEST:
2266 * Set the RTSP request method (OPTIONS, SETUP, PLAY, etc...)
2267 * Would this be better if the RTSPREQ_* were just moved into here?
2269 long curl_rtspreq = va_arg(param, long);
2270 Curl_RtspReq rtspreq = RTSPREQ_NONE;
2271 switch(curl_rtspreq) {
2272 case CURL_RTSPREQ_OPTIONS:
2273 rtspreq = RTSPREQ_OPTIONS;
2276 case CURL_RTSPREQ_DESCRIBE:
2277 rtspreq = RTSPREQ_DESCRIBE;
2280 case CURL_RTSPREQ_ANNOUNCE:
2281 rtspreq = RTSPREQ_ANNOUNCE;
2284 case CURL_RTSPREQ_SETUP:
2285 rtspreq = RTSPREQ_SETUP;
2288 case CURL_RTSPREQ_PLAY:
2289 rtspreq = RTSPREQ_PLAY;
2292 case CURL_RTSPREQ_PAUSE:
2293 rtspreq = RTSPREQ_PAUSE;
2296 case CURL_RTSPREQ_TEARDOWN:
2297 rtspreq = RTSPREQ_TEARDOWN;
2300 case CURL_RTSPREQ_GET_PARAMETER:
2301 rtspreq = RTSPREQ_GET_PARAMETER;
2304 case CURL_RTSPREQ_SET_PARAMETER:
2305 rtspreq = RTSPREQ_SET_PARAMETER;
2308 case CURL_RTSPREQ_RECORD:
2309 rtspreq = RTSPREQ_RECORD;
2312 case CURL_RTSPREQ_RECEIVE:
2313 rtspreq = RTSPREQ_RECEIVE;
2316 rtspreq = RTSPREQ_NONE;
2319 data->set.rtspreq = rtspreq;
2324 case CURLOPT_RTSP_SESSION_ID:
2326 * Set the RTSP Session ID manually. Useful if the application is
2327 * resuming a previously established RTSP session
2329 result = setstropt(&data->set.str[STRING_RTSP_SESSION_ID],
2330 va_arg(param, char *));
2333 case CURLOPT_RTSP_STREAM_URI:
2335 * Set the Stream URI for the RTSP request. Unless the request is
2336 * for generic server options, the application will need to set this.
2338 result = setstropt(&data->set.str[STRING_RTSP_STREAM_URI],
2339 va_arg(param, char *));
2342 case CURLOPT_RTSP_TRANSPORT:
2344 * The content of the Transport: header for the RTSP request
2346 result = setstropt(&data->set.str[STRING_RTSP_TRANSPORT],
2347 va_arg(param, char *));
2350 case CURLOPT_RTSP_CLIENT_CSEQ:
2352 * Set the CSEQ number to issue for the next RTSP request. Useful if the
2353 * application is resuming a previously broken connection. The CSEQ
2354 * will increment from this new number henceforth.
2356 data->state.rtsp_next_client_CSeq = va_arg(param, long);
2359 case CURLOPT_RTSP_SERVER_CSEQ:
2360 /* Same as the above, but for server-initiated requests */
2361 data->state.rtsp_next_client_CSeq = va_arg(param, long);
2364 case CURLOPT_INTERLEAVEDATA:
2365 data->set.rtp_out = va_arg(param, void *);
2367 case CURLOPT_INTERLEAVEFUNCTION:
2368 /* Set the user defined RTP write function */
2369 data->set.fwrite_rtp = va_arg(param, curl_write_callback);
2372 case CURLOPT_WILDCARDMATCH:
2373 data->set.wildcardmatch = (0 != va_arg(param, long))?TRUE:FALSE;
2375 case CURLOPT_CHUNK_BGN_FUNCTION:
2376 data->set.chunk_bgn = va_arg(param, curl_chunk_bgn_callback);
2378 case CURLOPT_CHUNK_END_FUNCTION:
2379 data->set.chunk_end = va_arg(param, curl_chunk_end_callback);
2381 case CURLOPT_FNMATCH_FUNCTION:
2382 data->set.fnmatch = va_arg(param, curl_fnmatch_callback);
2384 case CURLOPT_CHUNK_DATA:
2385 data->wildcard.customptr = va_arg(param, void *);
2387 case CURLOPT_FNMATCH_DATA:
2388 data->set.fnmatch_data = va_arg(param, void *);
2391 case CURLOPT_TLSAUTH_USERNAME:
2392 result = setstropt(&data->set.str[STRING_TLSAUTH_USERNAME],
2393 va_arg(param, char *));
2394 if(data->set.str[STRING_TLSAUTH_USERNAME] && !data->set.ssl.authtype)
2395 data->set.ssl.authtype = CURL_TLSAUTH_SRP; /* default to SRP */
2397 case CURLOPT_TLSAUTH_PASSWORD:
2398 result = setstropt(&data->set.str[STRING_TLSAUTH_PASSWORD],
2399 va_arg(param, char *));
2400 if(data->set.str[STRING_TLSAUTH_USERNAME] && !data->set.ssl.authtype)
2401 data->set.ssl.authtype = CURL_TLSAUTH_SRP; /* default to SRP */
2403 case CURLOPT_TLSAUTH_TYPE:
2404 if(strnequal((char *)va_arg(param, char *), "SRP", strlen("SRP")))
2405 data->set.ssl.authtype = CURL_TLSAUTH_SRP;
2407 data->set.ssl.authtype = CURL_TLSAUTH_NONE;
2410 case CURLOPT_DNS_SERVERS:
2411 result = Curl_set_dns_servers(data, va_arg(param, char *));
2414 case CURLOPT_TCP_KEEPALIVE:
2415 data->set.tcp_keepalive = (0 != va_arg(param, long))?TRUE:FALSE;
2417 case CURLOPT_TCP_KEEPIDLE:
2418 data->set.tcp_keepidle = va_arg(param, long);
2420 case CURLOPT_TCP_KEEPINTVL:
2421 data->set.tcp_keepintvl = va_arg(param, long);
2425 /* unknown tag and its companion, just ignore: */
2426 result = CURLE_UNKNOWN_OPTION;
2433 static void conn_free(struct connectdata *conn)
2438 /* possible left-overs from the async name resolvers */
2439 Curl_resolver_cancel(conn);
2441 /* close the SSL stuff before we close any sockets since they will/may
2442 write to the sockets */
2443 Curl_ssl_close(conn, FIRSTSOCKET);
2444 Curl_ssl_close(conn, SECONDARYSOCKET);
2446 /* close possibly still open sockets */
2447 if(CURL_SOCKET_BAD != conn->sock[SECONDARYSOCKET])
2448 Curl_closesocket(conn, conn->sock[SECONDARYSOCKET]);
2449 if(CURL_SOCKET_BAD != conn->sock[FIRSTSOCKET])
2450 Curl_closesocket(conn, conn->sock[FIRSTSOCKET]);
2452 #if defined(USE_NTLM) && defined(NTLM_WB_ENABLED)
2453 Curl_ntlm_wb_cleanup(conn);
2456 Curl_safefree(conn->user);
2457 Curl_safefree(conn->passwd);
2458 Curl_safefree(conn->options);
2459 Curl_safefree(conn->proxyuser);
2460 Curl_safefree(conn->proxypasswd);
2461 Curl_safefree(conn->allocptr.proxyuserpwd);
2462 Curl_safefree(conn->allocptr.uagent);
2463 Curl_safefree(conn->allocptr.userpwd);
2464 Curl_safefree(conn->allocptr.accept_encoding);
2465 Curl_safefree(conn->allocptr.te);
2466 Curl_safefree(conn->allocptr.rangeline);
2467 Curl_safefree(conn->allocptr.ref);
2468 Curl_safefree(conn->allocptr.host);
2469 Curl_safefree(conn->allocptr.cookiehost);
2470 Curl_safefree(conn->allocptr.rtsp_transport);
2471 Curl_safefree(conn->trailer);
2472 Curl_safefree(conn->host.rawalloc); /* host name buffer */
2473 Curl_safefree(conn->proxy.rawalloc); /* proxy name buffer */
2474 Curl_safefree(conn->master_buffer);
2476 Curl_llist_destroy(conn->send_pipe, NULL);
2477 Curl_llist_destroy(conn->recv_pipe, NULL);
2479 conn->send_pipe = NULL;
2480 conn->recv_pipe = NULL;
2482 Curl_safefree(conn->localdev);
2483 Curl_free_ssl_config(&conn->ssl_config);
2485 free(conn); /* free all the connection oriented data */
2488 CURLcode Curl_disconnect(struct connectdata *conn, bool dead_connection)
2490 struct SessionHandle *data;
2492 return CURLE_OK; /* this is closed and fine already */
2496 DEBUGF(fprintf(stderr, "DISCONNECT without easy handle, ignoring\n"));
2500 if(conn->dns_entry != NULL) {
2501 Curl_resolv_unlock(data, conn->dns_entry);
2502 conn->dns_entry = NULL;
2505 Curl_hostcache_prune(data); /* kill old DNS cache entries */
2508 int has_host_ntlm = (conn->ntlm.state != NTLMSTATE_NONE);
2509 int has_proxy_ntlm = (conn->proxyntlm.state != NTLMSTATE_NONE);
2511 /* Authentication data is a mix of connection-related and sessionhandle-
2512 related stuff. NTLM is connection-related so when we close the shop
2516 data->state.authhost.done = FALSE;
2517 data->state.authhost.picked =
2518 data->state.authhost.want;
2521 if(has_proxy_ntlm) {
2522 data->state.authproxy.done = FALSE;
2523 data->state.authproxy.picked =
2524 data->state.authproxy.want;
2527 if(has_host_ntlm || has_proxy_ntlm)
2528 data->state.authproblem = FALSE;
2531 /* Cleanup NTLM connection-related data */
2532 Curl_http_ntlm_cleanup(conn);
2534 /* Cleanup possible redirect junk */
2535 if(data->req.newurl) {
2536 free(data->req.newurl);
2537 data->req.newurl = NULL;
2540 if(conn->handler->disconnect)
2541 /* This is set if protocol-specific cleanups should be made */
2542 conn->handler->disconnect(conn, dead_connection);
2544 /* unlink ourselves! */
2545 infof(data, "Closing connection %d\n", conn->connection_id);
2546 Curl_conncache_remove_conn(data->state.conn_cache, conn);
2548 #if defined(USE_LIBIDN)
2549 if(conn->host.encalloc)
2550 idn_free(conn->host.encalloc); /* encoded host name buffer, must be freed
2551 with idn_free() since this was allocated
2553 if(conn->proxy.encalloc)
2554 idn_free(conn->proxy.encalloc); /* encoded proxy name buffer, must be
2555 freed with idn_free() since this was
2556 allocated by libidn */
2557 #elif defined(USE_WIN32_IDN)
2558 free(conn->host.encalloc); /* encoded host name buffer, must be freed with
2559 idn_free() since this was allocated by
2560 curl_win32_idn_to_ascii */
2561 if(conn->proxy.encalloc)
2562 free(conn->proxy.encalloc); /* encoded proxy name buffer, must be freed
2563 with idn_free() since this was allocated by
2564 curl_win32_idn_to_ascii */
2567 Curl_ssl_close(conn, FIRSTSOCKET);
2569 /* Indicate to all handles on the pipe that we're dead */
2570 if(Curl_multi_pipeline_enabled(data->multi)) {
2571 signalPipeClose(conn->send_pipe, TRUE);
2572 signalPipeClose(conn->recv_pipe, TRUE);
2576 data->state.current_conn = NULL;
2577 Curl_speedinit(data);
2583 * This function should return TRUE if the socket is to be assumed to
2584 * be dead. Most commonly this happens when the server has closed the
2585 * connection due to inactivity.
2587 static bool SocketIsDead(curl_socket_t sock)
2590 bool ret_val = TRUE;
2592 sval = Curl_socket_ready(sock, CURL_SOCKET_BAD, 0);
2600 static bool IsPipeliningPossible(const struct SessionHandle *handle,
2601 const struct connectdata *conn)
2603 if((conn->handler->protocol & CURLPROTO_HTTP) &&
2604 Curl_multi_pipeline_enabled(handle->multi) &&
2605 (handle->set.httpreq == HTTPREQ_GET ||
2606 handle->set.httpreq == HTTPREQ_HEAD) &&
2607 handle->set.httpversion != CURL_HTTP_VERSION_1_0)
2613 bool Curl_isPipeliningEnabled(const struct SessionHandle *handle)
2615 return Curl_multi_pipeline_enabled(handle->multi);
2618 CURLcode Curl_addHandleToPipeline(struct SessionHandle *data,
2619 struct curl_llist *pipeline)
2621 if(!Curl_llist_insert_next(pipeline, pipeline->tail, data))
2622 return CURLE_OUT_OF_MEMORY;
2623 infof(data, "Curl_addHandleToPipeline: length: %d\n", pipeline->size);
2627 int Curl_removeHandleFromPipeline(struct SessionHandle *handle,
2628 struct curl_llist *pipeline)
2630 struct curl_llist_element *curr;
2632 curr = pipeline->head;
2634 if(curr->ptr == handle) {
2635 Curl_llist_remove(pipeline, curr, NULL);
2636 return 1; /* we removed a handle */
2644 #if 0 /* this code is saved here as it is useful for debugging purposes */
2645 static void Curl_printPipeline(struct curl_llist *pipeline)
2647 struct curl_llist_element *curr;
2649 curr = pipeline->head;
2651 struct SessionHandle *data = (struct SessionHandle *) curr->ptr;
2652 infof(data, "Handle in pipeline: %s\n", data->state.path);
2658 static struct SessionHandle* gethandleathead(struct curl_llist *pipeline)
2660 struct curl_llist_element *curr = pipeline->head;
2662 return (struct SessionHandle *) curr->ptr;
2668 /* remove the specified connection from all (possible) pipelines and related
2670 void Curl_getoff_all_pipelines(struct SessionHandle *data,
2671 struct connectdata *conn)
2673 bool recv_head = (conn->readchannel_inuse &&
2674 (gethandleathead(conn->recv_pipe) == data)) ? TRUE : FALSE;
2676 bool send_head = (conn->writechannel_inuse &&
2677 (gethandleathead(conn->send_pipe) == data)) ? TRUE : FALSE;
2679 if(Curl_removeHandleFromPipeline(data, conn->recv_pipe) && recv_head)
2680 conn->readchannel_inuse = FALSE;
2681 if(Curl_removeHandleFromPipeline(data, conn->send_pipe) && send_head)
2682 conn->writechannel_inuse = FALSE;
2685 static void signalPipeClose(struct curl_llist *pipeline, bool pipe_broke)
2687 struct curl_llist_element *curr;
2692 curr = pipeline->head;
2694 struct curl_llist_element *next = curr->next;
2695 struct SessionHandle *data = (struct SessionHandle *) curr->ptr;
2697 #ifdef DEBUGBUILD /* debug-only code */
2698 if(data->magic != CURLEASY_MAGIC_NUMBER) {
2700 infof(data, "signalPipeClose() found BAAD easy handle\n");
2705 data->state.pipe_broke = TRUE;
2706 Curl_multi_handlePipeBreak(data);
2707 Curl_llist_remove(pipeline, curr, NULL);
2713 * This function finds the connection in the connection
2714 * cache that has been unused for the longest time.
2716 * Returns the pointer to the oldest idle connection, or NULL if none was
2719 static struct connectdata *
2720 find_oldest_idle_connection(struct SessionHandle *data)
2722 struct conncache *bc = data->state.conn_cache;
2723 struct curl_hash_iterator iter;
2724 struct curl_llist_element *curr;
2725 struct curl_hash_element *he;
2729 struct connectdata *conn_candidate = NULL;
2730 struct connectbundle *bundle;
2734 Curl_hash_start_iterate(bc->hash, &iter);
2736 he = Curl_hash_next_element(&iter);
2738 struct connectdata *conn;
2742 curr = bundle->conn_list->head;
2747 /* Set higher score for the age passed since the connection was used */
2748 score = Curl_tvdiff(now, conn->now);
2750 if(score > highscore) {
2752 conn_candidate = conn;
2758 he = Curl_hash_next_element(&iter);
2761 return conn_candidate;
2765 * This function finds the connection in the connection
2766 * bundle that has been unused for the longest time.
2768 * Returns the pointer to the oldest idle connection, or NULL if none was
2771 static struct connectdata *
2772 find_oldest_idle_connection_in_bundle(struct SessionHandle *data,
2773 struct connectbundle *bundle)
2775 struct curl_llist_element *curr;
2779 struct connectdata *conn_candidate = NULL;
2780 struct connectdata *conn;
2786 curr = bundle->conn_list->head;
2791 /* Set higher score for the age passed since the connection was used */
2792 score = Curl_tvdiff(now, conn->now);
2794 if(score > highscore) {
2796 conn_candidate = conn;
2802 return conn_candidate;
2806 * Given one filled in connection struct (named needle), this function should
2807 * detect if there already is one that has all the significant details
2808 * exactly the same and thus should be used instead.
2810 * If there is a match, this function returns TRUE - and has marked the
2811 * connection as 'in-use'. It must later be called with ConnectionDone() to
2812 * return back to 'idle' (unused) state.
2814 * The force_reuse flag is set if the connection must be used, even if
2815 * the pipelining strategy wants to open a new connection instead of reusing.
2818 ConnectionExists(struct SessionHandle *data,
2819 struct connectdata *needle,
2820 struct connectdata **usethis,
2823 struct connectdata *check;
2824 struct connectdata *chosen = 0;
2825 bool canPipeline = IsPipeliningPossible(data, needle);
2826 bool wantNTLM = (data->state.authhost.want==CURLAUTH_NTLM) ||
2827 (data->state.authhost.want==CURLAUTH_NTLM_WB) ? TRUE : FALSE;
2828 struct connectbundle *bundle;
2830 *force_reuse = FALSE;
2832 /* We can't pipe if the site is blacklisted */
2833 if(canPipeline && Curl_pipeline_site_blacklisted(data, needle)) {
2834 canPipeline = FALSE;
2837 /* Look up the bundle with all the connections to this
2839 bundle = Curl_conncache_find_bundle(data->state.conn_cache,
2842 size_t max_pipe_len = Curl_multi_max_pipeline_length(data->multi);
2843 size_t best_pipe_len = max_pipe_len;
2844 struct curl_llist_element *curr;
2846 infof(data, "Found bundle for host %s: %p\n", needle->host.name, bundle);
2848 /* We can't pipe if we don't know anything about the server */
2849 if(canPipeline && !bundle->server_supports_pipelining) {
2850 infof(data, "Server doesn't support pipelining\n");
2851 canPipeline = FALSE;
2854 curr = bundle->conn_list->head;
2857 bool credentialsMatch = FALSE;
2861 * Note that if we use a HTTP proxy, we check connections to that
2862 * proxy and not to the actual remote server.
2867 pipeLen = check->send_pipe->size + check->recv_pipe->size;
2869 if(!pipeLen && !check->inuse) {
2870 /* The check for a dead socket makes sense only if there are no
2871 handles in pipeline and the connection isn't already marked in
2874 if(check->handler->protocol & CURLPROTO_RTSP)
2875 /* RTSP is a special case due to RTP interleaving */
2876 dead = Curl_rtsp_connisdead(check);
2878 dead = SocketIsDead(check->sock[FIRSTSOCKET]);
2882 infof(data, "Connection %d seems to be dead!\n",
2883 check->connection_id);
2885 /* disconnect resources */
2886 Curl_disconnect(check, /* dead_connection */ TRUE);
2892 /* Make sure the pipe has only GET requests */
2893 struct SessionHandle* sh = gethandleathead(check->send_pipe);
2894 struct SessionHandle* rh = gethandleathead(check->recv_pipe);
2896 if(!IsPipeliningPossible(sh, check))
2900 if(!IsPipeliningPossible(rh, check))
2906 /* can only happen within multi handles, and means that another easy
2907 handle is using this connection */
2911 if(Curl_resolver_asynch()) {
2912 /* ip_addr_str[0] is NUL only if the resolving of the name hasn't
2913 completed yet and until then we don't re-use this connection */
2914 if(!check->ip_addr_str[0]) {
2916 "Connection #%ld is still name resolving, can't reuse\n",
2917 check->connection_id);
2922 if((check->sock[FIRSTSOCKET] == CURL_SOCKET_BAD) ||
2923 check->bits.close) {
2924 /* Don't pick a connection that hasn't connected yet or that is going
2926 infof(data, "Connection #%ld isn't open enough, can't reuse\n",
2927 check->connection_id);
2929 if(check->recv_pipe->size > 0) {
2931 "BAD! Unconnected #%ld has a non-empty recv pipeline!\n",
2932 check->connection_id);
2939 if((needle->handler->flags&PROTOPT_SSL) !=
2940 (check->handler->flags&PROTOPT_SSL))
2941 /* don't do mixed SSL and non-SSL connections */
2942 if(!(needle->handler->protocol & check->handler->protocol))
2943 /* except protocols that have been upgraded via TLS */
2946 if(needle->handler->flags&PROTOPT_SSL) {
2947 if((data->set.ssl.verifypeer != check->verifypeer) ||
2948 (data->set.ssl.verifyhost != check->verifyhost))
2952 if(needle->bits.proxy != check->bits.proxy)
2953 /* don't do mixed proxy and non-proxy connections */
2956 if(!canPipeline && check->inuse)
2957 /* this request can't be pipelined but the checked connection is
2958 already in use so we skip it */
2961 if(needle->localdev || needle->localport) {
2962 /* If we are bound to a specific local end (IP+port), we must not
2963 re-use a random other one, although if we didn't ask for a
2964 particular one we can reuse one that was bound.
2966 This comparison is a bit rough and too strict. Since the input
2967 parameters can be specified in numerous ways and still end up the
2968 same it would take a lot of processing to make it really accurate.
2969 Instead, this matching will assume that re-uses of bound connections
2970 will most likely also re-use the exact same binding parameters and
2971 missing out a few edge cases shouldn't hurt anyone very much.
2973 if((check->localport != needle->localport) ||
2974 (check->localportrange != needle->localportrange) ||
2976 !needle->localdev ||
2977 strcmp(check->localdev, needle->localdev))
2981 if((needle->handler->protocol & CURLPROTO_FTP) ||
2982 ((needle->handler->protocol & CURLPROTO_HTTP) && wantNTLM)) {
2983 /* This is FTP or HTTP+NTLM, verify that we're using the same name
2984 and password as well */
2985 if(!strequal(needle->user, check->user) ||
2986 !strequal(needle->passwd, check->passwd)) {
2987 /* one of them was different */
2990 credentialsMatch = TRUE;
2993 if(!needle->bits.httpproxy || needle->handler->flags&PROTOPT_SSL ||
2994 (needle->bits.httpproxy && check->bits.httpproxy &&
2995 needle->bits.tunnel_proxy && check->bits.tunnel_proxy &&
2996 Curl_raw_equal(needle->proxy.name, check->proxy.name) &&
2997 (needle->port == check->port))) {
2998 /* The requested connection does not use a HTTP proxy or it uses SSL or
2999 it is a non-SSL protocol tunneled over the same http proxy name and
3000 port number or it is a non-SSL protocol which is allowed to be
3003 if((Curl_raw_equal(needle->handler->scheme, check->handler->scheme) ||
3004 needle->handler->protocol & check->handler->protocol) &&
3005 Curl_raw_equal(needle->host.name, check->host.name) &&
3006 needle->remote_port == check->remote_port) {
3007 if(needle->handler->flags & PROTOPT_SSL) {
3008 /* This is a SSL connection so verify that we're using the same
3009 SSL options as well */
3010 if(!Curl_ssl_config_matches(&needle->ssl_config,
3011 &check->ssl_config)) {
3013 "Connection #%ld has different SSL parameters, "
3015 check->connection_id));
3018 else if(check->ssl[FIRSTSOCKET].state != ssl_connection_complete) {
3020 "Connection #%ld has not started SSL connect, "
3022 check->connection_id));
3029 else { /* The requested needle connection is using a proxy,
3030 is the checked one using the same host, port and type? */
3031 if(check->bits.proxy &&
3032 (needle->proxytype == check->proxytype) &&
3033 (needle->bits.tunnel_proxy == check->bits.tunnel_proxy) &&
3034 Curl_raw_equal(needle->proxy.name, check->proxy.name) &&
3035 needle->port == check->port) {
3036 /* This is the same proxy connection, use it! */
3042 /* If we are looking for an NTLM connection, check if this is already
3043 authenticating with the right credentials. If not, keep looking so
3044 that we can reuse NTLM connections if possible. (Especially we
3045 must not reuse the same connection if partway through
3048 if(credentialsMatch && check->ntlm.state != NTLMSTATE_NONE) {
3051 /* We must use this connection, no other */
3052 *force_reuse = TRUE;
3060 /* We can pipeline if we want to. Let's continue looking for
3061 the optimal connection to use, i.e the shortest pipe that is not
3065 /* We have the optimal connection. Let's stop looking. */
3070 /* We can't use the connection if the pipe is full */
3071 if(pipeLen >= max_pipe_len)
3074 /* We can't use the connection if the pipe is penalized */
3075 if(Curl_pipeline_penalized(data, check))
3078 if(pipeLen < best_pipe_len) {
3079 /* This connection has a shorter pipe so far. We'll pick this
3080 and continue searching */
3082 best_pipe_len = pipeLen;
3087 /* We have found a connection. Let's stop searching. */
3097 return TRUE; /* yes, we found one to use! */
3100 return FALSE; /* no matching connecting exists */
3103 /* Mark the connection as 'idle', or close it if the cache is full.
3104 Returns TRUE if the connection is kept, or FALSE if it was closed. */
3106 ConnectionDone(struct SessionHandle *data, struct connectdata *conn)
3108 /* data->multi->maxconnects can be negative, deal with it. */
3109 size_t maxconnects =
3110 (data->multi->maxconnects < 0) ? 0 : data->multi->maxconnects;
3111 struct connectdata *conn_candidate = NULL;
3113 /* Mark the current connection as 'unused' */
3114 conn->inuse = FALSE;
3116 if(maxconnects > 0 &&
3117 data->state.conn_cache->num_connections > maxconnects) {
3118 infof(data, "Connection cache is full, closing the oldest one.\n");
3120 conn_candidate = find_oldest_idle_connection(data);
3122 if(conn_candidate) {
3123 /* Set the connection's owner correctly */
3124 conn_candidate->data = data;
3126 /* the winner gets the honour of being disconnected */
3127 (void)Curl_disconnect(conn_candidate, /* dead_connection */ FALSE);
3131 return (conn_candidate == conn) ? FALSE : TRUE;
3135 * The given input connection struct pointer is to be stored in the connection
3136 * cache. If the cache is already full, least interesting existing connection
3137 * (if any) gets closed.
3139 * The given connection should be unique. That must've been checked prior to
3142 static CURLcode ConnectionStore(struct SessionHandle *data,
3143 struct connectdata *conn)
3145 static int connection_id_counter = 0;
3149 /* Assign a number to the connection for easier tracking in the log
3151 conn->connection_id = connection_id_counter++;
3153 result = Curl_conncache_add_conn(data->state.conn_cache, conn);
3154 if(result != CURLE_OK)
3155 conn->connection_id = -1;
3160 /* after a TCP connection to the proxy has been verified, this function does
3161 the next magic step.
3163 Note: this function's sub-functions call failf()
3166 CURLcode Curl_connected_proxy(struct connectdata *conn)
3168 if(!conn->bits.proxy)
3171 switch(conn->proxytype) {
3172 #ifndef CURL_DISABLE_PROXY
3173 case CURLPROXY_SOCKS5:
3174 case CURLPROXY_SOCKS5_HOSTNAME:
3175 return Curl_SOCKS5(conn->proxyuser, conn->proxypasswd,
3176 conn->host.name, conn->remote_port,
3179 case CURLPROXY_SOCKS4:
3180 return Curl_SOCKS4(conn->proxyuser, conn->host.name,
3181 conn->remote_port, FIRSTSOCKET, conn, FALSE);
3183 case CURLPROXY_SOCKS4A:
3184 return Curl_SOCKS4(conn->proxyuser, conn->host.name,
3185 conn->remote_port, FIRSTSOCKET, conn, TRUE);
3187 #endif /* CURL_DISABLE_PROXY */
3188 case CURLPROXY_HTTP:
3189 case CURLPROXY_HTTP_1_0:
3190 /* do nothing here. handled later. */
3194 } /* switch proxytype */
3199 static CURLcode ConnectPlease(struct SessionHandle *data,
3200 struct connectdata *conn,
3204 Curl_addrinfo *addr;
3205 #ifndef CURL_DISABLE_VERBOSE_STRINGS
3206 char *hostname = conn->bits.proxy?conn->proxy.name:conn->host.name;
3208 infof(data, "About to connect() to %s%s port %ld (#%ld)\n",
3209 conn->bits.proxy?"proxy ":"",
3210 hostname, conn->port, conn->connection_id);
3215 /*************************************************************
3216 * Connect to server/proxy
3217 *************************************************************/
3218 result= Curl_connecthost(conn,
3220 &conn->sock[FIRSTSOCKET],
3223 if(CURLE_OK == result) {
3224 /* All is cool, we store the current information */
3225 conn->ip_addr = addr;
3228 result = Curl_connected_proxy(conn);
3230 conn->bits.tcpconnect[FIRSTSOCKET] = TRUE;
3231 Curl_pgrsTime(data, TIMER_CONNECT); /* connect done */
3237 *connected = FALSE; /* mark it as not connected */
3243 * verboseconnect() displays verbose information after a connect
3245 #ifndef CURL_DISABLE_VERBOSE_STRINGS
3246 void Curl_verboseconnect(struct connectdata *conn)
3248 if(conn->data->set.verbose)
3249 infof(conn->data, "Connected to %s (%s) port %ld (#%ld)\n",
3250 conn->bits.proxy ? conn->proxy.dispname : conn->host.dispname,
3251 conn->ip_addr_str, conn->port, conn->connection_id);
3255 int Curl_protocol_getsock(struct connectdata *conn,
3256 curl_socket_t *socks,
3259 if(conn->handler->proto_getsock)
3260 return conn->handler->proto_getsock(conn, socks, numsocks);
3261 return GETSOCK_BLANK;
3264 int Curl_doing_getsock(struct connectdata *conn,
3265 curl_socket_t *socks,
3268 if(conn && conn->handler->doing_getsock)
3269 return conn->handler->doing_getsock(conn, socks, numsocks);
3270 return GETSOCK_BLANK;
3274 * We are doing protocol-specific connecting and this is being called over and
3275 * over from the multi interface until the connection phase is done on
3279 CURLcode Curl_protocol_connecting(struct connectdata *conn,
3282 CURLcode result=CURLE_OK;
3284 if(conn && conn->handler->connecting) {
3286 result = conn->handler->connecting(conn, done);
3295 * We are DOING this is being called over and over from the multi interface
3296 * until the DOING phase is done on protocol layer.
3299 CURLcode Curl_protocol_doing(struct connectdata *conn, bool *done)
3301 CURLcode result=CURLE_OK;
3303 if(conn && conn->handler->doing) {
3305 result = conn->handler->doing(conn, done);
3314 * We have discovered that the TCP connection has been successful, we can now
3315 * proceed with some action.
3318 CURLcode Curl_protocol_connect(struct connectdata *conn,
3319 bool *protocol_done)
3321 CURLcode result=CURLE_OK;
3323 *protocol_done = FALSE;
3325 if(conn->bits.tcpconnect[FIRSTSOCKET] && conn->bits.protoconnstart) {
3326 /* We already are connected, get back. This may happen when the connect
3327 worked fine in the first call, like when we connect to a local server
3328 or proxy. Note that we don't know if the protocol is actually done.
3330 Unless this protocol doesn't have any protocol-connect callback, as
3331 then we know we're done. */
3332 if(!conn->handler->connecting)
3333 *protocol_done = TRUE;
3338 if(!conn->bits.protoconnstart) {
3340 result = Curl_proxy_connect(conn);
3344 if(conn->bits.tunnel_proxy && conn->bits.httpproxy &&
3345 (conn->tunnel_state[FIRSTSOCKET] != TUNNEL_COMPLETE))
3346 /* when using an HTTP tunnel proxy, await complete tunnel establishment
3347 before proceeding further. Return CURLE_OK so we'll be called again */
3350 if(conn->handler->connect_it) {
3351 /* is there a protocol-specific connect() procedure? */
3353 /* Call the protocol-specific connect function */
3354 result = conn->handler->connect_it(conn, protocol_done);
3357 *protocol_done = TRUE;
3359 /* it has started, possibly even completed but that knowledge isn't stored
3362 conn->bits.protoconnstart = TRUE;
3365 return result; /* pass back status */
3369 * Helpers for IDNA convertions.
3371 static bool is_ASCII_name(const char *hostname)
3373 const unsigned char *ch = (const unsigned char*)hostname;
3384 * Check if characters in hostname is allowed in Top Level Domain.
3386 static bool tld_check_name(struct SessionHandle *data,
3387 const char *ace_hostname)
3390 char *uc_name = NULL;
3392 #ifndef CURL_DISABLE_VERBOSE_STRINGS
3393 const char *tld_errmsg = "<no msg>";
3398 /* Convert (and downcase) ACE-name back into locale's character set */
3399 rc = idna_to_unicode_lzlz(ace_hostname, &uc_name, 0);
3400 if(rc != IDNA_SUCCESS)
3403 rc = tld_check_lz(uc_name, &err_pos, NULL);
3404 #ifndef CURL_DISABLE_VERBOSE_STRINGS
3405 #ifdef HAVE_TLD_STRERROR
3406 if(rc != TLD_SUCCESS)
3407 tld_errmsg = tld_strerror((Tld_rc)rc);
3409 if(rc == TLD_INVALID)
3410 infof(data, "WARNING: %s; pos %u = `%c'/0x%02X\n",
3411 tld_errmsg, err_pos, uc_name[err_pos],
3412 uc_name[err_pos] & 255);
3413 else if(rc != TLD_SUCCESS)
3414 infof(data, "WARNING: TLD check for %s failed; %s\n",
3415 uc_name, tld_errmsg);
3416 #endif /* CURL_DISABLE_VERBOSE_STRINGS */
3419 if(rc != TLD_SUCCESS)
3427 * Perform any necessary IDN conversion of hostname
3429 static void fix_hostname(struct SessionHandle *data,
3430 struct connectdata *conn, struct hostname *host)
3435 #elif defined(CURL_DISABLE_VERBOSE_STRINGS)
3439 /* set the name we use to display the host name */
3440 host->dispname = host->name;
3441 if(!is_ASCII_name(host->name)) {
3443 /*************************************************************
3444 * Check name for non-ASCII and convert hostname to ACE form.
3445 *************************************************************/
3446 if(stringprep_check_version(LIBIDN_REQUIRED_VERSION)) {
3447 char *ace_hostname = NULL;
3448 int rc = idna_to_ascii_lz(host->name, &ace_hostname, 0);
3449 infof (data, "Input domain encoded as `%s'\n",
3450 stringprep_locale_charset ());
3451 if(rc != IDNA_SUCCESS)
3452 infof(data, "Failed to convert %s to ACE; %s\n",
3453 host->name, Curl_idn_strerror(conn,rc));
3455 /* tld_check_name() displays a warning if the host name contains
3456 "illegal" characters for this TLD */
3457 (void)tld_check_name(data, ace_hostname);
3459 host->encalloc = ace_hostname;
3460 /* change the name pointer to point to the encoded hostname */
3461 host->name = host->encalloc;
3464 #elif defined(USE_WIN32_IDN)
3465 /*************************************************************
3466 * Check name for non-ASCII and convert hostname to ACE form.
3467 *************************************************************/
3468 char *ace_hostname = NULL;
3469 int rc = curl_win32_idn_to_ascii(host->name, &ace_hostname);
3471 infof(data, "Failed to convert %s to ACE;\n",
3474 host->encalloc = ace_hostname;
3475 /* change the name pointer to point to the encoded hostname */
3476 host->name = host->encalloc;
3479 infof(data, "IDN support not present, can't parse Unicode domains\n");
3484 static void llist_dtor(void *user, void *element)
3492 * Allocate and initialize a new connectdata object.
3494 static struct connectdata *allocate_conn(struct SessionHandle *data)
3496 struct connectdata *conn = calloc(1, sizeof(struct connectdata));
3500 conn->handler = &Curl_handler_dummy; /* Be sure we have a handler defined
3501 already from start to avoid NULL
3502 situations and checks */
3504 /* and we setup a few fields in case we end up actually using this struct */
3506 conn->sock[FIRSTSOCKET] = CURL_SOCKET_BAD; /* no file descriptor */
3507 conn->sock[SECONDARYSOCKET] = CURL_SOCKET_BAD; /* no file descriptor */
3508 conn->connection_id = -1; /* no ID */
3509 conn->port = -1; /* unknown at this point */
3511 /* Default protocol-independent behavior doesn't support persistent
3512 connections, so we set this to force-close. Protocols that support
3513 this need to set this to FALSE in their "curl_do" functions. */
3514 conn->bits.close = TRUE;
3516 /* Store creation time to help future close decision making */
3517 conn->created = Curl_tvnow();
3519 conn->data = data; /* Setup the association between this connection
3520 and the SessionHandle */
3522 conn->proxytype = data->set.proxytype; /* type */
3524 #ifdef CURL_DISABLE_PROXY
3526 conn->bits.proxy = FALSE;
3527 conn->bits.httpproxy = FALSE;
3528 conn->bits.proxy_user_passwd = FALSE;
3529 conn->bits.tunnel_proxy = FALSE;
3531 #else /* CURL_DISABLE_PROXY */
3533 /* note that these two proxy bits are now just on what looks to be
3534 requested, they may be altered down the road */
3535 conn->bits.proxy = (data->set.str[STRING_PROXY] &&
3536 *data->set.str[STRING_PROXY])?TRUE:FALSE;
3537 conn->bits.httpproxy = (conn->bits.proxy &&
3538 (conn->proxytype == CURLPROXY_HTTP ||
3539 conn->proxytype == CURLPROXY_HTTP_1_0))?TRUE:FALSE;
3540 conn->bits.proxy_user_passwd =
3541 (NULL != data->set.str[STRING_PROXYUSERNAME])?TRUE:FALSE;
3542 conn->bits.tunnel_proxy = data->set.tunnel_thru_httpproxy;
3544 #endif /* CURL_DISABLE_PROXY */
3546 conn->bits.user_passwd = (NULL != data->set.str[STRING_USERNAME])?TRUE:FALSE;
3547 conn->bits.ftp_use_epsv = data->set.ftp_use_epsv;
3548 conn->bits.ftp_use_eprt = data->set.ftp_use_eprt;
3550 conn->verifypeer = data->set.ssl.verifypeer;
3551 conn->verifyhost = data->set.ssl.verifyhost;
3553 conn->ip_version = data->set.ipver;
3555 #if defined(USE_NTLM) && defined(NTLM_WB_ENABLED)
3556 conn->ntlm_auth_hlpr_socket = CURL_SOCKET_BAD;
3557 conn->ntlm_auth_hlpr_pid = 0;
3558 conn->challenge_header = NULL;
3559 conn->response_header = NULL;
3562 if(Curl_multi_pipeline_enabled(data->multi) &&
3563 !conn->master_buffer) {
3564 /* Allocate master_buffer to be used for pipelining */
3565 conn->master_buffer = calloc(BUFSIZE, sizeof (char));
3566 if(!conn->master_buffer)
3570 /* Initialize the pipeline lists */
3571 conn->send_pipe = Curl_llist_alloc((curl_llist_dtor) llist_dtor);
3572 conn->recv_pipe = Curl_llist_alloc((curl_llist_dtor) llist_dtor);
3573 if(!conn->send_pipe || !conn->recv_pipe)
3576 #if defined(HAVE_KRB4) || defined(HAVE_GSSAPI)
3577 conn->data_prot = PROT_CLEAR;
3580 /* Store the local bind parameters that will be used for this connection */
3581 if(data->set.str[STRING_DEVICE]) {
3582 conn->localdev = strdup(data->set.str[STRING_DEVICE]);
3586 conn->localportrange = data->set.localportrange;
3587 conn->localport = data->set.localport;
3589 /* the close socket stuff needs to be copied to the connection struct as
3590 it may live on without (this specific) SessionHandle */
3591 conn->fclosesocket = data->set.fclosesocket;
3592 conn->closesocket_client = data->set.closesocket_client;
3597 Curl_llist_destroy(conn->send_pipe, NULL);
3598 Curl_llist_destroy(conn->recv_pipe, NULL);
3600 conn->send_pipe = NULL;
3601 conn->recv_pipe = NULL;
3603 Curl_safefree(conn->master_buffer);
3604 Curl_safefree(conn->localdev);
3605 Curl_safefree(conn);
3609 static CURLcode findprotocol(struct SessionHandle *data,
3610 struct connectdata *conn,
3611 const char *protostr)
3613 const struct Curl_handler * const *pp;
3614 const struct Curl_handler *p;
3616 /* Scan protocol handler table and match against 'protostr' to set a few
3617 variables based on the URL. Now that the handler may be changed later
3618 when the protocol specific setup function is called. */
3619 for(pp = protocols; (p = *pp) != NULL; pp++) {
3620 if(Curl_raw_equal(p->scheme, protostr)) {
3621 /* Protocol found in table. Check if allowed */
3622 if(!(data->set.allowed_protocols & p->protocol))
3626 /* it is allowed for "normal" request, now do an extra check if this is
3627 the result of a redirect */
3628 if(data->state.this_is_a_follow &&
3629 !(data->set.redir_protocols & p->protocol))
3633 /* Perform setup complement if some. */
3634 conn->handler = conn->given = p;
3636 /* 'port' and 'remote_port' are set in setup_connection_internals() */
3642 /* The protocol was not found in the table, but we don't have to assign it
3643 to anything since it is already assigned to a dummy-struct in the
3644 create_conn() function when the connectdata struct is allocated. */
3645 failf(data, "Protocol %s not supported or disabled in " LIBCURL_NAME,
3648 return CURLE_UNSUPPORTED_PROTOCOL;
3652 * Parse URL and fill in the relevant members of the connection struct.
3654 static CURLcode parseurlandfillconn(struct SessionHandle *data,
3655 struct connectdata *conn,
3657 char *user, char *passwd, char *options)
3661 char *path = data->state.path;
3667 bool fix_slash = FALSE;
3669 *prot_missing = FALSE;
3671 /*************************************************************
3674 * We need to parse the url even when using the proxy, because we will need
3675 * the hostname and port in case we are trying to SSL connect through the
3676 * proxy -- and we don't know if we will need to use SSL until we parse the
3678 ************************************************************/
3679 if((2 == sscanf(data->change.url, "%15[^:]:%[^\n]",
3681 Curl_raw_equal(protobuf, "file")) {
3682 if(path[0] == '/' && path[1] == '/') {
3683 /* Allow omitted hostname (e.g. file:/<path>). This is not strictly
3684 * speaking a valid file: URL by RFC 1738, but treating file:/<path> as
3685 * file://localhost/<path> is similar to how other schemes treat missing
3686 * hostnames. See RFC 1808. */
3688 /* This cannot be done with strcpy() in a portable manner, since the
3689 memory areas overlap! */
3690 memmove(path, path + 2, strlen(path + 2)+1);
3693 * we deal with file://<host>/<path> differently since it supports no
3694 * hostname other than "localhost" and "127.0.0.1", which is unique among
3695 * the URL protocols specified in RFC 1738
3697 if(path[0] != '/') {
3698 /* the URL included a host name, we ignore host names in file:// URLs
3699 as the standards don't define what to do with them */
3700 char *ptr=strchr(path, '/');
3702 /* there was a slash present
3704 RFC1738 (section 3.1, page 5) says:
3706 The rest of the locator consists of data specific to the scheme,
3707 and is known as the "url-path". It supplies the details of how the
3708 specified resource can be accessed. Note that the "/" between the
3709 host (or port) and the url-path is NOT part of the url-path.
3711 As most agents use file://localhost/foo to get '/foo' although the
3712 slash preceding foo is a separator and not a slash for the path,
3713 a URL as file://localhost//foo must be valid as well, to refer to
3714 the same file with an absolute path.
3717 if(ptr[1] && ('/' == ptr[1]))
3718 /* if there was two slashes, we skip the first one as that is then
3719 used truly as a separator */
3722 /* This cannot be made with strcpy, as the memory chunks overlap! */
3723 memmove(path, ptr, strlen(ptr)+1);
3727 protop = "file"; /* protocol string */
3733 if(2 > sscanf(data->change.url,
3734 "%15[^\n:]://%[^\n/?]%[^\n]",
3736 conn->host.name, path)) {
3739 * The URL was badly formatted, let's try the browser-style _without_
3740 * protocol specified like 'http://'.
3742 rc = sscanf(data->change.url, "%[^\n/?]%[^\n]", conn->host.name, path);
3745 * We couldn't even get this format.
3746 * djgpp 2.04 has a sscanf() bug where 'conn->host.name' is
3747 * assigned, but the return value is EOF!
3749 #if defined(__DJGPP__) && (DJGPP_MINOR == 4)
3750 if(!(rc == -1 && *conn->host.name))
3753 failf(data, "<url> malformed");
3754 return CURLE_URL_MALFORMAT;
3759 * Since there was no protocol part specified, we guess what protocol it
3760 * is based on the first letters of the server name.
3763 /* Note: if you add a new protocol, please update the list in
3764 * lib/version.c too! */
3766 if(checkprefix("FTP.", conn->host.name))
3768 else if(checkprefix("DICT.", conn->host.name))
3770 else if(checkprefix("LDAP.", conn->host.name))
3772 else if(checkprefix("IMAP.", conn->host.name))
3778 *prot_missing = TRUE; /* not given in URL */
3784 /* We search for '?' in the host name (but only on the right side of a
3785 * @-letter to allow ?-letters in username and password) to handle things
3786 * like http://example.com?param= (notice the missing '/').
3788 at = strchr(conn->host.name, '@');
3790 query = strchr(at+1, '?');
3792 query = strchr(conn->host.name, '?');
3795 /* We must insert a slash before the '?'-letter in the URL. If the URL had
3796 a slash after the '?', that is where the path currently begins and the
3797 '?string' is still part of the host name.
3799 We must move the trailing part from the host name and put it first in
3800 the path. And have it all prefixed with a slash.
3803 size_t hostlen = strlen(query);
3804 size_t pathlen = strlen(path);
3806 /* move the existing path plus the zero byte forward, to make room for
3807 the host-name part */
3808 memmove(path+hostlen+1, path, pathlen+1);
3810 /* now copy the trailing host part in front of the existing path */
3811 memcpy(path+1, query, hostlen);
3813 path[0]='/'; /* prepend the missing slash */
3816 *query=0; /* now cut off the hostname at the ? */
3819 /* if there's no path set, use a single slash */
3824 /* If the URL is malformatted (missing a '/' after hostname before path) we
3825 * insert a slash here. The only letter except '/' we accept to start a path
3828 if(path[0] == '?') {
3829 /* We need this function to deal with overlapping memory areas. We know
3830 that the memory area 'path' points to is 'urllen' bytes big and that
3831 is bigger than the path. Use +1 to move the zero byte too. */
3832 memmove(&path[1], path, strlen(path)+1);
3839 * "fix_slash" means that the URL was malformatted so we need to generate an
3840 * updated version with the new slash inserted at the right place! We need
3841 * the corrected URL when communicating over HTTP proxy and we don't know at
3842 * this point if we're using a proxy or not.
3847 size_t plen = strlen(path); /* new path, should be 1 byte longer than
3849 size_t urllen = strlen(data->change.url); /* original URL length */
3851 reurl = malloc(urllen + 2); /* 2 for zerobyte + slash */
3853 return CURLE_OUT_OF_MEMORY;
3855 /* copy the prefix */
3856 memcpy(reurl, data->change.url, urllen - (plen-1));
3858 /* append the trailing piece + zerobyte */
3859 memcpy(&reurl[urllen - (plen-1)], path, plen + 1);
3861 /* possible free the old one */
3862 if(data->change.url_alloc) {
3863 Curl_safefree(data->change.url);
3864 data->change.url_alloc = FALSE;
3867 data->change.url = reurl;
3868 data->change.url_alloc = TRUE; /* free this later */
3872 * Parse the login details from the URL and strip them out of
3875 result = parse_url_login(data, conn, user, passwd, options);
3876 if(result != CURLE_OK)
3879 if(conn->host.name[0] == '[') {
3880 /* This looks like an IPv6 address literal. See if there is an address
3882 char *percent = strstr (conn->host.name, "%25");
3885 unsigned long scope = strtoul (percent + 3, &endp, 10);
3887 /* The address scope was well formed. Knock it out of the
3889 memmove(percent, endp, strlen(endp)+1);
3890 if(!data->state.this_is_a_follow)
3891 /* Don't honour a scope given in a Location: header */
3892 conn->scope = (unsigned int)scope;
3895 infof(data, "Invalid IPv6 address format\n");
3900 /* Override any scope that was set above. */
3901 conn->scope = data->set.scope;
3903 /* Remove the fragment part of the path. Per RFC 2396, this is always the
3904 last part of the URI. We are looking for the first '#' so that we deal
3905 gracefully with non conformant URI such as http://example.com#foo#bar. */
3906 fragment = strchr(path, '#');
3910 /* we know the path part ended with a fragment, so we know the full URL
3911 string does too and we need to cut it off from there so it isn't used
3913 fragment = strchr(data->change.url, '#');
3919 * So if the URL was A://B/C#D,
3921 * conn->host.name is B
3922 * data->state.path is /C
3925 return findprotocol(data, conn, protop);
3929 * If we're doing a resumed transfer, we need to setup our stuff
3932 static CURLcode setup_range(struct SessionHandle *data)
3934 struct UrlState *s = &data->state;
3935 s->resume_from = data->set.set_resume_from;
3936 if(s->resume_from || data->set.str[STRING_SET_RANGE]) {
3937 if(s->rangestringalloc)
3941 s->range = aprintf("%" FORMAT_OFF_TU "-", s->resume_from);
3943 s->range = strdup(data->set.str[STRING_SET_RANGE]);
3945 s->rangestringalloc = (s->range)?TRUE:FALSE;
3948 return CURLE_OUT_OF_MEMORY;
3950 /* tell ourselves to fetch this range */
3951 s->use_range = TRUE; /* enable range download */
3954 s->use_range = FALSE; /* disable range download */
3960 /***************************************************************
3961 * Setup connection internals specific to the requested protocol.
3962 * This MUST get called after proxy magic has been figured out.
3963 ***************************************************************/
3964 static CURLcode setup_connection_internals(struct connectdata *conn)
3966 const struct Curl_handler * p;
3969 conn->socktype = SOCK_STREAM; /* most of them are TCP streams */
3971 /* Scan protocol handler table. */
3973 /* Perform setup complement if some. */
3976 if(p->setup_connection) {
3977 result = (*p->setup_connection)(conn);
3979 if(result != CURLE_OK)
3982 p = conn->handler; /* May have changed. */
3986 /* we check for -1 here since if proxy was detected already, this
3987 was very likely already set to the proxy port */
3988 conn->port = p->defport;
3989 conn->remote_port = (unsigned short)conn->given->defport;
3994 #ifndef CURL_DISABLE_PROXY
3995 /****************************************************************
3996 * Checks if the host is in the noproxy list. returns true if it matches
3997 * and therefore the proxy should NOT be used.
3998 ****************************************************************/
3999 static bool check_noproxy(const char* name, const char* no_proxy)
4001 /* no_proxy=domain1.dom,host.domain2.dom
4002 * (a comma-separated list of hosts which should
4003 * not be proxied, or an asterisk to override
4004 * all proxy variables)
4008 const char* separator = ", ";
4009 size_t no_proxy_len;
4013 if(no_proxy && no_proxy[0]) {
4014 if(Curl_raw_equal("*", no_proxy)) {
4018 /* NO_PROXY was specified and it wasn't just an asterisk */
4020 no_proxy_len = strlen(no_proxy);
4021 endptr = strchr(name, ':');
4023 namelen = endptr - name;
4025 namelen = strlen(name);
4027 for(tok_start = 0; tok_start < no_proxy_len; tok_start = tok_end + 1) {
4028 while(tok_start < no_proxy_len &&
4029 strchr(separator, no_proxy[tok_start]) != NULL) {
4030 /* Look for the beginning of the token. */
4034 if(tok_start == no_proxy_len)
4035 break; /* It was all trailing separator chars, no more tokens. */
4037 for(tok_end = tok_start; tok_end < no_proxy_len &&
4038 strchr(separator, no_proxy[tok_end]) == NULL; ++tok_end)
4039 /* Look for the end of the token. */
4042 /* To match previous behaviour, where it was necessary to specify
4043 * ".local.com" to prevent matching "notlocal.com", we will leave
4046 if(no_proxy[tok_start] == '.')
4049 if((tok_end - tok_start) <= namelen) {
4050 /* Match the last part of the name to the domain we are checking. */
4051 const char *checkn = name + namelen - (tok_end - tok_start);
4052 if(Curl_raw_nequal(no_proxy + tok_start, checkn,
4053 tok_end - tok_start)) {
4054 if((tok_end - tok_start) == namelen || *(checkn - 1) == '.') {
4055 /* We either have an exact match, or the previous character is a .
4056 * so it is within the same domain, so no proxy for this host.
4061 } /* if((tok_end - tok_start) <= namelen) */
4062 } /* for(tok_start = 0; tok_start < no_proxy_len;
4063 tok_start = tok_end + 1) */
4064 } /* NO_PROXY was specified and it wasn't just an asterisk */
4069 /****************************************************************
4070 * Detect what (if any) proxy to use. Remember that this selects a host
4071 * name and is not limited to HTTP proxies only.
4072 * The returned pointer must be freed by the caller (unless NULL)
4073 ****************************************************************/
4074 static char *detect_proxy(struct connectdata *conn)
4078 #ifndef CURL_DISABLE_HTTP
4079 /* If proxy was not specified, we check for default proxy environment
4080 * variables, to enable i.e Lynx compliance:
4082 * http_proxy=http://some.server.dom:port/
4083 * https_proxy=http://some.server.dom:port/
4084 * ftp_proxy=http://some.server.dom:port/
4085 * no_proxy=domain1.dom,host.domain2.dom
4086 * (a comma-separated list of hosts which should
4087 * not be proxied, or an asterisk to override
4088 * all proxy variables)
4089 * all_proxy=http://some.server.dom:port/
4090 * (seems to exist for the CERN www lib. Probably
4091 * the first to check for.)
4093 * For compatibility, the all-uppercase versions of these variables are
4094 * checked if the lowercase versions don't exist.
4096 char *no_proxy=NULL;
4097 char proxy_env[128];
4099 no_proxy=curl_getenv("no_proxy");
4101 no_proxy=curl_getenv("NO_PROXY");
4103 if(!check_noproxy(conn->host.name, no_proxy)) {
4104 /* It was not listed as without proxy */
4105 const char *protop = conn->handler->scheme;
4106 char *envp = proxy_env;
4109 /* Now, build <protocol>_proxy and check for such a one to use */
4111 *envp++ = (char)tolower((int)*protop++);
4114 strcpy(envp, "_proxy");
4116 /* read the protocol proxy: */
4117 prox=curl_getenv(proxy_env);
4120 * We don't try the uppercase version of HTTP_PROXY because of
4123 * When curl is used in a webserver application
4124 * environment (cgi or php), this environment variable can
4125 * be controlled by the web server user by setting the
4126 * http header 'Proxy:' to some value.
4128 * This can cause 'internal' http/ftp requests to be
4129 * arbitrarily redirected by any external attacker.
4131 if(!prox && !Curl_raw_equal("http_proxy", proxy_env)) {
4132 /* There was no lowercase variable, try the uppercase version: */
4133 Curl_strntoupper(proxy_env, proxy_env, sizeof(proxy_env));
4134 prox=curl_getenv(proxy_env);
4137 if(prox && *prox) { /* don't count "" strings */
4138 proxy = prox; /* use this */
4141 proxy = curl_getenv("all_proxy"); /* default proxy to use */
4143 proxy=curl_getenv("ALL_PROXY");
4145 } /* if(!check_noproxy(conn->host.name, no_proxy)) - it wasn't specified
4150 #else /* !CURL_DISABLE_HTTP */
4153 #endif /* CURL_DISABLE_HTTP */
4159 * If this is supposed to use a proxy, we need to figure out the proxy
4160 * host name, so that we can re-use an existing connection
4161 * that may exist registered to the same proxy host.
4162 * proxy will be freed before this function returns.
4164 static CURLcode parse_proxy(struct SessionHandle *data,
4165 struct connectdata *conn, char *proxy)
4170 /* We use 'proxyptr' to point to the proxy name from now on... */
4175 /* We do the proxy host string parsing here. We want the host name and the
4176 * port name. Accept a protocol:// prefix
4179 /* Parse the protocol part if present */
4180 endofprot = strstr(proxy, "://");
4182 proxyptr = endofprot+3;
4183 if(checkprefix("socks5h", proxy))
4184 conn->proxytype = CURLPROXY_SOCKS5_HOSTNAME;
4185 else if(checkprefix("socks5", proxy))
4186 conn->proxytype = CURLPROXY_SOCKS5;
4187 else if(checkprefix("socks4a", proxy))
4188 conn->proxytype = CURLPROXY_SOCKS4A;
4189 else if(checkprefix("socks4", proxy) || checkprefix("socks", proxy))
4190 conn->proxytype = CURLPROXY_SOCKS4;
4191 /* Any other xxx:// : change to http proxy */
4194 proxyptr = proxy; /* No xxx:// head: It's a HTTP proxy */
4196 /* Is there a username and password given in this proxy url? */
4197 atsign = strchr(proxyptr, '@');
4199 CURLcode res = CURLE_OK;
4200 char *proxyuser = NULL;
4201 char *proxypasswd = NULL;
4203 res = parse_login_details(proxyptr, atsign - proxyptr,
4204 &proxyuser, &proxypasswd, NULL);
4206 /* found user and password, rip them out. note that we are
4207 unescaping them, as there is otherwise no way to have a
4208 username or password with reserved characters like ':' in
4210 Curl_safefree(conn->proxyuser);
4211 if(proxyuser && strlen(proxyuser) < MAX_CURL_USER_LENGTH)
4212 conn->proxyuser = curl_easy_unescape(data, proxyuser, 0, NULL);
4214 conn->proxyuser = strdup("");
4216 if(!conn->proxyuser)
4217 res = CURLE_OUT_OF_MEMORY;
4219 Curl_safefree(conn->proxypasswd);
4220 if(proxypasswd && strlen(proxypasswd) < MAX_CURL_PASSWORD_LENGTH)
4221 conn->proxypasswd = curl_easy_unescape(data, proxypasswd, 0, NULL);
4223 conn->proxypasswd = strdup("");
4225 if(!conn->proxypasswd)
4226 res = CURLE_OUT_OF_MEMORY;
4230 conn->bits.proxy_user_passwd = TRUE; /* enable it */
4231 atsign++; /* the right side of the @-letter */
4234 proxyptr = atsign; /* now use this instead */
4236 res = CURLE_OUT_OF_MEMORY;
4240 Curl_safefree(proxyuser);
4241 Curl_safefree(proxypasswd);
4247 /* start scanning for port number at this point */
4250 /* detect and extract RFC2732-style IPv6-addresses */
4251 if(*proxyptr == '[') {
4252 char *ptr = ++proxyptr; /* advance beyond the initial bracket */
4253 while(*ptr && (ISXDIGIT(*ptr) || (*ptr == ':') || (*ptr == '%') ||
4257 /* yeps, it ended nicely with a bracket as well */
4260 infof(data, "Invalid IPv6 address format\n");
4262 /* Note that if this didn't end with a bracket, we still advanced the
4263 * proxyptr first, but I can't see anything wrong with that as no host
4264 * name nor a numeric can legally start with a bracket.
4268 /* Get port number off proxy.server.com:1080 */
4269 prox_portno = strchr(portptr, ':');
4271 *prox_portno = 0x0; /* cut off number from host name */
4273 /* now set the local port number */
4274 conn->port = strtol(prox_portno, NULL, 10);
4277 if(proxyptr[0]=='/')
4278 /* If the first character in the proxy string is a slash, fail
4279 immediately. The following code will otherwise clear the string which
4280 will lead to code running as if no proxy was set! */
4281 return CURLE_COULDNT_RESOLVE_PROXY;
4283 /* without a port number after the host name, some people seem to use
4284 a slash so we strip everything from the first slash */
4285 atsign = strchr(proxyptr, '/');
4287 *atsign = 0x0; /* cut off path part from host name */
4289 if(data->set.proxyport)
4290 /* None given in the proxy string, then get the default one if it is
4292 conn->port = data->set.proxyport;
4295 /* now, clone the cleaned proxy host name */
4296 conn->proxy.rawalloc = strdup(proxyptr);
4297 conn->proxy.name = conn->proxy.rawalloc;
4299 if(!conn->proxy.rawalloc)
4300 return CURLE_OUT_OF_MEMORY;
4306 * Extract the user and password from the authentication string
4308 static CURLcode parse_proxy_auth(struct SessionHandle *data,
4309 struct connectdata *conn)
4311 char proxyuser[MAX_CURL_USER_LENGTH]="";
4312 char proxypasswd[MAX_CURL_PASSWORD_LENGTH]="";
4314 if(data->set.str[STRING_PROXYUSERNAME] != NULL) {
4315 strncpy(proxyuser, data->set.str[STRING_PROXYUSERNAME],
4316 MAX_CURL_USER_LENGTH);
4317 proxyuser[MAX_CURL_USER_LENGTH-1] = '\0'; /*To be on safe side*/
4319 if(data->set.str[STRING_PROXYPASSWORD] != NULL) {
4320 strncpy(proxypasswd, data->set.str[STRING_PROXYPASSWORD],
4321 MAX_CURL_PASSWORD_LENGTH);
4322 proxypasswd[MAX_CURL_PASSWORD_LENGTH-1] = '\0'; /*To be on safe side*/
4325 conn->proxyuser = curl_easy_unescape(data, proxyuser, 0, NULL);
4326 if(!conn->proxyuser)
4327 return CURLE_OUT_OF_MEMORY;
4329 conn->proxypasswd = curl_easy_unescape(data, proxypasswd, 0, NULL);
4330 if(!conn->proxypasswd)
4331 return CURLE_OUT_OF_MEMORY;
4335 #endif /* CURL_DISABLE_PROXY */
4340 * Parse the login details (user name, password and options) from the URL and
4341 * strip them out of the host name
4343 * Inputs: data->set.use_netrc (CURLOPT_NETRC)
4346 * Outputs: (almost :- all currently undefined)
4347 * conn->bits.user_passwd - non-zero if non-default passwords exist
4348 * user - non-zero length if defined
4349 * passwd - non-zero length if defined
4350 * options - non-zero length if defined
4351 * conn->host.name - remove user name and password
4353 static CURLcode parse_url_login(struct SessionHandle *data,
4354 struct connectdata *conn,
4355 char *user, char *passwd, char *options)
4357 CURLcode result = CURLE_OK;
4359 char *passwdp = NULL;
4360 char *optionsp = NULL;
4362 /* At this point, we're hoping all the other special cases have
4363 * been taken care of, so conn->host.name is at most
4364 * [user[:password][;options]]@]hostname
4366 * We need somewhere to put the embedded details, so do that first.
4369 char *ptr = strchr(conn->host.name, '@');
4370 char *login = conn->host.name;
4372 user[0] = 0; /* to make everything well-defined */
4376 /* We will now try to extract the
4377 * possible login information in a string like:
4378 * ftp://user:password@ftp.my.site:8021/README */
4380 /* There's login information to the left of the @ */
4382 conn->host.name = ++ptr;
4384 /* So the hostname is sane. Only bother interpreting the
4385 * results if we could care. It could still be wasted
4386 * work because it might be overtaken by the programmatically
4387 * set user/passwd, but doing that first adds more cases here :-(
4390 if(data->set.use_netrc != CURL_NETRC_REQUIRED) {
4391 /* We could use the login information in the URL so extract it */
4392 result = parse_login_details(login, ptr - login - 1,
4393 &userp, &passwdp, &optionsp);
4398 /* We have a user in the URL */
4399 conn->bits.userpwd_in_url = TRUE;
4400 conn->bits.user_passwd = TRUE; /* enable user+password */
4402 /* Decode the user */
4403 newname = curl_easy_unescape(data, userp, 0, NULL);
4405 return CURLE_OUT_OF_MEMORY;
4407 if(strlen(newname) < MAX_CURL_USER_LENGTH)
4408 strcpy(user, newname);
4414 /* We have a password in the URL so decode it */
4415 char *newpasswd = curl_easy_unescape(data, passwdp, 0, NULL);
4417 return CURLE_OUT_OF_MEMORY;
4419 if(strlen(newpasswd) < MAX_CURL_PASSWORD_LENGTH)
4420 strcpy(passwd, newpasswd);
4426 /* We have an options list in the URL so decode it */
4427 char *newoptions = curl_easy_unescape(data, optionsp, 0, NULL);
4429 return CURLE_OUT_OF_MEMORY;
4431 if(strlen(newoptions) < MAX_CURL_OPTIONS_LENGTH)
4432 strcpy(options, newoptions);
4438 Curl_safefree(userp);
4439 Curl_safefree(passwdp);
4440 Curl_safefree(optionsp);
4448 * parse_login_details()
4450 * This is used to parse a login string for user name, password and options in
4451 * the following formats:
4455 * user:password;options
4457 * user;options:password
4465 * login [in] - The login string.
4466 * len [in] - The length of the login string.
4467 * userp [in/out] - The address where a pointer to newly allocated memory
4468 * holding the user will be stored upon completion.
4469 * passdwp [in/out] - The address where a pointer to newly allocated memory
4470 * holding the password will be stored upon completion.
4471 * optionsp [in/out] - The address where a pointer to newly allocated memory
4472 * holding the options will be stored upon completion.
4474 * Returns CURLE_OK on success.
4476 static CURLcode parse_login_details(const char *login, const size_t len,
4477 char **userp, char **passwdp,
4480 CURLcode result = CURLE_OK;
4484 const char *psep = NULL;
4485 const char *osep = NULL;
4490 /* Attempt to find the password separator */
4492 psep = strchr(login, ':');
4494 /* Within the constraint of the login string */
4495 if(psep >= login + len)
4499 /* Attempt to find the options separator */
4501 osep = strchr(login, ';');
4503 /* Within the constraint of the login string */
4504 if(osep >= login + len)
4508 /* Calculate the portion lengths */
4510 (size_t)(osep && psep > osep ? osep - login : psep - login) :
4511 (osep ? (size_t)(osep - login) : len));
4513 (osep && osep > psep ? (size_t)(osep - psep) :
4514 (size_t)(login + len - psep)) - 1 : 0);
4516 (psep && psep > osep ? (size_t)(psep - osep) :
4517 (size_t)(login + len - osep)) - 1 : 0);
4519 /* Allocate the user portion buffer */
4521 ubuf = malloc(ulen + 1);
4523 result = CURLE_OUT_OF_MEMORY;
4526 /* Allocate the password portion buffer */
4527 if(!result && passwdp && plen) {
4528 pbuf = malloc(plen + 1);
4530 result = CURLE_OUT_OF_MEMORY;
4533 /* Allocate the options portion buffer */
4534 if(!result && optionsp && olen) {
4535 obuf = malloc(olen + 1);
4537 result = CURLE_OUT_OF_MEMORY;
4541 /* Store the user portion if necessary */
4543 memcpy(ubuf, login, ulen);
4545 Curl_safefree(*userp);
4549 /* Store the password portion if necessary */
4551 memcpy(pbuf, psep + 1, plen);
4553 Curl_safefree(*passwdp);
4557 /* Store the options portion if necessary */
4559 memcpy(obuf, osep + 1, olen);
4561 Curl_safefree(*optionsp);
4569 /*************************************************************
4570 * Figure out the remote port number and fix it in the URL
4572 * No matter if we use a proxy or not, we have to figure out the remote
4573 * port number of various reasons.
4575 * To be able to detect port number flawlessly, we must not confuse them
4576 * IPv6-specified addresses in the [0::1] style. (RFC2732)
4578 * The conn->host.name is currently [user:passwd@]host[:port] where host
4579 * could be a hostname, IPv4 address or IPv6 address.
4581 * The port number embedded in the URL is replaced, if necessary.
4582 *************************************************************/
4583 static CURLcode parse_remote_port(struct SessionHandle *data,
4584 struct connectdata *conn)
4589 /* Note that at this point, the IPv6 address cannot contain any scope
4590 suffix as that has already been removed in the parseurlandfillconn()
4592 if((1 == sscanf(conn->host.name, "[%*45[0123456789abcdefABCDEF:.]%c",
4594 (']' == endbracket)) {
4595 /* this is a RFC2732-style specified IP-address */
4596 conn->bits.ipv6_ip = TRUE;
4598 conn->host.name++; /* skip over the starting bracket */
4599 portptr = strchr(conn->host.name, ']');
4601 *portptr++ = '\0'; /* zero terminate, killing the bracket */
4603 portptr = NULL; /* no port number available */
4608 struct in6_addr in6;
4609 if(Curl_inet_pton(AF_INET6, conn->host.name, &in6) > 0) {
4610 /* This is a numerical IPv6 address, meaning this is a wrongly formatted
4612 failf(data, "IPv6 numerical address used in URL without brackets");
4613 return CURLE_URL_MALFORMAT;
4617 portptr = strrchr(conn->host.name, ':');
4620 if(data->set.use_port && data->state.allow_port) {
4621 /* if set, we use this and ignore the port possibly given in the URL */
4622 conn->remote_port = (unsigned short)data->set.use_port;
4624 *portptr = '\0'; /* cut off the name there anyway - if there was a port
4625 number - since the port number is to be ignored! */
4626 if(conn->bits.httpproxy) {
4627 /* we need to create new URL with the new port number */
4631 if(conn->bits.type_set)
4632 snprintf(type, sizeof(type), ";type=%c",
4633 data->set.prefer_ascii?'A':
4634 (data->set.ftp_list_only?'D':'I'));
4637 * This synthesized URL isn't always right--suffixes like ;type=A are
4638 * stripped off. It would be better to work directly from the original
4639 * URL and simply replace the port part of it.
4641 url = aprintf("%s://%s%s%s:%hu%s%s%s", conn->given->scheme,
4642 conn->bits.ipv6_ip?"[":"", conn->host.name,
4643 conn->bits.ipv6_ip?"]":"", conn->remote_port,
4644 data->state.slash_removed?"/":"", data->state.path,
4647 return CURLE_OUT_OF_MEMORY;
4649 if(data->change.url_alloc) {
4650 Curl_safefree(data->change.url);
4651 data->change.url_alloc = FALSE;
4654 data->change.url = url;
4655 data->change.url_alloc = TRUE;
4659 /* no CURLOPT_PORT given, extract the one from the URL */
4664 port=strtoul(portptr+1, &rest, 10); /* Port number must be decimal */
4666 if(rest != (portptr+1) && *rest == '\0') {
4667 /* The colon really did have only digits after it,
4668 * so it is either a port number or a mistake */
4670 if(port > 0xffff) { /* Single unix standard says port numbers are
4672 failf(data, "Port number too large: %lu", port);
4673 return CURLE_URL_MALFORMAT;
4676 *portptr = '\0'; /* cut off the name there */
4677 conn->remote_port = curlx_ultous(port);
4680 /* Browser behavior adaptation. If there's a colon with no digits after,
4681 just cut off the name there which makes us ignore the colon and just
4682 use the default port. Firefox and Chrome both do that. */
4689 * Override the login details from the URL with that in the CURLOPT_USERPWD
4690 * option or a .netrc file, if applicable.
4692 static void override_login(struct SessionHandle *data,
4693 struct connectdata *conn,
4694 char *user, char *passwd, char *options)
4696 if(data->set.str[STRING_USERNAME]) {
4697 strncpy(user, data->set.str[STRING_USERNAME], MAX_CURL_USER_LENGTH);
4698 user[MAX_CURL_USER_LENGTH - 1] = '\0'; /* To be on safe side */
4701 if(data->set.str[STRING_PASSWORD]) {
4702 strncpy(passwd, data->set.str[STRING_PASSWORD], MAX_CURL_PASSWORD_LENGTH);
4703 passwd[MAX_CURL_PASSWORD_LENGTH - 1] = '\0'; /* To be on safe side */
4706 if(data->set.str[STRING_OPTIONS]) {
4707 strncpy(options, data->set.str[STRING_OPTIONS], MAX_CURL_OPTIONS_LENGTH);
4708 options[MAX_CURL_OPTIONS_LENGTH - 1] = '\0'; /* To be on safe side */
4711 conn->bits.netrc = FALSE;
4712 if(data->set.use_netrc != CURL_NETRC_IGNORED) {
4713 if(Curl_parsenetrc(conn->host.name,
4715 data->set.str[STRING_NETRC_FILE])) {
4716 infof(data, "Couldn't find host %s in the "
4717 DOT_CHAR "netrc file; using defaults\n",
4721 /* set bits.netrc TRUE to remember that we got the name from a .netrc
4722 file, so that it is safe to use even if we followed a Location: to a
4723 different host or similar. */
4724 conn->bits.netrc = TRUE;
4726 conn->bits.user_passwd = TRUE; /* enable user+password */
4732 * Set password so it's available in the connection.
4734 static CURLcode set_login(struct connectdata *conn,
4735 const char *user, const char *passwd,
4736 const char *options)
4738 CURLcode result = CURLE_OK;
4740 /* If our protocol needs a password and we have none, use the defaults */
4741 if((conn->handler->flags & PROTOPT_NEEDSPWD) && !conn->bits.user_passwd) {
4742 /* Store the default user */
4743 conn->user = strdup(CURL_DEFAULT_USER);
4745 /* Store the default password */
4747 conn->passwd = strdup(CURL_DEFAULT_PASSWORD);
4749 conn->passwd = NULL;
4751 /* This is the default password, so DON'T set conn->bits.user_passwd */
4754 /* Store the user, zero-length if not set */
4755 conn->user = strdup(user);
4757 /* Store the password (only if user is present), zero-length if not set */
4759 conn->passwd = strdup(passwd);
4761 conn->passwd = NULL;
4764 if(!conn->user || !conn->passwd)
4765 result = CURLE_OUT_OF_MEMORY;
4767 /* Store the options, null if not set */
4768 if(!result && options[0]) {
4769 conn->options = strdup(options);
4772 result = CURLE_OUT_OF_MEMORY;
4778 /*************************************************************
4779 * Resolve the address of the server or proxy
4780 *************************************************************/
4781 static CURLcode resolve_server(struct SessionHandle *data,
4782 struct connectdata *conn,
4785 CURLcode result=CURLE_OK;
4786 long timeout_ms = Curl_timeleft(data, NULL, TRUE);
4788 /*************************************************************
4789 * Resolve the name of the server or proxy
4790 *************************************************************/
4791 if(conn->bits.reuse)
4792 /* We're reusing the connection - no need to resolve anything, and
4793 fix_hostname() was called already in create_conn() for the re-use
4798 /* this is a fresh connect */
4800 struct Curl_dns_entry *hostaddr;
4802 /* set a pointer to the hostname we display */
4803 fix_hostname(data, conn, &conn->host);
4805 if(!conn->proxy.name || !*conn->proxy.name) {
4806 /* If not connecting via a proxy, extract the port from the URL, if it is
4807 * there, thus overriding any defaults that might have been set above. */
4808 conn->port = conn->remote_port; /* it is the same port */
4810 /* Resolve target host right on */
4811 rc = Curl_resolv_timeout(conn, conn->host.name, (int)conn->port,
4812 &hostaddr, timeout_ms);
4813 if(rc == CURLRESOLV_PENDING)
4816 else if(rc == CURLRESOLV_TIMEDOUT)
4817 result = CURLE_OPERATION_TIMEDOUT;
4819 else if(!hostaddr) {
4820 failf(data, "Couldn't resolve host '%s'", conn->host.dispname);
4821 result = CURLE_COULDNT_RESOLVE_HOST;
4822 /* don't return yet, we need to clean up the timeout first */
4826 /* This is a proxy that hasn't been resolved yet. */
4828 /* IDN-fix the proxy name */
4829 fix_hostname(data, conn, &conn->proxy);
4832 rc = Curl_resolv_timeout(conn, conn->proxy.name, (int)conn->port,
4833 &hostaddr, timeout_ms);
4835 if(rc == CURLRESOLV_PENDING)
4838 else if(rc == CURLRESOLV_TIMEDOUT)
4839 result = CURLE_OPERATION_TIMEDOUT;
4841 else if(!hostaddr) {
4842 failf(data, "Couldn't resolve proxy '%s'", conn->proxy.dispname);
4843 result = CURLE_COULDNT_RESOLVE_PROXY;
4844 /* don't return yet, we need to clean up the timeout first */
4847 DEBUGASSERT(conn->dns_entry == NULL);
4848 conn->dns_entry = hostaddr;
4855 * Cleanup the connection just allocated before we can move along and use the
4856 * previously existing one. All relevant data is copied over and old_conn is
4857 * ready for freeing once this function returns.
4859 static void reuse_conn(struct connectdata *old_conn,
4860 struct connectdata *conn)
4862 if(old_conn->proxy.rawalloc)
4863 free(old_conn->proxy.rawalloc);
4865 /* free the SSL config struct from this connection struct as this was
4866 allocated in vain and is targeted for destruction */
4867 Curl_free_ssl_config(&old_conn->ssl_config);
4869 conn->data = old_conn->data;
4871 /* get the user+password information from the old_conn struct since it may
4872 * be new for this request even when we re-use an existing connection */
4873 conn->bits.user_passwd = old_conn->bits.user_passwd;
4874 if(conn->bits.user_passwd) {
4875 /* use the new user name and password though */
4876 Curl_safefree(conn->user);
4877 Curl_safefree(conn->passwd);
4878 conn->user = old_conn->user;
4879 conn->passwd = old_conn->passwd;
4880 old_conn->user = NULL;
4881 old_conn->passwd = NULL;
4884 conn->bits.proxy_user_passwd = old_conn->bits.proxy_user_passwd;
4885 if(conn->bits.proxy_user_passwd) {
4886 /* use the new proxy user name and proxy password though */
4887 Curl_safefree(conn->proxyuser);
4888 Curl_safefree(conn->proxypasswd);
4889 conn->proxyuser = old_conn->proxyuser;
4890 conn->proxypasswd = old_conn->proxypasswd;
4891 old_conn->proxyuser = NULL;
4892 old_conn->proxypasswd = NULL;
4895 /* host can change, when doing keepalive with a proxy or if the case is
4896 different this time etc */
4897 Curl_safefree(conn->host.rawalloc);
4898 conn->host=old_conn->host;
4900 /* persist connection info in session handle */
4901 Curl_persistconninfo(conn);
4904 conn->bits.reuse = TRUE; /* yes, we're re-using here */
4906 Curl_safefree(old_conn->user);
4907 Curl_safefree(old_conn->passwd);
4908 Curl_safefree(old_conn->proxyuser);
4909 Curl_safefree(old_conn->proxypasswd);
4910 Curl_safefree(old_conn->localdev);
4912 Curl_llist_destroy(old_conn->send_pipe, NULL);
4913 Curl_llist_destroy(old_conn->recv_pipe, NULL);
4915 old_conn->send_pipe = NULL;
4916 old_conn->recv_pipe = NULL;
4918 Curl_safefree(old_conn->master_buffer);
4922 * create_conn() sets up a new connectdata struct, or re-uses an already
4923 * existing one, and resolves host name.
4925 * if this function returns CURLE_OK and *async is set to TRUE, the resolve
4926 * response will be coming asynchronously. If *async is FALSE, the name is
4929 * @param data The sessionhandle pointer
4930 * @param in_connect is set to the next connection data pointer
4931 * @param async is set TRUE when an async DNS resolution is pending
4932 * @see Curl_setup_conn()
4934 * *NOTE* this function assigns the conn->data pointer!
4937 static CURLcode create_conn(struct SessionHandle *data,
4938 struct connectdata **in_connect,
4941 CURLcode result = CURLE_OK;
4942 struct connectdata *conn;
4943 struct connectdata *conn_temp = NULL;
4945 char user[MAX_CURL_USER_LENGTH];
4946 char passwd[MAX_CURL_PASSWORD_LENGTH];
4947 char options[MAX_CURL_OPTIONS_LENGTH];
4950 bool prot_missing = FALSE;
4951 bool no_connections_available = FALSE;
4953 size_t max_host_connections = Curl_multi_max_host_connections(data->multi);
4954 size_t max_total_connections = Curl_multi_max_total_connections(data->multi);
4958 /*************************************************************
4960 *************************************************************/
4962 if(!data->change.url)
4963 return CURLE_URL_MALFORMAT;
4965 /* First, split up the current URL in parts so that we can use the
4966 parts for checking against the already present connections. In order
4967 to not have to modify everything at once, we allocate a temporary
4968 connection data struct and fill in for comparison purposes. */
4969 conn = allocate_conn(data);
4972 return CURLE_OUT_OF_MEMORY;
4974 /* We must set the return variable as soon as possible, so that our
4975 parent can cleanup any possible allocs we may have done before
4979 /* This initing continues below, see the comment "Continue connectdata
4980 * initialization here" */
4982 /***********************************************************
4983 * We need to allocate memory to store the path in. We get the size of the
4984 * full URL to be sure, and we need to make it at least 256 bytes since
4985 * other parts of the code will rely on this fact
4986 ***********************************************************/
4987 #define LEAST_PATH_ALLOC 256
4988 urllen=strlen(data->change.url);
4989 if(urllen < LEAST_PATH_ALLOC)
4990 urllen=LEAST_PATH_ALLOC;
4993 * We malloc() the buffers below urllen+2 to make room for 2 possibilities:
4994 * 1 - an extra terminating zero
4995 * 2 - an extra slash (in case a syntax like "www.host.com?moo" is used)
4998 Curl_safefree(data->state.pathbuffer);
4999 data->state.path = NULL;
5001 data->state.pathbuffer = malloc(urllen+2);
5002 if(NULL == data->state.pathbuffer)
5003 return CURLE_OUT_OF_MEMORY; /* really bad error */
5004 data->state.path = data->state.pathbuffer;
5006 conn->host.rawalloc = malloc(urllen+2);
5007 if(NULL == conn->host.rawalloc) {
5008 Curl_safefree(data->state.pathbuffer);
5009 data->state.path = NULL;
5010 return CURLE_OUT_OF_MEMORY;
5013 conn->host.name = conn->host.rawalloc;
5014 conn->host.name[0] = 0;
5016 result = parseurlandfillconn(data, conn, &prot_missing, user, passwd,
5018 if(result != CURLE_OK)
5021 /*************************************************************
5022 * No protocol part in URL was used, add it!
5023 *************************************************************/
5025 /* We're guessing prefixes here and if we're told to use a proxy or if
5026 we're gonna follow a Location: later or... then we need the protocol
5027 part added so that we have a valid URL. */
5030 reurl = aprintf("%s://%s", conn->handler->scheme, data->change.url);
5033 Curl_safefree(proxy);
5034 return CURLE_OUT_OF_MEMORY;
5037 if(data->change.url_alloc) {
5038 Curl_safefree(data->change.url);
5039 data->change.url_alloc = FALSE;
5042 data->change.url = reurl;
5043 data->change.url_alloc = TRUE; /* free this later */
5046 /*************************************************************
5047 * If the protocol can't handle url query strings, then cut
5048 * of the unhandable part
5049 *************************************************************/
5050 if((conn->given->flags&PROTOPT_NOURLQUERY)) {
5051 char *path_q_sep = strchr(conn->data->state.path, '?');
5053 /* according to rfc3986, allow the query (?foo=bar)
5054 also on protocols that can't handle it.
5056 cut the string-part after '?'
5059 /* terminate the string */
5064 #ifndef CURL_DISABLE_PROXY
5065 /*************************************************************
5066 * Extract the user and password from the authentication string
5067 *************************************************************/
5068 if(conn->bits.proxy_user_passwd) {
5069 result = parse_proxy_auth(data, conn);
5070 if(result != CURLE_OK)
5074 /*************************************************************
5075 * Detect what (if any) proxy to use
5076 *************************************************************/
5077 if(data->set.str[STRING_PROXY]) {
5078 proxy = strdup(data->set.str[STRING_PROXY]);
5079 /* if global proxy is set, this is it */
5081 failf(data, "memory shortage");
5082 return CURLE_OUT_OF_MEMORY;
5086 if(data->set.str[STRING_NOPROXY] &&
5087 check_noproxy(conn->host.name, data->set.str[STRING_NOPROXY])) {
5089 free(proxy); /* proxy is in exception list */
5094 proxy = detect_proxy(conn);
5096 if(proxy && (!*proxy || (conn->handler->flags & PROTOPT_NONETWORK))) {
5097 free(proxy); /* Don't bother with an empty proxy string or if the
5098 protocol doesn't work with network */
5102 /***********************************************************************
5103 * If this is supposed to use a proxy, we need to figure out the proxy host
5104 * name, proxy type and port number, so that we can re-use an existing
5105 * connection that may exist registered to the same proxy host.
5106 ***********************************************************************/
5108 result = parse_proxy(data, conn, proxy);
5110 free(proxy); /* parse_proxy copies the proxy string */
5115 if((conn->proxytype == CURLPROXY_HTTP) ||
5116 (conn->proxytype == CURLPROXY_HTTP_1_0)) {
5117 #ifdef CURL_DISABLE_HTTP
5118 /* asking for a HTTP proxy is a bit funny when HTTP is disabled... */
5119 return CURLE_UNSUPPORTED_PROTOCOL;
5121 /* force this connection's protocol to become HTTP if not already
5122 compatible - if it isn't tunneling through */
5123 if(!(conn->handler->protocol & CURLPROTO_HTTP) &&
5124 !conn->bits.tunnel_proxy)
5125 conn->handler = &Curl_handler_http;
5127 conn->bits.httpproxy = TRUE;
5131 conn->bits.httpproxy = FALSE; /* not a HTTP proxy */
5132 conn->bits.proxy = TRUE;
5135 /* we aren't using the proxy after all... */
5136 conn->bits.proxy = FALSE;
5137 conn->bits.httpproxy = FALSE;
5138 conn->bits.proxy_user_passwd = FALSE;
5139 conn->bits.tunnel_proxy = FALSE;
5142 #endif /* CURL_DISABLE_PROXY */
5144 /*************************************************************
5145 * Setup internals depending on protocol. Needs to be done after
5146 * we figured out what/if proxy to use.
5147 *************************************************************/
5148 result = setup_connection_internals(conn);
5149 if(result != CURLE_OK) {
5150 Curl_safefree(proxy);
5154 conn->recv[FIRSTSOCKET] = Curl_recv_plain;
5155 conn->send[FIRSTSOCKET] = Curl_send_plain;
5156 conn->recv[SECONDARYSOCKET] = Curl_recv_plain;
5157 conn->send[SECONDARYSOCKET] = Curl_send_plain;
5159 /***********************************************************************
5160 * file: is a special case in that it doesn't need a network connection
5161 ***********************************************************************/
5162 #ifndef CURL_DISABLE_FILE
5163 if(conn->handler->flags & PROTOPT_NONETWORK) {
5165 /* this is supposed to be the connect function so we better at least check
5166 that the file is present here! */
5167 DEBUGASSERT(conn->handler->connect_it);
5168 result = conn->handler->connect_it(conn, &done);
5170 /* Setup a "faked" transfer that'll do nothing */
5171 if(CURLE_OK == result) {
5173 conn->bits.tcpconnect[FIRSTSOCKET] = TRUE; /* we are "connected */
5175 ConnectionStore(data, conn);
5178 * Setup whatever necessary for a resumed transfer
5180 result = setup_range(data);
5182 DEBUGASSERT(conn->handler->done);
5183 /* we ignore the return code for the protocol-specific DONE */
5184 (void)conn->handler->done(conn, result, FALSE);
5188 Curl_setup_transfer(conn, -1, -1, FALSE, NULL, /* no download */
5189 -1, NULL); /* no upload */
5196 /*************************************************************
5197 * If the protocol is using SSL and HTTP proxy is used, we set
5198 * the tunnel_proxy bit.
5199 *************************************************************/
5200 if((conn->given->flags&PROTOPT_SSL) && conn->bits.httpproxy)
5201 conn->bits.tunnel_proxy = TRUE;
5203 /*************************************************************
5204 * Figure out the remote port number and fix it in the URL
5205 *************************************************************/
5206 result = parse_remote_port(data, conn);
5207 if(result != CURLE_OK)
5210 /* Check for overridden login details and set them accordingly */
5211 override_login(data, conn, user, passwd, options);
5212 result = set_login(conn, user, passwd, options);
5213 if(result != CURLE_OK)
5216 /* Get a cloned copy of the SSL config situation stored in the
5217 connection struct. But to get this going nicely, we must first make
5218 sure that the strings in the master copy are pointing to the correct
5219 strings in the session handle strings array!
5221 Keep in mind that the pointers in the master copy are pointing to strings
5222 that will be freed as part of the SessionHandle struct, but all cloned
5223 copies will be separately allocated.
5225 data->set.ssl.CApath = data->set.str[STRING_SSL_CAPATH];
5226 data->set.ssl.CAfile = data->set.str[STRING_SSL_CAFILE];
5227 data->set.ssl.CRLfile = data->set.str[STRING_SSL_CRLFILE];
5228 data->set.ssl.issuercert = data->set.str[STRING_SSL_ISSUERCERT];
5229 data->set.ssl.random_file = data->set.str[STRING_SSL_RANDOM_FILE];
5230 data->set.ssl.egdsocket = data->set.str[STRING_SSL_EGDSOCKET];
5231 data->set.ssl.cipher_list = data->set.str[STRING_SSL_CIPHER_LIST];
5233 data->set.ssl.username = data->set.str[STRING_TLSAUTH_USERNAME];
5234 data->set.ssl.password = data->set.str[STRING_TLSAUTH_PASSWORD];
5237 if(!Curl_clone_ssl_config(&data->set.ssl, &conn->ssl_config))
5238 return CURLE_OUT_OF_MEMORY;
5240 /*************************************************************
5241 * Check the current list of connections to see if we can
5242 * re-use an already existing one or if we have to create a
5244 *************************************************************/
5246 /* reuse_fresh is TRUE if we are told to use a new connection by force, but
5247 we only acknowledge this option if this is not a re-used connection
5248 already (which happens due to follow-location or during a HTTP
5249 authentication phase). */
5250 if(data->set.reuse_fresh && !data->state.this_is_a_follow)
5253 reuse = ConnectionExists(data, conn, &conn_temp, &force_reuse);
5255 /* If we found a reusable connection, we may still want to
5256 open a new connection if we are pipelining. */
5257 if(reuse && !force_reuse && IsPipeliningPossible(data, conn_temp)) {
5258 size_t pipelen = conn_temp->send_pipe->size + conn_temp->recv_pipe->size;
5260 infof(data, "Found connection %d, with requests in the pipe (%d)\n",
5261 conn_temp->connection_id, pipelen);
5263 if(conn_temp->bundle->num_connections < max_host_connections &&
5264 data->state.conn_cache->num_connections < max_total_connections) {
5265 /* We want a new connection anyway */
5268 infof(data, "We can reuse, but we want a new connection anyway\n");
5275 * We already have a connection for this, we got the former connection
5276 * in the conn_temp variable and thus we need to cleanup the one we
5277 * just allocated before we can move along and use the previously
5280 conn_temp->inuse = TRUE; /* mark this as being in use so that no other
5281 handle in a multi stack may nick it */
5282 reuse_conn(conn, conn_temp);
5283 free(conn); /* we don't need this anymore */
5287 /* set a pointer to the hostname we display */
5288 fix_hostname(data, conn, &conn->host);
5290 infof(data, "Re-using existing connection! (#%ld) with host %s\n",
5291 conn->connection_id,
5292 conn->proxy.name?conn->proxy.dispname:conn->host.dispname);
5295 /* We have decided that we want a new connection. However, we may not
5296 be able to do that if we have reached the limit of how many
5297 connections we are allowed to open. */
5298 struct connectbundle *bundle;
5300 bundle = Curl_conncache_find_bundle(data->state.conn_cache,
5302 if(max_host_connections > 0 && bundle &&
5303 (bundle->num_connections >= max_host_connections)) {
5304 struct connectdata *conn_candidate;
5306 /* The bundle is full. Let's see if we can kill a connection. */
5307 conn_candidate = find_oldest_idle_connection_in_bundle(data, bundle);
5309 if(conn_candidate) {
5310 /* Set the connection's owner correctly, then kill it */
5311 conn_candidate->data = data;
5312 (void)Curl_disconnect(conn_candidate, /* dead_connection */ FALSE);
5315 no_connections_available = TRUE;
5318 if(max_total_connections > 0 &&
5319 (data->state.conn_cache->num_connections >= max_total_connections)) {
5320 struct connectdata *conn_candidate;
5322 /* The cache is full. Let's see if we can kill a connection. */
5323 conn_candidate = find_oldest_idle_connection(data);
5325 if(conn_candidate) {
5326 /* Set the connection's owner correctly, then kill it */
5327 conn_candidate->data = data;
5328 (void)Curl_disconnect(conn_candidate, /* dead_connection */ FALSE);
5331 no_connections_available = TRUE;
5335 if(no_connections_available) {
5336 infof(data, "No connections available.\n");
5341 return CURLE_NO_CONNECTION_AVAILABLE;
5345 * This is a brand new connection, so let's store it in the connection
5348 ConnectionStore(data, conn);
5352 /* Mark the connection as used */
5355 /* Setup and init stuff before DO starts, in preparing for the transfer. */
5359 * Setup whatever necessary for a resumed transfer
5361 result = setup_range(data);
5365 /* Continue connectdata initialization here. */
5368 * Inherit the proper values from the urldata struct AFTER we have arranged
5369 * the persistent connection stuff
5371 conn->fread_func = data->set.fread_func;
5372 conn->fread_in = data->set.in;
5373 conn->seek_func = data->set.seek_func;
5374 conn->seek_client = data->set.seek_client;
5376 /*************************************************************
5377 * Resolve the address of the server or proxy
5378 *************************************************************/
5379 result = resolve_server(data, conn, async);
5384 /* Curl_setup_conn() is called after the name resolve initiated in
5385 * create_conn() is all done.
5387 * Curl_setup_conn() also handles reused connections
5389 * conn->data MUST already have been setup fine (in create_conn)
5392 CURLcode Curl_setup_conn(struct connectdata *conn,
5393 bool *protocol_done)
5395 CURLcode result = CURLE_OK;
5396 struct SessionHandle *data = conn->data;
5398 Curl_pgrsTime(data, TIMER_NAMELOOKUP);
5400 if(conn->handler->flags & PROTOPT_NONETWORK) {
5401 /* nothing to setup when not using a network */
5402 *protocol_done = TRUE;
5405 *protocol_done = FALSE; /* default to not done */
5407 /* set proxy_connect_closed to false unconditionally already here since it
5408 is used strictly to provide extra information to a parent function in the
5409 case of proxy CONNECT failures and we must make sure we don't have it
5410 lingering set from a previous invoke */
5411 conn->bits.proxy_connect_closed = FALSE;
5414 * Set user-agent. Used for HTTP, but since we can attempt to tunnel
5415 * basically anything through a http proxy we can't limit this based on
5418 if(data->set.str[STRING_USERAGENT]) {
5419 Curl_safefree(conn->allocptr.uagent);
5420 conn->allocptr.uagent =
5421 aprintf("User-Agent: %s\r\n", data->set.str[STRING_USERAGENT]);
5422 if(!conn->allocptr.uagent)
5423 return CURLE_OUT_OF_MEMORY;
5426 data->req.headerbytecount = 0;
5428 #ifdef CURL_DO_LINEEND_CONV
5429 data->state.crlf_conversions = 0; /* reset CRLF conversion counter */
5430 #endif /* CURL_DO_LINEEND_CONV */
5432 /* set start time here for timeout purposes in the connect procedure, it
5433 is later set again for the progress meter purpose */
5434 conn->now = Curl_tvnow();
5437 /* loop for CURL_SERVER_CLOSED_CONNECTION */
5439 if(CURL_SOCKET_BAD == conn->sock[FIRSTSOCKET]) {
5440 /* Try to connect only if not already connected */
5441 bool connected = FALSE;
5443 result = ConnectPlease(data, conn, &connected);
5445 if(result && !conn->ip_addr) {
5446 /* transport connection failure not related with authentication */
5447 conn->bits.tcpconnect[FIRSTSOCKET] = FALSE;
5452 result = Curl_protocol_connect(conn, protocol_done);
5453 if(CURLE_OK == result)
5454 conn->bits.tcpconnect[FIRSTSOCKET] = TRUE;
5457 conn->bits.tcpconnect[FIRSTSOCKET] = FALSE;
5459 /* if the connection was closed by the server while exchanging
5460 authentication informations, retry with the new set
5461 authentication information */
5462 if(conn->bits.proxy_connect_closed) {
5463 /* reset the error buffer */
5464 if(data->set.errorbuffer)
5465 data->set.errorbuffer[0] = '\0';
5466 data->state.errorbuf = FALSE;
5470 if(CURLE_OK != result)
5474 Curl_pgrsTime(data, TIMER_CONNECT); /* we're connected already */
5475 Curl_pgrsTime(data, TIMER_APPCONNECT); /* we're connected already */
5476 conn->bits.tcpconnect[FIRSTSOCKET] = TRUE;
5477 *protocol_done = TRUE;
5478 Curl_verboseconnect(conn);
5479 Curl_updateconninfo(conn, conn->sock[FIRSTSOCKET]);
5481 /* Stop the loop now */
5485 conn->now = Curl_tvnow(); /* time this *after* the connect is done, we
5486 set this here perhaps a second time */
5490 * This check is quite a hack. We're calling _fsetmode to fix the problem
5491 * with fwrite converting newline characters (you get mangled text files,
5492 * and corrupted binary files when you download to stdout and redirect it to
5496 if((data->set.out)->_handle == NULL) {
5497 _fsetmode(stdout, "b");
5504 CURLcode Curl_connect(struct SessionHandle *data,
5505 struct connectdata **in_connect,
5507 bool *protocol_done)
5511 *asyncp = FALSE; /* assume synchronous resolves by default */
5513 /* call the stuff that needs to be called */
5514 code = create_conn(data, in_connect, asyncp);
5516 if(CURLE_OK == code) {
5518 if((*in_connect)->send_pipe->size || (*in_connect)->recv_pipe->size)
5520 *protocol_done = TRUE;
5522 /* DNS resolution is done: that's either because this is a reused
5523 connection, in which case DNS was unnecessary, or because DNS
5524 really did finish already (synch resolver/fast async resolve) */
5525 code = Curl_setup_conn(*in_connect, protocol_done);
5529 if(code == CURLE_NO_CONNECTION_AVAILABLE) {
5534 if(code && *in_connect) {
5535 /* We're not allowed to return failure with memory left allocated
5536 in the connectdata struct, free those here */
5537 Curl_disconnect(*in_connect, FALSE); /* close the connection */
5538 *in_connect = NULL; /* return a NULL */
5544 CURLcode Curl_done(struct connectdata **connp,
5545 CURLcode status, /* an error if this is called after an
5546 error was detected */
5550 struct connectdata *conn;
5551 struct SessionHandle *data;
5553 DEBUGASSERT(*connp);
5559 /* Stop if Curl_done() has already been called */
5562 Curl_getoff_all_pipelines(data, conn);
5564 if((conn->send_pipe->size + conn->recv_pipe->size != 0 &&
5565 !data->set.reuse_forbid &&
5567 /* Stop if pipeline is not empty and we do not have to close
5571 conn->bits.done = TRUE; /* called just now! */
5573 /* Cleanup possible redirect junk */
5574 if(data->req.newurl) {
5575 free(data->req.newurl);
5576 data->req.newurl = NULL;
5578 if(data->req.location) {
5579 free(data->req.location);
5580 data->req.location = NULL;
5583 Curl_resolver_cancel(conn);
5585 if(conn->dns_entry) {
5586 Curl_resolv_unlock(data, conn->dns_entry); /* done with this */
5587 conn->dns_entry = NULL;
5590 if(status == CURLE_ABORTED_BY_CALLBACK)
5591 /* When we're aborted due to a callback return code it basically have to
5592 be counted as premature as there is trouble ahead if we don't. We have
5593 many callbacks and protocols work differently, we could potentially do
5594 this more fine-grained in the future. */
5597 /* this calls the protocol-specific function pointer previously set */
5598 if(conn->handler->done)
5599 result = conn->handler->done(conn, status, premature);
5603 if(Curl_pgrsDone(conn) && !result)
5604 result = CURLE_ABORTED_BY_CALLBACK;
5606 /* if the transfer was completed in a paused state there can be buffered
5607 data left to write and then kill */
5608 if(data->state.tempwrite) {
5609 free(data->state.tempwrite);
5610 data->state.tempwrite = NULL;
5613 /* if data->set.reuse_forbid is TRUE, it means the libcurl client has
5614 forced us to close this no matter what we think.
5616 if conn->bits.close is TRUE, it means that the connection should be
5617 closed in spite of all our efforts to be nice, due to protocol
5618 restrictions in our or the server's end
5620 if premature is TRUE, it means this connection was said to be DONE before
5621 the entire request operation is complete and thus we can't know in what
5622 state it is for re-using, so we're forced to close it. In a perfect world
5623 we can add code that keep track of if we really must close it here or not,
5624 but currently we have no such detail knowledge.
5626 if(data->set.reuse_forbid || conn->bits.close || premature) {
5627 CURLcode res2 = Curl_disconnect(conn, premature); /* close connection */
5629 /* If we had an error already, make sure we return that one. But
5630 if we got a new error, return that. */
5635 /* the connection is no longer in use */
5636 if(ConnectionDone(data, conn)) {
5637 /* remember the most recently used connection */
5638 data->state.lastconnect = conn;
5640 infof(data, "Connection #%ld to host %s left intact\n",
5641 conn->connection_id,
5642 conn->bits.httpproxy?conn->proxy.dispname:conn->host.dispname);
5645 data->state.lastconnect = NULL;
5648 *connp = NULL; /* to make the caller of this function better detect that
5649 this was either closed or handed over to the connection
5650 cache here, and therefore cannot be used from this point on
5657 * do_init() inits the readwrite session. This is inited each time (in the DO
5658 * function before the protocol-specific DO functions are invoked) for a
5659 * transfer, sometimes multiple times on the same SessionHandle. Make sure
5660 * nothing in here depends on stuff that are setup dynamically for the
5664 static CURLcode do_init(struct connectdata *conn)
5666 struct SessionHandle *data = conn->data;
5667 struct SingleRequest *k = &data->req;
5669 conn->bits.done = FALSE; /* Curl_done() is not called yet */
5670 conn->bits.do_more = FALSE; /* by default there's no curl_do_more() to use */
5671 data->state.expect100header = FALSE;
5673 if(data->set.opt_no_body)
5674 /* in HTTP lingo, no body means using the HEAD request... */
5675 data->set.httpreq = HTTPREQ_HEAD;
5676 else if(HTTPREQ_HEAD == data->set.httpreq)
5677 /* ... but if unset there really is no perfect method that is the
5678 "opposite" of HEAD but in reality most people probably think GET
5679 then. The important thing is that we can't let it remain HEAD if the
5680 opt_no_body is set FALSE since then we'll behave wrong when getting
5682 data->set.httpreq = HTTPREQ_GET;
5684 /* NB: the content encoding software depends on this initialization */
5685 Curl_easy_initHandleData(data);
5687 k->start = Curl_tvnow(); /* start time */
5688 k->now = k->start; /* current time is now */
5689 k->header = TRUE; /* assume header */
5693 k->buf = data->state.buffer;
5694 k->uploadbuf = data->state.uploadbuffer;
5695 k->hbufp = data->state.headerbuff;
5696 k->ignorebody=FALSE;
5698 Curl_speedinit(data);
5700 Curl_pgrsSetUploadCounter(data, 0);
5701 Curl_pgrsSetDownloadCounter(data, 0);
5707 * do_complete is called when the DO actions are complete.
5709 * We init chunking and trailer bits to their default values here immediately
5710 * before receiving any header data for the current request in the pipeline.
5712 static void do_complete(struct connectdata *conn)
5714 conn->data->req.chunk=FALSE;
5715 conn->data->req.maxfd = (conn->sockfd>conn->writesockfd?
5716 conn->sockfd:conn->writesockfd)+1;
5717 Curl_pgrsTime(conn->data, TIMER_PRETRANSFER);
5720 CURLcode Curl_do(struct connectdata **connp, bool *done)
5722 CURLcode result=CURLE_OK;
5723 struct connectdata *conn = *connp;
5724 struct SessionHandle *data = conn->data;
5726 if(conn->handler->do_it) {
5727 /* generic protocol-specific function pointer set in curl_connect() */
5728 result = conn->handler->do_it(conn, done);
5730 /* This was formerly done in transfer.c, but we better do it here */
5731 if((CURLE_SEND_ERROR == result) && conn->bits.reuse) {
5733 * If the connection is using an easy handle, call reconnect
5734 * to re-establish the connection. Otherwise, let the multi logic
5735 * figure out how to re-establish the connection.
5738 result = Curl_reconnect_request(connp);
5740 if(result == CURLE_OK) {
5741 /* ... finally back to actually retry the DO phase */
5742 conn = *connp; /* re-assign conn since Curl_reconnect_request
5743 creates a new connection */
5744 result = conn->handler->do_it(conn, done);
5751 if((result == CURLE_OK) && *done)
5752 /* do_complete must be called after the protocol-specific DO function */
5759 * Curl_do_more() is called during the DO_MORE multi state. It is basically a
5760 * second stage DO state which (wrongly) was introduced to support FTP's
5761 * second connection.
5763 * TODO: A future libcurl should be able to work away this state.
5767 CURLcode Curl_do_more(struct connectdata *conn, bool *completed)
5769 CURLcode result=CURLE_OK;
5773 if(conn->handler->do_more)
5774 result = conn->handler->do_more(conn, completed);
5776 if(!result && *completed)
5777 /* do_complete must be called after the protocol-specific DO function */
5783 /* Called on connect, and if there's already a protocol-specific struct
5784 allocated for a different connection, this frees it that it can be setup
5785 properly later on. */
5786 void Curl_reset_reqproto(struct connectdata *conn)
5788 struct SessionHandle *data = conn->data;
5789 if(data->state.proto.generic && data->state.current_conn != conn) {
5790 free(data->state.proto.generic);
5791 data->state.proto.generic = NULL;
5793 data->state.current_conn = conn;