mirror
/
av
mirror of https://bitbucket.org/ausocean/av.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Fix comments munged by /.s/.c search and replaces.

This commit is contained in:
scruzin 2019-01-19 15:18:10 +10:30
parent 9cc0e5631c
commit 5548345439
1 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
rtmp/packet.go
View File

@ -270,7 +270,7 @@ func (pkt *packet) resize(size uint32, ht uint8) {
// writeTo writes a packet to the RTMP connection. // writeTo writes a packet to the RTMP connection.
// Packets are written in chunks which are Session.chunkSize in length (128 bytes in length). // Packets are written in chunks which are Session.chunkSize in length (128 bytes in length).
// We defer sending small audio packets and combine consecutive small audio packets where possible to reduce I/O. // We defer sending small audio packets and combine consecutive small audio packets where possible to reduce I/O.
// When queue is true, we expect a response to this request and cache the method on c.methodCallc. // When queue is true, we expect a response to this request and cache the method on c.methodCalls.
func (pkt *packet) writeTo(c *Conn, queue bool) error { func (pkt *packet) writeTo(c *Conn, queue bool) error {
if pkt.body == nil || pkt.bodySize == 0 { if pkt.body == nil || pkt.bodySize == 0 {
return errInvalidBody return errInvalidBody
@ -298,7 +298,7 @@ func (pkt *packet) writeTo(c *Conn, queue bool) error {
prevPkt := c.channelsOut[pkt.channel] prevPkt := c.channelsOut[pkt.channel]
var last int var last int
if prevPkt != nil && pkt.headerType != headerSizeLarge { if prevPkt != nil && pkt.headerType != headerSizeLarge {
// Compress header by using the previous packet's attributec. // Compress header by using the previous packet's attributes.
if prevPkt.bodySize == pkt.bodySize && prevPkt.packetType == pkt.packetType && pkt.headerType == headerSizeMedium { if prevPkt.bodySize == pkt.bodySize && prevPkt.packetType == pkt.packetType && pkt.headerType == headerSizeMedium {
pkt.headerType = headerSizeSmall pkt.headerType = headerSizeSmall
} }
@ -468,7 +468,7 @@ func (pkt *packet) writeTo(c *Conn, queue bool) error {
} }
} }
// If we invoked a remote method and queue is true, we queue the method until the result arrivec. // If we invoked a remote method and queue is true, we queue the method until the result arrives.
if pkt.packetType == packetTypeInvoke && queue { if pkt.packetType == packetTypeInvoke && queue {
buf := pkt.body[1:] buf := pkt.body[1:]
meth := amf.DecodeString(buf) meth := amf.DecodeString(buf)