interruptfs

Documentation

Index

• type InterruptFS
  • func New() *InterruptFS
  • func (fs *InterruptFS) EnableFlushBlocking()
  • func (fs *InterruptFS) EnableReadBlocking()
  • func (fs *InterruptFS) FlushFile(ctx context.Context, op *fuseops.FlushFileOp) error
  • func (fs *InterruptFS) GetInodeAttributes(ctx context.Context, op *fuseops.GetInodeAttributesOp) error
  • func (fs *InterruptFS) LookUpInode(ctx context.Context, op *fuseops.LookUpInodeOp) error
  • func (fs *InterruptFS) OpenFile(ctx context.Context, op *fuseops.OpenFileOp) error
  • func (fs *InterruptFS) ReadFile(ctx context.Context, op *fuseops.ReadFileOp) error
  • func (fs *InterruptFS) StatFS(ctx context.Context, op *fuseops.StatFSOp) error
  • func (fs *InterruptFS) WaitForFirstFlush()
  • func (fs *InterruptFS) WaitForFirstRead()

Types

type InterruptFS

type InterruptFS struct {
	fuseutil.NotImplementedFileSystem
	// contains filtered or unexported fields
}

A file system containing exactly one file, named "foo". ReadFile and FlushFile ops can be made to hang until interrupted. Exposes a method for synchronizing with the arrival of a read or a flush.

Must be created with New.

func New

func New() *InterruptFS

func (*InterruptFS) EnableFlushBlocking

func (fs *InterruptFS) EnableFlushBlocking()

Enable blocking until interrupted for the next (and subsequent) flush ops.

func (*InterruptFS) EnableReadBlocking

func (fs *InterruptFS) EnableReadBlocking()

Enable blocking until interrupted for the next (and subsequent) read ops.

func (*InterruptFS) FlushFile

func (fs *InterruptFS) FlushFile(
	ctx context.Context,
	op *fuseops.FlushFileOp) error

func (*InterruptFS) GetInodeAttributes

func (fs *InterruptFS) GetInodeAttributes(
	ctx context.Context,
	op *fuseops.GetInodeAttributesOp) error

func (*InterruptFS) LookUpInode

func (fs *InterruptFS) LookUpInode(
	ctx context.Context,
	op *fuseops.LookUpInodeOp) error

func (*InterruptFS) OpenFile

func (fs *InterruptFS) OpenFile(
	ctx context.Context,
	op *fuseops.OpenFileOp) error

func (*InterruptFS) ReadFile

func (fs *InterruptFS) ReadFile(
	ctx context.Context,
	op *fuseops.ReadFileOp) error

func (*InterruptFS) StatFS

func (fs *InterruptFS) StatFS(
	ctx context.Context,
	op *fuseops.StatFSOp) error

func (*InterruptFS) WaitForFirstFlush

func (fs *InterruptFS) WaitForFirstFlush()

Block until the first flush is received.

func (*InterruptFS) WaitForFirstRead

func (fs *InterruptFS) WaitForFirstRead()

Block until the first read is received.