diff --git a/writer/pkg/storage/file.go b/writer/pkg/storage/file.go index 22dd68a..f1de59a 100644 --- a/writer/pkg/storage/file.go +++ b/writer/pkg/storage/file.go @@ -427,11 +427,12 @@ func GetHeader(id, res, file string) ([]string, error) { if _, err := io.ReadFull(f, segData); err != nil { return nil, errors.New("reading header error: " + err.Error()) } - headerReader := bytes.NewReader(segData) - headerSeg, err := ReadHeaderSegment(headerReader) + //headerReader := bytes.NewReader(segData) + //headerSeg, err := ReadHeaderSegment(headerReader) if err != nil { return nil, errors.New("reading header error: " + err.Error()) } + return strings.Split(string(segData), "\n"), nil } // readString reads string length and then reads string data. @@ -517,8 +518,8 @@ func readPacket(r io.Reader) (InterleavedPacket, error) { return pkt, nil } -// readPacketSegment reads segment packets. -func readPacketSegment(r io.Reader) ([]InterleavedPacket, error) { +// ReadPacketSegment reads segment packets. +func ReadPacketSegment(r io.Reader) ([]InterleavedPacket, error) { var numPackets int32 if err := binary.Read(r, binary.LittleEndian, &numPackets); err != nil { return nil, err