Fix: fixed race conditions

pkg/protocol/block_dispatcher.go

@@ -242,7 +242,10 @@ func (b *BlockDispatcher) processWarpSyncResponse(commitmentID iotago.Commitment
 
 	b.processedWarpSyncRequests.Add(commitmentID)
 
-	// make sure the engine is clean before we start processing the blocks
+	// make sure the engine is clean and requires a warp-sync before we start processing the blocks
+	if targetEngine.Workers.WaitChildren(); targetEngine.Storage.Settings().LatestCommitment().ID().Slot() > commitmentID.Slot() {
+		return nil
+	}
 	targetEngine.Reset()
 
 	// Once all blocks are booked we

pkg/protocol/engine/engine.go

@@ -212,6 +212,7 @@ func New(
 		func(e *Engine) {
 			fmt.Println("Engine Settings", e.Storage.Settings().String())
 		},
+		(*Engine).Reset,
 		(*Engine).TriggerInitialized,
 	)
 }
@@ -223,8 +224,6 @@ func (e *Engine) ProcessBlockFromPeer(block *model.Block, source peer.ID) {
 
 // Reset resets the component to a clean state as if it was created at the last commitment.
 func (e *Engine) Reset() {
-	e.Workers.WaitChildren()
-
 	e.BlockRequester.Clear()
 	e.Storage.Reset()
 	e.EvictionState.Reset()