psa/rtsp_reader-writer
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Refactoring.

Browse Source
This commit is contained in:
Сергей Петров 2025-04-09 16:34:44 +05:00
parent 60d315c6f6
commit ba39c3a9fd
1 changed files with 5 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
writer/pkg/storage/file.go
View File

@ -427,11 +427,12 @@ func GetHeader(id, res, file string) ([]string, error) {
if _, err := io.ReadFull(f, segData); err != nil { if _, err := io.ReadFull(f, segData); err != nil {
return nil, errors.New("reading header error: " + err.Error()) return nil, errors.New("reading header error: " + err.Error())
} }
headerReader := bytes.NewReader(segData) //headerReader := bytes.NewReader(segData)
headerSeg, err := ReadHeaderSegment(headerReader) //headerSeg, err := ReadHeaderSegment(headerReader)
if err != nil { if err != nil {
return nil, errors.New("reading header error: " + err.Error()) 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. // readString reads string length and then reads string data.
@ -517,8 +518,8 @@ func readPacket(r io.Reader) (InterleavedPacket, error) {
return pkt, nil return pkt, nil
} }
// readPacketSegment reads segment packets. // ReadPacketSegment reads segment packets.
func readPacketSegment(r io.Reader) ([]InterleavedPacket, error) { func ReadPacketSegment(r io.Reader) ([]InterleavedPacket, error) {
var numPackets int32 var numPackets int32
if err := binary.Read(r, binary.LittleEndian, &numPackets); err != nil { if err := binary.Read(r, binary.LittleEndian, &numPackets); err != nil {
return nil, err return nil, err