ref: 1471e462a43ff169164215653f13bdf75ccf8ea4
parent: daf4e542e31036ad232613f82ca1c5d100a270a2
author: Sigrid Solveig Haflínudóttir <[email protected]>
date: Fri Aug 13 07:42:38 EDT 2021
don't flush on every audio/video packet
--- a/rtmp.c
+++ b/rtmp.c
@@ -324,7 +324,7 @@
}
static int
-rtmpsend(RTMP *r)
+rtmpsend(RTMP *r, int flush)
{u8int *p, *h, *e, hdata[24];
int len, n, hsz;
@@ -368,7 +368,7 @@
}
}
- if(Bflush(r) < 0)
+ if(flush && Bflush(r) < 0)
goto err;
if(debug){@@ -412,7 +412,7 @@
puti16(CtlPingResponse);
puti32(n);
- return rtmpsend(r);
+ return rtmpsend(r, 1);
}
static int
@@ -422,7 +422,7 @@
newmsg(r, SetChunkSize, Type0, CSUserCtl);
puti32(sz);
- n = rtmpsend(r);
+ n = rtmpsend(r, 1);
r->chunkout = sz;
return n;
@@ -676,7 +676,7 @@
r->o.msg.cmd.cb = streamcreated;
r->o.msg.cmd.aux = c;
- n = rtmpsend(r);
+ n = rtmpsend(r, 1);
qunlock(r);
@@ -732,7 +732,7 @@
r->o.msg.cmd.aux = c;
r->o.msg.cmd.code = "NetStream.Publish.Start";
r->o.msg.sid = sid;
- n = rtmpsend(r);
+ n = rtmpsend(r, 1);
qunlock(r);
@@ -777,7 +777,7 @@
putend();
r->o.msg.sid = sid;
- res = rtmpsend(r);
+ res = rtmpsend(r, 1);
qunlock(r);
@@ -872,7 +872,7 @@
putdata(ps, p-ps);
- if(rtmpsend(r) < 0)
+ if(rtmpsend(r, 0) < 0)
return -1;
r->sps = 1;
@@ -898,7 +898,7 @@
putdata(p, nsz);
}
- return rtmpsend(r);
+ return rtmpsend(r, 0);
}
static int
@@ -944,7 +944,7 @@
putbyte(0xe5);
putbyte(0x00);
- if(rtmpsend(r) < 0)
+ if(rtmpsend(r, 0) < 0)
return -1;
r->aacpd = 1;
@@ -961,7 +961,7 @@
putdata(p+7, sz-7);
- return rtmpsend(r);
+ return rtmpsend(r, 0);
}
int
@@ -1011,7 +1011,7 @@
putkvnum("objectEncoding", 0); /* AMF0 */putend();
- return rtmpsend(r);
+ return rtmpsend(r, 1);
}
static int