don't queue on full write queue

4 years ago · 42f721d691
parent 6d42b5f997
commit 42f721d691
1 changed files with 5 additions and 4 deletions
--- a/llarp/ev/ev_libuv.cpp
+++ b/llarp/ev/ev_libuv.cpp
@ -225,13 +225,14 @@ namespace libuv
        return -1;
      WriteBuffer_t buf(sz);
      std::copy_n(data, sz, buf.begin());
-      if(m_WriteQueue.pushBack(std::move(buf))
+      int result = -1;
+      if(m_WriteQueue.tryPushBack(std::move(buf))
         == llarp::thread::QueueReturn::Success)
      {
-        uv_async_send(&m_WriteNotify);
-        return sz;
+        result = sz;
      }
-      return -1;
+      uv_async_send(&m_WriteNotify);
+      return sz;
    }

    void