| 301 | } |
| 302 | |
| 303 | ssize_t fstack_sendmsg(int sockfd, const struct msghdr* message, int flags, Timeout timeout) { |
| 304 | return photon::net::DOIO_ONCE(ff_sendmsg(sockfd, message, flags), |
| 305 | g_engine->wait_for_fd_writable(sockfd, timeout)); |
| 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), |
no test coverage detected