actually drop shard data

pull/1629/head
Cory LaNou 2015-02-20 13:30:40 -07:00
parent 6d5be3da25
commit 8306057179
1 changed files with 9 additions and 0 deletions

View File

@ -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)