This commit is contained in:
Bin Wu 2015-09-16 15:58:11 -07:00
Родитель 28aa68beb0
Коммит 18e8a44a7c
2 изменённых файлов: 3 добавлений и 3 удалений

Просмотреть файл

@ -58,7 +58,7 @@ func (qre *QueryExecutor) Execute() (reply *mproto.QueryResult, err error) {
defer func(start time.Time) { defer func(start time.Time) {
duration := time.Now().Sub(start) duration := time.Now().Sub(start)
qre.qe.queryServiceStats.QueryStats.Add(planName, duration) qre.qe.queryServiceStats.QueryStats.Add(planName, duration)
addUserTableQueryStats(qre.qe.queryServiceStats, qre.ctx, qre.plan.TableName, "Execute", int64(duration)) // addUserTableQueryStats(qre.qe.queryServiceStats, qre.ctx, qre.plan.TableName, "Execute", int64(duration))
if reply == nil { if reply == nil {
qre.plan.AddStats(1, duration, 0, 1) qre.plan.AddStats(1, duration, 0, 1)
@ -145,7 +145,7 @@ func (qre *QueryExecutor) Stream(sendReply func(*mproto.QueryResult) error) erro
defer func(start time.Time) { defer func(start time.Time) {
qre.qe.queryServiceStats.QueryStats.Record(qre.plan.PlanId.String(), start) qre.qe.queryServiceStats.QueryStats.Record(qre.plan.PlanId.String(), start)
addUserTableQueryStats(qre.qe.queryServiceStats, qre.ctx, qre.plan.TableName, "Stream", int64(time.Now().Sub(start))) // addUserTableQueryStats(qre.qe.queryServiceStats, qre.ctx, qre.plan.TableName, "Stream", int64(time.Now().Sub(start)))
}(time.Now()) }(time.Now())
if err := qre.checkPermissions(); err != nil { if err := qre.checkPermissions(); err != nil {

Просмотреть файл

@ -679,7 +679,7 @@ func (tsv *TabletServer) SplitQuery(ctx context.Context, target *pb.Target, req
} }
defer func(start time.Time) { defer func(start time.Time) {
addUserTableQueryStats(tsv.qe.queryServiceStats, ctx, splitter.tableName, "SplitQuery", int64(time.Now().Sub(start))) // addUserTableQueryStats(tsv.qe.queryServiceStats, ctx, splitter.tableName, "SplitQuery", int64(time.Now().Sub(start)))
}(time.Now()) }(time.Now())
qre := &QueryExecutor{ qre := &QueryExecutor{