Skip to content

Commit

Permalink
Update callers
Browse files Browse the repository at this point in the history
  • Loading branch information
AlCutter committed Jan 9, 2025
1 parent 88f6ad5 commit 3d768c8
Show file tree
Hide file tree
Showing 4 changed files with 20 additions and 4 deletions.
6 changes: 5 additions & 1 deletion storage/aws/aws.go
Original file line number Diff line number Diff line change
Expand Up @@ -428,7 +428,11 @@ func (s *Storage) integrate(ctx context.Context, fromSeq uint64, entries []stora
})

errG.Go(func() error {
newSize, root, tiles, err := storage.Integrate(ctx, getTiles, fromSeq, entries)
lh := make([][]byte, len(entries))
for i, e := range entries {
lh[i] = e.LeafHash
}
newSize, root, tiles, err := storage.Integrate(ctx, getTiles, fromSeq, lh)
if err != nil {
return fmt.Errorf("Integrate: %v", err)
}
Expand Down
6 changes: 5 additions & 1 deletion storage/gcp/gcp.go
Original file line number Diff line number Diff line change
Expand Up @@ -382,7 +382,11 @@ func (s *Storage) integrate(ctx context.Context, fromSeq uint64, entries []stora
return n, nil
}

newSize, root, tiles, err := storage.Integrate(ctx, getTiles, fromSeq, entries)
lh := make([][]byte, len(entries))
for i, e := range entries {
lh[i] = e.LeafHash
}
newSize, root, tiles, err := storage.Integrate(ctx, getTiles, fromSeq, lh)
if err != nil {
return fmt.Errorf("Integrate: %v", err)
}
Expand Down
6 changes: 5 additions & 1 deletion storage/mysql/mysql.go
Original file line number Diff line number Diff line change
Expand Up @@ -501,7 +501,11 @@ func (s *Storage) integrate(ctx context.Context, tx *sql.Tx, fromSeq uint64, ent
}
}

newSize, newRoot, tiles, err := storage.Integrate(ctx, getTiles, fromSeq, sequencedEntries)
lh := make([][]byte, len(sequencedEntries))
for i, e := range sequencedEntries {
lh[i] = e.LeafHash
}
newSize, newRoot, tiles, err := storage.Integrate(ctx, getTiles, fromSeq, lh)
if err != nil {
return fmt.Errorf("tb.Integrate: %v", err)
}
Expand Down
6 changes: 5 additions & 1 deletion storage/posix/files.go
Original file line number Diff line number Diff line change
Expand Up @@ -275,7 +275,11 @@ func (s *Storage) doIntegrate(ctx context.Context, fromSeq uint64, entries []sto
return n, nil
}

newSize, newRoot, tiles, err := storage.Integrate(ctx, getTiles, fromSeq, entries)
lh := make([][]byte, len(entries))
for i, e := range entries {
lh[i] = e.LeafHash
}
newSize, newRoot, tiles, err := storage.Integrate(ctx, getTiles, fromSeq, lh)
if err != nil {
klog.Errorf("Integrate: %v", err)
return fmt.Errorf("Integrate: %v", err)
Expand Down

0 comments on commit 3d768c8

Please sign in to comment.