Simplify DB pipeline (#295)

alloc/allocator.go

@@ -98,10 +98,6 @@ type Deallocator[A Address] struct {
 
 // Deallocate deallocates single node.
 func (d *Deallocator[A]) Deallocate(nodeAddress A) {
-	if nodeAddress == 0 {
-		return
-	}
-
 	d.release = append(d.release, nodeAddress)
 	if len(d.release) == cap(d.release) {
 		d.sinkCh <- d.release

alloc/state.go

@@ -29,11 +29,9 @@ func NewState(
 	persistentAllocationCh, singularityPersistentAddress := NewAllocationCh[types.PersistentAddress](
 		persistentSize, nodesPerGroup, false)
 
-	singularityNode := (*types.SingularityNode)(unsafe.Add(dataP, types.NodeLength*singularityVolatileAddress))
 	return &State{
 		nodesPerGroup: nodesPerGroup,
 		singularityNodeRoot: types.NodeRoot{
-			Hash: &singularityNode.Hash,
 			Pointer: &types.Pointer{
 				Revision:          1,
 				VolatileAddress:   singularityVolatileAddress,

benchmark_test.go

@@ -66,7 +66,7 @@ func BenchmarkBalanceTransfer(b *testing.B) {
 				panic(err)
 			}
 
-			var size uint64 = 20 * 1024 * 1024 * 1024
+			var size uint64 = 5 * 1024 * 1024 * 1024
 			state, stateDeallocFunc, err := alloc.NewState(
 				size, store.Size(),
 				100,
@@ -77,13 +77,10 @@ func BenchmarkBalanceTransfer(b *testing.B) {
 			}
 			defer stateDeallocFunc()
 
-			db, err := quantum.New(quantum.Config{
+			db := quantum.New(quantum.Config{
 				State: state,
 				Store: store,
 			})
-			if err != nil {
-				panic(err)
-			}
 
 			ctx, cancel := context.WithCancel(logger.WithLogger(context.Background(), logger.New(logger.DefaultConfig)))
 			b.Cleanup(cancel)