int acceptConnect(int listenFd,int epollFd){ int sockConnect = 0; int addrLen = 0; struct epoll_event tempEvent; struct sockaddr_in remoteAddr; addrLen = sizeof(struct sockaddr_in); sockConnect = accept(listenFd, (struct sockaddr*)&remoteAddr, &addrLen); if ( sockConnect return -1; } setnonblocking(sockConnect); tempEvent.events = EPOLLIN | EPOLLET; tempEvent.data.fd = sockConnect; if (epoll_ctl(epollFd, EPOLL_CTL_ADD, sockConnect, &tempEvent) return -1; } return 0;} int initEpollFd(int listenFd) { struct epoll_event ev; int epfd = 0; epfd = epoll_create(MAX_EPOLL_FD); ev.events = EPOLLIN; ev.data.fd = listenFd; if (epoll_ctl(epfd,EPOLL_CTL_ADD,listenFd,&ev) return -1; } return epfd; }int initSrvSock(int port){ int ListenFd = 0; struct sockaddr_in serverAddr; int opts = 0x1; int ret = 0; bzero(&serverAddr, sizeof(struct sockaddr_in)); serverAddr.sin_family = AF_INET; serverAddr.sin_addr.s_addr = INADDR_ANY; serverAddr.sin_port = htons(port); ListenFd = socket(AF_INET, SOCK_STREAM, 0); if (ListenFd return -1; } setnonblocking(ListenFd); ret = setsockopt(ListenFd, SOL_SOCKET, SO_REUSEADDR, &opts, sizeof(int)); if ( ret == -1) { return -1; } ret = bind(ListenFd, (struct sockaddr *)&serverAddr, sizeof(serverAddr)); if (ret return -1; } ret = listen(ListenFd, MAX_CONN); if (ret return -1; } return ListenFd;}int processRequest(){ int i = 0; int epollFd = 0; int listenFd = 0; int nfds = 0; static actionPar par = { 0 }; struct epoll_event events[EV_LEN]; listenFd = initSrvSock(LISTEN_PORT); if (-1 == listenFd) { return -1; } epollFd = initEpollFd(listenFd); if (-1 == epollFd) { return -1; } while (1) { nfds = epoll_wait(epollFd, events, EV_LEN, TIMEOUT); for ( i = 0 ; i if ( listenFd == events[i].data.fd ) { acceptConnect(listenFd,epollFd); } else { if (recvData(events[i].data.fd,par.data, sizeof(par.data)) > 0) { par.sockFd = events[i].data.fd; par.dataSize = strlen(par.data); parseData(&par); } } } } return 0;}
