mirror of
https://github.com/emqx/neuron.git
synced 2026-10-28 14:07:20 +08:00
delay 10ms
This commit is contained in:
@@ -355,7 +355,12 @@ ssize_t neu_conn_send(neu_conn_t *conn, uint8_t *buf, ssize_t len)
|
||||
conn->fd, len, ret, strerror(errno), errno);
|
||||
break;
|
||||
} else {
|
||||
sleep(1);
|
||||
struct timespec t1 = {
|
||||
.tv_sec = 0,
|
||||
.tv_nsec = 1000 * 1000 * 10,
|
||||
};
|
||||
struct timespec t2 = { 0 };
|
||||
nanosleep(&t1, &t2);
|
||||
retry++;
|
||||
zlog_warn(conn->param.log,
|
||||
"not all data send, retry: %d, ret: "
|
||||
|
||||
Reference in New Issue
Block a user