113498266Sopenharmony_ci/*************************************************************************** 213498266Sopenharmony_ci * _ _ ____ _ 313498266Sopenharmony_ci * Project ___| | | | _ \| | 413498266Sopenharmony_ci * / __| | | | |_) | | 513498266Sopenharmony_ci * | (__| |_| | _ <| |___ 613498266Sopenharmony_ci * \___|\___/|_| \_\_____| 713498266Sopenharmony_ci * 813498266Sopenharmony_ci * Copyright (C) Daniel Stenberg, <daniel@haxx.se>, et al. 913498266Sopenharmony_ci * 1013498266Sopenharmony_ci * This software is licensed as described in the file COPYING, which 1113498266Sopenharmony_ci * you should have received as part of this distribution. The terms 1213498266Sopenharmony_ci * are also available at https://curl.se/docs/copyright.html. 1313498266Sopenharmony_ci * 1413498266Sopenharmony_ci * You may opt to use, copy, modify, merge, publish, distribute and/or sell 1513498266Sopenharmony_ci * copies of the Software, and permit persons to whom the Software is 1613498266Sopenharmony_ci * furnished to do so, under the terms of the COPYING file. 1713498266Sopenharmony_ci * 1813498266Sopenharmony_ci * This software is distributed on an "AS IS" basis, WITHOUT WARRANTY OF ANY 1913498266Sopenharmony_ci * KIND, either express or implied. 2013498266Sopenharmony_ci * 2113498266Sopenharmony_ci * SPDX-License-Identifier: curl 2213498266Sopenharmony_ci * 2313498266Sopenharmony_ci ***************************************************************************/ 2413498266Sopenharmony_ci/* <DESC> 2513498266Sopenharmony_ci * multi interface code doing two parallel HTTP transfers 2613498266Sopenharmony_ci * </DESC> 2713498266Sopenharmony_ci */ 2813498266Sopenharmony_ci#include <stdio.h> 2913498266Sopenharmony_ci#include <string.h> 3013498266Sopenharmony_ci 3113498266Sopenharmony_ci/* somewhat unix-specific */ 3213498266Sopenharmony_ci#include <sys/time.h> 3313498266Sopenharmony_ci#include <unistd.h> 3413498266Sopenharmony_ci 3513498266Sopenharmony_ci/* curl stuff */ 3613498266Sopenharmony_ci#include <curl/curl.h> 3713498266Sopenharmony_ci 3813498266Sopenharmony_ci/* 3913498266Sopenharmony_ci * Simply download two HTTP files! 4013498266Sopenharmony_ci */ 4113498266Sopenharmony_ciint main(void) 4213498266Sopenharmony_ci{ 4313498266Sopenharmony_ci CURL *http_handle; 4413498266Sopenharmony_ci CURL *http_handle2; 4513498266Sopenharmony_ci CURLM *multi_handle; 4613498266Sopenharmony_ci 4713498266Sopenharmony_ci int still_running = 1; /* keep number of running handles */ 4813498266Sopenharmony_ci 4913498266Sopenharmony_ci http_handle = curl_easy_init(); 5013498266Sopenharmony_ci http_handle2 = curl_easy_init(); 5113498266Sopenharmony_ci 5213498266Sopenharmony_ci /* set options */ 5313498266Sopenharmony_ci curl_easy_setopt(http_handle, CURLOPT_URL, "https://www.example.com/"); 5413498266Sopenharmony_ci 5513498266Sopenharmony_ci /* set options */ 5613498266Sopenharmony_ci curl_easy_setopt(http_handle2, CURLOPT_URL, "http://localhost/"); 5713498266Sopenharmony_ci 5813498266Sopenharmony_ci /* init a multi stack */ 5913498266Sopenharmony_ci multi_handle = curl_multi_init(); 6013498266Sopenharmony_ci 6113498266Sopenharmony_ci /* add the individual transfers */ 6213498266Sopenharmony_ci curl_multi_add_handle(multi_handle, http_handle); 6313498266Sopenharmony_ci curl_multi_add_handle(multi_handle, http_handle2); 6413498266Sopenharmony_ci 6513498266Sopenharmony_ci while(still_running) { 6613498266Sopenharmony_ci CURLMsg *msg; 6713498266Sopenharmony_ci int queued; 6813498266Sopenharmony_ci CURLMcode mc = curl_multi_perform(multi_handle, &still_running); 6913498266Sopenharmony_ci 7013498266Sopenharmony_ci if(still_running) 7113498266Sopenharmony_ci /* wait for activity, timeout or "nothing" */ 7213498266Sopenharmony_ci mc = curl_multi_poll(multi_handle, NULL, 0, 1000, NULL); 7313498266Sopenharmony_ci 7413498266Sopenharmony_ci if(mc) 7513498266Sopenharmony_ci break; 7613498266Sopenharmony_ci 7713498266Sopenharmony_ci do { 7813498266Sopenharmony_ci msg = curl_multi_info_read(multi_handle, &queued); 7913498266Sopenharmony_ci if(msg) { 8013498266Sopenharmony_ci if(msg->msg == CURLMSG_DONE) { 8113498266Sopenharmony_ci /* a transfer ended */ 8213498266Sopenharmony_ci fprintf(stderr, "Transfer completed\n"); 8313498266Sopenharmony_ci } 8413498266Sopenharmony_ci } 8513498266Sopenharmony_ci } while(msg); 8613498266Sopenharmony_ci } 8713498266Sopenharmony_ci 8813498266Sopenharmony_ci curl_multi_remove_handle(multi_handle, http_handle); 8913498266Sopenharmony_ci curl_multi_remove_handle(multi_handle, http_handle2); 9013498266Sopenharmony_ci 9113498266Sopenharmony_ci curl_multi_cleanup(multi_handle); 9213498266Sopenharmony_ci 9313498266Sopenharmony_ci curl_easy_cleanup(http_handle); 9413498266Sopenharmony_ci curl_easy_cleanup(http_handle2); 9513498266Sopenharmony_ci 9613498266Sopenharmony_ci return 0; 9713498266Sopenharmony_ci} 98