Changeset 64 for vtcross/branches

Timestamp:

11/20/08 15:25:32 (16 years ago)

Author:

trnewman

Message:

Added better socket functionality.

Files:

• vtcross/branches/trnewman/CR_shell/src/main_cognitive_radio.cpp (modified) (4 diffs)

vtcross/branches/trnewman/CR_shell/src/main_cognitive_radio.cpp

@@ -227 +227 @@
                 n = recv(socketfd,buffer,255,0);
                 if (n < 0) error("ERROR reading from socket");
-                if (n == 0) error("Client has closed the connection.");
+                if (n == 0) {
+                        printf("Client has closed the connection.\n");
+                        return;
+                }
                 
                 // Print message
@@ -257 +260 @@
         listen(sockfd,5);
         clilen = sizeof(cli_addr);
-        newsockfd = accept(sockfd, 
-                (struct sockaddr *) &cli_addr, 
-                (socklen_t*)&clilen);
-        if (newsockfd < 0) 
-                error("ERROR on accept");
-
-        // Begin parsing the messages
-        StartMessageParser(newsockfd);
-
+
+        while(1) {
+                newsockfd = accept(sockfd, 
+                        (struct sockaddr *) &cli_addr, 
+                        (socklen_t*)&clilen);
+                if (newsockfd < 0) 
+                        error("ERROR on accept");
+
+                // Begin parsing the messages
+                StartMessageParser(newsockfd);
+        }
         return 0;
 }
@@ -275 +280 @@
         // CognitiveEngineShell Shell;
         string pFilename; 
+        int pid;
 
         Utility * uList[10];
@@ -300 +306 @@
         cout << "Configuration file parsing completed." << endl;
 
-        // Open cognitive engine port   
-        StartShell(30000);
-
-        // Open policy engine port
-//      StartShell(30001);
+        pid = fork();
+        if(pid == 0) {
+                // In child process - open policy engine port.
+                StartShell(30001);
+        } else {
+                // In parent process - open cognitive engine port.
+                StartShell(30000);
+        } 
+        
 
    return 1;