• Marko Mäkelä's avatar
    MDEV-24449 cleanup: Remove a timeout · 3b7dbdf0
    Marko Mäkelä authored
    recv_sys_t::apply(): At the end of the last batch, wait for
    pending reads to complete (read_slots->wait()), instead of
    waiting for some time, and assert that buf_pool.n_pend_reads==0
    after that wait.
    
    io_callback(): Do not invoke read_slots->release()
    before the callback function has returned, to ensure
    the correct operation of recv_sys_t::apply().
    3b7dbdf0
log0recv.cc 111 KB