GOARCH="amd64"
GOBIN=""
GOEXE=""
GOHOSTARCH="amd64"
GOHOSTOS="linux"
GOOS="linux"
GOPATH="/usr/local/git_tree/gopath_third_party:/usr/local/git_tree/gopath:/usr/local/git_tree/gopath_third_party:/usr/local/git_tree/gopath"
GORACE=""
GOROOT="/usr/lib64/go"
GOTOOLDIR="/usr/lib64/go/pkg/tool/linux_amd64"
GO15VENDOREXPERIMENT="1"
CC="gcc"
GOGCCFLAGS="-fPIC -m64 -pthread -fmessage-length=0"
CXX="g++"
CGO_ENABLED="1"

package main

import (
        "bytes"
        "io/ioutil"
        "log"
        "os"
        "strconv"
        "sync"
        "time"

        "golang.org/x/exp/inotify"
)

var dosleep = true

func main() {
        w, err := inotify.NewWatcher()
        if err != nil {
                log.Fatal(err)
        }

        if err := w.Watch("."); err != nil {
                log.Fatal(err)
        }

        var wg sync.WaitGroup
        wg.Add(1)

        go func() {
                for err := range w.Error {
                        log.Println(err)
                }
        }()

        go func() {
                for event := range w.Event {
                        if event.Mask&inotify.IN_Q_OVERFLOW == inotify.IN_Q_OVERFLOW {
                                log.Println("inotify.IN_Q_OVERFLOW")
                        }

                        if dosleep {
                                time.Sleep(time.Second)
                        }
                }
        }()

        go func() {
                b, err := ioutil.ReadFile("/proc/sys/fs/inotify/max_queued_events")
                if err != nil {
                        log.Fatal(err)
                }

                b = bytes.TrimSpace(b)
                queuesize, err := strconv.Atoi(string(b))
                if err != nil {
                        log.Fatal(err)
                }

                queuesize *= 2
                log.Println("iterating", queuesize, "times")
                for i := 0; i < queuesize; i++ {
                        if f, err := os.Create("_test"); err != nil {
                                log.Fatal(err)
                        } else {
                                f.Close()
                                os.Remove("_test")
                        }
                }

                log.Println("stop iterating, drain queue")
                dosleep = false
        }()

        wg.Wait()
}