]> Cypherpunks.ru repositories - nncp.git/commitdiff
Go 1.6 compatibility revert fix
authorSergey Matveev <stargrave@stargrave.org>
Tue, 17 Jan 2017 19:02:52 +0000 (22:02 +0300)
committerSergey Matveev <stargrave@stargrave.org>
Tue, 17 Jan 2017 19:02:52 +0000 (22:02 +0300)
src/cypherpunks.ru/nncp/cmd/nncp-xfer/main.go
src/cypherpunks.ru/nncp/jobs.go
src/cypherpunks.ru/nncp/sp.go

index 940d8f54549948993299b14ceee7597c5ede2187..9c2b5e211efd96eaaa8acd1fbed765e3bcb41403 100644 (file)
@@ -184,7 +184,7 @@ func main() {
                                fd.Close()
                                continue
                        }
-                       fd.Seek(0, io.SeekStart)
+                       fd.Seek(0, 0)
                        tmp, err := ctx.NewTmpFileWHash()
                        if err != nil {
                                log.Fatalln(err)
index 2bbde622895d3469b0adc51b3027fc38c21377ac..1f3afd1e4f93534347b1826b73e28a62c48c16e1 100644 (file)
@@ -19,7 +19,6 @@ along with this program.  If not, see <http://www.gnu.org/licenses/>.
 package nncp
 
 import (
-       "io"
        "os"
        "path/filepath"
        "strconv"
@@ -69,7 +68,7 @@ func (ctx *Ctx) Jobs(nodeId *NodeId, xx TRxTx) chan Job {
                                fd.Close()
                                continue
                        }
-                       fd.Seek(0, io.SeekStart)
+                       fd.Seek(0, 0)
                        ctx.LogD("jobs", SDS{
                                "xx":   string(xx),
                                "node": pktEnc.Sender,
index 9a46961aad78c6494f28208f228d0a8b7fbe9e5b..17f62c5aa5ddbba4faf533daec6a7bb6166e2b43 100644 (file)
@@ -571,7 +571,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), io.SeekStart); err != nil {
+                                       if _, err = fd.Seek(int64(freq.Offset), 0); err != nil {
                                                state.ctx.LogE("sp-file", SdsAdd(sdsp, SDS{"err": err}), "")
                                                break
                                        }
@@ -813,7 +813,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), io.SeekStart); err != nil {
+                       if _, err = fd.Seek(int64(file.Offset), 0); err != nil {
                                state.ctx.LogE("sp-file", SdsAdd(sdsp, SDS{"err": err}), "")
                                fd.Close()
                                return nil, err
@@ -841,7 +841,7 @@ func (state *SPState) ProcessSP(payload []byte) ([][]byte, error) {
                                }
                                state.wg.Add(1)
                                defer state.wg.Done()
-                               fd.Seek(0, io.SeekStart)
+                               fd.Seek(0, 0)
                                state.ctx.LogD("sp-file", sdsp, "checking")
                                gut, err := Check(fd, file.Hash[:])
                                fd.Close()