[Gnash-commit] /srv/bzr/gnash/rtmp r9947: fixed enough to compile and not core dump, but has failures.

[rob]

------------------------------------------------------------
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)