mirror of
https://github.com/k3s-io/kubernetes.git
synced 2025-09-16 22:53:22 +00:00
upgrade etcd deps to v3.5.7
Signed-off-by: Paco Xu <paco.xu@daocloud.io>
This commit is contained in:
7
vendor/go.etcd.io/etcd/server/v3/mvcc/backend/batch_tx.go
generated
vendored
7
vendor/go.etcd.io/etcd/server/v3/mvcc/backend/batch_tx.go
generated
vendored
@@ -329,10 +329,6 @@ func (t *batchTxBuffered) CommitAndStop() {
|
||||
}
|
||||
|
||||
func (t *batchTxBuffered) commit(stop bool) {
|
||||
if t.backend.hooks != nil {
|
||||
t.backend.hooks.OnPreCommitUnsafe(t)
|
||||
}
|
||||
|
||||
// all read txs must be closed to acquire boltdb commit rwlock
|
||||
t.backend.readTx.Lock()
|
||||
t.unsafeCommit(stop)
|
||||
@@ -340,6 +336,9 @@ func (t *batchTxBuffered) commit(stop bool) {
|
||||
}
|
||||
|
||||
func (t *batchTxBuffered) unsafeCommit(stop bool) {
|
||||
if t.backend.hooks != nil {
|
||||
t.backend.hooks.OnPreCommitUnsafe(t)
|
||||
}
|
||||
if t.backend.readTx.tx != nil {
|
||||
// wait all store read transactions using the current boltdb tx to finish,
|
||||
// then close the boltdb tx
|
||||
|
Reference in New Issue
Block a user