a6544377bc
This test drives the new tools_webrtc/remove_extra_namespace.py tool. Bug: None Change-Id: I9b590aa1213e4cace2d64d555f4dafd893f03606 Reviewed-on: https://webrtc-review.googlesource.com/c/src/+/327021 Reviewed-by: Mirko Bonadei <mbonadei@webrtc.org> Commit-Queue: Harald Alvestrand <hta@webrtc.org> Cr-Commit-Position: refs/heads/main@{#41141}
98 lines
3.1 KiB
C++
98 lines
3.1 KiB
C++
/*
|
|
* Copyright 2012 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 "pc/test/integration_test_helpers.h"
|
|
|
|
namespace webrtc {
|
|
|
|
PeerConnectionInterface::RTCOfferAnswerOptions IceRestartOfferAnswerOptions() {
|
|
PeerConnectionInterface::RTCOfferAnswerOptions options;
|
|
options.ice_restart = true;
|
|
return options;
|
|
}
|
|
|
|
void RemoveSsrcsAndMsids(cricket::SessionDescription* desc) {
|
|
for (ContentInfo& content : desc->contents()) {
|
|
content.media_description()->mutable_streams().clear();
|
|
}
|
|
desc->set_msid_supported(false);
|
|
desc->set_msid_signaling(0);
|
|
}
|
|
|
|
void RemoveSsrcsAndKeepMsids(cricket::SessionDescription* desc) {
|
|
for (ContentInfo& content : desc->contents()) {
|
|
std::string track_id;
|
|
std::vector<std::string> stream_ids;
|
|
if (!content.media_description()->streams().empty()) {
|
|
const StreamParams& first_stream =
|
|
content.media_description()->streams()[0];
|
|
track_id = first_stream.id;
|
|
stream_ids = first_stream.stream_ids();
|
|
}
|
|
content.media_description()->mutable_streams().clear();
|
|
StreamParams new_stream;
|
|
new_stream.id = track_id;
|
|
new_stream.set_stream_ids(stream_ids);
|
|
content.media_description()->AddStream(new_stream);
|
|
}
|
|
}
|
|
|
|
int FindFirstMediaStatsIndexByKind(
|
|
const std::string& kind,
|
|
const std::vector<const RTCInboundRtpStreamStats*>& inbound_rtps) {
|
|
for (size_t i = 0; i < inbound_rtps.size(); i++) {
|
|
if (*inbound_rtps[i]->kind == kind) {
|
|
return i;
|
|
}
|
|
}
|
|
return -1;
|
|
}
|
|
|
|
void ReplaceFirstSsrc(StreamParams& stream, uint32_t ssrc) {
|
|
stream.ssrcs[0] = ssrc;
|
|
for (auto& group : stream.ssrc_groups) {
|
|
group.ssrcs[0] = ssrc;
|
|
}
|
|
}
|
|
|
|
TaskQueueMetronome::TaskQueueMetronome(TimeDelta tick_period)
|
|
: tick_period_(tick_period) {}
|
|
|
|
TaskQueueMetronome::~TaskQueueMetronome() {
|
|
RTC_DCHECK_RUN_ON(&sequence_checker_);
|
|
}
|
|
void TaskQueueMetronome::RequestCallOnNextTick(
|
|
absl::AnyInvocable<void() &&> callback) {
|
|
RTC_DCHECK_RUN_ON(&sequence_checker_);
|
|
callbacks_.push_back(std::move(callback));
|
|
// Only schedule a tick callback for the first `callback` addition.
|
|
// Schedule on the current task queue to comply with RequestCallOnNextTick
|
|
// requirements.
|
|
if (callbacks_.size() == 1) {
|
|
TaskQueueBase::Current()->PostDelayedTask(
|
|
SafeTask(safety_.flag(),
|
|
[this] {
|
|
RTC_DCHECK_RUN_ON(&sequence_checker_);
|
|
std::vector<absl::AnyInvocable<void() &&>> callbacks;
|
|
callbacks_.swap(callbacks);
|
|
for (auto& callback : callbacks)
|
|
std::move(callback)();
|
|
}),
|
|
tick_period_);
|
|
}
|
|
}
|
|
|
|
TimeDelta TaskQueueMetronome::TickPeriod() const {
|
|
RTC_DCHECK_RUN_ON(&sequence_checker_);
|
|
return tick_period_;
|
|
}
|
|
|
|
} // namespace webrtc
|