We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent e2cd9aa commit 12796cbCopy full SHA for 12796cb
pkg/cgfsmon/new.go
@@ -22,8 +22,13 @@ func New(opts ...Opt) (ret *CGroupFSMonitor, err error) {
22
23
w := &CGroupFSMonitor{}
24
25
- w.eventsOut = make(chan types.CGroupEvents, 1)
26
- w.eventsIn = make(chan notify.EventInfo, 1)
+ w.eventsOut = make(chan types.CGroupEvents)
+
27
+ // FIXME:
28
+ // github.com/rjeczalik/notify drop events if receiver is too slow.
29
+ // https://github.com/rjeczalik/notify/issues/85
30
+ // https://github.com/rjeczalik/notify/issues/98
31
+ w.eventsIn = make(chan notify.EventInfo, 20)
32
33
for i := range opts {
34
w, err = opts[i](w)
0 commit comments