mirror of
https://github.com/chrislusf/seaweedfs
synced 2024-05-20 10:20:00 +02:00
37 lines
630 B
Go
37 lines
630 B
Go
package sequence
|
|
|
|
import (
|
|
"sync"
|
|
)
|
|
|
|
// just for testing
|
|
type MemorySequencer struct {
|
|
counter uint64
|
|
sequenceLock sync.Mutex
|
|
}
|
|
|
|
func NewMemorySequencer() (m *MemorySequencer) {
|
|
m = &MemorySequencer{counter: 1}
|
|
return
|
|
}
|
|
|
|
func (m *MemorySequencer) NextFileId(count uint64) uint64 {
|
|
m.sequenceLock.Lock()
|
|
defer m.sequenceLock.Unlock()
|
|
ret := m.counter
|
|
m.counter += count
|
|
return ret
|
|
}
|
|
|
|
func (m *MemorySequencer) SetMax(seenValue uint64) {
|
|
m.sequenceLock.Lock()
|
|
defer m.sequenceLock.Unlock()
|
|
if m.counter <= seenValue {
|
|
m.counter = seenValue + 1
|
|
}
|
|
}
|
|
|
|
func (m *MemorySequencer) Peek() uint64 {
|
|
return m.counter
|
|
}
|