183 lines
		
	
	
		
			4.4 KiB
		
	
	
	
		
			C
		
	
	
	
	
	
			
		
		
	
	
			183 lines
		
	
	
		
			4.4 KiB
		
	
	
	
		
			C
		
	
	
	
	
	
| /*****************************************************************************
 | |
|  *                                  _   _ ____  _
 | |
|  *  Project                     ___| | | |  _ \| |
 | |
|  *                             / __| | | | |_) | |
 | |
|  *                            | (__| |_| |  _ <| |___
 | |
|  *                             \___|\___/|_| \_\_____|
 | |
|  *
 | |
|  * $Id: multi-debugcallback.c,v 1.4 2008-05-22 21:20:09 danf Exp $
 | |
|  *
 | |
|  * This is a very simple example using the multi interface and the debug
 | |
|  * callback.
 | |
|  */
 | |
| 
 | |
| #include <stdio.h>
 | |
| #include <string.h>
 | |
| 
 | |
| /* somewhat unix-specific */
 | |
| #include <sys/time.h>
 | |
| #include <unistd.h>
 | |
| 
 | |
| /* curl stuff */
 | |
| #include <curl/curl.h>
 | |
| 
 | |
| typedef char bool;
 | |
| #define TRUE 1
 | |
| 
 | |
| static
 | |
| void dump(const char *text,
 | |
|           FILE *stream, unsigned char *ptr, size_t size,
 | |
|           bool 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, "%s, %zd bytes (0x%zx)\n", text, size, size);
 | |
| 
 | |
|   for(i=0; i<size; i+= width) {
 | |
| 
 | |
|     fprintf(stream, "%04zx: ", i);
 | |
| 
 | |
|     if(!nohex) {
 | |
|       /* hex not disabled, show it */
 | |
|       for(c = 0; c < width; c++)
 | |
|         if(i+c < size)
 | |
|           fprintf(stream, "%02x ", ptr[i+c]);
 | |
|         else
 | |
|           fputs("   ", stream);
 | |
|     }
 | |
| 
 | |
|     for(c = 0; (c < width) && (i+c < size); c++) {
 | |
|       /* check for 0D0A; if found, skip past and start a new line of output */
 | |
|       if (nohex && (i+c+1 < size) && ptr[i+c]==0x0D && ptr[i+c+1]==0x0A) {
 | |
|         i+=(c+2-width);
 | |
|         break;
 | |
|       }
 | |
|       fprintf(stream, "%c",
 | |
|               (ptr[i+c]>=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)
 | |
| {
 | |
|   const char *text;
 | |
| 
 | |
|   (void)handle; /* prevent compiler warning */
 | |
| 
 | |
|   switch (type) {
 | |
|   case CURLINFO_TEXT:
 | |
|     fprintf(stderr, "== Info: %s", 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";
 | |
|     break;
 | |
|   case CURLINFO_HEADER_IN:
 | |
|     text = "<= Recv header";
 | |
|     break;
 | |
|   case CURLINFO_DATA_IN:
 | |
|     text = "<= Recv data";
 | |
|     break;
 | |
|   }
 | |
| 
 | |
|   dump(text, stderr, data, size, TRUE);
 | |
|   return 0;
 | |
| }
 | |
| 
 | |
| /*
 | |
|  * Simply download a HTTP file.
 | |
|  */
 | |
| int main(int argc, char **argv)
 | |
| {
 | |
|   CURL *http_handle;
 | |
|   CURLM *multi_handle;
 | |
| 
 | |
|   int still_running; /* keep number of running handles */
 | |
| 
 | |
|   http_handle = curl_easy_init();
 | |
| 
 | |
|   /* set the options (I left out a few, you'll get the point anyway) */
 | |
|   curl_easy_setopt(http_handle, CURLOPT_URL, "http://www.haxx.se/");
 | |
| 
 | |
|   curl_easy_setopt(http_handle, CURLOPT_DEBUGFUNCTION, my_trace);
 | |
|   curl_easy_setopt(http_handle, CURLOPT_VERBOSE, 1L);
 | |
| 
 | |
|   /* init a multi stack */
 | |
|   multi_handle = curl_multi_init();
 | |
| 
 | |
|   /* add the individual transfers */
 | |
|   curl_multi_add_handle(multi_handle, http_handle);
 | |
| 
 | |
|   /* we start some action by calling perform right away */
 | |
|   while(CURLM_CALL_MULTI_PERFORM ==
 | |
|         curl_multi_perform(multi_handle, &still_running));
 | |
| 
 | |
|   while(still_running) {
 | |
|     struct timeval timeout;
 | |
|     int rc; /* select() return code */
 | |
| 
 | |
|     fd_set fdread;
 | |
|     fd_set fdwrite;
 | |
|     fd_set fdexcep;
 | |
|     int maxfd;
 | |
| 
 | |
|     FD_ZERO(&fdread);
 | |
|     FD_ZERO(&fdwrite);
 | |
|     FD_ZERO(&fdexcep);
 | |
| 
 | |
|     /* set a suitable timeout to play around with */
 | |
|     timeout.tv_sec = 1;
 | |
|     timeout.tv_usec = 0;
 | |
| 
 | |
|     /* get file descriptors from the transfers */
 | |
|     curl_multi_fdset(multi_handle, &fdread, &fdwrite, &fdexcep, &maxfd);
 | |
| 
 | |
|     /* In a real-world program you OF COURSE check the return code of the
 | |
|        function calls, *and* you make sure that maxfd is bigger than -1
 | |
|        so that the call to select() below makes sense! */
 | |
| 
 | |
|     rc = select(maxfd+1, &fdread, &fdwrite, &fdexcep, &timeout);
 | |
| 
 | |
|     switch(rc) {
 | |
|     case -1:
 | |
|       /* select error */
 | |
|       still_running = 0;
 | |
|       printf("select() returns error, this is badness\n");
 | |
|       break;
 | |
|     case 0:
 | |
|     default:
 | |
|       /* timeout or readable/writable sockets */
 | |
|       while(CURLM_CALL_MULTI_PERFORM ==
 | |
|             curl_multi_perform(multi_handle, &still_running));
 | |
|       break;
 | |
|     }
 | |
|   }
 | |
| 
 | |
|   curl_multi_cleanup(multi_handle);
 | |
| 
 | |
|   curl_easy_cleanup(http_handle);
 | |
| 
 | |
|   return 0;
 | |
| }
 |