Changeset 222 for vtcross/trunk/src/shell/CognitiveRadioShell.cpp

Timestamp:

03/30/09 21:38:53 (15 years ago)

Author:

trnewman

Message:

Added libvtcross functionality. Made socketcomm a little more robust. Added libvtcross demo application to illustrate how to use the lib.

Files:

• vtcross/trunk/src/shell/CognitiveRadioShell.cpp (modified) (8 diffs)

vtcross/trunk/src/shell/CognitiveRadioShell.cpp

@@ -125 +125 @@
     // send utility     
     for(i = 0; i < radio_info->numUtilities; i++) {
-        SendMessage(socketfd, u[i].name.c_str());
-        SendMessage(socketfd, u[i].units.c_str());
-        SendMessage(socketfd, u[i].goal.c_str());
-        sprintf(var,"%f", u[i].target);
+        SendMessage(socketfd, utils[i].name.c_str());
+        SendMessage(socketfd, utils[i].units.c_str());
+        SendMessage(socketfd, utils[i].goal.c_str());
+        sprintf(var,"%f", utils[i].target);
         SendMessage(socketfd,var);
     }
@@ -136 +136 @@
     SendMessage(socketfd,counter);
     for(i = 0; i < radio_info->numParameters; i++) {
-        SendMessage(socketfd,p[i].name.c_str());
-        SendMessage(socketfd,p[i].units.c_str());
-        sprintf(var,"%f",p[i].min);
+        SendMessage(socketfd,params[i].name.c_str());
+        SendMessage(socketfd,params[i].units.c_str());
+        sprintf(var,"%f",params[i].min);
         SendMessage(socketfd,var);
-        sprintf(var,"%f",p[i].max);
+        sprintf(var,"%f",params[i].max);
         SendMessage(socketfd,var);
-        sprintf(var,"%f",p[i].step);
+        sprintf(var,"%f",params[i].step);
         SendMessage(socketfd,var);
 
-        sprintf(counter,"%i",p[i].numAffects); 
+        sprintf(counter,"%i",params[i].numAffects); 
         SendMessage(socketfd,counter);
-        for(j = 0; j < p[i].numAffects; j++) {
-            SendMessage(socketfd,p[i].affection_list[j].u->name.c_str());
-            SendMessage(socketfd,p[i].affection_list[j].relation.c_str());
+        for(j = 0; j < params[i].numAffects; j++) {
+            SendMessage(socketfd,params[i].affection_list[j].u->name.c_str());
+            SendMessage(socketfd,params[i].affection_list[j].relation.c_str());
         }
     }
@@ -157 +157 @@
     SendMessage(socketfd,counter);
     for(i = 0; i < radio_info->numObservables; i++) {
-        SendMessage(socketfd,o[i].name.c_str());
+        SendMessage(socketfd,observables[i].name.c_str());
                 
-        sprintf(counter,"%i",o[i].numAffects); 
+        sprintf(counter,"%i",observables[i].numAffects); 
         SendMessage(socketfd,counter);
-        for(j = 0; j < o[i].numAffects; j++) {
-            SendMessage(socketfd,o[i].affection_list[j].u->name.c_str());
-            SendMessage(socketfd,o[i].affection_list[j].relation.c_str());
+        for(j = 0; j < observables[i].numAffects; j++) {
+            SendMessage(socketfd,observables[i].affection_list[j].u->name.c_str());
+            SendMessage(socketfd,observables[i].affection_list[j].relation.c_str());
         }
     }
@@ -186 +186 @@
     LOG("Cognitive Radio Shell:: Sending radio experience to Cognitive Engine.\n");
     int32_t numberExp = 4;
-    
-    std::string numberExpString = numberExp;
-    SendMessage(socketFD, numberExp); 
+        char numberExpString[50];
+
+    sprintf(numberExpString,"%i",numberExp);
+    SendMessage(socketFD, numberExpString); 
 
     char buffer[256];
@@ -451 +452 @@
 CognitiveRadioShell::GetOptimalParameters(int32_t socketFD)
 {
+    char buffer[256];
+    uint32_t numObservables,numParameters;
+    char counter[55];
+    uint16_t i;
+    char var[50];
+
+    /* Receive Set of Observables */
+    LOG("Cognitive Radio Shell:: Got request for optimization.\n");
+    memset(buffer, 0, 256);
+    ReadMessage(commandSocketFD,buffer);
+    numObservables = atoi(buffer);
+  
+        LOG("Cognitive Radio Shell:: Attempting to get %i observables.\n",numObservables);
+    Observable * o = new Observable[numObservables];
+ 
+    for (i = 0; i < numObservables; i++){
+        memset(buffer, 0, 256);
+        ReadMessage(commandSocketFD,buffer);
+        o[i].name = std::string(buffer);
+    
+        memset(buffer, 0, 256);
+        ReadMessage(commandSocketFD,buffer);
+        o[i].value = atof(buffer);
+    }
+
+    /* Send to Cognitive Engine 
+         * TODO: With multiple CEs we need to make a decision about where
+         * to send this information
+         */
+
+        LOG("Cognitive Radio Shell:: Passing on observables to Cognitive Engine\n");
+    SendMessage(ceSocketFD,"get_solution");
+    sprintf(counter,"%i",numObservables);
+    SendMessage(ceSocketFD,counter);
+    for(i = 0; i < numObservables; i++) {
+        SendMessage(ceSocketFD,o[i].name.c_str());
+        sprintf(var,"%f",o[i].value);
+            SendMessage(ceSocketFD,var);
+    }
+
+
+        LOG("Cognitive Radio Shell:: Receiving optimized parameters from Cognitive Engine.\n");
+    /* Receive Set of Parameters */
+    memset(buffer, 0, 256);
+    ReadMessage(ceSocketFD,buffer);
+    numParameters = atoi(buffer);
+   
+    Parameter * p = new Parameter[numParameters];
+ 
+    for (i = 0; i < numParameters; i++){
+        memset(buffer, 0, 256);
+        ReadMessage(ceSocketFD,buffer);
+        LOG("socket_comm::Get Parameter - Name: %s\n", buffer);
+        p[i].name = std::string(buffer);
+    
+        memset(buffer, 0, 256);
+        ReadMessage(ceSocketFD,buffer);
+        LOG("socket_comm::Get Parameter - Value: %s\n", buffer);
+        p[i].value = atof(buffer);
+    }
+
+    /* Send to Application 
+         */
+        LOG("Cognitive Radio Shell:: Sending optimized parameters to Application.\n");
+    memset(counter, 0, 55);
+    sprintf(counter,"%i",numParameters);
+    SendMessage(commandSocketFD,counter);
+    for(i = 0; i < numParameters; i++) {
+        SendMessage(commandSocketFD,p[i].name.c_str());
+        sprintf(var,"%f",p[i].value);
+            SendMessage(commandSocketFD,var);
+    }
 }
 
@@ -473 +546 @@
     } else if(strcmp(buffer,"deregister_sml") == 0) {
         DeregisterSML(socketFD);
-    } else if(strcmp(buffer,"optimize") == 0) {
+    } else if(strcmp(buffer,"request_optimization") == 0) {
         /* Receive optimization request and current environment */
         GetOptimalParameters(socketFD);  
@@ -499 +572 @@
     servSock[command] = CreateTCPServerSocket(commandPort);
 
-    int32_t maxDescriptor = servSock[command];
+    int32_t maxDescriptor; 
+
+        if(servSock[primary] > servSock[policy])
+                maxDescriptor = servSock[primary];
+    else 
+                maxDescriptor = servSock[policy];
+
+        if(servSock[command] > maxDescriptor)
+                maxDescriptor = servSock[command];
 
     if(InitializeTCPServerPort(servSock[primary]) == -1)
@@ -540 +621 @@
                             if(new_sd < 0) 
                                 break;
-                            
+                           
+                            if(port == servSock[primary])
+                                ceSocketFD = new_sd;
+                            if(port == servSock[command])
+                                commandSocketFD = new_sd;
+                            if(port == servSock[policy])
+                                policySocketFD = new_sd;
+
                             HandleMessage(new_sd);
                             FD_SET(new_sd,&sockSet);