io: check connection error only on net_io_read
@@ -316,15 +316,10 @@ static FLB_INLINE int net_io_write_async(struct flb_coro *co,
static ssize_t fd_io_read(int fd, void *buf, size_t len);
static ssize_t net_io_read(struct flb_upstream_conn *u_conn,
void *buf, size_t len)
-{
- return fd_io_read(u_conn->fd, buf, len);
-}
-
-static ssize_t fd_io_read(int fd, void *buf, size_t len)
{
int ret;
- ret = recv(fd, buf, len, 0);
+ ret = fd_io_read(u_conn->fd, buf, len);
if (ret == -1) {
ret = FLB_WOULDBLOCK();
if (ret) {
@@ -340,6 +335,18 @@ static ssize_t fd_io_read(int fd, void *buf, size_t len)
return ret;
}
+static ssize_t fd_io_read(int fd, void *buf, size_t len)
+{
+ int ret;
+
+ ret = recv(fd, buf, len, 0);
+ if (ret == -1) {
+ return -1;
+ }
+
+ return ret;
+}
+
static FLB_INLINE ssize_t net_io_read_async(struct flb_coro *co,
struct flb_upstream_conn *u_conn,
void *buf, size_t len)
