diff --git a/cl/beacon/handler/validator_registration.go b/cl/beacon/handler/validator_registration.go index 32a6d2e1dbd..163439f0fec 100644 --- a/cl/beacon/handler/validator_registration.go +++ b/cl/beacon/handler/validator_registration.go @@ -36,7 +36,7 @@ func (a *ApiHandler) PostEthV1ValidatorPrepareBeaconProposal(w http.ResponseWrit return } for _, v := range req { - a.logger.Debug("[Caplin] Registered new proposer", "index", v.ValidatorIndex, "fee_recipient", v.FeeRecipient.String()) + a.logger.Trace("[Caplin] Registered new proposer", "index", v.ValidatorIndex, "fee_recipient", v.FeeRecipient.String()) a.validatorParams.SetFeeRecipient(v.ValidatorIndex, v.FeeRecipient) a.validatorsMonitor.ObserveValidator(v.ValidatorIndex) } diff --git a/cl/beacon/router.go b/cl/beacon/router.go index 4d21fcd28e4..60c2cc78b3d 100644 --- a/cl/beacon/router.go +++ b/cl/beacon/router.go @@ -56,7 +56,7 @@ func ListenAndServe(beaconHandler *LayeredBeaconHandler, routerCfg beacon_router if isNotFound(nfw.code) || nfw.code == 0 { start := time.Now() beaconHandler.ArchiveApi.ServeHTTP(w, r) - log.Debug("[Beacon API] Request", "uri", r.URL.String(), "path", r.URL.Path, "time", time.Since(start)) + log.Trace("[Beacon API] Request", "uri", r.URL.String(), "path", r.URL.Path, "time", time.Since(start)) } else { log.Warn("[Beacon API] Request to unavailable endpoint, check --beacon.api flag", "uri", r.URL.String(), "path", r.URL.Path) } diff --git a/cl/monitor/validator.go b/cl/monitor/validator.go index 57dfb2c5192..c64148ab468 100644 --- a/cl/monitor/validator.go +++ b/cl/monitor/validator.go @@ -140,10 +140,10 @@ func (m *validatorMonitorImpl) runReportProposerStatus() { if status := m.vaidatorStatuses.getValidatorStatus(proposerIndex, prevSlot/m.beaconCfg.SlotsPerEpoch); status != nil { if status.proposeSlots.Contains(prevSlot) { metricProposerHit.AddInt(1) - log.Info("[monitor] proposer hit", "slot", prevSlot, "proposerIndex", proposerIndex) + log.Warn("[monitor] proposer hit", "slot", prevSlot, "proposerIndex", proposerIndex) } else { metricProposerMiss.AddInt(1) - log.Info("[monitor] proposer miss", "slot", prevSlot, "proposerIndex", proposerIndex) + log.Warn("[monitor] proposer miss", "slot", prevSlot, "proposerIndex", proposerIndex) } } } @@ -196,7 +196,7 @@ func (s *validatorStatuses) addValidator(vid uint64) { defer s.vStatusMutex.Unlock() if _, ok := s.statuses[vid]; !ok { s.statuses[vid] = make(map[uint64]*validatorStatus) - log.Info("[monitor] add validator", "vid", vid) + log.Trace("[monitor] add validator", "vid", vid) } } @@ -205,7 +205,7 @@ func (s *validatorStatuses) removeValidator(vid uint64) { defer s.vStatusMutex.Unlock() if _, ok := s.statuses[vid]; ok { delete(s.statuses, vid) - log.Info("[monitor] remove validator", "vid", vid) + log.Trace("[monitor] remove validator", "vid", vid) } } diff --git a/cl/validator/committee_subscription/committee_subscription.go b/cl/validator/committee_subscription/committee_subscription.go index bc80afb1359..ca845430664 100644 --- a/cl/validator/committee_subscription/committee_subscription.go +++ b/cl/validator/committee_subscription/committee_subscription.go @@ -105,7 +105,7 @@ func (c *CommitteeSubscribeMgmt) AddAttestationSubscription(ctx context.Context, return errors.New("head state not available") } - log.Debug("Add attestation subscription", "slot", slot, "committeeIndex", cIndex, "isAggregator", p.IsAggregator, "validatorIndex", p.ValidatorIndex) + log.Trace("Add attestation subscription", "slot", slot, "committeeIndex", cIndex, "isAggregator", p.IsAggregator, "validatorIndex", p.ValidatorIndex) commiteePerSlot := headState.CommitteeCount(p.Slot / c.beaconConfig.SlotsPerEpoch) cn() subnetId := subnets.ComputeSubnetForAttestation(commiteePerSlot, slot, cIndex, c.beaconConfig.SlotsPerEpoch, c.netConfig.AttestationSubnetCount)