Return to lib555.c CVS log | Up to [ELWIX - Embedded LightWeight unIX -] / embedaddon / curl / tests / libtest |
1.1 ! misho 1: /*************************************************************************** ! 2: * _ _ ____ _ ! 3: * Project ___| | | | _ \| | ! 4: * / __| | | | |_) | | ! 5: * | (__| |_| | _ <| |___ ! 6: * \___|\___/|_| \_\_____| ! 7: * ! 8: * Copyright (C) 1998 - 2018, Daniel Stenberg, <daniel@haxx.se>, et al. ! 9: * ! 10: * This software is licensed as described in the file COPYING, which ! 11: * you should have received as part of this distribution. The terms ! 12: * are also available at https://curl.haxx.se/docs/copyright.html. ! 13: * ! 14: * You may opt to use, copy, modify, merge, publish, distribute and/or sell ! 15: * copies of the Software, and permit persons to whom the Software is ! 16: * furnished to do so, under the terms of the COPYING file. ! 17: * ! 18: * This software is distributed on an "AS IS" basis, WITHOUT WARRANTY OF ANY ! 19: * KIND, either express or implied. ! 20: * ! 21: ***************************************************************************/ ! 22: ! 23: /* This test case is supposed to be identical to 547 except that this uses the ! 24: * multi interface and 547 is easy interface. ! 25: * ! 26: * argv1 = URL ! 27: * argv2 = proxy ! 28: * argv3 = proxyuser:password ! 29: */ ! 30: ! 31: #include "test.h" ! 32: #include "testutil.h" ! 33: #include "warnless.h" ! 34: #include "memdebug.h" ! 35: ! 36: #define TEST_HANG_TIMEOUT 60 * 1000 ! 37: ! 38: static const char uploadthis[] = ! 39: #ifdef CURL_DOES_CONVERSIONS ! 40: /* ASCII representation with escape sequences for non-ASCII platforms */ ! 41: "\x74\x68\x69\x73\x20\x69\x73\x20\x74\x68\x65\x20\x62\x6c\x75\x72" ! 42: "\x62\x20\x77\x65\x20\x77\x61\x6e\x74\x20\x74\x6f\x20\x75\x70\x6c" ! 43: "\x6f\x61\x64\x0a"; ! 44: #else ! 45: "this is the blurb we want to upload\n"; ! 46: #endif ! 47: ! 48: static size_t readcallback(void *ptr, ! 49: size_t size, ! 50: size_t nmemb, ! 51: void *clientp) ! 52: { ! 53: int *counter = (int *)clientp; ! 54: ! 55: if(*counter) { ! 56: /* only do this once and then require a clearing of this */ ! 57: fprintf(stderr, "READ ALREADY DONE!\n"); ! 58: return 0; ! 59: } ! 60: (*counter)++; /* bump */ ! 61: ! 62: if(size * nmemb > strlen(uploadthis)) { ! 63: fprintf(stderr, "READ!\n"); ! 64: strcpy(ptr, uploadthis); ! 65: return strlen(uploadthis); ! 66: } ! 67: fprintf(stderr, "READ NOT FINE!\n"); ! 68: return 0; ! 69: } ! 70: static curlioerr ioctlcallback(CURL *handle, ! 71: int cmd, ! 72: void *clientp) ! 73: { ! 74: int *counter = (int *)clientp; ! 75: (void)handle; /* unused */ ! 76: if(cmd == CURLIOCMD_RESTARTREAD) { ! 77: fprintf(stderr, "REWIND!\n"); ! 78: *counter = 0; /* clear counter to make the read callback restart */ ! 79: } ! 80: return CURLIOE_OK; ! 81: } ! 82: ! 83: ! 84: int test(char *URL) ! 85: { ! 86: int res = 0; ! 87: CURL *curl = NULL; ! 88: int counter = 0; ! 89: CURLM *m = NULL; ! 90: int running = 1; ! 91: ! 92: start_test_timing(); ! 93: ! 94: global_init(CURL_GLOBAL_ALL); ! 95: ! 96: easy_init(curl); ! 97: ! 98: easy_setopt(curl, CURLOPT_URL, URL); ! 99: easy_setopt(curl, CURLOPT_VERBOSE, 1L); ! 100: easy_setopt(curl, CURLOPT_HEADER, 1L); ! 101: ! 102: /* read the POST data from a callback */ ! 103: easy_setopt(curl, CURLOPT_IOCTLFUNCTION, ioctlcallback); ! 104: easy_setopt(curl, CURLOPT_IOCTLDATA, &counter); ! 105: easy_setopt(curl, CURLOPT_READFUNCTION, readcallback); ! 106: easy_setopt(curl, CURLOPT_READDATA, &counter); ! 107: /* We CANNOT do the POST fine without setting the size (or choose ! 108: chunked)! */ ! 109: easy_setopt(curl, CURLOPT_POSTFIELDSIZE, (long)strlen(uploadthis)); ! 110: ! 111: easy_setopt(curl, CURLOPT_POST, 1L); ! 112: easy_setopt(curl, CURLOPT_PROXY, libtest_arg2); ! 113: easy_setopt(curl, CURLOPT_PROXYUSERPWD, libtest_arg3); ! 114: easy_setopt(curl, CURLOPT_PROXYAUTH, ! 115: (long) (CURLAUTH_NTLM | CURLAUTH_DIGEST | CURLAUTH_BASIC) ); ! 116: ! 117: multi_init(m); ! 118: ! 119: multi_add_handle(m, curl); ! 120: ! 121: while(running) { ! 122: struct timeval timeout; ! 123: fd_set fdread, fdwrite, fdexcep; ! 124: int maxfd = -99; ! 125: ! 126: timeout.tv_sec = 0; ! 127: timeout.tv_usec = 100000L; /* 100 ms */ ! 128: ! 129: multi_perform(m, &running); ! 130: ! 131: abort_on_test_timeout(); ! 132: ! 133: #ifdef TPF ! 134: sleep(1); /* avoid ctl-10 dump */ ! 135: #endif ! 136: ! 137: if(!running) ! 138: break; /* done */ ! 139: ! 140: FD_ZERO(&fdread); ! 141: FD_ZERO(&fdwrite); ! 142: FD_ZERO(&fdexcep); ! 143: ! 144: multi_fdset(m, &fdread, &fdwrite, &fdexcep, &maxfd); ! 145: ! 146: /* At this point, maxfd is guaranteed to be greater or equal than -1. */ ! 147: ! 148: select_test(maxfd + 1, &fdread, &fdwrite, &fdexcep, &timeout); ! 149: ! 150: abort_on_test_timeout(); ! 151: } ! 152: ! 153: test_cleanup: ! 154: ! 155: /* proper cleanup sequence - type PA */ ! 156: ! 157: curl_multi_remove_handle(m, curl); ! 158: curl_multi_cleanup(m); ! 159: curl_easy_cleanup(curl); ! 160: curl_global_cleanup(); ! 161: ! 162: return res; ! 163: }