Non-Blocking os.ReadDir()

gistfile1.txt

// readDir reads the directory and returns the list
// it uses a little separate go-routine in order to handle timeouts
func (s scannerApp) readDir(d string) ([]os.DirEntry, error) {
	ch := make(chan []os.DirEntry, 2)

	go func(d string) {
		deList, err := os.ReadDir(d)

		if err != nil {
			ml.La("ReadDir got Error", err)
			count.IncrSuffix("dir-read-err", s.file)
			ch <- []os.DirEntry{}
			return
		}
		ch <- deList

	}(d)

	select {
	case deList := <-ch:
		if len(deList) == 0 {
			return nil, errors.New("No Directory List")
		}
		return deList, nil
	case <-time.After(3600 * time.Second):
		count.Incr("dir-read-timeout")
		return nil, errors.New("Dir Read Timeout")
	}

}