alex/vfs
1
Fork 0
Code Releases Activity

Cleanup

Browse Source
This commit is contained in:
Alex Yatskov 2015-05-24 18:45:06 +09:00
parent 4dca3c16f8
commit 7e1207065e
1 changed files with 7 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
file.go
View File

@ -42,12 +42,12 @@ func newVersionedFile(node *versionedNode, inode uint64, parent *versionedDir) *
parent: parent} parent: parent}
} }
func (this versionedFile) Attr(attr *fuse.Attr) { func (this *versionedFile) Attr(attr *fuse.Attr) {
this.node.attr(attr) this.node.attr(attr)
attr.Inode = this.inode attr.Inode = this.inode
} }
func (this versionedFile) Write(ctx context.Context, req *fuse.WriteRequest, resp *fuse.WriteResponse) error { func (this *versionedFile) Write(ctx context.Context, req *fuse.WriteRequest, resp *fuse.WriteResponse) error {
file, err := os.OpenFile(this.node.rebasedPath(), os.O_WRONLY, 0666) file, err := os.OpenFile(this.node.rebasedPath(), os.O_WRONLY, 0666)
if err != nil { if err != nil {
return err return err
@ -63,7 +63,7 @@ func (this versionedFile) Write(ctx context.Context, req *fuse.WriteRequest, res
return nil return nil
} }
func (this versionedFile) Setattr(ctx context.Context, req *fuse.SetattrRequest, resp *fuse.SetattrResponse) error { func (this *versionedFile) Setattr(ctx context.Context, req *fuse.SetattrRequest, resp *fuse.SetattrResponse) error {
info, err := os.Stat(this.node.rebasedPath()) info, err := os.Stat(this.node.rebasedPath())
if err != nil { if err != nil {
return err return err
@ -74,18 +74,18 @@ func (this versionedFile) Setattr(ctx context.Context, req *fuse.SetattrRequest,
return nil return nil
} }
func (this versionedFile) Fsync(ctx context.Context, req *fuse.FsyncRequest) error { func (this *versionedFile) Fsync(ctx context.Context, req *fuse.FsyncRequest) error {
return nil return nil
} }
func (this versionedFile) Read(ctx context.Context, req *fuse.ReadRequest, resp *fuse.ReadResponse) error { func (this *versionedFile) Read(ctx context.Context, req *fuse.ReadRequest, resp *fuse.ReadResponse) error {
file, err := os.OpenFile(this.node.rebasedPath(), os.O_RDONLY, 0666) file, err := os.OpenFile(this.node.rebasedPath(), os.O_RDONLY, 0666)
if err != nil { if err != nil {
return err return err
} }
defer file.Close() defer file.Close()
resp.Data = make([]byte, req.Size, req.Size) resp.Data = make([]byte, req.Size)
if _, err = file.ReadAt(resp.Data, req.Offset); err != nil { if _, err = file.ReadAt(resp.Data, req.Offset); err != nil {
return err return err
} }
@ -93,7 +93,7 @@ func (this versionedFile) Read(ctx context.Context, req *fuse.ReadRequest, resp
return nil return nil
} }
func (this versionedFile) ReadAll(ctx context.Context) ([]byte, error) { func (this *versionedFile) ReadAll(ctx context.Context) ([]byte, error) {
bytes, err := ioutil.ReadFile(this.node.rebasedPath()) bytes, err := ioutil.ReadFile(this.node.rebasedPath())
if err != nil { if err != nil {
return nil, err return nil, err