mirror of
https://github.com/emqx/neuron.git
synced 2026-10-22 09:23:52 +08:00
@@ -106,6 +106,7 @@ neu_conn_t *neu_conn_new(neu_conn_param_t *param, void *data,
|
||||
neu_conn_callback disconnected);
|
||||
neu_conn_t *neu_conn_reconfig(neu_conn_t *conn, neu_conn_param_t *param);
|
||||
void neu_conn_destory(neu_conn_t *conn);
|
||||
void neu_conn_disconnect(neu_conn_t *conn);
|
||||
int neu_conn_tcp_server_accept(neu_conn_t *conn);
|
||||
int neu_conn_tcp_server_close_client(neu_conn_t *conn, int fd);
|
||||
|
||||
|
||||
@@ -370,6 +370,11 @@ void neu_conn_flush(neu_conn_t *conn)
|
||||
}
|
||||
}
|
||||
|
||||
void neu_conn_disconnect(neu_conn_t *conn)
|
||||
{
|
||||
conn_disconnect(conn);
|
||||
}
|
||||
|
||||
static void conn_free_param(neu_conn_t *conn)
|
||||
{
|
||||
switch (conn->param.type) {
|
||||
|
||||
Reference in New Issue
Block a user