Skip to content

Commit

Permalink
Update span names (#8394)
Browse files Browse the repository at this point in the history
Co-authored-by: Raul Jordan <raul@prysmaticlabs.com>
  • Loading branch information
terencechain and rauljordan authored Feb 4, 2021
1 parent cf88afb commit 4c25fe9
Show file tree
Hide file tree
Showing 2 changed files with 13 additions and 13 deletions.
22 changes: 11 additions & 11 deletions beacon-chain/core/state/transition.go
Original file line number Diff line number Diff line change
Expand Up @@ -71,7 +71,7 @@ func ExecuteStateTransition(
return nil, errors.New("nil block")
}

ctx, span := trace.StartSpan(ctx, "beacon-chain.ChainService.ExecuteStateTransition")
ctx, span := trace.StartSpan(ctx, "core.state.ExecuteStateTransition")
defer span.End()
var err error
// Execute per slots transition.
Expand Down Expand Up @@ -127,7 +127,7 @@ func ExecuteStateTransitionNoVerifyAnySig(
return nil, nil, errors.New("nil block")
}

ctx, span := trace.StartSpan(ctx, "beacon-chain.ChainService.ExecuteStateTransitionNoVerifyAttSigs")
ctx, span := trace.StartSpan(ctx, "core.state.ExecuteStateTransitionNoVerifyAttSigs")
defer span.End()
var err error

Expand Down Expand Up @@ -173,7 +173,7 @@ func CalculateStateRoot(
state *stateTrie.BeaconState,
signed *ethpb.SignedBeaconBlock,
) ([32]byte, error) {
ctx, span := trace.StartSpan(ctx, "beacon-chain.ChainService.CalculateStateRoot")
ctx, span := trace.StartSpan(ctx, "core.state.CalculateStateRoot")
defer span.End()
if ctx.Err() != nil {
traceutil.AnnotateError(span, ctx.Err())
Expand Down Expand Up @@ -229,7 +229,7 @@ func CalculateStateRoot(
// previous_block_root = hash_tree_root(state.latest_block_header)
// state.block_roots[state.slot % SLOTS_PER_HISTORICAL_ROOT] = previous_block_root
func ProcessSlot(ctx context.Context, state *stateTrie.BeaconState) (*stateTrie.BeaconState, error) {
ctx, span := trace.StartSpan(ctx, "beacon-chain.ChainService.state.ProcessSlot")
ctx, span := trace.StartSpan(ctx, "core.state.ProcessSlot")
defer span.End()
span.AddAttributes(trace.Int64Attribute("slot", int64(state.Slot())))

Expand Down Expand Up @@ -274,7 +274,7 @@ func ProcessSlotsUsingNextSlotCache(
parentState *stateTrie.BeaconState,
parentRoot []byte,
slot uint64) (*stateTrie.BeaconState, error) {
ctx, span := trace.StartSpan(ctx, "beacon-chain.ChainService.ProcessSlotsUsingNextSlotCache")
ctx, span := trace.StartSpan(ctx, "core.state.ProcessSlotsUsingNextSlotCache")
defer span.End()

// Check whether the parent state has been advanced by 1 slot in next slot cache.
Expand Down Expand Up @@ -312,7 +312,7 @@ func ProcessSlotsUsingNextSlotCache(
// state.slot += 1
// ]
func ProcessSlots(ctx context.Context, state *stateTrie.BeaconState, slot uint64) (*stateTrie.BeaconState, error) {
ctx, span := trace.StartSpan(ctx, "beacon-chain.ChainService.ProcessSlots")
ctx, span := trace.StartSpan(ctx, "core.state.ProcessSlots")
defer span.End()
if state == nil {
return nil, errors.New("nil state")
Expand Down Expand Up @@ -416,7 +416,7 @@ func ProcessBlock(
state *stateTrie.BeaconState,
signed *ethpb.SignedBeaconBlock,
) (*stateTrie.BeaconState, error) {
ctx, span := trace.StartSpan(ctx, "beacon-chain.ChainService.state.ProcessBlock")
ctx, span := trace.StartSpan(ctx, "core.state.ProcessBlock")
defer span.End()

var err error
Expand Down Expand Up @@ -447,7 +447,7 @@ func ProcessBlockNoVerifyAnySig(
state *stateTrie.BeaconState,
signed *ethpb.SignedBeaconBlock,
) (*bls.SignatureSet, *stateTrie.BeaconState, error) {
ctx, span := trace.StartSpan(ctx, "beacon-chain.ChainService.state.ProcessBlockNoVerifyAnySig")
ctx, span := trace.StartSpan(ctx, "core.state.ProcessBlockNoVerifyAnySig")
defer span.End()

state, err := b.ProcessBlockHeaderNoVerify(state, signed.Block)
Expand Down Expand Up @@ -523,7 +523,7 @@ func ProcessOperationsNoVerifyAttsSigs(
ctx context.Context,
state *stateTrie.BeaconState,
signedBeaconBlock *ethpb.SignedBeaconBlock) (*stateTrie.BeaconState, error) {
ctx, span := trace.StartSpan(ctx, "beacon-chain.ChainService.state.ProcessOperationsNoVerifyAttsSigs")
ctx, span := trace.StartSpan(ctx, "core.state.ProcessOperationsNoVerifyAttsSigs")
defer span.End()

if _, err := VerifyOperationLengths(ctx, state, signedBeaconBlock); err != nil {
Expand Down Expand Up @@ -621,7 +621,7 @@ func CanProcessEpoch(state *stateTrie.BeaconState) bool {
// ProcessEpochPrecompute describes the per epoch operations that are performed on the beacon state.
// It's optimized by pre computing validator attested info and epoch total/attested balances upfront.
func ProcessEpochPrecompute(ctx context.Context, state *stateTrie.BeaconState) (*stateTrie.BeaconState, error) {
ctx, span := trace.StartSpan(ctx, "beacon-chain.ChainService.state.ProcessEpochPrecompute")
ctx, span := trace.StartSpan(ctx, "core.state.ProcessEpochPrecompute")
defer span.End()
span.AddAttributes(trace.Int64Attribute("epoch", int64(helpers.CurrentEpoch(state))))

Expand Down Expand Up @@ -671,7 +671,7 @@ func ProcessBlockForStateRoot(
state *stateTrie.BeaconState,
signed *ethpb.SignedBeaconBlock,
) (*stateTrie.BeaconState, error) {
ctx, span := trace.StartSpan(ctx, "beacon-chain.ChainService.state.ProcessBlockForStateRoot")
ctx, span := trace.StartSpan(ctx, "core.state.ProcessBlockForStateRoot")
defer span.End()

state, err := b.ProcessBlockHeaderNoVerify(state, signed.Block)
Expand Down
4 changes: 2 additions & 2 deletions beacon-chain/state/stategen/replay.go
Original file line number Diff line number Diff line change
Expand Up @@ -122,7 +122,7 @@ func executeStateTransitionStateGen(
return nil, errUnknownBlock
}

ctx, span := trace.StartSpan(ctx, "beacon-chain.ChainService.ExecuteStateTransitionStateGen")
ctx, span := trace.StartSpan(ctx, "stategen.ExecuteStateTransitionStateGen")
defer span.End()
var err error

Expand All @@ -148,7 +148,7 @@ func executeStateTransitionStateGen(
// There's no skip slot cache involved given state gen only works with already stored block and state in DB.
// WARNING: This method should not be used for future slot.
func processSlotsStateGen(ctx context.Context, state *stateTrie.BeaconState, slot uint64) (*stateTrie.BeaconState, error) {
ctx, span := trace.StartSpan(ctx, "beacon-chain.ChainService.ProcessSlotsStateGen")
ctx, span := trace.StartSpan(ctx, "stategen.ProcessSlotsStateGen")
defer span.End()
if state == nil {
return nil, errUnknownState
Expand Down

0 comments on commit 4c25fe9

Please sign in to comment.