X-Git-Url: http://www.git.cypherpunks.ru/?p=nncp.git;a=blobdiff_plain;f=src%2Fsp.go;h=e8e477cff9da8b5aa83b5ef75697142bd5c28cb8;hp=4db358742a17b1f584aa102ac853a1c6386c6d13;hb=a7bc092eb93fb9526b27bca20ae7b88b01d99f84;hpb=025e183975f87d56a06b9b31d839dbf7f778df62 diff --git a/src/sp.go b/src/sp.go index 4db3587..e8e477c 100644 --- a/src/sp.go +++ b/src/sp.go @@ -27,6 +27,7 @@ import ( "os" "path/filepath" "sort" + "strconv" "sync" "time" @@ -39,6 +40,7 @@ const ( MaxSPSize = 1<<16 - 256 PartSuffix = ".part" SPHeadOverhead = 4 + CfgDeadline = "NNCPDEADLINE" ) type MTHAndOffset struct { @@ -132,6 +134,14 @@ type ConnDeadlined interface { } func init() { + if v := os.Getenv(CfgDeadline); v != "" { + i, err := strconv.Atoi(v) + if err != nil { + log.Fatalln("Can not convert", CfgDeadline, "to integer:", err) + } + DefaultDeadline = time.Duration(i) * time.Second + } + var buf bytes.Buffer spHead := SPHead{Type: SPTypeHalt} if _, err := xdr.Marshal(&buf, spHead); err != nil {