1 /*
2 * Copyright 2018 The WebRTC Project Authors. All rights reserved.
3 *
4 * Use of this source code is governed by a BSD-style license
5 * that can be found in the LICENSE file in the root of the source
6 * tree. An additional intellectual property rights grant can be found
7 * in the file PATENTS. All contributing project authors may
8 * be found in the AUTHORS file in the root of the source tree.
9 */
10
11 #include "p2p/base/regathering_controller.h"
12
13 #include "api/task_queue/pending_task_safety_flag.h"
14 #include "api/units/time_delta.h"
15
16 namespace webrtc {
17
BasicRegatheringController(const Config & config,cricket::IceTransportInternal * ice_transport,rtc::Thread * thread)18 BasicRegatheringController::BasicRegatheringController(
19 const Config& config,
20 cricket::IceTransportInternal* ice_transport,
21 rtc::Thread* thread)
22 : config_(config), ice_transport_(ice_transport), thread_(thread) {
23 RTC_DCHECK(thread_);
24 RTC_DCHECK_RUN_ON(thread_);
25 RTC_DCHECK(ice_transport_);
26 ice_transport_->SignalStateChanged.connect(
27 this, &BasicRegatheringController::OnIceTransportStateChanged);
28 ice_transport->SignalWritableState.connect(
29 this, &BasicRegatheringController::OnIceTransportWritableState);
30 ice_transport->SignalReceivingState.connect(
31 this, &BasicRegatheringController::OnIceTransportReceivingState);
32 ice_transport->SignalNetworkRouteChanged.connect(
33 this, &BasicRegatheringController::OnIceTransportNetworkRouteChanged);
34 }
35
~BasicRegatheringController()36 BasicRegatheringController::~BasicRegatheringController() {
37 RTC_DCHECK_RUN_ON(thread_);
38 }
39
Start()40 void BasicRegatheringController::Start() {
41 RTC_DCHECK_RUN_ON(thread_);
42 ScheduleRecurringRegatheringOnFailedNetworks();
43 }
44
SetConfig(const Config & config)45 void BasicRegatheringController::SetConfig(const Config& config) {
46 RTC_DCHECK_RUN_ON(thread_);
47 bool need_reschedule_on_failed_networks =
48 pending_regathering_ && (config_.regather_on_failed_networks_interval !=
49 config.regather_on_failed_networks_interval);
50 config_ = config;
51 if (need_reschedule_on_failed_networks) {
52 ScheduleRecurringRegatheringOnFailedNetworks();
53 }
54 }
55
56 void BasicRegatheringController::
ScheduleRecurringRegatheringOnFailedNetworks()57 ScheduleRecurringRegatheringOnFailedNetworks() {
58 RTC_DCHECK_RUN_ON(thread_);
59 RTC_DCHECK(config_.regather_on_failed_networks_interval >= 0);
60 // Reset pending_regathering_ to cancel any potentially pending tasks.
61 pending_regathering_.reset(new ScopedTaskSafety());
62
63 thread_->PostDelayedTask(
64 SafeTask(pending_regathering_->flag(),
65 [this]() {
66 RTC_DCHECK_RUN_ON(thread_);
67 // Only regather when the current session is in the CLEARED
68 // state (i.e., not running or stopped). It is only
69 // possible to enter this state when we gather continually,
70 // so there is an implicit check on continual gathering
71 // here.
72 if (allocator_session_ && allocator_session_->IsCleared()) {
73 allocator_session_->RegatherOnFailedNetworks();
74 }
75 ScheduleRecurringRegatheringOnFailedNetworks();
76 }),
77 TimeDelta::Millis(config_.regather_on_failed_networks_interval));
78 }
79
80 } // namespace webrtc
81