fix close on closed socket_writer (#2748)

This commit is contained in:
Patrick Hemmer
2017-05-02 14:06:49 -04:00
committed by Daniel Nelson
parent b0a2e8e1bd
commit ce203dc687
2 changed files with 11 additions and 1 deletions

View File

@@ -124,6 +124,16 @@ func (sw *SocketWriter) Write(metrics []telegraf.Metric) error {
return nil
}
// Close closes the connection. Noop if already closed.
func (sw *SocketWriter) Close() error {
if sw.Conn == nil {
return nil
}
err := sw.Conn.Close()
sw.Conn = nil
return err
}
func newSocketWriter() *SocketWriter {
s, _ := serializers.NewInfluxSerializer()
return &SocketWriter{