Merge pull request #3640 from influxdb/graphite_hang
Shutdown Graphite listener first during Close()pull/3647/head
commit
9b964f93cc
|
@ -40,6 +40,7 @@ There are breaking changes in this release. Please see the *Features* section be
|
|||
- [#3625](https://github.com/influxdb/influxdb/pull/3625): Don't panic when aggregate and raw queries are in a single statement
|
||||
- [#3629](https://github.com/influxdb/influxdb/pull/3629): Use sensible batching defaults for Graphite.
|
||||
- [#3638](https://github.com/influxdb/influxdb/pull/3638): Cluster config fixes and removal of meta.peers config field
|
||||
- [#3640](https://github.com/influxdb/influxdb/pull/3640): Shutdown Graphite service when signal received.
|
||||
|
||||
## v0.9.2 [2015-07-24]
|
||||
|
||||
|
|
|
@ -121,13 +121,15 @@ func (s *Service) Open() error {
|
|||
|
||||
// Close stops all data processing on the Graphite input.
|
||||
func (s *Service) Close() error {
|
||||
s.batcher.Flush()
|
||||
close(s.done)
|
||||
s.wg.Wait()
|
||||
s.done = nil
|
||||
if s.ln != nil {
|
||||
s.ln.Close()
|
||||
}
|
||||
|
||||
s.batcher.Stop()
|
||||
close(s.done)
|
||||
s.wg.Wait()
|
||||
s.done = nil
|
||||
|
||||
return nil
|
||||
}
|
||||
|
||||
|
|
Loading…
Reference in New Issue