@@ -24,13 +24,13 @@ func (f *file) sectorForPos(pos int64) int64 {
24
24
}
25
25
26
26
func (f * file ) deleteSector (sectorOffset int64 ) error {
27
- n := sectorNameFromSectorOffset (sectorOffset )
27
+ n := f . sectorNameFromSectorOffset (sectorOffset )
28
28
err := f .vfs .kc .CoreV1 ().ConfigMaps (f .namespaceName ()).Delete (context .TODO (), n , metav1.DeleteOptions {})
29
29
return err
30
30
}
31
31
32
32
func (f * file ) writeSector (s * sector ) error {
33
- sectorName := sectorNameFromSectorOffset (s .offset )
33
+ sectorName := f . sectorNameFromSectorOffset (s .offset )
34
34
b64Data := make ([]byte , base64 .StdEncoding .EncodedLen (len (s .data )))
35
35
base64 .StdEncoding .Encode (b64Data , s .data )
36
36
//map[string][]byte]{"sector": "b64Data"}
@@ -55,18 +55,23 @@ func (f *file) writeSector(s *sector) error {
55
55
return nil
56
56
}
57
57
58
- func sectorNameFromSectorOffset (sectorOffset int64 ) string {
58
+ func (f * file ) sectorNameFromSectorOffset (sectorOffset int64 ) string {
59
+ // if sectorOffset == -1 {
60
+ // last, err := f.getLastSector()
61
+
62
+ // }
59
63
sectorName := fmt .Sprintf ("%d" , sectorOffset )
60
64
return sectorName
61
65
}
62
66
63
67
func (f * file ) getSector (sectorOffset int64 ) (* sector , error ) {
64
- sectorName := sectorNameFromSectorOffset (sectorOffset )
68
+ f .vfs .logger .Debugw ("getSector" , "sectorOffset" , sectorOffset )
69
+ sectorName := f .sectorNameFromSectorOffset (sectorOffset )
65
70
cm , err := f .vfs .kc .CoreV1 ().ConfigMaps (f .namespaceName ()).Get (context .TODO (), sectorName , metav1.GetOptions {})
66
71
67
72
if err != nil {
68
73
f .vfs .logger .Error (err )
69
- return nil , err
74
+ return nil , sqlite3vfs . CantOpenError
70
75
}
71
76
72
77
// Make a new function, and inverse
0 commit comments