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.haxx.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#include "test.h" 2513498266Sopenharmony_ci 2613498266Sopenharmony_ci#ifdef HAVE_INET_PTON 2713498266Sopenharmony_ci 2813498266Sopenharmony_ci#ifdef HAVE_NETINET_IN_H 2913498266Sopenharmony_ci#include <netinet/in.h> 3013498266Sopenharmony_ci#endif 3113498266Sopenharmony_ci#ifdef HAVE_SYS_SOCKET_H 3213498266Sopenharmony_ci#include <sys/socket.h> 3313498266Sopenharmony_ci#endif 3413498266Sopenharmony_ci#ifdef HAVE_ARPA_INET_H 3513498266Sopenharmony_ci#include <arpa/inet.h> 3613498266Sopenharmony_ci#endif 3713498266Sopenharmony_ci 3813498266Sopenharmony_ci#include "memdebug.h" 3913498266Sopenharmony_ci 4013498266Sopenharmony_ci/* to prevent libcurl from closing our socket */ 4113498266Sopenharmony_cistatic int closesocket_cb(void *clientp, curl_socket_t item) 4213498266Sopenharmony_ci{ 4313498266Sopenharmony_ci (void)clientp; 4413498266Sopenharmony_ci (void)item; 4513498266Sopenharmony_ci return 0; 4613498266Sopenharmony_ci} 4713498266Sopenharmony_ci 4813498266Sopenharmony_ci/* provide our own socket */ 4913498266Sopenharmony_cistatic curl_socket_t socket_cb(void *clientp, 5013498266Sopenharmony_ci curlsocktype purpose, 5113498266Sopenharmony_ci struct curl_sockaddr *address) 5213498266Sopenharmony_ci{ 5313498266Sopenharmony_ci int s = *(int *)clientp; 5413498266Sopenharmony_ci (void)purpose; 5513498266Sopenharmony_ci (void)address; 5613498266Sopenharmony_ci return (curl_socket_t)s; 5713498266Sopenharmony_ci} 5813498266Sopenharmony_ci 5913498266Sopenharmony_ci/* tell libcurl the socket is connected */ 6013498266Sopenharmony_cistatic int sockopt_cb(void *clientp, 6113498266Sopenharmony_ci curl_socket_t curlfd, 6213498266Sopenharmony_ci curlsocktype purpose) 6313498266Sopenharmony_ci{ 6413498266Sopenharmony_ci (void)clientp; 6513498266Sopenharmony_ci (void)curlfd; 6613498266Sopenharmony_ci (void)purpose; 6713498266Sopenharmony_ci return CURL_SOCKOPT_ALREADY_CONNECTED; 6813498266Sopenharmony_ci} 6913498266Sopenharmony_ci 7013498266Sopenharmony_ci/* Expected args: URL IP PORT */ 7113498266Sopenharmony_ciint test(char *URL) 7213498266Sopenharmony_ci{ 7313498266Sopenharmony_ci CURL *curl = NULL; 7413498266Sopenharmony_ci CURLcode res = TEST_ERR_MAJOR_BAD; 7513498266Sopenharmony_ci int status; 7613498266Sopenharmony_ci curl_socket_t client_fd = CURL_SOCKET_BAD; 7713498266Sopenharmony_ci struct sockaddr_in serv_addr; 7813498266Sopenharmony_ci unsigned short port; 7913498266Sopenharmony_ci 8013498266Sopenharmony_ci if(!strcmp("check", URL)) 8113498266Sopenharmony_ci return 0; /* no output makes it not skipped */ 8213498266Sopenharmony_ci 8313498266Sopenharmony_ci port = (unsigned short)atoi(libtest_arg3); 8413498266Sopenharmony_ci 8513498266Sopenharmony_ci if(curl_global_init(CURL_GLOBAL_ALL) != CURLE_OK) { 8613498266Sopenharmony_ci fprintf(stderr, "curl_global_init() failed\n"); 8713498266Sopenharmony_ci return TEST_ERR_MAJOR_BAD; 8813498266Sopenharmony_ci } 8913498266Sopenharmony_ci 9013498266Sopenharmony_ci /* 9113498266Sopenharmony_ci * This code connects to the TCP port "manually" so that we then can hand 9213498266Sopenharmony_ci * over this socket as "already connected" to libcurl and make sure that 9313498266Sopenharmony_ci * this works. 9413498266Sopenharmony_ci */ 9513498266Sopenharmony_ci client_fd = socket(AF_INET, SOCK_STREAM, 0); 9613498266Sopenharmony_ci if(client_fd == CURL_SOCKET_BAD) { 9713498266Sopenharmony_ci fprintf(stderr, "socket creation error\n"); 9813498266Sopenharmony_ci goto test_cleanup; 9913498266Sopenharmony_ci } 10013498266Sopenharmony_ci 10113498266Sopenharmony_ci serv_addr.sin_family = AF_INET; 10213498266Sopenharmony_ci serv_addr.sin_port = htons(port); 10313498266Sopenharmony_ci 10413498266Sopenharmony_ci if(inet_pton(AF_INET, libtest_arg2, &serv_addr.sin_addr) <= 0) { 10513498266Sopenharmony_ci fprintf(stderr, "inet_pton failed\n"); 10613498266Sopenharmony_ci goto test_cleanup; 10713498266Sopenharmony_ci } 10813498266Sopenharmony_ci 10913498266Sopenharmony_ci status = connect(client_fd, (struct sockaddr*)&serv_addr, sizeof(serv_addr)); 11013498266Sopenharmony_ci if(status < 0) { 11113498266Sopenharmony_ci fprintf(stderr, "connection failed\n"); 11213498266Sopenharmony_ci goto test_cleanup; 11313498266Sopenharmony_ci } 11413498266Sopenharmony_ci 11513498266Sopenharmony_ci curl = curl_easy_init(); 11613498266Sopenharmony_ci if(!curl) { 11713498266Sopenharmony_ci fprintf(stderr, "curl_easy_init() failed\n"); 11813498266Sopenharmony_ci goto test_cleanup; 11913498266Sopenharmony_ci } 12013498266Sopenharmony_ci 12113498266Sopenharmony_ci test_setopt(curl, CURLOPT_VERBOSE, 1L); 12213498266Sopenharmony_ci test_setopt(curl, CURLOPT_OPENSOCKETFUNCTION, socket_cb); 12313498266Sopenharmony_ci test_setopt(curl, CURLOPT_OPENSOCKETDATA, &client_fd); 12413498266Sopenharmony_ci test_setopt(curl, CURLOPT_SOCKOPTFUNCTION, sockopt_cb); 12513498266Sopenharmony_ci test_setopt(curl, CURLOPT_SOCKOPTDATA, NULL); 12613498266Sopenharmony_ci test_setopt(curl, CURLOPT_CLOSESOCKETFUNCTION, closesocket_cb); 12713498266Sopenharmony_ci test_setopt(curl, CURLOPT_CLOSESOCKETDATA, NULL); 12813498266Sopenharmony_ci test_setopt(curl, CURLOPT_VERBOSE, 1L); 12913498266Sopenharmony_ci test_setopt(curl, CURLOPT_HEADER, 1L); 13013498266Sopenharmony_ci test_setopt(curl, CURLOPT_URL, URL); 13113498266Sopenharmony_ci 13213498266Sopenharmony_ci res = curl_easy_perform(curl); 13313498266Sopenharmony_ci 13413498266Sopenharmony_citest_cleanup: 13513498266Sopenharmony_ci if(client_fd != CURL_SOCKET_BAD) 13613498266Sopenharmony_ci sclose(client_fd); 13713498266Sopenharmony_ci curl_easy_cleanup(curl); 13813498266Sopenharmony_ci curl_global_cleanup(); 13913498266Sopenharmony_ci 14013498266Sopenharmony_ci return res; 14113498266Sopenharmony_ci} 14213498266Sopenharmony_ci#else 14313498266Sopenharmony_ciint test(char *URL) 14413498266Sopenharmony_ci{ 14513498266Sopenharmony_ci (void)URL; 14613498266Sopenharmony_ci printf("lacks inet_pton\n"); 14713498266Sopenharmony_ci return 0; 14813498266Sopenharmony_ci} 14913498266Sopenharmony_ci#endif 150