Sequential MTH optimization

[nncp.git] / src / check.go

diff --git a/src/check.go b/src/check.go
index 4f0a081479c9e12b3e6a56beae33028ac12c7155..7a3d5b8041a42a11059b763a5a2ac3e285c54646 100644 (file)
--- a/src/check.go
+++ b/src/check.go
@@ -79,7 +79,7 @@ func (ctx *Ctx) Check(nodeId *NodeId) bool {
        return !(ctx.checkXxIsBad(nodeId, TRx) || ctx.checkXxIsBad(nodeId, TTx))
 }
 
-func (ctx *Ctx) CheckNoCK(nodeId *NodeId, hshValue *[MTHSize]byte, mth *MTH) (int64, error) {
+func (ctx *Ctx) CheckNoCK(nodeId *NodeId, hshValue *[MTHSize]byte, mth MTH) (int64, error) {
        dirToSync := filepath.Join(ctx.Spool, nodeId.String(), string(TRx))
        pktName := Base32Codec.EncodeToString(hshValue[:])
        pktPath := filepath.Join(dirToSync, pktName)
@@ -103,7 +103,7 @@ func (ctx *Ctx) CheckNoCK(nodeId *NodeId, hshValue *[MTHSize]byte, mth *MTH) (in
        if mth == nil {
                gut, err = Check(fd, size, hshValue[:], les, ctx.ShowPrgrs)
        } else {
-               mth.PktName = pktName
+               mth.SetPktName(pktName)
                if _, err = mth.PrependFrom(bufio.NewReaderSize(fd, MTHSize)); err != nil {
                        return 0, err
                }