This commit is contained in:
Piotr Tabor 2021-05-14 22:25:44 +02:00
parent 79eafb9719
commit 4a2ffc2cbe

View File

@ -37,10 +37,11 @@ func (txb *txBuffer) reset() {
// txWriteBuffer buffers writes of pending updates that have not yet committed.
type txWriteBuffer struct {
txBuffer
// Map from bucket name into information whether this bucket is edited
// sequentially (i.e. keys are growing monotonically).
seq map[string]bool
}
func (txw *txWriteBuffer) put(bucket, k, v []byte) {
txw.seq[string(bucket)] = false
txw.putSeq(bucket, k, v)