/* * Copyright (c) 2019 TAOS Data, Inc. * * This program is free software: you can use, redistribute, and/or modify * it under the terms of the GNU Affero General Public License, version 3 * or later ("AGPL"), as published by the Free Software Foundation. * * This program is distributed in the hope that it will be useful, but WITHOUT * ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or * FITNESS FOR A PARTICULAR PURPOSE. * * You should have received a copy of the GNU Affero General Public License * along with this program. If not, see . */ #include #include #include #include #include #include #include #include #include #include #include #include #include #include #include #define BUFFER_SIZE 200 typedef struct { int port; } info_s; typedef struct Arguments { char * host; uint16_t port; uint16_t max_port; } SArguments; static struct argp_option options[] = { {0, 'h', "host", 0, "The host to connect to TDEngine. Default is localhost.", 0}, {0, 'p', "port", 0, "The TCP or UDP port number to use for the connection. Default is 6041.", 1}, {0, 'm', "max port", 0, "The max TCP or UDP port number to use for the connection. Default is 6050.", 2}}; static error_t parse_opt(int key, char *arg, struct argp_state *state) { SArguments *arguments = state->input; switch (key) { case 'h': arguments->host = arg; break; case 'p': arguments->port = atoi(arg); break; case 'm': arguments->max_port = atoi(arg); break; } return 0; } static struct argp argp = {options, parse_opt, 0, 0}; static void *bindTcpPort(void *sarg) { info_s *pinfo = (info_s *)sarg; int port = pinfo->port; int serverSocket; struct sockaddr_in server_addr; struct sockaddr_in clientAddr; int addr_len = sizeof(clientAddr); int client; char buffer[BUFFER_SIZE]; int iDataNum; if ((serverSocket = socket(AF_INET, SOCK_STREAM, IPPROTO_TCP)) < 0) { perror("socket"); return NULL; } bzero(&server_addr, sizeof(server_addr)); server_addr.sin_family = AF_INET; server_addr.sin_port = htons(port); server_addr.sin_addr.s_addr = htonl(INADDR_ANY); if (bind(serverSocket, (struct sockaddr *)&server_addr, sizeof(server_addr)) < 0) { perror("connect"); return NULL; } if (listen(serverSocket, 5) < 0) { perror("listen"); return NULL; } //printf("Bind port: %d success\n", port); while (1) { client = accept(serverSocket, (struct sockaddr *)&clientAddr, (socklen_t *)&addr_len); if (client < 0) { perror("accept"); continue; } //printf("=================================\n"); printf("Client ip is %s, Server port is %d\n", inet_ntoa(clientAddr.sin_addr), port); while (1) { buffer[0] = '\0'; iDataNum = recv(client, buffer, BUFFER_SIZE, 0); if (iDataNum < 0) { perror("recv null"); continue; } if (iDataNum > 0) { buffer[iDataNum] = '\0'; //printf("read msg:%s\n", buffer); if (strcmp(buffer, "quit") == 0) break; buffer[0] = '\0'; sprintf(buffer, "ack port_%d", port); //printf("send ack msg:%s\n", buffer); send(client, buffer, strlen(buffer), 0); break; } } //printf("=================================\n"); } close(serverSocket); return NULL; } static void *bindUdpPort(void *sarg) { info_s *pinfo = (info_s *)sarg; int port = pinfo->port; int serverSocket; struct sockaddr_in server_addr; struct sockaddr_in clientAddr; char buffer[BUFFER_SIZE]; int iDataNum; if ((serverSocket = socket(AF_INET, SOCK_DGRAM, IPPROTO_UDP)) < 0) { perror("socket"); return NULL; } bzero(&server_addr, sizeof(server_addr)); server_addr.sin_family = AF_INET; server_addr.sin_port = htons(port); server_addr.sin_addr.s_addr = htonl(INADDR_ANY); if (bind(serverSocket, (struct sockaddr *)&server_addr, sizeof(server_addr)) < 0) { perror("connect"); return NULL; } socklen_t sin_size; //printf("Bind port: %d success\n", port); while (1) { buffer[0] = '\0'; sin_size = sizeof(*(struct sockaddr *)&server_addr); iDataNum = recvfrom(serverSocket, buffer, BUFFER_SIZE, 0, (struct sockaddr *)&clientAddr, &sin_size); if (iDataNum < 0) { perror("recvfrom null"); continue; } if (iDataNum > 0) { //printf("=================================\n"); printf("Client ip is %s, Server port is %d\n", inet_ntoa(clientAddr.sin_addr), port); buffer[iDataNum] = '\0'; //printf("Read msg from udp:%s\n", buffer); if (strcmp(buffer, "quit") == 0) break; buffer[0] = '\0'; sprintf(buffer, "ack port_%d by udp", port); //printf("Send ack msg by udp:%s\n", buffer); sendto(serverSocket, buffer, strlen(buffer), 0, (struct sockaddr *)&clientAddr, (int)sin_size); //printf("=================================\n"); } } close(serverSocket); return NULL; } int main(int argc, char *argv[]) { SArguments arguments = {"127.0.0.1", 6030, 6060}; argp_parse(&argp, argc, argv, 0, 0, &arguments); int port = arguments.port; int num = arguments.max_port - arguments.port + 1; if (num < 0) { num = 1; } pthread_t *pids = malloc(2 * num * sizeof(pthread_t)); info_s * tinfos = malloc(num * sizeof(info_s)); info_s * uinfos = malloc(num * sizeof(info_s)); for (size_t i = 0; i < num; i++) { info_s *tcpInfo = tinfos + i; tcpInfo->port = port + i; if (pthread_create(pids + i, NULL, bindTcpPort, tcpInfo) != 0) { printf("create thread fail, port:%d.\n", port); exit(-1); } info_s *udpInfo = uinfos + i; udpInfo->port = port + i; if (pthread_create(pids + num + i, NULL, bindUdpPort, udpInfo) != 0) { printf("create thread fail, port:%d.\n", port); exit(-1); } } for (int i = 0; i < num; i++) { pthread_join(pids[i], NULL); pthread_join(pids[(num + i)], NULL); } }