- 論壇徽章:
- 0
|
epoll主動關(guān)閉一個沒有心跳的套接字后
會自動跳到重新連接函數(shù)(accept());
///////////////////服務(wù)器主動關(guān)閉客戶端
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(); //每次主動關(guān)閉客戶端的時候,客戶端會自動重連。
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);
} |
|