]> Cypherpunks.ru repositories - nncp.git/commitdiff
SeekStart constant instead of hardcode
authorSergey Matveev <stargrave@stargrave.org>
Fri, 13 Jan 2017 19:38:22 +0000 (22:38 +0300)
committerSergey Matveev <stargrave@stargrave.org>
Fri, 13 Jan 2017 19:38:22 +0000 (22:38 +0300)
src/cypherpunks.ru/nncp/cmd/nncp-xfer/main.go
src/cypherpunks.ru/nncp/jobs.go
src/cypherpunks.ru/nncp/sp.go

index 9c2b5e211efd96eaaa8acd1fbed765e3bcb41403..940d8f54549948993299b14ceee7597c5ede2187 100644 (file)
@@ -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)
index 1f3afd1e4f93534347b1826b73e28a62c48c16e1..2bbde622895d3469b0adc51b3027fc38c21377ac 100644 (file)
@@ -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,
index 0a2b047fce12c12456940a82f19afa535a240ba1..979dd9e0c38455065af587cd23e3cd6ca15d9dc6 100644 (file)
@@ -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()