Skip to content

Commit

Permalink
Fixes
Browse files Browse the repository at this point in the history
  • Loading branch information
AlCutter committed Dec 2, 2024
1 parent 0e2fc71 commit e756f77
Show file tree
Hide file tree
Showing 2 changed files with 3 additions and 2 deletions.
3 changes: 2 additions & 1 deletion cmd/conformance/mysql/main.go
Original file line number Diff line number Diff line change
Expand Up @@ -40,6 +40,7 @@ var (
initSchemaPath = flag.String("init_schema_path", "", "Location of the schema file if database initialization is needed")
listen = flag.String("listen", ":2024", "Address:port to listen on")
privateKeyPath = flag.String("private_key_path", "", "Location of private key file")
publishInterval = flag.Duration("publish_interval", 3*time.Second, "How frequently to publish updated checkpoints")
additionalPrivateKeyPaths = []string{}
)

Expand All @@ -61,7 +62,7 @@ func main() {
// Initialise the Tessera MySQL storage
storage, err := mysql.New(ctx, db,
tessera.WithCheckpointSigner(noteSigner, additionalSigners...),
tessera.WithCheckpointInterval(3*time.Second),
tessera.WithCheckpointInterval(*publishInterval),
)
if err != nil {
klog.Exitf("Failed to create new MySQL storage: %v", err)
Expand Down
2 changes: 1 addition & 1 deletion storage/mysql/mysql.go
Original file line number Diff line number Diff line change
Expand Up @@ -495,7 +495,7 @@ func (s *Storage) integrate(ctx context.Context, tx *sql.Tx, fromSeq uint64, ent
}
}

// Write new checkpoint.
// Write new tree state.
if err := s.writeTreeState(ctx, tx, newSize, newRoot); err != nil {
return fmt.Errorf("writeCheckpoint: %w", err)
}
Expand Down

0 comments on commit e756f77

Please sign in to comment.