X-Git-Url: http://www.git.cypherpunks.ru/?p=nncp.git;a=blobdiff_plain;f=src%2Fcmd%2Fnncp-ack%2Fmain.go;fp=src%2Fcmd%2Fnncp-ack%2Fmain.go;h=18a6f4be359e26bb9be55b5394b982c0fbc5bb31;hp=7342c848e9e0e4dc0e8ef0a51cec0b6655f30893;hb=2e22bda93fdf8f2f84e4d19b3f1d46318b497139;hpb=16b44ce6e0f7e3d668c8cf7edf0ecf0bb38e1a4c diff --git a/src/cmd/nncp-ack/main.go b/src/cmd/nncp-ack/main.go index 7342c84..18a6f4b 100644 --- a/src/cmd/nncp-ack/main.go +++ b/src/cmd/nncp-ack/main.go @@ -47,7 +47,7 @@ func main() { cfgPath = flag.String("cfg", nncp.DefaultCfgPath, "Path to configuration file") niceRaw = flag.String("nice", nncp.NicenessFmt(nncp.DefaultNiceFreq), "Outbound packet niceness") - minSizeRaw = flag.Uint64("minsize", 0, "Minimal required resulting packet size, in KiB") + minSizeRaw = flag.Int64("minsize", -1, "Minimal required resulting packet size, in KiB") viaOverride = flag.String("via", "", "Override Via path to destination node (ignored with -all)") spoolPath = flag.String("spool", "", "Override path to spool") logPath = flag.String("log", "", "Override path to logfile") @@ -94,7 +94,6 @@ func main() { } ctx.Umask() - minSize := int64(*minSizeRaw) * 1024 var nodes []*nncp.Node if *nodesRaw != "" { @@ -130,6 +129,14 @@ func main() { os.Exit(1) } nncp.ViaOverride(*viaOverride, ctx, nodes[0]) + + var minSize int64 + if *minSizeRaw < 0 { + minSize = nodes[0].ACKMinSize + } else if *minSizeRaw > 0 { + minSize = *minSizeRaw * 1024 + } + pktName, err := ctx.TxACK(nodes[0], nice, *pktRaw, minSize) if err != nil { log.Fatalln(err) @@ -140,6 +147,12 @@ func main() { isBad := false for _, node := range nodes { + var minSize int64 + if *minSizeRaw < 0 { + minSize = node.ACKMinSize + } else if *minSizeRaw > 0 { + minSize = *minSizeRaw * 1024 + } for job := range ctx.Jobs(node.Id, nncp.TRx) { pktName := filepath.Base(job.Path) sender := ctx.Neigh[*job.PktEnc.Sender]