gfwleak/tango-kni
Archived
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

修复保活过程中从tfe收到reset包没有将tfe移除的bug

Browse Source
This commit is contained in:
崔一鸣
2019-06-21 15:05:50 +08:00
parent 76487ab332
commit b56d52a325
1 changed files with 2 additions and 13 deletions
Download Patch File Download Diff File Expand all files Collapse all files

15
entry/src/tfe_mgr.cpp
View File

@@ -124,15 +124,10 @@ static void* thread_tfe_keepalive_recv(void *args){
}
if(ret <= 0){
if(errno == EINTR || errno == EAGAIN || errno == EWOULDBLOCK){
KNI_LOG_ERROR(logger, "recv error, errno is %d, errmsg is %s, continue recv, tfe_id is %d", errno, strerror(errno), tfe_id);
continue;
}
if(errno == ETIMEDOUT){
KNI_LOG_ERROR(logger, "recv error, errno is %d, errmsg is %s, del tfe alive node, tfe_id is %d", errno, strerror(errno), tfe_id);
break;
}
KNI_LOG_ERROR(logger, "recv error, errno is %d, errmsg is %s, error_out, tfe_id is %d", errno, strerror(errno), tfe_id);
goto error_out;
KNI_LOG_ERROR(logger, "recv error, errno is %d, errmsg is %s, continue recv, tfe_id is %d", errno, strerror(errno), tfe_id);
break;
}
}
//recv fin: del alive node
@@ -146,12 +141,6 @@ static void* thread_tfe_keepalive_recv(void *args){
KNI_LOG_ERROR(logger, "Succeed at del tfe alive node, tfe_id is %d", tfe_id);
}
return NULL;
error_out:
if(client_fd > 0){
close(client_fd);
}
return NULL;
}
static void* thread_tfe_keepalive_accept(void *args){