upstream/icingadb
1
0
Fork 0
mirror of https://github.com/Icinga/icingadb.git synced 2026-05-28 04:35:54 -04:00
Code Issues Projects Releases Packages Wiki Activity Actions 1

Merge branch 'bugfix/serializable' into 'master'

Browse source 
Get rid of serializable transactions

See merge request icingadb/icingadb-main!28
This commit is contained in:
Eric Lippmann 2019-10-25 11:40:11 +02:00
commit 10fdcd3362
2 changed files with 2 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
configobject/history/history.go
View file

@ -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(

2
configobject/statesync/statesync.go
View file

@ -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))