util

package

v1.0.0 Latest Latest Go to latest Published: Nov 19, 2019 License: Apache-2.0 Imports: 5 Imported by: 4

Details

This section is empty.

This section is empty.

func CalculateBreakRange(startPieceNum, pieceContSize int, rangeLength int64) (string, error)

CalculateBreakRange calculates the start and end of piece with the following formula:

start = pieceNum * pieceSize
end = rangeLength - 1

The different with the CalculatePieceRange function is that the end is calculated by rangeLength which is passed in by the caller itself.

func CalculatePieceNum(rangeStr string) int

CalculatePieceNum calculates the number of piece according to the parameter range.

func CalculatePieceRange(pieceNum int, pieceSize int32) string

CalculatePieceRange calculates the start and end of piece with the following formula:

start = pieceNum * pieceSize
end = start + pieceSize - 1

func CalculatePieceSize(rangeStr string) int64

CalculatePieceSize calculates the size of piece according to the parameter range.

func GetLock(key string, ro bool)

GetLock locks key with defaultLocker.

func ParsePieceIndex(rangeStr string) (start, end int64, err error)

ParsePieceIndex parses the start and end index according to range string.

func ReleaseLock(key string, ro bool)

ReleaseLock unlocks key with defaultLocker.

type LockerPool struct {
	sync.Mutex
	// contains filtered or unexported fields
}

LockerPool is a set of reader/writer mutual exclusion locks.

func NewLockerPool() *LockerPool

NewLockerPool returns a *LockerPool with self-defined prefix.

func (l *LockerPool) GetLock(key string, ro bool)

GetLock locks key. If ro(readonly) is true, then it locks key for reading. Otherwise, locks key for writing.

func (l *LockerPool) ReleaseLock(key string, ro bool)

ReleaseLock unlocks key. If ro(readonly) is true, then it unlocks key for reading. Otherwise, unlocks key for writing.