Updated TODOs.
diff --git a/example/example_producer.go b/example/example_producer.go
index 56de36d..5b688f5 100644
--- a/example/example_producer.go
+++ b/example/example_producer.go
@@ -12,8 +12,6 @@
lower++
ringBuffer[(lower)&RingMask] = lower
}
- // ringBuffer[sequence&RingMask] = sequence
writer.Commit(sequence-ItemsToPublish+1, sequence)
}
- }
}
diff --git a/reader.go b/reader.go
index 7c7a278..271d5b9 100644
--- a/reader.go
+++ b/reader.go
@@ -21,6 +21,7 @@
// TODO: performance when current (or next?) sequence is received as a parameter to Receive
// instead of reading the cursor...
+// TODO: signature: lower, upper instead of lower, count
func (this *Reader) Receive() (int64, int64) {
next := this.readerCursor.Load() + 1
ready := this.upstreamBarrier.LoadBarrier(next)
diff --git a/shared_writer.go b/shared_writer.go
index 6550f22..171bcea 100644
--- a/shared_writer.go
+++ b/shared_writer.go
@@ -24,6 +24,7 @@
}
}
+// TODO: return lower, upper instead of upper
func (this *SharedWriter) Reserve(count int64) int64 {
for {
previous := this.reservation.Load()
diff --git a/writer.go b/writer.go
index 5c6e499..f4470a5 100644
--- a/writer.go
+++ b/writer.go
@@ -27,6 +27,7 @@
}
}
+// TODO: return lower, upper instead of upper
func (this *Writer) Reserve(count int64) int64 {
next := this.previous + count
wrap := next - this.capacity
