Lines Matching refs:enc
1583 char *enc; in SendConnectPacket() local
1596 enc = packet.m_body; in SendConnectPacket()
1597 enc = AMF_EncodeString(enc, pend, &av_connect); in SendConnectPacket()
1598 enc = AMF_EncodeNumber(enc, pend, ++r->m_numInvokes); in SendConnectPacket()
1599 *enc++ = AMF_OBJECT; in SendConnectPacket()
1601 enc = AMF_EncodeNamedString(enc, pend, &av_app, &r->Link.app); in SendConnectPacket()
1602 if (!enc) in SendConnectPacket()
1606 enc = AMF_EncodeNamedString(enc, pend, &av_type, &av_nonprivate); in SendConnectPacket()
1607 if (!enc) in SendConnectPacket()
1612 enc = AMF_EncodeNamedString(enc, pend, &av_flashVer, &r->Link.flashVer); in SendConnectPacket()
1613 if (!enc) in SendConnectPacket()
1618 enc = AMF_EncodeNamedString(enc, pend, &av_swfUrl, &r->Link.swfUrl); in SendConnectPacket()
1619 if (!enc) in SendConnectPacket()
1624 enc = AMF_EncodeNamedString(enc, pend, &av_tcUrl, &r->Link.tcUrl); in SendConnectPacket()
1625 if (!enc) in SendConnectPacket()
1630 enc = AMF_EncodeNamedBoolean(enc, pend, &av_fpad, FALSE); in SendConnectPacket()
1631 if (!enc) in SendConnectPacket()
1633 enc = AMF_EncodeNamedNumber(enc, pend, &av_capabilities, 15.0); in SendConnectPacket()
1634 if (!enc) in SendConnectPacket()
1636 enc = AMF_EncodeNamedNumber(enc, pend, &av_audioCodecs, r->m_fAudioCodecs); in SendConnectPacket()
1637 if (!enc) in SendConnectPacket()
1639 enc = AMF_EncodeNamedNumber(enc, pend, &av_videoCodecs, r->m_fVideoCodecs); in SendConnectPacket()
1640 if (!enc) in SendConnectPacket()
1642 enc = AMF_EncodeNamedNumber(enc, pend, &av_videoFunction, 1.0); in SendConnectPacket()
1643 if (!enc) in SendConnectPacket()
1647 enc = AMF_EncodeNamedString(enc, pend, &av_pageUrl, &r->Link.pageUrl); in SendConnectPacket()
1648 if (!enc) in SendConnectPacket()
1654 enc = AMF_EncodeNamedNumber(enc, pend, &av_objectEncoding, r->m_fEncoding); in SendConnectPacket()
1655 if (!enc) in SendConnectPacket()
1658 if (enc + 3 >= pend) in SendConnectPacket()
1660 *enc++ = 0; in SendConnectPacket()
1661 *enc++ = 0; /* end of object - 0x00 0x00 0x09 */ in SendConnectPacket()
1662 *enc++ = AMF_OBJECT_END; in SendConnectPacket()
1667 enc = AMF_EncodeBoolean(enc, pend, r->Link.lFlags & RTMP_LF_AUTH); in SendConnectPacket()
1668 if (!enc) in SendConnectPacket()
1670 enc = AMF_EncodeString(enc, pend, &r->Link.auth); in SendConnectPacket()
1671 if (!enc) in SendConnectPacket()
1679 enc = AMFProp_Encode(&r->Link.extras.o_props[i], enc, pend); in SendConnectPacket()
1680 if (!enc) in SendConnectPacket()
1684 packet.m_nBodySize = enc - packet.m_body; in SendConnectPacket()
1697 char *enc;
1707 enc = packet.m_body;
1708 enc = AMF_EncodeString(enc, pend, &av_bgHasStream);
1709 enc = AMF_EncodeNumber(enc, pend, dId);
1710 *enc++ = AMF_NULL;
1712 enc = AMF_EncodeString(enc, pend, playpath);
1713 if (enc == NULL)
1716 packet.m_nBodySize = enc - packet.m_body;
1729 char *enc; in RTMP_SendCreateStream() local
1739 enc = packet.m_body; in RTMP_SendCreateStream()
1740 enc = AMF_EncodeString(enc, pend, &av_createStream); in RTMP_SendCreateStream()
1741 enc = AMF_EncodeNumber(enc, pend, ++r->m_numInvokes); in RTMP_SendCreateStream()
1742 *enc++ = AMF_NULL; /* NULL */ in RTMP_SendCreateStream()
1744 packet.m_nBodySize = enc - packet.m_body; in RTMP_SendCreateStream()
1756 char *enc; in SendFCSubscribe() local
1766 enc = packet.m_body; in SendFCSubscribe()
1767 enc = AMF_EncodeString(enc, pend, &av_FCSubscribe); in SendFCSubscribe()
1768 enc = AMF_EncodeNumber(enc, pend, ++r->m_numInvokes); in SendFCSubscribe()
1769 *enc++ = AMF_NULL; in SendFCSubscribe()
1770 enc = AMF_EncodeString(enc, pend, subscribepath); in SendFCSubscribe()
1772 if (!enc) in SendFCSubscribe()
1775 packet.m_nBodySize = enc - packet.m_body; in SendFCSubscribe()
1788 char *enc; in SendUsherToken() local
1798 enc = packet.m_body; in SendUsherToken()
1799 enc = AMF_EncodeString(enc, pend, &av_NetStream_Authenticate_UsherToken); in SendUsherToken()
1800 enc = AMF_EncodeNumber(enc, pend, ++r->m_numInvokes); in SendUsherToken()
1801 *enc++ = AMF_NULL; in SendUsherToken()
1802 enc = AMF_EncodeString(enc, pend, usherToken); in SendUsherToken()
1804 if (!enc) in SendUsherToken()
1807 packet.m_nBodySize = enc - packet.m_body; in SendUsherToken()
1820 char *enc; in SendReleaseStream() local
1830 enc = packet.m_body; in SendReleaseStream()
1831 enc = AMF_EncodeString(enc, pend, &av_releaseStream); in SendReleaseStream()
1832 enc = AMF_EncodeNumber(enc, pend, ++r->m_numInvokes); in SendReleaseStream()
1833 *enc++ = AMF_NULL; in SendReleaseStream()
1834 enc = AMF_EncodeString(enc, pend, &r->Link.playpath); in SendReleaseStream()
1835 if (!enc) in SendReleaseStream()
1838 packet.m_nBodySize = enc - packet.m_body; in SendReleaseStream()
1850 char *enc; in SendFCPublish() local
1860 enc = packet.m_body; in SendFCPublish()
1861 enc = AMF_EncodeString(enc, pend, &av_FCPublish); in SendFCPublish()
1862 enc = AMF_EncodeNumber(enc, pend, ++r->m_numInvokes); in SendFCPublish()
1863 *enc++ = AMF_NULL; in SendFCPublish()
1864 enc = AMF_EncodeString(enc, pend, &r->Link.playpath); in SendFCPublish()
1865 if (!enc) in SendFCPublish()
1868 packet.m_nBodySize = enc - packet.m_body; in SendFCPublish()
1880 char *enc; in SendFCUnpublish() local
1890 enc = packet.m_body; in SendFCUnpublish()
1891 enc = AMF_EncodeString(enc, pend, &av_FCUnpublish); in SendFCUnpublish()
1892 enc = AMF_EncodeNumber(enc, pend, ++r->m_numInvokes); in SendFCUnpublish()
1893 *enc++ = AMF_NULL; in SendFCUnpublish()
1894 enc = AMF_EncodeString(enc, pend, &r->Link.playpath); in SendFCUnpublish()
1895 if (!enc) in SendFCUnpublish()
1898 packet.m_nBodySize = enc - packet.m_body; in SendFCUnpublish()
1912 char *enc; in SendPublish() local
1922 enc = packet.m_body; in SendPublish()
1923 enc = AMF_EncodeString(enc, pend, &av_publish); in SendPublish()
1924 enc = AMF_EncodeNumber(enc, pend, ++r->m_numInvokes); in SendPublish()
1925 *enc++ = AMF_NULL; in SendPublish()
1926 enc = AMF_EncodeString(enc, pend, &r->Link.playpath); in SendPublish()
1927 if (!enc) in SendPublish()
1931 enc = AMF_EncodeString(enc, pend, &av_live); in SendPublish()
1932 if (!enc) in SendPublish()
1935 packet.m_nBodySize = enc - packet.m_body; in SendPublish()
1947 char *enc; in SendDeleteStream() local
1957 enc = packet.m_body; in SendDeleteStream()
1958 enc = AMF_EncodeString(enc, pend, &av_deleteStream); in SendDeleteStream()
1959 enc = AMF_EncodeNumber(enc, pend, ++r->m_numInvokes); in SendDeleteStream()
1960 *enc++ = AMF_NULL; in SendDeleteStream()
1961 enc = AMF_EncodeNumber(enc, pend, dStreamId); in SendDeleteStream()
1963 packet.m_nBodySize = enc - packet.m_body; in SendDeleteStream()
1976 char *enc; in RTMP_SendPause() local
1986 enc = packet.m_body; in RTMP_SendPause()
1987 enc = AMF_EncodeString(enc, pend, &av_pause); in RTMP_SendPause()
1988 enc = AMF_EncodeNumber(enc, pend, ++r->m_numInvokes); in RTMP_SendPause()
1989 *enc++ = AMF_NULL; in RTMP_SendPause()
1990 enc = AMF_EncodeBoolean(enc, pend, DoPause); in RTMP_SendPause()
1991 enc = AMF_EncodeNumber(enc, pend, (double)iTime); in RTMP_SendPause()
1993 packet.m_nBodySize = enc - packet.m_body; in RTMP_SendPause()
2014 char *enc; in RTMP_SendSeek() local
2024 enc = packet.m_body; in RTMP_SendSeek()
2025 enc = AMF_EncodeString(enc, pend, &av_seek); in RTMP_SendSeek()
2026 enc = AMF_EncodeNumber(enc, pend, ++r->m_numInvokes); in RTMP_SendSeek()
2027 *enc++ = AMF_NULL; in RTMP_SendSeek()
2028 enc = AMF_EncodeNumber(enc, pend, (double)iTime); in RTMP_SendSeek()
2030 packet.m_nBodySize = enc - packet.m_body; in RTMP_SendSeek()
2109 char *enc; in SendCheckBW() local
2119 enc = packet.m_body; in SendCheckBW()
2120 enc = AMF_EncodeString(enc, pend, &av__checkbw); in SendCheckBW()
2121 enc = AMF_EncodeNumber(enc, pend, ++r->m_numInvokes); in SendCheckBW()
2122 *enc++ = AMF_NULL; in SendCheckBW()
2124 packet.m_nBodySize = enc - packet.m_body; in SendCheckBW()
2137 char *enc; in SendCheckBWResult() local
2147 enc = packet.m_body; in SendCheckBWResult()
2148 enc = AMF_EncodeString(enc, pend, &av__result); in SendCheckBWResult()
2149 enc = AMF_EncodeNumber(enc, pend, txn); in SendCheckBWResult()
2150 *enc++ = AMF_NULL; in SendCheckBWResult()
2151 enc = AMF_EncodeNumber(enc, pend, (double)r->m_nBWCheckCounter++); in SendCheckBWResult()
2153 packet.m_nBodySize = enc - packet.m_body; in SendCheckBWResult()
2166 char *enc; in SendPong() local
2176 enc = packet.m_body; in SendPong()
2177 enc = AMF_EncodeString(enc, pend, &av_pong); in SendPong()
2178 enc = AMF_EncodeNumber(enc, pend, txn); in SendPong()
2179 *enc++ = AMF_NULL; in SendPong()
2181 packet.m_nBodySize = enc - packet.m_body; in SendPong()
2193 char *enc; in SendPlay() local
2203 enc = packet.m_body; in SendPlay()
2204 enc = AMF_EncodeString(enc, pend, &av_play); in SendPlay()
2205 enc = AMF_EncodeNumber(enc, pend, ++r->m_numInvokes); in SendPlay()
2206 *enc++ = AMF_NULL; in SendPlay()
2211 enc = AMF_EncodeString(enc, pend, &r->Link.playpath); in SendPlay()
2212 if (!enc) 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()
2232 if (!enc) in SendPlay()
2243 enc = AMF_EncodeNumber(enc, pend, r->Link.stopTime - r->Link.seekTime); in SendPlay()
2244 if (!enc) in SendPlay()
2248 packet.m_nBodySize = enc - packet.m_body; in SendPlay()
2261 char *enc; in SendPlaylist() local
2271 enc = packet.m_body; in SendPlaylist()
2272 enc = AMF_EncodeString(enc, pend, &av_set_playlist); in SendPlaylist()
2273 enc = AMF_EncodeNumber(enc, pend, 0); in SendPlaylist()
2274 *enc++ = AMF_NULL; in SendPlaylist()
2275 *enc++ = AMF_ECMA_ARRAY; in SendPlaylist()
2276 *enc++ = 0; in SendPlaylist()
2277 *enc++ = 0; in SendPlaylist()
2278 *enc++ = 0; in SendPlaylist()
2279 *enc++ = AMF_OBJECT; in SendPlaylist()
2280 enc = AMF_EncodeNamedString(enc, pend, &av_0, &r->Link.playpath); in SendPlaylist()
2281 if (!enc) in SendPlaylist()
2283 if (enc + 3 >= pend) in SendPlaylist()
2285 *enc++ = 0; in SendPlaylist()
2286 *enc++ = 0; in SendPlaylist()
2287 *enc++ = AMF_OBJECT_END; in SendPlaylist()
2289 packet.m_nBodySize = enc - packet.m_body; in SendPlaylist()
2299 char *enc; in SendSecureTokenResponse() local
2309 enc = packet.m_body; in SendSecureTokenResponse()
2310 enc = AMF_EncodeString(enc, pend, &av_secureTokenResponse); in SendSecureTokenResponse()
2311 enc = AMF_EncodeNumber(enc, pend, 0.0); in SendSecureTokenResponse()
2312 *enc++ = AMF_NULL; in SendSecureTokenResponse()
2313 enc = AMF_EncodeString(enc, pend, resp); in SendSecureTokenResponse()
2314 if (!enc) in SendSecureTokenResponse()
2317 packet.m_nBodySize = enc - packet.m_body; in SendSecureTokenResponse()
5100 char *pend, *enc; in RTMP_Write() local
5148 enc = pkt->m_body; in RTMP_Write()
5149 pend = enc + pkt->m_nBodySize; in RTMP_Write()
5152 enc = AMF_EncodeString(enc, pend, &av_setDataFrame); in RTMP_Write()
5153 pkt->m_nBytesRead = enc - pkt->m_body; in RTMP_Write()
5158 enc = pkt->m_body + pkt->m_nBytesRead; in RTMP_Write()
5163 memcpy(enc, buf, num); in RTMP_Write()