fsnotify_bug.go

package main

import (
	"fmt"
	"io/ioutil"
	"log"
	"path"

	"github.com/fsnotify/fsnotify"
)

func main() {
	watcher, err := fsnotify.NewWatcher()
	if err != nil {
		log.Fatalf("error from fsnotify.NewWatcher(): %s", err)
	}
	defer watcher.Close()

	// create a temp dir
	tempDir, err := ioutil.TempDir("", "fs_notify_bug")
	if err != nil {
		log.Fatalf("error creating tempdir: %s", err)
	}

	log.Printf("using tempdir: %s", tempDir)

	// create 300 files in temp dir (no watch set yet)
	for i := 0; i < 300; i++ {
		f := path.Join(tempDir, fmt.Sprintf("file%d", i))
		err = ioutil.WriteFile(f, []byte("stuff"), 0644)
		if err != nil {
			log.Fatal("error creating %s: %s", f, err)
		}

		log.Printf("created %s", f)
	}

	err = watcher.Add(tempDir)
	if err != nil {
		log.Fatalf("error adding %s: %s", tempDir, err)
	}
	log.Printf("watching %s", tempDir)

	for {
		select {
		case event := <-watcher.Events:
			log.Println("event:", event)

		case err := <-watcher.Errors:
			log.Printf("error from <-watcher.Errors: %s", err)
		}
	}
}