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 <[email protected]>
Authored: Tue Nov 17 10:58:42 2015 -0800
Committer: Colin P. Mccabe <[email protected]>
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
 }

Reply via email to