Method ChunkAndWrite

pkg/rtmp/message_packer.go:55–75

(writer io.Writer, csid int, typeid uint8, streamid int)

}

func (packer *MessagePacker) ChunkAndWrite(writer io.Writer, csid int, typeid uint8, streamid int) error {
	bodyLen := packer.b.Len() - 12

	if bodyLen <= LocalChunkSize {
		// 如果一个chunk就够放（大部分信令都是这种情况），我们直接在buffer前面预留的空间写入chunk header内容，避免造成拷贝
		writeSingleChunkHeader(packer.b.Bytes(), csid, bodyLen, typeid, streamid)
		_, err := packer.b.WriteTo(writer)
		return err
	}

	var h base.RtmpHeader
	h.Csid = csid
	h.MsgLen = uint32(bodyLen)
	h.MsgTypeId = typeid
	h.MsgStreamId = streamid
	h.TimestampAbs = 0
	chunks := Message2Chunks(packer.b.Bytes()[12:], &h)
	packer.b.Reset()
	_, err := writer.Write(chunks)
	return err
}

func (packer *MessagePacker) writeProtocolControlMessage(writer io.Writer, typeid uint8, val int) error {
	packer.b.ModWritePos(12)