fuse: add cancel channel to Release call

This is unlikely to be useful, but makes the API more uniform.

fuse/api.go

@@ -246,7 +246,7 @@ type RawFileSystem interface {
 	SetLk(cancel <-chan struct{}, input *LkIn) (code Status)
 	SetLkw(cancel <-chan struct{}, input *LkIn) (code Status)
 
-	Release(input *ReleaseIn)
+	Release(cancel <-chan struct{}, input *ReleaseIn)
 	Write(cancel <-chan struct{}, input *WriteIn, data []byte) (written uint32, code Status)
 	CopyFileRange(cancel <-chan struct{}, input *CopyFileRangeIn) (written uint32, code Status)
 

fuse/defaultraw.go

@@ -125,7 +125,7 @@ func (fs *defaultRawFileSystem) SetLkw(cancel <-chan struct{}, in *LkIn) (code S
 	return ENOSYS
 }
 
-func (fs *defaultRawFileSystem) Release(input *ReleaseIn) {
+func (fs *defaultRawFileSystem) Release(cancel <-chan struct{}, input *ReleaseIn) {
 }
 
 func (fs *defaultRawFileSystem) Write(cancel <-chan struct{}, input *WriteIn, data []byte) (written uint32, code Status) {

fuse/nodefs/fsops.go

@@ -362,7 +362,7 @@ func (c *rawBridge) Create(cancel <-chan struct{}, input *fuse.CreateIn, name st
 	return code
 }
 
-func (c *rawBridge) Release(input *fuse.ReleaseIn) {
+func (c *rawBridge) Release(cancel <-chan struct{}, input *fuse.ReleaseIn) {
 	if input.Fh != 0 {
 		node := c.toInode(input.NodeId)
 		opened := node.mount.unregisterFileHandle(input.Fh, node)

fuse/opcode.go

@@ -360,7 +360,7 @@ func doFlush(server *Server, req *request) {
 }
 
 func doRelease(server *Server, req *request) {
-	server.fileSystem.Release((*ReleaseIn)(req.inData))
+	server.fileSystem.Release(req.cancel, (*ReleaseIn)(req.inData))
 }
 
 func doFsync(server *Server, req *request) {

nodefs/bridge.go

@@ -550,15 +550,14 @@ func (b *rawBridge) SetLkw(cancel <-chan struct{}, input *fuse.LkIn) fuse.Status
 	return fuse.ENOTSUP
 }
 
-func (b *rawBridge) Release(input *fuse.ReleaseIn) {
-	// XXX should have cancel channel too.
+func (b *rawBridge) Release(cancel <-chan struct{}, input *fuse.ReleaseIn) {
 	n, f := b.releaseFileEntry(input.NodeId, input.Fh)
 	if f == nil {
 		return
 	}
 
 	f.wg.Wait()
-	n.fileOps().Release(&fuse.Context{Caller: input.Caller, Cancel: nil}, f.file)
+	n.fileOps().Release(&fuse.Context{Caller: input.Caller, Cancel: cancel}, f.file)
 
 	b.mu.Lock()
 	defer b.mu.Unlock()