112 static int HandShake(RTMP *r, int FP9HandShake);
113 static int SocksNegotiate(RTMP *r);
115 static int SendConnectPacket(RTMP *r, RTMPPacket *cp);
116 static int SendCheckBW(RTMP *r);
117 static int SendCheckBWResult(RTMP *r, double txn);
118 static int SendDeleteStream(RTMP *r, double dStreamId);
119 static int SendFCSubscribe(RTMP *r, AVal *subscribepath);
120 static int SendPlay(RTMP *r);
121 static int SendBytesReceived(RTMP *r);
122 static int SendUsherToken(RTMP *r, AVal *usherToken);
125 static int SendBGHasStream(RTMP *r, double dId, AVal *playpath);
128 static int HandleInvoke(RTMP *r, const char *body, unsigned int nBodySize);
129 static int HandleMetadata(RTMP *r, char *body, unsigned int len);
130 static void HandleChangeChunkSize(RTMP *r, const RTMPPacket *packet);
131 static void HandleAudio(RTMP *r, const RTMPPacket *packet);
132 static void HandleVideo(RTMP *r, const RTMPPacket *packet);
133 static void HandleCtrl(RTMP *r, const RTMPPacket *packet);
134 static void HandleServerBW(RTMP *r, const RTMPPacket *packet);
135 static void HandleClientBW(RTMP *r, const RTMPPacket *packet);
137 static int ReadN(RTMP *r, char *buffer, int n);
138 static int WriteN(RTMP *r, const char *buffer, int n);
142 static int HTTP_Post(RTMP *r, RTMPTCmd cmd, const char *buf, int len);
143 static int HTTP_read(RTMP *r, int fill);
145 static void CloseInternal(RTMP *r, int reconnect);
316 RTMP *
319   return calloc(1, sizeof(RTMP));  in RTMP_Alloc()
323 RTMP_Free(RTMP *r)  in RTMP_Free()
329 RTMP_Init(RTMP *r)  in RTMP_Init()
336   memset(r, 0, sizeof(RTMP));  in RTMP_Init()
351 RTMP_EnableWrite(RTMP *r)  in RTMP_EnableWrite()
357 RTMP_GetDuration(RTMP *r)  in RTMP_GetDuration()
363 RTMP_IsConnected(RTMP *r)  in RTMP_IsConnected()
369 RTMP_Socket(RTMP *r)  in RTMP_Socket()
375 RTMP_IsTimedout(RTMP *r)  in RTMP_IsTimedout()
381 RTMP_SetBufferMS(RTMP *r, int size)  in RTMP_SetBufferMS()
387 RTMP_UpdateBufferMS(RTMP *r)  in RTMP_UpdateBufferMS()
410 SocksSetup(RTMP *r, AVal *sockshost)  in SocksSetup()
435 RTMP_SetupStream(RTMP *r,  in RTMP_SetupStream()
547 #define OFF(x)	offsetof(struct RTMP,x)
713 int RTMP_SetOpt(RTMP *r, const AVal *opt, AVal *arg)  in RTMP_SetOpt()
757 int RTMP_SetupURL(RTMP *r, char *url)  in RTMP_SetupURL()
906 RTMP_Connect0(RTMP *r, struct sockaddr * service)  in RTMP_Connect0()
960 RTMP_TLS_Accept(RTMP *r, void *ctx)  in RTMP_TLS_Accept()
977 RTMP_Connect1(RTMP *r, RTMPPacket *cp)  in RTMP_Connect1()
1031 RTMP_Connect(RTMP *r, RTMPPacket *cp)  in RTMP_Connect()
1062 SocksNegotiate(RTMP *r)  in SocksNegotiate()
1099 RTMP_ConnectStream(RTMP *r, int seekTime)  in RTMP_ConnectStream()
1135 RTMP_ReconnectStream(RTMP *r, int seekTime)  in RTMP_ReconnectStream()
1145 RTMP_ToggleStream(RTMP *r)  in RTMP_ToggleStream()
1167 RTMP_DeleteStream(RTMP *r)  in RTMP_DeleteStream()
1179 RTMP_GetNextMediaPacket(RTMP *r, RTMPPacket *packet)  in RTMP_GetNextMediaPacket()
1226 RTMP_ClientPacket(RTMP *r, RTMPPacket *packet)  in RTMP_ClientPacket()
1390 ReadN(RTMP *r, char *buffer, int n)  in ReadN()
1502 WriteN(RTMP *r, const char *buffer, int n)  in WriteN()
1579 SendConnectPacket(RTMP *r, RTMPPacket *cp)  in SendConnectPacket()
1693 SendBGHasStream(RTMP *r, double dId, AVal *playpath)
1725 RTMP_SendCreateStream(RTMP *r)  in RTMP_SendCreateStream()
1752 SendFCSubscribe(RTMP *r, AVal *subscribepath)  in SendFCSubscribe()
1784 SendUsherToken(RTMP *r, AVal *usherToken)  in SendUsherToken()
1816 SendReleaseStream(RTMP *r)  in SendReleaseStream()
1846 SendFCPublish(RTMP *r)  in SendFCPublish()
1876 SendFCUnpublish(RTMP *r)  in SendFCUnpublish()
1908 SendPublish(RTMP *r)  in SendPublish()
1943 SendDeleteStream(RTMP *r, double dStreamId)  in SendDeleteStream()
1972 RTMP_SendPause(RTMP *r, int DoPause, int iTime)  in RTMP_SendPause()
1999 int RTMP_Pause(RTMP *r, int DoPause)  in RTMP_Pause()
2010 RTMP_SendSeek(RTMP *r, int iTime)  in RTMP_SendSeek()
2039 RTMP_SendServerBW(RTMP *r)  in RTMP_SendServerBW()
2059 RTMP_SendClientBW(RTMP *r)  in RTMP_SendClientBW()
2080 SendBytesReceived(RTMP *r)  in SendBytesReceived()
2105 SendCheckBW(RTMP *r)  in SendCheckBW()
2133 SendCheckBWResult(RTMP *r, double txn)  in SendCheckBWResult()
2162 SendPong(RTMP *r, double txn)  in SendPong()
2189 SendPlay(RTMP *r)  in SendPlay()
2257 SendPlaylist(RTMP *r)  in SendPlaylist()
2295 SendSecureTokenResponse(RTMP *r, AVal *resp)  in SendSecureTokenResponse()
2339 RTMP_SendCtrl(RTMP *r, short nType, unsigned int nObject, unsigned int nTime)  in RTMP_SendCtrl()
2408 RTMP_DropRequest(RTMP *r, int i, int freeit)  in RTMP_DropRequest()
2522 PublisherAuth(RTMP *r, AVal *description)  in PublisherAuth()
2912 HandleInvoke(RTMP *r, const char *body, unsigned int nBodySize)  in HandleInvoke()
3303 HandleMetadata(RTMP *r, char *body, unsigned int len)  in HandleMetadata()
3345 HandleChangeChunkSize(RTMP *r, const RTMPPacket *packet)  in HandleChangeChunkSize()
3356 HandleAudio(RTMP *r, const RTMPPacket *packet)  in HandleAudio()
3361 HandleVideo(RTMP *r, const RTMPPacket *packet)  in HandleVideo()
3366 HandleCtrl(RTMP *r, const RTMPPacket *packet)  in HandleCtrl()
3508 HandleServerBW(RTMP *r, const RTMPPacket *packet)  in HandleServerBW()
3515 HandleClientBW(RTMP *r, const RTMPPacket *packet)  in HandleClientBW()
3550 RTMP_ReadPacket(RTMP *r, RTMPPacket *packet)  in RTMP_ReadPacket()
3744 HandShake(RTMP *r, int FP9HandShake)  in HandShake()
3808 SHandShake(RTMP *r)  in SHandShake()
3872 RTMP_SendChunk(RTMP *r, RTMPChunk *chunk)  in RTMP_SendChunk()
3896 RTMP_SendPacket(RTMP *r, RTMPPacket *packet, int queue)  in RTMP_SendPacket()
4121 RTMP_Serve(RTMP *r)  in RTMP_Serve()
4127 RTMP_Close(RTMP *r)  in RTMP_Close()
4133 CloseInternal(RTMP *r, int reconnect)  in CloseInternal()
4407 HTTP_Post(RTMP *r, RTMPTCmd cmd, const char *buf, int len)  in HTTP_Post()
4429 HTTP_read(RTMP *r, int fill)  in HTTP_read()
4503 Read_1_Packet(RTMP *r, char *buf, unsigned int buflen)  in Read_1_Packet()
4981 RTMP_Read(RTMP *r, char *buf, int size)  in RTMP_Read()
5097 RTMP_Write(RTMP *r, const char *buf, int size)  in RTMP_Write()