Prefixed progress messages

[nncp.git] / src / cmd / nncp-reass / main.go

diff --git a/src/cmd/nncp-reass/main.go b/src/cmd/nncp-reass/main.go
index 75aaf5a0aa06b036373e8aff2b10c9efc45b41ab..7d6e1c96965d2bc8c418921d6f30a7a717a7e836 100644 (file)
--- a/src/cmd/nncp-reass/main.go
+++ b/src/cmd/nncp-reass/main.go
@@ -144,10 +144,14 @@ func process(ctx *nncp.Ctx, path string, keep, dryRun, stdout, dumpMeta bool) bo
                if err != nil {
                        log.Fatalln(err)
                }
-               if _, err = nncp.CopyProgressed(hsh, bufio.NewReader(fd), nncp.SDS{
-                       "pkt":      chunkPath,
-                       "fullsize": fi.Size(),
-               }, ctx.ShowPrgrs); err != nil {
+               if _, err = nncp.CopyProgressed(
+                       hsh, bufio.NewReader(fd), "check",
+                       nncp.SDS{
+                               "pkt":      chunkPath,
+                               "fullsize": fi.Size(),
+                       },
+                       ctx.ShowPrgrs,
+               ); err != nil {
                        log.Fatalln(err)
                }
                fd.Close()
@@ -195,10 +199,14 @@ func process(ctx *nncp.Ctx, path string, keep, dryRun, stdout, dumpMeta bool) bo
                if err != nil {
                        log.Fatalln("Can not stat file:", err)
                }
-               if _, err = nncp.CopyProgressed(dstW, bufio.NewReader(fd), nncp.SDS{
-                       "pkt":      chunkPath,
-                       "fullsize": fi.Size(),
-               }, ctx.ShowPrgrs); err != nil {
+               if _, err = nncp.CopyProgressed(
+                       dstW, bufio.NewReader(fd), "reass",
+                       nncp.SDS{
+                               "pkt":      chunkPath,
+                               "fullsize": fi.Size(),
+                       },
+                       ctx.ShowPrgrs,
+               ); err != nil {
                        log.Fatalln(err)
                }
                fd.Close()