thebestvibedev/tromcho.net
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Do not attempt to free outbound ops in clear_immediate_ops (fix #88)

Browse Source
This commit is contained in:
Vitaliy Filippov
2025-09-17 12:22:48 +03:00
parent 2d42f29385
commit 52bc3261e9
1 changed files with 3 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/client/msgr_receive.cpp
+3 -1
View File
@@ -109,6 +109,7 @@ bool osd_messenger_t::handle_read(int result, osd_client_t *cl)
if (!handle_read_buffer(cl, cl->in_buf, result)) if (!handle_read_buffer(cl, cl->in_buf, result))
{ {
clear_immediate_ops(peer_fd); clear_immediate_ops(peer_fd);
handle_immediate_ops();
return false; return false;
} }
} }
@@ -122,6 +123,7 @@ bool osd_messenger_t::handle_read(int result, osd_client_t *cl)
if (!handle_finished_read(cl)) if (!handle_finished_read(cl))
{ {
clear_immediate_ops(peer_fd); clear_immediate_ops(peer_fd);
handle_immediate_ops();
return false; return false;
} }
} }
@@ -140,7 +142,7 @@ void osd_messenger_t::clear_immediate_ops(int peer_fd)
size_t i = 0, j = 0; size_t i = 0, j = 0;
while (i < set_immediate_ops.size()) while (i < set_immediate_ops.size())
{ {
if (set_immediate_ops[i]->peer_fd == peer_fd) if (set_immediate_ops[i]->peer_fd == peer_fd && set_immediate_ops[i]->op_type == OSD_OP_IN)
{ {
delete set_immediate_ops[i]; delete set_immediate_ops[i];
} }