Changeset 9887 for fact/tools/FAD/SocketFunctions/SocketFunctions.cpp

Timestamp:

08/20/10 13:02:36 (14 years ago)

Author:

neise

Message:

added 'fadfake' a programm acting as a FAD board. still with very limited funcionality, but 
nice for testing...
added a function OpenServerSocket() to SocketFunctions.cpp

File:

• fact/tools/FAD/SocketFunctions/SocketFunctions.cpp (modified) (1 diff)

fact/tools/FAD/SocketFunctions/SocketFunctions.cpp

@@ -225 +225 @@
 } // end of CloseSockets
         
+
+// returns Array of Sockethandles
+int * OpenServerSockets (unsigned int NumberOfSockets, unsigned int StartPort) {
+
+        // allocate memory for ServerSocket Descriptors
+//      int ServerSocket[NumberOfSockets];
+        int *ServerSocket;
+        ServerSocket = (int *) malloc( NumberOfSockets * sizeof(int) );
+
+        // Create Sockets
+  for(unsigned int i=0 ; i < NumberOfSockets; i++ ){
+    if ((ServerSocket[i] = socket(PF_INET, SOCK_STREAM, 0)) == -1) {
+      printf("Could not open server socket Nr. %d, no remote connection possible .\n", i);
+      return NULL;
+    }
+  }
+
+  // Allows immediate reuse of socket after closing (circumvents TIME_WAIT)
+  int Value=1;
+  for(unsigned int i=0 ; i < NumberOfSockets; i++ ){
+    if (setsockopt(ServerSocket[i], SOL_SOCKET, SO_REUSEADDR, (char *) &Value, sizeof (Value)) == -1) {
+      printf("Warning (ServerSocket Nr. %d): Could not set server socket option SO_REUSEADDR \n", i);
+    }
+  }
+  
+        struct sockaddr_in SocketAddress[NumberOfSockets];
+  for(unsigned int i=0 ; i < NumberOfSockets; i++ ){
+    SocketAddress[i].sin_family = PF_INET;
+    SocketAddress[i].sin_port = htons((unsigned short) StartPort + i);
+    SocketAddress[i].sin_addr.s_addr = INADDR_ANY;
+  }
+
+
+  for(unsigned int i=0 ; i < NumberOfSockets; i++ ){
+    if (bind(ServerSocket[i], (struct sockaddr *) &SocketAddress[i], sizeof(SocketAddress[i])) == -1) {
+      printf("Could not bind port %d to socket Nr.: %d\n", StartPort+i, i );
+      close(ServerSocket[i]);
+      return NULL;
+    }
+  }
+
+  for(unsigned int i=0 ; i < NumberOfSockets; i++ ){
+    if (listen(ServerSocket[i], 0) == -1) {
+      printf("Could not set socket Nr. %d to listening \n", i);
+      close(ServerSocket[i]);
+      return NULL;
+    }
+  }
+
+        int *ConnectionSocket;
+        ConnectionSocket = (int *) malloc( NumberOfSockets * sizeof(int) );
+        struct sockaddr_in ClientAddress;
+  socklen_t SizeClientAddress=sizeof(ClientAddress);
+  
+
+//  while (1) { // Looping to wait for incoming connection
+        printf ("Waiting for connection...\n");
+          for(unsigned int i=0 ; i < NumberOfSockets; i++ ){
+                        if ((ConnectionSocket[i] = accept(ServerSocket[i], (struct sockaddr *) &ClientAddress, &SizeClientAddress)) == -1){
+                                close(ServerSocket[i]);
+                                return NULL;
+                        }
+        }
+//      }
+  for(unsigned int i=0 ; i < NumberOfSockets; i++ ){
+        //      close(ServerSocket[i]); 
+        }
+
+        printf("Connected to client at %s \n", inet_ntoa(ClientAddress.sin_addr));
+        return ConnectionSocket;
+} // end of OpenServerSockets