From 1b85f2410d1d644ff00284e78b1eeff6cfad2fc4 Mon Sep 17 00:00:00 2001 From: christian mueller Date: Mon, 5 Mar 2012 13:55:09 +0100 Subject: * fixing CAmSerializer.h - smaller changes and copy past stuff * adding new class in Controler plugin to use CAmSerializer to build up a shadow * added test to test the new class (unfinished) --- .../src/IAmControlReceiverShadow.cpp | 511 +++++++++++++++++++++ 1 file changed, 511 insertions(+) create mode 100644 PluginControlInterface/src/IAmControlReceiverShadow.cpp (limited to 'PluginControlInterface/src') diff --git a/PluginControlInterface/src/IAmControlReceiverShadow.cpp b/PluginControlInterface/src/IAmControlReceiverShadow.cpp new file mode 100644 index 0000000..e7572ff --- /dev/null +++ b/PluginControlInterface/src/IAmControlReceiverShadow.cpp @@ -0,0 +1,511 @@ +/* + * IAmControlReceiverShadow.cpp + * + * Created on: Mar 2, 2012 + * Author: christian + */ + +#include "IAmControlReceiverShadow.h" +#include "control/IAmControlReceive.h" + +namespace am +{ + +IAmControlReceiverShadow::IAmControlReceiverShadow(IAmControlReceive *iReceiveInterface, CAmSocketHandler *iSocketHandler) : + mpIAmControlReceiver(iReceiveInterface), // + mCAmSerializer(iSocketHandler) +{ +} + +IAmControlReceiverShadow::~IAmControlReceiverShadow() +{ + +} + +am_Error_e IAmControlReceiverShadow::getRoute(bool onlyfree, am_sourceID_t sourceID, am_sinkID_t sinkID, std::vector & returnList) +{ + am_Error_e error; + mCAmSerializer.syncCall &, bool, am_sourceID_t, am_sinkID_t, std::vector >(mpIAmControlReceiver, &IAmControlReceive::getRoute, error, onlyfree, sourceID, sinkID, returnList); + return (error); +} + +am_Error_e IAmControlReceiverShadow::connect(am_Handle_s & handle, am_connectionID_t & connectionID, am_ConnectionFormat_e format, am_sourceID_t sourceID, am_sinkID_t sinkID) +{ + am_Error_e error; + mCAmSerializer.syncCall(mpIAmControlReceiver, &IAmControlReceive::connect, error, handle, connectionID, format, sourceID, sinkID); + return (error); +} + +am_Error_e IAmControlReceiverShadow::disconnect(am_Handle_s & handle, am_connectionID_t connectionID) +{ + am_Error_e error; + mCAmSerializer.syncCall(mpIAmControlReceiver, &IAmControlReceive::disconnect, error, handle, connectionID); + return (error); +} + +am_Error_e IAmControlReceiverShadow::crossfade(am_Handle_s & handle, am_HotSink_e hotSource, am_crossfaderID_t crossfaderID, am_RampType_e rampType, am_time_t rampTime) +{ + am_Error_e error; + mCAmSerializer.syncCall(mpIAmControlReceiver, &IAmControlReceive::crossfade, error, handle, hotSource, crossfaderID, rampType, rampTime); + return (error); +} + +am_Error_e IAmControlReceiverShadow::abortAction(am_Handle_s handle) +{ + am_Error_e error; + mCAmSerializer.syncCall(mpIAmControlReceiver, &IAmControlReceive::abortAction, error, handle); + return (error); +} + +am_Error_e IAmControlReceiverShadow::setSourceState(am_Handle_s & handle, am_sourceID_t sourceID, am_SourceState_e state) +{ + am_Error_e error; + mCAmSerializer.syncCall(mpIAmControlReceiver, &IAmControlReceive::setSourceState, error, handle, sourceID, state); + return (error); + +} + +am_Error_e IAmControlReceiverShadow::setSinkVolume(am_Handle_s & handle, am_sinkID_t sinkID, am_volume_t volume, am_RampType_e ramp, am_time_t time) +{ + am_Error_e error; + mCAmSerializer.syncCall(mpIAmControlReceiver, &IAmControlReceive::setSinkVolume, error, handle, sinkID, volume, ramp, time); + return (error); +} + +am_Error_e IAmControlReceiverShadow::setSourceVolume(am_Handle_s & handle, am_sourceID_t sourceID, am_volume_t volume, am_RampType_e rampType, am_time_t time) +{ + am_Error_e error; + mCAmSerializer.syncCall(mpIAmControlReceiver, &IAmControlReceive::setSourceVolume, error, handle, sourceID, volume, rampType, time); + return (error); +} + +am_Error_e IAmControlReceiverShadow::setSinkSoundProperties(am_Handle_s & handle, am_sinkID_t sinkID, std::vector & soundProperty) +{ + am_Error_e error; + mCAmSerializer.syncCall &, am_Handle_s, am_sinkID_t, std::vector >(mpIAmControlReceiver, &IAmControlReceive::setSinkSoundProperties, error, handle, sinkID, soundProperty); + return (error); +} + +am_Error_e IAmControlReceiverShadow::setSinkSoundProperty(am_Handle_s & handle, am_sinkID_t sinkID, am_SoundProperty_s & soundProperty) +{ + am_Error_e error; + mCAmSerializer.syncCall(mpIAmControlReceiver, &IAmControlReceive::setSinkSoundProperty, error, handle, sinkID, soundProperty); + return (error); +} + +am_Error_e IAmControlReceiverShadow::setSourceSoundProperties(am_Handle_s & handle, am_sourceID_t sourceID, std::vector & soundProperty) +{ + am_Error_e error; + mCAmSerializer.syncCall &, am_Handle_s, am_sourceID_t, std::vector >(mpIAmControlReceiver, &IAmControlReceive::setSourceSoundProperties, error, handle, sourceID, soundProperty); + return (error); +} + +am_Error_e IAmControlReceiverShadow::setSourceSoundProperty(am_Handle_s & handle, am_sourceID_t sourceID, am_SoundProperty_s & soundProperty) +{ + am_Error_e error; + mCAmSerializer.syncCall(mpIAmControlReceiver, &IAmControlReceive::setSourceSoundProperty, error, handle, sourceID, soundProperty); + return (error); +} + +am_Error_e IAmControlReceiverShadow::setDomainState(am_domainID_t domainID, am_DomainState_e domainState) +{ + am_Error_e error; + mCAmSerializer.syncCall(mpIAmControlReceiver, &IAmControlReceive::setDomainState, error, domainID, domainState); + return (error); +} + +am_Error_e IAmControlReceiverShadow::enterDomainDB(am_Domain_s & domainData, am_domainID_t & domainID) +{ + am_Error_e error; + mCAmSerializer.syncCall(mpIAmControlReceiver, &IAmControlReceive::enterDomainDB, error, domainData, domainID); + return (error); +} + +am_Error_e IAmControlReceiverShadow::enterMainConnectionDB(am_MainConnection_s & mainConnectionData, am_mainConnectionID_t & connectionID) +{ + am_Error_e error; + mCAmSerializer.syncCall(mpIAmControlReceiver, &IAmControlReceive::enterMainConnectionDB, error, mainConnectionData, connectionID); + return (error); +} + +am_Error_e IAmControlReceiverShadow::enterSinkDB(am_Sink_s & sinkData, am_sinkID_t & sinkID) +{ + am_Error_e error; + mCAmSerializer.syncCall(mpIAmControlReceiver, &IAmControlReceive::enterSinkDB, error, sinkData, sinkID); + return (error); +} + +am_Error_e IAmControlReceiverShadow::enterCrossfaderDB(am_Crossfader_s & crossfaderData, am_crossfaderID_t & crossfaderID) +{ + am_Error_e error; + mCAmSerializer.syncCall(mpIAmControlReceiver, &IAmControlReceive::enterCrossfaderDB, error, crossfaderData, crossfaderID); + return (error); +} + +am_Error_e IAmControlReceiverShadow::enterGatewayDB(am_Gateway_s & gatewayData, am_gatewayID_t & gatewayID) +{ + am_Error_e error; + mCAmSerializer.syncCall(mpIAmControlReceiver, &IAmControlReceive::enterGatewayDB, error, gatewayData, gatewayID); + return (error); +} + +am_Error_e IAmControlReceiverShadow::enterSourceDB(am_Source_s & sourceData, am_sourceID_t & sourceID) +{ + am_Error_e error; + mCAmSerializer.syncCall(mpIAmControlReceiver, &IAmControlReceive::enterSourceDB, error, sourceData, sourceID); + return (error); +} + +am_Error_e IAmControlReceiverShadow::enterSinkClassDB(am_SinkClass_s & sinkClass, am_sinkClass_t & sinkClassID) +{ + am_Error_e error; + mCAmSerializer.syncCall(mpIAmControlReceiver, &IAmControlReceive::enterSinkClassDB, error, sinkClass, sinkClassID); + return (error); +} + +am_Error_e IAmControlReceiverShadow::enterSourceClassDB(am_sourceClass_t & sourceClassID, am_SourceClass_s & sourceClass) +{ + am_Error_e error; + mCAmSerializer.syncCall(mpIAmControlReceiver, &IAmControlReceive::enterSourceClassDB, error, sourceClassID, sourceClass); + return (error); +} + +am_Error_e IAmControlReceiverShadow::changeSinkClassInfoDB(am_SinkClass_s & sinkClass) +{ + am_Error_e error; + mCAmSerializer.syncCall(mpIAmControlReceiver, &IAmControlReceive::changeSinkClassInfoDB, error, sinkClass); + return (error); +} + +am_Error_e IAmControlReceiverShadow::changeSourceClassInfoDB(am_SourceClass_s & sourceClass) +{ + am_Error_e error; + mCAmSerializer.syncCall(mpIAmControlReceiver, &IAmControlReceive::changeSourceClassInfoDB, error, sourceClass); + return (error); +} + +am_Error_e IAmControlReceiverShadow::enterSystemPropertiesListDB(std::vector & listSystemProperties) +{ + am_Error_e error; + mCAmSerializer.syncCall &, std::vector >(mpIAmControlReceiver, &IAmControlReceive::enterSystemPropertiesListDB, error, listSystemProperties); + return (error); +} + +am_Error_e IAmControlReceiverShadow::changeMainConnectionRouteDB(am_mainConnectionID_t mainconnectionID, std::vector & listConnectionID) +{ + am_Error_e error; + mCAmSerializer.syncCall &, am_mainConnectionID_t, std::vector >(mpIAmControlReceiver, &IAmControlReceive::changeMainConnectionRouteDB, error, mainconnectionID, listConnectionID); + return (error); +} + +am_Error_e IAmControlReceiverShadow::changeMainConnectionStateDB(am_mainConnectionID_t mainconnectionID, am_ConnectionState_e connectionState) +{ + am_Error_e error; + mCAmSerializer.syncCall(mpIAmControlReceiver, &IAmControlReceive::changeMainConnectionStateDB, error, mainconnectionID, connectionState); + return (error); +} + +am_Error_e IAmControlReceiverShadow::changeSinkMainVolumeDB(am_mainVolume_t mainVolume, am_sinkID_t sinkID) +{ + am_Error_e error; + mCAmSerializer.syncCall(mpIAmControlReceiver, &IAmControlReceive::changeSinkMainVolumeDB, error, mainVolume, sinkID); + return (error); +} + +am_Error_e IAmControlReceiverShadow::getListMainConnections(std::vector & listMainConnections) +{ + am_Error_e error; + mCAmSerializer.syncCall &, std::vector >(mpIAmControlReceiver, &IAmControlReceive::getListMainConnections, error, listMainConnections); + return (error); +} + +am_Error_e IAmControlReceiverShadow::getListDomains(std::vector & listDomains) +{ + am_Error_e error; + mCAmSerializer.syncCall &, std::vector >(mpIAmControlReceiver, &IAmControlReceive::getListDomains, error, listDomains); + return (error); +} + +am_Error_e IAmControlReceiverShadow::getListConnections(std::vector & listConnections) +{ + am_Error_e error; + mCAmSerializer.syncCall&, std::vector >(mpIAmControlReceiver, &IAmControlReceive::getListConnections, error, listConnections); + return (error); +} + +am_Error_e IAmControlReceiverShadow::getListSinks(std::vector & listSinks) +{ + am_Error_e error; + mCAmSerializer.syncCall &, std::vector >(mpIAmControlReceiver, &IAmControlReceive::getListSinks, error, listSinks); + return (error); +} + +am_Error_e IAmControlReceiverShadow::getListSources(std::vector & listSources) +{ + am_Error_e error; + mCAmSerializer.syncCall &, std::vector >(mpIAmControlReceiver, &IAmControlReceive::getListSources, error, listSources); + return (error); +} + +am_Error_e IAmControlReceiverShadow::getListSourceClasses(std::vector & listSourceClasses) +{ + am_Error_e error; + mCAmSerializer.syncCall &, std::vector >(mpIAmControlReceiver, &IAmControlReceive::getListSourceClasses, error, listSourceClasses); + return (error); +} + +am_Error_e IAmControlReceiverShadow::getListHandles(std::vector & listHandles) +{ + am_Error_e error; + mCAmSerializer.syncCall &, std::vector >(mpIAmControlReceiver, &IAmControlReceive::getListHandles, error, listHandles); + return (error); +} + +am_Error_e IAmControlReceiverShadow::getListCrossfaders(std::vector & listCrossfaders) +{ + am_Error_e error; + mCAmSerializer.syncCall &, std::vector >(mpIAmControlReceiver, &IAmControlReceive::getListCrossfaders, error, listCrossfaders); + return (error); +} + +am_Error_e IAmControlReceiverShadow::getListGateways(std::vector & listGateways) +{ + am_Error_e error; + mCAmSerializer.syncCall&, std::vector >(mpIAmControlReceiver, &IAmControlReceive::getListGateways, error, listGateways); + return (error); +} + +am_Error_e IAmControlReceiverShadow::getListSinkClasses(std::vector & listSinkClasses) +{ + am_Error_e error; + mCAmSerializer.syncCall &, std::vector >(mpIAmControlReceiver, &IAmControlReceive::getListSinkClasses, error, listSinkClasses); + return (error); +} + +am_Error_e IAmControlReceiverShadow::getListSystemProperties(std::vector & listSystemProperties) +{ + am_Error_e error; + mCAmSerializer.syncCall &, std::vector >(mpIAmControlReceiver, &IAmControlReceive::getListSystemProperties, error, listSystemProperties); + return (error); +} + +void IAmControlReceiverShadow::setCommandReady() +{ + mCAmSerializer.asyncCall(mpIAmControlReceiver, &IAmControlReceive::setCommandReady); +} + +void IAmControlReceiverShadow::setCommandRundown() +{ + mCAmSerializer.asyncCall(mpIAmControlReceiver, &IAmControlReceive::setCommandRundown); +} + +void IAmControlReceiverShadow::setRoutingReady() +{ + mCAmSerializer.asyncCall(mpIAmControlReceiver, &IAmControlReceive::setRoutingReady); +} + +void IAmControlReceiverShadow::setRoutingRundown() +{ + mCAmSerializer.asyncCall(mpIAmControlReceiver, &IAmControlReceive::setRoutingRundown); +} + +void IAmControlReceiverShadow::confirmControllerReady() +{ + mCAmSerializer.asyncCall(mpIAmControlReceiver, &IAmControlReceive::confirmControllerReady); +} + +void IAmControlReceiverShadow::confirmControllerRundown() +{ + mCAmSerializer.asyncCall(mpIAmControlReceiver, &IAmControlReceive::confirmControllerRundown); +} + +am_Error_e IAmControlReceiverShadow::getSocketHandler(CAmSocketHandler *& socketHandler) +{ + am_Error_e error; + mCAmSerializer.syncCall(mpIAmControlReceiver, &IAmControlReceive::getSocketHandler, error, socketHandler); + return (error); +} + +am_Error_e IAmControlReceiverShadow::changeSinkAvailabilityDB(am_Availability_s& availability, am_sinkID_t sinkID) +{ + am_Error_e error; + mCAmSerializer.syncCall(mpIAmControlReceiver, &IAmControlReceive::changeSinkAvailabilityDB, error, availability, sinkID); + return (error); +} + +am_Error_e IAmControlReceiverShadow::changDomainStateDB(am_DomainState_e domainState, am_domainID_t domainID) +{ + am_Error_e error; + mCAmSerializer.syncCall(mpIAmControlReceiver, &IAmControlReceive::changDomainStateDB, error, domainState, domainID); + return (error); +} + +am_Error_e IAmControlReceiverShadow::changeSinkMuteStateDB(am_MuteState_e muteState, am_sinkID_t sinkID) +{ + am_Error_e error; + mCAmSerializer.syncCall(mpIAmControlReceiver, &IAmControlReceive::changeSinkMuteStateDB, error, muteState, sinkID); + return (error); +} + +am_Error_e IAmControlReceiverShadow::changeMainSinkSoundPropertyDB(am_MainSoundProperty_s& soundProperty, am_sinkID_t sinkID) +{ + am_Error_e error; + mCAmSerializer.syncCall(mpIAmControlReceiver, &IAmControlReceive::changeMainSinkSoundPropertyDB, error, soundProperty, sinkID); + return (error); +} + +am_Error_e IAmControlReceiverShadow::changeMainSourceSoundPropertyDB(am_MainSoundProperty_s& soundProperty, am_sourceID_t sourceID) +{ + am_Error_e error; + mCAmSerializer.syncCall(mpIAmControlReceiver, &IAmControlReceive::changeMainSourceSoundPropertyDB, error, soundProperty, sourceID); + return (error); +} + +am_Error_e IAmControlReceiverShadow::changeSourceAvailabilityDB(am_Availability_s& availability, am_sourceID_t sourceID) +{ + am_Error_e error; + mCAmSerializer.syncCall(mpIAmControlReceiver, &IAmControlReceive::changeSourceAvailabilityDB, error, availability, sourceID); + return (error); +} + +am_Error_e IAmControlReceiverShadow::changeSystemPropertyDB(am_SystemProperty_s& property) +{ + am_Error_e error; + mCAmSerializer.syncCall(mpIAmControlReceiver, &IAmControlReceive::changeSystemPropertyDB, error, property); + return (error); +} + +am_Error_e IAmControlReceiverShadow::removeMainConnectionDB(am_mainConnectionID_t mainConnectionID) +{ + am_Error_e error; + mCAmSerializer.syncCall(mpIAmControlReceiver, &IAmControlReceive::removeMainConnectionDB, error, mainConnectionID); + return (error); +} + +am_Error_e IAmControlReceiverShadow::removeSinkDB(am_sinkID_t sinkID) +{ + am_Error_e error; + mCAmSerializer.syncCall(mpIAmControlReceiver, &IAmControlReceive::removeSinkDB, error, sinkID); + return (error); +} + +am_Error_e IAmControlReceiverShadow::removeSourceDB(am_sourceID_t sourceID) +{ + am_Error_e error; + mCAmSerializer.syncCall(mpIAmControlReceiver, &IAmControlReceive::removeSourceDB, error, sourceID); + return (error); +} + +am_Error_e IAmControlReceiverShadow::removeGatewayDB(am_gatewayID_t gatewayID) +{ + am_Error_e error; + mCAmSerializer.syncCall(mpIAmControlReceiver, &IAmControlReceive::removeGatewayDB, error, gatewayID); + return (error); +} + +am_Error_e IAmControlReceiverShadow::removeCrossfaderDB(am_crossfaderID_t crossfaderID) +{ + am_Error_e error; + mCAmSerializer.syncCall(mpIAmControlReceiver, &IAmControlReceive::removeCrossfaderDB, error, crossfaderID); + return (error); +} + +am_Error_e IAmControlReceiverShadow::removeDomainDB(am_domainID_t domainID) +{ + am_Error_e error; + mCAmSerializer.syncCall(mpIAmControlReceiver, &IAmControlReceive::removeDomainDB, error, domainID); + return (error); +} + +am_Error_e IAmControlReceiverShadow::removeSinkClassDB(am_sinkClass_t sinkClassID) +{ + am_Error_e error; + mCAmSerializer.syncCall(mpIAmControlReceiver, &IAmControlReceive::removeSinkClassDB, error, sinkClassID); + return (error); +} + +am_Error_e IAmControlReceiverShadow::removeSourceClassDB(am_sourceClass_t sourceClassID) +{ + am_Error_e error; + mCAmSerializer.syncCall(mpIAmControlReceiver, &IAmControlReceive::removeSourceClassDB, error, sourceClassID); + return (error); +} + +am_Error_e IAmControlReceiverShadow::getSourceClassInfoDB(am_sourceID_t sourceID, am_SourceClass_s& classInfo) +{ + am_Error_e error; + mCAmSerializer.syncCall(mpIAmControlReceiver, &IAmControlReceive::getSourceClassInfoDB, error, sourceID, classInfo); + return (error); +} + +am_Error_e IAmControlReceiverShadow::getSinkClassInfoDB(am_sinkID_t sinkID, am_SinkClass_s& sinkClass) +{ + am_Error_e error; + mCAmSerializer.syncCall(mpIAmControlReceiver, &IAmControlReceive::getSinkClassInfoDB, error, sinkID, sinkClass); + return (error); +} + +am_Error_e IAmControlReceiverShadow::getSinkInfoDB(am_sinkID_t sinkID, am_Sink_s& sinkData) +{ + am_Error_e error; + mCAmSerializer.syncCall(mpIAmControlReceiver, &IAmControlReceive::getSinkInfoDB, error, sinkID, sinkData); + return (error); +} + +am_Error_e IAmControlReceiverShadow::getSourceInfoDB(am_sourceID_t sourceID, am_Source_s& sourceData) +{ + am_Error_e error; + mCAmSerializer.syncCall(mpIAmControlReceiver, &IAmControlReceive::getSourceInfoDB, error, sourceID, sourceData); + return (error); +} + +am_Error_e IAmControlReceiverShadow::getGatewayInfoDB(am_gatewayID_t gatewayID, am_Gateway_s& gatewayData) +{ + am_Error_e error; + mCAmSerializer.syncCall(mpIAmControlReceiver, &IAmControlReceive::getGatewayInfoDB, error, gatewayID, gatewayData); + return (error); +} + +am_Error_e IAmControlReceiverShadow::getCrossfaderInfoDB(am_crossfaderID_t crossfaderID, am_Crossfader_s& crossfaderData) +{ + am_Error_e error; + mCAmSerializer.syncCall(mpIAmControlReceiver, &IAmControlReceive::getCrossfaderInfoDB, error, crossfaderID, crossfaderData); + return (error); +} + +am_Error_e IAmControlReceiverShadow::getMainConnectionInfoDB(am_mainConnectionID_t mainConnectionID, am_MainConnection_s& mainConnectionData) +{ + am_Error_e error; + mCAmSerializer.syncCall(mpIAmControlReceiver, &IAmControlReceive::getMainConnectionInfoDB, error, mainConnectionID, mainConnectionData); + return (error); +} + +am_Error_e IAmControlReceiverShadow::getListSinksOfDomain(am_domainID_t domainID, std::vector& listSinkID) +{ + am_Error_e error; + mCAmSerializer.syncCall&, am_domainID_t, std::vector >(mpIAmControlReceiver, &IAmControlReceive::getListSinksOfDomain, error, domainID, listSinkID); + return (error); +} + +am_Error_e IAmControlReceiverShadow::getListSourcesOfDomain(am_domainID_t domainID, std::vector& listSourceID) +{ + am_Error_e error; + mCAmSerializer.syncCall&, am_domainID_t, std::vector >(mpIAmControlReceiver, &IAmControlReceive::getListSourcesOfDomain, error, domainID, listSourceID); + return (error); +} + +am_Error_e IAmControlReceiverShadow::getListCrossfadersOfDomain(am_domainID_t domainID, std::vector& listCrossfadersID) +{ + am_Error_e error; + mCAmSerializer.syncCall&, am_domainID_t, std::vector >(mpIAmControlReceiver, &IAmControlReceive::getListCrossfadersOfDomain, error, domainID, listCrossfadersID); + return (error); +} + +am_Error_e IAmControlReceiverShadow::getListGatewaysOfDomain(am_domainID_t domainID, std::vector& listGatewaysID) +{ + am_Error_e error; + mCAmSerializer.syncCall&, am_domainID_t, std::vector >(mpIAmControlReceiver, &IAmControlReceive::getListGatewaysOfDomain, error, domainID, listGatewaysID); + return (error); +} + +} /* namespace am */ -- cgit v1.2.1