You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@htrace.apache.org by cm...@apache.org on 2015/11/17 19:59:14 UTC
incubator-htrace git commit: HTRACE-300. Reaper should be initialized
before shards are activated (Masatake Iwasaki via Colin P. McCabe)
Repository: incubator-htrace
Updated Branches:
refs/heads/master b94898e67 -> 3845a187e
HTRACE-300. Reaper should be initialized before shards are activated (Masatake Iwasaki via Colin P. McCabe)
Project: http://git-wip-us.apache.org/repos/asf/incubator-htrace/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-htrace/commit/3845a187
Tree: http://git-wip-us.apache.org/repos/asf/incubator-htrace/tree/3845a187
Diff: http://git-wip-us.apache.org/repos/asf/incubator-htrace/diff/3845a187
Branch: refs/heads/master
Commit: 3845a187e2b46b9643c780aef9ab032bd77a0246
Parents: b94898e
Author: Colin P. Mccabe <cm...@apache.org>
Authored: Tue Nov 17 10:58:42 2015 -0800
Committer: Colin P. Mccabe <cm...@apache.org>
Committed: Tue Nov 17 10:58:42 2015 -0800
----------------------------------------------------------------------
htrace-htraced/go/src/org/apache/htrace/htraced/datastore.go | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-htrace/blob/3845a187/htrace-htraced/go/src/org/apache/htrace/htraced/datastore.go
----------------------------------------------------------------------
diff --git a/htrace-htraced/go/src/org/apache/htrace/htraced/datastore.go b/htrace-htraced/go/src/org/apache/htrace/htraced/datastore.go
index fad69d7..ab2747b 100644
--- a/htrace-htraced/go/src/org/apache/htrace/htraced/datastore.go
+++ b/htrace-htraced/go/src/org/apache/htrace/htraced/datastore.go
@@ -509,6 +509,7 @@ func CreateDataStore(cnf *conf.Config, writtenSpans chan *common.Span) (*dataSto
store.shards = append(store.shards, shd)
}
store.msink = NewMetricsSink(cnf)
+ store.rpr = NewReaper(cnf)
for idx := range store.shards {
shd := store.shards[idx]
shd.exited = make(chan bool, 1)
@@ -526,7 +527,6 @@ func CreateDataStore(cnf *conf.Config, writtenSpans chan *common.Span) (*dataSto
targetChan: shd.heartbeats,
})
}
- store.rpr = NewReaper(cnf)
store.startMs = common.TimeToUnixMs(time.Now().UTC())
return store, nil
}