From a89a4d6b401b87f052d6366e283046397e78fb0b Mon Sep 17 00:00:00 2001 From: Jason Wilder Date: Wed, 11 May 2016 12:59:51 -0600 Subject: [PATCH] Add PointsWriter write timeout back Was ignored for some reason. --- coordinator/points_writer.go | 6 ++++++ 1 file changed, 6 insertions(+) diff --git a/coordinator/points_writer.go b/coordinator/points_writer.go index b0c171b1ea..c4ba382022 100644 --- a/coordinator/points_writer.go +++ b/coordinator/points_writer.go @@ -252,10 +252,16 @@ func (w *PointsWriter) WritePoints(database, retentionPolicy string, consistency w.statMap.Add(statSubWriteDrop, 1) } + timeout := time.NewTimer(w.WriteTimeout) + defer timeout.Stop() for range shardMappings.Points { select { case <-w.closing: return ErrWriteFailed + case <-timeout.C: + w.statMap.Add(statWriteTimeout, 1) + // return timeout error to caller + return ErrTimeout case err := <-ch: if err != nil { return err