From b7e748007bbe0b16fa8a8a089c6cc8fe43bc7aac Mon Sep 17 00:00:00 2001
From: christian mueller <christian.ei.mueller@bmw.de>
Date: Wed, 28 Dec 2011 15:55:32 +0100
Subject: * assert on empty busname (routinginterface) * added busname for
 DbusroutingSender * rework of sockethandlertests * small changes on
 compilerflags * new default error messages on dummy controller plugin * new
 plugin Asynchronous including tests

---
 .../test/sockethandler/sockethandlerTest.cpp       | 80 ++++++++++++++++++----
 1 file changed, 68 insertions(+), 12 deletions(-)

(limited to 'AudioManagerDaemon/test/sockethandler/sockethandlerTest.cpp')

diff --git a/AudioManagerDaemon/test/sockethandler/sockethandlerTest.cpp b/AudioManagerDaemon/test/sockethandler/sockethandlerTest.cpp
index 69af391..87b2751 100644
--- a/AudioManagerDaemon/test/sockethandler/sockethandlerTest.cpp
+++ b/AudioManagerDaemon/test/sockethandler/sockethandlerTest.cpp
@@ -84,11 +84,54 @@ void am::timerCallBack::timer4Callback(sh_timerHandle_t, void* userData)
 void* playWithSocketServer(void* data)
 {
 	SocketHandler myHandler;
-	SamplePlugin myplugin(&myHandler);
+	SamplePlugin::sockType_e type=SamplePlugin::INET;
+	SamplePlugin myplugin(&myHandler,type);
 	myHandler.start_listenting();
 }
 
+void* playWithUnixSocketServer(void* data)
+{
+	SocketHandler myHandler;
+	SamplePlugin::sockType_e type=SamplePlugin::UNIX;
+	SamplePlugin myplugin(&myHandler,type);
+	myHandler.start_listenting();
+}
+
+TEST(sockethandlerTest,playWithUNIXSockets)
+{
+	pthread_t serverThread;
+	char buffer[3000];
+	struct sockaddr_un servAddr;
+	int socket_;
+
+	//creates a thread that handles the serverpart
+	pthread_create(&serverThread,NULL,playWithUnixSocketServer,NULL);
+
+	sleep(1); //we need that here because the port needs to be opened
+    if ((socket_ = socket(AF_UNIX, SOCK_STREAM, 0)) < 0)
+    {
+    	std::cout<<"socket problem"<<std::endl;
+
+    }
+
+    memset(&servAddr, 0, sizeof(servAddr));
+    strcpy(servAddr.sun_path, SOCK_PATH);
+    servAddr.sun_family = AF_UNIX;
+    if (connect(socket_, (struct sockaddr *) &servAddr, sizeof(servAddr)) < 0)
+    {
+     	std::cout<<"ERROR: connect() failed\n"<<std::endl;
+    }
+
+	for (int i=0;i<=1000;i++)
+	{
+		std::string string("Got It?");
+		send(socket_,string.c_str(),string.size(),0);
+	}
+	std::string string("finish!");
+	send(socket_,string.c_str(),string.size(),0);
 
+	pthread_join(serverThread,NULL);
+}
 
 TEST(sockethandlerTest,playWithSockets)
 {
@@ -176,7 +219,7 @@ int main(int argc, char **argv)
 	return RUN_ALL_TESTS();
 }
 
-am::SamplePlugin::SamplePlugin(SocketHandler *mySocketHandler)
+am::SamplePlugin::SamplePlugin(SocketHandler *mySocketHandler, sockType_e socketType)
 	:connectFiredCB(this,&SamplePlugin::connectSocket),
 	 receiveFiredCB(this,&SamplePlugin::receiveData),
 	 sampleDispatchCB(this,&SamplePlugin::dispatchData),
@@ -189,19 +232,32 @@ am::SamplePlugin::SamplePlugin(SocketHandler *mySocketHandler)
 	int ret;
 	int yes = 1;
 
+	int socketHandle;
 	struct sockaddr_in servAddr;
+	struct sockaddr_un unixAddr;
 	unsigned int servPort = 6060;
-	int socketHandle = socket(PF_INET, SOCK_STREAM, IPPROTO_TCP);
-    setsockopt(socketHandle, SOL_SOCKET, SO_REUSEADDR, &yes, sizeof(int));
-    memset(&servAddr, 0, sizeof(servAddr));
-    servAddr.sin_family      = AF_INET;
-    servAddr.sin_addr.s_addr = INADDR_ANY;
-    servAddr.sin_port        = htons(servPort);
 
-    if (bind(socketHandle, (struct sockaddr *) &servAddr, sizeof(servAddr)) < 0)
-    {
-    	std::cout<<"bind ok"<<std::endl;
-    } /* if */
+	switch (socketType)
+	{
+	case UNIX:
+		socketHandle = socket(AF_UNIX, SOCK_STREAM, 0);
+		unixAddr.sun_family = AF_UNIX;
+		strcpy(unixAddr.sun_path,SOCK_PATH);
+		unlink(unixAddr.sun_path);
+		bind(socketHandle, (struct sockaddr *)&unixAddr, strlen(unixAddr.sun_path) + sizeof(unixAddr.sun_family));
+		break;
+	case INET:
+		socketHandle = socket(PF_INET, SOCK_STREAM, IPPROTO_TCP);
+		setsockopt(socketHandle, SOL_SOCKET, SO_REUSEADDR, &yes, sizeof(int));
+		memset(&servAddr, 0, sizeof(servAddr));
+		servAddr.sin_family      = AF_INET;
+		servAddr.sin_addr.s_addr = INADDR_ANY;
+		servAddr.sin_port        = htons(servPort);
+	    bind(socketHandle, (struct sockaddr *) &servAddr, sizeof(servAddr));
+	    break;
+	default:
+		break;
+	}
 
     if (listen(socketHandle, 3) < 0)
     {
-- 
cgit v1.2.1