|
|
@@ -67,7 +67,6 @@ func (w *Ruspa) Ammucchia(t *Trivella) {
|
|
|
for len(w.Opened) > 0 {
|
|
|
select {
|
|
|
case report := <-w.ReportIn:
|
|
|
- Console.Debugln(Gray("ReportIn:", report))
|
|
|
if report.err == nil {
|
|
|
w.INode.Size += report.size
|
|
|
fmt.Fprintf(t.Writer, "%s: %d\n", w.INode.Path, w.INode.Size)
|
|
|
@@ -75,7 +74,6 @@ func (w *Ruspa) Ammucchia(t *Trivella) {
|
|
|
Console.Debugln(Red(report.err))
|
|
|
}
|
|
|
case leaf := <-w.DoneIn:
|
|
|
- Console.Debugln(Gray("Done:", leaf.path))
|
|
|
delete(w.Opened, leaf.path)
|
|
|
}
|
|
|
}
|
|
|
@@ -110,7 +108,6 @@ func (w *Ruspa) Scava(t *Trivella) {
|
|
|
}
|
|
|
}
|
|
|
if len(w.Opened) != 0 {
|
|
|
- Console.Debugln(Gray("Spawning Ammucchia:", w.INode.Path))
|
|
|
go w.Ammucchia(t)
|
|
|
} else {
|
|
|
w.DoneOut <- StatusReport{path: w.INode.Path, size: w.INode.Size}
|
|
|
@@ -132,7 +129,6 @@ func NastroConvogliatore(path string, depth uint) {
|
|
|
if err != nil {
|
|
|
Console.Fatalln("Failed creating inode:", err)
|
|
|
}
|
|
|
- Console.Debugln(Gray("Starting Pesa on path:", path))
|
|
|
report := make(chan StatusReport)
|
|
|
done := make(chan StatusReport)
|
|
|
writer := bufio.NewWriter(os.Stdout)
|
|
|
@@ -150,5 +146,4 @@ func NastroConvogliatore(path string, depth uint) {
|
|
|
}
|
|
|
}
|
|
|
fmt.Fprintf(writer, "%s: %d\n", path, pathINode.Size)
|
|
|
- return
|
|
|
}
|
