mirrors/dendrite
1
0
Fork 0
mirror of https://github.com/matrix-org/dendrite.git synced 2025-12-21 05:43:09 -06:00
Code Issues Packages Projects Releases Wiki Activity

Rename SQLiteTransactionWriter to ExclusiveTransactionWriter

Browse source
This commit is contained in:
Neil Alexander 2020-08-19 14:04:08 +01:00
parent 9f0e734840
commit a05ff7f635
No known key found for this signature in database
GPG key ID: A02A2019A2BB0944
1 changed files with 6 additions and 6 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

12
internal/sqlutil/writer_sqlite.go → internal/sqlutil/writer_exclusive.go
View file

@ -7,16 +7,16 @@ import (
"go.uber.org/atomic" "go.uber.org/atomic"
) )
// SQLiteTransactionWriter allows queuing database writes so that you don't // ExclusiveTransactionWriter allows queuing database writes so that you don't
// contend on database locks in, e.g. SQLite. Only one task will run // contend on database locks in, e.g. SQLite. Only one task will run
// at a time on a given SQLiteTransactionWriter. // at a time on a given ExclusiveTransactionWriter.
type SQLiteTransactionWriter struct { type ExclusiveTransactionWriter struct {
running atomic.Bool running atomic.Bool
todo chan transactionWriterTask todo chan transactionWriterTask
} }
func NewTransactionWriter() TransactionWriter { func NewTransactionWriter() TransactionWriter {
return &SQLiteTransactionWriter{ return &ExclusiveTransactionWriter{
todo: make(chan transactionWriterTask), todo: make(chan transactionWriterTask),
} }
} }
@ -34,7 +34,7 @@ type transactionWriterTask struct {
// txn parameter if one is supplied, and if not, will take out a // txn parameter if one is supplied, and if not, will take out a
// new transaction from the database supplied in the database // new transaction from the database supplied in the database
// parameter. Either way, this will block until the task is done. // parameter. Either way, this will block until the task is done.
func (w *SQLiteTransactionWriter) Do(db *sql.DB, txn *sql.Tx, f func(txn *sql.Tx) error) error { func (w *ExclusiveTransactionWriter) Do(db *sql.DB, txn *sql.Tx, f func(txn *sql.Tx) error) error {
if w.todo == nil { if w.todo == nil {
return errors.New("not initialised") return errors.New("not initialised")
} }
@ -55,7 +55,7 @@ func (w *SQLiteTransactionWriter) Do(db *sql.DB, txn *sql.Tx, f func(txn *sql.Tx
// of these goroutines will run at a time. A transaction will be // of these goroutines will run at a time. A transaction will be
// opened using the database object from the task and then this will // opened using the database object from the task and then this will
// be passed as a parameter to the task function. // be passed as a parameter to the task function.
func (w *SQLiteTransactionWriter) run() { func (w *ExclusiveTransactionWriter) run() {
if !w.running.CAS(false, true) { if !w.running.CAS(false, true) {
return return
} }