97 lines
3.4 KiB
C++
97 lines
3.4 KiB
C++
/* -*- Mode: C++; tab-width: 2; indent-tabs-mode: nil; c-basic-offset: 2 -*- */
|
|
/* vim:set ts=2 sw=2 sts=2 et cindent: */
|
|
/* This Source Code Form is subject to the terms of the Mozilla Public
|
|
* License, v. 2.0. If a copy of the MPL was not distributed with this file,
|
|
* You can obtain one at http://mozilla.org/MPL/2.0/. */
|
|
|
|
#include "WebrtcCallWrapper.h"
|
|
|
|
#include "jsapi/PeerConnectionCtx.h"
|
|
#include "libwebrtcglue/WebrtcEnvironmentWrapper.h"
|
|
#include "MediaConduitInterface.h"
|
|
|
|
// libwebrtc includes
|
|
#include "call/rtp_transport_controller_send_factory.h"
|
|
|
|
namespace mozilla {
|
|
|
|
/* static */ RefPtr<WebrtcCallWrapper> WebrtcCallWrapper::Create(
|
|
RefPtr<WebrtcEnvironmentWrapper> aEnvWrapper,
|
|
const dom::RTCStatsTimestampMaker& aTimestampMaker,
|
|
UniquePtr<media::ShutdownBlockingTicket> aShutdownTicket,
|
|
const RefPtr<SharedWebrtcState>& aSharedState) {
|
|
auto videoBitrateAllocatorFactory =
|
|
WrapUnique(webrtc::CreateBuiltinVideoBitrateAllocatorFactory().release());
|
|
RefPtr<WebrtcCallWrapper> wrapper = new WebrtcCallWrapper(
|
|
aSharedState, std::move(videoBitrateAllocatorFactory),
|
|
std::move(aEnvWrapper), aTimestampMaker, std::move(aShutdownTicket));
|
|
|
|
wrapper->mCallThread->Dispatch(
|
|
NS_NewRunnableFunction(__func__, [wrapper, aSharedState] {
|
|
webrtc::CallConfig config(wrapper->mEnvWrapper->Environment(), nullptr);
|
|
config.audio_state =
|
|
webrtc::AudioState::Create(aSharedState->mAudioStateConfig);
|
|
wrapper->SetCall(
|
|
WrapUnique(webrtc::Call::Create(std::move(config)).release()));
|
|
}));
|
|
|
|
return wrapper;
|
|
}
|
|
|
|
void WebrtcCallWrapper::SetCall(UniquePtr<webrtc::Call> aCall) {
|
|
MOZ_ASSERT(mCallThread->IsOnCurrentThread());
|
|
MOZ_ASSERT(!mCall);
|
|
mCall = std::move(aCall);
|
|
}
|
|
|
|
webrtc::Call* WebrtcCallWrapper::Call() const {
|
|
MOZ_ASSERT(mCallThread->IsOnCurrentThread());
|
|
return mCall.get();
|
|
}
|
|
|
|
void WebrtcCallWrapper::UnsetRemoteSSRC(uint32_t aSsrc) {
|
|
MOZ_ASSERT(mCallThread->IsOnCurrentThread());
|
|
for (const auto& conduit : mConduits) {
|
|
conduit->UnsetRemoteSSRC(aSsrc);
|
|
}
|
|
}
|
|
|
|
void WebrtcCallWrapper::RegisterConduit(MediaSessionConduit* conduit) {
|
|
MOZ_ASSERT(mCallThread->IsOnCurrentThread());
|
|
mConduits.insert(conduit);
|
|
}
|
|
|
|
void WebrtcCallWrapper::UnregisterConduit(MediaSessionConduit* conduit) {
|
|
MOZ_ASSERT(mCallThread->IsOnCurrentThread());
|
|
mConduits.erase(conduit);
|
|
}
|
|
|
|
void WebrtcCallWrapper::Destroy() {
|
|
MOZ_ASSERT(mCallThread->IsOnCurrentThread());
|
|
mCall = nullptr;
|
|
mShutdownTicket = nullptr;
|
|
}
|
|
|
|
const dom::RTCStatsTimestampMaker& WebrtcCallWrapper::GetTimestampMaker()
|
|
const {
|
|
return mClock.mTimestampMaker;
|
|
}
|
|
|
|
WebrtcCallWrapper::~WebrtcCallWrapper() { MOZ_ASSERT(!mCall); }
|
|
|
|
WebrtcCallWrapper::WebrtcCallWrapper(
|
|
RefPtr<SharedWebrtcState> aSharedState,
|
|
UniquePtr<webrtc::VideoBitrateAllocatorFactory>
|
|
aVideoBitrateAllocatorFactory,
|
|
RefPtr<WebrtcEnvironmentWrapper> aEnvWrapper,
|
|
const dom::RTCStatsTimestampMaker& aTimestampMaker,
|
|
UniquePtr<media::ShutdownBlockingTicket> aShutdownTicket)
|
|
: mSharedState(std::move(aSharedState)),
|
|
mClock(aTimestampMaker),
|
|
mShutdownTicket(std::move(aShutdownTicket)),
|
|
mCallThread(mSharedState->mCallWorkerThread),
|
|
mAudioDecoderFactory(mSharedState->mAudioDecoderFactory),
|
|
mVideoBitrateAllocatorFactory(std::move(aVideoBitrateAllocatorFactory)),
|
|
mEnvWrapper(std::move(aEnvWrapper)) {}
|
|
|
|
} // namespace mozilla
|