Commit takes two parameters--lower and upper (in preparation for SharedWriter). There is no performance degradation as a result.
diff --git a/example/main.go b/example/main.go
index 31c59c7..d375917 100644
--- a/example/main.go
+++ b/example/main.go
@@ -39,7 +39,7 @@
sequence += Reservations
writer.Await(sequence)
ringBuffer[sequence&BufferMask] = sequence
- writer.Commit(sequence)
+ writer.Commit(sequence, sequence)
}
}
@@ -49,7 +49,7 @@
// for sequence <= Iterations {
// sequence = writer.Reserve(Reservations)
// ringBuffer[sequence&BufferMask] = sequence
-// writer.Commit(sequence)
+// writer.Commit(sequence, sequence)
// }
// }
diff --git a/writer.go b/writer.go
index d580b8a..45e7e72 100644
--- a/writer.go
+++ b/writer.go
@@ -40,6 +40,6 @@
this.gate = this.upstream.Read(0)
}
}
-func (this *Writer) Commit(sequence int64) {
- this.written.sequence = sequence
+func (this *Writer) Commit(lower, upper int64) {
+ this.written.sequence = upper
}