flushFS.ReadFile
parent
8e46de74a3
commit
f7694a22b7
|
@ -149,6 +149,27 @@ func (fs *flushFS) OpenFile(
|
||||||
return
|
return
|
||||||
}
|
}
|
||||||
|
|
||||||
|
func (fs *flushFS) ReadFile(
|
||||||
|
ctx context.Context,
|
||||||
|
req *fuse.ReadFileRequest) (
|
||||||
|
resp *fuse.ReadFileResponse, err error) {
|
||||||
|
resp = &fuse.ReadFileResponse{}
|
||||||
|
|
||||||
|
fs.mu.Lock()
|
||||||
|
defer fs.mu.Unlock()
|
||||||
|
|
||||||
|
// Ensure the offset is in range.
|
||||||
|
if req.Offset > int64(len(fs.fooContents)) {
|
||||||
|
return
|
||||||
|
}
|
||||||
|
|
||||||
|
// Read what we can.
|
||||||
|
resp.Data = make([]byte, req.Size)
|
||||||
|
copy(resp.Data, fs.fooContents[req.Offset:])
|
||||||
|
|
||||||
|
return
|
||||||
|
}
|
||||||
|
|
||||||
func (fs *flushFS) WriteFile(
|
func (fs *flushFS) WriteFile(
|
||||||
ctx context.Context,
|
ctx context.Context,
|
||||||
req *fuse.WriteFileRequest) (
|
req *fuse.WriteFileRequest) (
|
||||||
|
|
Loading…
Reference in New Issue