@ -48,11 +48,11 @@
@@ -48,11 +48,11 @@
* @ brief Keeps sources for users in group calls .
*/
ToxCall : : ToxCall ( bool VideoEnabled , CoreAV & av , IAudioControl & audio )
: av { & av }
, audio ( audio )
, videoEnabled { VideoEnabled }
, audioSource ( audio . makeSource ( ) )
ToxCall : : ToxCall ( bool VideoEnabled_ , CoreAV & av_ , IAudioControl & audio_ )
: av { & av_ }
, audio ( audio_ )
, videoEnabled { VideoEnabled_ }
, audioSource ( audio_ . makeSource ( ) )
{ }
ToxCall : : ~ ToxCall ( )
@ -118,20 +118,20 @@ CoreVideoSource* ToxCall::getVideoSource() const
@@ -118,20 +118,20 @@ CoreVideoSource* ToxCall::getVideoSource() const
return videoSource ;
}
ToxFriendCall : : ToxFriendCall ( uint32_t FriendNum , bool VideoEnabled , CoreAV & av , IAudioControl & audio )
: ToxCall ( VideoEnabled , av , audio )
, sink ( audio . makeSink ( ) )
ToxFriendCall : : ToxFriendCall ( uint32_t FriendNum , bool VideoEnabled , CoreAV & av_ , IAudioControl & audio_ )
: ToxCall ( VideoEnabled , av_ , audio_ )
, sink ( audio_ . makeSink ( ) )
, friendId { FriendNum }
{
connect ( audioSource . get ( ) , & IAudioSource : : frameAvailable , this ,
[ this ] ( const int16_t * pcm , size_t samples , uint8_t chans , uint32_t rate ) {
this - > av - > sendCallAudio ( this - > friendId , pcm , samples , chans , rate ) ;
av - > sendCallAudio ( friendId , pcm , samples , chans , rate ) ;
} ) ;
connect ( audioSource . get ( ) , & IAudioSource : : invalidated , this , & ToxFriendCall : : onAudioSourceInvalidated ) ;
if ( sink ) {
audioSinkInvalid = sink - > connectTo_invalidated ( this , [ this ] ( ) { this - > onAudioSinkInvalidated ( ) ; } ) ;
audioSinkInvalid = sink - > connectTo_invalidated ( this , [ this ] ( ) { onAudioSinkInvalidated ( ) ; } ) ;
}
// register video
@ -144,8 +144,8 @@ ToxFriendCall::ToxFriendCall(uint32_t FriendNum, bool VideoEnabled, CoreAV& av,
@@ -144,8 +144,8 @@ ToxFriendCall::ToxFriendCall(uint32_t FriendNum, bool VideoEnabled, CoreAV& av,
}
source . subscribe ( ) ;
videoInConn = QObject : : connect ( & source , & VideoSource : : frameAvailable ,
[ & av , FriendNum ] ( std : : shared_ptr < VideoFrame > frame ) {
av . sendCallVideo ( FriendNum , frame ) ;
[ & av_ , FriendNum ] ( std : : shared_ptr < VideoFrame > frame ) {
av_ . sendCallVideo ( FriendNum , frame ) ;
} ) ;
if ( ! videoInConn ) {
qDebug ( ) < < " Video connection not working " ;
@ -163,7 +163,7 @@ void ToxFriendCall::onAudioSourceInvalidated()
@@ -163,7 +163,7 @@ void ToxFriendCall::onAudioSourceInvalidated()
auto newSrc = audio . makeSource ( ) ;
connect ( newSrc . get ( ) , & IAudioSource : : frameAvailable , this ,
[ this ] ( const int16_t * pcm , size_t samples , uint8_t chans , uint32_t rate ) {
this - > av - > sendCallAudio ( this - > friendId , pcm , samples , chans , rate ) ;
av - > sendCallAudio ( friendId , pcm , samples , chans , rate ) ;
} ) ;
audioSource = std : : move ( newSrc ) ;
@ -175,7 +175,7 @@ void ToxFriendCall::onAudioSinkInvalidated()
@@ -175,7 +175,7 @@ void ToxFriendCall::onAudioSinkInvalidated()
auto newSink = audio . makeSink ( ) ;
if ( newSink ) {
audioSinkInvalid = newSink - > connectTo_invalidated ( this , [ this ] ( ) { this - > onAudioSinkInvalidated ( ) ; } ) ;
audioSinkInvalid = newSink - > connectTo_invalidated ( this , [ this ] ( ) { onAudioSinkInvalidated ( ) ; } ) ;
}
sink = std : : move ( newSink ) ;
@ -199,18 +199,18 @@ void ToxFriendCall::playAudioBuffer(const int16_t* data, int samples, unsigned c
@@ -199,18 +199,18 @@ void ToxFriendCall::playAudioBuffer(const int16_t* data, int samples, unsigned c
}
}
ToxGroupCall : : ToxGroupCall ( const Group & group , CoreAV & av , IAudioControl & audio )
: ToxCall ( false , av , audio )
, group { group }
ToxGroupCall : : ToxGroupCall ( const Group & group_ , CoreAV & av_ , IAudioControl & audio_ )
: ToxCall ( false , av_ , audio_ )
, group { group_ }
{
// register audio
connect ( audioSource . get ( ) , & IAudioSource : : frameAvailable , this ,
[ this ] ( const int16_t * pcm , size_t samples , uint8_t chans , uint32_t rate ) {
if ( this - > group . getPeersCount ( ) < = 1 ) {
if ( group . getPeersCount ( ) < = 1 ) {
return ;
}
this - > av - > sendGroupCallAudio ( this - > group . getId ( ) , pcm , samples , chans , rate ) ;
av - > sendGroupCallAudio ( group . getId ( ) , pcm , samples , chans , rate ) ;
} ) ;
connect ( audioSource . get ( ) , & IAudioSource : : invalidated , this , & ToxGroupCall : : onAudioSourceInvalidated ) ;
@ -227,11 +227,11 @@ void ToxGroupCall::onAudioSourceInvalidated()
@@ -227,11 +227,11 @@ void ToxGroupCall::onAudioSourceInvalidated()
auto newSrc = audio . makeSource ( ) ;
connect ( audioSource . get ( ) , & IAudioSource : : frameAvailable ,
[ this ] ( const int16_t * pcm , size_t samples , uint8_t chans , uint32_t rate ) {
if ( this - > group . getPeersCount ( ) < = 1 ) {
if ( group . getPeersCount ( ) < = 1 ) {
return ;
}
this - > av - > sendGroupCallAudio ( this - > group . getId ( ) , pcm , samples , chans , rate ) ;
av - > sendGroupCallAudio ( group . getId ( ) , pcm , samples , chans , rate ) ;
} ) ;
audioSource = std : : move ( newSrc ) ;
@ -266,7 +266,7 @@ void ToxGroupCall::addPeer(ToxPk peerId)
@@ -266,7 +266,7 @@ void ToxGroupCall::addPeer(ToxPk peerId)
QMetaObject : : Connection con ;
if ( newSink ) {
con = newSink - > connectTo_invalidated ( this , [ this , peerId ] ( ) { this - > onAudioSinkInvalidated ( peerId ) ; } ) ;
con = newSink - > connectTo_invalidated ( this , [ this , peerId ] ( ) { onAudioSinkInvalidated ( peerId ) ; } ) ;
}
peers . emplace ( peerId , std : : move ( newSink ) ) ;