39 lines
766 B
Go
39 lines
766 B
Go
|
package fuse
|
||
|
|
|
||
|
|
import (
|
||
|
|
"bufio"
|
||
|
|
"errors"
|
||
|
|
"io"
|
||
|
|
"log"
|
||
|
|
"sync"
|
||
|
|
)
|
||
|
|
|
||
|
|
var (
|
||
|
|
// ErrOSXFUSENotFound is returned from Mount when the OSXFUSE
|
||
|
|
// installation is not detected.
|
||
|
|
//
|
||
|
|
// Only happens on OS X. Make sure OSXFUSE is installed, or see
|
||
|
|
// OSXFUSELocations for customization.
|
||
|
|
ErrOSXFUSENotFound = errors.New("cannot locate OSXFUSE")
|
||
|
|
)
|
||
|
|
|
||
|
|
func neverIgnoreLine(line string) bool {
|
||
|
|
return false
|
||
|
|
}
|
||
|
|
|
||
|
|
func lineLogger(wg *sync.WaitGroup, prefix string, ignore func(line string) bool, r io.ReadCloser) {
|
||
|
|
defer wg.Done()
|
||
|
|
|
||
|
|
scanner := bufio.NewScanner(r)
|
||
|
|
for scanner.Scan() {
|
||
|
|
line := scanner.Text()
|
||
|
|
if ignore(line) {
|
||
|
|
continue
|
||
|
|
}
|
||
|
|
log.Printf("%s: %s", prefix, line)
|
||
|
|
}
|
||
|
|
if err := scanner.Err(); err != nil {
|
||
|
|
log.Printf("%s, error reading: %v", prefix, err)
|
||
|
|
}
|
||
|
|
}
|