Lines Matching refs:m_body
197 p->m_body = ptr + RTMP_MAX_HEADER_SIZE; in RTMPPacket_Alloc()
205 if (p->m_body) in RTMPPacket_Free()
207 free(p->m_body - RTMP_MAX_HEADER_SIZE); in RTMPPacket_Free()
208 p->m_body = NULL; in RTMPPacket_Free()
218 p->m_nBodySize, p->m_body ? (unsigned char)p->m_body[0] : 0); in RTMPPacket_Dump()
1303 int nRes = obj.Decode(packet.m_body+1, packet.m_nBodySize-1); in RTMP_ClientPacket()
1312 if (HandleInvoke(r, packet->m_body + 1, packet->m_nBodySize - 1) == 1) in RTMP_ClientPacket()
1320 if (HandleMetadata(r, packet->m_body, packet->m_nBodySize)) in RTMP_ClientPacket()
1335 if (HandleInvoke(r, packet->m_body, packet->m_nBodySize) == 1) in RTMP_ClientPacket()
1347 …uint32_t dataSize = AMF_DecodeInt24(packet->m_body + pos + 1); /* size without header (11) and pre… in RTMP_ClientPacket()
1354 if (packet->m_body[pos] == 0x12) in RTMP_ClientPacket()
1356 HandleMetadata(r, packet->m_body + pos + 11, dataSize); in RTMP_ClientPacket()
1358 else if (packet->m_body[pos] == 8 || packet->m_body[pos] == 9) in RTMP_ClientPacket()
1360 nTimeStamp = AMF_DecodeInt24(packet->m_body + pos + 4); in RTMP_ClientPacket()
1361 nTimeStamp |= (packet->m_body[pos + 7] << 24); in RTMP_ClientPacket()
1377 RTMP_LogHex(RTMP_LOGDEBUG, packet->m_body, packet->m_nBodySize); in RTMP_ClientPacket()
1594 packet.m_body = pbuf + RTMP_MAX_HEADER_SIZE; in SendConnectPacket()
1596 enc = packet.m_body; in SendConnectPacket()
1684 packet.m_nBodySize = enc - packet.m_body; in SendConnectPacket()
1705 packet.m_body = pbuf + RTMP_MAX_HEADER_SIZE;
1707 enc = packet.m_body;
1716 packet.m_nBodySize = enc - packet.m_body;
1737 packet.m_body = pbuf + RTMP_MAX_HEADER_SIZE; in RTMP_SendCreateStream()
1739 enc = packet.m_body; in RTMP_SendCreateStream()
1744 packet.m_nBodySize = enc - packet.m_body; in RTMP_SendCreateStream()
1763 packet.m_body = pbuf + RTMP_MAX_HEADER_SIZE; in SendFCSubscribe()
1766 enc = packet.m_body; in SendFCSubscribe()
1775 packet.m_nBodySize = enc - packet.m_body; in SendFCSubscribe()
1795 packet.m_body = pbuf + RTMP_MAX_HEADER_SIZE; in SendUsherToken()
1798 enc = packet.m_body; in SendUsherToken()
1807 packet.m_nBodySize = enc - packet.m_body; in SendUsherToken()
1828 packet.m_body = pbuf + RTMP_MAX_HEADER_SIZE; in SendReleaseStream()
1830 enc = packet.m_body; in SendReleaseStream()
1838 packet.m_nBodySize = enc - packet.m_body; in SendReleaseStream()
1858 packet.m_body = pbuf + RTMP_MAX_HEADER_SIZE; in SendFCPublish()
1860 enc = packet.m_body; in SendFCPublish()
1868 packet.m_nBodySize = enc - packet.m_body; in SendFCPublish()
1888 packet.m_body = pbuf + RTMP_MAX_HEADER_SIZE; in SendFCUnpublish()
1890 enc = packet.m_body; in SendFCUnpublish()
1898 packet.m_nBodySize = enc - packet.m_body; in SendFCUnpublish()
1920 packet.m_body = pbuf + RTMP_MAX_HEADER_SIZE; in SendPublish()
1922 enc = packet.m_body; in SendPublish()
1935 packet.m_nBodySize = enc - packet.m_body; in SendPublish()
1955 packet.m_body = pbuf + RTMP_MAX_HEADER_SIZE; in SendDeleteStream()
1957 enc = packet.m_body; in SendDeleteStream()
1963 packet.m_nBodySize = enc - packet.m_body; in SendDeleteStream()
1984 packet.m_body = pbuf + RTMP_MAX_HEADER_SIZE; in RTMP_SendPause()
1986 enc = packet.m_body; in RTMP_SendPause()
1993 packet.m_nBodySize = enc - packet.m_body; in RTMP_SendPause()
2022 packet.m_body = pbuf + RTMP_MAX_HEADER_SIZE; in RTMP_SendSeek()
2024 enc = packet.m_body; in RTMP_SendSeek()
2030 packet.m_nBodySize = enc - packet.m_body; in RTMP_SendSeek()
2050 packet.m_body = pbuf + RTMP_MAX_HEADER_SIZE; in RTMP_SendServerBW()
2054 AMF_EncodeInt32(packet.m_body, pend, r->m_nServerBW); in RTMP_SendServerBW()
2070 packet.m_body = pbuf + RTMP_MAX_HEADER_SIZE; in RTMP_SendClientBW()
2074 AMF_EncodeInt32(packet.m_body, pend, r->m_nClientBW); in RTMP_SendClientBW()
2075 packet.m_body[4] = r->m_nClientBW2; in RTMP_SendClientBW()
2091 packet.m_body = pbuf + RTMP_MAX_HEADER_SIZE; in SendBytesReceived()
2095 AMF_EncodeInt32(packet.m_body, pend, r->m_nBytesIn); /* hard coded for now */ in SendBytesReceived()
2117 packet.m_body = pbuf + RTMP_MAX_HEADER_SIZE; in SendCheckBW()
2119 enc = packet.m_body; in SendCheckBW()
2124 packet.m_nBodySize = enc - packet.m_body; in SendCheckBW()
2145 packet.m_body = pbuf + RTMP_MAX_HEADER_SIZE; in SendCheckBWResult()
2147 enc = packet.m_body; in SendCheckBWResult()
2153 packet.m_nBodySize = enc - packet.m_body; in SendCheckBWResult()
2174 packet.m_body = pbuf + RTMP_MAX_HEADER_SIZE; in SendPong()
2176 enc = packet.m_body; in SendPong()
2181 packet.m_nBodySize = enc - packet.m_body; in SendPong()
2201 packet.m_body = pbuf + RTMP_MAX_HEADER_SIZE; in SendPlay()
2203 enc = packet.m_body; in SendPlay()
2248 packet.m_nBodySize = enc - packet.m_body; in SendPlay()
2269 packet.m_body = pbuf + RTMP_MAX_HEADER_SIZE; in SendPlaylist()
2271 enc = packet.m_body; in SendPlaylist()
2289 packet.m_nBodySize = enc - packet.m_body; in SendPlaylist()
2307 packet.m_body = pbuf + RTMP_MAX_HEADER_SIZE; in SendSecureTokenResponse()
2309 enc = packet.m_body; in SendSecureTokenResponse()
2317 packet.m_nBodySize = enc - packet.m_body; in SendSecureTokenResponse()
2354 packet.m_body = pbuf + RTMP_MAX_HEADER_SIZE; in RTMP_SendCtrl()
2365 buf = packet.m_body; in RTMP_SendCtrl()
2373 RTMP_LogHex(RTMP_LOGDEBUG, (uint8_t *)packet.m_body, packet.m_nBodySize); in RTMP_SendCtrl()
3349 r->m_inChunkSize = AMF_DecodeInt32(packet->m_body); in HandleChangeChunkSize()
3370 if (packet->m_body && packet->m_nBodySize >= 2) in HandleCtrl()
3371 nType = AMF_DecodeInt16(packet->m_body); in HandleCtrl()
3381 tmp = AMF_DecodeInt32(packet->m_body + 2); in HandleCtrl()
3386 tmp = AMF_DecodeInt32(packet->m_body + 2); in HandleCtrl()
3393 tmp = AMF_DecodeInt32(packet->m_body + 2); in HandleCtrl()
3398 tmp = AMF_DecodeInt32(packet->m_body + 2); in HandleCtrl()
3403 tmp = AMF_DecodeInt32(packet->m_body + 2); in HandleCtrl()
3445 tmp = AMF_DecodeInt32(packet->m_body + 2); in HandleCtrl()
3464 tmp = AMF_DecodeInt32(packet->m_body + 2); in HandleCtrl()
3469 tmp = AMF_DecodeInt32(packet->m_body + 2); in HandleCtrl()
3479 if (packet->m_nBodySize > 2 && packet->m_body[2] > 0x01) in HandleCtrl()
3483 __FUNCTION__, packet->m_body[2]); in HandleCtrl()
3510 r->m_nServerBW = AMF_DecodeInt32(packet->m_body); in HandleServerBW()
3517 r->m_nClientBW = AMF_DecodeInt32(packet->m_body); in HandleClientBW()
3519 r->m_nClientBW2 = packet->m_body[4]; in HandleClientBW()
3675 if (packet->m_nBodySize > 0 && packet->m_body == NULL) in RTMP_ReadPacket()
3696 packet->m_chunk->c_chunk = packet->m_body + packet->m_nBytesRead; in RTMP_ReadPacket()
3700 if (ReadN(r, packet->m_body + packet->m_nBytesRead, nChunk) != nChunk) in RTMP_ReadPacket()
3707 RTMP_LogHexString(RTMP_LOGDEBUG2, (uint8_t *)packet->m_body + packet->m_nBytesRead, nChunk); in RTMP_ReadPacket()
3730 r->m_vecChannelsIn[packet->m_nChannel]->m_body = NULL; in RTMP_ReadPacket()
3736 packet->m_body = NULL; /* so it won't be erased on free */ in RTMP_ReadPacket()
3949 if (packet->m_body) in RTMP_SendPacket()
3951 header = packet->m_body - nSize; in RTMP_SendPacket()
3952 hend = packet->m_body; in RTMP_SendPacket()
4017 buffer = packet->m_body; in RTMP_SendPacket()
4102 ptr = packet->m_body + 1; in RTMP_SendPacket()
4517 char *packetBody = packet.m_body; in Read_1_Packet()
5148 enc = pkt->m_body; 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()