RTMP 157 cygnal/cgi-bin/oflaDemo/oflaDemo.cpp RTMP::HEADER_12, error->allocated(), RTMP 158 cygnal/cgi-bin/oflaDemo/oflaDemo.cpp RTMP::INVOKE, RTMPMsg::FROM_SERVER); RTMP 507 cygnal/cgi-bin/oflaDemo/oflaDemo.cpp RTMP::HEADER_8, total_size, RTMP 508 cygnal/cgi-bin/oflaDemo/oflaDemo.cpp RTMP::INVOKE, RTMPMsg::FROM_SERVER); RTMP 573 cygnal/cygnal.cpp rtmp_data->protocol = Network::RTMP; RTMP 899 cygnal/cygnal.cpp if (args->protocol == Network::RTMP) { RTMP 927 cygnal/cygnal.cpp hand->addClient(args->netfd, Network::RTMP); RTMP 1093 cygnal/cygnal.cpp case Network::RTMP: RTMP 116 cygnal/handler.cpp case Network::RTMP: RTMP 203 cygnal/handler.cpp case Network::RTMP: RTMP 237 cygnal/handler.cpp case Network::RTMP: RTMP 170 cygnal/libnet/rtmp.cpp RTMP::headerSize(boost::uint8_t header) RTMP 192 cygnal/libnet/rtmp.cpp RTMP::RTMP() RTMP 214 cygnal/libnet/rtmp.cpp _type[i] = RTMP::NONE; RTMP 218 cygnal/libnet/rtmp.cpp RTMP::~RTMP() RTMP 229 cygnal/libnet/rtmp.cpp RTMP::addProperty(cygnal::Element &el) RTMP 236 cygnal/libnet/rtmp.cpp RTMP::addProperty(char *name, cygnal::Element &el) RTMP 244 cygnal/libnet/rtmp.cpp RTMP::getProperty(const std::string &name) RTMP 256 cygnal/libnet/rtmp.cpp boost::shared_ptr<RTMP::rtmp_head_t> RTMP 257 cygnal/libnet/rtmp.cpp RTMP::decodeHeader(cygnal::Buffer &buf) RTMP 263 cygnal/libnet/rtmp.cpp boost::shared_ptr<RTMP::rtmp_head_t> RTMP 264 cygnal/libnet/rtmp.cpp RTMP::decodeHeader(boost::uint8_t *in) RTMP 268 cygnal/libnet/rtmp.cpp boost::shared_ptr<RTMP::rtmp_head_t> head(new RTMP::rtmp_head_t); RTMP 338 cygnal/libnet/rtmp.cpp if (head->type <= RTMP::INVOKE ) { RTMP 345 cygnal/libnet/rtmp.cpp if (_type[head->channel] <= RTMP::FLV_DATA) { RTMP 376 cygnal/libnet/rtmp.cpp RTMP::encodeHeader(int amf_index, rtmp_headersize_e head_size) RTMP 392 cygnal/libnet/rtmp.cpp RTMP::encodeHeader(int amf_index, rtmp_headersize_e head_size, RTMP 440 cygnal/libnet/rtmp.cpp if (head_size == HEADER_12 && type != RTMP::USER) { RTMP 441 cygnal/libnet/rtmp.cpp if (type != RTMP::AUDIO_DATA && type != RTMP::VIDEO_DATA) { RTMP 466 cygnal/libnet/rtmp.cpp RTMP::packetRead(cygnal::Buffer &buf) RTMP 484 cygnal/libnet/rtmp.cpp RTMP::rtmp_head_t *rthead = decodeHeader(ptr); RTMP 550 cygnal/libnet/rtmp.cpp RTMP::dump() RTMP 591 cygnal/libnet/rtmp.cpp boost::shared_ptr<RTMP::rtmp_ping_t> RTMP 592 cygnal/libnet/rtmp.cpp RTMP::decodePing(boost::uint8_t *data) RTMP 618 cygnal/libnet/rtmp.cpp boost::shared_ptr<RTMP::rtmp_ping_t> RTMP 619 cygnal/libnet/rtmp.cpp RTMP::decodePing(cygnal::Buffer &buf) RTMP 625 cygnal/libnet/rtmp.cpp boost::shared_ptr<RTMP::user_event_t> RTMP 626 cygnal/libnet/rtmp.cpp RTMP::decodeUserControl(cygnal::Buffer &buf) RTMP 632 cygnal/libnet/rtmp.cpp boost::shared_ptr<RTMP::user_event_t> RTMP 633 cygnal/libnet/rtmp.cpp RTMP::decodeUserControl(boost::uint8_t *data) RTMP 638 cygnal/libnet/rtmp.cpp boost::shared_ptr<user_event_t> user(new RTMP::user_event_t); RTMP 683 cygnal/libnet/rtmp.cpp RTMP::encodeUserControl(user_control_e eventid, boost::uint32_t data) RTMP 729 cygnal/libnet/rtmp.cpp RTMP::decodeMsgBody(boost::uint8_t *data, size_t size) RTMP 796 cygnal/libnet/rtmp.cpp RTMP::decodeMsgBody(cygnal::Buffer &buf) RTMP 806 cygnal/libnet/rtmp.cpp RTMP::encodeChunkSize(int size) RTMP 818 cygnal/libnet/rtmp.cpp RTMP::decodeChunkSize() RTMP 827 cygnal/libnet/rtmp.cpp RTMP::encodeBytesRead() RTMP 835 cygnal/libnet/rtmp.cpp RTMP::decodeBytesRead() RTMP 842 cygnal/libnet/rtmp.cpp RTMP::encodeServer() RTMP 850 cygnal/libnet/rtmp.cpp RTMP::decodeServer() RTMP 857 cygnal/libnet/rtmp.cpp RTMP::encodeClient() RTMP 865 cygnal/libnet/rtmp.cpp RTMP::decodeClient() RTMP 872 cygnal/libnet/rtmp.cpp RTMP::encodeAudioData() RTMP 880 cygnal/libnet/rtmp.cpp RTMP::decodeAudioData() RTMP 887 cygnal/libnet/rtmp.cpp RTMP::encodeVideoData() RTMP 895 cygnal/libnet/rtmp.cpp RTMP::decodeVideoData() RTMP 902 cygnal/libnet/rtmp.cpp RTMP::encodeNotify() RTMP 910 cygnal/libnet/rtmp.cpp RTMP::decodeNotify() RTMP 917 cygnal/libnet/rtmp.cpp RTMP::encodeSharedObj() RTMP 925 cygnal/libnet/rtmp.cpp RTMP::decodeSharedObj() RTMP 932 cygnal/libnet/rtmp.cpp RTMP::encodeInvoke() RTMP 939 cygnal/libnet/rtmp.cpp RTMP::decodeInvoke() RTMP 950 cygnal/libnet/rtmp.cpp RTMP::sendMsg(int channel, rtmp_headersize_e head_size, RTMP 959 cygnal/libnet/rtmp.cpp RTMP::sendMsg(int fd, int channel, rtmp_headersize_e head_size, RTMP 969 cygnal/libnet/rtmp.cpp RTMP::sendMsg(int channel, rtmp_headersize_e head_size, RTMP 978 cygnal/libnet/rtmp.cpp RTMP::sendMsg(int fd, int channel, rtmp_headersize_e head_size, RTMP 1010 cygnal/libnet/rtmp.cpp boost::shared_ptr<cygnal::Buffer> cont_head = encodeHeader(channel, RTMP::HEADER_1); RTMP 1096 cygnal/libnet/rtmp.cpp RTMP::sendRecvMsg(cygnal::Buffer &bufin) RTMP 1110 cygnal/libnet/rtmp.cpp RTMP::rtmp_head_t *rthead = 0; RTMP 1120 cygnal/libnet/rtmp.cpp RTMP::queues_t *que = split(buf); RTMP 1136 cygnal/libnet/rtmp.cpp if (rthead->type <= RTMP::FLV_DATA) { RTMP 1153 cygnal/libnet/rtmp.cpp RTMP::rtmp_ping_t *ping = decodePing(ptr); RTMP 1249 cygnal/libnet/rtmp.cpp RTMP::recvMsg() RTMP 1260 cygnal/libnet/rtmp.cpp RTMP::recvMsg(int fd) RTMP 1309 cygnal/libnet/rtmp.cpp boost::shared_ptr<RTMP::queues_t> RTMP 1310 cygnal/libnet/rtmp.cpp RTMP::split(cygnal::Buffer &buf) RTMP 1316 cygnal/libnet/rtmp.cpp boost::shared_ptr<RTMP::queues_t> RTMP 1317 cygnal/libnet/rtmp.cpp RTMP::split(boost::uint8_t *data, size_t size) RTMP 1325 cygnal/libnet/rtmp.cpp boost::shared_ptr<RTMP::queues_t> channels(new RTMP::queues_t); RTMP 143 cygnal/libnet/rtmp.h class DSOEXPORT RTMP : public Network RTMP 322 cygnal/libnet/rtmp.h RTMP(); RTMP 323 cygnal/libnet/rtmp.h virtual ~RTMP(); RTMP 306 cygnal/libnet/rtmp_client.cpp RTMP::HEADER_12, ncbuf->allocated(), RTMP 307 cygnal/libnet/rtmp_client.cpp RTMP::INVOKE, RTMPMsg::FROM_CLIENT); RTMP 342 cygnal/libnet/rtmp_client.cpp boost::shared_ptr<RTMP::rtmp_head_t> rthead; RTMP 343 cygnal/libnet/rtmp_client.cpp boost::shared_ptr<RTMP::queues_t> que; RTMP 565 cygnal/libnet/rtmp_client.cpp *handshake += RTMP::getTime(); RTMP 740 cygnal/libnet/rtmp_client.cpp boost::shared_ptr<RTMP::rtmp_head_t> rthead; RTMP 741 cygnal/libnet/rtmp_client.cpp boost::shared_ptr<RTMP::queues_t> que = split(pktstart, response->allocated()-1); RTMP 770 cygnal/libnet/rtmp_client.cpp case RTMP::NONE: RTMP 773 cygnal/libnet/rtmp_client.cpp case RTMP::CHUNK_SIZE: RTMP 776 cygnal/libnet/rtmp_client.cpp case RTMP::ABORT: RTMP 779 cygnal/libnet/rtmp_client.cpp case RTMP::BYTES_READ: RTMP 782 cygnal/libnet/rtmp_client.cpp case RTMP::USER: RTMP 784 cygnal/libnet/rtmp_client.cpp boost::shared_ptr<RTMP::rtmp_ping_t> ping = decodePing(ptr->reference() + rthead->head_size); RTMP 788 cygnal/libnet/rtmp_client.cpp case RTMP::WINDOW_SIZE: RTMP 791 cygnal/libnet/rtmp_client.cpp case RTMP::SET_BANDWITH: RTMP 794 cygnal/libnet/rtmp_client.cpp case RTMP::ROUTE: RTMP 797 cygnal/libnet/rtmp_client.cpp case RTMP::AUDIO_DATA: RTMP 805 cygnal/libnet/rtmp_client.cpp case RTMP::VIDEO_DATA: RTMP 813 cygnal/libnet/rtmp_client.cpp case RTMP::SHARED_OBJ: RTMP 816 cygnal/libnet/rtmp_client.cpp case RTMP::AMF3_NOTIFY: RTMP 819 cygnal/libnet/rtmp_client.cpp case RTMP::AMF3_SHARED_OBJ: RTMP 822 cygnal/libnet/rtmp_client.cpp case RTMP::AMF3_INVOKE: RTMP 825 cygnal/libnet/rtmp_client.cpp case RTMP::NOTIFY: RTMP 828 cygnal/libnet/rtmp_client.cpp case RTMP::INVOKE: RTMP 836 cygnal/libnet/rtmp_client.cpp case RTMP::FLV_DATA: RTMP 40 cygnal/libnet/rtmp_client.h class DSOEXPORT RTMPClient : public RTMP RTMP 107 cygnal/rtmp_server.cpp RTMP::setTimeout(10); RTMP 121 cygnal/rtmp_server.cpp boost::shared_ptr<cygnal::Buffer> handshake1 = RTMP::recvMsg(fd); RTMP 136 cygnal/rtmp_server.cpp boost::shared_ptr<cygnal::Buffer> handshake2 = RTMP::recvMsg(fd); RTMP 157 cygnal/rtmp_server.cpp boost::shared_ptr<RTMP::rtmp_head_t> qhead = RTMP::decodeHeader(pkt->reference()); RTMP 200 cygnal/rtmp_server.cpp _netconnect = RTMP::decodeMsgBody(newptr->begin(), qhead->bodysize); RTMP 230 cygnal/rtmp_server.cpp if (RTMP::sendMsg(fd, qhead->channel, RTMP::HEADER_8, RTMP 231 cygnal/rtmp_server.cpp bwdone->size(), RTMP::INVOKE, RTMPMsg::FROM_SERVER, *bwdone)) { RTMP 245 cygnal/rtmp_server.cpp if (RTMP::sendMsg(fd, RTMP_SYSTEM_CHANNEL, RTMP::HEADER_12, RTMP 246 cygnal/rtmp_server.cpp winsize->size(), RTMP::WINDOW_SIZE, RTMPMsg::FROM_CLIENT, *winsize)) { RTMP 256 cygnal/rtmp_server.cpp encodePing(RTMP::PING_RESET, 0); RTMP 257 cygnal/rtmp_server.cpp if (RTMP::sendMsg(fd, RTMP_SYSTEM_CHANNEL, RTMP::HEADER_8, RTMP 258 cygnal/rtmp_server.cpp ping_reset->size(), RTMP::USER, RTMPMsg::FROM_SERVER, *ping_reset)) { RTMP 271 cygnal/rtmp_server.cpp if (RTMP::sendMsg(fd, 3, RTMP::HEADER_8, response->allocated(), RTMP 272 cygnal/rtmp_server.cpp RTMP::INVOKE, RTMPMsg::FROM_SERVER, *response)) { RTMP 319 cygnal/rtmp_server.cpp timestamp = RTMP::getTime(); RTMP 921 cygnal/rtmp_server.cpp boost::uint8_t byte = static_cast<boost::uint8_t>(RTMP::WINDOW_SIZE & 0x000000ff); RTMP 1277 cygnal/rtmp_server.cpp if (sendMsg(fd, getChannel(), RTMP::HEADER_12, filesize, RTMP 1278 cygnal/rtmp_server.cpp RTMP::NOTIFY, RTMPMsg::FROM_SERVER, filestream->get(), RTMP 1287 cygnal/rtmp_server.cpp if (sendMsg(fd, getChannel(), RTMP::HEADER_4, filesize, RTMP 1288 cygnal/rtmp_server.cpp RTMP::NOTIFY, RTMPMsg::FROM_SERVER, filestream->get(), RTMP 1297 cygnal/rtmp_server.cpp if (sendMsg(fd, getChannel(), RTMP::HEADER_12, filesize, RTMP 1298 cygnal/rtmp_server.cpp RTMP::NOTIFY, RTMPMsg::FROM_SERVER, filestream->get()+24, RTMP 1390 cygnal/rtmp_server.cpp RTMP::HEADER_8, 4096, RTMP 1391 cygnal/rtmp_server.cpp RTMP::NOTIFY, RTMPMsg::FROM_SERVER, RTMP 1414 cygnal/rtmp_server.cpp boost::shared_ptr<RTMP::queues_t> que = rtmp->split(*pkt); RTMP 1419 cygnal/rtmp_server.cpp boost::shared_ptr<RTMP::rtmp_head_t> qhead; RTMP 1432 cygnal/rtmp_server.cpp if (qhead->type == RTMP::USER) { RTMP 1433 cygnal/rtmp_server.cpp boost::shared_ptr<RTMP::user_event_t> user RTMP 1436 cygnal/rtmp_server.cpp case RTMP::STREAM_START: RTMP 1439 cygnal/rtmp_server.cpp case RTMP::STREAM_EOF: RTMP 1442 cygnal/rtmp_server.cpp case RTMP::STREAM_NODATA: RTMP 1445 cygnal/rtmp_server.cpp case RTMP::STREAM_BUFFER: RTMP 1448 cygnal/rtmp_server.cpp case RTMP::STREAM_LIVE: RTMP 1451 cygnal/rtmp_server.cpp case RTMP::STREAM_PING: RTMP 1453 cygnal/rtmp_server.cpp boost::shared_ptr<RTMP::rtmp_ping_t> ping RTMP 1459 cygnal/rtmp_server.cpp case RTMP::STREAM_PONG: RTMP 1465 cygnal/rtmp_server.cpp } else if (qhead->type == RTMP::AUDIO_DATA) { RTMP 1467 cygnal/rtmp_server.cpp } else if (qhead->type == RTMP::VIDEO_DATA) { RTMP 1469 cygnal/rtmp_server.cpp } else if (qhead->type == RTMP::WINDOW_SIZE) { RTMP 1478 cygnal/rtmp_server.cpp case RTMP::CHUNK_SIZE: RTMP 1481 cygnal/rtmp_server.cpp case RTMP::BYTES_READ: RTMP 1484 cygnal/rtmp_server.cpp case RTMP::ABORT: RTMP 1485 cygnal/rtmp_server.cpp case RTMP::USER: RTMP 1489 cygnal/rtmp_server.cpp case RTMP::WINDOW_SIZE: RTMP 1492 cygnal/rtmp_server.cpp case RTMP::SET_BANDWITH: RTMP 1495 cygnal/rtmp_server.cpp case RTMP::ROUTE: RTMP 1496 cygnal/rtmp_server.cpp case RTMP::AUDIO_DATA: RTMP 1497 cygnal/rtmp_server.cpp case RTMP::VIDEO_DATA: RTMP 1498 cygnal/rtmp_server.cpp case RTMP::SHARED_OBJ: RTMP 1502 cygnal/rtmp_server.cpp case RTMP::AMF3_NOTIFY: RTMP 1505 cygnal/rtmp_server.cpp case RTMP::AMF3_SHARED_OBJ: RTMP 1508 cygnal/rtmp_server.cpp case RTMP::AMF3_INVOKE: RTMP 1511 cygnal/rtmp_server.cpp case RTMP::NOTIFY: RTMP 1514 cygnal/rtmp_server.cpp case RTMP::INVOKE: RTMP 1534 cygnal/rtmp_server.cpp RTMP::HEADER_8, response->allocated(), RTMP 1535 cygnal/rtmp_server.cpp RTMP::INVOKE, RTMPMsg::FROM_SERVER, RTMP 1552 cygnal/rtmp_server.cpp RTMP::HEADER_12, response->allocated(), RTMP 1553 cygnal/rtmp_server.cpp RTMP::CHUNK_SIZE, RTMPMsg::FROM_SERVER, RTMP 1560 cygnal/rtmp_server.cpp RTMP::HEADER_8, response->allocated(), RTMP 1561 cygnal/rtmp_server.cpp RTMP::INVOKE, RTMPMsg::FROM_SERVER, RTMP 1567 cygnal/rtmp_server.cpp RTMP::HEADER_8, response->allocated(), RTMP 1568 cygnal/rtmp_server.cpp RTMP::INVOKE, RTMPMsg::FROM_SERVER, RTMP 1574 cygnal/rtmp_server.cpp RTMP::HEADER_8, response->allocated(), RTMP 1575 cygnal/rtmp_server.cpp RTMP::INVOKE, RTMPMsg::FROM_SERVER, RTMP 1581 cygnal/rtmp_server.cpp response = rtmp->encodeUserControl(RTMP::STREAM_LIVE, 1); RTMP 1583 cygnal/rtmp_server.cpp RTMP::HEADER_12, response->allocated(), RTMP 1584 cygnal/rtmp_server.cpp RTMP::USER, RTMPMsg::FROM_SERVER, RTMP 1591 cygnal/rtmp_server.cpp RTMP::HEADER_12, 0, RTMP 1592 cygnal/rtmp_server.cpp RTMP::AUDIO_DATA, RTMPMsg::FROM_SERVER, RTMP 1598 cygnal/rtmp_server.cpp RTMP::HEADER_12, 0, RTMP 1599 cygnal/rtmp_server.cpp RTMP::VIDEO_DATA, RTMPMsg::FROM_SERVER, RTMP 1604 cygnal/rtmp_server.cpp response = rtmp->encodeUserControl(RTMP::STREAM_START, 1); RTMP 1606 cygnal/rtmp_server.cpp RTMP::HEADER_12, response->allocated(), RTMP 1607 cygnal/rtmp_server.cpp RTMP::USER, RTMPMsg::FROM_SERVER, RTMP 1616 cygnal/rtmp_server.cpp RTMP::HEADER_12, 400, RTMP 1617 cygnal/rtmp_server.cpp RTMP::NOTIFY, RTMPMsg::FROM_SERVER, RTMP 1646 cygnal/rtmp_server.cpp RTMP::HEADER_8, result->allocated(), RTMP 1647 cygnal/rtmp_server.cpp RTMP::INVOKE, RTMPMsg::FROM_SERVER, RTMP 1656 cygnal/rtmp_server.cpp case RTMP::FLV_DATA: RTMP 1670 cygnal/rtmp_server.cpp if (rtmp->sendMsg(args->netfd, 0x3, RTMP::HEADER_8, ret, RTMP 1671 cygnal/rtmp_server.cpp RTMP::INVOKE, RTMPMsg::FROM_SERVER, *result)) { RTMP 1688 cygnal/rtmp_server.cpp rtmp->encodePing(RTMP::PING_CLEAR, 0); RTMP 1690 cygnal/rtmp_server.cpp RTMP::HEADER_12, ping_reset->size(), RTMP 1691 cygnal/rtmp_server.cpp RTMP::PING, RTMPMsg::FROM_SERVER, *ping_reset)) { RTMP 45 cygnal/rtmp_server.h class RTMPServer : public gnash::RTMP RTMP 151 cygnal/testsuite/libnet.all/test_rtmp.cpp boost::shared_ptr<RTMP::rtmp_head_t> rthead; RTMP 155 cygnal/testsuite/libnet.all/test_rtmp.cpp boost::shared_ptr<RTMP::queues_t> queues1 = client.split(*buf1); RTMP 219 cygnal/testsuite/libnet.all/test_rtmp.cpp boost::shared_ptr<RTMP::queues_t> queues2 = client.split(*buf2); RTMP 319 cygnal/testsuite/libnet.all/test_rtmp.cpp boost::shared_ptr<RTMP::queues_t> queues3 = client.split(*buf3); RTMP 347 cygnal/testsuite/libnet.all/test_rtmp.cpp if ((*tmpbuf->reference() == 0x05) && (rthead->type <= RTMP::INVOKE)) { RTMP 362 cygnal/testsuite/libnet.all/test_rtmp.cpp if ((*tmpbuf->reference() == 0x07) && (rthead->type <= RTMP::VIDEO_DATA)) { RTMP 377 cygnal/testsuite/libnet.all/test_rtmp.cpp if ((*tmpbuf->reference() == 0x08) && (rthead->type <= RTMP::AUDIO_DATA)) { RTMP 392 cygnal/testsuite/libnet.all/test_rtmp.cpp if ((*tmpbuf->reference() == 0x08) && (rthead->type <= RTMP::AUDIO_DATA)) { RTMP 407 cygnal/testsuite/libnet.all/test_rtmp.cpp if ((*tmpbuf->reference() == 0x02) && (rthead->type <= RTMP::AUDIO_DATA)) { RTMP 419 cygnal/testsuite/libnet.all/test_rtmp.cpp boost::shared_ptr<RTMP::queues_t> queues4 = client.split(*buf4); RTMP 454 cygnal/testsuite/libnet.all/test_rtmp.cpp boost::shared_ptr<RTMP::rtmp_ping_t> ping1 = client.decodePing(*buf1); RTMP 455 cygnal/testsuite/libnet.all/test_rtmp.cpp if (ping1->type == RTMP::PING_CLEAR) { RTMP 463 cygnal/testsuite/libnet.all/test_rtmp.cpp boost::shared_ptr<amf::Buffer> enc1 = server.encodePing(RTMP::PING_CLEAR); RTMP 471 cygnal/testsuite/libnet.all/test_rtmp.cpp boost::shared_ptr<amf::Buffer> enc2 = server.encodePing(RTMP::PING_CLIENT, htonl(time)); RTMP 481 cygnal/testsuite/libnet.all/test_rtmp.cpp boost::shared_ptr<RTMP::rtmp_ping_t> ping2 = client.decodePing(*buf2); RTMP 482 cygnal/testsuite/libnet.all/test_rtmp.cpp if ((ping2->type == RTMP::PING_CLIENT) RTMP 525 cygnal/testsuite/libnet.all/test_rtmp.cpp boost::shared_ptr<amf::Buffer> head1 = client.encodeHeader(0x3, RTMP::HEADER_12, 287, RTMP 526 cygnal/testsuite/libnet.all/test_rtmp.cpp RTMP::INVOKE, RTMPMsg::FROM_CLIENT); RTMP 535 cygnal/testsuite/libnet.all/test_rtmp.cpp boost::shared_ptr<RTMP::rtmp_head_t> header1 = client.decodeHeader(buf1->reference()); RTMP 537 cygnal/testsuite/libnet.all/test_rtmp.cpp && (header1->bodysize == 287) && (header1->type == RTMP::INVOKE)) { RTMP 544 cygnal/testsuite/libnet.all/test_rtmp.cpp boost::shared_ptr<amf::Buffer> head2 = client.encodeHeader(0x2, RTMP::HEADER_12, PING_MSG_SIZE, RTMP 545 cygnal/testsuite/libnet.all/test_rtmp.cpp RTMP::USER, RTMPMsg::FROM_SERVER); RTMP 554 cygnal/testsuite/libnet.all/test_rtmp.cpp boost::shared_ptr<amf::Buffer> head3 = client.encodeHeader(0x2, RTMP::HEADER_12, PING_MSG_SIZE, RTMP 555 cygnal/testsuite/libnet.all/test_rtmp.cpp RTMP::USER, RTMPMsg::FROM_SERVER); RTMP 563 cygnal/testsuite/libnet.all/test_rtmp.cpp boost::shared_ptr<RTMP::rtmp_head_t> header2 = client.decodeHeader(*buf3); RTMP 565 cygnal/testsuite/libnet.all/test_rtmp.cpp && (header2->bodysize == 6) && (header2->type == RTMP::USER)) { RTMP 572 cygnal/testsuite/libnet.all/test_rtmp.cpp boost::shared_ptr<amf::Buffer> head4 = client.encodeHeader(0x2, RTMP::HEADER_1); RTMP 584 cygnal/testsuite/libnet.all/test_rtmp.cpp boost::shared_ptr<amf::Buffer> head5 = client.encodeHeader(0x3, RTMP::HEADER_8, 0x19, RTMP::INVOKE, RTMP 594 cygnal/testsuite/libnet.all/test_rtmp.cpp boost::shared_ptr<RTMP::rtmp_head_t> header3 = client.decodeHeader(*buf5); RTMP 596 cygnal/testsuite/libnet.all/test_rtmp.cpp && (header3->bodysize == 0x19) && (header3->type == RTMP::INVOKE)) { RTMP 604 cygnal/testsuite/libnet.all/test_rtmp.cpp boost::shared_ptr<amf::Buffer> head6 = client.encodeHeader(0x3, RTMP::HEADER_4, 0x19, RTMP::INVOKE, RTMP 788 cygnal/testsuite/libnet.all/test_rtmp.cpp RTMP rtmp; RTMP 810 cygnal/testsuite/libnet.all/test_rtmp.cpp buf2 = rtmp.encodeStreamOp(0, RTMP::STREAM_PLAY, false, "gate06_tablan_bcueu_01"); RTMP 818 cygnal/testsuite/libnet.all/test_rtmp.cpp buf2 = rtmp.encodeStreamOp(0, RTMP::STREAM_PAUSE, true, 0); RTMP 826 cygnal/testsuite/libnet.all/test_rtmp.cpp buf2 = rtmp.encodeStreamOp(0, RTMP::STREAM_STOP, false); RTMP 834 cygnal/testsuite/libnet.all/test_rtmp.cpp buf2 = rtmp.encodeStreamOp(0, RTMP::STREAM_PUBLISH, false); RTMP 845 cygnal/testsuite/libnet.all/test_rtmp.cpp buf2 = rtmp.encodeStreamOp(0, RTMP::STREAM_SEEK, false); RTMP 853 cygnal/testsuite/libnet.all/test_rtmp.cpp buf2 = rtmp.encodeStreamOp(0, RTMP::STREAM_SEEK, false, 12000); RTMP 45 libbase/RTMP.cpp bool sendBytesReceived(RTMP* r); RTMP 47 libbase/RTMP.cpp void handleMetadata(RTMP& r, const boost::uint8_t *payload, RTMP 49 libbase/RTMP.cpp void handleChangeChunkSize(RTMP& r, const RTMPPacket& packet); RTMP 50 libbase/RTMP.cpp void handleControl(RTMP& r, const RTMPPacket& packet); RTMP 51 libbase/RTMP.cpp void handleServerBW(RTMP& r, const RTMPPacket& packet); RTMP 52 libbase/RTMP.cpp void handleClientBW(RTMP& r, const RTMPPacket& packet); RTMP 142 libbase/RTMP.cpp RTMP::RTMP() RTMP 157 libbase/RTMP.cpp RTMP::~RTMP() RTMP 162 libbase/RTMP.cpp RTMP::hasPacket(ChannelType t, size_t channel) const RTMP 169 libbase/RTMP.cpp RTMP::getPacket(ChannelType t, size_t channel) RTMP 176 libbase/RTMP.cpp RTMP::storePacket(ChannelType t, size_t channel, const RTMPPacket& p) RTMP 185 libbase/RTMP.cpp RTMP::setBufferTime(size_t size, int streamID) RTMP 191 libbase/RTMP.cpp RTMP::call(const SimpleBuffer& amf) RTMP 202 libbase/RTMP.cpp RTMP::connect(const URL& url) RTMP 233 libbase/RTMP.cpp RTMP::update() RTMP 287 libbase/RTMP.cpp RTMP::handlePacket(const RTMPPacket& packet) RTMP 361 libbase/RTMP.cpp RTMP::readSocket(boost::uint8_t* buffer, int n) RTMP 389 libbase/RTMP.cpp RTMP::play(const SimpleBuffer& buf, int streamID) RTMP 406 libbase/RTMP.cpp sendServerBW(RTMP& r) RTMP 429 libbase/RTMP.cpp RTMP::readPacketHeader(RTMPPacket& packet) RTMP 568 libbase/RTMP.cpp RTMP::readPacketPayload(RTMPPacket& packet) RTMP 591 libbase/RTMP.cpp RTMP::sendPacket(RTMPPacket& packet) RTMP 794 libbase/RTMP.cpp RTMP::close() RTMP 969 libbase/RTMP.cpp sendCtrl(RTMP& r, ControlType t, unsigned int nObject, unsigned int nTime) RTMP 1000 libbase/RTMP.cpp sendBytesReceived(RTMP* r) RTMP 1017 libbase/RTMP.cpp handleMetadata(RTMP& /*r*/, const boost::uint8_t* /* payload*/, RTMP 1024 libbase/RTMP.cpp handleChangeChunkSize(RTMP& r, const RTMPPacket& packet) RTMP 1033 libbase/RTMP.cpp handleControl(RTMP& r, const RTMPPacket& packet) RTMP 1092 libbase/RTMP.cpp handleServerBW(RTMP& r, const RTMPPacket& packet) RTMP 1100 libbase/RTMP.cpp handleClientBW(RTMP& r, const RTMPPacket& packet) RTMP 325 libbase/RTMP.h struct DSOEXPORT RTMP RTMP 329 libbase/RTMP.h RTMP(); RTMP 331 libbase/RTMP.h ~RTMP(); RTMP 541 libbase/RTMP.h bool sendServerBW(RTMP& r); RTMP 544 libbase/RTMP.h bool sendCtrl(RTMP& r, ControlType, unsigned int nObject, unsigned int nTime); RTMP 77 libcore/asobj/NetConnection_as.cpp void replyBWCheck(rtmp::RTMP& r, double txn); RTMP 388 libcore/asobj/NetConnection_as.cpp rtmp::RTMP _rtmp; RTMP 1328 libcore/asobj/NetConnection_as.cpp replyBWCheck(rtmp::RTMP& r, double txn) RTMP 185 utilities/rtmpget.cpp bool handleInvoke(rtmp::RTMP& r, FakeNC& nc, const boost::uint8_t* payload, RTMP 194 utilities/rtmpget.cpp sendConnectPacket(rtmp::RTMP& r, FakeNC& nc, const std::string& app, RTMP 235 utilities/rtmpget.cpp sendCheckBW(rtmp::RTMP& r, FakeNC& nc) RTMP 250 utilities/rtmpget.cpp replyBWCheck(rtmp::RTMP& r, FakeNC& /*nc*/, double txn) RTMP 264 utilities/rtmpget.cpp sendPausePacket(rtmp::RTMP& r, FakeNC& nc, bool flag, double time) RTMP 289 utilities/rtmpget.cpp sendPlayPacket(rtmp::RTMP& r, FakeNC& nc) RTMP 331 utilities/rtmpget.cpp sendCreateStream(rtmp::RTMP& r, FakeNC& nc) RTMP 343 utilities/rtmpget.cpp sendDeleteStream(rtmp::RTMP& r, FakeNC& nc, double id) RTMP 359 utilities/rtmpget.cpp sendFCSubscribe(rtmp::RTMP& r, FakeNC& nc, const std::string& subscribepath) RTMP 473 utilities/rtmpget.cpp gnash::rtmp::RTMP r; RTMP 541 utilities/rtmpget.cpp handleInvoke(rtmp::RTMP& r, FakeNC& nc, const boost::uint8_t* payload,