set st to idle when block timeout

baidu · May 24, 2023 · 9c2a4ee · 9c2a4ee
1 parent 334730e
commit 9c2a4ee
Showing 1 changed file with 7 additions and 0 deletions.
diff --git a/src/braft/replicator.cpp b/src/braft/replicator.cpp
@@ -218,6 +218,13 @@ void Replicator::wait_for_caught_up(ReplicatorId id,
 }
 
 void* Replicator::_on_block_timedout_in_new_thread(void* arg) {
+    Replicator* r = NULL;
+    bthread_id_t id = { (uint64_t)arg };
+    if (bthread_id_lock(id, (void**)&r) != 0) {
+        return NULL;
+    }
+    r->_st.st = IDLE;
+    bthread_id_unlock(id);
     Replicator::_continue_sending(arg, ETIMEDOUT);
     return NULL;
 }