GithubStar/neuron
1
0
Fork 0
mirror of https://github.com/emqx/neuron.git synced 2026-10-22 01:05:56 +08:00
Code Issues Packages Projects Releases Wiki Activity

Merge pull request #1639 from fengzeroz/v2.6

Browse Source 
chore(conn): disconnect if udp recv error
This commit is contained in:
fengzeroz
2023-11-01 03:49:41 -05:00
committed by GitHub
parent 2ac8e80145 d1d02d7413
commit 87474d76da
1 changed files with 13 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/connection/connection.c
+13 -3
View File
@@ -447,11 +447,21 @@ ssize_t neu_conn_recv(neu_conn_t *conn, uint8_t *buf, ssize_t len)
conn->fd, len, ret, strerror(errno), errno);
conn_disconnect(conn);
}
} else if (conn->param.type == NEU_CONN_UDP ||
conn->param.type == NEU_CONN_UDP_TO) {
if (ret <= 0) {
zlog_error(
conn->param.log,
"udp conn fd: %d, recv buf len %zd, ret: %zd, errno: %s(%d)",
conn->fd, len, ret, strerror(errno), errno);
conn_disconnect(conn);
}
} else {
if (ret <= 0) {
zlog_error(conn->param.log,
"conn fd: %d, recv buf len %zd, ret: %zd, errno: %s(%d)",
conn->fd, len, ret, strerror(errno), errno);
zlog_error(
conn->param.log,
"tcp conn fd: %d, recv buf len %zd, ret: %zd, errno: %s(%d)",
conn->fd, len, ret, strerror(errno), errno);
if (ret == 0 || (ret == -1 && errno != EAGAIN)) {
conn_disconnect(conn);
}