Lines Matching refs:pend
1582 char pbuf[4096], *pend = pbuf + sizeof(pbuf); in SendConnectPacket() local
1597 enc = AMF_EncodeString(enc, pend, &av_connect); in SendConnectPacket()
1598 enc = AMF_EncodeNumber(enc, pend, ++r->m_numInvokes); in SendConnectPacket()
1601 enc = AMF_EncodeNamedString(enc, pend, &av_app, &r->Link.app); in SendConnectPacket()
1606 enc = AMF_EncodeNamedString(enc, pend, &av_type, &av_nonprivate); in SendConnectPacket()
1612 enc = AMF_EncodeNamedString(enc, pend, &av_flashVer, &r->Link.flashVer); in SendConnectPacket()
1618 enc = AMF_EncodeNamedString(enc, pend, &av_swfUrl, &r->Link.swfUrl); in SendConnectPacket()
1624 enc = AMF_EncodeNamedString(enc, pend, &av_tcUrl, &r->Link.tcUrl); in SendConnectPacket()
1630 enc = AMF_EncodeNamedBoolean(enc, pend, &av_fpad, FALSE); in SendConnectPacket()
1633 enc = AMF_EncodeNamedNumber(enc, pend, &av_capabilities, 15.0); in SendConnectPacket()
1636 enc = AMF_EncodeNamedNumber(enc, pend, &av_audioCodecs, r->m_fAudioCodecs); in SendConnectPacket()
1639 enc = AMF_EncodeNamedNumber(enc, pend, &av_videoCodecs, r->m_fVideoCodecs); in SendConnectPacket()
1642 enc = AMF_EncodeNamedNumber(enc, pend, &av_videoFunction, 1.0); in SendConnectPacket()
1647 enc = AMF_EncodeNamedString(enc, pend, &av_pageUrl, &r->Link.pageUrl); in SendConnectPacket()
1654 enc = AMF_EncodeNamedNumber(enc, pend, &av_objectEncoding, r->m_fEncoding); in SendConnectPacket()
1658 if (enc + 3 >= pend) in SendConnectPacket()
1667 enc = AMF_EncodeBoolean(enc, pend, r->Link.lFlags & RTMP_LF_AUTH); in SendConnectPacket()
1670 enc = AMF_EncodeString(enc, pend, &r->Link.auth); in SendConnectPacket()
1679 enc = AMFProp_Encode(&r->Link.extras.o_props[i], enc, pend); in SendConnectPacket()
1696 char pbuf[1024], *pend = pbuf + sizeof(pbuf);
1708 enc = AMF_EncodeString(enc, pend, &av_bgHasStream);
1709 enc = AMF_EncodeNumber(enc, pend, dId);
1712 enc = AMF_EncodeString(enc, pend, playpath);
1728 char pbuf[256], *pend = pbuf + sizeof(pbuf); in RTMP_SendCreateStream() local
1740 enc = AMF_EncodeString(enc, pend, &av_createStream); in RTMP_SendCreateStream()
1741 enc = AMF_EncodeNumber(enc, pend, ++r->m_numInvokes); in RTMP_SendCreateStream()
1755 char pbuf[512], *pend = pbuf + sizeof(pbuf); in SendFCSubscribe() local
1767 enc = AMF_EncodeString(enc, pend, &av_FCSubscribe); in SendFCSubscribe()
1768 enc = AMF_EncodeNumber(enc, pend, ++r->m_numInvokes); in SendFCSubscribe()
1770 enc = AMF_EncodeString(enc, pend, subscribepath); in SendFCSubscribe()
1787 char pbuf[1024], *pend = pbuf + sizeof(pbuf); in SendUsherToken() local
1799 enc = AMF_EncodeString(enc, pend, &av_NetStream_Authenticate_UsherToken); in SendUsherToken()
1800 enc = AMF_EncodeNumber(enc, pend, ++r->m_numInvokes); in SendUsherToken()
1802 enc = AMF_EncodeString(enc, pend, usherToken); in SendUsherToken()
1819 char pbuf[1024], *pend = pbuf + sizeof(pbuf); in SendReleaseStream() local
1831 enc = AMF_EncodeString(enc, pend, &av_releaseStream); in SendReleaseStream()
1832 enc = AMF_EncodeNumber(enc, pend, ++r->m_numInvokes); in SendReleaseStream()
1834 enc = AMF_EncodeString(enc, pend, &r->Link.playpath); in SendReleaseStream()
1849 char pbuf[1024], *pend = pbuf + sizeof(pbuf); in SendFCPublish() local
1861 enc = AMF_EncodeString(enc, pend, &av_FCPublish); in SendFCPublish()
1862 enc = AMF_EncodeNumber(enc, pend, ++r->m_numInvokes); in SendFCPublish()
1864 enc = AMF_EncodeString(enc, pend, &r->Link.playpath); in SendFCPublish()
1879 char pbuf[1024], *pend = pbuf + sizeof(pbuf); in SendFCUnpublish() local
1891 enc = AMF_EncodeString(enc, pend, &av_FCUnpublish); in SendFCUnpublish()
1892 enc = AMF_EncodeNumber(enc, pend, ++r->m_numInvokes); in SendFCUnpublish()
1894 enc = AMF_EncodeString(enc, pend, &r->Link.playpath); in SendFCUnpublish()
1911 char pbuf[1024], *pend = pbuf + sizeof(pbuf); in SendPublish() local
1923 enc = AMF_EncodeString(enc, pend, &av_publish); in SendPublish()
1924 enc = AMF_EncodeNumber(enc, pend, ++r->m_numInvokes); in SendPublish()
1926 enc = AMF_EncodeString(enc, pend, &r->Link.playpath); in SendPublish()
1931 enc = AMF_EncodeString(enc, pend, &av_live); in SendPublish()
1946 char pbuf[256], *pend = pbuf + sizeof(pbuf); in SendDeleteStream() local
1958 enc = AMF_EncodeString(enc, pend, &av_deleteStream); in SendDeleteStream()
1959 enc = AMF_EncodeNumber(enc, pend, ++r->m_numInvokes); in SendDeleteStream()
1961 enc = AMF_EncodeNumber(enc, pend, dStreamId); in SendDeleteStream()
1975 char pbuf[256], *pend = pbuf + sizeof(pbuf); in RTMP_SendPause() local
1987 enc = AMF_EncodeString(enc, pend, &av_pause); in RTMP_SendPause()
1988 enc = AMF_EncodeNumber(enc, pend, ++r->m_numInvokes); in RTMP_SendPause()
1990 enc = AMF_EncodeBoolean(enc, pend, DoPause); in RTMP_SendPause()
1991 enc = AMF_EncodeNumber(enc, pend, (double)iTime); in RTMP_SendPause()
2013 char pbuf[256], *pend = pbuf + sizeof(pbuf); in RTMP_SendSeek() local
2025 enc = AMF_EncodeString(enc, pend, &av_seek); in RTMP_SendSeek()
2026 enc = AMF_EncodeNumber(enc, pend, ++r->m_numInvokes); in RTMP_SendSeek()
2028 enc = AMF_EncodeNumber(enc, pend, (double)iTime); in RTMP_SendSeek()
2042 char pbuf[256], *pend = pbuf + sizeof(pbuf); in RTMP_SendServerBW() local
2054 AMF_EncodeInt32(packet.m_body, pend, r->m_nServerBW); in RTMP_SendServerBW()
2062 char pbuf[256], *pend = pbuf + sizeof(pbuf); in RTMP_SendClientBW() local
2074 AMF_EncodeInt32(packet.m_body, pend, r->m_nClientBW); in RTMP_SendClientBW()
2083 char pbuf[256], *pend = pbuf + sizeof(pbuf); in SendBytesReceived() local
2095 AMF_EncodeInt32(packet.m_body, pend, r->m_nBytesIn); /* hard coded for now */ in SendBytesReceived()
2108 char pbuf[256], *pend = pbuf + sizeof(pbuf); in SendCheckBW() local
2120 enc = AMF_EncodeString(enc, pend, &av__checkbw); in SendCheckBW()
2121 enc = AMF_EncodeNumber(enc, pend, ++r->m_numInvokes); in SendCheckBW()
2136 char pbuf[256], *pend = pbuf + sizeof(pbuf); in SendCheckBWResult() local
2148 enc = AMF_EncodeString(enc, pend, &av__result); in SendCheckBWResult()
2149 enc = AMF_EncodeNumber(enc, pend, txn); in SendCheckBWResult()
2151 enc = AMF_EncodeNumber(enc, pend, (double)r->m_nBWCheckCounter++); in SendCheckBWResult()
2165 char pbuf[256], *pend = pbuf + sizeof(pbuf); in SendPong() local
2177 enc = AMF_EncodeString(enc, pend, &av_pong); in SendPong()
2178 enc = AMF_EncodeNumber(enc, pend, txn); in SendPong()
2192 char pbuf[1024], *pend = pbuf + sizeof(pbuf); in SendPlay() local
2204 enc = AMF_EncodeString(enc, pend, &av_play); in SendPlay()
2205 enc = AMF_EncodeNumber(enc, pend, ++r->m_numInvokes); in SendPlay()
2211 enc = AMF_EncodeString(enc, pend, &r->Link.playpath); in SendPlay()
2224 enc = AMF_EncodeNumber(enc, pend, -1000.0); in SendPlay()
2228 enc = AMF_EncodeNumber(enc, pend, r->Link.seekTime); /* resume from here */ in SendPlay()
2230 …enc = AMF_EncodeNumber(enc, pend, 0.0); /*-2000.0);*/ /* recorded as default, -2000.0 is not relia… in SendPlay()
2243 enc = AMF_EncodeNumber(enc, pend, r->Link.stopTime - r->Link.seekTime); in SendPlay()
2260 char pbuf[1024], *pend = pbuf + sizeof(pbuf); in SendPlaylist() local
2272 enc = AMF_EncodeString(enc, pend, &av_set_playlist); in SendPlaylist()
2273 enc = AMF_EncodeNumber(enc, pend, 0); in SendPlaylist()
2280 enc = AMF_EncodeNamedString(enc, pend, &av_0, &r->Link.playpath); in SendPlaylist()
2283 if (enc + 3 >= pend) in SendPlaylist()
2298 char pbuf[1024], *pend = pbuf + sizeof(pbuf); in SendSecureTokenResponse() local
2310 enc = AMF_EncodeString(enc, pend, &av_secureTokenResponse); in SendSecureTokenResponse()
2311 enc = AMF_EncodeNumber(enc, pend, 0.0); in SendSecureTokenResponse()
2313 enc = AMF_EncodeString(enc, pend, resp); in SendSecureTokenResponse()
2342 char pbuf[256], *pend = pbuf + sizeof(pbuf); in RTMP_SendCtrl() local
2366 buf = AMF_EncodeInt16(buf, pend, nType); in RTMP_SendCtrl()
2383 buf = AMF_EncodeInt32(buf, pend, nObject); in RTMP_SendCtrl()
2386 buf = AMF_EncodeInt32(buf, pend, nTime); in RTMP_SendCtrl()
4510 char *ptr, *pend; in Read_1_Packet() local
4817 pend = ptr + size + 4; in Read_1_Packet()
4832 ptr = AMF_EncodeInt24(ptr, pend, nPacketLen); in Read_1_Packet()
4853 ptr = AMF_EncodeInt24(ptr, pend, nTimeStamp); in Read_1_Packet()
4858 ptr = AMF_EncodeInt24(ptr, pend, 0); in Read_1_Packet()
4885 AMF_EncodeInt24(ptr+pos+4, pend, nTimeStamp); in Read_1_Packet()
4907 AMF_EncodeInt32(ptr + pos + 11 + dataSize, pend, in Read_1_Packet()
4933 AMF_EncodeInt32(ptr + pos + 11 + dataSize, pend, in Read_1_Packet()
4946 AMF_EncodeInt32(ptr, pend, prevTagSize); in Read_1_Packet()
5100 char *pend, *enc; in RTMP_Write() local
5149 pend = enc + pkt->m_nBodySize; in RTMP_Write()
5152 enc = AMF_EncodeString(enc, pend, &av_setDataFrame); in RTMP_Write()