Rework on Camera behavior.

This commit is contained in:
Julien Wadel 2024-04-23 12:55:52 +02:00
parent eb804e499f
commit 7f3d774817
7 changed files with 110 additions and 59 deletions

View file

@ -51,77 +51,117 @@ CameraGui::CameraGui(QQuickItem *parent) : QQuickFramebufferObject(parent) {
CameraGui::~CameraGui() { CameraGui::~CameraGui() {
mustBeInMainThread("~" + getClassName()); mustBeInMainThread("~" + getClassName());
mRefreshTimer.stop(); mRefreshTimer.stop();
mIsDeleting = true;
setWindowIdLocation(None); setWindowIdLocation(None);
} }
QQuickFramebufferObject::Renderer *CameraGui::createRenderer() const { // Hack for Qt constness on create Renderer.
auto renderer = createRenderer(false); // We need to store the renderer in order to update the SDK filters with this renderer.
if (!renderer) { QMap<const CameraGui *, QQuickFramebufferObject::Renderer *> gRenderers;
lInfo() << log().arg("(%1) Setting Camera to Dummy, %2").arg(mQmlName).arg(getSourceLocation()); QMutex gRenderesLock;
QTimer::singleShot(1, this, &CameraGui::isNotReady);
renderer = new CameraDummy(); // Used to fill a renderer to avoid pushing a NULL. //-------------------------------------------------------------
/*if (getSourceLocation() != CorePreview)*/ QTimer::singleShot(1000, this, &CameraGui::requestNewRenderer);
// TODO : peut etre enelever le check sur le corepreview void CameraGui::refreshLastRenderer() {
} else QTimer::singleShot(1, this, &CameraGui::isReady); // Hack because of constness of createRenderer() gRenderesLock.lock();
return renderer; if (gRenderers.contains(this)) setRenderer(gRenderers[this]);
else clearRenderer();
updateSDKRenderer();
gRenderesLock.unlock();
} }
QQuickFramebufferObject::Renderer *CameraGui::createRenderer(bool resetWindowId) const { void CameraGui::setRenderer(QQuickFramebufferObject::Renderer *renderer) {
mLastRenderer = renderer;
}
void CameraGui::clearRenderer() {
mLastRenderer = nullptr;
}
QQuickFramebufferObject::Renderer *CameraGui::createRenderer() const {
QQuickFramebufferObject::Renderer *renderer = NULL; QQuickFramebufferObject::Renderer *renderer = NULL;
lDebug() << log().arg("CreateRenderer. Reset=") << resetWindowId; lDebug() << log().arg("CreateRenderer");
// A renderer is mandatory, we cannot wait async. // A renderer is mandatory, we cannot wait async.
switch (getSourceLocation()) { switch (getSourceLocation()) {
case CorePreview: { case CorePreview: {
if (resetWindowId) PreviewManager::getInstance()->unsubscribe(this); // if (resetWindowId) PreviewManager::getInstance()->unsubscribe(this);
else renderer = PreviewManager::getInstance()->subscribe(this); renderer = PreviewManager::getInstance()->subscribe(this);
//(QQuickFramebufferObject::Renderer *)CoreModel::getInstance()->getCore()->createNativePreviewWindowId();
} break; } break;
case Call: { case Call: {
auto f = [qmlName = mQmlName, callGui = mCallGui, &renderer, resetWindowId]() { App::postModelBlock([qmlName = mQmlName, callGui = mCallGui, &renderer]() {
auto call = callGui->getCore()->getModel()->getMonitor(); auto call = callGui->getCore()->getModel()->getMonitor();
if (call) { if (call) {
lInfo() << "[Camera] (" << qmlName << ") " << (resetWindowId ? "Resetting" : "Setting") lInfo() << "[Camera] (" << qmlName << ") Camera create from CallModel";
<< " Camera to CallModel"; renderer = (QQuickFramebufferObject::Renderer *)call->createNativeVideoWindowId();
if (resetWindowId) {
renderer = (QQuickFramebufferObject::Renderer *)call->getNativeVideoWindowId();
if (renderer) call->setNativeVideoWindowId(NULL);
} else {
renderer = (QQuickFramebufferObject::Renderer *)call->createNativeVideoWindowId();
if (renderer) call->setNativeVideoWindowId(renderer);
else {
renderer = (QQuickFramebufferObject::Renderer *)call->createNativeVideoWindowId();
}
}
} }
}; });
App::postModelBlock(f);
} break; } break;
case Device: { case Device: {
auto f = [qmlName = mQmlName, participantDeviceGui = mParticipantDeviceGui, &renderer, resetWindowId]() { App::postModelBlock([qmlName = mQmlName, participantDeviceGui = mParticipantDeviceGui, &renderer]() {
auto device = participantDeviceGui->getCore()->getModel()->getMonitor(); auto device = participantDeviceGui->getCore()->getModel()->getMonitor();
if (device) { if (device) {
lInfo() << "[Camera] (" << qmlName << ") " << (resetWindowId ? "Resetting" : "Setting") lInfo() << "[Camera] (" << qmlName << ") Camera create from ParticipantDeviceModel";
<< " Camera to ParticipantDeviceModel"; renderer = (QQuickFramebufferObject::Renderer *)device->createNativeVideoWindowId();
if (resetWindowId) {
renderer = (QQuickFramebufferObject::Renderer *)device->getNativeVideoWindowId();
if (renderer) device->setNativeVideoWindowId(NULL);
} else {
renderer = (QQuickFramebufferObject::Renderer *)device->createNativeVideoWindowId();
if (renderer) device->setNativeVideoWindowId(renderer);
}
} }
}; });
App::postModelBlock(f);
} break; } break;
default: { default: {
} }
} }
// Storing Qt renderer
gRenderesLock.lock();
gRenderers[this] = renderer;
gRenderesLock.unlock();
QTimer::singleShot(
1, this, &CameraGui::refreshLastRenderer); // Assign new renderer to the current CameraGui (bypassing constness)
if (!renderer) {
lInfo() << log().arg("(%1) Setting Camera to Dummy, %2").arg(mQmlName).arg(getSourceLocation());
QTimer::singleShot(1, this, &CameraGui::isNotReady);
renderer = new CameraDummy(); // Used to fill a renderer to avoid pushing a NULL.
QTimer::singleShot(1000, this, &CameraGui::requestNewRenderer);
} else QTimer::singleShot(1, this, &CameraGui::isReady); // Hack because of constness of createRenderer()
return renderer; return renderer;
} }
void CameraGui::resetWindowId() const { void CameraGui::updateSDKRenderer() {
createRenderer(true); updateSDKRenderer(mLastRenderer);
}
void CameraGui::updateSDKRenderer(QQuickFramebufferObject::Renderer *renderer) {
lDebug() << log().arg("Apply Qt Renderer to SDK") << renderer;
switch (getSourceLocation()) {
case CorePreview: {
} break;
case Call: {
App::postModelAsync([qmlName = mQmlName, callGui = mCallGui, renderer]() {
auto call = callGui->getCore()->getModel()->getMonitor();
if (call) {
lInfo() << "[Camera] (" << qmlName << ") Camera to CallModel";
call->setNativeVideoWindowId(renderer);
}
});
} break;
case Device: {
App::postModelAsync([qmlName = mQmlName, participantDeviceGui = mParticipantDeviceGui, renderer]() {
auto device = participantDeviceGui->getCore()->getModel()->getMonitor();
if (device) {
lInfo() << "[Camera] (" << qmlName << ") Camera to ParticipantDevice";
device->setNativeVideoWindowId(renderer);
}
});
} break;
default: {
}
}
}
void CameraGui::resetWindowId() {
updateSDKRenderer(nullptr);
} }
void CameraGui::checkVideoDefinition() { /* void CameraGui::checkVideoDefinition() { /*
if (mWindowIdLocation == WindowIdLocation::CorePreview) { if (mWindowIdLocation == WindowIdLocation::CorePreview) {
@ -201,15 +241,16 @@ void CameraGui::setWindowIdLocation(const WindowIdLocation &location) {
if (mWindowIdLocation != location) { if (mWindowIdLocation != location) {
lDebug() << log().arg("Update Window Id location from %2 to %3").arg(mWindowIdLocation).arg(location); lDebug() << log().arg("Update Window Id location from %2 to %3").arg(mWindowIdLocation).arg(location);
if (mWindowIdLocation == CorePreview) PreviewManager::getInstance()->unsubscribe(this); if (mWindowIdLocation == CorePreview) PreviewManager::getInstance()->unsubscribe(this);
else if (mWindowIdLocation != None) resetWindowId(); // Location change: Reset old window ID. // else if (mWindowIdLocation != None) resetWindowId(); // Location change: Reset old window ID.
resetWindowId();
mWindowIdLocation = location; mWindowIdLocation = location;
if (mWindowIdLocation == CorePreview) PreviewManager::getInstance()->subscribe(this); if (mWindowIdLocation == CorePreview) PreviewManager::getInstance()->subscribe(this);
update(); else updateSDKRenderer();
QTimer::singleShot(100, this, &CameraGui::requestNewRenderer); // QTimer::singleShot(100, this, &CameraGui::requestNewRenderer);
// if (mWindowIdLocation == WindowIdLocation::CorePreview) { // if (mWindowIdLocation == WindowIdLocation::CorePreview) {
// mLastVideoDefinition = // mLastVideoDefinition =
// CoreManager::getInstance()->getSettingsModel()->getCurrentPreviewVideoDefinition(); emit // CoreManager::getInstance()->getSettingsModel()->getCurrentPreviewVideoDefinition(); emit
// videoDefinitionChanged(); mLastVideoDefinitionChecker.start(); // videoDefinitionChanged(); mLastVideoDefinitionChecker.start();
// } else mLastVideoDefinitionChecker.stop(); // } else mLastVideoDefinitionChecker.stop();
} }
} }

View file

@ -49,9 +49,8 @@ public:
CameraGui(QQuickItem *parent = Q_NULLPTR); CameraGui(QQuickItem *parent = Q_NULLPTR);
virtual ~CameraGui(); virtual ~CameraGui();
QQuickFramebufferObject::Renderer *createRenderer() const override; QQuickFramebufferObject::Renderer *createRenderer() const override;
QQuickFramebufferObject::Renderer *createRenderer(bool resetWindowid) const;
Q_INVOKABLE void resetWindowId() const; // const to be used from createRenderer() Q_INVOKABLE void resetWindowId();
void checkVideoDefinition(); void checkVideoDefinition();
bool getIsReady() const; bool getIsReady() const;
@ -75,6 +74,12 @@ public:
void callStateChanged(LinphoneEnums::CallState state); void callStateChanged(LinphoneEnums::CallState state);
void setRenderer(QQuickFramebufferObject::Renderer *);
void refreshLastRenderer(); // Lookup in stocked renderer and link it.
void clearRenderer();
void updateSDKRenderer();
void updateSDKRenderer(QQuickFramebufferObject::Renderer *renderer);
signals: signals:
void requestNewRenderer(); void requestNewRenderer();
void isReadyChanged(bool isReady); void isReadyChanged(bool isReady);
@ -95,9 +100,10 @@ private:
CallGui *mCallGui = nullptr; CallGui *mCallGui = nullptr;
ParticipantDeviceGui *mParticipantDeviceGui = nullptr; ParticipantDeviceGui *mParticipantDeviceGui = nullptr;
QQuickFramebufferObject::Renderer *mLastRenderer = nullptr;
WindowIdLocation mWindowIdLocation = None; WindowIdLocation mWindowIdLocation = None;
mutable bool mIsWindowIdSet = false; mutable bool mIsWindowIdSet = false;
bool mIsDeleting = false;
DECLARE_ABSTRACT_OBJECT DECLARE_ABSTRACT_OBJECT
DECLARE_GUI_OBJECT DECLARE_GUI_OBJECT

View file

@ -46,6 +46,7 @@ PreviewManager *PreviewManager::getInstance() {
} }
} }
// Create a Renderer from SDK preview
QQuickFramebufferObject::Renderer *PreviewManager::subscribe(const CameraGui *candidate) { QQuickFramebufferObject::Renderer *PreviewManager::subscribe(const CameraGui *candidate) {
QQuickFramebufferObject::Renderer *renderer = nullptr; QQuickFramebufferObject::Renderer *renderer = nullptr;
mCounterMutex.lock(); mCounterMutex.lock();
@ -101,8 +102,7 @@ void PreviewManager::unsubscribe(const CameraGui *candidate) { // If nullptr, Us
mCandidates.erase(itCandidate); mCandidates.erase(itCandidate);
lDebug() << log().arg("Update") << mCandidates.first().first->getQmlName(); lDebug() << log().arg("Update") << mCandidates.first().first->getQmlName();
auto renderer = mCandidates.first().second; auto renderer = mCandidates.first().second;
if (!renderer) QTimer::singleShot(1, mCandidates.first().first, &CameraGui::requestNewRenderer); if (renderer)
else
App::postModelBlock([renderer = mCandidates.first().second]() { App::postModelBlock([renderer = mCandidates.first().second]() {
CoreModel::getInstance()->getCore()->setNativePreviewWindowId(renderer); CoreModel::getInstance()->getCore()->setNativePreviewWindowId(renderer);
}); });

View file

@ -83,7 +83,11 @@ void ParticipantDeviceCore::setSelf(QSharedPointer<ParticipantDeviceCore> me) {
}); });
mParticipantDeviceModelConnection->makeConnectToModel( mParticipantDeviceModelConnection->makeConnectToModel(
&ParticipantDeviceModel::stateChanged, [this](LinphoneEnums::ParticipantDeviceState state) { &ParticipantDeviceModel::stateChanged, [this](LinphoneEnums::ParticipantDeviceState state) {
mParticipantDeviceModelConnection->invokeToCore([this, state] { setState(state); }); mParticipantDeviceModelConnection->invokeToCore(
[this, state, isVideoEnabled = mParticipantDeviceModel->isVideoEnabled()] {
setState(state);
setIsVideoEnabled(isVideoEnabled);
});
}); });
mParticipantDeviceModelConnection->makeConnectToModel( mParticipantDeviceModelConnection->makeConnectToModel(
&ParticipantDeviceModel::streamCapabilityChanged, [this](linphone::StreamType) { &ParticipantDeviceModel::streamCapabilityChanged, [this](linphone::StreamType) {

View file

@ -88,7 +88,7 @@ Item {
onTriggered: {cameraLoader.reset = !cameraLoader.reset} onTriggered: {cameraLoader.reset = !cameraLoader.reset}
} }
active: mainItem.visible && mainItem.videoEnabled && !cameraLoader.reset active: mainItem.visible && mainItem.videoEnabled && !cameraLoader.reset
onActiveChanged: console.log("("+mainItem.qmlName+") Camera active " + active) onActiveChanged: console.log("("+mainItem.qmlName+") Camera active " + active +", visible="+mainItem.visible +", videoEnabled="+mainItem.videoEnabled +", reset="+cameraLoader.reset)
sourceComponent: cameraComponent sourceComponent: cameraComponent
} }
Component{ Component{

View file

@ -94,7 +94,7 @@ Item{
clip: true clip: true
delegate: Item{ // Spacing workaround delegate: Item{ // Spacing workaround
visible: $modelData && mainItem.callState != LinphoneEnums.CallState.End && mainItem.callState != LinphoneEnums.CallState.Released visible: $modelData && mainItem.callState != LinphoneEnums.CallState.End && mainItem.callState != LinphoneEnums.CallState.Released
&& $modelData.core.address != activeSpeakerSticker.address && $modelData.core.address != activeSpeakerSticker.address || false
height: visible ? (180 + 15) * DefaultStyle.dp : 0 height: visible ? (180 + 15) * DefaultStyle.dp : 0
width: 300 * DefaultStyle.dp width: 300 * DefaultStyle.dp
Sticker { Sticker {

View file

@ -21,11 +21,11 @@ Mosaic {
id: allDevices id: allDevices
qmlName: "G" qmlName: "G"
Component.onCompleted: console.log("Loaded : " +allDevices + " = " +allDevices.count) Component.onCompleted: console.log("Loaded : " +allDevices + " = " +allDevices.count)
} }
model: grid.call.core.isConference ? participantDevices: [0,1] model: grid.call.core.isConference ? participantDevices: [0,1]
delegate: Item{ delegate: Item{
id: avatarCell id: avatarCell
property ParticipantDeviceGui currentDevice: grid.call.core.isConference ? gridModel.participantDevices.getAt(index) : null property ParticipantDeviceGui currentDevice: index >= 0 && grid.call.core.isConference ? $modelData : null
onCurrentDeviceChanged: { onCurrentDeviceChanged: {
if(index < 0) cameraView.enabled = false // this is a delegate destruction. We need to stop camera before Qt change its currentDevice (and then, let CameraView to delete wrong renderer) if(index < 0) cameraView.enabled = false // this is a delegate destruction. We need to stop camera before Qt change its currentDevice (and then, let CameraView to delete wrong renderer)
} }