- 论坛徽章:
- 0
|
epoll主动关闭一个没有心跳的套接字后
会自动跳到重新连接函数(accept());
///////////////////服务器主动关闭客户端
if (time(NULL) - iter->second.last_active > s_nSecond)
{
printf("del no heart beat sock\n");
EpollCloseSock(sock);
close(sock);
sock = EX_SOCK_INVALID;
}
////
void EpollCloseSock(int sockfd)
{
printf("Dev Close Sock :%d\n",sockfd);
EpollDel(sockfd);
m_MapBuf[sockfd] = "";
}
////
void EpollDel(int sock)
{
struct epoll_event ev;
ev.events = EPOLLIN|EPOLLET;
ev.data.fd = sock;
if(epoll_ctl(m_epfd, EPOLL_CTL_DEL, sock, &ev) < 0)
{
perror("epoll_ctl:EPOLL_CTL_DEL");
}
}
//////以上是代码的部分功能,请各路高手帮我分析原因。
//Accept
if (pEvent->data.fd == lisSocket)
{
if(pEvent->events & EPOLLIN)
{
int confd = 0;
while (true)
{
confd = EpollAccept(); //每次主动关闭客户端的时候,客户端会自动重连。
if (confd > 0)
{
AddOneConnection(confd);
SetNonBlocking(confd);
EpollAddNewClient(confd);
}
else
{
if(errno == EAGAIN)
{
break;
}
}
}
}
}
else if(pEvent->events & EPOLLIN)
//if(pEvent->events & EPOLLIN)
{
if (pEvent->data.fd <= 0)
{
return;
}
Read(pEvent->data.fd);
} |
|