mirror of
https://github.com/emqx/neuron.git
synced 2026-10-27 12:28:44 +08:00
Merge pull request #888 from fengzeroz/main
connection(serial): wait reading all msg
This commit is contained in:
@@ -342,6 +342,15 @@ ssize_t neu_conn_recv(neu_conn_t *conn, uint8_t *buf, ssize_t len)
|
||||
break;
|
||||
case NEU_CONN_TTY_CLIENT:
|
||||
ret = read(conn->fd, buf, len);
|
||||
while (ret > 0 && ret < len) {
|
||||
ssize_t rv = read(conn->fd, buf + ret, len - ret);
|
||||
if (rv <= 0) {
|
||||
ret = rv;
|
||||
break;
|
||||
}
|
||||
|
||||
ret += rv;
|
||||
}
|
||||
break;
|
||||
}
|
||||
if (ret <= 0) {
|
||||
|
||||
Reference in New Issue
Block a user