Method processListFile

input/list.go:218–260

(f io.Reader)

}

func (s *List) processListFile(f io.Reader) {

	// Parse the list file line by line, in a way that allows
	// us to also check the status of the s.ci.Done channel
	// to abort.
	// This handles the case in which we're reading from stdin
	// which is possibly never closed, but we still want to abort
	// (eg: CTRL+C).
	lines := make(chan string, 8)

	go func() {
		scanner := bufio.NewScanner(f)
		for scanner.Scan() {
			line := scanner.Text()
			if line == "" {
				continue
			}
			err := scanner.Err()
			if err != nil {
				log.WithError(err).Fatal("Failed to scan list input file.")
			}
			lines <- line
		}
		err := scanner.Err()
		if err != nil {
			log.WithError(err).Fatal("Failed to scan list input file.")
		}
		close(lines)
	}()

	for {
		select {
		case line, ok := <-lines:
			if !ok {
				return
			}

			s.processFileOrList(line)
		case <-s.ci.Done:
			return
		}
	}
}

func (s *List) processList(fn string) error {
	if fn == "-" {