blob: 3570f005e5e113610b60a2909079a784c6716525 [file] [log] [blame]
package disruptor
const (
Gating = -2
Idling = -3
)
type Reader struct {
upstreamBarrier Barrier
writerCursor *Cursor
readerCursor *Cursor
}
func NewReader(upstreamBarrier Barrier, writerCursor, readerCursor *Cursor) *Reader {
return &Reader{
upstreamBarrier: upstreamBarrier,
writerCursor: writerCursor,
readerCursor: readerCursor,
}
}
// TODO: performance when current (or next?) sequence is received as a parameter to Receive
// instead of reading the cursor...
func (this *Reader) Receive() (int64, int64) {
next := this.readerCursor.Load() + 1
ready := this.upstreamBarrier.Load()
if next <= ready {
return next, ready - next
} else if next <= this.writerCursor.Load() {
return next, Gating
} else {
return next, Idling
}
}