aboutsummaryrefslogtreecommitdiffstats
path: root/app_example
diff options
context:
space:
mode:
Diffstat (limited to 'app_example')
-rw-r--r--app_example/perf-test/CMakeLists.txt17
-rw-r--r--app_example/perf-test/multi_tcp_common_app_Cli.c (renamed from app_example/perf-test/multi_tcp_epoll_app_Cli.c)232
-rw-r--r--app_example/perf-test/multi_tcp_select_app_Ser.c436
3 files changed, 448 insertions, 237 deletions
diff --git a/app_example/perf-test/CMakeLists.txt b/app_example/perf-test/CMakeLists.txt
index a22f071..4abde0f 100644
--- a/app_example/perf-test/CMakeLists.txt
+++ b/app_example/perf-test/CMakeLists.txt
@@ -16,20 +16,27 @@
LINK_DIRECTORIES(${LIB_PATH_SHARED} ${LIB_PATH_STATIC})
-ADD_EXECUTABLE(vc_epoll multi_tcp_epoll_app_Cli.c)
-ADD_DEPENDENCIES(vc_epoll nStackAPI)
-TARGET_LINK_LIBRARIES(vc_epoll libnStackAPI.so -Wl,-rpath=. -lpthread -lrt)
+ADD_EXECUTABLE(vc_common multi_tcp_common_app_Cli.c)
+ADD_DEPENDENCIES(vc_common nStackAPI)
+TARGET_LINK_LIBRARIES(vc_common libnStackAPI.so -Wl,-rpath=. -lpthread -lrt)
ADD_EXECUTABLE(vs_epoll multi_tcp_epoll_app_Ser.c)
ADD_DEPENDENCIES(vs_epoll nStackAPI)
TARGET_LINK_LIBRARIES(vs_epoll libnStackAPI.so -Wl,-rpath=. -lpthread -lrt)
-ADD_EXECUTABLE(kc_epoll multi_tcp_epoll_app_Cli.c)
-TARGET_LINK_LIBRARIES(kc_epoll pthread)
+ADD_EXECUTABLE(vs_select multi_tcp_select_app_Ser.c)
+ADD_DEPENDENCIES(vs_select nStackAPI)
+TARGET_LINK_LIBRARIES(vs_select libnStackAPI.so -Wl,-rpath=. -lpthread -lrt)
+
+ADD_EXECUTABLE(kc_common multi_tcp_common_app_Cli.c)
+TARGET_LINK_LIBRARIES(kc_common pthread)
ADD_EXECUTABLE(ks_epoll multi_tcp_epoll_app_Ser.c)
TARGET_LINK_LIBRARIES(ks_epoll pthread)
+ADD_EXECUTABLE(ks_select multi_tcp_select_app_Ser.c)
+TARGET_LINK_LIBRARIES(ks_select pthread)
+
#ADD_EXECUTABLE(vs_no_epoll multi_tcp_no_epoll_Ser.c)
#ADD_DEPENDENCIES(vs_no_epoll nStackAPI)
#TARGET_LINK_LIBRARIES(vs_no_epoll libnStackAPI.so -Wl,-rpath=. -lpthread -lrt)
diff --git a/app_example/perf-test/multi_tcp_epoll_app_Cli.c b/app_example/perf-test/multi_tcp_common_app_Cli.c
index c09d422..5c1fada 100644
--- a/app_example/perf-test/multi_tcp_epoll_app_Cli.c
+++ b/app_example/perf-test/multi_tcp_common_app_Cli.c
@@ -359,236 +359,6 @@ process_client (void)
pthread_exit (NULL);
}
-/*
- using this thread to do recv msg;
-*/
-void *
-process_server_msg_thread (void *pArgv)
-{
- int recvLen = 0, recvLen2 = 0;
- char send_buf[1000];
- char recv_buf[1000];
- int recv_count = 0;
- long recv_ppstime = 0;
- int recv_pps = 0;
- int ret;
-
- struct epoll_event eventList[MAX_EVENTS];
-
- struct timespec recvStart;
- struct timespec recvEnd;
- memset (&recvStart, 0, sizeof (recvStart));
- memset (&recvEnd, 0, sizeof (recvEnd));
-
- int msgEpFd = *(int *) pArgv;
-
- clock_gettime (CLOCK_MONOTONIC, &recvStart);
- while (1)
- {
- int timeout = -1;
- int m;
- int sock;
- ret = epoll_wait (msgEpFd, eventList, MAX_EVENTS, timeout);
- if (ret == 0)
- continue;
-
- for (m = 0; m < ret; m++)
- {
- if ((eventList[m].events & EPOLLERR)
- || (eventList[m].events & EPOLLHUP)
- || !(eventList[m].events & EPOLLIN))
- {
- printf ("fd %d epoll error event:%d\n", eventList[m].data.fd,
- eventList[m].events);
- close (eventList[m].data.fd);
- continue;
- }
- else
- {
- recvLen = 0;
- recvLen2 = 0;
- sock = eventList[m].data.fd;
-
- do
- {
- recvLen2 =
- recv (sock, recv_buf + recvLen, msg_length - recvLen, 0);
- if (recvLen2 <= 0)
- {
- break;
- }
- else if (recvLen2 == msg_length - recvLen)
- {
- recvLen = 0;
- recv_count++;
- }
- else if (recvLen2 < msg_length - recvLen)
- {
- recvLen += recvLen2;
- }
- if ((flagPrint != 0) && ((recv_count % unitPrint) == 0))
- {
- clock_gettime (CLOCK_MONOTONIC, &recvEnd);
- recv_ppstime =
- (recvEnd.tv_sec - recvStart.tv_sec) * 1000000000 +
- recvEnd.tv_nsec - recvStart.tv_nsec;
- recv_pps =
- ((float) 1000000000 / recv_ppstime) * unitPrint;
- printf ("receive count:%d, receive time: %ld ns\n",
- recv_count, recv_ppstime);
- printf ("receive pps = %d\n", recv_pps);
- clock_gettime (CLOCK_MONOTONIC, &recvStart);
- }
- }
- while (1);
- }
-
- }
-
- if (recv_count == connectNum * times)
- {
- break;
- }
- }
-
- close (msgEpFd);
-}
-
-/*
- using this thread to do accept connect
-*/
-void *
-process_server_accept_thread (void *pArgv)
-{
- int listenFd = 0;
- int x, optval, ret, m = 0;
- int acpt_socketfd[1000] = { 0 };
- int msgEpFd = *(int *) pArgv;
-
- listenFd = socket (PF_INET, SOCK_STREAM, IPPROTO_TCP);
- if (0 > listenFd)
- {
- printf ("ERROR:socket failed,errno [%d]\n", errno);
- return NULL;
- }
- else
- {
- printf ("INFO:Create listen socket Success, listenFd[%d]\n", listenFd);
- }
-
- if (0 > fcntl (listenFd, F_SETFL, O_NONBLOCK))
- {
- printf ("ERROR:fcntl failed. fd[%d], errno[%d]/n", listenFd, errno);
- close (listenFd);
- }
-
- optval = 1;
- ret =
- setsockopt (listenFd, SOL_SOCKET, SO_REUSEADDR, (void *) &optval,
- sizeof (optval));
- if (ret == -1)
- {
- printf ("ERROR:setsockopt failed. fd[%d], errno[%d]\n", listenFd,
- errno);
- close (listenFd);
- return NULL;
- }
-
- if (0 !=
- bind (listenFd, (struct sockaddr *) &g_recv, sizeof (struct sockaddr)))
- {
- printf ("ERROR:bind failed. fd[%d] errno [%d]\n", listenFd, errno);
- printf ("Info Bind Success, port %d IP:%s\n", ntohs (g_recv.sin_port),
- inet_ntoa (*((struct in_addr *) &(g_recv.sin_addr.s_addr))));
- close (listenFd);
- return NULL;
- }
- else
- {
- printf ("Info Bind Success, port %d IP:%s\n", ntohs (g_recv.sin_port),
- inet_ntoa (*((struct in_addr *) &(g_recv.sin_addr.s_addr))));
- }
-
- if (0 != listen (listenFd, 100))
- {
- printf ("server socket listen failed. err %d\n", errno);
- close (listenFd);
- return NULL;
- }
- printf ("Listen Success\n");
-
- int accEpFd;
- struct epoll_event eventList[100];
- accEpFd = epoll_create (100);
- struct epoll_event event;
- event.events = EPOLLIN | EPOLLET;
- event.data.fd = listenFd;
-
- if (epoll_ctl (accEpFd, EPOLL_CTL_ADD, listenFd, &event) < 0)
- {
- printf ("epoll_ctl add [%d] to epfd:%d failed\n", listenFd, accEpFd);
- exit (-1);
- }
-
- int timeout = -1;
- int accpedNum = 0;
- while (accpedNum < connectNum)
- {
- ret = epoll_wait (accEpFd, eventList, connectNum, timeout);
-
- if (ret < 0)
- {
- printf ("accept_thread epoll_wait error, epfd[%d], errno[%d]\n",
- accEpFd, errno);
- continue;
- }
- else if (ret == 0)
- continue;
-
- /*loop done ever Event */
- for (x = 0; x < ret; x++)
- {
- printf ("event:%d; ret:%d\n", eventList[x].events, ret);
- if ((eventList[x].events & EPOLLERR)
- || !(eventList[x].events & EPOLLIN))
- {
- printf ("epoll fd %d error\n", eventList[x].data.fd);
- close (eventList[x].data.fd);
- continue;
- }
-
- while (1)
- {
- acpt_socketfd[accpedNum] =
- accept4 (listenFd, NULL, NULL, SOCK_NONBLOCK);
- if (acpt_socketfd[accpedNum] < 0)
- {
- perror ("epoll connect error\n");
- break;
- }
- /*add new accptFd to MsgEpFD */
- event.events = EPOLLIN | EPOLLET;
- event.data.fd = acpt_socketfd[accpedNum];
- if (epoll_ctl
- (msgEpFd, EPOLL_CTL_ADD, acpt_socketfd[accpedNum],
- &event) < 0)
- {
- printf ("epoll add fd[%d] to msgEpfd:[%d] failed\n",
- acpt_socketfd[accpedNum], msgEpFd);
- continue;
- }
- printf ("accept cnt [%d], cur accept fd [%d]\n", accpedNum,
- acpt_socketfd[accpedNum]);
- accpedNum++;
- }
- }
- }
-
- close (listenFd);
- close (accEpFd);
- pthread_exit (NULL);
-}
-
void
main (int argc, char *argv[])
{
@@ -605,8 +375,6 @@ main (int argc, char *argv[])
return;
}
- int accEpFd = epoll_create (100);
-
pthread_t client_thread_id;
if (pthread_create
diff --git a/app_example/perf-test/multi_tcp_select_app_Ser.c b/app_example/perf-test/multi_tcp_select_app_Ser.c
new file mode 100644
index 0000000..d413363
--- /dev/null
+++ b/app_example/perf-test/multi_tcp_select_app_Ser.c
@@ -0,0 +1,436 @@
+/*
+*
+* Copyright (c) 2018 Huawei Technologies Co.,Ltd.
+* Licensed under the Apache License, Version 2.0 (the "License");
+* you may not use this file except in compliance with the License.
+* You may obtain a copy of the License at:
+*
+* http://www.apache.org/licenses/LICENSE-2.0
+*
+* Unless required by applicable law or agreed to in writing, software
+* distributed under the License is distributed on an "AS IS" BASIS,
+* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+* See the License for the specific language governing permissions and
+* limitations under the License.
+*/
+
+#define _GNU_SOURCE
+#include <sys/socket.h>
+#include <fcntl.h>
+#include <memory.h>
+#include <signal.h>
+#include <stdio.h>
+#include <unistd.h>
+#include <stdio.h>
+#include <stdlib.h>
+#include <sys/stat.h>
+#include <netinet/in.h>
+#include <time.h>
+#include <linux/tcp.h>
+#include <sched.h>
+#include <pthread.h>
+#include <arpa/inet.h>
+#include <sys/epoll.h>
+#include <errno.h>
+
+#define _BIND bind
+#define _LISTEN listen
+#define _SOCKET socket
+#define _ACCEPT accept
+#define _SEND send
+#define _RECV recv
+#define _CLOSE close
+#define _CONNECT connect
+#define _PROTOCOL IPPROTO_TCP
+
+#define MAX_TEST_TIME 1000
+#define MSG_LENGTH 256
+#define CORE_NUM 8
+#define START_CPU_ID 2
+#define MAX_CONN_LIMIT 256
+#define MAX_PORT_NUM 65535
+//1:A-B ;0:A-B-A
+#define SEND_RECV_MODE 1
+#define MAX_EVENTS 1000
+#define Default_PortID 12345
+#define Default_SleepCnt 10000
+#define Default_SleepTime 1000000
+#define Flag_Print 1
+#define Fd_Number 1
+
+static struct sockaddr_in g_dest;
+static struct sockaddr_in g_src;
+static struct sockaddr_in g_recv;
+
+int times = MAX_TEST_TIME;
+int msg_length = MSG_LENGTH;
+int coreNum = CORE_NUM;
+int startCPUId = START_CPU_ID;
+int connectNum = MAX_CONN_LIMIT;
+int msgMode = SEND_RECV_MODE;
+int sleepCnt = Default_SleepCnt;
+int sleepTime = Default_SleepTime; //us
+int fdNumber = Fd_Number;
+int flagPrint = Flag_Print;
+int unitPrint = 0;
+int waitTime = 0;
+
+int srcPort = Default_PortID;
+int destPort = 0;
+int recvPort = 0;
+char sendarr[256] = "";
+char recvarr[256] = "";
+char destarr[256] = "";
+
+static void
+setArgsDefault ()
+{
+
+ memset (&g_dest, 0, sizeof (g_dest));
+ g_dest.sin_family = AF_INET;
+ g_dest.sin_addr.s_addr = inet_addr ("127.0.0.1");
+ g_dest.sin_port = htons (12345);
+ bzero (&(g_dest.sin_zero), 8);
+
+ memset (&g_src, 0, sizeof (g_src));
+ g_src.sin_family = AF_INET;
+ g_src.sin_addr.s_addr = inet_addr ("0.0.0.0");
+ g_src.sin_port = htons (7895);
+ bzero (&(g_src.sin_zero), 8);
+
+ memset (&g_recv, 0, sizeof (g_recv));
+ g_recv.sin_family = AF_INET;
+ g_recv.sin_addr.s_addr = inet_addr ("0.0.0.0");
+ g_recv.sin_port = htons (7895);
+ bzero (&(g_recv.sin_zero), 8);
+
+}
+
+static int
+process_arg (int argc, char *argv[])
+{
+ int opt = 0;
+ int error = 0;
+ const char *optstring = "p:d:s:a:l:t:e:i:f:r:n:w:u:x:";
+ int rw_mark = 0;
+
+ if (argc < 4)
+ {
+ printf
+ ("Param info :-p dest_portid; -d dest_serverIP; -a src_portid; -s src_clientIP; -l msg_length; \n");
+ printf
+ ("\t-t MAX_TEST_TIME; -i msg_interval ; -f client fd number ; -r receive port; -n connectNum(one server vs n client)\n");
+ return 0;
+ }
+ while ((opt = getopt (argc, argv, optstring)) != -1)
+ {
+ switch (opt)
+ {
+ case 'p':
+ destPort = atoi (optarg);
+ g_dest.sin_port = htons (atoi (optarg));
+ break;
+ case 'd':
+ stpcpy (destarr, optarg);
+ g_dest.sin_addr.s_addr = inet_addr (optarg);
+ break;
+ case 's':
+ stpcpy (sendarr, optarg);
+ g_src.sin_addr.s_addr = inet_addr (optarg);
+ g_recv.sin_addr.s_addr = inet_addr (optarg);
+ break;
+ case 'a':
+ //g_src.sin_port = htons(atoi(optarg));
+ srcPort = atoi (optarg);
+ break;
+ case 'l':
+ msg_length = atoi (optarg);
+ break;
+ case 't':
+ times = atoi (optarg);
+ break;
+ case 'e':
+ sleepCnt = atoi (optarg);
+ break;
+ case 'i':
+ sleepTime = atoi (optarg);
+ break;
+ case 'f':
+ fdNumber = atoi (optarg);
+ break;
+ case 'r':
+ recvPort = atoi (optarg);
+ g_recv.sin_port = htons (atoi (optarg));
+ break;
+ case 'n':
+ connectNum = atoi (optarg);
+ break;
+ case 'w':
+ waitTime = atoi (optarg);
+ break;
+ case 'u':
+ unitPrint = atoi (optarg);
+ break;
+ case 'x':
+ flagPrint = atoi (optarg);
+ break;
+
+ }
+ }
+ return 1;
+}
+
+
+/*
+ using this thread to do recv msg;
+*/
+void *
+process_server_msg_thread (void *pArgv)
+{
+ int recvLen = 0, recvLen2 = 0;
+ char send_buf[1000];
+ char recv_buf[1000];
+ int recv_count = 0;
+ long recv_ppstime = 0;
+ int recv_pps = 0;
+ int ret;
+ struct timeval timeout;
+ fd_set rfds;
+ int maxfd;
+
+ struct timespec recvStart;
+ struct timespec recvEnd;
+ memset (&recvStart, 0, sizeof (recvStart));
+ memset (&recvEnd, 0, sizeof (recvEnd));
+
+ pthread_detach (pthread_self ());
+
+ int msgFd = *(int *) pArgv;
+
+ clock_gettime (CLOCK_MONOTONIC, &recvStart);
+ while (1)
+ {
+ FD_ZERO(&rfds);
+ FD_SET(msgFd, &rfds);
+ maxfd = msgFd + 1;
+ timeout.tv_sec = 10;
+ timeout.tv_usec = 0;
+ ret = select(maxfd, &rfds, NULL, NULL, &timeout);
+
+ if (ret <= 0)
+ {
+ continue;
+ }
+
+ if (FD_ISSET(msgFd, &rfds) == 0)
+ {
+ continue;
+ }
+
+ recvLen = 0;
+ recvLen2 = 0;
+
+ do
+ {
+ recvLen2 =
+ recv (msgFd, recv_buf + recvLen, msg_length - recvLen, 0);
+ if (recvLen2 <= 0)
+ {
+ break;
+ }
+ else if (recvLen2 == msg_length - recvLen)
+ {
+ recvLen = 0;
+ recv_count++;
+ if (msg_length != send (msgFd, send_buf, msg_length, 0))
+ {
+ printf ("send failed!====, need exit\n");
+ }
+ }
+ else if (recvLen2 < msg_length - recvLen)
+ {
+ recvLen += recvLen2;
+ }
+ if ((flagPrint != 0) && ((recv_count % unitPrint) == 0))
+ {
+ clock_gettime (CLOCK_MONOTONIC, &recvEnd);
+ recv_ppstime =
+ (recvEnd.tv_sec - recvStart.tv_sec) * 1000000000 +
+ recvEnd.tv_nsec - recvStart.tv_nsec;
+ recv_pps =
+ ((float) 1000000000 / recv_ppstime) * unitPrint;
+ printf ("receive count:%d, receive time: %ld ns\n",
+ recv_count, recv_ppstime);
+ printf ("receive pps = %d\n", recv_pps);
+ clock_gettime (CLOCK_MONOTONIC, &recvStart);
+ }
+ }
+ while (1);
+
+ if (recv_count == times)
+ {
+ break;
+ }
+ }
+ close (msgFd);
+}
+
+/*
+ using this thread to do accept connect
+*/
+void *
+process_server_accept_thread (void *pArgv)
+{
+ int listenFd = 0;
+ int x, optval, ret, m = 0;
+ int acpt_socketfd[1000] = { 0 };
+ struct timeval timeout;
+ fd_set rfds;
+ int maxfd;
+
+ listenFd = socket (PF_INET, SOCK_STREAM, IPPROTO_TCP);
+ if (0 > listenFd)
+ {
+ printf ("ERROR:socket failed,errno [%d]\n", errno);
+ return NULL;
+ }
+ else
+ {
+ printf ("INFO:Create listen socket Success, listenFd[%d]\n", listenFd);
+ }
+
+ if (0 > fcntl (listenFd, F_SETFL, O_NONBLOCK))
+ {
+ printf ("ERROR:fcntl failed. fd[%d], errno[%d]/n", listenFd, errno);
+ close (listenFd);
+ }
+
+ optval = 1;
+ ret =
+ setsockopt (listenFd, SOL_SOCKET, SO_REUSEADDR, (void *) &optval,
+ sizeof (optval));
+ if (ret == -1)
+ {
+ printf ("ERROR:setsockopt failed. fd[%d], errno[%d]\n", listenFd,
+ errno);
+ close (listenFd);
+ return NULL;
+ }
+
+ if (0 !=
+ bind (listenFd, (struct sockaddr *) &g_recv, sizeof (struct sockaddr)))
+ {
+ printf ("ERROR:bind failed. fd[%d] errno [%d]\n", listenFd, errno);
+ close (listenFd);
+ //return NULL;
+ exit(-1);
+ }
+ else
+ {
+ printf ("Info Bind Success, port %d IP:%s\n", ntohs (g_recv.sin_port),
+ inet_ntoa (*((struct in_addr *) &(g_recv.sin_addr.s_addr))));
+ }
+
+ if (0 != listen (listenFd, 100))
+ {
+ printf ("server socket listen failed. err %d\n", errno);
+ close (listenFd);
+ return NULL;
+ }
+ printf ("Listen Success\n");
+
+ while (accpedNum < connectNum)
+ {
+ FD_ZERO(&rfds);
+ FD_SET(listenFd, &rfds);
+ maxfd = listenFd + 1;
+ timeout.tv_sec = 10;
+ timeout.tv_usec = 0;
+ ret = select(maxfd, &rfds, NULL, NULL, &timeout);
+
+ if (ret <= 0)
+ {
+ continue;
+ }
+
+ if (FD_ISSET(lisendFd, &rfds) == 0)
+ {
+ continue;
+ }
+
+
+ while (1)
+ {
+ acpt_socketfd[accpedNum] =
+ accept4 (listenFd, NULL, NULL, SOCK_NONBLOCK);
+ if (acpt_socketfd[accpedNum] < 0)
+ {
+ perror ("select connect error\n");
+ break;
+ }
+ /*add new accptFd to MsgEpFD */
+ pthread_t ser_rcv_thread_id;
+ if (pthread_create
+ (&ser_rcv_thread_id, NULL, process_server_msg_thread,
+ (void *) &acpt_socketfd[accpedNum]) == -1)
+ {
+ printf ("create process_server_msg_thread fail\n");
+ break;
+ }
+
+ printf ("accept cnt [%d], cur accept fd [%d]\n", accpedNum,
+ acpt_socketfd[accpedNum]);
+ accpedNum++;
+ }
+ }
+
+ close (listenFd);
+
+ while (1)
+ {
+ sleep (10);
+ }
+
+ pthread_exit (NULL);
+}
+
+void
+main (int argc, char *argv[])
+{
+ socklen_t addrlen = sizeof (struct sockaddr);
+ int err = 0, result = 0, ret = 0;
+ int i = 0, j = 0, optval = 0, z = 0, x, listenfd;
+ cpu_set_t mask;
+
+ setArgsDefault ();
+ ret = process_arg (argc, argv);
+ if (ret != 1)
+ {
+ printf ("The param error\n");
+ return;
+ }
+
+ pthread_t server_thread_id;
+
+ if (pthread_create
+ (&server_thread_id, NULL, process_server_accept_thread, NULL) == -1)
+ {
+ printf ("create process_server_accept_thread fail\n");
+ return;
+ }
+
+ printf ("create process_server_accept_thread success\n");
+
+ if (server_thread_id != 0)
+ {
+ printf ("Server Thread join\n");
+ pthread_join (server_thread_id, NULL);
+ }
+
+ while (1)
+ {
+ sleep (10);
+ }
+
+ return;
+}