Wire up RTP keep-alive in ortc api.

webrtc/ortc/rtptransportcontrolleradapter.cc

 /*
  *  Copyright 2017 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.
  */
 
@@ skipping 111 matching lines @@
     DestroyVideoChannel();
   }
   // Call must be destroyed on the worker thread.
   worker_thread_->Invoke<void>(
       RTC_FROM_HERE,
       rtc::Bind(&RtpTransportControllerAdapter::Close_w, this));
 }
 
 RTCErrorOr<std::unique_ptr<RtpTransportInterface>>
 RtpTransportControllerAdapter::CreateProxiedRtpTransport(
-    const RtcpParameters& rtcp_parameters,
+    const RtpTransportParameters& parameters,
     PacketTransportInterface* rtp,
     PacketTransportInterface* rtcp) {
-  auto result =
-      RtpTransportAdapter::CreateProxied(rtcp_parameters, rtp, rtcp, this);
+  auto result = RtpTransportAdapter::CreateProxied(parameters, rtp, rtcp, this);
   if (result.ok()) {
     transport_proxies_.push_back(result.value().get());
     transport_proxies_.back()->GetInternal()->SignalDestroyed.connect(
         this, &RtpTransportControllerAdapter::OnRtpTransportDestroyed);
   }
   return result;
 }
 
 RTCErrorOr<std::unique_ptr<SrtpTransportInterface>>
 RtpTransportControllerAdapter::CreateProxiedSrtpTransport(
-    const RtcpParameters& rtcp_parameters,
+    const RtpTransportParameters& parameters,
     PacketTransportInterface* rtp,
     PacketTransportInterface* rtcp) {
   auto result =
-      RtpTransportAdapter::CreateSrtpProxied(rtcp_parameters, rtp, rtcp, this);
+      RtpTransportAdapter::CreateSrtpProxied(parameters, rtp, rtcp, this);
   if (result.ok()) {
     transport_proxies_.push_back(result.value().get());
     transport_proxies_.back()->GetInternal()->SignalDestroyed.connect(
         this, &RtpTransportControllerAdapter::OnRtpTransportDestroyed);
   }
   return result;
 }
 
 RTCErrorOr<std::unique_ptr<OrtcRtpSenderInterface>>
 RtpTransportControllerAdapter::CreateProxiedRtpSender(
@@ skipping 83 matching lines @@
                                             cricket::CA_ANSWER, nullptr)) {
         break;
       }
     }
     return RTCError::OK();
   } while (false);
   LOG_AND_RETURN_ERROR(RTCErrorType::INTERNAL_ERROR,
                        "Failed to apply new RTCP parameters.");
 }
 
