fixit

llarp/ev.hpp

@@ -456,6 +456,9 @@ namespace llarp
       flush_write_buffers(0);
     }
 
+    virtual void
+    before_flush_write(){};
+
     /// called in event loop when fd is ready for writing
     /// requeues anything not written
     /// this assumes fd is set to non blocking
@@ -463,11 +466,14 @@ namespace llarp
     flush_write_buffers(size_t amount)
     {
       if(m_LossyWriteQueue)
+      {
+        before_flush_write();
         m_LossyWriteQueue->Process([&](WriteBuffer& buffer) {
           do_write(buffer.buf, buffer.bufsz);
           // if we would block we save the entries for later
           // discard entry
         });
+      }
       else if(m_BlockingWriteQueue)
       {
         if(amount)

llarp/ev_kqueue.hpp

@@ -244,12 +244,11 @@ namespace llarp
 #endif
 
     void
-    flush_write()
+    before_flush_write() override
     {
       if(t->before_write)
       {
         t->before_write(t);
-        ev_io::flush_write();
       }
     }
 
@@ -258,7 +257,6 @@ namespace llarp
     {
       if(t->tick)
         t->tick(t);
-      flush_write();
       return true;
     }