Method EventChan

cgroup2/manager.go:837–893

()

}

func (c *Manager) EventChan() (<-chan Event, <-chan error) {
	ec := make(chan Event, 1)
	errCh := make(chan error, 1)

	fd, err := c.memoryEventNonBlockFD()
	if err != nil {
		errCh <- err
		return ec, errCh
	}

	go func() {
		defer close(errCh)
		defer fd.Close()

		for {
			buffer := make([]byte, unix.SizeofInotifyEvent*10)
			bytesRead, err := fd.Read(buffer)
			if err != nil {
				errCh <- err
				return
			}

			if bytesRead < unix.SizeofInotifyEvent {
				continue
			}

			// Check cgroup.events first
			shouldExit := false
			if c.isCgroupEmpty() {
				shouldExit = true
			}

			out := make(map[string]uint64)
			if err := readKVStatsFile(c.path, "memory.events", out); err != nil {
				// When cgroup is deleted read may return -ENODEV instead of -ENOENT from open.
				if _, statErr := os.Lstat(filepath.Join(c.path, "memory.events")); !os.IsNotExist(statErr) {
					errCh <- err
				}
				return
			}

			ec <- Event{
				Low:          out["low"],
				High:         out["high"],
				Max:          out["max"],
				OOM:          out["oom"],
				OOMKill:      out["oom_kill"],
				OOMGroupKill: out["oom_group_kill"],
			}

			if shouldExit {
				return
			}
		}
	}()
	return ec, errCh
}