save

cmd/state/exec3/state.go

@@ -303,8 +303,6 @@ func NewWorkersPool(lock sync.Locker, ctx context.Context, background bool, chai
 				w.ResetTx(nil)
 			}
 			//applyWorker.ResetTx(nil)
-			log.Warn("before rws.Close()")
-			rws.Close()
 		}
 	}
 	applyWorker = NewWorker(lock, ctx, false, chainDb, rs, in, blockReader, chainConfig, genesis, rws, engine)

eth/stagedsync/exec3.go

@@ -271,6 +271,8 @@ func ExecV3(ctx context.Context,
 	if parallel {
 		// `rwLoop` lives longer than `applyLoop`
 		rwLoop := func(ctx context.Context) error {
+			defer stopWorkers()
+
 			tx, err := chainDb.BeginRw(ctx)
 			if err != nil {
 				return err
@@ -419,6 +421,7 @@ func ExecV3(ctx context.Context,
 			if err = tx.Commit(); err != nil {
 				return err
 			}
+			rws.Close()
 			return nil
 		}