From 466f99a1c8b015e2f94b8637bde89df0de18e3fc Mon Sep 17 00:00:00 2001 From: winlin Date: Tue, 5 Nov 2019 10:31:21 +0800 Subject: [PATCH] Cover protocol stack RTMP. 3.0.63 --- trunk/src/utest/srs_utest_protostack.cpp | 22 ++++++++++++++++++++++ 1 file changed, 22 insertions(+) diff --git a/trunk/src/utest/srs_utest_protostack.cpp b/trunk/src/utest/srs_utest_protostack.cpp index 413af4d4e..7ff5d2092 100644 --- a/trunk/src/utest/srs_utest_protostack.cpp +++ b/trunk/src/utest/srs_utest_protostack.cpp @@ -333,6 +333,28 @@ VOID TEST(ProtoStackTest, HugeMessages) HELPER_EXPECT_SUCCESS(p.send_and_free_messages(msgs, 1024, 1)); EXPECT_EQ(269*1024, io.out_buffer.length()); } + + if (true) { + MockBufferIO io; + SrsProtocol p(&io); + + SrsCommonMessage pkt; + pkt.header.initialize_audio(200, 1000, 1); + pkt.create_payload(256); + pkt.size = 256; + + SrsSharedPtrMessage* msg = new SrsSharedPtrMessage(); + msg->create(&pkt); + SrsAutoFree(SrsSharedPtrMessage, msg); + + SrsSharedPtrMessage* msgs[10240]; + for (int i = 0; i < 10240; i++) { + msgs[i] = msg->copy(); + } + + HELPER_EXPECT_SUCCESS(p.send_and_free_messages(msgs, 10240, 1)); + EXPECT_EQ(269*10240, io.out_buffer.length()); + } } VOID TEST(ProtoStackTest, DecodeMessages)