mirror of
https://github.com/emqx/neuron.git
synced 2026-10-21 00:36:23 +08:00
fix(connection): disconnect if recv return 0
This commit is contained in:
@@ -389,7 +389,7 @@ ssize_t neu_conn_recv(neu_conn_t *conn, uint8_t *buf, ssize_t len)
|
||||
conn->fd, len, ret, strerror(errno), errno);
|
||||
}
|
||||
|
||||
if (errno == EPIPE || ret == -1) {
|
||||
if (errno == EPIPE || ret == -1 || ret == 0) {
|
||||
conn_disconnect(conn);
|
||||
}
|
||||
|
||||
|
||||
@@ -48,6 +48,7 @@ static void sig_handler(int sig)
|
||||
}
|
||||
zlog_fini();
|
||||
exit_flag = true;
|
||||
exit(-1);
|
||||
}
|
||||
|
||||
static int neuron_run(const neu_cli_args_t *args)
|
||||
|
||||
Reference in New Issue
Block a user