diff options
Diffstat (limited to 'src/io-unix.c')
-rw-r--r-- | src/io-unix.c | 16 |
1 files changed, 8 insertions, 8 deletions
diff --git a/src/io-unix.c b/src/io-unix.c index ea65a76..39cdf64 100644 --- a/src/io-unix.c +++ b/src/io-unix.c @@ -119,7 +119,7 @@ int tf_read_fully(struct tf_fd *fd, void *buf, size_t count) continue; } - r = tf_schedule(); + r = __tf_fiber_schedule(); } while (r == TF_WAKEUP_FD); tf_fd_unmonitor(fd); @@ -152,7 +152,7 @@ int tf_write_fully(struct tf_fd *fd, const void *buf, size_t count) continue; } - r = tf_schedule(); + r = __tf_fiber_schedule(); } while (r == TF_WAKEUP_FD); tf_fd_unmonitor(fd); @@ -174,7 +174,7 @@ ssize_t tf_read(struct tf_fd *fd, void *buf, size_t count) n = -errno; break; } - n = tf_schedule(); + n = __tf_fiber_schedule(); } while (n == TF_WAKEUP_FD); tf_fd_unmonitor(fd); @@ -196,7 +196,7 @@ ssize_t tf_write(struct tf_fd *fd, const void *buf, size_t count) n = -errno; break; } - n = tf_schedule(); + n = __tf_fiber_schedule(); } while (n == TF_WAKEUP_FD); tf_fd_unmonitor(fd); @@ -270,7 +270,7 @@ int tf_accept(struct tf_fd *listen_fd, struct tf_fd *child_fd, tf_fd_unmonitor(listen_fd); return -errno; } - r = tf_schedule(); + r = __tf_fiber_schedule(); } while (r == TF_WAKEUP_FD); tf_fd_unmonitor(listen_fd); if (r < 0) @@ -293,7 +293,7 @@ int tf_connect(struct tf_fd *fd, const struct tf_sockaddr *to) /* Wait for socket to become readable */ tf_fd_monitor(fd, EPOLLOUT); - r = tf_schedule(); + r = __tf_fiber_schedule(); tf_fd_unmonitor(fd); if (r != TF_WAKEUP_FD) return r; @@ -337,7 +337,7 @@ ssize_t tf_recvmsg(struct tf_fd *fd, r = -errno; break; } - r = tf_schedule(); + r = __tf_fiber_schedule(); } while (r == TF_WAKEUP_FD); tf_fd_unmonitor(fd); @@ -400,7 +400,7 @@ ssize_t tf_sendmsg(struct tf_fd *fd, r = -errno; break; } - r = tf_schedule(); + r = __tf_fiber_schedule(); } while (r == TF_WAKEUP_FD); tf_fd_unmonitor(fd); |