mirror of
https://github.com/chrislusf/seaweedfs
synced 2024-06-23 02:53:03 +02:00
5ce6bbf076
glide has its own requirements. My previous workaround caused me some code checkin errors. Need to fix this.
37 lines
655 B
Go
37 lines
655 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, uint64) {
|
|
m.sequenceLock.Lock()
|
|
defer m.sequenceLock.Unlock()
|
|
ret := m.counter
|
|
m.counter += uint64(count)
|
|
return ret, count
|
|
}
|
|
|
|
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
|
|
}
|