Fix socket send in resolver (#42)

resetius · Sep 12, 2024 · 2768f45 · 2768f45
1 parent c736dad
commit 2768f45
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/coroio/resolver.cpp b/coroio/resolver.cpp
@@ -1,5 +1,6 @@
 #include "resolver.hpp"
 #include "socket.hpp"
+#include "sockutils.hpp"
 #include "promises.hpp"
 #ifdef __linux__
 #include "uring.hpp"
@@ -216,8 +217,7 @@ TFuture<void> TResolver<TPoller>::SenderTask() {
         Inflight[Xid] = req;
         CreatePacket(req.Name, req.Type, buf, &len, Xid);
         Xid = 1 + (Xid + 1) % 65535;
-        auto size = co_await Socket.WriteSome(buf, len);
-        assert(size == len);
+        co_await TByteWriter(Socket).Write(buf, len);
     }
     co_return;
 }