diff --git a/entry/src/tfe_mgr.cpp b/entry/src/tfe_mgr.cpp index 4755c4d..09c5793 100644 --- a/entry/src/tfe_mgr.cpp +++ b/entry/src/tfe_mgr.cpp @@ -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){