From ad85345e3e4851e1ab5596671ff101c89bdc55b8 Mon Sep 17 00:00:00 2001 From: Edward Muller Date: Wed, 21 May 2014 17:57:57 -0300 Subject: [PATCH] Close #566. Add some timing data to the logs --- src/coordinator/coordinator.go | 6 +++++- 1 file changed, 5 insertions(+), 1 deletion(-) diff --git a/src/coordinator/coordinator.go b/src/coordinator/coordinator.go index dc49a53dd0..e35f661264 100644 --- a/src/coordinator/coordinator.go +++ b/src/coordinator/coordinator.go @@ -12,6 +12,7 @@ import ( "regexp" "strings" "sync" + "time" log "code.google.com/p/log4go" ) @@ -65,7 +66,10 @@ func NewCoordinatorImpl(config *configuration.Configuration, raftServer ClusterC } func (self *CoordinatorImpl) RunQuery(user common.User, database string, queryString string, seriesWriter SeriesWriter) (err error) { - log.Info("Query: db: %s, u: %s, q: %s", database, user.GetName(), queryString) + log.Info("Start Query: db: %s, u: %s, q: %s", database, user.GetName(), queryString) + defer func(t time.Time) { + log.Debug("End Query: db: %s, u: %s, q: %s, t: %f", database, user.GetName(), queryString, time.Now().Sub(t)) + }(time.Now()) // don't let a panic pass beyond RunQuery defer common.RecoverFunc(database, queryString, nil)