summaryrefslogtreecommitdiff
path: root/pkg/btrfs/io1_pv.go
diff options
context:
space:
mode:
authorLuke Shumaker <lukeshu@lukeshu.com>2022-07-10 13:18:30 -0600
committerLuke Shumaker <lukeshu@lukeshu.com>2022-07-10 13:35:20 -0600
commit27401b6ea459921a6152ab1744da1618358465f4 (patch)
tree2c4f9c096f1a593e65d7f824901e815ca48bfaf0 /pkg/btrfs/io1_pv.go
parent42f6f78e0a32ba0eda707154f8e1ffb4579604ee (diff)
Rename the module, mv pkg lib
Diffstat (limited to 'pkg/btrfs/io1_pv.go')
-rw-r--r--pkg/btrfs/io1_pv.go96
1 files changed, 0 insertions, 96 deletions
diff --git a/pkg/btrfs/io1_pv.go b/pkg/btrfs/io1_pv.go
deleted file mode 100644
index b9f7ea4..0000000
--- a/pkg/btrfs/io1_pv.go
+++ /dev/null
@@ -1,96 +0,0 @@
-package btrfs
-
-import (
- "fmt"
- "os"
-
- "lukeshu.com/btrfs-tools/pkg/binstruct"
- "lukeshu.com/btrfs-tools/pkg/btrfs/btrfsvol"
- "lukeshu.com/btrfs-tools/pkg/util"
-)
-
-type Device struct {
- *os.File
-
- cacheSuperblocks []*util.Ref[btrfsvol.PhysicalAddr, Superblock]
- cacheSuperblock *util.Ref[btrfsvol.PhysicalAddr, Superblock]
-}
-
-var _ util.File[btrfsvol.PhysicalAddr] = (*Device)(nil)
-
-func (dev Device) Size() (btrfsvol.PhysicalAddr, error) {
- fi, err := dev.Stat()
- if err != nil {
- return 0, err
- }
- return btrfsvol.PhysicalAddr(fi.Size()), nil
-}
-
-func (dev *Device) ReadAt(dat []byte, paddr btrfsvol.PhysicalAddr) (int, error) {
- return dev.File.ReadAt(dat, int64(paddr))
-}
-
-func (dev *Device) WriteAt(dat []byte, paddr btrfsvol.PhysicalAddr) (int, error) {
- return dev.File.WriteAt(dat, int64(paddr))
-}
-
-var SuperblockAddrs = []btrfsvol.PhysicalAddr{
- 0x00_0001_0000, // 64KiB
- 0x00_0400_0000, // 64MiB
- 0x40_0000_0000, // 256GiB
-}
-
-func (dev *Device) Superblocks() ([]*util.Ref[btrfsvol.PhysicalAddr, Superblock], error) {
- if dev.cacheSuperblocks != nil {
- return dev.cacheSuperblocks, nil
- }
- superblockSize := btrfsvol.PhysicalAddr(binstruct.StaticSize(Superblock{}))
-
- sz, err := dev.Size()
- if err != nil {
- return nil, err
- }
-
- var ret []*util.Ref[btrfsvol.PhysicalAddr, Superblock]
- for i, addr := range SuperblockAddrs {
- if addr+superblockSize <= sz {
- superblock := &util.Ref[btrfsvol.PhysicalAddr, Superblock]{
- File: dev,
- Addr: addr,
- }
- if err := superblock.Read(); err != nil {
- return nil, fmt.Errorf("superblock %v: %w", i, err)
- }
- ret = append(ret, superblock)
- }
- }
- if len(ret) == 0 {
- return nil, fmt.Errorf("no superblocks")
- }
- dev.cacheSuperblocks = ret
- return ret, nil
-}
-
-func (dev *Device) Superblock() (*util.Ref[btrfsvol.PhysicalAddr, Superblock], error) {
- if dev.cacheSuperblock != nil {
- return dev.cacheSuperblock, nil
- }
- sbs, err := dev.Superblocks()
- if err != nil {
- return nil, err
- }
-
- for i, sb := range sbs {
- if err := sb.Data.ValidateChecksum(); err != nil {
- return nil, fmt.Errorf("superblock %v: %w", i, err)
- }
- if i > 0 {
- if !sb.Data.Equal(sbs[0].Data) {
- return nil, fmt.Errorf("superblock %v and superblock %v disagree", 0, i)
- }
- }
- }
-
- dev.cacheSuperblock = sbs[0]
- return sbs[0], nil
-}