/***************************************************************************** * _ _ ____ _ * Project ___| | | | _ \| | * / __| | | | |_) | | * | (__| |_| | _ <| |___ * \___|\___/|_| \_\_____| * * $Id: lib500.c,v 1.9 2008-09-20 04:26:56 yangtse Exp $ */ #include #ifndef _MSC_VER #include #include #else // _MSC_VER #include #define bool unsigned int #define true 1 #define false 0 #define __bool_true_false_are_defined 1 #define usleep(x) Sleep( (x) / 1000 ) #define snprintf _snprintf #endif // _MSC_VER #include #define numChannels 2 #define activeFtp false #define DEFAULT_TIMEOUT_MILLISECS 250 #define MAX_TIMEOUT_MILLISECS 1000 #define URL "ftp://localhost/tmp" #define USERPWD "name:password" struct data { char trace_ascii; /* 1 or 0 */ }; static void dump(CURL *handle, const char *text, FILE *stream, unsigned char *ptr, size_t size, char nohex) { size_t i; size_t c; unsigned int width=0x10; if(nohex) /* without the hex output, we can fit more on screen */ width = 0x40; fprintf(stream, "[%p] %s, %zd bytes (0x%zx)\n", handle, text, size, size); for(i=0; i=0x20) && (ptr[i+c]<0x80)?ptr[i+c]:'.'); /* check again for 0D0A, to avoid an extra \n if it's at width */ if (nohex && (i+c+2 < size) && ptr[i+c+1]==0x0D && ptr[i+c+2]==0x0A) { i+=(c+3-width); break; } } fputc('\n', stream); /* newline */ } fflush(stream); } static int my_trace(CURL *handle, curl_infotype type, char *data, size_t size, void *userp) { struct data *config = (struct data *)userp; const char *text; switch (type) { case CURLINFO_TEXT: fprintf(stderr, "[%p] == Info: %s", handle, data); default: /* in case a new one is introduced to shock us */ return 0; case CURLINFO_HEADER_OUT: text = "=> Send header"; break; case CURLINFO_DATA_OUT: text = "=> Send data"; return 0; /* ignore this data */ case CURLINFO_SSL_DATA_OUT: text = "=> Send SSL data"; break; case CURLINFO_HEADER_IN: text = "<= Recv header"; break; case CURLINFO_DATA_IN: text = "<= Recv data"; break; case CURLINFO_SSL_DATA_IN: text = "<= Recv SSL data"; break; } dump(handle, text, stderr, (unsigned char *)data, size, config->trace_ascii); return 0; } struct upload { const char *path; const char *data; int repeat; int count; }; static size_t CurlReadCallback( void *ptr, size_t size, size_t nmemb, void *stream ) { struct upload *up = (struct upload *)stream; (void)size; (void)nmemb; /* we repeat sending the data until count repeat cycles are complete */ if(up->count++ >= up->repeat) return 0; strcpy(ptr, up->data); return strlen(up->data); } int main(void) { const char *userPassword = USERPWD; CURLM* curlMulti = curl_multi_init(); CURL *curlEasy[numChannels]; int i; int running_handles; CURLMcode multiResult; bool result = true; int indx=0; char urlbuffer[256]; long timeout; int fdMax; fd_set fdRead, fdWrite, fdException; struct data config; config.trace_ascii = 1; /* enable ascii tracing */ struct upload updata[]= { {"file01", "mooo", 12, 0}, {"file02", "more than the 1234456789", 10, 0}, {"file03", "mooo123", 100, 0}, {"file04", "more than the 1234456789 ABC", 400, 0}, {"file05", "more than the 1234456789 ABC more than the 1234456789 ABC more than the 1234456789 ABC more than the 1234456789 ABC more than the 1234456789 ABC more than the 1234456789 ABC more than the 1234456789 ABC", 170, 0}, {"file06", "more than the 1234456789 ABC more than the 1234456789 ABC more than the 1234456789 ABC more than the 1234456789 ABC more than the 1234456789 ABC more than the 1234456789 ABC more than the 1234456789 ABC more than the 1234456789 ABC more than the 1234456789 ABC more than the 1234456789 ABC more than the 1234456789 ABC more than the 1234456789 ABC more than the 1234456789 ABC more than the 1234456789 ABC more than the 1234456789 ABC more than the 1234456789 ABC more than the 1234456789 ABC more than the 1234456789 ABC more than the 1234456789 ABC more than the 1234456789 ABC more than the 1234456789 ABC", 123, 0}, {"file07", "more than the 1234456789 ABC", 116, 0}, {"file08", "mooo123 mooo123 mooo123asd fhsdah fhjasdjkfjhasd jfd hjsdasfjhdsfhjsdaas djjhsdajhf hjsd fj jhsdajsld jhsdh jhasd fjasd jh jhsd jhsda jadfj kjhsd jh jsdslafkasd fhsdah fhjasdjkfjhasd jfd hjsdasfjhdsfhjsdaas djjhsdajhf hjsd fj jhsdajsld jhsdh jhasd fjasd jh jhsd jhsda jadfj kjhsd jh jsdslafkasd fhsdah fhjasdjkfjhasd jfd hjsdasfjhdsfhjsdaas djjhsdajhf hjsd fj jhsdajsld jhsdh jhasd fjasd jh jhsd jhsda jadfj kjhsd jh jsdslafkasd fhsdah fhjasdjkfjhasd jfd hjsdasfjhdsfhjsdaas djjhsdajhf hjsd fj jhsdajsld jhsdh jhasd fjasd jh jhsd jhsda jadfj kjhsd jh jsdslafkasd fhsdah fhjasdjkfjhasd jfd hjsdasfjhdsfhjsdaas djjhsdajhf hjsd fj jhsdajsld jhsdh jhasd fjasd jh jhsd jhsda jadfj kjhsd jh jsdslafk", 1, 0}, {"file09", "asd fhsdah fhjasdjkfjhasd jfd hjsdasfjhdsfhjsdaas djjhsdajhf hjsd fj jhsdajsld jhsdh jhasd fjasd jh jhsd jhsda jadfj kjhsd jh jsdslafk", 33, 0}, {"file10", "mooosaysthecowanddisappears!mooosaysthecowanddisappears!mooosaysthecowanddisappears", 200, 0}, {"file11", "mooo", 1, 0}, {"file12", "more than the 1234456789", 134, 0}, {"file13", "mooo123", 6, 0}, {"file14", "more than the 1234456789 ABC", 99, 0}, {"file15", "more than the 1234456789 ABC more than the 1234456789 ABC more than the 1234456789 ABC more than the 1234456789 ABC more than the 1234456789 ABC more than the 1234456789 ABC more than the 1234456789 ABC", 112, 0}, {"file16", "more than the 1234456789 ABC more than the 1234456789 ABC more than the 1234456789 ABC more than the 1234456789 ABC more than the 1234456789 ABC more than the 1234456789 ABC more than the 1234456789 ABC more than the 1234456789 ABC more than the 1234456789 ABC more than the 1234456789 ABC more than the 1234456789 ABC more than the 1234456789 ABC more than the 1234456789 ABC more than the 1234456789 ABC more than the 1234456789 ABC more than the 1234456789 ABC more than the 1234456789 ABC more than the 1234456789 ABC more than the 1234456789 ABC more than the 1234456789 ABC more than the 1234456789 ABC", 210, 0}, {"file17", "more than the 1234456789 ABC", 170, 0}, {"file18", "mooo123 mooo123 mooo123", 200, 0}, {"file19", "asd fhsdah fhjasdjkfjhasd jfd hjsdasfjhdsfhjsdaas djjhsdajhf hjsd fj jhsdajsld jhsdh jhasd fjasd jh jhsd jhsda jadfj kjhsd jh jsdslafk", 12, 0}, {"file20", "mooosaysthecowanddisappears!mooosaysthecowanddisappears!mooosaysthecowanddisappears", 23, 0}, {"file21", "mooo", 34, 0}, {"file22", "more than the 1234456789", 45, 0}, {"file23", "mooo123", 56, 0}, {"file24", "more than the 1234456789 ABC", 67, 0}, {"file25", "more than the 1234456789 ABC more than the 1234456789 ABC more than the 1234456789 ABC more than the 1234456789 ABC more than the 1234456789 ABC more than the 1234456789 ABC more than the 1234456789 ABC", 78, 0}, {"file26", "more than the 1234456789 ABC more than the 1234456789 ABC more than the 1234456789 ABC more than the 1234456789 ABC more than the 1234456789 ABC more than the 1234456789 ABC more than the 1234456789 ABC more than the 1234456789 ABC more than the 1234456789 ABC more than the 1234456789 ABC more than the 1234456789 ABC more than the 1234456789 ABC more than the 1234456789 ABC more than the 1234456789 ABC more than the 1234456789 ABC more than the 1234456789 ABC more than the 1234456789 ABC more than the 1234456789 ABC more than the 1234456789 ABC more than the 1234456789 ABC more than the 1234456789 ABC", 389, 0}, {"file27", "more than the 1234456789 ABC", 90, 0}, {"file28", "mooo123 mooo123 mooo123", 100, 0}, {"file29", "asd fhsdah fhjasdjkfjhasd jfd hjsdasfjhdsfhjsdaas djjhsdajhf hjsd fj jhsdajsld jhsdh jhasd fjasd jh jhsd jhsda jadfj kjhsd jh jsdslafkasd fhsdah fhjasdjkfjhasd jfd hjsdasfjhdsfhjsdaas djjhsdajhf hjsd fj jhsdajsld jhsdh jhasd fjasd jh jhsd jhsda jadfj kjhsd jh jsdslafkasd fhsdah fhjasdjkfjhasd jfd hjsdasfjhdsfhjsdaas djjhsdajhf hjsd fj jhsdajsld jhsdh jhasd fjasd jh jhsd jhsda jadfj kjhsd jh jsdslafkasd fhsdah fhjasdjkfjhasd jfd hjsdasfjhdsfhjsdaas djjhsdajhf hjsd fj jhsdajsld jhsdh jhasd fjasd jh jhsd jhsda jadfj kjhsd jh jsdslafkasd fhsdah fhjasdjkfjhasd jfd hjsdasfjhdsfhjsdaas djjhsdajhf hjsd fj jhsdajsld jhsdh jhasd fjasd jh jhsd jhsda jadfj kjhsd jh jsdslafkasd fhsdah fhjasdjkfjhasd jfd hjsdasfjhdsfhjsdaas djjhsdajhf hjsd fj jhsdajsld jhsdh jhasd fjasd jh jhsd jhsda jadfj kjhsd jh jsdslafk", 750, 0}, {"file30", "mooosaysthecowanddisappears!mooosaysthecowanddisappears!mooosaysthecowanddisappears", 10, 0}, {"file31", "mooo", 1, 0}, {"file32", "more than the 1234456789", 400, 0}, {"file33", "mooo123", 500, 0}, {"file34", "more than the 1234456789 ABC", 315, 0}, {"file35", "more than the 1234456789 ABC more than the 1234456789 ABC more than the 1234456789 ABC more than the 1234456789 ABC more than the 1234456789 ABC more than the 1234456789 ABC more than the 1234456789 ABC", 102, 0}, {"file36", "more than the 1234456789 ABC more than the 1234456789 ABC more than the 1234456789 ABC more than the 1234456789 ABC more than the 1234456789 ABC more than the 1234456789 ABC more than the 1234456789 ABC more than the 1234456789 ABC more than the 1234456789 ABC more than the 1234456789 ABC more than the 1234456789 ABC more than the 1234456789 ABC more than the 1234456789 ABC more than the 1234456789 ABC more than the 1234456789 ABC more than the 1234456789 ABC more than the 1234456789 ABC more than the 1234456789 ABC more than the 1234456789 ABC more than the 1234456789 ABC more than the 1234456789 ABC", 123, 0}, {"file37", "more than the 1234456789 ABC", 450, 0}, {"file38", "mooo123 mooo123 mooo123", 145, 0}, {"file39", "asd fhsdah fhjasdjkfjhasd jfd hjsdasfjhdsfhjsdaas djjhsdajhf hjsd fj jhsdajsld jhsdh jhasd fjasd jh jhsd jhsda jadfj kjhsd jh jsdslafkasd fhsdah fhjasdjkfjhasd jfd hjsdasfjhdsfhjsdaas djjhsdajhf hjsd fj jhsdajsld jhsdh jhasd fjasd jh jhsd jhsda jadfj kjhsd jh jsdslafkasd fhsdah fhjasdjkfjhasd jfd hjsdasfjhdsfhjsdaas djjhsdajhf hjsd fj jhsdajsld jhsdh jhasd fjasd jh jhsd jhsda jadfj kjhsd jh jsdslafkasd fhsdah fhjasdjkfjhasd jfd hjsdasfjhdsfhjsdaas djjhsdajhf hjsd fj jhsdajsld jhsdh jhasd fjasd jh jhsd jhsda jadfj kjhsd jh jsdslafkasd fhsdah fhjasdjkfjhasd jfd hjsdasfjhdsfhjsdaas djjhsdajhf hjsd fj jhsdajsld jhsdh jhasd fjasd jh jhsd jhsda jadfj kjhsd jh jsdslafkasd fhsdah fhjasdjkfjhasd jfd hjsdasfjhdsfhjsdaas djjhsdajhf hjsd fj jhsdajsld jhsdh jhasd fjasd jh jhsd jhsda jadfj kjhsd jh jsdslafk", 223, 0}, {"file40", "mooosaysthecowanddisappears!mooosaysthecowanddisappears!mooosaysthecowanddisappears", 10, 0}, {"file41", "mooo", 1, 0}, {"file42", "more than the 1234456789", 400, 0}, {"file43", "mooo123", 500, 0}, {"file44", "more than the 1234456789 ABC", 75, 0}, {"file45", "more than the 1234456789 ABC more than the 1234456789 ABC more than the 1234456789 ABC more than the 1234456789 ABC more than the 1234456789 ABC more than the 1234456789 ABC more than the 1234456789 ABC", 102, 0}, {"file46", "more than the 1234456789 ABC more than the 1234456789 ABC more than the 1234456789 ABC more than the 1234456789 ABC more than the 1234456789 ABC more than the 1234456789 ABC more than the 1234456789 ABC more than the 1234456789 ABC more than the 1234456789 ABC more than the 1234456789 ABC more than the 1234456789 ABC more than the 1234456789 ABC more than the 1234456789 ABC more than the 1234456789 ABC more than the 1234456789 ABC more than the 1234456789 ABC more than the 1234456789 ABC more than the 1234456789 ABC more than the 1234456789 ABC more than the 1234456789 ABC more than the 1234456789 ABC", 123, 0}, {"file47", "more than the 1234456789 ABC", 50, 0}, {"file48", "mooo123 mooo123 mooo123", 45, 0}, {"file49", "asd fhsdah fhjasdjkfjhasd jfd hjsdasfjhdsfhjsdaas djjhsdajhf hjsd fj jhsdajsld jhsdh jhasd fjasd jh jhsd jhsda jadfj kjhsd jh jsdslafkasd fhsdah fhjasdjkfjhasd jfd hjsdasfjhdsfhjsdaas djjhsdajhf hjsd fj jhsdajsld jhsdh jhasd fjasd jh jhsd jhsda jadfj kjhsd jh jsdslafkasd fhsdah fhjasdjkfjhasd jfd hjsdasfjhdsfhjsdaas djjhsdajhf hjsd fj jhsdajsld jhsdh jhasd fjasd jh jhsd jhsda jadfj kjhsd jh jsdslafkasd fhsdah fhjasdjkfjhasd jfd hjsdasfjhdsfhjsdaas djjhsdajhf hjsd fj jhsdajsld jhsdh jhasd fjasd jh jhsd jhsda jadfj kjhsd jh jsdslafkasd fhsdah fhjasdjkfjhasd jfd hjsdasfjhdsfhjsdaas djjhsdajhf hjsd fj jhsdajsld jhsdh jhasd fjasd jh jhsd jhsda jadfj kjhsd jh jsdslafkasd fhsdah fhjasdjkfjhasd jfd hjsdasfjhdsfhjsdaas djjhsdajhf hjsd fj jhsdajsld jhsdh jhasd fjasd jh jhsd jhsda jadfj kjhsd jh jsdslafk", 123, 0}, {"file50", "mooosaysthecowanddisappears!mooosaysthecowanddisappears!mooosaysthecowanddisappears", 23, 0}, {"file51", "mooo", 34, 0}, {"file52", "more than the 1234456789", 245, 0}, {"file53", "mooo123", 56, 0}, {"file54", "more than the 1234456789 ABC", 67, 0}, {"file55", "more than the 1234456789 ABC more than the 1234456789 ABC more than the 1234456789 ABC more than the 1234456789 ABC more than the 1234456789 ABC more than the 1234456789 ABC more than the 1234456789 ABC", 78, 0}, {"file56", "more than the 1234456789 ABC more than the 1234456789 ABC more than the 1234456789 ABC more than the 1234456789 ABC more than the 1234456789 ABC more than the 1234456789 ABC more than the 1234456789 ABC more than the 1234456789 ABC more than the 1234456789 ABC more than the 1234456789 ABC more than the 1234456789 ABC more than the 1234456789 ABC more than the 1234456789 ABC more than the 1234456789 ABC more than the 1234456789 ABC more than the 1234456789 ABC more than the 1234456789 ABC more than the 1234456789 ABC more than the 1234456789 ABC more than the 1234456789 ABC more than the 1234456789 ABC", 89, 0}, {"file57", "more than the 1234456789 ABC", 590, 0}, {"file58", "mooo123 mooo123 mooo123", 100, 0}, {"file59", "asd fhsdah fhjasdjkfjhasd jfd hjsdasfjhdsfhjsdaas djjhsdajhf hjsd fj jhsdajsld jhsdh jhasd fjasd jh jhsd jhsda jadfj kjhsd jh jsdslafkasd fhsdah fhjasdjkfjhasd jfd hjsdasfjhdsfhjsdaas djjhsdajhf hjsd fj jhsdajsld jhsdh jhasd fjasd jh jhsd jhsda jadfj kjhsd jh jsdslafkasd fhsdah fhjasdjkfjhasd jfd hjsdasfjhdsfhjsdaas djjhsdajhf hjsd fj jhsdajsld jhsdh jhasd fjasd jh jhsd jhsda jadfj kjhsd jh jsdslafkasd fhsdah fhjasdjkfjhasd jfd hjsdasfjhdsfhjsdaas djjhsdajhf hjsd fj jhsdajsld jhsdh jhasd fjasd jh jhsd jhsda jadfj kjhsd jh jsdslafkasd fhsdah fhjasdjkfjhasd jfd hjsdasfjhdsfhjsdaas djjhsdajhf hjsd fj jhsdajsld jhsdh jhasd fjasd jh jhsd jhsda jadfj kjhsd jh jsdslafkasd fhsdah fhjasdjkfjhasd jfd hjsdasfjhdsfhjsdaas djjhsdajhf hjsd fj jhsdajsld jhsdh jhasd fjasd jh jhsd jhsda jadfj kjhsd jh jsdslafk", 250, 0}, {NULL, NULL, 0, 0} /* end of list */ }; for(i = 0; i < numChannels; i++ ) { CURL* easy = curl_easy_init(); snprintf(urlbuffer, sizeof(urlbuffer), "%s/%s", URL, updata[indx].path); printf("WE USE URL(%d) %s\n", indx, urlbuffer); curl_easy_setopt( easy, CURLOPT_UPLOAD, 1 ); curl_easy_setopt( easy, CURLOPT_NOSIGNAL, 1 ); curl_easy_setopt( easy, CURLOPT_NOPROGRESS, 1); curl_easy_setopt( easy, CURLOPT_VERBOSE, 1 ); curl_easy_setopt( easy, CURLOPT_FTP_USE_EPRT, 0 /* use PORT instead */ ); curl_easy_setopt( easy, CURLOPT_FTP_USE_EPSV, 0 /* use PASV instead */ ); curl_easy_setopt( easy, CURLOPT_FTP_FILEMETHOD, CURLFTPMETHOD_MULTICWD ); curl_easy_setopt( easy, CURLOPT_FTP_CREATE_MISSING_DIRS , 1 ); curl_easy_setopt( easy, CURLOPT_SSH_AUTH_TYPES , CURLSSH_AUTH_PASSWORD ); curl_easy_setopt( easy, CURLOPT_USERPWD , userPassword); curl_easy_setopt( easy, CURLOPT_FTPPORT , activeFtp ? "-" : 0 ); curl_easy_setopt( easy, CURLOPT_URL , urlbuffer ); curl_easy_setopt( easy, CURLOPT_READFUNCTION , CurlReadCallback ); curl_easy_setopt( easy, CURLOPT_READDATA , &updata[indx] ); curl_easy_setopt( easy, CURLOPT_DEBUGFUNCTION, my_trace); curl_easy_setopt( easy, CURLOPT_DEBUGDATA, &config); curl_multi_add_handle( curlMulti, easy ); indx++; curlEasy[ i ] = easy; } while( result ) { int num_messages; CURLMsg* curlMsg; /* call curl_multi_perform, as long as it wants to be called: */ while( ( multiResult = curl_multi_perform( curlMulti, &running_handles ) ) == CURLM_CALL_MULTI_PERFORM ); /* now process waiting easy handle messages: */ curlMsg = curl_multi_info_read( curlMulti, &num_messages ); while( curlMsg ) { if( curlMsg->msg == CURLMSG_DONE ) { CURL* easy = curlMsg->easy_handle; CURLcode easyResult = curlMsg->data.result; curl_multi_remove_handle( curlMulti, easy ); if( ( easyResult != CURLE_URL_MALFORMAT ) && ( easyResult != CURLE_OK ) ) { /* serious error occured. */ result = false; break; } /* prepare and resurrect easy handle for next transfer: */ if( updata[indx].path ) { snprintf(urlbuffer, sizeof(urlbuffer), "%s/%s", URL, updata[indx].path); printf("WE USE URL(%d) %s\n", indx, urlbuffer); curl_easy_setopt( easy, CURLOPT_URL , urlbuffer ); curl_easy_setopt( easy, CURLOPT_READFUNCTION, CurlReadCallback); curl_easy_setopt( easy, CURLOPT_READDATA, &updata[indx]); curl_multi_add_handle( curlMulti, easy ); indx++; running_handles++; } } curlMsg = curl_multi_info_read( curlMulti, &num_messages ); } if( !running_handles ) break; /* get curl timeout setting: */ curl_multi_timeout( curlMulti, &timeout ); if( timeout < 0 ) timeout = DEFAULT_TIMEOUT_MILLISECS; if( timeout > MAX_TIMEOUT_MILLISECS ) timeout = MAX_TIMEOUT_MILLISECS; /* check socket action: */ FD_ZERO( &fdRead ); FD_ZERO( &fdWrite ); FD_ZERO( &fdException ); curl_multi_fdset( curlMulti, &fdRead, &fdWrite, &fdException, &fdMax ); if( fdMax != -1 ) { /* socket stuff to do: */ struct timeval tv; int select_result; tv.tv_sec = timeout/1000; tv.tv_usec = (timeout%1000) * 1000; select_result = select( fdMax + 1, &fdRead, &fdWrite, &fdException, &tv ); if( select_result < 0 ) { result = false; break; } } else { usleep( DEFAULT_TIMEOUT_MILLISECS * 1000 ); } } /* clean-up libcurl easy handles: */ for(i = 0; i < numChannels; i++ ) { curl_multi_remove_handle( curlMulti, curlEasy[ i ] ); curl_easy_cleanup( curlEasy[ i ] ); } /* clean-up libcurl multi handle: */ curl_multi_cleanup( curlMulti ); return( result ); }