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

Change invalid_txn_id to global (for efficiency)

Browse source
This commit is contained in:
Andrew Morgan 2018-07-05 13:41:52 +01:00
parent f0c2ccb37a
commit 06bfc299ad
1 changed files with 6 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

7
src/github.com/matrix-org/dendrite/appservice/storage/appservice_events_table.go
View file

@ -57,6 +57,12 @@ const updateTxnIDForEventsSQL = "" +
const deleteEventsBeforeAndIncludingIDSQL = "" + const deleteEventsBeforeAndIncludingIDSQL = "" +
"DELETE FROM appservice_events WHERE as_id = $1 AND id <= $2" "DELETE FROM appservice_events WHERE as_id = $1 AND id <= $2"
const (
// A transaction ID number that no transaction should ever have. Used for
// checking again the default value.
invalidTxnID = -2
)
type eventsStatements struct { type eventsStatements struct {
selectEventsByApplicationServiceIDStmt *sql.Stmt selectEventsByApplicationServiceIDStmt *sql.Stmt
countEventsByApplicationServiceIDStmt *sql.Stmt countEventsByApplicationServiceIDStmt *sql.Stmt
@ -131,7 +137,6 @@ func retrieveEvents(eventRows *sql.Rows, limit int) (events []gomatrixserverlib.
// Iterate through each row and store event contents // Iterate through each row and store event contents
// If txn_id changes dramatically, we've switched from collecting old events to // If txn_id changes dramatically, we've switched from collecting old events to
// new ones. Send back those events first. // new ones. Send back those events first.
invalidTxnID := -2
lastTxnID := invalidTxnID lastTxnID := invalidTxnID
for eventsProcessed := 0; eventRows.Next(); { for eventsProcessed := 0; eventRows.Next(); {
var event gomatrixserverlib.Event var event gomatrixserverlib.Event