X-Git-Url: http://www.git.cypherpunks.ru/?a=blobdiff_plain;f=src%2Fjobs.go;h=6e428770a3473edd4552f9d77e06486910fb6394;hb=ab7c7eca0e53661f0ba904c2a6ba752990bea367;hp=0819738f4033b4ffdc8022b9d9adf600e308289c;hpb=0ca5764d9eeff210ebf50d6c2e03fa6cbd173b99;p=nncp.git diff --git a/src/jobs.go b/src/jobs.go index 0819738..6e42877 100644 --- a/src/jobs.go +++ b/src/jobs.go @@ -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 }