RTCRtpTransceiver.cpp [plain text]
#include "config.h"
#include "RTCRtpTransceiver.h"
#if ENABLE(WEB_RTC)
#include <wtf/NeverDestroyed.h>
namespace WebCore {
RTCRtpTransceiver::RTCRtpTransceiver(Ref<RTCRtpSender>&& sender, Ref<RTCRtpReceiver>&& receiver, std::unique_ptr<RTCRtpTransceiverBackend>&& backend)
: m_direction(RTCRtpTransceiverDirection::Sendrecv)
, m_sender(WTFMove(sender))
, m_receiver(WTFMove(receiver))
, m_iceTransport(RTCIceTransport::create())
, m_backend(WTFMove(backend))
{
}
String RTCRtpTransceiver::mid() const
{
return m_backend ? m_backend->mid() : String { };
}
bool RTCRtpTransceiver::hasSendingDirection() const
{
return m_direction == RTCRtpTransceiverDirection::Sendrecv || m_direction == RTCRtpTransceiverDirection::Sendonly;
}
RTCRtpTransceiverDirection RTCRtpTransceiver::direction() const
{
if (!m_backend)
return m_direction;
return m_backend->direction();
}
Optional<RTCRtpTransceiverDirection> RTCRtpTransceiver::currentDirection() const
{
if (!m_backend)
return WTF::nullopt;
return m_backend->currentDirection();
}
void RTCRtpTransceiver::setDirection(RTCRtpTransceiverDirection direction)
{
m_direction = direction;
if (m_backend)
m_backend->setDirection(direction);
}
void RTCRtpTransceiver::enableSendingDirection()
{
if (m_direction == RTCRtpTransceiverDirection::Recvonly)
m_direction = RTCRtpTransceiverDirection::Sendrecv;
else if (m_direction == RTCRtpTransceiverDirection::Inactive)
m_direction = RTCRtpTransceiverDirection::Sendonly;
}
void RTCRtpTransceiver::disableSendingDirection()
{
if (m_direction == RTCRtpTransceiverDirection::Sendrecv)
m_direction = RTCRtpTransceiverDirection::Recvonly;
else if (m_direction == RTCRtpTransceiverDirection::Sendonly)
m_direction = RTCRtpTransceiverDirection::Inactive;
}
void RTCRtpTransceiver::stop()
{
if (m_stopped)
return;
m_stopped = true;
m_receiver->stop();
m_sender->stop();
if (m_backend)
m_backend->stop();
}
bool RTCRtpTransceiver::stopped() const
{
if (m_backend)
return m_backend->stopped();
return m_stopped;
}
void RtpTransceiverSet::append(Ref<RTCRtpTransceiver>&& transceiver)
{
m_transceivers.append(WTFMove(transceiver));
}
Vector<std::reference_wrapper<RTCRtpSender>> RtpTransceiverSet::senders() const
{
Vector<std::reference_wrapper<RTCRtpSender>> senders;
for (auto& transceiver : m_transceivers) {
if (transceiver->stopped())
continue;
senders.append(transceiver->sender());
}
return senders;
}
Vector<std::reference_wrapper<RTCRtpReceiver>> RtpTransceiverSet::receivers() const
{
Vector<std::reference_wrapper<RTCRtpReceiver>> receivers;
for (auto& transceiver : m_transceivers) {
if (transceiver->stopped())
continue;
receivers.append(transceiver->receiver());
}
return receivers;
}
}
#endif // ENABLE(WEB_RTC)