From: Sergey Matveev <stargrave@stargrave.org>
Date: Sat, 27 Apr 2019 08:46:04 +0000 (+0300)
Subject: Seek-related constants usage
X-Git-Tag: 4.0^2~12
X-Git-Url: http://www.git.cypherpunks.ru/?a=commitdiff_plain;h=1f8cc69e60101cb09a4ae64fccb365e6979c375b;p=nncp.git

Seek-related constants usage
---

diff --git a/src/cypherpunks.ru/nncp/jobs.go b/src/cypherpunks.ru/nncp/jobs.go
index bea093c..f3aa9e9 100644
--- a/src/cypherpunks.ru/nncp/jobs.go
+++ b/src/cypherpunks.ru/nncp/jobs.go
@@ -19,6 +19,7 @@ along with this program.  If not, see <http://www.gnu.org/licenses/>.
 package nncp
 
 import (
+	"io"
 	"os"
 	"path/filepath"
 	"strconv"
@@ -68,7 +69,7 @@ func (ctx *Ctx) Jobs(nodeId *NodeId, xx TRxTx) chan Job {
 				fd.Close()
 				continue
 			}
-			fd.Seek(0, 0)
+			fd.Seek(0, io.SeekStart)
 			ctx.LogD("jobs", SDS{
 				"xx":   string(xx),
 				"node": pktEnc.Sender,
diff --git a/src/cypherpunks.ru/nncp/sp.go b/src/cypherpunks.ru/nncp/sp.go
index c9474bd..cd8272c 100644
--- a/src/cypherpunks.ru/nncp/sp.go
+++ b/src/cypherpunks.ru/nncp/sp.go
@@ -622,7 +622,7 @@ func (state *SPState) StartWorkers(
 				var buf []byte
 				if freq.Offset < fullSize {
 					state.ctx.LogD("sp-file", sdsp, "seeking")
-					if _, err = fd.Seek(int64(freq.Offset), 0); err != nil {
+					if _, err = fd.Seek(int64(freq.Offset), io.SeekStart); err != nil {
 						state.ctx.LogE("sp-file", SdsAdd(sdsp, SDS{"err": err}), "")
 						break
 					}
@@ -868,7 +868,7 @@ func (state *SPState) ProcessSP(payload []byte) ([][]byte, error) {
 				SdsAdd(sdsp, SDS{"offset": strconv.FormatInt(int64(file.Offset), 10)}),
 				"seeking",
 			)
-			if _, err = fd.Seek(int64(file.Offset), 0); err != nil {
+			if _, err = fd.Seek(int64(file.Offset), io.SeekStart); err != nil {
 				state.ctx.LogE("sp-file", SdsAdd(sdsp, SDS{"err": err}), "")
 				fd.Close()
 				return nil, err
@@ -901,7 +901,7 @@ func (state *SPState) ProcessSP(payload []byte) ([][]byte, error) {
 				}
 				state.wg.Add(1)
 				defer state.wg.Done()
-				fd.Seek(0, 0)
+				fd.Seek(0, io.SeekStart)
 				state.ctx.LogD("sp-file", sdsp, "checking")
 				gut, err := Check(fd, file.Hash[:])
 				fd.Close()
diff --git a/src/cypherpunks.ru/nncp/tx.go b/src/cypherpunks.ru/nncp/tx.go
index 260f9bd..b3f8da5 100644
--- a/src/cypherpunks.ru/nncp/tx.go
+++ b/src/cypherpunks.ru/nncp/tx.go
@@ -128,7 +128,7 @@ func prepareTxFile(srcPath string) (io.Reader, *os.File, int64, error) {
 		if err = tmpW.Flush(); err != nil {
 			return nil, nil, 0, err
 		}
-		src.Seek(0, 0)
+		src.Seek(0, io.SeekStart)
 		r, w := io.Pipe()
 		go ae(tmpKey, bufio.NewReader(src), w)
 		reader = r