X-Git-Url: http://www.git.cypherpunks.ru/?a=blobdiff_plain;f=src%2Fcypherpunks.ru%2Fnncp%2Fjobs.go;h=8630846d254747e1b59e5c75b94b17720389b844;hb=535d386941ae38abbaa8e1a6df69a5e739058011;hp=2bbde622895d3469b0adc51b3027fc38c21377ac;hpb=13f60f201fe653a42a7a53e0d9a6fc28e381b80e;p=nncp.git diff --git a/src/cypherpunks.ru/nncp/jobs.go b/src/cypherpunks.ru/nncp/jobs.go index 2bbde62..8630846 100644 --- a/src/cypherpunks.ru/nncp/jobs.go +++ b/src/cypherpunks.ru/nncp/jobs.go @@ -19,7 +19,6 @@ along with this program. If not, see . package nncp import ( - "io" "os" "path/filepath" "strconv" @@ -65,11 +64,11 @@ func (ctx *Ctx) Jobs(nodeId *NodeId, xx TRxTx) chan Job { continue } var pktEnc PktEnc - if _, err = xdr.Unmarshal(fd, &pktEnc); err != nil || pktEnc.Magic != MagicNNCPEv1 { + if _, err = xdr.Unmarshal(fd, &pktEnc); err != nil || pktEnc.Magic != MagicNNCPEv3 { fd.Close() continue } - fd.Seek(0, io.SeekStart) + fd.Seek(0, 0) ctx.LogD("jobs", SDS{ "xx": string(xx), "node": pktEnc.Sender,