From 6fc333b4165cd57a1cfcda79e9f71d59472d4d79 Mon Sep 17 00:00:00 2001 From: Jianfeng Jiang Date: Wed, 31 May 2023 10:47:16 +0800 Subject: [PATCH] Add network test --- regression/apps/network/Makefile | 13 +++++ regression/apps/network/nettest.sh | 11 ++++ regression/apps/network/tcp/client | 3 ++ regression/apps/network/tcp/client.c | 51 +++++++++++++++++++ regression/apps/network/tcp/server | 3 ++ regression/apps/network/tcp/server.c | 75 ++++++++++++++++++++++++++++ regression/apps/network/udp/client | 3 ++ regression/apps/network/udp/client.c | 54 ++++++++++++++++++++ regression/apps/network/udp/server | 3 ++ regression/apps/network/udp/server.c | 63 +++++++++++++++++++++++ 10 files changed, 279 insertions(+) create mode 100644 regression/apps/network/Makefile create mode 100755 regression/apps/network/nettest.sh create mode 100755 regression/apps/network/tcp/client create mode 100644 regression/apps/network/tcp/client.c create mode 100755 regression/apps/network/tcp/server create mode 100644 regression/apps/network/tcp/server.c create mode 100755 regression/apps/network/udp/client create mode 100644 regression/apps/network/udp/client.c create mode 100755 regression/apps/network/udp/server create mode 100644 regression/apps/network/udp/server.c diff --git a/regression/apps/network/Makefile b/regression/apps/network/Makefile new file mode 100644 index 000000000..07bde4319 --- /dev/null +++ b/regression/apps/network/Makefile @@ -0,0 +1,13 @@ +.PHONY: build clean + +build: tcp/client.c tcp/server.c udp/client.c udp/server.c + @gcc tcp/client.c -o tcp/client + @gcc tcp/server.c -o tcp/server + @gcc udp/server.c -o udp/server + @gcc udp/client.c -o udp/client + +clean: + @rm tcp/client + @rm tcp/server + @rm udp/client + @rm udp/server diff --git a/regression/apps/network/nettest.sh b/regression/apps/network/nettest.sh new file mode 100755 index 000000000..a133ae321 --- /dev/null +++ b/regression/apps/network/nettest.sh @@ -0,0 +1,11 @@ +#!/bin/sh + +NETTEST_DIR=/network +cd ${NETTEST_DIR} +echo "Start net test......" +./tcp/server & +./tcp/client +./udp/server & +./udp/client + +echo "All net test passed" diff --git a/regression/apps/network/tcp/client b/regression/apps/network/tcp/client new file mode 100755 index 000000000..89ea0a558 --- /dev/null +++ b/regression/apps/network/tcp/client @@ -0,0 +1,3 @@ +version https://git-lfs.github.com/spec/v1 +oid sha256:6ba2aa2da39e5e6d7be121f13e9321a43a4a47b03f50d3d8303d3d51753e2f5c +size 17096 diff --git a/regression/apps/network/tcp/client.c b/regression/apps/network/tcp/client.c new file mode 100644 index 000000000..a290bf3f2 --- /dev/null +++ b/regression/apps/network/tcp/client.c @@ -0,0 +1,51 @@ +// From: https://www.geeksforgeeks.org/socket-programming-cc/. +// Some minor modifications are made to the original code base. +// Lisenced under CCBY-SA. + +// Client side C/C++ program to demonstrate socket programming +#include +#include +#include +#include +#include +#define PORT 8080 + +int main(int argc, char const* argv[]) +{ + int status, valread, client_fd; + struct sockaddr_in serv_addr; + char* hello = "Hello from client"; + char buffer[1024] = { 0 }; + if ((client_fd = socket(AF_INET, SOCK_STREAM, 0)) < 0) { + printf("\n Socket creation error \n"); + return -1; + } + + serv_addr.sin_family = AF_INET; + serv_addr.sin_port = htons(PORT); + + // Convert IPv4 and IPv6 addresses from text to binary + // form + if (inet_pton(AF_INET, "127.0.0.1", &serv_addr.sin_addr) + <= 0) { + printf( + "\nInvalid address/ Address not supported \n"); + return -1; + } + + if ((status + = connect(client_fd, (struct sockaddr*)&serv_addr, + sizeof(serv_addr))) + < 0) { + printf("\nConnection Failed \n"); + return -1; + } + send(client_fd, hello, strlen(hello), 0); + printf("Hello message sent\n"); + valread = read(client_fd, buffer, 1024); + printf("%s\n", buffer); + + // closing the connected socket + close(client_fd); + return 0; +} \ No newline at end of file diff --git a/regression/apps/network/tcp/server b/regression/apps/network/tcp/server new file mode 100755 index 000000000..2d38b73ae --- /dev/null +++ b/regression/apps/network/tcp/server @@ -0,0 +1,3 @@ +version https://git-lfs.github.com/spec/v1 +oid sha256:209ffb16164cc1e4f7dc978ce3d660e5c9bee5cd4f70e20088d59c8ff64b8d7d +size 17368 diff --git a/regression/apps/network/tcp/server.c b/regression/apps/network/tcp/server.c new file mode 100644 index 000000000..170991476 --- /dev/null +++ b/regression/apps/network/tcp/server.c @@ -0,0 +1,75 @@ +// From: https://www.geeksforgeeks.org/socket-programming-cc/. +// Some minor modifications are made to the original code base. +// Lisenced under CCBY-SA. + +// Server side C/C++ program to demonstrate socket programming +#include +#include +#include +#include +#include +#include +#include +#define PORT 8080 +int main(int argc, char const* argv[]) +{ + int server_fd, new_socket, valread; + struct sockaddr_in address; + int opt = 1; + int addrlen = sizeof(address); + char buffer[1024] = { 0 }; + char* hello = "Hello from server"; + + // Creating socket file descriptor + if ((server_fd = socket(AF_INET, SOCK_STREAM, 0)) < 0) { + perror("socket failed"); + exit(EXIT_FAILURE); + } + + // Forcefully attaching socket to the port 8080 + if (setsockopt(server_fd, SOL_SOCKET, + SO_REUSEADDR | SO_REUSEPORT, &opt, + sizeof(opt))) { + perror("setsockopt"); + exit(EXIT_FAILURE); + } + address.sin_family = AF_INET; + address.sin_port = htons(PORT); + // Convert IPv4 and IPv6 addresses from text to binary + // form + if (inet_pton(AF_INET, "127.0.0.1", &address.sin_addr) + <= 0) { + printf( + "\nInvalid address/ Address not supported \n"); + return -1; + } + + // Forcefully attaching socket to the port 8080 + if (bind(server_fd, (struct sockaddr*)&address, + sizeof(address)) + < 0) { + perror("bind failed"); + exit(EXIT_FAILURE); + } + if (listen(server_fd, 3) < 0) { + perror("listen"); + exit(EXIT_FAILURE); + } + if ((new_socket + = accept(server_fd, (struct sockaddr*)&address, + (socklen_t*)&addrlen)) + < 0) { + perror("accept"); + exit(EXIT_FAILURE); + } + valread = read(new_socket, buffer, 1024); + printf("%s\n", buffer); + send(new_socket, hello, strlen(hello), 0); + printf("Hello message sent\n"); + + // closing the connected socket + close(new_socket); + // closing the listening socket + shutdown(server_fd, SHUT_RDWR); + return 0; +} \ No newline at end of file diff --git a/regression/apps/network/udp/client b/regression/apps/network/udp/client new file mode 100755 index 000000000..24847dae4 --- /dev/null +++ b/regression/apps/network/udp/client @@ -0,0 +1,3 @@ +version https://git-lfs.github.com/spec/v1 +oid sha256:2701b848bdcbde4c1a2af2923f6c57d261befd7b20180fe0c10ac820f7082303 +size 17280 diff --git a/regression/apps/network/udp/client.c b/regression/apps/network/udp/client.c new file mode 100644 index 000000000..2ad81b8de --- /dev/null +++ b/regression/apps/network/udp/client.c @@ -0,0 +1,54 @@ +#include +#include +#include +#include +#include +#include +#include + +#define SERVER_IP "127.0.0.1" +#define SERVER_PORT 1234 +#define BUFFER_SIZE 1024 + +int main() { + int sock_fd; + char buffer[BUFFER_SIZE]; + struct sockaddr_in serv_addr; + + // Create UDP socket + if ((sock_fd = socket(AF_INET, SOCK_DGRAM, 0)) < 0) { + perror("socket creation failed"); + exit(EXIT_FAILURE); + } + + // Set server address + memset(&serv_addr, 0, sizeof(serv_addr)); + serv_addr.sin_family = AF_INET; + serv_addr.sin_port = htons(SERVER_PORT); + if (inet_pton(AF_INET, SERVER_IP, &serv_addr.sin_addr) <= 0) { + perror("invalid IP address"); + exit(EXIT_FAILURE); + } + + // Send massage to server + const char* message = "Hello world from udp client!"; + if (sendto(sock_fd, message, strlen(message), 0, (const struct sockaddr *)&serv_addr, sizeof(serv_addr)) < 0) { + perror("sendto failed"); + exit(EXIT_FAILURE); + } + + // Receive message from server + struct sockaddr_in sender_addr; + socklen_t sender_len = sizeof(sender_addr); + int recv_len; + if ((recv_len = recvfrom(sock_fd, buffer, BUFFER_SIZE, 0, (struct sockaddr *)&sender_addr, &sender_len)) < 0) { + perror("recvfrom failed"); + exit(EXIT_FAILURE); + } + buffer[recv_len] = '\0'; + printf("Received %s from %s:%d\n", buffer, inet_ntoa(sender_addr.sin_addr), ntohs(sender_addr.sin_port)); + + // close socket + close(sock_fd); + return 0; +} \ No newline at end of file diff --git a/regression/apps/network/udp/server b/regression/apps/network/udp/server new file mode 100755 index 000000000..5ee027fd6 --- /dev/null +++ b/regression/apps/network/udp/server @@ -0,0 +1,3 @@ +version https://git-lfs.github.com/spec/v1 +oid sha256:8e890e0782c4320369841b50abfb56f0059b02881ea5b3384224ae65ce9c1d65 +size 17328 diff --git a/regression/apps/network/udp/server.c b/regression/apps/network/udp/server.c new file mode 100644 index 000000000..435097d97 --- /dev/null +++ b/regression/apps/network/udp/server.c @@ -0,0 +1,63 @@ +#include +#include +#include +#include +#include +#include +#include + +#define SERVER_IP "127.0.0.1" +#define SERVER_PORT 1234 +#define BUFFER_SIZE 1024 + +int main() { + int sock_fd; + char buffer[BUFFER_SIZE]; + struct sockaddr_in serv_addr; + + // Create UDP socket + if ((sock_fd = socket(AF_INET, SOCK_DGRAM, 0)) < 0) { + perror("socket creation failed"); + exit(EXIT_FAILURE); + } + + // Set server address + memset(&serv_addr, 0, sizeof(serv_addr)); + serv_addr.sin_family = AF_INET; + serv_addr.sin_port = htons(SERVER_PORT); + if (inet_pton(AF_INET, SERVER_IP, &serv_addr.sin_addr) <= 0) { + perror("invalid IP address"); + exit(EXIT_FAILURE); + } + + // Bind to server address + if (bind(sock_fd, (struct sockaddr*)&serv_addr, + sizeof(serv_addr)) + < 0) { + perror("bind failed"); + exit(EXIT_FAILURE); + } + + // Receive message from client + struct sockaddr_in sender_addr; + socklen_t sender_len = sizeof(sender_addr); + int recv_len; + if ((recv_len = recvfrom(sock_fd, buffer, BUFFER_SIZE, 0, (struct sockaddr *)&sender_addr, &sender_len)) < 0) { + perror("recvfrom failed"); + exit(EXIT_FAILURE); + } + buffer[recv_len] = '\0'; + printf("Received %s from %s:%d\n", buffer, inet_ntoa(sender_addr.sin_addr), ntohs(sender_addr.sin_port)); + + /// Send message to client + const char* message = "Hello world from udp server!"; + if (sendto(sock_fd, message, strlen(message), 0, (const struct sockaddr *)&sender_addr, sizeof(sender_addr)) < 0) { + perror("sendto failed"); + exit(EXIT_FAILURE); + } + + // 关闭socket + close(sock_fd); + + return 0; +} \ No newline at end of file