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

Merge pull request #639 from fengzeroz/main

Browse Source 
fix(connection): trigger disconnect callback if reconfig
This commit is contained in:
fengzeroz
2022-07-14 14:08:20 +08:00
committed by GitHub
parent 99424112b5 e477336fa1
commit 65fb38b419
1 changed files with 4 additions and 12 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/connection/connection.c
+4 -12
View File
@@ -243,10 +243,6 @@ ssize_t neu_conn_send(neu_conn_t *conn, uint8_t *buf, ssize_t len)
if (ret == -1 && errno != EAGAIN) {
conn_disconnect(conn);
if (conn->callback_trigger == true) {
conn->disconnected(conn->data, conn->fd);
conn->callback_trigger = false;
}
}
if (ret > 0 && conn->callback_trigger == false) {
@@ -296,10 +292,6 @@ ssize_t neu_conn_recv(neu_conn_t *conn, uint8_t *buf, ssize_t len)
if (errno == EPIPE || ret <= 0) {
conn_disconnect(conn);
if (conn->callback_trigger == true) {
conn->disconnected(conn->data, conn->fd);
conn->callback_trigger = false;
}
}
if (ret > 0 && conn->callback_trigger == false) {
@@ -350,10 +342,6 @@ void neu_conn_flush(neu_conn_t *conn)
void neu_conn_disconnect(neu_conn_t *conn)
{
conn_disconnect(conn);
if (conn->callback_trigger == true) {
conn->disconnected(conn->data, conn->fd);
conn->callback_trigger = false;
}
}
static void conn_free_param(neu_conn_t *conn)
@@ -723,6 +711,10 @@ static void conn_disconnect(neu_conn_t *conn)
}
conn->is_connected = false;
if (conn->callback_trigger == true) {
conn->disconnected(conn->data, conn->fd);
conn->callback_trigger = false;
}
}
static void conn_tcp_server_add_client(neu_conn_t *conn, int fd,