Update return types.

Author: MA-ETL

src/io/sendmsg_zc.rs

@@ -34,13 +34,15 @@ impl Op<SendMsgZc, MultiCQEFuture> {
 }
 
 impl Completable for SendMsgZc {
-    type Output = io::Result<usize>;
+    //type Output = io::Result<usize>;
 
-    fn complete(self, cqe: CqeResult) -> Self::Output {
+    fn complete(self, cqe: CqeResult) -> (libc::msghdr, io::Result<usize>) {
         // Convert the operation result to `usize`
         let res = cqe.result.map(|v| v as usize);
+
+        let msghdr = self.msghdr;
 
-        res
+        (msghdr, res)
     }
 }
 

src/io/socket.rs

@@ -147,7 +147,7 @@ impl Socket {
         op.await
     }
 
-    pub(crate) async fn sendmsg_zc(&self, msghdr: &libc::msghdr) -> io::Result<usize> {
+    pub(crate) async fn sendmsg_zc(&self, msghdr: &libc::msghdr) -> (libc::msghdr, io::Result<usize>) {
         let op = Op::sendmsg_zc(&self.fd, msghdr).unwrap();
         op.await
     }

src/net/udp.rs

@@ -220,7 +220,7 @@ impl UdpSocket {
         self.inner.send_zc(buf).await
     }
 
-    pub async fn sendmsg_zc(&self, msghdr: &libc::msghdr) -> io::Result<usize> {
+    pub async fn sendmsg_zc(&self, msghdr: &libc::msghdr) -> (libc::msghdr, io::Result<usize>)  {
         self.inner.sendmsg_zc(msghdr).await
     }