From 6a03ab3ad4f1835f47a8fcbc6a8b4a070541d4e6 Mon Sep 17 00:00:00 2001 From: Daniel Stenberg Date: Thu, 8 Jun 2006 22:43:21 +0000 Subject: [PATCH] lib525.c does a FTP upload with PORT using multi interface --- tests/libtest/Makefile.am | 6 +- tests/libtest/lib525.c | 129 ++++++++++++++++++++++++++++++++++++++ 2 files changed, 134 insertions(+), 1 deletion(-) create mode 100644 tests/libtest/lib525.c diff --git a/tests/libtest/Makefile.am b/tests/libtest/Makefile.am index 2af887726..95cd9fb9f 100644 --- a/tests/libtest/Makefile.am +++ b/tests/libtest/Makefile.am @@ -40,7 +40,7 @@ SUPPORTFILES = first.c test.h # These are all libcurl test programs noinst_PROGRAMS = lib500 lib501 lib502 lib503 lib504 lib505 lib506 lib507 \ lib508 lib509 lib510 lib511 lib512 lib513 lib514 lib515 lib516 lib517 \ - lib518 lib519 lib520 lib521 lib523 lib524 + lib518 lib519 lib520 lib521 lib523 lib524 lib525 lib500_SOURCES = lib500.c $(SUPPORTFILES) lib500_LDADD = $(LIBDIR)/libcurl.la @@ -137,3 +137,7 @@ lib523_DEPENDENCIES = $(LIBDIR)/libcurl.la lib524_SOURCES = lib524.c $(SUPPORTFILES) lib524_LDADD = $(LIBDIR)/libcurl.la lib524_DEPENDENCIES = $(LIBDIR)/libcurl.la + +lib525_SOURCES = lib525.c $(SUPPORTFILES) +lib525_LDADD = $(LIBDIR)/libcurl.la +lib525_DEPENDENCIES = $(LIBDIR)/libcurl.la diff --git a/tests/libtest/lib525.c b/tests/libtest/lib525.c new file mode 100644 index 000000000..b4cde12a2 --- /dev/null +++ b/tests/libtest/lib525.c @@ -0,0 +1,129 @@ +/***************************************************************************** + * _ _ ____ _ + * Project ___| | | | _ \| | + * / __| | | | |_) | | + * | (__| |_| | _ <| |___ + * \___|\___/|_| \_\_____| + * + * $Id$ + */ + +#include "test.h" + +#include +#include +#include + +int test(char *URL) +{ + CURLMcode res = CURLE_OK; + CURL *curl; + FILE *hd_src ; + int hd ; + struct stat file_info; + int running; + char done=FALSE; + CURLM *m; + + /* get the file size of the local file */ + hd = open(arg2, O_RDONLY) ; + fstat(hd, &file_info); + close(hd) ; + + /* get a FILE * of the same file, could also be made with + fdopen() from the previous descriptor, but hey this is just + an example! */ + hd_src = fopen(arg2, "rb"); + + /* In windows, this will init the winsock stuff */ + curl_global_init(CURL_GLOBAL_ALL); + + /* get a curl handle */ + curl = curl_easy_init(); + if(!curl) + return 100; /* major bad */ + + + /* enable uploading */ + curl_easy_setopt(curl, CURLOPT_UPLOAD, TRUE) ; + + /* specify target */ + curl_easy_setopt(curl,CURLOPT_URL, URL); + + /* go verbose */ + curl_easy_setopt(curl, CURLOPT_VERBOSE, 1); + + /* use active FTP */ + curl_easy_setopt(curl, CURLOPT_FTPPORT, "-"); + + /* now specify which file to upload */ + curl_easy_setopt(curl, CURLOPT_READDATA, hd_src); + + /* NOTE: if you want this code to work on Windows with libcurl as a DLL, you + MUST also provide a read callback with CURLOPT_READFUNCTION. Failing to + do so will give you a crash since a DLL may not use the variable's memory + when passed in to it from an app like this. */ + + /* Set the size of the file to upload (optional). If you give a *_LARGE + option you MUST make sure that the type of the passed-in argument is a + curl_off_t. If you use CURLOPT_INFILESIZE (without _LARGE) you must + make sure that to pass in a type 'long' argument. */ + curl_easy_setopt(curl, CURLOPT_INFILESIZE_LARGE, + (curl_off_t)file_info.st_size); + + m = curl_multi_init(); + + res = curl_multi_add_handle(m, curl); + + while(!done) { + fd_set rd, wr, exc; + int max_fd; + struct timeval interval; + + interval.tv_sec = 1; + interval.tv_usec = 0; + + while (res == CURLM_CALL_MULTI_PERFORM) { + res = curl_multi_perform(m, &running); + if (running <= 0) { + done = TRUE; + break; + } + } + if(done) + break; + + if (res != CURLM_OK) { + fprintf(stderr, "not okay???\n"); + break; + } + + FD_ZERO(&rd); + FD_ZERO(&wr); + FD_ZERO(&exc); + max_fd = 0; + + if (curl_multi_fdset(m, &rd, &wr, &exc, &max_fd) != CURLM_OK) { + fprintf(stderr, "unexpected failured of fdset.\n"); + res = 189; + break; + } + + if (select(max_fd+1, &rd, &wr, &exc, &interval) == -1) { + fprintf(stderr, "bad select??\n"); + res = 195; + break; + } + + res = CURLM_CALL_MULTI_PERFORM; + } + + curl_multi_remove_handle(m, curl); + curl_easy_cleanup(curl); + curl_multi_cleanup(m); + + fclose(hd_src); /* close the local file */ + + curl_global_cleanup(); + return (int)res; +}