1e6cd738ed3716c02557fb3a47515244e949ade39Bertrand SIMONNET/*************************************************************************** 2e6cd738ed3716c02557fb3a47515244e949ade39Bertrand SIMONNET * _ _ ____ _ 3e6cd738ed3716c02557fb3a47515244e949ade39Bertrand SIMONNET * Project ___| | | | _ \| | 4e6cd738ed3716c02557fb3a47515244e949ade39Bertrand SIMONNET * / __| | | | |_) | | 5e6cd738ed3716c02557fb3a47515244e949ade39Bertrand SIMONNET * | (__| |_| | _ <| |___ 6e6cd738ed3716c02557fb3a47515244e949ade39Bertrand SIMONNET * \___|\___/|_| \_\_____| 7e6cd738ed3716c02557fb3a47515244e949ade39Bertrand SIMONNET * 8d15eaac64ca1a7244824d660ea84e8815a23d058Alex Deymo * Copyright (C) 1998 - 2016, Daniel Stenberg, <daniel@haxx.se>, et al. 9e6cd738ed3716c02557fb3a47515244e949ade39Bertrand SIMONNET * 10e6cd738ed3716c02557fb3a47515244e949ade39Bertrand SIMONNET * This software is licensed as described in the file COPYING, which 11e6cd738ed3716c02557fb3a47515244e949ade39Bertrand SIMONNET * you should have received as part of this distribution. The terms 12d15eaac64ca1a7244824d660ea84e8815a23d058Alex Deymo * are also available at https://curl.haxx.se/docs/copyright.html. 13e6cd738ed3716c02557fb3a47515244e949ade39Bertrand SIMONNET * 14e6cd738ed3716c02557fb3a47515244e949ade39Bertrand SIMONNET * You may opt to use, copy, modify, merge, publish, distribute and/or sell 15e6cd738ed3716c02557fb3a47515244e949ade39Bertrand SIMONNET * copies of the Software, and permit persons to whom the Software is 16e6cd738ed3716c02557fb3a47515244e949ade39Bertrand SIMONNET * furnished to do so, under the terms of the COPYING file. 17e6cd738ed3716c02557fb3a47515244e949ade39Bertrand SIMONNET * 18e6cd738ed3716c02557fb3a47515244e949ade39Bertrand SIMONNET * This software is distributed on an "AS IS" basis, WITHOUT WARRANTY OF ANY 19e6cd738ed3716c02557fb3a47515244e949ade39Bertrand SIMONNET * KIND, either express or implied. 20e6cd738ed3716c02557fb3a47515244e949ade39Bertrand SIMONNET * 21e6cd738ed3716c02557fb3a47515244e949ade39Bertrand SIMONNET ***************************************************************************/ 22d15eaac64ca1a7244824d660ea84e8815a23d058Alex Deymo/* <DESC> 23d15eaac64ca1a7244824d660ea84e8815a23d058Alex Deymo * Multiplexed HTTP/2 downloads over a single connection 24d15eaac64ca1a7244824d660ea84e8815a23d058Alex Deymo * </DESC> 25d15eaac64ca1a7244824d660ea84e8815a23d058Alex Deymo */ 26e6cd738ed3716c02557fb3a47515244e949ade39Bertrand SIMONNET#include <stdio.h> 27e6cd738ed3716c02557fb3a47515244e949ade39Bertrand SIMONNET#include <stdlib.h> 28d15eaac64ca1a7244824d660ea84e8815a23d058Alex Deymo#include <string.h> 29e6cd738ed3716c02557fb3a47515244e949ade39Bertrand SIMONNET 30e6cd738ed3716c02557fb3a47515244e949ade39Bertrand SIMONNET/* somewhat unix-specific */ 31e6cd738ed3716c02557fb3a47515244e949ade39Bertrand SIMONNET#include <sys/time.h> 32e6cd738ed3716c02557fb3a47515244e949ade39Bertrand SIMONNET#include <unistd.h> 33e6cd738ed3716c02557fb3a47515244e949ade39Bertrand SIMONNET 34e6cd738ed3716c02557fb3a47515244e949ade39Bertrand SIMONNET/* curl stuff */ 35e6cd738ed3716c02557fb3a47515244e949ade39Bertrand SIMONNET#include <curl/curl.h> 36e6cd738ed3716c02557fb3a47515244e949ade39Bertrand SIMONNET 37e6cd738ed3716c02557fb3a47515244e949ade39Bertrand SIMONNET#ifndef CURLPIPE_MULTIPLEX 38e6cd738ed3716c02557fb3a47515244e949ade39Bertrand SIMONNET/* This little trick will just make sure that we don't enable pipelining for 39e6cd738ed3716c02557fb3a47515244e949ade39Bertrand SIMONNET libcurls old enough to not have this symbol. It is _not_ defined to zero in 40e6cd738ed3716c02557fb3a47515244e949ade39Bertrand SIMONNET a recent libcurl header. */ 41e6cd738ed3716c02557fb3a47515244e949ade39Bertrand SIMONNET#define CURLPIPE_MULTIPLEX 0 42e6cd738ed3716c02557fb3a47515244e949ade39Bertrand SIMONNET#endif 43e6cd738ed3716c02557fb3a47515244e949ade39Bertrand SIMONNET 44e6cd738ed3716c02557fb3a47515244e949ade39Bertrand SIMONNET#define NUM_HANDLES 1000 45e6cd738ed3716c02557fb3a47515244e949ade39Bertrand SIMONNET 46e6cd738ed3716c02557fb3a47515244e949ade39Bertrand SIMONNETvoid *curl_hnd[NUM_HANDLES]; 47e6cd738ed3716c02557fb3a47515244e949ade39Bertrand SIMONNETint num_transfers; 48e6cd738ed3716c02557fb3a47515244e949ade39Bertrand SIMONNET 49e6cd738ed3716c02557fb3a47515244e949ade39Bertrand SIMONNET/* a handle to number lookup, highly ineffective when we do many 50e6cd738ed3716c02557fb3a47515244e949ade39Bertrand SIMONNET transfers... */ 51e6cd738ed3716c02557fb3a47515244e949ade39Bertrand SIMONNETstatic int hnd2num(CURL *hnd) 52e6cd738ed3716c02557fb3a47515244e949ade39Bertrand SIMONNET{ 53e6cd738ed3716c02557fb3a47515244e949ade39Bertrand SIMONNET int i; 54e6cd738ed3716c02557fb3a47515244e949ade39Bertrand SIMONNET for(i=0; i< num_transfers; i++) { 55e6cd738ed3716c02557fb3a47515244e949ade39Bertrand SIMONNET if(curl_hnd[i] == hnd) 56e6cd738ed3716c02557fb3a47515244e949ade39Bertrand SIMONNET return i; 57e6cd738ed3716c02557fb3a47515244e949ade39Bertrand SIMONNET } 58e6cd738ed3716c02557fb3a47515244e949ade39Bertrand SIMONNET return 0; /* weird, but just a fail-safe */ 59e6cd738ed3716c02557fb3a47515244e949ade39Bertrand SIMONNET} 60e6cd738ed3716c02557fb3a47515244e949ade39Bertrand SIMONNET 61e6cd738ed3716c02557fb3a47515244e949ade39Bertrand SIMONNETstatic 62e6cd738ed3716c02557fb3a47515244e949ade39Bertrand SIMONNETvoid dump(const char *text, int num, unsigned char *ptr, size_t size, 63e6cd738ed3716c02557fb3a47515244e949ade39Bertrand SIMONNET char nohex) 64e6cd738ed3716c02557fb3a47515244e949ade39Bertrand SIMONNET{ 65e6cd738ed3716c02557fb3a47515244e949ade39Bertrand SIMONNET size_t i; 66e6cd738ed3716c02557fb3a47515244e949ade39Bertrand SIMONNET size_t c; 67e6cd738ed3716c02557fb3a47515244e949ade39Bertrand SIMONNET 68e6cd738ed3716c02557fb3a47515244e949ade39Bertrand SIMONNET unsigned int width=0x10; 69e6cd738ed3716c02557fb3a47515244e949ade39Bertrand SIMONNET 70e6cd738ed3716c02557fb3a47515244e949ade39Bertrand SIMONNET if(nohex) 71e6cd738ed3716c02557fb3a47515244e949ade39Bertrand SIMONNET /* without the hex output, we can fit more on screen */ 72e6cd738ed3716c02557fb3a47515244e949ade39Bertrand SIMONNET width = 0x40; 73e6cd738ed3716c02557fb3a47515244e949ade39Bertrand SIMONNET 74e6cd738ed3716c02557fb3a47515244e949ade39Bertrand SIMONNET fprintf(stderr, "%d %s, %ld bytes (0x%lx)\n", 75e6cd738ed3716c02557fb3a47515244e949ade39Bertrand SIMONNET num, text, (long)size, (long)size); 76e6cd738ed3716c02557fb3a47515244e949ade39Bertrand SIMONNET 77e6cd738ed3716c02557fb3a47515244e949ade39Bertrand SIMONNET for(i=0; i<size; i+= width) { 78e6cd738ed3716c02557fb3a47515244e949ade39Bertrand SIMONNET 79e6cd738ed3716c02557fb3a47515244e949ade39Bertrand SIMONNET fprintf(stderr, "%4.4lx: ", (long)i); 80e6cd738ed3716c02557fb3a47515244e949ade39Bertrand SIMONNET 81e6cd738ed3716c02557fb3a47515244e949ade39Bertrand SIMONNET if(!nohex) { 82e6cd738ed3716c02557fb3a47515244e949ade39Bertrand SIMONNET /* hex not disabled, show it */ 83e6cd738ed3716c02557fb3a47515244e949ade39Bertrand SIMONNET for(c = 0; c < width; c++) 84e6cd738ed3716c02557fb3a47515244e949ade39Bertrand SIMONNET if(i+c < size) 85e6cd738ed3716c02557fb3a47515244e949ade39Bertrand SIMONNET fprintf(stderr, "%02x ", ptr[i+c]); 86e6cd738ed3716c02557fb3a47515244e949ade39Bertrand SIMONNET else 87e6cd738ed3716c02557fb3a47515244e949ade39Bertrand SIMONNET fputs(" ", stderr); 88e6cd738ed3716c02557fb3a47515244e949ade39Bertrand SIMONNET } 89e6cd738ed3716c02557fb3a47515244e949ade39Bertrand SIMONNET 90e6cd738ed3716c02557fb3a47515244e949ade39Bertrand SIMONNET for(c = 0; (c < width) && (i+c < size); c++) { 91e6cd738ed3716c02557fb3a47515244e949ade39Bertrand SIMONNET /* check for 0D0A; if found, skip past and start a new line of output */ 92d15eaac64ca1a7244824d660ea84e8815a23d058Alex Deymo if(nohex && (i+c+1 < size) && ptr[i+c]==0x0D && ptr[i+c+1]==0x0A) { 93e6cd738ed3716c02557fb3a47515244e949ade39Bertrand SIMONNET i+=(c+2-width); 94e6cd738ed3716c02557fb3a47515244e949ade39Bertrand SIMONNET break; 95e6cd738ed3716c02557fb3a47515244e949ade39Bertrand SIMONNET } 96e6cd738ed3716c02557fb3a47515244e949ade39Bertrand SIMONNET fprintf(stderr, "%c", 97e6cd738ed3716c02557fb3a47515244e949ade39Bertrand SIMONNET (ptr[i+c]>=0x20) && (ptr[i+c]<0x80)?ptr[i+c]:'.'); 98e6cd738ed3716c02557fb3a47515244e949ade39Bertrand SIMONNET /* check again for 0D0A, to avoid an extra \n if it's at width */ 99d15eaac64ca1a7244824d660ea84e8815a23d058Alex Deymo if(nohex && (i+c+2 < size) && ptr[i+c+1]==0x0D && ptr[i+c+2]==0x0A) { 100e6cd738ed3716c02557fb3a47515244e949ade39Bertrand SIMONNET i+=(c+3-width); 101e6cd738ed3716c02557fb3a47515244e949ade39Bertrand SIMONNET break; 102e6cd738ed3716c02557fb3a47515244e949ade39Bertrand SIMONNET } 103e6cd738ed3716c02557fb3a47515244e949ade39Bertrand SIMONNET } 104e6cd738ed3716c02557fb3a47515244e949ade39Bertrand SIMONNET fputc('\n', stderr); /* newline */ 105e6cd738ed3716c02557fb3a47515244e949ade39Bertrand SIMONNET } 106e6cd738ed3716c02557fb3a47515244e949ade39Bertrand SIMONNET} 107e6cd738ed3716c02557fb3a47515244e949ade39Bertrand SIMONNET 108e6cd738ed3716c02557fb3a47515244e949ade39Bertrand SIMONNETstatic 109e6cd738ed3716c02557fb3a47515244e949ade39Bertrand SIMONNETint my_trace(CURL *handle, curl_infotype type, 110e6cd738ed3716c02557fb3a47515244e949ade39Bertrand SIMONNET char *data, size_t size, 111e6cd738ed3716c02557fb3a47515244e949ade39Bertrand SIMONNET void *userp) 112e6cd738ed3716c02557fb3a47515244e949ade39Bertrand SIMONNET{ 113e6cd738ed3716c02557fb3a47515244e949ade39Bertrand SIMONNET const char *text; 114e6cd738ed3716c02557fb3a47515244e949ade39Bertrand SIMONNET int num = hnd2num(handle); 115e6cd738ed3716c02557fb3a47515244e949ade39Bertrand SIMONNET (void)handle; /* prevent compiler warning */ 116e6cd738ed3716c02557fb3a47515244e949ade39Bertrand SIMONNET (void)userp; 117e6cd738ed3716c02557fb3a47515244e949ade39Bertrand SIMONNET switch (type) { 118e6cd738ed3716c02557fb3a47515244e949ade39Bertrand SIMONNET case CURLINFO_TEXT: 119e6cd738ed3716c02557fb3a47515244e949ade39Bertrand SIMONNET fprintf(stderr, "== %d Info: %s", num, data); 120e6cd738ed3716c02557fb3a47515244e949ade39Bertrand SIMONNET default: /* in case a new one is introduced to shock us */ 121e6cd738ed3716c02557fb3a47515244e949ade39Bertrand SIMONNET return 0; 122e6cd738ed3716c02557fb3a47515244e949ade39Bertrand SIMONNET 123e6cd738ed3716c02557fb3a47515244e949ade39Bertrand SIMONNET case CURLINFO_HEADER_OUT: 124e6cd738ed3716c02557fb3a47515244e949ade39Bertrand SIMONNET text = "=> Send header"; 125e6cd738ed3716c02557fb3a47515244e949ade39Bertrand SIMONNET break; 126e6cd738ed3716c02557fb3a47515244e949ade39Bertrand SIMONNET case CURLINFO_DATA_OUT: 127e6cd738ed3716c02557fb3a47515244e949ade39Bertrand SIMONNET text = "=> Send data"; 128e6cd738ed3716c02557fb3a47515244e949ade39Bertrand SIMONNET break; 129e6cd738ed3716c02557fb3a47515244e949ade39Bertrand SIMONNET case CURLINFO_SSL_DATA_OUT: 130e6cd738ed3716c02557fb3a47515244e949ade39Bertrand SIMONNET text = "=> Send SSL data"; 131e6cd738ed3716c02557fb3a47515244e949ade39Bertrand SIMONNET break; 132e6cd738ed3716c02557fb3a47515244e949ade39Bertrand SIMONNET case CURLINFO_HEADER_IN: 133e6cd738ed3716c02557fb3a47515244e949ade39Bertrand SIMONNET text = "<= Recv header"; 134e6cd738ed3716c02557fb3a47515244e949ade39Bertrand SIMONNET break; 135e6cd738ed3716c02557fb3a47515244e949ade39Bertrand SIMONNET case CURLINFO_DATA_IN: 136e6cd738ed3716c02557fb3a47515244e949ade39Bertrand SIMONNET text = "<= Recv data"; 137e6cd738ed3716c02557fb3a47515244e949ade39Bertrand SIMONNET break; 138e6cd738ed3716c02557fb3a47515244e949ade39Bertrand SIMONNET case CURLINFO_SSL_DATA_IN: 139e6cd738ed3716c02557fb3a47515244e949ade39Bertrand SIMONNET text = "<= Recv SSL data"; 140e6cd738ed3716c02557fb3a47515244e949ade39Bertrand SIMONNET break; 141e6cd738ed3716c02557fb3a47515244e949ade39Bertrand SIMONNET } 142e6cd738ed3716c02557fb3a47515244e949ade39Bertrand SIMONNET 143e6cd738ed3716c02557fb3a47515244e949ade39Bertrand SIMONNET dump(text, num, (unsigned char *)data, size, 1); 144e6cd738ed3716c02557fb3a47515244e949ade39Bertrand SIMONNET return 0; 145e6cd738ed3716c02557fb3a47515244e949ade39Bertrand SIMONNET} 146e6cd738ed3716c02557fb3a47515244e949ade39Bertrand SIMONNET 147e6cd738ed3716c02557fb3a47515244e949ade39Bertrand SIMONNETstatic void setup(CURL *hnd, int num) 148e6cd738ed3716c02557fb3a47515244e949ade39Bertrand SIMONNET{ 149e6cd738ed3716c02557fb3a47515244e949ade39Bertrand SIMONNET FILE *out; 150e6cd738ed3716c02557fb3a47515244e949ade39Bertrand SIMONNET char filename[128]; 151e6cd738ed3716c02557fb3a47515244e949ade39Bertrand SIMONNET 152d15eaac64ca1a7244824d660ea84e8815a23d058Alex Deymo snprintf(filename, 128, "dl-%d", num); 153e6cd738ed3716c02557fb3a47515244e949ade39Bertrand SIMONNET 154e6cd738ed3716c02557fb3a47515244e949ade39Bertrand SIMONNET out = fopen(filename, "wb"); 155e6cd738ed3716c02557fb3a47515244e949ade39Bertrand SIMONNET 156e6cd738ed3716c02557fb3a47515244e949ade39Bertrand SIMONNET /* write to this file */ 157e6cd738ed3716c02557fb3a47515244e949ade39Bertrand SIMONNET curl_easy_setopt(hnd, CURLOPT_WRITEDATA, out); 158e6cd738ed3716c02557fb3a47515244e949ade39Bertrand SIMONNET 159e6cd738ed3716c02557fb3a47515244e949ade39Bertrand SIMONNET /* set the same URL */ 160e6cd738ed3716c02557fb3a47515244e949ade39Bertrand SIMONNET curl_easy_setopt(hnd, CURLOPT_URL, "https://localhost:8443/index.html"); 161e6cd738ed3716c02557fb3a47515244e949ade39Bertrand SIMONNET 162e6cd738ed3716c02557fb3a47515244e949ade39Bertrand SIMONNET /* send it verbose for max debuggaility */ 163e6cd738ed3716c02557fb3a47515244e949ade39Bertrand SIMONNET curl_easy_setopt(hnd, CURLOPT_VERBOSE, 1L); 164e6cd738ed3716c02557fb3a47515244e949ade39Bertrand SIMONNET curl_easy_setopt(hnd, CURLOPT_DEBUGFUNCTION, my_trace); 165e6cd738ed3716c02557fb3a47515244e949ade39Bertrand SIMONNET 166e6cd738ed3716c02557fb3a47515244e949ade39Bertrand SIMONNET /* HTTP/2 please */ 167e6cd738ed3716c02557fb3a47515244e949ade39Bertrand SIMONNET curl_easy_setopt(hnd, CURLOPT_HTTP_VERSION, CURL_HTTP_VERSION_2_0); 168e6cd738ed3716c02557fb3a47515244e949ade39Bertrand SIMONNET 169e6cd738ed3716c02557fb3a47515244e949ade39Bertrand SIMONNET /* we use a self-signed test server, skip verification during debugging */ 170e6cd738ed3716c02557fb3a47515244e949ade39Bertrand SIMONNET curl_easy_setopt(hnd, CURLOPT_SSL_VERIFYPEER, 0L); 171e6cd738ed3716c02557fb3a47515244e949ade39Bertrand SIMONNET curl_easy_setopt(hnd, CURLOPT_SSL_VERIFYHOST, 0L); 172e6cd738ed3716c02557fb3a47515244e949ade39Bertrand SIMONNET 173e6cd738ed3716c02557fb3a47515244e949ade39Bertrand SIMONNET#if (CURLPIPE_MULTIPLEX > 0) 174e6cd738ed3716c02557fb3a47515244e949ade39Bertrand SIMONNET /* wait for pipe connection to confirm */ 175e6cd738ed3716c02557fb3a47515244e949ade39Bertrand SIMONNET curl_easy_setopt(hnd, CURLOPT_PIPEWAIT, 1L); 176e6cd738ed3716c02557fb3a47515244e949ade39Bertrand SIMONNET#endif 177e6cd738ed3716c02557fb3a47515244e949ade39Bertrand SIMONNET 178e6cd738ed3716c02557fb3a47515244e949ade39Bertrand SIMONNET curl_hnd[num] = hnd; 179e6cd738ed3716c02557fb3a47515244e949ade39Bertrand SIMONNET} 180e6cd738ed3716c02557fb3a47515244e949ade39Bertrand SIMONNET 181e6cd738ed3716c02557fb3a47515244e949ade39Bertrand SIMONNET/* 182e6cd738ed3716c02557fb3a47515244e949ade39Bertrand SIMONNET * Simply download two files over HTTP/2, using the same physical connection! 183e6cd738ed3716c02557fb3a47515244e949ade39Bertrand SIMONNET */ 184e6cd738ed3716c02557fb3a47515244e949ade39Bertrand SIMONNETint main(int argc, char **argv) 185e6cd738ed3716c02557fb3a47515244e949ade39Bertrand SIMONNET{ 186e6cd738ed3716c02557fb3a47515244e949ade39Bertrand SIMONNET CURL *easy[NUM_HANDLES]; 187e6cd738ed3716c02557fb3a47515244e949ade39Bertrand SIMONNET CURLM *multi_handle; 188e6cd738ed3716c02557fb3a47515244e949ade39Bertrand SIMONNET int i; 189e6cd738ed3716c02557fb3a47515244e949ade39Bertrand SIMONNET int still_running; /* keep number of running handles */ 190e6cd738ed3716c02557fb3a47515244e949ade39Bertrand SIMONNET 191e6cd738ed3716c02557fb3a47515244e949ade39Bertrand SIMONNET if(argc > 1) 192e6cd738ed3716c02557fb3a47515244e949ade39Bertrand SIMONNET /* if given a number, do that many transfers */ 193e6cd738ed3716c02557fb3a47515244e949ade39Bertrand SIMONNET num_transfers = atoi(argv[1]); 194e6cd738ed3716c02557fb3a47515244e949ade39Bertrand SIMONNET 195e6cd738ed3716c02557fb3a47515244e949ade39Bertrand SIMONNET if(!num_transfers || (num_transfers > NUM_HANDLES)) 196e6cd738ed3716c02557fb3a47515244e949ade39Bertrand SIMONNET num_transfers = 3; /* a suitable low default */ 197e6cd738ed3716c02557fb3a47515244e949ade39Bertrand SIMONNET 198e6cd738ed3716c02557fb3a47515244e949ade39Bertrand SIMONNET /* init a multi stack */ 199e6cd738ed3716c02557fb3a47515244e949ade39Bertrand SIMONNET multi_handle = curl_multi_init(); 200e6cd738ed3716c02557fb3a47515244e949ade39Bertrand SIMONNET 201e6cd738ed3716c02557fb3a47515244e949ade39Bertrand SIMONNET for(i=0; i<num_transfers; i++) { 202e6cd738ed3716c02557fb3a47515244e949ade39Bertrand SIMONNET easy[i] = curl_easy_init(); 203e6cd738ed3716c02557fb3a47515244e949ade39Bertrand SIMONNET /* set options */ 204e6cd738ed3716c02557fb3a47515244e949ade39Bertrand SIMONNET setup(easy[i], i); 205e6cd738ed3716c02557fb3a47515244e949ade39Bertrand SIMONNET 206e6cd738ed3716c02557fb3a47515244e949ade39Bertrand SIMONNET /* add the individual transfer */ 207e6cd738ed3716c02557fb3a47515244e949ade39Bertrand SIMONNET curl_multi_add_handle(multi_handle, easy[i]); 208e6cd738ed3716c02557fb3a47515244e949ade39Bertrand SIMONNET } 209e6cd738ed3716c02557fb3a47515244e949ade39Bertrand SIMONNET 210e6cd738ed3716c02557fb3a47515244e949ade39Bertrand SIMONNET curl_multi_setopt(multi_handle, CURLMOPT_PIPELINING, CURLPIPE_MULTIPLEX); 211e6cd738ed3716c02557fb3a47515244e949ade39Bertrand SIMONNET 212e6cd738ed3716c02557fb3a47515244e949ade39Bertrand SIMONNET /* we start some action by calling perform right away */ 213e6cd738ed3716c02557fb3a47515244e949ade39Bertrand SIMONNET curl_multi_perform(multi_handle, &still_running); 214e6cd738ed3716c02557fb3a47515244e949ade39Bertrand SIMONNET 215e6cd738ed3716c02557fb3a47515244e949ade39Bertrand SIMONNET do { 216e6cd738ed3716c02557fb3a47515244e949ade39Bertrand SIMONNET struct timeval timeout; 217e6cd738ed3716c02557fb3a47515244e949ade39Bertrand SIMONNET int rc; /* select() return code */ 218e6cd738ed3716c02557fb3a47515244e949ade39Bertrand SIMONNET CURLMcode mc; /* curl_multi_fdset() return code */ 219e6cd738ed3716c02557fb3a47515244e949ade39Bertrand SIMONNET 220e6cd738ed3716c02557fb3a47515244e949ade39Bertrand SIMONNET fd_set fdread; 221e6cd738ed3716c02557fb3a47515244e949ade39Bertrand SIMONNET fd_set fdwrite; 222e6cd738ed3716c02557fb3a47515244e949ade39Bertrand SIMONNET fd_set fdexcep; 223e6cd738ed3716c02557fb3a47515244e949ade39Bertrand SIMONNET int maxfd = -1; 224e6cd738ed3716c02557fb3a47515244e949ade39Bertrand SIMONNET 225e6cd738ed3716c02557fb3a47515244e949ade39Bertrand SIMONNET long curl_timeo = -1; 226e6cd738ed3716c02557fb3a47515244e949ade39Bertrand SIMONNET 227e6cd738ed3716c02557fb3a47515244e949ade39Bertrand SIMONNET FD_ZERO(&fdread); 228e6cd738ed3716c02557fb3a47515244e949ade39Bertrand SIMONNET FD_ZERO(&fdwrite); 229e6cd738ed3716c02557fb3a47515244e949ade39Bertrand SIMONNET FD_ZERO(&fdexcep); 230e6cd738ed3716c02557fb3a47515244e949ade39Bertrand SIMONNET 231e6cd738ed3716c02557fb3a47515244e949ade39Bertrand SIMONNET /* set a suitable timeout to play around with */ 232e6cd738ed3716c02557fb3a47515244e949ade39Bertrand SIMONNET timeout.tv_sec = 1; 233e6cd738ed3716c02557fb3a47515244e949ade39Bertrand SIMONNET timeout.tv_usec = 0; 234e6cd738ed3716c02557fb3a47515244e949ade39Bertrand SIMONNET 235e6cd738ed3716c02557fb3a47515244e949ade39Bertrand SIMONNET curl_multi_timeout(multi_handle, &curl_timeo); 236e6cd738ed3716c02557fb3a47515244e949ade39Bertrand SIMONNET if(curl_timeo >= 0) { 237e6cd738ed3716c02557fb3a47515244e949ade39Bertrand SIMONNET timeout.tv_sec = curl_timeo / 1000; 238e6cd738ed3716c02557fb3a47515244e949ade39Bertrand SIMONNET if(timeout.tv_sec > 1) 239e6cd738ed3716c02557fb3a47515244e949ade39Bertrand SIMONNET timeout.tv_sec = 1; 240e6cd738ed3716c02557fb3a47515244e949ade39Bertrand SIMONNET else 241e6cd738ed3716c02557fb3a47515244e949ade39Bertrand SIMONNET timeout.tv_usec = (curl_timeo % 1000) * 1000; 242e6cd738ed3716c02557fb3a47515244e949ade39Bertrand SIMONNET } 243e6cd738ed3716c02557fb3a47515244e949ade39Bertrand SIMONNET 244e6cd738ed3716c02557fb3a47515244e949ade39Bertrand SIMONNET /* get file descriptors from the transfers */ 245e6cd738ed3716c02557fb3a47515244e949ade39Bertrand SIMONNET mc = curl_multi_fdset(multi_handle, &fdread, &fdwrite, &fdexcep, &maxfd); 246e6cd738ed3716c02557fb3a47515244e949ade39Bertrand SIMONNET 247d15eaac64ca1a7244824d660ea84e8815a23d058Alex Deymo if(mc != CURLM_OK) { 248e6cd738ed3716c02557fb3a47515244e949ade39Bertrand SIMONNET fprintf(stderr, "curl_multi_fdset() failed, code %d.\n", mc); 249e6cd738ed3716c02557fb3a47515244e949ade39Bertrand SIMONNET break; 250e6cd738ed3716c02557fb3a47515244e949ade39Bertrand SIMONNET } 251e6cd738ed3716c02557fb3a47515244e949ade39Bertrand SIMONNET 252e6cd738ed3716c02557fb3a47515244e949ade39Bertrand SIMONNET /* On success the value of maxfd is guaranteed to be >= -1. We call 253e6cd738ed3716c02557fb3a47515244e949ade39Bertrand SIMONNET select(maxfd + 1, ...); specially in case of (maxfd == -1) there are 254e6cd738ed3716c02557fb3a47515244e949ade39Bertrand SIMONNET no fds ready yet so we call select(0, ...) --or Sleep() on Windows-- 255e6cd738ed3716c02557fb3a47515244e949ade39Bertrand SIMONNET to sleep 100ms, which is the minimum suggested value in the 256e6cd738ed3716c02557fb3a47515244e949ade39Bertrand SIMONNET curl_multi_fdset() doc. */ 257e6cd738ed3716c02557fb3a47515244e949ade39Bertrand SIMONNET 258e6cd738ed3716c02557fb3a47515244e949ade39Bertrand SIMONNET if(maxfd == -1) { 259e6cd738ed3716c02557fb3a47515244e949ade39Bertrand SIMONNET#ifdef _WIN32 260e6cd738ed3716c02557fb3a47515244e949ade39Bertrand SIMONNET Sleep(100); 261e6cd738ed3716c02557fb3a47515244e949ade39Bertrand SIMONNET rc = 0; 262e6cd738ed3716c02557fb3a47515244e949ade39Bertrand SIMONNET#else 263e6cd738ed3716c02557fb3a47515244e949ade39Bertrand SIMONNET /* Portable sleep for platforms other than Windows. */ 264e6cd738ed3716c02557fb3a47515244e949ade39Bertrand SIMONNET struct timeval wait = { 0, 100 * 1000 }; /* 100ms */ 265e6cd738ed3716c02557fb3a47515244e949ade39Bertrand SIMONNET rc = select(0, NULL, NULL, NULL, &wait); 266e6cd738ed3716c02557fb3a47515244e949ade39Bertrand SIMONNET#endif 267e6cd738ed3716c02557fb3a47515244e949ade39Bertrand SIMONNET } 268e6cd738ed3716c02557fb3a47515244e949ade39Bertrand SIMONNET else { 269e6cd738ed3716c02557fb3a47515244e949ade39Bertrand SIMONNET /* Note that on some platforms 'timeout' may be modified by select(). 270e6cd738ed3716c02557fb3a47515244e949ade39Bertrand SIMONNET If you need access to the original value save a copy beforehand. */ 271e6cd738ed3716c02557fb3a47515244e949ade39Bertrand SIMONNET rc = select(maxfd+1, &fdread, &fdwrite, &fdexcep, &timeout); 272e6cd738ed3716c02557fb3a47515244e949ade39Bertrand SIMONNET } 273e6cd738ed3716c02557fb3a47515244e949ade39Bertrand SIMONNET 274e6cd738ed3716c02557fb3a47515244e949ade39Bertrand SIMONNET switch(rc) { 275e6cd738ed3716c02557fb3a47515244e949ade39Bertrand SIMONNET case -1: 276e6cd738ed3716c02557fb3a47515244e949ade39Bertrand SIMONNET /* select error */ 277e6cd738ed3716c02557fb3a47515244e949ade39Bertrand SIMONNET break; 278e6cd738ed3716c02557fb3a47515244e949ade39Bertrand SIMONNET case 0: 279e6cd738ed3716c02557fb3a47515244e949ade39Bertrand SIMONNET default: 280e6cd738ed3716c02557fb3a47515244e949ade39Bertrand SIMONNET /* timeout or readable/writable sockets */ 281e6cd738ed3716c02557fb3a47515244e949ade39Bertrand SIMONNET curl_multi_perform(multi_handle, &still_running); 282e6cd738ed3716c02557fb3a47515244e949ade39Bertrand SIMONNET break; 283e6cd738ed3716c02557fb3a47515244e949ade39Bertrand SIMONNET } 284e6cd738ed3716c02557fb3a47515244e949ade39Bertrand SIMONNET } while(still_running); 285e6cd738ed3716c02557fb3a47515244e949ade39Bertrand SIMONNET 286e6cd738ed3716c02557fb3a47515244e949ade39Bertrand SIMONNET curl_multi_cleanup(multi_handle); 287e6cd738ed3716c02557fb3a47515244e949ade39Bertrand SIMONNET 288e6cd738ed3716c02557fb3a47515244e949ade39Bertrand SIMONNET for(i=0; i<num_transfers; i++) 289e6cd738ed3716c02557fb3a47515244e949ade39Bertrand SIMONNET curl_easy_cleanup(easy[i]); 290e6cd738ed3716c02557fb3a47515244e949ade39Bertrand SIMONNET 291e6cd738ed3716c02557fb3a47515244e949ade39Bertrand SIMONNET return 0; 292e6cd738ed3716c02557fb3a47515244e949ade39Bertrand SIMONNET} 293