mirror of
https://github.com/emqx/neuron.git
synced 2026-10-21 16:55:53 +08:00
@@ -122,6 +122,7 @@ static nng_http_server *server_init(char *type)
|
||||
|
||||
ret = nng_http_server_hold(&server, url);
|
||||
if (ret != 0) {
|
||||
nlog_error("rest api server bind error: %d", ret);
|
||||
return NULL;
|
||||
}
|
||||
nng_url_free(url);
|
||||
|
||||
@@ -257,6 +257,9 @@ ssize_t neu_conn_send(neu_conn_t *conn, uint8_t *buf, ssize_t len)
|
||||
"conn fd: %d, send buf len: %zd, ret: %zd, "
|
||||
"errno: %s(%d)",
|
||||
conn->fd, len, ret, strerror(errno), errno);
|
||||
} else {
|
||||
nlog_debug("conn fd: %d, send buf len %zd success, ret: %zd",
|
||||
conn->fd, len, ret);
|
||||
}
|
||||
|
||||
if (ret == -1 && errno != EAGAIN) {
|
||||
@@ -310,6 +313,9 @@ ssize_t neu_conn_recv(neu_conn_t *conn, uint8_t *buf, ssize_t len)
|
||||
zlog_error(neuron,
|
||||
"conn fd: %d, recv buf len %zd, ret: %zd, errno: %s(%d)",
|
||||
conn->fd, len, ret, strerror(errno), errno);
|
||||
} else {
|
||||
nlog_debug("conn fd: %d, recv buf len %zd success, ret: %zd", conn->fd,
|
||||
len, ret);
|
||||
}
|
||||
|
||||
if (errno == EPIPE || ret <= 0) {
|
||||
|
||||
Reference in New Issue
Block a user