+RTCError RtpTransportControllerAdapter::SetRtpTransportParameters(
+    const RtpTransportParameters& parameters) {
+  if (!call_->SetRtpKeepAliveConfig(parameters.keepalive)) {
+    LOG_AND_RETURN_ERROR(RTCErrorType::INTERNAL_ERROR,
+                         "Failed to apply new RTP transport parameters.");
+  }
+  return RTCError::OK();
+}
+
 RTCError RtpTransportControllerAdapter::ValidateAndApplyAudioSenderParameters(
     const RtpParameters& parameters,
     uint32_t* primary_ssrc) {
   RTC_DCHECK(voice_channel_);
   RTC_DCHECK(have_audio_sender_);
 
   auto codecs_result = ToCricketCodecs<cricket::AudioCodec>(parameters.codecs);
   if (!codecs_result.ok()) {
     return codecs_result.MoveError();
   }
 
   auto extensions_result =
       ToCricketRtpHeaderExtensions(parameters.header_extensions);
   if (!extensions_result.ok()) {
     return extensions_result.MoveError();
   }
 
   auto stream_params_result = MakeSendStreamParamsVec(
-      parameters.encodings, inner_audio_transport_->GetRtcpParameters().cname,
+      parameters.encodings, inner_audio_transport_->GetParameters().rtcp.cname,
       local_audio_description_);
   if (!stream_params_result.ok()) {
     return stream_params_result.MoveError();
   }
 
   // Check that audio/video sender aren't using the same IDs to refer to
   // different things, if they share the same transport.
   if (inner_audio_transport_ == inner_video_transport_) {
     RTCError err = CheckForIdConflicts(
         codecs_result.value(), extensions_result.value(),
@@ skipping 68 matching lines @@
     return codecs_result.MoveError();
   }
 
   auto extensions_result =
       ToCricketRtpHeaderExtensions(parameters.header_extensions);
   if (!extensions_result.ok()) {
     return extensions_result.MoveError();
   }
 
   auto stream_params_result = MakeSendStreamParamsVec(
-      parameters.encodings, inner_video_transport_->GetRtcpParameters().cname,
+      parameters.encodings, inner_video_transport_->GetParameters().rtcp.cname,
       local_video_description_);
   if (!stream_params_result.ok()) {
     return stream_params_result.MoveError();
   }
 
   // Check that audio/video sender aren't using the same IDs to refer to
   // different things, if they share the same transport.
   if (inner_audio_transport_ == inner_video_transport_) {
     RTCError err = CheckForIdConflicts(
         codecs_result.value(), extensions_result.value(),
@@ skipping 276 matching lines @@
                          "supported.");
   }
   RTCError err = MaybeSetCryptos(inner_transport, &local_audio_description_,
                                  &remote_audio_description_);
   if (!err.ok()) {
     return err;
   }
   // If setting new transport, extract its RTCP parameters and create voice
   // channel.
   if (!inner_audio_transport_) {
-    CopyRtcpParametersToDescriptions(inner_transport->GetRtcpParameters(),
+    CopyRtcpParametersToDescriptions(inner_transport->GetParameters().rtcp,
                                      &local_audio_description_,
                                      &remote_audio_description_);
     inner_audio_transport_ = inner_transport;
     CreateVoiceChannel();
   }
   have_audio_sender_ = true;
   sender->SignalDestroyed.connect(
       this, &RtpTransportControllerAdapter::OnAudioSenderDestroyed);
   return RTCError::OK();
 }
@@ skipping 14 matching lines @@
                          "supported.");
   }
   RTCError err = MaybeSetCryptos(inner_transport, &local_video_description_,
                                  &remote_video_description_);
   if (!err.ok()) {
     return err;
   }
   // If setting new transport, extract its RTCP parameters and create video
   // channel.
   if (!inner_video_transport_) {
-    CopyRtcpParametersToDescriptions(inner_transport->GetRtcpParameters(),
+    CopyRtcpParametersToDescriptions(inner_transport->GetParameters().rtcp,
                                      &local_video_description_,
                                      &remote_video_description_);
     inner_video_transport_ = inner_transport;
     CreateVideoChannel();
   }
   have_video_sender_ = true;
   sender->SignalDestroyed.connect(
       this, &RtpTransportControllerAdapter::OnVideoSenderDestroyed);
   return RTCError::OK();
 }
@@ skipping 14 matching lines @@
                          "supported.");
   }
   RTCError err = MaybeSetCryptos(inner_transport, &local_audio_description_,
                                  &remote_audio_description_);
   if (!err.ok()) {
     return err;
   }
   // If setting new transport, extract its RTCP parameters and create voice
   // channel.
   if (!inner_audio_transport_) {
-    CopyRtcpParametersToDescriptions(inner_transport->GetRtcpParameters(),
+    CopyRtcpParametersToDescriptions(inner_transport->GetParameters().rtcp,
                                      &local_audio_description_,
                                      &remote_audio_description_);
     inner_audio_transport_ = inner_transport;
     CreateVoiceChannel();
   }
   have_audio_receiver_ = true;
   receiver->SignalDestroyed.connect(
       this, &RtpTransportControllerAdapter::OnAudioReceiverDestroyed);
   return RTCError::OK();
 }
@@ skipping 14 matching lines @@
                          "supported.");
   }
   RTCError err = MaybeSetCryptos(inner_transport, &local_video_description_,
                                  &remote_video_description_);
   if (!err.ok()) {
     return err;
   }
   // If setting new transport, extract its RTCP parameters and create video
   // channel.
   if (!inner_video_transport_) {
-    CopyRtcpParametersToDescriptions(inner_transport->GetRtcpParameters(),
+    CopyRtcpParametersToDescriptions(inner_transport->GetParameters().rtcp,
                                      &local_video_description_,
                                      &remote_video_description_);
     inner_video_transport_ = inner_transport;
     CreateVideoChannel();
   }
   have_video_receiver_ = true;
   receiver->SignalDestroyed.connect(
       this, &RtpTransportControllerAdapter::OnVideoReceiverDestroyed);
   return RTCError::OK();
 }
@@ skipping 199 matching lines @@
     local_description->set_cryptos(cryptos);
 
     cryptos.clear();
     cryptos.push_back(*(rtp_transport->GetInternal()->send_key()));
     remote_description->set_cryptos(cryptos);
   }
   return RTCError::OK();
 }
 
 }  // namespace webrtc