Fix memory leak: Remove signal.Notify code from plugins/inputs/win_perf_counters.(*Win_PerfCounters).Gather
This commit is contained in:
parent
24a2aaef4b
commit
2163fde0a4
|
@ -6,12 +6,8 @@ import (
|
||||||
"errors"
|
"errors"
|
||||||
"fmt"
|
"fmt"
|
||||||
"strings"
|
"strings"
|
||||||
"syscall"
|
|
||||||
"unsafe"
|
"unsafe"
|
||||||
|
|
||||||
"os"
|
|
||||||
"os/signal"
|
|
||||||
|
|
||||||
"github.com/influxdata/telegraf"
|
"github.com/influxdata/telegraf"
|
||||||
"github.com/influxdata/telegraf/plugins/inputs"
|
"github.com/influxdata/telegraf/plugins/inputs"
|
||||||
"github.com/lxn/win"
|
"github.com/lxn/win"
|
||||||
|
@ -253,16 +249,6 @@ func (m *Win_PerfCounters) Gather(acc telegraf.Accumulator) error {
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
// When interrupt or terminate is called.
|
|
||||||
c := make(chan os.Signal, 1)
|
|
||||||
signal.Notify(c, os.Interrupt)
|
|
||||||
signal.Notify(c, syscall.SIGTERM)
|
|
||||||
go func() error {
|
|
||||||
<-c
|
|
||||||
m.Cleanup(&metrics)
|
|
||||||
return nil
|
|
||||||
}()
|
|
||||||
|
|
||||||
var bufSize uint32
|
var bufSize uint32
|
||||||
var bufCount uint32
|
var bufCount uint32
|
||||||
var size uint32 = uint32(unsafe.Sizeof(win.PDH_FMT_COUNTERVALUE_ITEM_DOUBLE{}))
|
var size uint32 = uint32(unsafe.Sizeof(win.PDH_FMT_COUNTERVALUE_ITEM_DOUBLE{}))
|
||||||
|
|
Loading…
Reference in New Issue