assert write version is increasing per slot as we read from a slot (#29624)
This commit is contained in:
parent
c3353c27c2
commit
ad400419b5
|
@ -790,10 +790,10 @@ impl Accounts {
|
|||
match accum.entry(loaded_account_pubkey) {
|
||||
// Double check in case another thread interleaved a write between the read + write.
|
||||
Occupied(mut occupied_entry) => {
|
||||
if loaded_write_version > occupied_entry.get().0 {
|
||||
assert!(loaded_write_version > occupied_entry.get().0);
|
||||
// overwrite
|
||||
occupied_entry.insert((loaded_write_version, val));
|
||||
}
|
||||
}
|
||||
|
||||
Vacant(vacant_entry) => {
|
||||
vacant_entry.insert((loaded_write_version, val));
|
||||
|
|
|
@ -7620,10 +7620,10 @@ impl AccountsDb {
|
|||
// keep the latest write version for each pubkey
|
||||
match accum.entry(*loaded_account.pubkey()) {
|
||||
Occupied(mut occupied_entry) => {
|
||||
if loaded_write_version > occupied_entry.get().version() {
|
||||
assert!(loaded_write_version > occupied_entry.get().version());
|
||||
// overwrite
|
||||
occupied_entry.insert((loaded_write_version, loaded_hash));
|
||||
}
|
||||
}
|
||||
|
||||
Vacant(vacant_entry) => {
|
||||
vacant_entry.insert((loaded_write_version, loaded_hash));
|
||||
|
|
Loading…
Reference in New Issue