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

Don't parse points twice when receiving remote writes 

The monitoring stats were causing points to be parsed twice create
more cpu time just parsing points.
pull/5465/head
Jason Wilder 2016-01-27 14:24:56 -07:00
parent 47c5ade858
commit d54f930c2d
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
cluster/service.go
View File

@ -188,7 +188,7 @@ func (s *Service) processWriteShardRequest(buf []byte) error {
points := req.Points()
s.statMap.Add(writeShardPointsReq, int64(len(points)))
err := s.TSDBStore.WriteToShard(req.ShardID(), req.Points())
err := s.TSDBStore.WriteToShard(req.ShardID(), points)
// We may have received a write for a shard that we don't have locally because the
// sending node may have just created the shard (via the metastore) and the write
@ -211,7 +211,7 @@ func (s *Service) processWriteShardRequest(buf []byte) error {
if err != nil {
return err
}
return s.TSDBStore.WriteToShard(req.ShardID(), req.Points())
return s.TSDBStore.WriteToShard(req.ShardID(), points)
}
if err != nil {