正在显示
1 个修改的文件
包含
12 行增加
和
3 行删除
| @@ -4635,7 +4635,10 @@ VOID TEST(ProtocolStackTest, ProtocolSendVMessage) | @@ -4635,7 +4635,10 @@ VOID TEST(ProtocolStackTest, ProtocolSendVMessage) | ||
| 4635 | msg->payload = new char[msg->size]; | 4635 | msg->payload = new char[msg->size]; |
| 4636 | memcpy(msg->payload, data, msg->size); | 4636 | memcpy(msg->payload, data, msg->size); |
| 4637 | 4637 | ||
| 4638 | - EXPECT_TRUE(ERROR_SUCCESS == proto.send_and_free_message(msg, 0)); | 4638 | + SrsSharedPtrMessage m; |
| 4639 | + ASSERT_TRUE(ERROR_SUCCESS == m.create(msg)); | ||
| 4640 | + | ||
| 4641 | + EXPECT_TRUE(ERROR_SUCCESS == proto.send_and_free_message(m.copy(), 0)); | ||
| 4639 | EXPECT_EQ(16, bio.out_buffer.length()); | 4642 | EXPECT_EQ(16, bio.out_buffer.length()); |
| 4640 | } | 4643 | } |
| 4641 | 4644 | ||
| @@ -5347,7 +5350,10 @@ VOID TEST(ProtocolStackTest, ProtocolAckSizeFlow) | @@ -5347,7 +5350,10 @@ VOID TEST(ProtocolStackTest, ProtocolAckSizeFlow) | ||
| 5347 | msg->header.message_type = 9; | 5350 | msg->header.message_type = 9; |
| 5348 | EXPECT_TRUE(msg->header.is_video()); | 5351 | EXPECT_TRUE(msg->header.is_video()); |
| 5349 | 5352 | ||
| 5350 | - EXPECT_TRUE(ERROR_SUCCESS == proto.send_and_free_message(msg, 1)); | 5353 | + SrsSharedPtrMessage m; |
| 5354 | + ASSERT_TRUE(ERROR_SUCCESS == m.create(msg)); | ||
| 5355 | + | ||
| 5356 | + EXPECT_TRUE(ERROR_SUCCESS == proto.send_and_free_message(m.copy(), 1)); | ||
| 5351 | } | 5357 | } |
| 5352 | 5358 | ||
| 5353 | // copy output to input | 5359 | // copy output to input |
| @@ -5393,7 +5399,10 @@ VOID TEST(ProtocolStackTest, ProtocolAckSizeFlow) | @@ -5393,7 +5399,10 @@ VOID TEST(ProtocolStackTest, ProtocolAckSizeFlow) | ||
| 5393 | msg->header.message_type = 9; | 5399 | msg->header.message_type = 9; |
| 5394 | EXPECT_TRUE(msg->header.is_video()); | 5400 | EXPECT_TRUE(msg->header.is_video()); |
| 5395 | 5401 | ||
| 5396 | - EXPECT_TRUE(ERROR_SUCCESS == proto.send_and_free_message(msg, 1)); | 5402 | + SrsSharedPtrMessage m; |
| 5403 | + ASSERT_TRUE(ERROR_SUCCESS == m.create(msg)); | ||
| 5404 | + | ||
| 5405 | + EXPECT_TRUE(ERROR_SUCCESS == proto.send_and_free_message(m.copy(), 1)); | ||
| 5397 | } | 5406 | } |
| 5398 | // copy output to input | 5407 | // copy output to input |
| 5399 | if (true) { | 5408 | if (true) { |
-
请 注册 或 登录 后发表评论