| 498 | } |
| 499 | |
| 500 | ssize_t do_sendmsg(int sockfd, const struct msghdr* message, int flags, Timeout timeout) override { |
| 501 | ssize_t n = photon::net::sendmsg(sockfd, message, flags | ZEROCOPY_FLAG, timeout); |
| 502 | m_num_calls++; |
| 503 | auto ret = zerocopy_confirm(sockfd, m_num_calls - 1, timeout); |
| 504 | if (ret < 0) |
| 505 | return ret; |
| 506 | return n; |
| 507 | } |
| 508 | }; |
| 509 | |
| 510 | class ZeroCopySocketServer : public KernelSocketServer { |
nothing calls this directly
no test coverage detected