From 13f60f201fe653a42a7a53e0d9a6fc28e381b80e Mon Sep 17 00:00:00 2001 From: Sergey Matveev Date: Fri, 13 Jan 2017 22:38:22 +0300 Subject: [PATCH] SeekStart constant instead of hardcode --- src/cypherpunks.ru/nncp/cmd/nncp-xfer/main.go | 2 +- src/cypherpunks.ru/nncp/jobs.go | 3 ++- src/cypherpunks.ru/nncp/sp.go | 6 +++--- 3 files changed, 6 insertions(+), 5 deletions(-) diff --git a/src/cypherpunks.ru/nncp/cmd/nncp-xfer/main.go b/src/cypherpunks.ru/nncp/cmd/nncp-xfer/main.go index 9c2b5e2..940d8f5 100644 --- a/src/cypherpunks.ru/nncp/cmd/nncp-xfer/main.go +++ b/src/cypherpunks.ru/nncp/cmd/nncp-xfer/main.go @@ -184,7 +184,7 @@ func main() { fd.Close() continue } - fd.Seek(0, 0) + fd.Seek(0, io.SeekStart) tmp, err := ctx.NewTmpFileWHash() if err != nil { log.Fatalln(err) diff --git a/src/cypherpunks.ru/nncp/jobs.go b/src/cypherpunks.ru/nncp/jobs.go index 1f3afd1..2bbde62 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 . 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 0a2b047..979dd9e 100644 --- a/src/cypherpunks.ru/nncp/sp.go +++ b/src/cypherpunks.ru/nncp/sp.go @@ -527,7 +527,7 @@ func (state *SPState) StartWorkers(conn net.Conn, infosPayloads [][]byte, payloa 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 } @@ -762,7 +762,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 @@ -790,7 +790,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() -- 2.44.0