vitalif
/
fusego
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

Fixed interruptfs.

geesefs-0-30-9
Aaron Jacobs 2015-06-05 14:24:14 +10:00
parent 4cba8c73d1
commit 5e2cea4b7a
1 changed files with 5 additions and 20 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

25
samples/interruptfs/interrupt_fs.go
View File

@ -78,18 +78,12 @@ func (fs *InterruptFS) WaitForReadInFlight() {
//////////////////////////////////////////////////////////////////////// ////////////////////////////////////////////////////////////////////////
func (fs *InterruptFS) Init( func (fs *InterruptFS) Init(
op *fuseops.InitOp) { op *fuseops.InitOp) (err error) {
var err error
defer fuseutil.RespondToOp(op, &err)
return return
} }
func (fs *InterruptFS) LookUpInode( func (fs *InterruptFS) LookUpInode(
op *fuseops.LookUpInodeOp) { op *fuseops.LookUpInodeOp) (err error) {
var err error
defer fuseutil.RespondToOp(op, &err)
// We support only one parent. // We support only one parent.
if op.Parent != fuseops.RootInodeID { if op.Parent != fuseops.RootInodeID {
err = fmt.Errorf("Unexpected parent: %v", op.Parent) err = fmt.Errorf("Unexpected parent: %v", op.Parent)
@ -110,10 +104,7 @@ func (fs *InterruptFS) LookUpInode(
} }
func (fs *InterruptFS) GetInodeAttributes( func (fs *InterruptFS) GetInodeAttributes(
op *fuseops.GetInodeAttributesOp) { op *fuseops.GetInodeAttributesOp) (err error) {
var err error
defer fuseutil.RespondToOp(op, &err)
switch op.Inode { switch op.Inode {
case fuseops.RootInodeID: case fuseops.RootInodeID:
op.Attributes = rootAttrs op.Attributes = rootAttrs
@ -130,18 +121,12 @@ func (fs *InterruptFS) GetInodeAttributes(
} }
func (fs *InterruptFS) OpenFile( func (fs *InterruptFS) OpenFile(
op *fuseops.OpenFileOp) { op *fuseops.OpenFileOp) (err error) {
var err error
defer fuseutil.RespondToOp(op, &err)
return return
} }
func (fs *InterruptFS) ReadFile( func (fs *InterruptFS) ReadFile(
op *fuseops.ReadFileOp) { op *fuseops.ReadFileOp) (err error) {
var err error
defer fuseutil.RespondToOp(op, &err)
// Signal that a read has been received. // Signal that a read has been received.
fs.mu.Lock() fs.mu.Lock()
fs.readInFlight = true fs.readInFlight = true