#include "common.hpp"
#include "MediaSoupErrors.hpp"
#include "RTC/SCTP/packet/Chunk.hpp"
#include "RTC/SCTP/packet/chunks/SackChunk.hpp"
#include "test/include/RTC/SCTP/sctpCommon.hpp"
#include <catch2/catch_test_macros.hpp>
#include <cstring>
#include <vector>
SCENARIO("Selective Acknowledgement Chunk (3)", "[serializable][sctp][chunk]")
{
sctpCommon::ResetBuffers();
SECTION("SackChunk::Parse() succeeds")
{
alignas(4) uint8_t buffer[] =
{
0x03, 0b00000000, 0x00, 0x24,
0x11, 0x22, 0x33, 0x44,
0xFF, 0x00, 0x66, 0x77,
0x00, 0x02, 0x00, 0x03,
0x03, 0xE8, 0x07, 0xCF,
0x07, 0xD0, 0x0B, 0xB7,
0x11, 0x22, 0x33, 0x44,
0xFF, 0x00, 0x66, 0x77,
0x21, 0x32, 0x43, 0x54,
0xAA, 0xBB, 0xCC, 0xDD,
0xAA, 0xBB, 0xCC
};
auto* chunk = RTC::SCTP::SackChunk::Parse(buffer, sizeof(buffer));
CHECK_SCTP_CHUNK(
chunk,
buffer,
sizeof(buffer),
36,
RTC::SCTP::Chunk::ChunkType::SACK,
false,
RTC::SCTP::Chunk::ActionForUnknownChunkType::STOP,
0b00000000,
false,
0,
false,
0);
REQUIRE(chunk->GetCumulativeTsnAck() == 287454020);
REQUIRE(chunk->GetAdvertisedReceiverWindowCredit() == 4278216311);
REQUIRE(
chunk->GetDuplicateTsns() == std::vector<uint32_t>{
{ 287454020, 4278216311, 556942164 }
});
REQUIRE(
chunk->GetGapAckBlocks() == std::vector<RTC::SCTP::SackChunk::GapAckBlock>{
{ 1000, 1999 },
{ 2000, 2999 }
});
REQUIRE(
chunk->GetValidatedGapAckBlocks() == std::vector<RTC::SCTP::SackChunk::GapAckBlock>{
{ 1000, 2999 },
});
chunk->Serialize(sctpCommon::SerializeBuffer, sizeof(sctpCommon::SerializeBuffer));
std::memset(buffer, 0x00, sizeof(buffer));
CHECK_SCTP_CHUNK(
chunk,
sctpCommon::SerializeBuffer,
sizeof(sctpCommon::SerializeBuffer),
36,
RTC::SCTP::Chunk::ChunkType::SACK,
false,
RTC::SCTP::Chunk::ActionForUnknownChunkType::STOP,
0b00000000,
false,
0,
false,
0);
REQUIRE(chunk->GetCumulativeTsnAck() == 287454020);
REQUIRE(chunk->GetAdvertisedReceiverWindowCredit() == 4278216311);
REQUIRE(
chunk->GetDuplicateTsns() == std::vector<uint32_t>{
{ 287454020, 4278216311, 556942164 }
});
REQUIRE(
chunk->GetGapAckBlocks() == std::vector<RTC::SCTP::SackChunk::GapAckBlock>{
{ 1000, 1999 },
{ 2000, 2999 }
});
REQUIRE(
chunk->GetValidatedGapAckBlocks() == std::vector<RTC::SCTP::SackChunk::GapAckBlock>{
{ 1000, 2999 }
});
auto* clonedChunk = chunk->Clone(sctpCommon::CloneBuffer, sizeof(sctpCommon::CloneBuffer));
std::memset(sctpCommon::SerializeBuffer, 0x00, sizeof(sctpCommon::SerializeBuffer));
delete chunk;
CHECK_SCTP_CHUNK(
clonedChunk,
sctpCommon::CloneBuffer,
sizeof(sctpCommon::CloneBuffer),
36,
RTC::SCTP::Chunk::ChunkType::SACK,
false,
RTC::SCTP::Chunk::ActionForUnknownChunkType::STOP,
0b00000000,
false,
0,
false,
0);
REQUIRE(clonedChunk->GetCumulativeTsnAck() == 287454020);
REQUIRE(clonedChunk->GetAdvertisedReceiverWindowCredit() == 4278216311);
REQUIRE(
clonedChunk->GetDuplicateTsns() == std::vector<uint32_t>{
{ 287454020, 4278216311, 556942164 }
});
REQUIRE(
clonedChunk->GetGapAckBlocks() == std::vector<RTC::SCTP::SackChunk::GapAckBlock>{
{ 1000, 1999 },
{ 2000, 2999 }
});
REQUIRE(
clonedChunk->GetValidatedGapAckBlocks() == std::vector<RTC::SCTP::SackChunk::GapAckBlock>{
{ 1000, 2999 }
});
delete clonedChunk;
}
SECTION("SackChunk::Parse() fails")
{
alignas(4) uint8_t buffer1[] =
{
0x03, 0b00000000, 0x00, 0x18,
0x11, 0x22, 0x33, 0x44,
0xFF, 0x00, 0x66, 0x77,
0x00, 0x01, 0x00, 0x02,
0x03, 0xE8, 0x07, 0xCF,
0x11, 0x22, 0x33, 0x44,
0xFF, 0x00, 0x66, 0x77,
0xAA, 0xBB, 0xCC, 0xDD,
0xAA, 0xBB, 0xCC
};
REQUIRE(!RTC::SCTP::SackChunk::Parse(buffer1, sizeof(buffer1)));
alignas(4) uint8_t buffer2[] =
{
0x03, 0b00000000, 0x00, 0x20,
0x11, 0x22, 0x33, 0x44,
0xFF, 0x00, 0x66, 0x77,
0x00, 0x01, 0x00, 0x02,
0x03, 0xE8, 0x07, 0xCF,
0x11, 0x22, 0x33, 0x44,
0xFF, 0x00, 0x66, 0x77,
0xFF, 0x00, 0x66, 0x78,
0xAA, 0xBB, 0xCC, 0xDD,
0xAA, 0xBB, 0xCC
};
REQUIRE(!RTC::SCTP::SackChunk::Parse(buffer2, sizeof(buffer2)));
alignas(4) uint8_t buffer3[] =
{
0x03, 0b00000000, 0x00, 0x18,
0x11, 0x22, 0x33, 0x44,
0xFF, 0x00, 0x66, 0x77,
0x00, 0x01, 0x00, 0x00,
0x03, 0xE8, 0x07, 0xCF,
};
REQUIRE(!RTC::SCTP::SackChunk::Parse(buffer3, sizeof(buffer3)));
}
SECTION("SackChunk::Factory() succeeds")
{
auto* chunk =
RTC::SCTP::SackChunk::Factory(sctpCommon::FactoryBuffer, sizeof(sctpCommon::FactoryBuffer));
CHECK_SCTP_CHUNK(
chunk,
sctpCommon::FactoryBuffer,
sizeof(sctpCommon::FactoryBuffer),
16,
RTC::SCTP::Chunk::ChunkType::SACK,
false,
RTC::SCTP::Chunk::ActionForUnknownChunkType::STOP,
0b00000000,
false,
0,
false,
0);
REQUIRE(chunk->GetCumulativeTsnAck() == 0);
REQUIRE(chunk->GetAdvertisedReceiverWindowCredit() == 0);
REQUIRE(chunk->GetDuplicateTsns().empty());
REQUIRE(chunk->GetGapAckBlocks().empty());
REQUIRE(chunk->GetValidatedGapAckBlocks().empty());
chunk->SetCumulativeTsnAck(1234);
chunk->SetAdvertisedReceiverWindowCredit(5678);
chunk->AddDuplicateTsn(10000000);
chunk->AddAckBlock(10000, 19999);
chunk->AddAckBlock(RTC::SCTP::SackChunk::GapAckBlock(20000, 20999));
chunk->AddDuplicateTsn(20000000);
chunk->AddAckBlock(60000, 60999);
chunk->AddDuplicateTsn(30000000);
chunk->AddDuplicateTsn(40000000);
CHECK_SCTP_CHUNK(
chunk,
sctpCommon::FactoryBuffer,
sizeof(sctpCommon::FactoryBuffer),
44,
RTC::SCTP::Chunk::ChunkType::SACK,
false,
RTC::SCTP::Chunk::ActionForUnknownChunkType::STOP,
0b00000000,
false,
0,
false,
0);
REQUIRE(chunk->GetCumulativeTsnAck() == 1234);
REQUIRE(chunk->GetAdvertisedReceiverWindowCredit() == 5678);
REQUIRE(
chunk->GetDuplicateTsns() == std::vector<uint32_t>{ 10000000, 20000000, 30000000, 40000000 });
REQUIRE(
chunk->GetGapAckBlocks() == std::vector<RTC::SCTP::SackChunk::GapAckBlock>{
{ 10000, 19999 },
{ 20000, 20999 },
{ 60000, 60999 }
});
REQUIRE(
chunk->GetValidatedGapAckBlocks() == std::vector<RTC::SCTP::SackChunk::GapAckBlock>{
{ 10000, 20999 },
{ 60000, 60999 }
});
auto* parsedChunk = RTC::SCTP::SackChunk::Parse(chunk->GetBuffer(), chunk->GetLength());
delete chunk;
CHECK_SCTP_CHUNK(
parsedChunk,
sctpCommon::FactoryBuffer,
44,
44,
RTC::SCTP::Chunk::ChunkType::SACK,
false,
RTC::SCTP::Chunk::ActionForUnknownChunkType::STOP,
0b00000000,
false,
0,
false,
0);
REQUIRE(parsedChunk->GetCumulativeTsnAck() == 1234);
REQUIRE(parsedChunk->GetAdvertisedReceiverWindowCredit() == 5678);
REQUIRE(
parsedChunk->GetDuplicateTsns() ==
std::vector<uint32_t>{ 10000000, 20000000, 30000000, 40000000 });
REQUIRE(
parsedChunk->GetGapAckBlocks() == std::vector<RTC::SCTP::SackChunk::GapAckBlock>{
{ 10000, 19999 },
{ 20000, 20999 },
{ 60000, 60999 }
});
REQUIRE(
parsedChunk->GetValidatedGapAckBlocks() == std::vector<RTC::SCTP::SackChunk::GapAckBlock>{
{ 10000, 20999 },
{ 60000, 60999 }
});
delete parsedChunk;
}
}