page

package

v0.0.0-...-b142f4f Latest Latest Go to latest Published: May 10, 2023 License: MIT Imports: 12 Imported by: 0

Details

View Source

const PageSize = 1 << 20

View Source

const PoolSize = 64 << 20

This section is empty.

This section is empty.

type MemAttr struct {
	// contains filtered or unexported fields
}

func NewMemAttr(ctx context.Context, pool *Pool, inode metadata.Ino) (*MemAttr, error)

func (memAttr *MemAttr) CopyFromAttr(src *metadata.Attr)

func (memAttr *MemAttr) CopyToAttr(dst *metadata.Attr)

func (memAttr *MemAttr) Length() uint64

func (memAttr *MemAttr) Setattr(ctx context.Context, in *fuse.SetAttrIn, out *fuse.AttrOut) syscall.Errno

func (memAttr *MemAttr) UpdateLength(lens uint64)

func (memAttr *MemAttr) UpdateLengthIfMore(lens uint64)

type Page struct {
	// contains filtered or unexported fields
}

func NewPage(pageNumber int64) *Page

func NewPageWithReader(pageNumber int64, reader io.Reader, totalSize int64) (*Page, error)

func (p *Page) Fsync(ctx context.Context, source *datasource.DataSource, inode metadata.Ino) error

func (p *Page) Read(offset int64, data []byte, length int64) int64

func (p *Page) Truncate(size int64)

func (p *Page) Write(offset int64, data []byte)

type Pool struct {
	*datasource.DataSource
	// contains filtered or unexported fields
}

func NewPagePool(ctx context.Context, dataSource *datasource.DataSource, inode metadata.Ino) (*Pool, error)

func (p *Pool) Fsync(ctx context.Context) error

Fsync write all dirty pages to minio, and write the meta of the file

func (p *Pool) MemAttr() *MemAttr

func (p *Pool) Read(ctx context.Context, dest []byte, off int64) (fuse.ReadResult, error)

func (p *Pool) Setattr(ctx context.Context, in *fuse.SetAttrIn, out *fuse.AttrOut) syscall.Errno

func (p *Pool) TruncateWithLock(ctx context.Context, size uint64) error

TruncateWithLock remove/truncate the cache pages which offset larger than size\

func (p *Pool) Write(ctx context.Context, data []byte, off int64) (uint32, error)