LaconicNetwork/cosmos-sdk
7
0
Fork 0
Code Issues Pull Requests Packages Projects Releases 2 Wiki Activity

Merge PR #6761: telemetry: use UTC() in wrappers

Browse Source
This commit is contained in:
Adam Bozanich
2020-07-17 15:33:50 -04:00
committed by GitHub
parent 32de79d0aa
commit f33749263f
15 changed files with 33 additions and 33 deletions
Download Patch File Download Diff File Expand all files Collapse all files
baseapp/abci.go
+6 -6
View File
@@ -104,7 +104,7 @@ func (app *BaseApp) FilterPeerByID(info string) abci.ResponseQuery {
// BeginBlock implements the ABCI application interface.
func (app *BaseApp) BeginBlock(req abci.RequestBeginBlock) (res abci.ResponseBeginBlock) {
defer telemetry.MeasureSince(time.Now().UTC(), "abci", "begin_block")
defer telemetry.MeasureSince(time.Now(), "abci", "begin_block")
if app.cms.TracingEnabled() {
app.cms.SetTracingContext(sdk.TraceContext(
@@ -149,7 +149,7 @@ func (app *BaseApp) BeginBlock(req abci.RequestBeginBlock) (res abci.ResponseBeg
// EndBlock implements the ABCI interface.
func (app *BaseApp) EndBlock(req abci.RequestEndBlock) (res abci.ResponseEndBlock) {
defer telemetry.MeasureSince(time.Now().UTC(), "abci", "end_block")
defer telemetry.MeasureSince(time.Now(), "abci", "end_block")
if app.deliverState.ms.TracingEnabled() {
app.deliverState.ms = app.deliverState.ms.SetTracingContext(nil).(sdk.CacheMultiStore)
@@ -169,7 +169,7 @@ func (app *BaseApp) EndBlock(req abci.RequestEndBlock) (res abci.ResponseEndBloc
// will contain releveant error information. Regardless of tx execution outcome,
// the ResponseCheckTx will contain relevant gas execution context.
func (app *BaseApp) CheckTx(req abci.RequestCheckTx) abci.ResponseCheckTx {
defer telemetry.MeasureSince(time.Now().UTC(), "abci", "check_tx")
defer telemetry.MeasureSince(time.Now(), "abci", "check_tx")
tx, err := app.txDecoder(req.Tx)
if err != nil {
@@ -209,7 +209,7 @@ func (app *BaseApp) CheckTx(req abci.RequestCheckTx) abci.ResponseCheckTx {
// Regardless of tx execution outcome, the ResponseDeliverTx will contain relevant
// gas execution context.
func (app *BaseApp) DeliverTx(req abci.RequestDeliverTx) abci.ResponseDeliverTx {
defer telemetry.MeasureSince(time.Now().UTC(), "abci", "deliver_tx")
defer telemetry.MeasureSince(time.Now(), "abci", "deliver_tx")
tx, err := app.txDecoder(req.Tx)
if err != nil {
@@ -249,7 +249,7 @@ func (app *BaseApp) DeliverTx(req abci.RequestDeliverTx) abci.ResponseDeliverTx
// against that height and gracefully halt if it matches the latest committed
// height.
func (app *BaseApp) Commit() (res abci.ResponseCommit) {
defer telemetry.MeasureSince(time.Now().UTC(), "abci", "commit")
defer telemetry.MeasureSince(time.Now(), "abci", "commit")
header := app.deliverState.ctx.BlockHeader()
@@ -317,7 +317,7 @@ func (app *BaseApp) halt() {
// Query implements the ABCI interface. It delegates to CommitMultiStore if it
// implements Queryable.
func (app *BaseApp) Query(req abci.RequestQuery) abci.ResponseQuery {
defer telemetry.MeasureSince(time.Now().UTC(), "abci", "query")
defer telemetry.MeasureSince(time.Now(), "abci", "query")
// handle gRPC routes first rather than calling splitPath because '/' characters
// are used as part of gRPC paths