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

fix compile warning

Browse Source
This commit is contained in:
fengzero
2023-04-10 03:25:44 +00:00
parent 7548de61c6
commit e4e00b2d1b
1 changed files with 6 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/connection/connection.c
+6 -8
View File
@@ -69,7 +69,7 @@ struct neu_conn {
static void conn_tcp_server_add_client(neu_conn_t *conn, int fd,
struct sockaddr_in client);
static void conn_tcp_server_del_client(neu_conn_t *conn, int fd);
static void conn_tcp_server_replace_client(neu_conn_t *conn, int fd);
static int conn_tcp_server_replace_client(neu_conn_t *conn, int fd);
static void conn_tcp_server_listen(neu_conn_t *conn);
static void conn_tcp_server_stop(neu_conn_t *conn);
@@ -191,7 +191,7 @@ int neu_conn_tcp_server_accept(neu_conn_t *conn)
}
if (conn->tcp_server.n_client >= conn->param.params.tcp_server.max_link) {
int free_fd = conn_tcp_server_del_first_client(conn, fd);
int free_fd = conn_tcp_server_replace_client(conn, fd);
if (free_fd > 0) {
zlog_warn(conn->param.log, "replace old client %d with %d", free_fd,
fd);
@@ -898,23 +898,21 @@ static void conn_tcp_server_del_client(neu_conn_t *conn, int fd)
}
}
static void conn_tcp_server_replace_client(neu_conn_t *conn, int fd)
static int conn_tcp_server_replace_client(neu_conn_t *conn, int fd)
{
int ret = 0;
for (int i = 0; i < conn->param.params.tcp_server.max_link; i++) {
if (conn->tcp_server.clients[i].fd > 0) {
ret = conn->tcp_server.clients[i].fd;
int ret = conn->tcp_server.clients[i].fd;
close(conn->tcp_server.clients[i].fd);
conn->tcp_server.clients[i].fd = 0;
conn->tcp_server.clients[i].fd = fd;
return;
return ret;
}
}
return ret;
return 0;
}
int neu_conn_stream_consume(neu_conn_t *conn, void *context,