[Top][All Lists]
[Date Prev][Date Next][Thread Prev][Thread Next][Date Index][Thread Index]
[Gnash-commit] /srv/bzr/gnash/rtmp r9947: fixed enough to compile and no
From: |
rob |
Subject: |
[Gnash-commit] /srv/bzr/gnash/rtmp r9947: fixed enough to compile and not core dump, but has failures. |
Date: |
Sun, 18 Jan 2009 08:02:02 -0000 |
User-agent: |
Bazaar (1.5) |
------------------------------------------------------------
revno: 9947
committer: address@hidden
branch nick: rtmp
timestamp: Thu 2009-01-01 18:12:26 -0700
message:
fixed enough to compile and not core dump, but has failures.
modified:
testsuite/libnet.all/test_rtmp.cpp
=== modified file 'testsuite/libnet.all/test_rtmp.cpp'
--- a/testsuite/libnet.all/test_rtmp.cpp 2008-10-25 16:29:48 +0000
+++ b/testsuite/libnet.all/test_rtmp.cpp 2009-01-02 01:12:26 +0000
@@ -148,11 +148,11 @@
RTMPClient client;
bool notest = false;
- RTMP::rtmp_head_t *rthead = 0;
+ boost::shared_ptr<RTMP::rtmp_head_t> rthead;
CQue *que;
boost::shared_ptr<Buffer> buf1(new Buffer("04 00 00 00 00 00 b8 14 01 00
00 00 02 00 08 6f 6e 53 74 61 74 75 73 00 00 00 00 00 00 00 00 00 05 03 00 05
6c 65 76 65 6c 02 00 06 73 74 61 74 75 73 00 04 63 6f 64 65 02 00 14 4e 65 74
53 74 72 65 61 6d 2e 50 6c 61 79 2e 52 65 73 65 74 00 0b 64 65 73 63 72 69 70
74 69 6f 6e 02 00 2d 50 6c 61 79 69 6e 67 20 61 6e 64 20 72 65 73 65 74 74 69
6e 67 20 67 61 74 65 30 36 5f 74 61 62 6c 61 6e 5f 62 63 75 65 75 5f 30 31 2e
c4 00 07 64 65 74 61 69 6c 73 02 00 16 67 61 74 65 30 36 5f 74 61 62 6c 61 6e
5f 62 63 75 65 75 5f 30 31 00 08 63 6c 69 65 6e 74 69 64 00 41 bf e4 78 30 00
00 00 00 00 09"));
- RTMP::queues_t *queues1 = client.split(buf1);
+ boost::shared_ptr<RTMP::queues_t> queues1 = client.split(*buf1);
if (queues1->size() == 0) {
notest = true;
}
@@ -208,7 +208,7 @@
// delete queues1;
boost::shared_ptr<Buffer> buf2(new Buffer("02 00 00 00 00 00 04 01 00 00
00 00 00 00 00 80 02 00 00 00 00 00 06 04 00 00 00 00 00 04 00 00 00 01 04 00
00 00 00 00 b8 14 01 00 00 00 02 00 08 6f 6e 53 74 61 74 75 73 00 00 00 00 00
00 00 00 00 05 03 00 05 6c 65 76 65 6c 02 00 06 73 74 61 74 75 73 00 04 63 6f
64 65 02 00 14 4e 65 74 53 74 72 65 61 6d 2e 50 6c 61 79 2e 52 65 73 65 74 00
0b 64 65 73 63 72 69 70 74 69 6f 6e 02 00 2d 50 6c 61 79 69 6e 67 20 61 6e 64
20 72 65 73 65 74 74 69 6e 67 20 67 61 74 65 30 36 5f 74 61 62 6c 61 6e 5f 62
63 75 65 75 5f 30 31 2e 02 00 00 00 00 00 06 04 00 00 00 00 00 00 00 00 00 01
c4 00 07 64 65 74 61 69 6c 73 02 00 16 67 61 74 65 30 36 5f 74 61 62 6c 61 6e
5f 62 63 75 65 75 5f 30 31 00 08 63 6c 69 65 6e 74 69 64 00 41 d8 fb 78 56 00
00 00 00 00 09"));
- RTMP::queues_t *queues2 = client.split(buf2);
+ boost::shared_ptr<RTMP::queues_t> queues2 = client.split(*buf2);
if (queues2->size() == 0) {
notest = true;
}
@@ -302,7 +302,7 @@
// for other channels.
//
...............onStatus.............level...status..code...NetStream.Play.Start..description..'Started
playing
gate06_tablan_bcueu_01...clie......'address@hidden;...../..rP.....K.......m......,......%......................B........M.<.$.....`.......i..9..C..J..........%..........G....2Np."address@hidden;.ntid.A..xV.....
boost::shared_ptr<Buffer> buf3(new Buffer("05 00 00 00 00 00 90 14 01 00
00 00 02 00 08 6f 6e 53 74 61 74 75 73 00 00 00 00 00 00 00 00 00 05 03 00 05
6c 65 76 65 6c 02 00 06 73 74 61 74 75 73 00 04 63 6f 64 65 02 00 14 4e 65 74
53 74 72 65 61 6d 2e 50 6c 61 79 2e 53 74 61 72 74 00 0b 64 65 73 63 72 69 70
74 69 6f 6e 02 00 27 53 74 61 72 74 65 64 20 70 6c 61 79 69 6e 67 20 67 61 74
65 30 36 5f 74 61 62 6c 61 6e 5f 62 63 75 65 75 5f 30 31 2e 00 08 63 6c 69 65
07 00 00 00 00 00 27 09 01 00 00 00 14 00 78 46 0f 14 0f 14 3f 6a ff ff 00 08
9f 40 10 9f f8 8b 3f fd b2 4f fb 5d c0 00 00 00 00 00 00 00 00 00 00 00 00 08
00 00 00 00 00 00 08 01 00 00 00 08 00 00 00 00 01 3b 08 01 00 00 00 2f ff fb
72 50 00 00 00 00 00 4b 00 00 00 00 07 e0 09 6d 00 00 00 00 00 01 2c 00 00 00
00 1f 80 25 b4 00 00 00 ff ff ff ff ff ff ff ff ff ff ff ff ff ff ff fc 0c 87
42 80 ec c8 b0 0e 90 c2 12 4d 90 3c 18 24 16 01 88 03 e1 60 1a 1a a0 1a 09 9c
1a 69 a1 10 39 06 8d 43 02 c3 4a 12 0b 00 c8 1f 0b 00 d8 16 00 25 9f ff ff fe
c1 a0 00 00 ff 8a 47 80 80 0e 1e 32 4e 70 f1 22 ed 31 60 40 f8 02 00 00 00 00
00 04 01 00 00 00 00 00 00 01 3b c5 6e 74 69 64 00 41 d8 fb 78 56 00 00 00 00
00 09"));
- RTMP::queues_t *queues3 = client.split(buf3);
+ boost::shared_ptr<RTMP::queues_t> queues3 = client.split(*buf3);
if (queues3->size() == 0) {
notest = true;
}
@@ -324,7 +324,7 @@
tmpbuf = que->pop();
// tmpbuf->dump();
queues3->pop_front();
- rthead = client.decodeHeader(tmpbuf);
+ rthead = client.decodeHeader(tmpbuf->reference());
if ((*tmpbuf->reference() == 0x05) && (rthead->type <= RTMP::INVOKE))
{
runtest.pass("RTMP::split(1st packet header) of 6");
} else {
@@ -339,7 +339,7 @@
tmpbuf = que->pop();
// tmpbuf->dump();
queues3->pop_front();
- rthead = client.decodeHeader(tmpbuf);
+ rthead = client.decodeHeader(tmpbuf->reference());
if ((*tmpbuf->reference() == 0x07) && (rthead->type <=
RTMP::VIDEO_DATA)) {
runtest.pass("RTMP::split(2nd packet header) of 6");
} else {
@@ -354,7 +354,7 @@
tmpbuf = que->pop();
// tmpbuf->dump();
queues3->pop_front();
- rthead = client.decodeHeader(tmpbuf);
+ rthead = client.decodeHeader(tmpbuf->reference());
if ((*tmpbuf->reference() == 0x08) && (rthead->type <=
RTMP::AUDIO_DATA)) {
runtest.pass("RTMP::split(3rd packet header) of 6");
} else {
@@ -369,7 +369,7 @@
tmpbuf = que->pop();
// tmpbuf->dump();
queues3->pop_front();
- rthead = client.decodeHeader(tmpbuf);
+ rthead = client.decodeHeader(tmpbuf->reference());
if ((*tmpbuf->reference() == 0x08) && (rthead->type <=
RTMP::AUDIO_DATA)) {
runtest.pass("RTMP::split(4th packet header) of 6");
} else {
@@ -384,7 +384,7 @@
// tmpbuf->dump();
queues3->pop_front();
- rthead = client.decodeHeader(tmpbuf);
+ rthead = client.decodeHeader(tmpbuf->reference());
if ((*tmpbuf->reference() == 0x02) && (rthead->type <=
RTMP::AUDIO_DATA)) {
runtest.pass("RTMP::split(5th packet header) of 6");
} else {
@@ -406,20 +406,21 @@
GNASH_REPORT_FUNCTION;
RTMPClient client;
- RTMPServer server;
boost::shared_ptr<amf::Buffer> buf1(new amf::Buffer("00 00 00 00 00 00"));
// clear buffer message
boost::shared_ptr<amf::Buffer> buf2(new amf::Buffer("00 06 cf 03 04 c3"));
// ping client from server
boost::shared_ptr<amf::Buffer> buf3(new amf::Buffer("00 07 cf 03 04 c3"));
// Pong, reply from client
boost::shared_ptr<amf::Buffer> buf4(new amf::Buffer("00 00 00 00 00 01"));
// clear buffer message
- RTMP::rtmp_ping_t *ping1 = client.decodePing(buf1);
+ boost::shared_ptr<RTMP::rtmp_ping_t> ping1 = client.decodePing(*buf1);
if (ping1->type == RTMP::PING_CLEAR) {
runtest.pass("Decoded RTMP Ping message");
} else {
runtest.fail("Decoded RTMP Ping message");
}
+#if 0
+ RTMPServer server;
boost::shared_ptr<amf::Buffer> enc1 = server.encodePing(RTMP::PING_CLEAR);
if ((memcmp(buf1->reference(), enc1->reference(), 6) == 0)) {
runtest.pass("Encoded RTMP Ping Clear message");
@@ -436,8 +437,9 @@
} else {
runtest.fail("Encoded RTMP Ping Client message");
}
-
- RTMP::rtmp_ping_t *ping2 = client.decodePing(buf2);
+#endif
+
+ boost::shared_ptr<RTMP::rtmp_ping_t> ping2 = client.decodePing(*buf2);
if ((ping2->type == RTMP::PING_CLIENT)
&& (ping2->target == 0xcf03)
&& (ping2->param1 == 0x4c3)) {
@@ -470,8 +472,6 @@
// "c2 00 06 30 86 0a ae";
// cleanup
- delete ping1;
- delete ping2;
}
void
@@ -479,12 +479,11 @@
{
GNASH_REPORT_FUNCTION;
RTMPClient client;
- RTMPServer server;
// this is a sample 12 bytes RTMP header
// const char *x1 = "03 00 00 00 00 01 1f 14 00 00 00 00";
boost::shared_ptr<amf::Buffer> buf1(new Buffer("03 00 00 00 00 01 1f 14 00
00 00 00"));
- boost::shared_ptr<amf::Buffer> head1 = server.encodeHeader(0x3,
RTMP::HEADER_12, 287,
+ boost::shared_ptr<amf::Buffer> head1 = client.encodeHeader(0x3,
RTMP::HEADER_12, 287,
RTMP::INVOKE, RTMPMsg::FROM_SERVER);
// cerr << hexify(buf1->begin(), RTMP_MAX_HEADER_SIZE, false) << endl;
// cerr << hexify(head1->begin(), RTMP_MAX_HEADER_SIZE, false) << endl;
@@ -494,8 +493,7 @@
} else {
runtest.fail("Encoded RTMP header(Invoke)");
}
-
- RTMP::rtmp_head_t *header1 = server.decodeHeader(buf1->reference());
+ boost::shared_ptr<RTMP::rtmp_head_t> header1 =
client.decodeHeader(buf1->reference());
if ((header1->channel == 0x3) && (header1->head_size ==
RTMP_MAX_HEADER_SIZE)
&& (header1->bodysize == 287) && (header1->type == RTMP::INVOKE)) {
runtest.pass("Decoded RTMP header(Invoke)");
@@ -504,7 +502,7 @@
}
boost::shared_ptr<amf::Buffer> buf2(new Buffer("02 00 00 00 00 00 06 04
00 00 00 00"));
- boost::shared_ptr<amf::Buffer> head2 = server.encodeHeader(0x2,
RTMP::HEADER_12, PING_MSG_SIZE,
+ boost::shared_ptr<amf::Buffer> head2 = client.encodeHeader(0x2,
RTMP::HEADER_12, PING_MSG_SIZE,
RTMP::PING, RTMPMsg::FROM_SERVER);
// cerr << hexify(head2->begin(), RTMP_MAX_HEADER_SIZE, false) << endl;
if ((memcmp(buf2->reference(), head2->reference(), 8) == 0)) {
@@ -514,7 +512,7 @@
}
boost::shared_ptr<amf::Buffer> buf3(new Buffer("02 ff e3 6c 00 00 06 04
00 00 00 00"));
- boost::shared_ptr<amf::Buffer> head3 = server.encodeHeader(0x2,
RTMP::HEADER_12, PING_MSG_SIZE,
+ boost::shared_ptr<amf::Buffer> head3 = client.encodeHeader(0x2,
RTMP::HEADER_12, PING_MSG_SIZE,
RTMP::PING, RTMPMsg::FROM_SERVER);
// cerr << hexify(head3->begin(), RTMP_MAX_HEADER_SIZE, false) << endl;
if ((memcmp(buf2->reference(), head3->reference(), 8) == 0)) {
@@ -523,7 +521,7 @@
runtest.fail("Encoded RTMP header(Ping 1)");
}
- RTMP::rtmp_head_t *header2 = client.decodeHeader(buf3);
+ boost::shared_ptr<RTMP::rtmp_head_t> header2 = client.decodeHeader(*buf3);
if ((header2->channel == 0x2) && (header2->head_size ==
RTMP_MAX_HEADER_SIZE)
&& (header2->bodysize == 6) && (header2->type == RTMP::PING)) {
runtest.pass("Decoded RTMP header(Ping)");
@@ -532,7 +530,7 @@
}
boost::shared_ptr<amf::Buffer> buf4(new Buffer("c2"));
- boost::shared_ptr<amf::Buffer> head4 = server.encodeHeader(0x2,
RTMP::HEADER_1);
+ boost::shared_ptr<amf::Buffer> head4 = client.encodeHeader(0x2,
RTMP::HEADER_1);
// cerr << hexify(head4->begin(), RTMP_MAX_HEADER_SIZE, false) << endl;
if ((memcmp(buf4->reference(), head4->reference(), 1) == 0)) {
runtest.pass("Encoded RTMP header(size 1)");
@@ -544,7 +542,7 @@
// 6f 6e 65 00 40 00 00 00 00 00 00 00 05
boost::shared_ptr<amf::Buffer> buf5(new Buffer("43 00 00 00 00 00 19
14"));
- boost::shared_ptr<amf::Buffer> head5 = server.encodeHeader(0x3,
RTMP::HEADER_8, 0x19, RTMP::INVOKE,
+ boost::shared_ptr<amf::Buffer> head5 = client.encodeHeader(0x3,
RTMP::HEADER_8, 0x19, RTMP::INVOKE,
RTMPMsg::FROM_CLIENT);
// head5->dump();
// cerr << hexify(head5->begin(), 8, false) << endl;
@@ -554,13 +552,24 @@
runtest.fail("Encoded RTMP header(size 8)");
}
- RTMP::rtmp_head_t *header3 = client.decodeHeader(buf5);
+ boost::shared_ptr<RTMP::rtmp_head_t> header3 = client.decodeHeader(*buf5);
if ((header3->channel == 0x3) && (header3->head_size == 8)
&& (header3->bodysize == 0x19) && (header3->type == RTMP::INVOKE)) {
runtest.pass("Decoded RTMP header(size 8)");
} else {
runtest.fail("Decoded RTMP header(size 8)");
}
+
+ // 4 byte header
+ boost::shared_ptr<amf::Buffer> buf6(new Buffer("83 00 04 16"));
+ boost::shared_ptr<amf::Buffer> head6 = client.encodeHeader(0x3,
RTMP::HEADER_4, 0x19, RTMP::INVOKE,
+ RTMPMsg::FROM_CLIENT);
+ if ((memcmp(buf6->reference(), head6->reference(), 4) == 0)) {
+ runtest.pass("Encoded RTMP header(size 4)");
+ } else {
+ runtest.fail("Encoded RTMP header(size 4)");
+ }
+// head5->dump();
}
void
@@ -579,7 +588,7 @@
// 63 74 2e 53 75 63 63 65 73 73 00 00 c3 09 ct.Success....
boost::shared_ptr<amf::Buffer> hex2(new Buffer("02 00 07 5f 72 65 73 75 6c
74 00 3f f0 00 00 00 00 00 00 05 03 00 0b 61 70 70 6c 69 63 61 74 69 6f 6e 05
00 05 6c 65 76 65 6c 02 00 06 73 74 61 74 75 73 00 0b 64 65 73 63 72 69 70 74
69 6f 6e 02 00 15 43 6f 6e 6e 65 63 74 69 6f 6e 20 73 75 63 63 65 65 64 65 64
2e 00 04 63 6f 64 65 02 00 1d 4e 65 74 43 6f 6e 6e 65 63 74 69 6f 6e 2e 43 6f
6e 6e 65 63 74 2e 53 75 63 63 65 73 73 00 00 09"));
- RTMPMsg *msg1 = rtmp.decodeMsgBody(hex2);
+ RTMPMsg *msg1 = rtmp.decodeMsgBody(*hex2);
if (msg1) {
std::vector<boost::shared_ptr<amf::Element> > hell =
msg1->getElements();
std::vector<boost::shared_ptr<amf::Element> > props =
hell[0]->getProperties();
@@ -613,7 +622,7 @@
#endif
boost::shared_ptr<amf::Buffer> hex3(new Buffer("02 00 07 5f 72 65 73 75 6c
74 00 3f f0 00 00 00 00 00 00 05 03 00 0b 61 70 70 6c 69 63 61 74 69 6f 6e 05
00 05 6c 65 76 65 6c 02 00 05 65 72 72 6f 72 00 0b 64 65 73 63 72 69 70 74 69
6f 6e 02 00 00 00 04 63 6f 64 65 02 00 1c 4e 65 74 43 6f 6e 6e 65 63 74 69 6f
6e 2e 43 6f 6e 6e 65 63 74 2e 46 61 69 6c 65 64 00 00 09"));
- RTMPMsg *msg2 = rtmp.decodeMsgBody(hex3);
+ RTMPMsg *msg2 = rtmp.decodeMsgBody(*hex3);
std::vector<boost::shared_ptr<amf::Element> > hell = msg2->getElements();
std::vector<boost::shared_ptr<amf::Element> > props =
hell[0]->getProperties();
// printf("FIXME: %d, %d, %s:%s\n", props.size(), msg1->getStatus(),
@@ -654,7 +663,7 @@
// clientid
// dsLgYohb
boost::shared_ptr<amf::Buffer> hex4(new Buffer("02 00 08 6f 6e 53 74 61 74
75 73 00 00 00 00 00 00 00 00 00 05 03 00 05 6c 65 76 65 6c 02 00 06 73 74 61
74 75 73 00 04 63 6f 64 65 02 00 14 4e 65 74 53 74 72 65 61 6d 2e 50 6c 61 79
2e 52 65 73 65 74 00 0b 64 65 73 63 72 69 70 74 69 6f 6e 02 00 2a 50 6c 61 79
69 6e 67 20 61 6e 64 20 72 65 73 65 74 74 69 6e 67 20 50 44 5f 45 6e 67 6c 69
73 68 5f 4c 6f 77 40 32 30 30 31 2e 00 07 64 65 74 61 69 6c 73 02 00 13 50 44
5f 45 6e 67 6c 69 73 68 5f 4c 6f 77 40 32 30 30 31 00 08 63 6c 69 65 6e 74 69
64 02 00 08 64 73 4c 67 59 6f 68 62 00 00 09"));
- RTMPMsg *msg4 = rtmp.decodeMsgBody(hex4);
+ RTMPMsg *msg4 = rtmp.decodeMsgBody(*hex4);
// msg4->dump();
// std::vector<amf::Element *> hell4 = msg4->getElements();
if ((msg4->getStatus() == RTMPMsg::NS_PLAY_RESET)
@@ -672,7 +681,7 @@
// NetStream
// Data.Start
boost::shared_ptr<amf::Buffer> hex5(new Buffer("02 00 08 6f 6e 53 74 61 74
75 73 03 00 04 63 6f 64 65 02 00 14 4e 65 74 53 74 72 65 61 6d 2e 44 61 74 61
2e 53 74 61 72 74 00 00 09"));
- RTMPMsg *msg5 = rtmp.decodeMsgBody(hex5);
+ RTMPMsg *msg5 = rtmp.decodeMsgBody(*hex5);
// msg5->dump();
// cout << msg5->getStreamID() << endl;
// std::vector<amf::Element *> hell4 = msg4->getElements();
@@ -696,7 +705,7 @@
// details
// address@hidden
boost::shared_ptr<amf::Buffer> hex6(new Buffer("02 00 08 6f 6e 53 74 61 74
75 73 00 00 00 00 00 00 00 00 00 05 03 00 05 6c 65 76 65 6c 02 00 06 73 74 61
74 75 73 00 04 63 6f 64 65 02 00 14 4e 65 74 53 74 72 65 61 6d 2e 50 6c 61 79
2e 53 74 61 72 74 00 0b 64 65 73 63 72 69 70 74 69 6f 6e 02 00 24 53 74 61 72
74 65 64 20 70 6c 61 79 69 6e 67 20 50 44 5f 45 6e 67 6c 69 73 68 5f 4c 6f 77
40 32 30 30 31 2e 00 07 64 65 74 61 69 6c 73 02 00 13 50 44 5f 45 6e 67 6c 69
73 68 5f 4c 6f 77 40 32 30 30 31 00 08 63 6c 69 65 6e 74 69 64 02 00 08 64 73
4c 67 59 6f 68 62 00 00 09"));
- RTMPMsg *msg6 = rtmp.decodeMsgBody(hex6);
+ RTMPMsg *msg6 = rtmp.decodeMsgBody(*hex6);
// msg6->dump();
// std::vector<amf::Element *> hell4 = msg4->getElements();
if ((msg6->getStatus() == RTMPMsg::NS_PLAY_START)
@@ -711,7 +720,7 @@
// ..............._error.?.........
..level...error..code...NetConnection.Connect.Rejected..description..A[
Server.Reject ] : Virtual host _defa.ultVHost_ is not available....
boost::shared_ptr<amf::Buffer> hex7(new Buffer("02 00 06 5f 65 72 72 6f 72
00 3f f0 00 00 00 00 00 00 05 03 00 05 6c 65 76 65 6c 02 00 05 65 72 72 6f 72
00 04 63 6f 64 65 02 00 1e 4e 65 74 43 6f 6e 6e 65 63 74 69 6f 6e 2e 43 6f 6e
6e 65 63 74 2e 52 65 6a 65 63 74 65 64 00 0b 64 65 73 63 72 69 70 74 69 6f 6e
02 00 41 5b 20 53 65 72 76 65 72 2e 52 65 6a 65 63 74 20 5d 20 3a 20 56 69 72
74 75 61 6c 20 68 6f 73 74 20 5f 64 65 66 61 c3 75 6c 74 56 48 6f 73 74 5f 20
69 73 20 6e 6f 74 20 61 76 61 69 6c 61 62 6c 65 2e 00 00 09"));
- RTMPMsg *msg7 = rtmp.decodeMsgBody(hex7);
+ RTMPMsg *msg7 = rtmp.decodeMsgBody(*hex7);
if ((msg7->getStatus() == RTMPMsg::NC_CONNECT_REJECTED)
&& (msg7->getMethodName() == "_error")
&& (msg7->size() == 1)) {
@@ -723,7 +732,7 @@
//.onStatus.............level...error..code...NetStream.Play.StreamNotFound..description..6Failed
to play gate06_tablan_bcueu_; .stream not
found...details...gate06_tablan_bcueu_..clientid.A.;..
boost::shared_ptr<amf::Buffer> hex8(new Buffer("02 00 08 6f 6e 53 74 61 74
75 73 00 00 00 00 00 00 00 00 00 05 03 00 05 6c 65 76 65 6c 02 00 05 65 72 72
6f 72 00 04 63 6f 64 65 02 00 1d 4e 65 74 53 74 72 65 61 6d 2e 50 6c 61 79 2e
53 74 72 65 61 6d 4e 6f 74 46 6f 75 6e 64 00 0b 64 65 73 63 72 69 70 74 69 6f
6e 02 00 36 46 61 69 6c 65 64 20 74 6f 20 70 6c 61 79 20 67 61 74 65 30 36 5f
74 61 62 6c 61 6e 5f 62 63 75 65 75 5f 3b 20 c4 73 74 72 65 61 6d 20 6e 6f 74
20 66 6f 75 6e 64 2e 00 07 64 65 74 61 69 6c 73 02 00 14 67 61 74 65 30 36 5f
74 61 62 6c 61 6e 5f 62 63 75 65 75 5f 00 08 63 6c 69 65 6e 74 69 64 00 41 d8
3b b4 e4 00 00 00 00 00 09"));
- RTMPMsg *msg8 = rtmp.decodeMsgBody(hex8);
+ RTMPMsg *msg8 = rtmp.decodeMsgBody(*hex8);
// msg4->dump();
// std::vector<amf::Element *> hell4 = msg4->getElements();
if ((msg8->getStatus() == RTMPMsg::NS_PLAY_STREAMNOTFOUND)
@@ -738,7 +747,7 @@
//.....onStatus.............level...status..code...NetStream.Play.Stop..description..%Stopped
playing
gate06_tablan_bcueu_...details....gate06_tablan_bcueu_..clientid.A.;.......reason......
boost::shared_ptr<amf::Buffer> hex9(new Buffer("02 00 08 6f 6e 53 74 61 74
75 73 00 00 00 00 00 00 00 00 00 05 03 00 05 6c 65 76 65 6c 02 00 06 73 74 61
74 75 73 00 04 63 6f 64 65 02 00 13 4e 65 74 53 74 72 65 61 6d 2e 50 6c 61 79
2e 53 74 6f 70 00 0b 64 65 73 63 72 69 70 74 69 6f 6e 02 00 25 53 74 6f 70 70
65 64 20 70 6c 61 79 69 6e 67 20 67 61 74 65 30 36 5f 74 61 62 6c 61 6e 5f 62
63 75 65 75 5f 2e 00 07 64 65 74 61 69 6c 73 c4 02 00 14 67 61 74 65 30 36 5f
74 61 62 6c 61 6e 5f 62 63 75 65 75 5f 00 08 63 6c 69 65 6e 74 69 64 00 41 d8
3b b4 e4 00 00 00 00 06 72 65 61 73 6f 6e 02 00 00 00 00 09"));
- RTMPMsg *msg9 = rtmp.decodeMsgBody(hex9);
+ RTMPMsg *msg9 = rtmp.decodeMsgBody(*hex9);
// msg4->dump();
// std::vector<amf::Element *> hell4 = msg4->getElements();
if ((msg9->getStatus() == RTMPMsg::NS_PLAY_STOP)
[Prev in Thread] |
Current Thread |
[Next in Thread] |
- [Gnash-commit] /srv/bzr/gnash/rtmp r9947: fixed enough to compile and not core dump, but has failures.,
rob <=