[rtmpdump] rtmpdump ustream patch

[BIITER]

Hi, this patch allows rtmpdump to keep connection with ustream server.
BIITER

--- old/rtmpdump/librtmp/rtmp.c	2010-05-29 06:15:18.000000000 +0200
+++ new/rtmpdump/librtmp/rtmp.c	2010-05-29 04:21:44.000000000 +0200
@@ -1929,6 +1929,35 @@ SendCheckBWResult(RTMP *r, double txn)
   return RTMP_SendPacket(r, &packet, false);
 }

+SAVC(ping);
+SAVC(pong);
+
+static bool
+SendPong(RTMP *r, double txn)
+{
+  RTMPPacket packet;
+  char pbuf[256], *pend = pbuf + sizeof(pbuf);
+  char *enc;
+
+  packet.m_nChannel = 0x03;	/* control channel (invoke) */
+  packet.m_headerType = RTMP_PACKET_SIZE_MEDIUM;
+  packet.m_packetType = 0x14;	/* INVOKE */
+  packet.m_nTimeStamp = 0x16 * r->m_nBWCheckCounter;	/* temp inc
value. till we figure it out. */
+  packet.m_nInfoField2 = 0;
+  packet.m_hasAbsTimestamp = 0;
+  packet.m_body = pbuf + RTMP_MAX_HEADER_SIZE;
+
+  enc = packet.m_body;
+  enc = AMF_EncodeString(enc, pend, &av_pong);
+  enc = AMF_EncodeNumber(enc, pend, txn);
+  *enc++ = AMF_NULL;
+
+  packet.m_nBodySize = enc - packet.m_body;
+
+  return RTMP_SendPacket(r, &packet, false);
+}
+
+
 SAVC(play);

 static bool
@@ -2321,6 +2350,10 @@ HandleInvoke(RTMP *r, const char *body,
       RTMP_Close(r);
       ret = 1;
     }
+  else if (AVMATCH(&method, &av_ping))
+    {
+		SendPong(r, 3.0);
+	}
   else if (AVMATCH(&method, &av__onbwcheck))
     {
       SendCheckBWResult(r, txn);