]> Cypherpunks.ru repositories - nncp.git/blobdiff - src/jobs.go
Multicast areas
[nncp.git] / src / jobs.go
index 0819738f4033b4ffdc8022b9d9adf600e308289c..6e428770a3473edd4552f9d77e06486910fb6394 100644 (file)
@@ -20,6 +20,7 @@ package nncp
 import (
        "bytes"
        "fmt"
+       "io"
        "os"
        "path/filepath"
        "strings"
@@ -44,9 +45,9 @@ type Job struct {
        HshValue *[MTHSize]byte
 }
 
-func (ctx *Ctx) HdrRead(fd *os.File) (*PktEnc, []byte, error) {
+func (ctx *Ctx) HdrRead(r io.Reader) (*PktEnc, []byte, error) {
        var pktEnc PktEnc
-       _, err := xdr.Unmarshal(fd, &pktEnc)
+       _, err := xdr.Unmarshal(r, &pktEnc)
        if err != nil {
                return nil, nil, err
        }