Batch handle_immediate_ops more

2026-04-03 21:22:42 +03:00
parent ea280609ce
commit 1eec28bc65
3 changed files with 7 additions and 5 deletions
@@ -75,6 +75,7 @@ void osd_messenger_t::read_requests()
        }
    }
    read_ready_clients.clear();
+    handle_immediate_ops();
 }

 void osd_messenger_t::handle_read(int result, osd_client_t *cl)
@@ -110,7 +111,8 @@ void osd_messenger_t::handle_read(int result, osd_client_t *cl)
            full_read = result >= cl->read_iov.iov_len;
            if (!handle_read_buffer(cl, cl->in_buf, result))
            {
-                handle_immediate_ops();
+                if (set_immediate_ops.size())
+                    ringloop->wakeup();
                return;
            }
        }
@@ -153,7 +155,8 @@ void osd_messenger_t::handle_read(int result, osd_client_t *cl)
    {
        read_ready_clients.push_back(cl->client_id);
    }
-    handle_immediate_ops();
+    if (set_immediate_ops.size())
+        ringloop->wakeup();
 }

 void osd_messenger_t::handle_immediate_ops()