mirror of
https://github.com/mollyim/webrtc.git
synced 2025-05-14 06:10:40 +01:00

MID is a RFC8260 property on an I-DATA chunk, replacing the SSN property on the DATA chunk in non-interleaved message. The MID stands for "Message Identifier", and it was frequently named "message_id" in the source code, but sometimes "mid". To be consistent and using the same terminology as is most common in the RFC, use "mid" everywhere. This was triggered by the need to introduce yet another "message identifier" - but for now, this is just a refacotring CL. Bug: None Change-Id: I9cca898d9f3a2f162d6f2e4508ec1b4bc8d7308f Reviewed-on: https://webrtc-review.googlesource.com/c/src/+/322500 Reviewed-by: Harald Alvestrand <hta@webrtc.org> Commit-Queue: Victor Boivie <boivie@webrtc.org> Cr-Commit-Position: refs/heads/main@{#40876}
123 lines
4.1 KiB
C++
123 lines
4.1 KiB
C++
/*
|
|
* Copyright (c) 2021 The WebRTC project authors. All Rights Reserved.
|
|
*
|
|
* Use of this source code is governed by a BSD-style license
|
|
* that can be found in the LICENSE file in the root of the source
|
|
* tree. An additional intellectual property rights grant can be found
|
|
* in the file PATENTS. All contributing project authors may
|
|
* be found in the AUTHORS file in the root of the source tree.
|
|
*/
|
|
#include "net/dcsctp/packet/chunk/idata_chunk.h"
|
|
|
|
#include <cstdint>
|
|
#include <type_traits>
|
|
#include <vector>
|
|
|
|
#include "api/array_view.h"
|
|
#include "net/dcsctp/testing/testing_macros.h"
|
|
#include "rtc_base/gunit.h"
|
|
#include "test/gmock.h"
|
|
|
|
namespace dcsctp {
|
|
namespace {
|
|
using ::testing::ElementsAre;
|
|
|
|
TEST(IDataChunkTest, AtBeginningFromCapture) {
|
|
/*
|
|
I_DATA chunk(ordered, first segment, TSN: 2487901653, SID: 1, MID: 0,
|
|
payload length: 1180 bytes)
|
|
Chunk type: I_DATA (64)
|
|
Chunk flags: 0x02
|
|
Chunk length: 1200
|
|
Transmission sequence number: 2487901653
|
|
Stream identifier: 0x0001
|
|
Reserved: 0
|
|
Message identifier: 0
|
|
Payload protocol identifier: WebRTC Binary (53)
|
|
Reassembled Message in frame: 39
|
|
*/
|
|
|
|
uint8_t data[] = {0x40, 0x02, 0x00, 0x15, 0x94, 0x4a, 0x5d, 0xd5,
|
|
0x00, 0x01, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00,
|
|
0x00, 0x00, 0x00, 0x35, 0x01, 0x00, 0x00, 0x00};
|
|
|
|
ASSERT_HAS_VALUE_AND_ASSIGN(IDataChunk chunk, IDataChunk::Parse(data));
|
|
EXPECT_EQ(*chunk.tsn(), 2487901653);
|
|
EXPECT_EQ(*chunk.stream_id(), 1);
|
|
EXPECT_EQ(*chunk.mid(), 0u);
|
|
EXPECT_EQ(*chunk.ppid(), 53u);
|
|
EXPECT_EQ(*chunk.fsn(), 0u); // Not provided (so set to zero)
|
|
}
|
|
|
|
TEST(IDataChunkTest, AtBeginningSerializeAndDeserialize) {
|
|
IDataChunk::Options options;
|
|
options.is_beginning = Data::IsBeginning(true);
|
|
IDataChunk chunk(TSN(123), StreamID(456), MID(789), PPID(53), FSN(0), {1},
|
|
options);
|
|
|
|
std::vector<uint8_t> serialized;
|
|
chunk.SerializeTo(serialized);
|
|
|
|
ASSERT_HAS_VALUE_AND_ASSIGN(IDataChunk deserialized,
|
|
IDataChunk::Parse(serialized));
|
|
EXPECT_EQ(*deserialized.tsn(), 123u);
|
|
EXPECT_EQ(*deserialized.stream_id(), 456u);
|
|
EXPECT_EQ(*deserialized.mid(), 789u);
|
|
EXPECT_EQ(*deserialized.ppid(), 53u);
|
|
EXPECT_EQ(*deserialized.fsn(), 0u);
|
|
|
|
EXPECT_EQ(deserialized.ToString(),
|
|
"I-DATA, type=ordered::first, tsn=123, stream_id=456, "
|
|
"mid=789, ppid=53, length=1");
|
|
}
|
|
|
|
TEST(IDataChunkTest, InMiddleFromCapture) {
|
|
/*
|
|
I_DATA chunk(ordered, last segment, TSN: 2487901706, SID: 3, MID: 1,
|
|
FSN: 8, payload length: 560 bytes)
|
|
Chunk type: I_DATA (64)
|
|
Chunk flags: 0x01
|
|
Chunk length: 580
|
|
Transmission sequence number: 2487901706
|
|
Stream identifier: 0x0003
|
|
Reserved: 0
|
|
Message identifier: 1
|
|
Fragment sequence number: 8
|
|
Reassembled SCTP Fragments (10000 bytes, 9 fragments):
|
|
*/
|
|
|
|
uint8_t data[] = {0x40, 0x01, 0x00, 0x15, 0x94, 0x4a, 0x5e, 0x0a,
|
|
0x00, 0x03, 0x00, 0x00, 0x00, 0x00, 0x00, 0x01,
|
|
0x00, 0x00, 0x00, 0x08, 0x01, 0x00, 0x00, 0x00};
|
|
|
|
ASSERT_HAS_VALUE_AND_ASSIGN(IDataChunk chunk, IDataChunk::Parse(data));
|
|
EXPECT_EQ(*chunk.tsn(), 2487901706);
|
|
EXPECT_EQ(*chunk.stream_id(), 3u);
|
|
EXPECT_EQ(*chunk.mid(), 1u);
|
|
EXPECT_EQ(*chunk.ppid(), 0u); // Not provided (so set to zero)
|
|
EXPECT_EQ(*chunk.fsn(), 8u);
|
|
}
|
|
|
|
TEST(IDataChunkTest, InMiddleSerializeAndDeserialize) {
|
|
IDataChunk chunk(TSN(123), StreamID(456), MID(789), PPID(0), FSN(101112),
|
|
{1, 2, 3}, /*options=*/{});
|
|
|
|
std::vector<uint8_t> serialized;
|
|
chunk.SerializeTo(serialized);
|
|
|
|
ASSERT_HAS_VALUE_AND_ASSIGN(IDataChunk deserialized,
|
|
IDataChunk::Parse(serialized));
|
|
EXPECT_EQ(*deserialized.tsn(), 123u);
|
|
EXPECT_EQ(*deserialized.stream_id(), 456u);
|
|
EXPECT_EQ(*deserialized.mid(), 789u);
|
|
EXPECT_EQ(*deserialized.ppid(), 0u);
|
|
EXPECT_EQ(*deserialized.fsn(), 101112u);
|
|
EXPECT_THAT(deserialized.payload(), ElementsAre(1, 2, 3));
|
|
|
|
EXPECT_EQ(deserialized.ToString(),
|
|
"I-DATA, type=ordered::middle, tsn=123, stream_id=456, "
|
|
"mid=789, fsn=101112, length=3");
|
|
}
|
|
|
|
} // namespace
|
|
} // namespace dcsctp
|