update

cl/transition/impl/eth2/operations.go

@@ -236,26 +236,46 @@ func (I *impl) ProcessDeposit(s abstract.BeaconState, deposit *cltypes.Deposit)
 
 }
 
+func getPendingBalanceToWithdraw(s abstract.BeaconState, validatorIndex uint64) uint64 {
+	ws := s.GetPendingPartialWithdrawals()
+	balance := uint64(0)
+	ws.Range(func(index int, withdrawal *solid.PendingPartialWithdrawal, length int) bool {
+		if withdrawal.Index == validatorIndex {
+			balance += withdrawal.Amount
+		}
+		return true
+	})
+	return balance
+}
+
 func IsVoluntaryExitApplicable(s abstract.BeaconState, voluntaryExit *cltypes.VoluntaryExit) error {
 	currentEpoch := state.Epoch(s)
 	validator, err := s.ValidatorForValidatorIndex(int(voluntaryExit.ValidatorIndex))
 	if err != nil {
 		return err
 	}
+	// Verify the validator is active
 	if !validator.Active(currentEpoch) {
 		return errors.New("ProcessVoluntaryExit: validator is not active")
 	}
+	// Verify exit has not been initiated
 	if validator.ExitEpoch() != s.BeaconConfig().FarFutureEpoch {
 		return errors.New(
 			"ProcessVoluntaryExit: another exit for the same validator is already getting processed",
 		)
 	}
+	// Exits must specify an epoch when they become valid; they are not valid before then
 	if currentEpoch < voluntaryExit.Epoch {
 		return errors.New("ProcessVoluntaryExit: exit is happening in the future")
 	}
+	// Verify the validator has been active long enough
 	if currentEpoch < validator.ActivationEpoch()+s.BeaconConfig().ShardCommitteePeriod {
 		return errors.New("ProcessVoluntaryExit: exit is happening too fast")
 	}
+	// Only exit validator if it has no pending withdrawals in the queue
+	if b := getPendingBalanceToWithdraw(s, voluntaryExit.ValidatorIndex); b > 0 {
+		return fmt.Errorf("ProcessVoluntaryExit: validator has pending balance to withdraw: %d", b)
+	}
 	return nil
 }
 

cl/transition/impl/eth2/statechange/process_epoch.go

@@ -90,6 +90,11 @@ func ProcessEpoch(s abstract.BeaconState) error {
 
 	// fmt.Println("ProcessSlashings", time.Since(start))
 	ProcessEth1DataReset(s)
+	if s.Version() >= clparams.ElectraVersion {
+		ProcessPendingDeposits(s)
+		ProcessPendingConsolidations(s)
+	}
+
 	start = time.Now()
 	if err := ProcessEffectiveBalanceUpdates(s); err != nil {
 		return err

cl/transition/impl/eth2/statechange/process_pending_consolidations.go

@@ -0,0 +1,11 @@
+package statechange
+
+import (
+	"errors"
+
+	"github.com/erigontech/erigon/cl/abstract"
+)
+
+func ProcessPendingConsolidations(s abstract.BeaconState) error {
+	return errors.New("not implemented")
+}

cl/transition/impl/eth2/statechange/process_pending_deposits.go

@@ -0,0 +1,11 @@
+package statechange
+
+import (
+	"errors"
+
+	"github.com/erigontech/erigon/cl/abstract"
+)
+
+func ProcessPendingDeposits(s abstract.BeaconState) error {
+	return errors.New("not implemented")
+}