allocate

package

v1.2.1 Latest Latest Go to latest Published: Mar 4, 2024 License: Apache-2.0 Imports: 4 Imported by: 0

Details

SPDX-License-Identifier: Apache-2.0

This section is empty.

View Source

var (
	OsPageSize = os.Getpagesize()

	End        = errors.New("END")
	OsPageMask = OsPageSize - 1
)

This section is empty.

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

func NewBytesAllocator(cap int) *BytesAllocator

func (bsa *BytesAllocator) AllocAt(offset int64, n int) ([]byte, error)

AllocAt 在分配器中获取[offset:offset+n)范围内的缓存区, 如果offset不在分配器范围则返回END错误，如果offset+n超过分配器上限，则返回的缓存区大小将会小于n

func (bsa *BytesAllocator) Release()

func (bsa *BytesAllocator) Resize(size int) error

func (bsa *BytesAllocator) Size() int

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

func NewMmapAllocator(f *file.File, offset int64, mmSize int, mapPort, mapFlag int, lock bool) (*MmapAllocator, error)

func (mal *MmapAllocator) AllocAt(offset int64, n int) ([]byte, error)

AllocAt 在映射区中获取[offset:offset+n)范围内的缓存区, 如果offset不在映射区范围则返回END错误，如果offset+n超过映射区上线，则返回的缓存区大小将会小于n

func (mal *MmapAllocator) Flush() error

func (mal *MmapAllocator) Release()

Release 释放映射区

func (mal *MmapAllocator) Resize(foffset int64, mmSize int) error

Resize 重映射映射区

func (mal *MmapAllocator) Size() int

Size 当前映射区的大小