blob: 3f00a46a35ac74e597a0c8234b52ee4727d0f069 [file] [log] [blame]
package main
import "github.com/smartystreets/go-disruptor"
func publish(writer *disruptor.Writer) {
for {
sequence := writer.Reserve(ItemsToPublish)
if sequence != disruptor.Gating {
for lower := sequence - ItemsToPublish; lower < sequence; {
lower++
ringBuffer[(lower)&RingMask] = lower
}
writer.Commit(sequence)
}
}
}
const ItemsToPublish = 4