| 306 | } |
| 307 | |
| 308 | ssize_t fstack_recv(int sockfd, void* buf, size_t count, int flags, Timeout timeout) { |
| 309 | return photon::net::DOIO_ONCE(ff_recv(sockfd, buf, count, flags), |
| 310 | g_engine->wait_for_fd_writable(sockfd, timeout)); |
| 311 | } |
| 312 | |
| 313 | ssize_t fstack_recvmsg(int sockfd, struct msghdr* message, int flags, Timeout timeout) { |
| 314 | return photon::net::DOIO_ONCE(ff_recvmsg(sockfd, message, flags), |
no test coverage detected