dcsctp: Add Data Generator
The Data Generator is a testonly library for generating Data with correct sequence numbers. Bug: webrtc:12614 Change-Id: Ifc04dfd14d858d905312ffed13e8905c23d59923 Reviewed-on: https://webrtc-review.googlesource.com/c/src/+/214041 Commit-Queue: Victor Boivie <boivie@webrtc.org> Reviewed-by: Tommi <tommi@webrtc.org> Reviewed-by: Mirko Bonadei <mbonadei@webrtc.org> Cr-Commit-Position: refs/heads/master@{#33667}
This commit is contained in:
committed by
Commit Bot
parent
6fa0cfa4dd
commit
5f4ac67c7b
@ -12,3 +12,17 @@ rtc_source_set("testing_macros") {
|
||||
testonly = true
|
||||
sources = [ "testing_macros.h" ]
|
||||
}
|
||||
|
||||
rtc_library("data_generator") {
|
||||
testonly = true
|
||||
deps = [
|
||||
"../../../api:array_view",
|
||||
"../../../rtc_base",
|
||||
"../../../rtc_base:checks",
|
||||
"../../../rtc_base:rtc_base_approved",
|
||||
]
|
||||
sources = [
|
||||
"data_generator.cc",
|
||||
"data_generator.h",
|
||||
]
|
||||
}
|
||||
|
||||
65
net/dcsctp/testing/data_generator.cc
Normal file
65
net/dcsctp/testing/data_generator.cc
Normal file
@ -0,0 +1,65 @@
|
||||
/*
|
||||
* 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/testing/data_generator.h"
|
||||
|
||||
#include <cstdint>
|
||||
#include <string>
|
||||
#include <utility>
|
||||
#include <vector>
|
||||
|
||||
#include "absl/strings/string_view.h"
|
||||
#include "net/dcsctp/packet/data.h"
|
||||
#include "net/dcsctp/public/types.h"
|
||||
|
||||
namespace dcsctp {
|
||||
constexpr PPID kPpid = PPID(53);
|
||||
|
||||
Data DataGenerator::Ordered(std::vector<uint8_t> payload,
|
||||
absl::string_view flags,
|
||||
const DataGeneratorOptions opts) {
|
||||
Data::IsBeginning is_beginning(flags.find('B') != std::string::npos);
|
||||
Data::IsEnd is_end(flags.find('E') != std::string::npos);
|
||||
|
||||
if (is_beginning) {
|
||||
fsn_ = FSN(0);
|
||||
} else {
|
||||
fsn_ = FSN(*fsn_ + 1);
|
||||
}
|
||||
MID message_id = opts.message_id.value_or(message_id_);
|
||||
Data ret = Data(opts.stream_id, SSN(static_cast<uint16_t>(*message_id)),
|
||||
message_id, fsn_, opts.ppid, std::move(payload), is_beginning,
|
||||
is_end, IsUnordered(false));
|
||||
|
||||
if (is_end) {
|
||||
message_id_ = MID(*message_id + 1);
|
||||
}
|
||||
return ret;
|
||||
}
|
||||
|
||||
Data DataGenerator::Unordered(std::vector<uint8_t> payload,
|
||||
absl::string_view flags,
|
||||
const DataGeneratorOptions opts) {
|
||||
Data::IsBeginning is_beginning(flags.find('B') != std::string::npos);
|
||||
Data::IsEnd is_end(flags.find('E') != std::string::npos);
|
||||
|
||||
if (is_beginning) {
|
||||
fsn_ = FSN(0);
|
||||
} else {
|
||||
fsn_ = FSN(*fsn_ + 1);
|
||||
}
|
||||
MID message_id = opts.message_id.value_or(message_id_);
|
||||
Data ret = Data(opts.stream_id, SSN(0), message_id, fsn_, kPpid,
|
||||
std::move(payload), is_beginning, is_end, IsUnordered(true));
|
||||
if (is_end) {
|
||||
message_id_ = MID(*message_id + 1);
|
||||
}
|
||||
return ret;
|
||||
}
|
||||
} // namespace dcsctp
|
||||
59
net/dcsctp/testing/data_generator.h
Normal file
59
net/dcsctp/testing/data_generator.h
Normal file
@ -0,0 +1,59 @@
|
||||
/*
|
||||
* 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.
|
||||
*/
|
||||
#ifndef NET_DCSCTP_TESTING_DATA_GENERATOR_H_
|
||||
#define NET_DCSCTP_TESTING_DATA_GENERATOR_H_
|
||||
|
||||
#include <cstdint>
|
||||
#include <vector>
|
||||
|
||||
#include "absl/strings/string_view.h"
|
||||
#include "absl/types/optional.h"
|
||||
#include "api/array_view.h"
|
||||
#include "net/dcsctp/common/internal_types.h"
|
||||
#include "net/dcsctp/packet/data.h"
|
||||
|
||||
namespace dcsctp {
|
||||
|
||||
struct DataGeneratorOptions {
|
||||
StreamID stream_id = StreamID(1);
|
||||
absl::optional<MID> message_id = absl::nullopt;
|
||||
PPID ppid = PPID(53);
|
||||
};
|
||||
|
||||
// Generates Data with correct sequence numbers, and used only in unit tests.
|
||||
class DataGenerator {
|
||||
public:
|
||||
explicit DataGenerator(MID start_message_id = MID(0))
|
||||
: message_id_(start_message_id) {}
|
||||
|
||||
// Generates ordered "data" with the provided `payload` and flags, which can
|
||||
// contain "B" for setting the "is_beginning" flag, and/or "E" for setting the
|
||||
// "is_end" flag.
|
||||
Data Ordered(std::vector<uint8_t> payload,
|
||||
absl::string_view flags = "",
|
||||
const DataGeneratorOptions opts = {});
|
||||
|
||||
// Generates unordered "data" with the provided `payload` and flags, which can
|
||||
// contain "B" for setting the "is_beginning" flag, and/or "E" for setting the
|
||||
// "is_end" flag.
|
||||
Data Unordered(std::vector<uint8_t> payload,
|
||||
absl::string_view flags = "",
|
||||
const DataGeneratorOptions opts = {});
|
||||
|
||||
// Resets the Message ID identifier - simulating a "stream reset".
|
||||
void ResetStream() { message_id_ = MID(0); }
|
||||
|
||||
private:
|
||||
MID message_id_;
|
||||
FSN fsn_ = FSN(0);
|
||||
};
|
||||
} // namespace dcsctp
|
||||
|
||||
#endif // NET_DCSCTP_TESTING_DATA_GENERATOR_H_
|
||||
Reference in New Issue
Block a user