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

Merge pull request #1302 from fengzeroz/v2.4

Browse Source 
fix(connection): disconnect if decode fail
This commit is contained in:
fengzeroz
2023-06-01 17:40:12 +08:00
committed by GitHub
parent 8d8afa3c84 2f2fc27b49
commit cee2260cfd
1 changed files with 6 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/connection/connection.c
+6 -4
View File
@@ -942,8 +942,7 @@ int neu_conn_stream_consume(neu_conn_t *conn, void *context,
if (used == 0) {
break;
} else if (used == -1) {
memset(conn->buf, 0, conn->buf_size);
conn->offset = 0;
neu_conn_disconnect(conn);
break;
}
}
@@ -974,8 +973,7 @@ int neu_conn_stream_tcp_server_consume(neu_conn_t *conn, int fd, void *context,
if (used == 0) {
break;
} else if (used == -1) {
memset(conn->buf, 0, conn->buf_size);
conn->offset = 0;
neu_conn_tcp_server_close_client(conn, fd);
break;
}
}
@@ -1013,6 +1011,8 @@ int neu_conn_wait_msg(neu_conn_t *conn, void *context, uint16_t n_byte,
result.need, conn->buf_size, conn->offset);
return -1;
}
} else if (result.need == 0) {
return result.used;
} else {
neu_conn_disconnect(conn);
return result.used;
@@ -1046,6 +1046,8 @@ int neu_conn_tcp_server_wait_msg(neu_conn_t *conn, int fd, void *context,
result.need, conn->buf_size, conn->offset);
return -1;
}
} else if (result.need == 0) {
return result.used;
} else {
neu_conn_tcp_server_close_client(conn, fd);
return result.used;