Skip to content

Commit dfc17b0

Browse files
committed
move increment after tx commit
1 parent f5da9fe commit dfc17b0

File tree

1 file changed

+7
-6
lines changed

1 file changed

+7
-6
lines changed

sqlstore.go

Lines changed: 7 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -297,11 +297,7 @@ func (store *sqlStore) SaveMessageAndIncrNextSenderMsgSeqNum(seqNum int, msg []b
297297
return err
298298
}
299299

300-
if err := store.cache.IncrNextSenderMsgSeqNum(); err != nil {
301-
return errors.Wrap(err, "cache incr next")
302-
}
303-
304-
next := store.cache.NextSenderMsgSeqNum()
300+
next := store.cache.NextSenderMsgSeqNum() + 1
305301
_, err = tx.Exec(sqlString(`UPDATE sessions SET outgoing_seqnum = ?
306302
WHERE beginstring=? AND session_qualifier=?
307303
AND sendercompid=? AND sendersubid=? AND senderlocid=?
@@ -313,12 +309,17 @@ func (store *sqlStore) SaveMessageAndIncrNextSenderMsgSeqNum(seqNum int, msg []b
313309
return err
314310
}
315311

312+
err = tx.Commit()
313+
if err != nil {
314+
return err
315+
}
316+
316317
err = store.cache.SetNextSenderMsgSeqNum(next)
317318
if err != nil {
318319
return err
319320
}
320321

321-
return tx.Commit()
322+
return nil
322323
}
323324

324325
func (store *sqlStore) GetMessages(beginSeqNum, endSeqNum int) ([][]byte, error) {

0 commit comments

Comments
 (0)