Skip to content

Commit ac05c50

Browse files
fix avx2 deadlock bug
1 parent a9251fa commit ac05c50

File tree

1 file changed

+2
-0
lines changed

1 file changed

+2
-0
lines changed

core/commit_manager.hpp

+2
Original file line numberDiff line numberDiff line change
@@ -166,6 +166,7 @@ namespace livegraph
166166
check_unfinished_epoch_id();
167167
cv_client[local_client_mutex ^ 1].notify_all();
168168
}
169+
std::unique_lock<std::mutex> client_lock(client_mutex[local_client_mutex]);
169170

170171
global_client_mutex ^= 1;
171172

@@ -226,6 +227,7 @@ namespace livegraph
226227
lock.unlock();
227228
seq_front[local_client_mutex] += num_txns;
228229
cv_client[local_client_mutex].notify_all();
230+
client_lock.unlock();
229231

230232
--num_unfinished;
231233
}

0 commit comments

Comments
 (0)