mirror of
https://github.com/emqx/neuron.git
synced 2026-10-21 16:55:53 +08:00
fix: close invalid fd
This commit is contained in:
@@ -858,6 +858,7 @@ static void conn_connect(neu_conn_t *conn)
|
||||
} else {
|
||||
zlog_error(conn->param.log, "invalid ip: %s",
|
||||
conn->param.params.tcp_server.ip);
|
||||
close(fd);
|
||||
return;
|
||||
}
|
||||
|
||||
@@ -926,6 +927,7 @@ static void conn_connect(neu_conn_t *conn)
|
||||
ret = bind(fd, (struct sockaddr *) &local,
|
||||
sizeof(struct sockaddr_in6));
|
||||
} else {
|
||||
close(fd);
|
||||
zlog_error(conn->param.log, "invalid ip: %s",
|
||||
conn->param.params.tcp_server.ip);
|
||||
return;
|
||||
@@ -1028,6 +1030,7 @@ static void conn_connect(neu_conn_t *conn)
|
||||
ret = bind(fd, (struct sockaddr *) &local,
|
||||
sizeof(struct sockaddr_in6));
|
||||
} else {
|
||||
close(fd);
|
||||
zlog_error(conn->param.log, "invalid ip: %s",
|
||||
conn->param.params.tcp_server.ip);
|
||||
return;
|
||||
|
||||
Reference in New Issue
Block a user