Fix: avoid update the stateObjects at conflict check phase

There can be a issue that the object updated by mainDB.GetNonce etc is
obseleted.

The fix use statedb.getStateObjectNoUpdate to avoid touching the
stateObjects of mainDB.

Case: TestBlockchain/ValidBlocks/bcEIP1559/intrinsic.json

core/state/parallel_statedb.go

@@ -1285,7 +1285,13 @@ func (slotDB *ParallelStateDB) IsParallelReadsValid(isStage2 bool) bool {
 				}
 			}
 		}
-		nonceMain := mainDB.GetNonce(addr)
+
+		/* can not use mainDB.GetNonce() because we do not want to record the stateObject */
+		var nonceMain uint64 = 0
+		mainObj := mainDB.getStateObjectNoUpdate(addr)
+		if mainObj != nil {
+			nonceMain = mainObj.Nonce()
+		}
 		if nonceSlot != nonceMain {
 			log.Debug("IsSlotDBReadsValid nonce read is invalid", "addr", addr,
 				"nonceSlot", nonceSlot, "nonceMain", nonceMain, "SlotIndex", slotDB.parallel.SlotIndex,
@@ -1304,7 +1310,12 @@ func (slotDB *ParallelStateDB) IsParallelReadsValid(isStage2 bool) bool {
 			}
 		}
 
-		balanceMain := mainDB.GetBalance(addr)
+		balanceMain := common.U2560
+		mainObj := mainDB.getStateObjectNoUpdate(addr)
+		if mainObj != nil {
+			balanceMain = mainObj.Balance()
+		}
+
 		if balanceSlot.Cmp(balanceMain) != 0 {
 			log.Debug("IsSlotDBReadsValid balance read is invalid", "addr", addr,
 				"balanceSlot", balanceSlot, "balanceMain", balanceMain, "SlotIndex", slotDB.parallel.SlotIndex,
@@ -1390,7 +1401,11 @@ func (slotDB *ParallelStateDB) IsParallelReadsValid(isStage2 bool) bool {
 
 	// check code
 	for addr, codeSlot := range slotDB.parallel.codeReadsInSlot {
-		codeMain := mainDB.GetCode(addr)
+		var codeMain []byte = nil
+		object := mainDB.getStateObjectNoUpdate(addr)
+		if object != nil {
+			codeMain = object.Code()
+		}
 		if !bytes.Equal(codeSlot, codeMain) {
 			log.Debug("IsSlotDBReadsValid code read is invalid", "addr", addr,
 				"len codeSlot", len(codeSlot), "len codeMain", len(codeMain), "SlotIndex", slotDB.parallel.SlotIndex,
@@ -1400,7 +1415,11 @@ func (slotDB *ParallelStateDB) IsParallelReadsValid(isStage2 bool) bool {
 	}
 	// check codeHash
 	for addr, codeHashSlot := range slotDB.parallel.codeHashReadsInSlot {
-		codeHashMain := mainDB.GetCodeHash(addr)
+		codeHashMain := common.Hash{}
+		object := mainDB.getStateObjectNoUpdate(addr)
+		if object != nil {
+			codeHashMain = common.BytesToHash(object.CodeHash())
+		}
 		if !bytes.Equal(codeHashSlot.Bytes(), codeHashMain.Bytes()) {
 			log.Debug("IsSlotDBReadsValid codehash read is invalid", "addr", addr,
 				"codeHashSlot", codeHashSlot, "codeHashMain", codeHashMain, "SlotIndex", slotDB.parallel.SlotIndex,
@@ -1411,7 +1430,7 @@ func (slotDB *ParallelStateDB) IsParallelReadsValid(isStage2 bool) bool {
 	// addr state check
 	for addr, stateSlot := range slotDB.parallel.addrStateReadsInSlot {
 		stateMain := false // addr not exist
-		if mainDB.getStateObject(addr) != nil {
+		if mainDB.getStateObjectNoUpdate(addr) != nil {
 			stateMain = true // addr exist in main DB
 		}
 		if stateSlot != stateMain {
@@ -1424,7 +1443,7 @@ func (slotDB *ParallelStateDB) IsParallelReadsValid(isStage2 bool) bool {
 	}
 	// snapshot destructs check
 	for addr, destructRead := range slotDB.parallel.addrSnapDestructsReadsInSlot {
-		mainObj := mainDB.getStateObject(addr)
+		mainObj := mainDB.getStateObjectNoUpdate(addr)
 		if mainObj == nil {
 			log.Debug("IsSlotDBReadsValid snapshot destructs read invalid, address should exist",
 				"addr", addr, "destruct", destructRead,
@@ -1491,7 +1510,7 @@ func (s *ParallelStateDB) FinaliseForParallel(deleteEmptyObjects bool, mainDB *S
 				delete(mainDB.accounts, obj.addrHash)      // Clear out any previously updated account data (may be recreated via a resurrect)
 				delete(mainDB.accountsOrigin, obj.address) // Clear out any previously updated account data (may be recreated via a resurrect)
 				mainDB.AccountMux.Unlock()
-				
+
 				mainDB.StorageMux.Lock()
 				delete(mainDB.storages, obj.addrHash)      // Clear out any previously updated storage data (may be recreated via a resurrect)
 				delete(mainDB.storagesOrigin, obj.address) // Clear out any previously updated storage data (may be recreated via a resurrect)
@@ -1573,6 +1592,7 @@ func (s *ParallelStateDB) FinaliseForParallel(deleteEmptyObjects bool, mainDB *S
 				obj.finalise(true) // Prefetch slots in the background
 			} else {
 				obj.fixUpOriginAndResetPendingStorage()
+				obj.finalise(false)
 			}
 		}
 

core/state/state_object.go

@@ -258,7 +258,7 @@ func newObject(dbItf StateDBer, isParallel bool, address common.Address, acct *t
 		address:        address,
 		addrHash:       crypto.Keccak256Hash(address[:]),
 		origin:         origin,
-		data:           *acct,
+		data:           *acct.Copy(),
 		isParallel:     isParallel,
 		originStorage:  newStorage(isParallel),
 		pendingStorage: newStorage(isParallel),
@@ -267,7 +267,8 @@ func newObject(dbItf StateDBer, isParallel bool, address common.Address, acct *t
 	}
 
 	// dirty data when create a new account
-	if acct == nil {
+
+	if created {
 		s.dirtyBalance = new(uint256.Int).Set(acct.Balance)
 		s.dirtyNonce = new(uint64)
 		*s.dirtyNonce = acct.Nonce
@@ -834,7 +835,7 @@ func (s *stateObject) deepCopy(db *StateDB) *stateObject {
 		address:    s.address,
 		addrHash:   s.addrHash,
 		origin:     s.origin,
-		data:       s.data,
+		data:       *s.data.Copy(),
 		isParallel: s.isParallel,
 	}
 	if s.trie != nil {
@@ -972,7 +973,7 @@ func (s *stateObject) Root() common.Hash {
 func (s *stateObject) fixUpOriginAndResetPendingStorage() {
 	if s.db.isParallel && s.db.parallel.isSlotDB {
 		mainDB := s.db.parallel.baseStateDB
-		origObj := mainDB.getStateObject(s.address)
+		origObj := mainDB.getStateObjectNoUpdate(s.address)
 		mainDB.accountStorageParallelLock.RLock()
 		if origObj != nil && origObj.originStorage.Length() != 0 {
 			s.originStorage = origObj.originStorage.Copy()

core/state/statedb.go

@@ -76,6 +76,8 @@ func (s *StateObjectSyncMap) StoreStateObject(addr common.Address, stateObject *
 func (s *StateDB) loadStateObj(addr common.Address) (*stateObject, bool) {
 
 	if s.isParallel {
+		s.parallelStateAccessLock.Lock()
+		defer s.parallelStateAccessLock.Unlock()
 		ret, ok := s.parallel.stateObjects.LoadStateObject(addr)
 		return ret, ok
 	}
@@ -90,9 +92,9 @@ func (s *StateDB) storeStateObj(addr common.Address, stateObject *stateObject) {
 		// When a state object is stored into s.parallel.stateObjects,
 		// it belongs to base StateDB, it is confirmed and valid.
 		// TODO-dav: remove the lock/unlock?
-		stateObject.db.parallelStateAccessLock.Lock()
-		s.parallel.stateObjects.Store(addr, stateObject)
-		stateObject.db.parallelStateAccessLock.Unlock()
+		s.parallelStateAccessLock.Lock()
+		s.parallel.stateObjects.StoreStateObject(addr, stateObject)
+		s.parallelStateAccessLock.Unlock()
 	} else {
 		s.stateObjects[addr] = stateObject
 	}
@@ -816,6 +818,33 @@ func (s *StateDB) getStateObject(addr common.Address) *stateObject {
 	return nil
 }
 
+// getStateObjectNoUpdate is similar with getStateObject except that it does not
+// update stateObjects records.
+func (s *StateDB) getStateObjectNoUpdate(addr common.Address) *stateObject {
+	obj := s.getDeletedStateObjectNoUpdate(addr)
+	if obj != nil && !obj.deleted {
+		return obj
+	}
+	return nil
+}
+
+func (s *StateDB) getDeletedStateObjectNoUpdate(addr common.Address) *stateObject {
+	s.RecordRead(types.AccountStateKey(addr, types.AccountSelf), struct{}{})
+
+	// Prefer live objects if any is available
+	if obj, _ := s.getStateObjectFromStateObjects(addr); obj != nil {
+		return obj
+	}
+
+	data, ok := s.getStateObjectFromSnapshotOrTrie(addr)
+	if !ok {
+		return nil
+	}
+	// Insert into the live set
+	obj := newObject(s, s.isParallel, addr, data)
+	return obj
+}
+
 func (s *StateDB) GetStateObjectFromSnapshotOrTrie(addr common.Address) (data *types.StateAccount, ok bool) {
 	return s.getStateObjectFromSnapshotOrTrie(addr)
 }
@@ -878,11 +907,11 @@ func (s *StateDB) getStateObjectFromSnapshotOrTrie(addr common.Address) (data *t
 
 	// If snapshot unavailable or reading from it failed, load from the database
 	if data == nil {
+		s.trieParallelLock.Lock()
+		defer s.trieParallelLock.Unlock()
 		var trie Trie
 		if s.isParallel {
 			// hold lock for parallel
-			s.trieParallelLock.Lock()
-			defer s.trieParallelLock.Unlock()
 			if s.parallel.isSlotDB {
 				if s.parallel.baseStateDB == nil {
 					return nil, false