diff --git a/pkg/coordinator/clients/consensus/pool.go b/pkg/coordinator/clients/consensus/pool.go index 57b58f1..6e3d39a 100644 --- a/pkg/coordinator/clients/consensus/pool.go +++ b/pkg/coordinator/clients/consensus/pool.go @@ -3,6 +3,7 @@ package consensus import ( "context" "fmt" + "runtime" "sync" "time" @@ -38,6 +39,8 @@ type Pool struct { rrLastIndexes map[ClientType]uint16 } +var debugValSetCounter uint64 = 1 + func NewPool(ctx context.Context, config *PoolConfig, logger logrus.FieldLogger) (*Pool, error) { var err error @@ -83,6 +86,15 @@ func (pool *Pool) GetValidatorSet() map[phase0.ValidatorIndex]*v1.Validator { return nil } + valsetID := debugValSetCounter + debugValSetCounter++ + + fmt.Printf("valset alloc: %v\n", valsetID) + + runtime.SetFinalizer(&valset, func(_ any) { + fmt.Printf("valset free: %v\n", valsetID) + }) + return valset }) }