From e97b7162da9f034819390f658eadabe8b9ccead6 Mon Sep 17 00:00:00 2001 From: Cong Zhao Date: Wed, 30 Jan 2019 19:29:01 +0800 Subject: [PATCH] fix missing commit at latest release --- server/concurrent/async_local_client.go | 1 + 1 file changed, 1 insertion(+) diff --git a/server/concurrent/async_local_client.go b/server/concurrent/async_local_client.go index 7b8dd9c49..6071f24c9 100644 --- a/server/concurrent/async_local_client.go +++ b/server/concurrent/async_local_client.go @@ -380,6 +380,7 @@ func (app *asyncLocalClient) CommitSync() (*types.ResponseCommit, error) { app.commitLock.Lock() // this must come before the wgCommit.Wait() defer app.commitLock.Unlock() app.checkTxMidLock.Unlock() + app.wgCommit.Wait() // wait for all the submitted CheckTx/DeliverTx/Query finish app.rwLock.Lock() defer app.rwLock.Unlock() // only checkTxLock is locked here