Influxdata
/
influxdb
mirror of https://github.com/influxdata/influxdb.git
1
0
Fork 0
Code Issues Projects Releases Wiki Activity

no need for the reference to self

pull/476/merge
John Shahid 2014-05-22 17:01:31 -04:00
parent 696d61d534
commit 9ccc4af946
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
src/cluster/cluster_configuration.go
View File

@ -691,7 +691,7 @@ func (self *ClusterConfiguration) GetShardToWriteToBySeriesAndTime(db, series st
if hasRandomSplit && splitRegex.MatchString(series) {
return matchingShards[self.random.Intn(len(matchingShards))], nil
}
index := self.HashDbAndSeriesToInt(db, series)
index := HashDbAndSeriesToInt(db, series)
index = index % len(matchingShards)
return matchingShards[index], nil
}
@ -841,7 +841,7 @@ func (self *ClusterConfiguration) getShardRange(querySpec QuerySpec, shards []*S
return shards[startIndex : endIndex+startIndex]
}
func (self *ClusterConfiguration) HashDbAndSeriesToInt(database, series string) int {
func HashDbAndSeriesToInt(database, series string) int {
hasher := sha1.New()
hasher.Write([]byte(fmt.Sprintf("%s%s", database, series)))
buf := bytes.NewBuffer(hasher.Sum(nil))