Fix attempting to close an already closed connection

unum-cloud · May 13, 2024 · 02548db · 02548db
1 parent 6120231
commit 02548db
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/src/engine_uring.cpp b/src/engine_uring.cpp
@@ -947,7 +947,8 @@ void automata_t::receive_next() noexcept {
 void automata_t::operator()() noexcept {
 
     if (is_corrupted())
-        return close_gracefully();
+        if ( connection.stage != stage_t::waiting_to_close_k )
+            return close_gracefully();
 
     switch (connection.stage) {