diff --git a/pkg/database/sql/sql.go b/pkg/database/sql/sql.go index 96bacfb1e..473aa82b9 100644 --- a/pkg/database/sql/sql.go +++ b/pkg/database/sql/sql.go @@ -38,7 +38,7 @@ var ( type DB struct { write *conn read []*conn - idx int64 + idx uint64 master *DB } @@ -217,8 +217,8 @@ func (db *DB) readIndex() int { if len(db.read) == 0 { return 0 } - v := atomic.AddInt64(&db.idx, 1) - return int(v) % len(db.read) + v := atomic.AddUint64(&db.idx, 1) + return int(v % uint64(len(db.read))) } // Close closes the write and read database, releasing any open resources.