summaryrefslogtreecommitdiff
path: root/lib/btrfsprogs/btrfsinspect/scanforextents/scan.go
diff options
context:
space:
mode:
authorLuke Shumaker <lukeshu@lukeshu.com>2022-07-17 11:54:15 -0600
committerLuke Shumaker <lukeshu@lukeshu.com>2022-07-17 11:54:15 -0600
commit987a4b238e047238bd83384c87b8317afdd45ad8 (patch)
treedc834771abc88b77c64afe7dcdc2a8e77c9cc461 /lib/btrfsprogs/btrfsinspect/scanforextents/scan.go
parent35e80a0c76be663f5ba710c2884e9508afa58ce2 (diff)
export CSumBlockSize
Diffstat (limited to 'lib/btrfsprogs/btrfsinspect/scanforextents/scan.go')
-rw-r--r--lib/btrfsprogs/btrfsinspect/scanforextents/scan.go20
1 files changed, 10 insertions, 10 deletions
diff --git a/lib/btrfsprogs/btrfsinspect/scanforextents/scan.go b/lib/btrfsprogs/btrfsinspect/scanforextents/scan.go
index 3aeb05a..64e0871 100644
--- a/lib/btrfsprogs/btrfsinspect/scanforextents/scan.go
+++ b/lib/btrfsprogs/btrfsinspect/scanforextents/scan.go
@@ -29,11 +29,11 @@ func ScanForExtents(ctx context.Context, fs *btrfs.FS, blockgroups map[btrfsvol.
laddr = next
continue
}
- off := int((laddr-run.Addr)/csumBlockSize) * run.ChecksumSize
+ off := int((laddr-run.Addr)/CSumBlockSize) * run.ChecksumSize
deltaAddr := slices.Min[btrfsvol.AddrDelta](
blockgroup.Size-laddr.Sub(blockgroup.LAddr),
- btrfsvol.AddrDelta((len(run.Sums)-off)/run.ChecksumSize)*csumBlockSize)
- deltaOff := int(deltaAddr/csumBlockSize) * run.ChecksumSize
+ btrfsvol.AddrDelta((len(run.Sums)-off)/run.ChecksumSize)*CSumBlockSize)
+ deltaOff := int(deltaAddr/CSumBlockSize) * run.ChecksumSize
bgSums[blockgroup.LAddr] = append(bgSums[blockgroup.LAddr], SumRun[btrfsvol.LogicalAddr]{
ChecksumSize: run.ChecksumSize,
Addr: laddr,
@@ -67,7 +67,7 @@ func ScanForExtents(ctx context.Context, fs *btrfs.FS, blockgroups map[btrfsvol.
for _, match := range matches {
bgMatches[bgLAddr] = append(bgMatches[bgLAddr], btrfsvol.QualifiedPhysicalAddr{
Dev: devID,
- Addr: gap.Addr + (btrfsvol.PhysicalAddr(match) * csumBlockSize),
+ Addr: gap.Addr + (btrfsvol.PhysicalAddr(match) * CSumBlockSize),
})
}
return nil
@@ -106,7 +106,7 @@ func ScanForExtents(ctx context.Context, fs *btrfs.FS, blockgroups map[btrfsvol.
sum2laddrs := make(map[ShortSum][]btrfsvol.LogicalAddr)
var numUnmappedBlocks int64
if err := sums.WalkLogical(ctx, func(laddr btrfsvol.LogicalAddr, sum ShortSum) error {
- var dat [csumBlockSize]byte
+ var dat [CSumBlockSize]byte
if _, err := fs.ReadAt(dat[:], laddr); err != nil {
if errors.Is(err, btrfsvol.ErrCouldNotMap) {
sum2laddrs[sum] = append(sum2laddrs[sum], laddr)
@@ -179,12 +179,12 @@ type ExtentMappings struct {
}
func (em *ExtentMappings) considerMapping(ctx context.Context, laddr btrfsvol.LogicalAddr, paddr btrfsvol.QualifiedPhysicalAddr) (btrfsvol.Mapping, bool) {
- blockgroup := LookupBlockGroup(em.InBlockGroups, laddr, csumBlockSize)
+ blockgroup := LookupBlockGroup(em.InBlockGroups, laddr, CSumBlockSize)
if blockgroup == nil {
return btrfsvol.Mapping{
LAddr: laddr,
PAddr: paddr,
- Size: csumBlockSize,
+ Size: CSumBlockSize,
}, true
}
mapping := btrfsvol.Mapping{
@@ -204,7 +204,7 @@ func (em *ExtentMappings) considerMapping(ctx context.Context, laddr btrfsvol.Lo
return btrfsvol.Mapping{}, false
}
- for offset := btrfsvol.AddrDelta(0); offset <= mapping.Size; offset += csumBlockSize {
+ for offset := btrfsvol.AddrDelta(0); offset <= mapping.Size; offset += CSumBlockSize {
expCSum, ok := em.InSums.SumForLAddr(mapping.LAddr.Add(offset))
if !ok {
continue
@@ -242,7 +242,7 @@ func (em *ExtentMappings) ScanOneDev(
dlog.Infof(ctx, "... dev[%q] Scanning for extents...", devName)
var totalMappings int
- _ = WalkGaps(ctx, gaps, csumBlockSize,
+ _ = WalkGaps(ctx, gaps, CSumBlockSize,
func(_, _ int64) {},
func(paddr btrfsvol.PhysicalAddr) error {
qpaddr := btrfsvol.QualifiedPhysicalAddr{
@@ -266,7 +266,7 @@ func (em *ExtentMappings) ScanOneDev(
lastProgress = pct
}
}
- return WalkGaps(ctx, gaps, csumBlockSize,
+ return WalkGaps(ctx, gaps, CSumBlockSize,
func(_, _ int64) {
progress()
},