From 8306057179bffd4f255350ad0d0fa0ebb6d756ea Mon Sep 17 00:00:00 2001 From: Cory LaNou Date: Fri, 20 Feb 2015 13:30:40 -0700 Subject: [PATCH] actually drop shard data --- server.go | 9 +++++++++ 1 file changed, 9 insertions(+) diff --git a/server.go b/server.go index a4697414d8..73c912475d 100644 --- a/server.go +++ b/server.go @@ -1535,6 +1535,15 @@ func (s *Server) applyDeleteSeries(m *messaging.Message) error { } } + for _, rp := range s.databases[c.Database].policies { + for _, id := range c.SeriesIDs { + err := rp.deleteSeries(id) + if err != nil { + return err + } + } + } + // Delete the database entry. for _, id := range c.SeriesIDs { delete(s.databases[c.Database].series, id)