fix: update committed flag after batch commit

rosedblabs · Jun 14, 2023 · 19383b5 · 19383b5
1 parent 67e7a9c
commit 19383b5
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 0 deletions.
diff --git a/batch.go b/batch.go
@@ -5,6 +5,7 @@ import (
 	"sync"
 
 	"github.com/bwmarrin/snowflake"
+
 	"github.com/rosedblabs/wal"
 )
 
@@ -202,6 +203,7 @@ func (b *Batch) Commit() error {
 
 	batchId := b.batchId.Generate()
 	positions := make(map[string]*wal.ChunkPosition)
+
 	// write to wal
 	for _, record := range b.pendingWrites {
 		record.BatchId = uint64(batchId)
@@ -238,5 +240,6 @@ func (b *Batch) Commit() error {
 		}
 	}
 
+	b.committed = true
 	return nil
 }
diff --git a/rosedb-server b/rosedb-server