admin/webrtc_m130
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Keep state internally of connections added to P2PTransportChannel (#4/n)

Browse Source 
P2PTransportChannel currently relies on the ICE controller to keep track of this, even though P2PTransportChannel is actually supposed to hold the mutable connections.

Reading connections from the ICE controller also leaks some internal state from the ICE controller through the ordering of connections, which isn't strictly part of the interface. This change is a step towards fixing this.

This change is functionally no-op for now. The internal state will be used behind a field-trial in a future CL. That is also when some tests will be updated to work with the new internal state.

Bug: webrtc:14367, webrtc:1413
Change-Id: I6f8c5d805c780411fe940926f192fd2d6ce86d29
Reviewed-on: https://webrtc-review.googlesource.com/c/src/+/275081
Commit-Queue: Sameer Vijaykar <samvi@google.com>
Reviewed-by: Jonas Oreland <jonaso@webrtc.org>
Cr-Commit-Position: refs/heads/main@{#38080}
This commit is contained in:
Sameer Vijaykar 2022-09-14 11:49:47 +02:00 committed by WebRTC LUCI CQ
parent 80ed9b8eb9
commit 18408391ad
2 changed files with 16 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

17
p2p/base/p2p_transport_channel.cc
View File

@ -223,7 +223,7 @@ P2PTransportChannel::~P2PTransportChannel() {
std::vector<Connection*> copy(connections().begin(), connections().end());
for (Connection* connection : copy) {
connection->SignalDestroyed.disconnect(this);
ice_controller_->OnConnectionDestroyed(connection);
RemoveConnection(connection);
connection->Destroy();
}
resolvers_.clear();
@ -281,6 +281,7 @@ void P2PTransportChannel::AddConnection(Connection* connection) {
LogCandidatePairConfig(connection,
webrtc::IceCandidatePairConfigType::kAdded);
connections_.push_back(connection);
ice_controller_->AddConnection(connection);
}
@ -1693,7 +1694,7 @@ void P2PTransportChannel::RemoveConnectionForTest(Connection* connection) {
RTC_DCHECK_RUN_ON(network_thread_);
RTC_DCHECK(FindConnection(connection));
connection->SignalDestroyed.disconnect(this);
ice_controller_->OnConnectionDestroyed(connection);
RemoveConnection(connection);
RTC_DCHECK(!FindConnection(connection));
if (selected_connection_ == connection)
selected_connection_ = nullptr;
@ -2045,7 +2046,7 @@ void P2PTransportChannel::HandleAllTimedOut() {
update_selected_connection = true;
}
connection->SignalDestroyed.disconnect(this);
ice_controller_->OnConnectionDestroyed(connection);
RemoveConnection(connection);
connection->Destroy();
}
@ -2172,7 +2173,7 @@ void P2PTransportChannel::OnConnectionDestroyed(Connection* connection) {
// use it.
// Remove this connection from the list.
ice_controller_->OnConnectionDestroyed(connection);
RemoveConnection(connection);
RTC_LOG(LS_INFO) << ToString() << ": Removed connection " << connection
<< " (" << connections().size() << " remaining)";
@ -2193,6 +2194,14 @@ void P2PTransportChannel::OnConnectionDestroyed(Connection* connection) {
}
}
void P2PTransportChannel::RemoveConnection(const Connection* connection) {
RTC_DCHECK_RUN_ON(network_thread_);
auto it = absl::c_find(connections_, connection);
RTC_DCHECK(it != connections_.end());
connections_.erase(it);
ice_controller_->OnConnectionDestroyed(connection);
}
// When a port is destroyed, remove it from our list of ports to use for
// connection attempts.
void P2PTransportChannel::OnPortDestroyed(PortInterface* port) {

3
p2p/base/p2p_transport_channel.h
View File

@ -200,6 +200,8 @@ class RTC_EXPORT P2PTransportChannel : public IceTransportInternal {
int check_receiving_interval() const;
absl::optional<rtc::NetworkRoute> network_route() const override;
void RemoveConnection(const Connection* connection);
// Helper method used only in unittest.
rtc::DiffServCodePoint DefaultDscpValue() const;
@ -427,6 +429,7 @@ class RTC_EXPORT P2PTransportChannel : public IceTransportInternal {
std::vector<PortInterface*> pruned_ports_ RTC_GUARDED_BY(network_thread_);
Connection* selected_connection_ RTC_GUARDED_BY(network_thread_) = nullptr;
std::vector<Connection*> connections_ RTC_GUARDED_BY(network_thread_);
std::vector<RemoteCandidate> remote_candidates_
RTC_GUARDED_BY(network_thread_);