mahmad/stream-server
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity

msg stream id little-endian fix

Browse source
This commit is contained in:
Muaz Ahmad 2023-08-17 13:28:00 +05:00
parent 4f4a896b84
commit f6e23abbaf
2 changed files with 2 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
rtmp/chunk.go
View file

@ -85,7 +85,7 @@ func read_msg_streamid(conn net.Conn, chunk_bufs_ptr *ChunkBuffers) (msg_streami
if _, err = conn.Read(chunk_bufs_ptr.msg_streamid); err != nil { if _, err = conn.Read(chunk_bufs_ptr.msg_streamid); err != nil {
return return
} }
msg_streamid = binary.BigEndian.Uint32(chunk_bufs_ptr.msg_streamid) msg_streamid = binary.LittleEndian.Uint32(chunk_bufs_ptr.msg_streamid)
return return
} }

2
rtmp/chunk2.go
View file

@ -23,7 +23,7 @@ func write_message_header_0(chunk_buffer *[]byte, msg_strmid uint32, msg_ptr *Me
binary.BigEndian.PutUint32(msg_len_inter, msg_ptr.msg_len) binary.BigEndian.PutUint32(msg_len_inter, msg_ptr.msg_len)
copy((*chunk_buffer)[basic_header_size + 3:basic_header_size + 6], msg_len_inter[1:]) copy((*chunk_buffer)[basic_header_size + 3:basic_header_size + 6], msg_len_inter[1:])
(*chunk_buffer)[basic_header_size + 6] = msg_ptr.msg_type (*chunk_buffer)[basic_header_size + 6] = msg_ptr.msg_type
binary.BigEndian.PutUint32((*chunk_buffer)[basic_header_size + 7:basic_header_size + 11], msg_strmid) binary.LittleEndian.PutUint32((*chunk_buffer)[basic_header_size + 7:basic_header_size + 11], msg_strmid)
} }
func write_chunk_data(chunk_buffer *[]byte, data []byte, bytes_buffered *uint32, chunk_data_size uint32, header_size uint32) { func write_chunk_data(chunk_buffer *[]byte, data []byte, bytes_buffered *uint32, chunk_data_size uint32, header_size uint32) {