1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
|
/*
* CAmControlReceiverShadowTest.cpp
*
* Created on: Mar 2, 2012
* Author: christian
*/
#include "CAmControlReceiverShadowTest.h"
using namespace testing;
using namespace am;
CAmControlReceiverShadowTest::CAmControlReceiverShadowTest() :
psocketHandler(), //
pMockReceive(), //
pShadow(&pMockReceive, &psocketHandler), //
ptimerCallback(this, &CAmControlReceiverShadowTest::timerCallback)
{
DefaultValue<am_Error_e>::Set(E_OK); // Sets the default value to be returned.
}
CAmControlReceiverShadowTest::~CAmControlReceiverShadowTest()
{
}
void CAmControlReceiverShadowTest::SetUp()
{
timespec t;
t.tv_nsec = 10000;
t.tv_sec = 0;
sh_timerHandle_t handle;
CAmShTimerCallBack *buf = &ptimerCallback;
//lets use a timeout so the test will finish
psocketHandler.addTimer(t, buf, handle, (void*) NULL);
}
void CAmControlReceiverShadowTest::timerCallback(sh_timerHandle_t handle, void* userData)
{
(void)handle;
(void)userData;
psocketHandler.stop_listening();
}
void CAmControlReceiverShadowTest::TearDown()
{
}
void* run_the_loop(void* socketHandlerPtr)
{
CAmSocketHandler* socketHandler = static_cast<CAmSocketHandler*>(socketHandlerPtr);
socketHandler->start_listenting();
return (NULL);
}
TEST_F(CAmControlReceiverShadowTest,getRoute)
{
pthread_t ptestThread;
bool onlyfree(true);
am_sourceID_t sourceID(1);
am_sinkID_t sinkID(2);
am_Route_s route;
am_RoutingElement_s routingElement;
std::vector<am_RoutingElement_s> route_;
std::vector<am_Route_s> returnList, List;
routingElement.sinkID = 1;
routingElement.sourceID = 2;
routingElement.domainID = 3;
routingElement.connectionFormat = CF_GENIVI_ANALOG;
route_.push_back(routingElement);
route.sinkID = 1;
route.sourceID = 2;
route.route = route_;
returnList.push_back(route);
EXPECT_CALL(pMockReceive,getRoute(onlyfree,sourceID,sinkID,_)).WillOnce(DoAll(SetArgReferee<3>(returnList),Return(E_OK)));
pthread_create(&ptestThread, NULL, run_the_loop, (void*) &psocketHandler);
ASSERT_EQ(E_OK, pShadow.getRoute(onlyfree, sourceID, sinkID, List));
pthread_join(ptestThread, NULL);
}
TEST_F(CAmControlReceiverShadowTest,connect)
{
pthread_t ptestThread;
am_Handle_s handle, handleReturn;
handle.handle = 1;
handle.handleType = H_CONNECT;
am_connectionID_t connectionID(3), connectionIDReturn;
am_ConnectionFormat_e connectionFormat(CF_GENIVI_ANALOG);
am_sourceID_t sourceID(1);
am_sinkID_t sinkID(2);
EXPECT_CALL(pMockReceive, connect(_,_, connectionFormat, sourceID, sinkID)).WillOnce(DoAll(SetArgReferee<0>(handle),SetArgReferee<1>(connectionID),Return(E_OK)));
pthread_create(&ptestThread, NULL, run_the_loop, (void*) &psocketHandler);
ASSERT_EQ(E_OK,pShadow.connect(handleReturn,connectionIDReturn, connectionFormat, sourceID, sinkID));
ASSERT_EQ(handleReturn.handle,handle.handle);
ASSERT_EQ(handleReturn.handleType,handle.handleType);
ASSERT_EQ(connectionIDReturn,connectionID);
pthread_join(ptestThread, NULL);
}
TEST_F(CAmControlReceiverShadowTest,disconnect)
{
pthread_t ptestThread;
am_Handle_s handle, handleReturn;
handle.handle = 1;
handle.handleType = H_CONNECT;
am_connectionID_t connectionID(3);
EXPECT_CALL(pMockReceive, disconnect(_,connectionID)).WillOnce(DoAll(SetArgReferee<0>(handle),Return(E_OK)));
pthread_create(&ptestThread, NULL, run_the_loop, (void*) &psocketHandler);
ASSERT_EQ(E_OK,pShadow.disconnect(handleReturn,connectionID));
ASSERT_EQ(handleReturn.handle,handle.handle);
ASSERT_EQ(handleReturn.handleType,handle.handleType);
pthread_join(ptestThread, NULL);
}
int main(int argc, char **argv)
{
::testing::InitGoogleTest(&argc, argv);
return RUN_ALL_TESTS();
}
|
