``` static int s_iServerSocket = 0; static stNetAddr stClient = {0}; //static pthread_t s_stServerThread; int TCPSvr_Run(void) { int iRet = -1; int iClientSocket; int iTaskID = 0; int iCLientNumber = 0; struct sockaddr_in stClientaddr; socklen_t addrlen = sizeof(stClientaddr); if (s_iServerSocket <= 0) { cmn_PrtError("server socket not available"); } if(listen(s_iServerSocket,cmnDfn_MAX_CLIENT) < 0) { cmn_PrtError("listen error"); } while (g_iExit == 0) { if(((iClientSocket = accept(s_iServerSocket, (struct sockaddr *)&stClientaddr,&addrlen))) < 0) { cmn_PrtError("accept failed"); } stClient.iServerSocket = iClientSocket; stClient.iClientNumber = iCLientNumber++; if(ThreadPoolSubmit(TCPRcvTrd, &stClient,&iTaskID) < 0) { cmn_PrtError("Error in submitting task to thread pool"); } if(ThreadPoolSubmit(TCPSndTrd, &stClient,&iTaskID) < 0) { cmn_PrtError("Error in submitting task to thread pool"); } } iRet = 0; _Exit: return iRet; } static int s_iClientSocket; static struct sockaddr_in stServerAddr; static stNetAddr stServer = {0}; //static pthread_t s_iClientPhread; int TCPClnt_Run(void) { int iRet = -1; int iTaskID = 0; //struct sockaddr_in stServerAddr; if(s_iClientSocket == -1) { cmn_PrtError("Client socket not available"); } if(connect(s_iClientSocket, (struct sockaddr *)&stServerAddr, sizeof(stServerAddr)) < 0) { cmn_PrtError("Error in connecting to server"); } stServer.iServerSocket = s_iClientSocket; if(ThreadPoolSubmit(TCPSndTrd,&stServer,&iTaskID) < 0) { cmn_PrtError("Error in submitting task to thread pool"); } if (ThreadPoolSubmit(TCPRcvTrd,&stServer,&iTaskID) < 0) { cmn_PrtError("Error in submitting task to thread pool"); } while (g_iExit == 0) { } iRet = 0; _Exit: return iRet; } void* TCPRcvTrd(void *arg) { //int iSockfd = *(int*)arg; //int iSockfd = (int)(intptr_t)arg; //int iLoopNum = 0; stNetAddr * ServerAddr = (stNetAddr *)arg; int iSockfd = ServerAddr->iServerSocket; int iClientNum = ServerAddr->iClientNumber; char crcvBuffer[cmnDfn_BUFF_LEN]; int iBytesReceived; unsigned long long ulTotalBytes = 0; struct timeval stStartTime; struct timeval stEndTime; //struct timeval stDisplayedTime = {0}; float fElapsedTime; float fNetSpeed; gettimeofday(&stStartTime, NULL); while (g_iExit == 0) { if((iBytesReceived = recv(iSockfd, crcvBuffer, sizeof(crcvBuffer), 0)) < 0) { cmn_PrtError("Error in receiving data"); } else if(iBytesReceived == 0) { printf("Client disconnected\n"); break; } ulTotalBytes += iBytesReceived; gettimeofday(&stEndTime,NULL); fElapsedTime = (stEndTime.tv_sec - stStartTime.tv_sec) + (stEndTime.tv_usec - stStartTime.tv_usec) / 1000000.0; fNetSpeed = ((float)ulTotalBytes * 8) / (fElapsedTime * 1000 * 1000); if (fElapsedTime >= DISPLAY_INTERVAL) { //printf("Received: %d bytes\n", ulTotalBytes); if(ServerAddr->iByteNumber != 0) { printf("Client %d Net Speed: %.2f Mbps\r", iClientNum,fNetSpeed); fflush(stdout); } else if(ServerAddr->iByteNumber == 0) { printf("Net Speed: %.2f Mbps\n", fNetSpeed); fflush(stdout); } stStartTime = stEndTime; ulTotalBytes = 0; } } _Exit: //close(iSockfd); pthread_exit(NULL); }```给出代码运行逻辑和运行流程图