X-Git-Url: http://www.git.cypherpunks.ru/?a=blobdiff_plain;f=src%2Fjobs.go;h=9aa8be4a765d2295baeec85224e9f15b4f2aa883;hb=0fad171c0d79ad583c0faf5427e22d1d62a0a52d;hp=1b5cef8fbf24c5e1824cbff0c473cd478cf69bb2;hpb=116c4cf07862ff127054fca98b1fdac9451fb3a0;p=nncp.git diff --git a/src/jobs.go b/src/jobs.go index 1b5cef8..9aa8be4 100644 --- a/src/jobs.go +++ b/src/jobs.go @@ -41,7 +41,7 @@ type Job struct { PktEnc *PktEnc Path string Size int64 - HshValue *[32]byte + HshValue *[MTHSize]byte } func (ctx *Ctx) HdrRead(fd *os.File) (*PktEnc, []byte, error) { @@ -139,7 +139,7 @@ func (ctx *Ctx) jobsFind(nodeId *NodeId, xx TRxTx, nock bool) chan Job { } pktEnc, pktEncRaw, err := ctx.HdrRead(fd) fd.Close() - if err != nil || pktEnc.Magic != MagicNNCPEv4 { + if err != nil || pktEnc.Magic != MagicNNCPEv5 { continue } ctx.LogD("job", LEs{ @@ -163,7 +163,7 @@ func (ctx *Ctx) jobsFind(nodeId *NodeId, xx TRxTx, nock bool) chan Job { PktEnc: pktEnc, Path: pth, Size: fi.Size(), - HshValue: new([32]byte), + HshValue: new([MTHSize]byte), } copy(job.HshValue[:], hshValue) jobs <- job