-
-
Notifications
You must be signed in to change notification settings - Fork 11
/
pproffd.go
122 lines (101 loc) · 1.66 KB
/
pproffd.go
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
// Package pproffd is for detecting resource leaks due to unclosed handles.
package pproffd
import (
"io"
"net"
"os"
"runtime/pprof"
)
var enabled = func() bool {
_, ok := os.LookupEnv("PPROFFD")
return ok
}()
var p *pprof.Profile
func init() {
if enabled {
p = pprof.NewProfile("fds")
}
}
type fd int
func (me *fd) Closed() {
if enabled {
p.Remove(me)
}
}
func add(skip int) (ret *fd) {
if enabled {
ret = new(fd)
p.Add(ret, skip+2)
}
return
}
type Wrapped interface {
Wrapped() io.Closer
}
type CloseWrapper struct {
fd *fd
c io.Closer
}
func (me CloseWrapper) Wrapped() io.Closer {
return me.c
}
func (me CloseWrapper) Close() error {
me.fd.Closed()
return me.c.Close()
}
func NewCloseWrapper(c io.Closer) CloseWrapper {
// TODO: Check enabled?
return CloseWrapper{
fd: add(2),
c: c,
}
}
type wrappedNetConn struct {
net.Conn
CloseWrapper
}
func (me wrappedNetConn) Close() error {
return me.CloseWrapper.Close()
}
// Tracks a net.Conn until Close() is explicitly called.
func WrapNetConn(nc net.Conn) net.Conn {
if !enabled {
return nc
}
if nc == nil {
return nil
}
return wrappedNetConn{
nc,
NewCloseWrapper(nc),
}
}
type OSFile interface {
io.Reader
io.Seeker
io.Closer
io.Writer
Stat() (os.FileInfo, error)
io.ReaderAt
io.WriterAt
Wrapped
}
type wrappedOSFile struct {
*os.File
CloseWrapper
}
func (me wrappedOSFile) Close() error {
return me.CloseWrapper.Close()
}
type unwrappedOsFile struct {
*os.File
}
func (me unwrappedOsFile) Wrapped() io.Closer {
return me.File
}
func WrapOSFile(f *os.File) OSFile {
if !enabled {
return unwrappedOsFile{f}
}
return &wrappedOSFile{f, NewCloseWrapper(f)}
}