diff options
Diffstat (limited to 'PluginRoutingInterfaceAsync/test/testRoutingInterfaceAsync.cpp')
| -rw-r--r-- | PluginRoutingInterfaceAsync/test/testRoutingInterfaceAsync.cpp | 476 |
1 files changed, 476 insertions, 0 deletions
diff --git a/PluginRoutingInterfaceAsync/test/testRoutingInterfaceAsync.cpp b/PluginRoutingInterfaceAsync/test/testRoutingInterfaceAsync.cpp new file mode 100644 index 0000000..fc3ad3b --- /dev/null +++ b/PluginRoutingInterfaceAsync/test/testRoutingInterfaceAsync.cpp @@ -0,0 +1,476 @@ +/* + * testRoutingInterfaceAsync.cpp + * + * Created on: Dec 27, 2011 + * Author: christian + */ + +#include "testRoutingInterfaceAsync.h" +#include "config.h" + + +using namespace am; +using namespace testing; + + +DLT_DECLARE_CONTEXT(DLT_CONTEXT) + + +std::vector<std::string> testRoutingInterfaceAsync::pListRoutingPluginDirs=returnListPlugins(); +am_domainID_t testRoutingInterfaceAsync::mDomainIDCount=0; +RoutingSender testRoutingInterfaceAsync::pRoutingSender=RoutingSender(pListRoutingPluginDirs); + +testRoutingInterfaceAsync::testRoutingInterfaceAsync() + :pSocketHandler(), + pReceiveInterface(), + ptimerCallback(this, &testRoutingInterfaceAsync::timerCallback) +{ +} + +testRoutingInterfaceAsync::~testRoutingInterfaceAsync() +{ +} + +void testRoutingInterfaceAsync::SetUp() +{ + DLT_REGISTER_APP("DPtest","RoutingInterfacetest"); + DLT_REGISTER_CONTEXT(DLT_CONTEXT,"Main","Main Context"); + DLT_LOG(DLT_CONTEXT,DLT_LOG_INFO, DLT_STRING("RoutingSendInterface Test started ")); + + std::vector<int> domainIDs; + domainIDs.push_back(0); + domainIDs.push_back(1); + + EXPECT_CALL(pReceiveInterface,getSocketHandler(_)).WillOnce(DoAll(SetArgReferee<0>(&pSocketHandler),Return(E_OK))); + EXPECT_CALL(pReceiveInterface,registerDomain(_,_)).WillRepeatedly(Invoke(testRoutingInterfaceAsync::handleDomainRegister)); + EXPECT_CALL(pReceiveInterface,registerSource(_,_)).WillRepeatedly(Invoke(testRoutingInterfaceAsync::handleSourceRegister)); + EXPECT_CALL(pReceiveInterface,registerSink(_,_)).WillRepeatedly(Invoke(testRoutingInterfaceAsync::handleSinkRegister)); + + pRoutingSender.startupRoutingInterface(&pReceiveInterface); + pRoutingSender.routingInterfacesReady(); + + timespec t; + t.tv_nsec=0; + t.tv_sec=4; + + sh_timerHandle_t handle; + + shTimerCallBack *buf=&ptimerCallback; + //lets use a timeout so the test will finish + pSocketHandler.addTimer(t,buf,handle,(void*)NULL); +} + +std::vector<std::string> am::testRoutingInterfaceAsync::returnListPlugins() +{ + std::vector<std::string> list; + list.push_back(std::string(DEFAULT_PLUGIN_ROUTING_DIR)); + return (list); +} + +am_Error_e am::testRoutingInterfaceAsync::handleSourceRegister(const am_Source_s & sourceData, am_sourceID_t & sourceID) +{ + sourceID=sourceData.sourceID; + pRoutingSender.addSourceLookup(sourceData); + return (E_OK); +} + +am_Error_e am::testRoutingInterfaceAsync::handleSinkRegister(const am_Sink_s & sinkData, am_sinkID_t & sinkID) +{ + sinkID=sinkData.sinkID; + pRoutingSender.addSinkLookup(sinkData); + return(E_OK); +} + +am_Error_e am::testRoutingInterfaceAsync::handleDomainRegister(const am_Domain_s & domainData, am_domainID_t & domainID) +{ + am_Domain_s domain=domainData; + domainID=mDomainIDCount++; + domain.domainID=domainID; + pRoutingSender.addDomainLookup(domain); + return (E_OK); +} + +void am::testRoutingInterfaceAsync::timerCallback(sh_timerHandle_t handle, void *userData) +{ + pSocketHandler.stop_listening(); +} + +void testRoutingInterfaceAsync::TearDown() +{ + DLT_UNREGISTER_CONTEXT(DLT_CONTEXT); +} + +std::string DBUSCOMMAND = "dbus-send --session --print-reply --dest=org.genivi.test /org/genivi/test org.genivi.test."; + + + + +TEST_F(testRoutingInterfaceAsync,setDomainState) +{ + am_domainID_t domainID=1; + am_DomainState_e state=DS_INDEPENDENT_RUNDOWN; + + EXPECT_CALL(pReceiveInterface,hookDomainStateChange(_,DS_INDEPENDENT_RUNDOWN)).Times(1); + + ASSERT_EQ(E_OK,pRoutingSender.setDomainState(domainID,state)); + pSocketHandler.start_listenting(); +} +TEST_F(testRoutingInterfaceAsync,hookInterruptStatusChange) +{ + am_sourceID_t sourceID=2; + EXPECT_CALL(pReceiveInterface,hookInterruptStatusChange(sourceID,_)).Times(1); + system((DBUSCOMMAND + std::string("InterruptStatusChange int16:2")).c_str()); + pSocketHandler.start_listenting(); +} + +TEST_F(testRoutingInterfaceAsync,hookSourceAvailablityStatusChange) +{ + am_sourceID_t sourceID=2; + EXPECT_CALL(pReceiveInterface,hookSourceAvailablityStatusChange(sourceID,_)).Times(1); + system((DBUSCOMMAND + std::string("SourceAvailablityStatusChange int16:2")).c_str()); + pSocketHandler.start_listenting(); +} + +TEST_F(testRoutingInterfaceAsync,hookSinkAvailablityStatusChange) +{ + am_sinkID_t sinkID=2; + EXPECT_CALL(pReceiveInterface,hookSinkAvailablityStatusChange(sinkID,_)).Times(1); + system((DBUSCOMMAND + std::string("SinkAvailablityStatusChange int16:2")).c_str()); + pSocketHandler.start_listenting(); +} + +TEST_F(testRoutingInterfaceAsync,hookTimingInformationChanged) +{ + am_connectionID_t connectionID=4; + am_timeSync_t delay=35; + EXPECT_CALL(pReceiveInterface,hookTimingInformationChanged(connectionID,delay)).Times(1); + system((DBUSCOMMAND + std::string("timingChanged int16:4 int16:35")).c_str()); + pSocketHandler.start_listenting(); +} + + +TEST_F(testRoutingInterfaceAsync,setSourceSoundProperty) +{ + + am_Handle_s handle; + handle.handle=1; + handle.handleType=H_SETSOURCESOUNDPROPERTY; + + am_sourceID_t sourceID=3; + am_SoundProperty_s property; + property.type=SP_MID; + property.value=24; + + EXPECT_CALL(pReceiveInterface,ackSetSourceSoundProperty(_,E_OK)).Times(1); + + ASSERT_EQ(E_OK,pRoutingSender.asyncSetSourceSoundProperty(handle,sourceID,property)); + pSocketHandler.start_listenting(); +} + +TEST_F(testRoutingInterfaceAsync,setSinkSoundProperty) +{ + + am_Handle_s handle; + handle.handle=1; + handle.handleType=H_SETSINKSOUNDPROPERTY; + + am_sinkID_t sinkID=1; + am_SoundProperty_s property; + property.type=SP_MID; + property.value=24; + + EXPECT_CALL(pReceiveInterface,ackSetSinkSoundProperty(_,E_OK)).Times(1); + + ASSERT_EQ(E_OK,pRoutingSender.asyncSetSinkSoundProperty(handle,sinkID,property)); + pSocketHandler.start_listenting(); +} + +TEST_F(testRoutingInterfaceAsync,setSourceState) +{ + + am_Handle_s handle; + handle.handle=1; + handle.handleType=H_SETSOURCEVOLUME; + + am_sourceID_t sourceID=1; + am_SourceState_e state=SS_OFF; + + EXPECT_CALL(pReceiveInterface,ackSetSourceState(_,E_OK)).Times(1); + + ASSERT_EQ(E_OK,pRoutingSender.asyncSetSourceState(handle,sourceID,state)); + pSocketHandler.start_listenting(); +} + +TEST_F(testRoutingInterfaceAsync,setSourceVolume) +{ + + am_Handle_s handle; + handle.handle=1; + handle.handleType=H_SETSOURCEVOLUME; + + am_sourceID_t sourceID=3; + am_volume_t volume=3; + am_RampType_e ramp=RAMP_DIRECT; + am_time_t myTime=25; + + EXPECT_CALL(pReceiveInterface,ackSourceVolumeTick(_,sourceID,_)).Times(3); + EXPECT_CALL(pReceiveInterface,ackSetSourceVolumeChange(_,volume,E_OK)).Times(1); + + ASSERT_EQ(E_OK,pRoutingSender.asyncSetSourceVolume(handle,sourceID,volume,ramp,myTime)); + pSocketHandler.start_listenting(); +} + +TEST_F(testRoutingInterfaceAsync,setSinkVolume) +{ + + am_Handle_s handle; + handle.handle=1; + handle.handleType=H_SETSINKVOLUME; + + am_sinkID_t sinkID=1; + am_volume_t volume=9; + am_RampType_e ramp=RAMP_DIRECT; + am_time_t myTime=25; + + EXPECT_CALL(pReceiveInterface,ackSinkVolumeTick(_,sinkID,_)).Times(9); + EXPECT_CALL(pReceiveInterface,ackSetSinkVolumeChange(_,volume,E_OK)).Times(1); + + ASSERT_EQ(E_OK,pRoutingSender.asyncSetSinkVolume(handle,sinkID,volume,ramp,myTime)); + pSocketHandler.start_listenting(); +} + +TEST_F(testRoutingInterfaceAsync,setSinkVolumeAbort) +{ + + am_Handle_s handle; + handle.handle=1; + handle.handleType=H_SETSINKVOLUME; + + am_sinkID_t sinkID=2; + am_volume_t volume=25; + am_RampType_e ramp=RAMP_DIRECT; + am_time_t myTime=25; + + EXPECT_CALL(pReceiveInterface,ackSinkVolumeTick(_,sinkID,_)); + EXPECT_CALL(pReceiveInterface,ackSetSinkVolumeChange(_,AllOf(Ne(volume),Ne(0)),E_ABORTED)).Times(1); + + ASSERT_EQ(E_OK,pRoutingSender.asyncSetSinkVolume(handle,sinkID,volume,ramp,myTime)); + sleep(0.5); + ASSERT_EQ(E_OK,pRoutingSender.asyncAbort(handle)); + pSocketHandler.start_listenting(); +} + + +TEST_F(testRoutingInterfaceAsync,disconnectTooEarly) +{ + + am_Handle_s handle; + handle.handle=1; + handle.handleType=H_CONNECT; + + am_connectionID_t connectionID=4; + am_sourceID_t sourceID=2; + am_sinkID_t sinkID=1; + am_ConnectionFormat_e format=CF_ANALOG; + + EXPECT_CALL(pReceiveInterface,ackConnect(_,connectionID,E_OK)); + EXPECT_CALL(pReceiveInterface,ackDisconnect(_,connectionID,E_OK)).Times(0); + ASSERT_EQ(E_OK,pRoutingSender.asyncConnect(handle,connectionID,sourceID,sinkID,format)); + ASSERT_EQ(E_NON_EXISTENT,pRoutingSender.asyncDisconnect(handle,connectionID)); + pSocketHandler.start_listenting(); +} + +TEST_F(testRoutingInterfaceAsync,disconnectAbort) +{ + + am_Handle_s handle; + handle.handle=1; + handle.handleType=H_CONNECT; + + am_connectionID_t connectionID=4; + am_sourceID_t sourceID=2; + am_sinkID_t sinkID=1; + am_ConnectionFormat_e format=CF_ANALOG; + + EXPECT_CALL(pReceiveInterface,ackConnect(_,connectionID,E_OK)); + EXPECT_CALL(pReceiveInterface,ackDisconnect(_,connectionID,E_ABORTED)); + ASSERT_EQ(E_OK,pRoutingSender.asyncConnect(handle,connectionID,sourceID,sinkID,format)); + sleep(2); + ASSERT_EQ(E_OK,pRoutingSender.asyncDisconnect(handle,connectionID)); + ASSERT_EQ(E_OK,pRoutingSender.asyncAbort(handle)); + pSocketHandler.start_listenting(); +} + +TEST_F(testRoutingInterfaceAsync,disconnectNonExisting) +{ + + am_Handle_s handle; + handle.handle=1; + handle.handleType=H_CONNECT; + + am_connectionID_t connectionID=4; + am_sourceID_t sourceID=2; + am_sinkID_t sinkID=1; + am_ConnectionFormat_e format=CF_ANALOG; + + EXPECT_CALL(pReceiveInterface,ackConnect(_,connectionID,E_OK)).Times(0); + EXPECT_CALL(pReceiveInterface,ackDisconnect(_,connectionID,E_OK)).Times(0); + ASSERT_EQ(E_NON_EXISTENT,pRoutingSender.asyncDisconnect(handle,connectionID)); + pSocketHandler.start_listenting(); +} + +TEST_F(testRoutingInterfaceAsync,disconnect) +{ + + am_Handle_s handle; + handle.handle=1; + handle.handleType=H_CONNECT; + + am_connectionID_t connectionID=4; + am_sourceID_t sourceID=2; + am_sinkID_t sinkID=1; + am_ConnectionFormat_e format=CF_ANALOG; + + EXPECT_CALL(pReceiveInterface,ackConnect(_,connectionID,E_OK)); + EXPECT_CALL(pReceiveInterface,ackDisconnect(_,connectionID,E_OK)); + ASSERT_EQ(E_OK,pRoutingSender.asyncConnect(handle,connectionID,sourceID,sinkID,format)); + sleep(2); + ASSERT_EQ(E_OK,pRoutingSender.asyncDisconnect(handle,connectionID)); + pSocketHandler.start_listenting(); +} + +TEST_F(testRoutingInterfaceAsync,connectNoMoreThreads) +{ + + am_Handle_s handle; + handle.handle=1; + handle.handleType=H_CONNECT; + + am_connectionID_t connectionID=1; + am_sourceID_t sourceID=2; + am_sinkID_t sinkID=1; + am_ConnectionFormat_e format=CF_ANALOG; + + EXPECT_CALL(pReceiveInterface,ackConnect(_,_,E_OK)).Times(10); + for(int i=0;i<10;i++) + { + handle.handle++; + connectionID++; + ASSERT_EQ(E_OK,pRoutingSender.asyncConnect(handle,connectionID,sourceID,sinkID,format)); + } + ASSERT_EQ(E_NOT_POSSIBLE,pRoutingSender.asyncConnect(handle,connectionID,sourceID,sinkID,format)); + pSocketHandler.start_listenting(); +} + +TEST_F(testRoutingInterfaceAsync,connectAbortTooLate) +{ + + am_Handle_s handle; + handle.handle=1; + handle.handleType=H_CONNECT; + + am_connectionID_t connectionID=4; + am_sourceID_t sourceID=2; + am_sinkID_t sinkID=1; + am_ConnectionFormat_e format=CF_ANALOG; + + EXPECT_CALL(pReceiveInterface,ackConnect(_,connectionID,E_OK)).Times(1); + ASSERT_EQ(E_OK,pRoutingSender.asyncConnect(handle,connectionID,sourceID,sinkID,format)); + sleep(3); + ASSERT_EQ(E_NON_EXISTENT,pRoutingSender.asyncAbort(handle)); + pSocketHandler.start_listenting(); +} + +TEST_F(testRoutingInterfaceAsync,connectAbort) +{ + + am_Handle_s handle; + handle.handle=1; + handle.handleType=H_CONNECT; + + am_connectionID_t connectionID=4; + am_sourceID_t sourceID=2; + am_sinkID_t sinkID=1; + am_ConnectionFormat_e format=CF_ANALOG; + + EXPECT_CALL(pReceiveInterface,ackConnect(_,connectionID,E_ABORTED)).Times(1); + ASSERT_EQ(E_OK,pRoutingSender.asyncConnect(handle,connectionID,sourceID,sinkID,format)); + sleep(0.5); + ASSERT_EQ(E_OK,pRoutingSender.asyncAbort(handle)); + pSocketHandler.start_listenting(); +} + +TEST_F(testRoutingInterfaceAsync,connectWrongFormat) +{ + + am_Handle_s handle; + handle.handle=1; + handle.handleType=H_CONNECT; + + am_connectionID_t connectionID=4; + am_sourceID_t sourceID=2; + am_sinkID_t sinkID=1; + am_ConnectionFormat_e format=CF_MONO; + + EXPECT_CALL(pReceiveInterface,ackConnect(_,connectionID,E_OK)).Times(0); + ASSERT_EQ(E_WRONG_FORMAT,pRoutingSender.asyncConnect(handle,connectionID,sourceID,sinkID,format)); + pSocketHandler.start_listenting(); +} + +TEST_F(testRoutingInterfaceAsync,connectWrongSink) +{ + + am_Handle_s handle; + handle.handle=1; + handle.handleType=H_CONNECT; + + am_connectionID_t connectionID=4; + am_sourceID_t sourceID=2; + am_sinkID_t sinkID=122; + am_ConnectionFormat_e format=CF_ANALOG; + + EXPECT_CALL(pReceiveInterface,ackConnect(_,connectionID,E_OK)).Times(0); + ASSERT_EQ(E_NON_EXISTENT,pRoutingSender.asyncConnect(handle,connectionID,sourceID,sinkID,format)); + pSocketHandler.start_listenting(); +} + +TEST_F(testRoutingInterfaceAsync,connectWrongSource) +{ + am_Handle_s handle; + handle.handle=1; + handle.handleType=H_CONNECT; + + am_connectionID_t connectionID=4; + am_sourceID_t sourceID=25; + am_sinkID_t sinkID=1; + am_ConnectionFormat_e format=CF_ANALOG; + + EXPECT_CALL(pReceiveInterface,ackConnect(_,connectionID,E_OK)).Times(0); + ASSERT_EQ(E_NON_EXISTENT,pRoutingSender.asyncConnect(handle,connectionID,sourceID,sinkID,format)); + pSocketHandler.start_listenting(); +} + +TEST_F(testRoutingInterfaceAsync,connect) +{ + + am_Handle_s handle; + handle.handle=1; + handle.handleType=H_CONNECT; + + am_connectionID_t connectionID=4; + am_sourceID_t sourceID=2; + am_sinkID_t sinkID=1; + am_ConnectionFormat_e format=CF_ANALOG; + + EXPECT_CALL(pReceiveInterface,ackConnect(_,connectionID,E_OK)); + ASSERT_EQ(E_OK,pRoutingSender.asyncConnect(handle,connectionID,sourceID,sinkID,format)); + pSocketHandler.start_listenting(); +} + +int main(int argc, char **argv) +{ + ::testing::InitGoogleTest(&argc, argv); + return RUN_ALL_TESTS(); +} + + |