2016-10-17 18:03:51 -04:00
///////////////////////////////////////////////////////////////////////////////////
// Copyright (C) 2016 Edouard Griffiths, F4EXB //
// //
// This program is free software; you can redistribute it and/or modify //
// it under the terms of the GNU General Public License as published by //
// the Free Software Foundation as version 3 of the License, or //
// //
// This program is distributed in the hope that it will be useful, //
// but WITHOUT ANY WARRANTY; without even the implied warranty of //
// MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the //
// GNU General Public License V3 for more details. //
// //
// You should have received a copy of the GNU General Public License //
// along with this program. If not, see <http://www.gnu.org/licenses/>. //
///////////////////////////////////////////////////////////////////////////////////
2017-09-25 18:22:08 -04:00
# include <plugin/plugininstancegui.h>
2016-10-17 18:03:51 -04:00
# include "device/devicesinkapi.h"
2016-12-29 06:41:10 -05:00
# include "device/devicesourceapi.h"
2017-09-17 11:35:03 -04:00
# include "dsp/devicesamplesink.h"
2016-10-17 18:03:51 -04:00
# include "plugin/pluginapi.h"
# include "plugin/plugininterface.h"
# include "gui/glspectrum.h"
# include "gui/channelwindow.h"
# include "mainwindow.h"
# include "settings/preset.h"
2017-09-14 07:55:57 -04:00
// TODO: extract GUI dependencies in a separate object
2016-10-17 18:03:51 -04:00
DeviceSinkAPI : : DeviceSinkAPI ( MainWindow * mainWindow ,
int deviceTabIndex ,
DSPDeviceSinkEngine * deviceSinkEngine ,
GLSpectrum * glSpectrum ,
ChannelWindow * channelWindow ) :
m_deviceTabIndex ( deviceTabIndex ) ,
m_deviceSinkEngine ( deviceSinkEngine ) ,
m_spectrum ( glSpectrum ) ,
m_channelWindow ( channelWindow ) ,
m_sampleSinkSequence ( 0 ) ,
2017-09-14 19:49:18 -04:00
m_pluginInterface ( 0 ) ,
2017-09-03 14:24:17 -04:00
m_sampleSinkPluginInstanceUI ( 0 ) ,
2017-07-03 02:59:48 -04:00
m_buddySharedPtr ( 0 ) ,
2017-09-14 07:55:57 -04:00
m_isBuddyLeader ( false ) ,
m_masterTimer ( mainWindow - > getMasterTimer ( ) ) // TODO: get master timer directly not from main window
2016-10-17 18:03:51 -04:00
{
}
DeviceSinkAPI : : ~ DeviceSinkAPI ( )
{
}
2016-10-24 12:06:44 -04:00
void DeviceSinkAPI : : addSpectrumSink ( BasebandSampleSink * spectrumSink )
2016-10-17 18:03:51 -04:00
{
2016-10-24 12:06:44 -04:00
m_deviceSinkEngine - > addSpectrumSink ( spectrumSink ) ;
2016-10-17 18:03:51 -04:00
}
2016-10-24 12:06:44 -04:00
void DeviceSinkAPI : : removeSpectrumSink ( BasebandSampleSink * spectrumSink )
2016-10-17 18:03:51 -04:00
{
2016-10-24 12:06:44 -04:00
m_deviceSinkEngine - > removeSpectrumSink ( spectrumSink ) ;
2016-10-17 18:03:51 -04:00
}
void DeviceSinkAPI : : addSource ( BasebandSampleSource * source )
{
m_deviceSinkEngine - > addSource ( source ) ;
}
void DeviceSinkAPI : : removeSource ( BasebandSampleSource * source )
{
m_deviceSinkEngine - > removeSource ( source ) ;
}
void DeviceSinkAPI : : addThreadedSource ( ThreadedBasebandSampleSource * source )
{
m_deviceSinkEngine - > addThreadedSource ( source ) ;
}
void DeviceSinkAPI : : removeThreadedSource ( ThreadedBasebandSampleSource * source )
{
m_deviceSinkEngine - > removeThreadedSource ( source ) ;
}
2016-12-26 09:26:25 -05:00
uint32_t DeviceSinkAPI : : getNumberOfSources ( )
{
return m_deviceSinkEngine - > getNumberOfSources ( ) ;
}
2017-09-16 05:34:25 -04:00
void DeviceSinkAPI : : setSampleSink ( DeviceSampleSink * sink )
2016-10-17 18:03:51 -04:00
{
m_deviceSinkEngine - > setSink ( sink ) ;
}
2017-09-16 05:34:25 -04:00
DeviceSampleSink * DeviceSinkAPI : : getSampleSink ( )
{
return m_deviceSinkEngine - > getSink ( ) ;
}
2016-10-17 18:03:51 -04:00
bool DeviceSinkAPI : : initGeneration ( )
{
return m_deviceSinkEngine - > initGeneration ( ) ;
}
bool DeviceSinkAPI : : startGeneration ( )
{
return m_deviceSinkEngine - > startGeneration ( ) ;
}
void DeviceSinkAPI : : stopGeneration ( )
{
m_deviceSinkEngine - > stopGeneration ( ) ;
}
DSPDeviceSinkEngine : : State DeviceSinkAPI : : state ( ) const
{
return m_deviceSinkEngine - > state ( ) ;
}
QString DeviceSinkAPI : : errorMessage ( )
{
return m_deviceSinkEngine - > errorMessage ( ) ;
}
uint DeviceSinkAPI : : getDeviceUID ( ) const
{
return m_deviceSinkEngine - > getUID ( ) ;
}
2017-09-13 17:42:28 -04:00
MessageQueue * DeviceSinkAPI : : getDeviceEngineInputMessageQueue ( )
2016-10-17 18:03:51 -04:00
{
return m_deviceSinkEngine - > getInputMessageQueue ( ) ;
}
2017-09-17 11:35:03 -04:00
MessageQueue * DeviceSinkAPI : : getSampleSinkInputMessageQueue ( )
2016-10-17 18:03:51 -04:00
{
2017-09-17 11:35:03 -04:00
return getSampleSink ( ) - > getInputMessageQueue ( ) ;
}
MessageQueue * DeviceSinkAPI : : getSampleSinkGUIMessageQueue ( )
{
return getSampleSink ( ) - > getMessageQueueToGUI ( ) ;
2016-10-17 18:03:51 -04:00
}
GLSpectrum * DeviceSinkAPI : : getSpectrum ( )
{
return m_spectrum ;
}
void DeviceSinkAPI : : addChannelMarker ( ChannelMarker * channelMarker )
{
m_spectrum - > addChannelMarker ( channelMarker ) ;
}
void DeviceSinkAPI : : addRollupWidget ( QWidget * widget )
{
m_channelWindow - > addRollupWidget ( widget ) ;
}
2016-12-29 06:41:10 -05:00
void DeviceSinkAPI : : setHardwareId ( const QString & id )
{
m_hardwareId = id ;
}
2016-10-17 18:03:51 -04:00
void DeviceSinkAPI : : setSampleSinkId ( const QString & id )
{
m_sampleSinkId = id ;
}
2017-09-16 05:34:25 -04:00
void DeviceSinkAPI : : resetSampleSinkId ( )
{
m_sampleSinkId . clear ( ) ;
}
2016-10-17 18:03:51 -04:00
void DeviceSinkAPI : : setSampleSinkSerial ( const QString & serial )
{
m_sampleSinkSerial = serial ;
}
2017-09-14 19:49:18 -04:00
void DeviceSinkAPI : : setSampleSinkDisplayName ( const QString & name )
{
m_sampleSinkDisplayName = name ;
}
2016-10-17 18:03:51 -04:00
void DeviceSinkAPI : : setSampleSinkSequence ( int sequence )
{
m_sampleSinkSequence = sequence ;
m_deviceSinkEngine - > setSinkSequence ( sequence ) ;
}
2017-09-15 12:48:30 -04:00
void DeviceSinkAPI : : setSampleSinkPluginInterface ( PluginInterface * iface )
2017-09-14 19:49:18 -04:00
{
2017-09-15 12:48:30 -04:00
m_pluginInterface = iface ;
2017-09-14 19:49:18 -04:00
}
2017-09-25 18:22:08 -04:00
void DeviceSinkAPI : : setSampleSinkPluginInstanceUI ( PluginInstanceGUI * gui )
2016-10-17 18:03:51 -04:00
{
2017-09-03 14:24:17 -04:00
m_sampleSinkPluginInstanceUI = gui ;
2016-10-17 18:03:51 -04:00
}
2017-09-25 18:22:08 -04:00
void DeviceSinkAPI : : registerChannelInstance ( const QString & channelName , PluginInstanceGUI * pluginGUI )
2016-10-17 18:03:51 -04:00
{
m_channelInstanceRegistrations . append ( ChannelInstanceRegistration ( channelName , pluginGUI ) ) ;
renameChannelInstances ( ) ;
}
2017-09-25 18:22:08 -04:00
void DeviceSinkAPI : : removeChannelInstance ( PluginInstanceGUI * pluginGUI )
2016-10-17 18:03:51 -04:00
{
for ( ChannelInstanceRegistrations : : iterator it = m_channelInstanceRegistrations . begin ( ) ; it ! = m_channelInstanceRegistrations . end ( ) ; + + it )
{
if ( it - > m_gui = = pluginGUI )
{
m_channelInstanceRegistrations . erase ( it ) ;
break ;
}
}
renameChannelInstances ( ) ;
}
void DeviceSinkAPI : : renameChannelInstances ( )
{
for ( int i = 0 ; i < m_channelInstanceRegistrations . count ( ) ; i + + )
{
m_channelInstanceRegistrations [ i ] . m_gui - > setName ( QString ( " %1:%2 " ) . arg ( m_channelInstanceRegistrations [ i ] . m_channelName ) . arg ( i ) ) ;
}
}
2017-09-16 05:34:25 -04:00
void DeviceSinkAPI : : freeChannels ( )
2016-10-17 18:03:51 -04:00
{
for ( int i = 0 ; i < m_channelInstanceRegistrations . count ( ) ; i + + )
{
qDebug ( " DeviceSinkAPI::freeAll: destroying channel [%s] " , qPrintable ( m_channelInstanceRegistrations [ i ] . m_channelName ) ) ;
m_channelInstanceRegistrations [ i ] . m_gui - > destroy ( ) ;
}
}
void DeviceSinkAPI : : loadSinkSettings ( const Preset * preset )
{
2016-10-18 18:07:42 -04:00
if ( preset - > isSourcePreset ( ) )
2016-10-17 18:03:51 -04:00
{
2016-10-22 04:10:17 -04:00
qDebug ( " DeviceSinkAPI::loadSinkSettings: Preset [%s | %s] is not a sink preset " , qPrintable ( preset - > getGroup ( ) ) , qPrintable ( preset - > getDescription ( ) ) ) ;
2016-10-18 18:07:42 -04:00
}
else
{
2016-10-22 04:10:17 -04:00
qDebug ( " DeviceSinkAPI::loadSinkSettings: Loading preset [%s | %s] " , qPrintable ( preset - > getGroup ( ) ) , qPrintable ( preset - > getDescription ( ) ) ) ;
2016-10-17 18:03:51 -04:00
2017-09-03 14:24:17 -04:00
if ( m_sampleSinkPluginInstanceUI ! = 0 )
2016-10-17 18:03:51 -04:00
{
2016-10-18 18:07:42 -04:00
const QByteArray * sourceConfig = preset - > findBestDeviceConfig ( m_sampleSinkId , m_sampleSinkSerial , m_sampleSinkSequence ) ;
2016-10-17 18:03:51 -04:00
2016-10-18 18:07:42 -04:00
if ( sourceConfig ! = 0 )
{
2016-10-22 04:10:17 -04:00
qDebug ( " DeviceSinkAPI::loadSinkSettings: deserializing sink: %s " , qPrintable ( m_sampleSinkId ) ) ;
2017-09-03 14:24:17 -04:00
m_sampleSinkPluginInstanceUI - > deserialize ( * sourceConfig ) ;
2016-10-18 18:07:42 -04:00
}
qint64 centerFrequency = preset - > getCenterFrequency ( ) ;
2017-09-03 14:24:17 -04:00
m_sampleSinkPluginInstanceUI - > setCenterFrequency ( centerFrequency ) ;
2016-10-18 18:07:42 -04:00
}
2016-10-17 18:03:51 -04:00
}
}
void DeviceSinkAPI : : saveSinkSettings ( Preset * preset )
{
2016-10-18 18:07:42 -04:00
if ( preset - > isSourcePreset ( ) )
2016-10-17 18:03:51 -04:00
{
2016-10-18 18:07:42 -04:00
qDebug ( " DeviceSinkAPI::saveSinkSettings: not a sink preset " ) ;
}
else
{
2017-09-03 14:24:17 -04:00
if ( m_sampleSinkPluginInstanceUI ! = NULL )
2016-10-18 18:07:42 -04:00
{
2017-09-03 14:24:17 -04:00
qDebug ( " DeviceSinkAPI::saveSourceSettings: %s saved " , qPrintable ( m_sampleSinkPluginInstanceUI - > getName ( ) ) ) ;
preset - > addOrUpdateDeviceConfig ( m_sampleSinkId , m_sampleSinkSerial , m_sampleSinkSequence , m_sampleSinkPluginInstanceUI - > serialize ( ) ) ;
preset - > setCenterFrequency ( m_sampleSinkPluginInstanceUI - > getCenterFrequency ( ) ) ;
2016-10-18 18:07:42 -04:00
}
2016-10-22 04:10:17 -04:00
else
{
qDebug ( " DeviceSinkAPI::saveSinkSettings: no sink " ) ;
}
2016-10-17 18:03:51 -04:00
}
}
void DeviceSinkAPI : : loadChannelSettings ( const Preset * preset , PluginAPI * pluginAPI )
{
2016-10-18 18:07:42 -04:00
if ( preset - > isSourcePreset ( ) )
{
2016-10-22 04:10:17 -04:00
qDebug ( " DeviceSinkAPI::loadChannelSettings: Loading preset [%s | %s] not a sink preset " , qPrintable ( preset - > getGroup ( ) ) , qPrintable ( preset - > getDescription ( ) ) ) ;
2016-10-18 18:07:42 -04:00
}
else
2016-10-17 18:03:51 -04:00
{
2016-10-22 04:10:17 -04:00
qDebug ( " DeviceSinkAPI::loadChannelSettings: Loading preset [%s | %s] " , qPrintable ( preset - > getGroup ( ) ) , qPrintable ( preset - > getDescription ( ) ) ) ;
2016-10-17 18:03:51 -04:00
2016-10-18 18:07:42 -04:00
// Available channel plugins
2016-10-22 06:07:28 -04:00
PluginAPI : : ChannelRegistrations * channelRegistrations = pluginAPI - > getTxChannelRegistrations ( ) ;
2016-10-17 18:03:51 -04:00
2016-10-18 18:07:42 -04:00
// copy currently open channels and clear list
ChannelInstanceRegistrations openChannels = m_channelInstanceRegistrations ;
m_channelInstanceRegistrations . clear ( ) ;
2016-10-22 04:10:17 -04:00
qDebug ( " DeviceSinkAPI::loadChannelSettings: %d channel(s) in preset " , preset - > getChannelCount ( ) ) ;
2016-10-18 18:07:42 -04:00
for ( int i = 0 ; i < preset - > getChannelCount ( ) ; i + + )
2016-10-17 18:03:51 -04:00
{
2016-10-18 18:07:42 -04:00
const Preset : : ChannelConfig & channelConfig = preset - > getChannelConfig ( i ) ;
ChannelInstanceRegistration reg ;
2016-10-17 18:03:51 -04:00
2016-10-18 18:07:42 -04:00
// if we have one instance available already, use it
for ( int i = 0 ; i < openChannels . count ( ) ; i + + )
2016-10-17 18:03:51 -04:00
{
2016-10-22 04:10:17 -04:00
qDebug ( " DeviceSinkAPI::loadChannelSettings: channels compare [%s] vs [%s] " , qPrintable ( openChannels [ i ] . m_channelName ) , qPrintable ( channelConfig . m_channel ) ) ;
2016-10-18 18:07:42 -04:00
if ( openChannels [ i ] . m_channelName = = channelConfig . m_channel )
{
2016-10-22 04:10:17 -04:00
qDebug ( " DeviceSinkAPI::loadChannelSettings: channel [%s] found " , qPrintable ( openChannels [ i ] . m_channelName ) ) ;
2016-10-18 18:07:42 -04:00
reg = openChannels . takeAt ( i ) ;
m_channelInstanceRegistrations . append ( reg ) ;
break ;
}
2016-10-17 18:03:51 -04:00
}
2016-10-18 18:07:42 -04:00
// if we haven't one already, create one
2016-10-17 18:03:51 -04:00
2016-10-22 06:07:28 -04:00
if ( reg . m_gui = = 0 )
2016-10-17 18:03:51 -04:00
{
2016-10-18 18:07:42 -04:00
for ( int i = 0 ; i < channelRegistrations - > count ( ) ; i + + )
2016-10-17 18:03:51 -04:00
{
2016-10-18 18:07:42 -04:00
if ( ( * channelRegistrations ) [ i ] . m_channelName = = channelConfig . m_channel )
{
2016-10-22 04:10:17 -04:00
qDebug ( " DeviceSinkAPI::loadChannelSettings: creating new channel [%s] " , qPrintable ( channelConfig . m_channel ) ) ;
2016-10-18 18:07:42 -04:00
reg = ChannelInstanceRegistration ( channelConfig . m_channel , ( * channelRegistrations ) [ i ] . m_plugin - > createTxChannel ( channelConfig . m_channel , this ) ) ;
break ;
}
2016-10-17 18:03:51 -04:00
}
}
2016-10-18 18:07:42 -04:00
2016-10-22 06:07:28 -04:00
if ( reg . m_gui ! = 0 )
2016-10-18 18:07:42 -04:00
{
2016-10-22 04:10:17 -04:00
qDebug ( " DeviceSinkAPI::loadChannelSettings: deserializing channel [%s] " , qPrintable ( channelConfig . m_channel ) ) ;
2016-10-18 18:07:42 -04:00
reg . m_gui - > deserialize ( channelConfig . m_config ) ;
}
2016-10-17 18:03:51 -04:00
}
2016-10-18 18:07:42 -04:00
// everything, that is still "available" is not needed anymore
for ( int i = 0 ; i < openChannels . count ( ) ; i + + )
2016-10-17 18:03:51 -04:00
{
2016-10-22 04:10:17 -04:00
qDebug ( " DeviceSinkAPI::loadChannelSettings: destroying spare channel [%s] " , qPrintable ( openChannels [ i ] . m_channelName ) ) ;
2016-10-18 18:07:42 -04:00
openChannels [ i ] . m_gui - > destroy ( ) ;
2016-10-17 18:03:51 -04:00
}
2016-10-18 18:07:42 -04:00
renameChannelInstances ( ) ;
2016-10-17 18:03:51 -04:00
}
}
void DeviceSinkAPI : : saveChannelSettings ( Preset * preset )
{
2016-10-18 18:07:42 -04:00
if ( preset - > isSourcePreset ( ) )
{
qDebug ( " DeviceSinkAPI::saveChannelSettings: not a sink preset " ) ;
}
else
{
qSort ( m_channelInstanceRegistrations . begin ( ) , m_channelInstanceRegistrations . end ( ) ) ; // sort by increasing delta frequency and type
2016-10-17 18:03:51 -04:00
2016-10-18 18:07:42 -04:00
for ( int i = 0 ; i < m_channelInstanceRegistrations . count ( ) ; i + + )
{
2016-10-22 04:10:17 -04:00
qDebug ( " DeviceSinkAPI::saveChannelSettings: channel [%s] saved " , qPrintable ( m_channelInstanceRegistrations [ i ] . m_channelName ) ) ;
2016-10-18 18:07:42 -04:00
preset - > addChannel ( m_channelInstanceRegistrations [ i ] . m_channelName , m_channelInstanceRegistrations [ i ] . m_gui - > serialize ( ) ) ;
}
2016-10-17 18:03:51 -04:00
}
}
// sort by increasing delta frequency and type (i.e. name)
bool DeviceSinkAPI : : ChannelInstanceRegistration : : operator < ( const ChannelInstanceRegistration & other ) const
{
if ( m_gui & & other . m_gui )
{
if ( m_gui - > getCenterFrequency ( ) = = other . m_gui - > getCenterFrequency ( ) )
{
return m_gui - > getName ( ) < other . m_gui - > getName ( ) ;
}
else
{
return m_gui - > getCenterFrequency ( ) < other . m_gui - > getCenterFrequency ( ) ;
}
}
else
{
return false ;
}
}
2016-12-29 06:41:10 -05:00
void DeviceSinkAPI : : addSourceBuddy ( DeviceSourceAPI * buddy )
{
m_sourceBuddies . push_back ( buddy ) ;
2017-01-02 17:30:50 -05:00
buddy - > m_sinkBuddies . push_back ( this ) ;
2016-12-29 13:26:45 -05:00
qDebug ( " DeviceSinkAPI::addSourceBuddy: added buddy %s(%s) to the list [%lx] <-> [%lx] " ,
2016-12-29 06:41:10 -05:00
qPrintable ( buddy - > getHardwareId ( ) ) ,
2016-12-29 13:26:45 -05:00
qPrintable ( buddy - > getSampleSourceSerial ( ) ) ,
( uint64_t ) buddy ,
( uint64_t ) this ) ;
2016-12-29 06:41:10 -05:00
}
void DeviceSinkAPI : : addSinkBuddy ( DeviceSinkAPI * buddy )
{
m_sinkBuddies . push_back ( buddy ) ;
2017-01-02 17:30:50 -05:00
buddy - > m_sinkBuddies . push_back ( this ) ;
2016-12-29 13:26:45 -05:00
qDebug ( " DeviceSinkAPI::addSinkBuddy: added buddy %s(%s) to the list [%lx] <-> [%lx] " ,
2016-12-29 06:41:10 -05:00
qPrintable ( buddy - > getHardwareId ( ) ) ,
2016-12-29 13:26:45 -05:00
qPrintable ( buddy - > getSampleSinkSerial ( ) ) ,
( uint64_t ) buddy ,
( uint64_t ) this ) ;
2016-12-29 06:41:10 -05:00
}
void DeviceSinkAPI : : removeSourceBuddy ( DeviceSourceAPI * buddy )
{
std : : vector < DeviceSourceAPI * > : : iterator it = m_sourceBuddies . begin ( ) ;
for ( ; it ! = m_sourceBuddies . end ( ) ; + + it )
{
2016-12-29 13:26:45 -05:00
if ( * it = = buddy )
2016-12-29 06:41:10 -05:00
{
2016-12-29 13:26:45 -05:00
qDebug ( " DeviceSinkAPI::removeSourceBuddy: buddy %s(%s) [%lx] removed from the list of [%lx] " ,
2016-12-29 06:41:10 -05:00
qPrintable ( buddy - > getHardwareId ( ) ) ,
2016-12-29 13:26:45 -05:00
qPrintable ( buddy - > getSampleSourceSerial ( ) ) ,
( uint64_t ) ( * it ) ,
( uint64_t ) this ) ;
m_sourceBuddies . erase ( it ) ;
2016-12-29 06:41:10 -05:00
return ;
}
}
2016-12-29 13:26:45 -05:00
qDebug ( " DeviceSinkAPI::removeSourceBuddy: buddy %s(%s) [%lx] not found in the list of [%lx] " ,
2016-12-29 06:41:10 -05:00
qPrintable ( buddy - > getHardwareId ( ) ) ,
2016-12-29 13:26:45 -05:00
qPrintable ( buddy - > getSampleSourceSerial ( ) ) ,
( uint64_t ) buddy ,
( uint64_t ) this ) ;
2016-12-29 06:41:10 -05:00
}
void DeviceSinkAPI : : removeSinkBuddy ( DeviceSinkAPI * buddy )
{
std : : vector < DeviceSinkAPI * > : : iterator it = m_sinkBuddies . begin ( ) ;
for ( ; it ! = m_sinkBuddies . end ( ) ; + + it )
{
2016-12-29 13:26:45 -05:00
if ( * it = = buddy )
2016-12-29 06:41:10 -05:00
{
2016-12-29 13:26:45 -05:00
qDebug ( " DeviceSinkAPI::removeSinkBuddy: buddy %s(%s) [%lx] removed from the list of [%lx] " ,
2016-12-29 06:41:10 -05:00
qPrintable ( buddy - > getHardwareId ( ) ) ,
2016-12-29 13:26:45 -05:00
qPrintable ( buddy - > getSampleSinkSerial ( ) ) ,
( uint64_t ) ( * it ) ,
( uint64_t ) this ) ;
m_sinkBuddies . erase ( it ) ;
2016-12-29 06:41:10 -05:00
return ;
}
}
2016-12-29 13:26:45 -05:00
qDebug ( " DeviceSinkAPI::removeSinkBuddy: buddy %s(%s) [%lx] not found in the list of [%lx] " ,
2016-12-29 06:41:10 -05:00
qPrintable ( buddy - > getHardwareId ( ) ) ,
2016-12-29 13:26:45 -05:00
qPrintable ( buddy - > getSampleSinkSerial ( ) ) ,
( uint64_t ) buddy ,
( uint64_t ) this ) ;
2016-12-29 06:41:10 -05:00
}
2016-12-29 13:26:45 -05:00
void DeviceSinkAPI : : clearBuddiesLists ( )
2016-12-29 06:41:10 -05:00
{
std : : vector < DeviceSourceAPI * > : : iterator itSource = m_sourceBuddies . begin ( ) ;
std : : vector < DeviceSinkAPI * > : : iterator itSink = m_sinkBuddies . begin ( ) ;
2017-07-03 02:59:48 -04:00
bool leaderElected = false ;
2016-12-29 06:41:10 -05:00
for ( ; itSource ! = m_sourceBuddies . end ( ) ; + + itSource )
{
2017-07-03 02:59:48 -04:00
if ( isBuddyLeader ( ) & & ! leaderElected )
{
( * itSource ) - > setBuddyLeader ( true ) ;
leaderElected = true ;
}
2016-12-29 06:41:10 -05:00
( * itSource ) - > removeSinkBuddy ( this ) ;
}
2016-12-29 13:26:45 -05:00
m_sourceBuddies . clear ( ) ;
2016-12-29 06:41:10 -05:00
for ( ; itSink ! = m_sinkBuddies . end ( ) ; + + itSink )
{
2017-07-03 02:59:48 -04:00
if ( isBuddyLeader ( ) & & ! leaderElected )
{
( * itSink ) - > setBuddyLeader ( true ) ;
leaderElected = true ;
}
2016-12-29 06:41:10 -05:00
( * itSink ) - > removeSinkBuddy ( this ) ;
}
2016-12-29 13:26:45 -05:00
m_sinkBuddies . clear ( ) ;
2016-12-29 06:41:10 -05:00
}
2016-10-17 18:03:51 -04:00