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

fix print client info in connection

Browse Source
This commit is contained in:
fengzero
2022-03-16 08:13:25 +00:00
parent d244079e67
commit 50fa869cca
1 changed files with 5 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/connection/connection.c
+5 -6
View File
@@ -155,7 +155,7 @@ int neu_conn_get_fd(neu_conn_t *conn)
int neu_conn_tcp_server_accept(neu_conn_t *conn)
{
struct sockaddr_in client = { 0 };
socklen_t client_len = 0;
socklen_t client_len = sizeof(struct sockaddr_in);
int fd = 0;
pthread_mutex_lock(&conn->mtx);
@@ -197,9 +197,10 @@ int neu_conn_tcp_server_accept(neu_conn_t *conn)
conn->connected(conn->data, fd);
conn->callback_trigger = true;
log_info("%s:%d accpet new client: %s:%d", conn->param.params.tcp_server.ip,
log_info("%s:%d accpet new client: %s:%d, fd: %d",
conn->param.params.tcp_server.ip,
conn->param.params.tcp_server.port, inet_ntoa(client.sin_addr),
ntohs(client.sin_port));
ntohs(client.sin_port), fd);
pthread_mutex_unlock(&conn->mtx);
@@ -224,7 +225,7 @@ int neu_conn_tcp_server_close_client(neu_conn_t *conn, int fd)
ssize_t neu_conn_tcp_server_send(neu_conn_t *conn, int fd, uint8_t *buf,
ssize_t len)
{
(void) conn;
conn_tcp_server_listen(conn);
ssize_t ret = send(fd, buf, len, MSG_NOSIGNAL);
if (ret != len) {
log_error("tcp server fd: %d, send buf len: %d, ret: %d, "
@@ -262,8 +263,6 @@ ssize_t neu_conn_send(neu_conn_t *conn, uint8_t *buf, ssize_t len)
pthread_mutex_lock(&conn->mtx);
conn_tcp_server_listen(conn);
if (conn->is_connected) {
switch (conn->param.type) {
case NEU_CONN_TCP_SERVER: