From c6af9a230ceb7378e78892c65c1cbdca0fb3f5ee Mon Sep 17 00:00:00 2001 From: "Alexander A. Klimov" Date: Wed, 23 Oct 2019 12:53:18 +0200 Subject: [PATCH] Get rid of serializable transactions --- configobject/history/history.go | 2 +- configobject/statesync/statesync.go | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/configobject/history/history.go b/configobject/history/history.go index 841f6b9c..6bcb83bc 100644 --- a/configobject/history/history.go +++ b/configobject/history/history.go @@ -384,7 +384,7 @@ func historyWorker(super *supervisor.Supervisor, objectType string, historyType } for { - errTx := super.Dbw.SqlTransaction(true, true, false, func(tx connection.DbTransaction) error { + errTx := super.Dbw.SqlTransaction(false, true, false, func(tx connection.DbTransaction) error { for i, state := range entries { for statementIndex, statement := range preparedStatements { _, errExec := super.Dbw.SqlExecTx( diff --git a/configobject/statesync/statesync.go b/configobject/statesync/statesync.go index 60cc84bb..9e80d0d1 100644 --- a/configobject/statesync/statesync.go +++ b/configobject/statesync/statesync.go @@ -86,7 +86,7 @@ func syncStates(super *supervisor.Supervisor, objectType string) { } for { - errTx := super.Dbw.SqlTransaction(true, true, false, func(tx connection.DbTransaction) error { + errTx := super.Dbw.SqlTransaction(false, true, false, func(tx connection.DbTransaction) error { for i, state := range states { values := state.Values id, _ := hex.DecodeString(values["id"].(string))