Changeset 554 for vtcross/branches/nikhil/crossmodel1/src/shell/CognitiveRadioShell.cpp

Timestamp:

05/17/10 03:14:03 (14 years ago)

Author:

nikhil

Message:

 

Location:

vtcross/branches/nikhil/crossmodel1

Files:

• . (copied) (copied from vtcross/trunk)
• src/shell/CognitiveRadioShell.cpp (modified) (14 diffs)

vtcross/branches/nikhil/crossmodel1/src/shell/CognitiveRadioShell.cpp

@@ -183 +183 @@
         }
     }
+
     
     /* Receive ACK for radio configuration */
@@ -215 +216 @@
         return false;
     }
+
     return true;
 }
@@ -252 +254 @@
 }
 
-
-void
-CognitiveRadioShell::RegisterPolicyEngine(int32_t socketFD)
-{
-    LOG("Cognitive Radio Shell:: Received registration from Policy Engine on socket %d.\n", \
-            socketFD);
-
-    PE_present = true;
-}
-
-
-void 
-CognitiveRadioShell::DeregisterPolicyEngine(int32_t socketFD)
-{
-    LOG("Cognitive Radio Shell:: Received deregistration message from Policy Engine.\n");
-
-    PE_present = false;
-    
-    SendMessage(socketFD, "deregister_ack");
-    shutdown(socketFD, 2);
-    close(socketFD);
-    LOG("Cognitive Radio Shell:: Socket %d closed.\n", socketFD);
-}
-
-
-void
-CognitiveRadioShell::RegisterSML(int32_t socketFD)
-{
-    LOG("Cognitive Radio Shell:: Received registration from SML on socket %d.\n", \
-            socketFD);
-
-    SML_present = true;
-}
-
-
-void 
-CognitiveRadioShell::DeregisterSML(int32_t socketFD)
-{
-    LOG("Cognitive Radio Shell:: Received deregistration message from SML.\n");
-
-    SML_present = false;
-
-    SendMessage(socketFD, "deregister_ack");
-    shutdown(socketFD, 2);
-    close(socketFD);
-    LOG("Cognitive Radio Shell:: Socket %d closed.\n", socketFD);
-}
-
-void 
-CognitiveRadioShell::SetActiveMission(int32_t socketFD)
-{
-    char buffer[256];
-
-    LOG("Cognitive Radio Shell:: Received Set Active Mission command from host.\n");
-   
-    /* Read the name of the active mission to be set from the host. */
-    memset(buffer, 0, 256);
-    ReadMessage(commandSocketFD, buffer);
-
-    /* Send command to SML. */
-    SendMessage(ceSocketFD, "set_active_mission");
-    SendMessage(ceSocketFD, buffer);
-
-    /* Get ack from SML saying the mission was set properly */
-    memset(buffer, 0, 256);
-    ReadMessage(ceSocketFD, buffer);
-
-    /* Forward ack to host */
-    SendMessage(commandSocketFD, buffer);
-}
 
 void 
@@ -415 +347 @@
             }
 
-            if(!match_found) { 
-                ERROR(1, "Error: %s: %s is not a valid utility.\n", \
-                    oList[item_count].name.c_str(), oUtilName);
-            }
-            else
-                match_found = false;    
+  
+//////////////////WE are not looking for relationship between them..            
+//            if(!match_found) { 
+//                ERROR(1, "Error: %s: %s is not a valid utility.\n", \
+//                    oList[item_count].name.c_str(), oUtilName);
+//            }
+//            else
+//                match_found = false;    
         }
         oList[item_count].numAffects = affect_count; 
@@ -476 +410 @@
             }
 
-            if(!match_found) {
-                ERROR(1, "Error: %s: %s is not a valid utility.\n", \
-                    pList[item_count].name.c_str(), pUtilName);
-            }
-
-            match_found = false;    
+//            if(!match_found) {
+//                ERROR(1, "Error: %s: %s is not a valid utility.\n", \
+//                    pList[item_count].name.c_str(), pUtilName);
+//            }
+
+//            match_found = false;    
         }
 
@@ -536 +470 @@
         cp[i].value = atof(buffer);
     }
+////////////// NEW    INCLUSION ///////////////////
+
+/* Receive Set of Utilities */
+    memset(buffer, 0, 256);
+    ReadMessage(commandSocketFD,buffer);
+    uint32_t numUtilities = atoi(buffer);
+
+    LOG("Cognitive Radio Shell:: Attempting to get %i utilities.\n",numUtilities);
+    Utility *u = new Utility[numUtilities];
+
+    for (size_t i = 0;i < numUtilities; i++){
+        memset(buffer, 0, 256);
+        ReadMessage(commandSocketFD,buffer);
+        u[i].name = std::string(buffer);
+
+        memset(buffer, 0, 256);
+        ReadMessage(commandSocketFD,buffer);
+        u[i].value = atof(buffer);
+    }
+
+///////////////////////////////////////
 
     /* Send to Cognitive Engine 
@@ -541 +496 @@
      * to send this information
      */
+    SendMessage(ceSocketFD,"request_optimization");
+
     LOG("Cognitive Radio Shell:: Passing on observables.\n");
-    SendMessage(ceSocketFD,"request_optimization");
     sprintf(counter,"%i",numObservables);
     SendMessage(ceSocketFD,counter);
@@ -559 +515 @@
         SendMessage(ceSocketFD,var); 
     }
+
+/////////////  NEW  ////////////////////////////////////////////////////////
+    LOG("Cognitive Radio Shell:: Passing on utilities.\n");
+    sprintf(counter,"%i",numUtilities);
+    SendMessage(ceSocketFD,counter);
+    for(size_t i = 0; i < numUtilities; i++) {
+        SendMessage(ceSocketFD,u[i].name.c_str());
+        sprintf(var,"%f",u[i].value);
+        SendMessage(ceSocketFD,var);
+    }
+
+////////////// END of NEW /////////////////////////////////////
 
     /* Receive Set of Parameters */
@@ -591 +559 @@
 
     delete [] o;
+    delete [] u;
     delete [] p;
 }
@@ -634 +603 @@
         ReadMessage(commandSocketFD, buffer);
         o[i].value = atof(buffer);
+    }
+
+    /* Receive Set of Utilities */
+    memset(buffer, 0, 256);
+    ReadMessage(commandSocketFD, buffer);
+    uint32_t numUtilities = atoi(buffer);
+
+    Utility *u = new Utility[numUtilities];
+
+    for(size_t i = 0; i < numUtilities; i++) {
+        memset(buffer, 0, 256);
+        ReadMessage(commandSocketFD, buffer);
+        u[i].name = std::string(buffer);
+
+        memset(buffer, 0, 256);
+        ReadMessage(commandSocketFD, buffer);
+        u[i].value = atof(buffer);
     }
 
@@ -650 +636 @@
     
     /* Send Observables */
+    memset(counter, 0, 55);
     sprintf(counter, "%i", numObservables);
     SendMessage(ceSocketFD, counter);
@@ -658 +645 @@
     }   
 
+     /* Send Utilities */
+     memset(counter, 0, 55);
+     sprintf(counter, "%i", numUtilities);
+     SendMessage(ceSocketFD,counter);
+     for(size_t i = 0; i < numUtilities; i++) {
+        SendMessage(ceSocketFD, u[i].name.c_str());
+        sprintf(var, "%f", u[i].value);
+        SendMessage(ceSocketFD, var);
+     }
+
+
     delete [] p;
     delete [] o;
+    delete [] u;
 }
 
@@ -678 +677 @@
     } else if(strcmp(buffer, "deregister_engine_cognitive") == 0) {
         DeregisterCognitiveEngine(socketFD);
-    } else if(strcmp(buffer, "register_engine_policy") == 0) {
-        RegisterPolicyEngine(socketFD);
-    } else if(strcmp(buffer, "deregister_engine_policy") == 0) {
-        DeregisterPolicyEngine(socketFD);
-    } else if(strcmp(buffer, "register_sml") == 0) {
-        RegisterSML(socketFD);
-    } else if(strcmp(buffer, "deregister_sml") == 0) {
-        DeregisterSML(socketFD);
     } else if(strcmp(buffer, "update_performance") == 0) {
         UpdateParameterPerformance(socketFD);
@@ -703 +694 @@
         /* Receive optimization request and current environment */
         GetOptimalParameters(socketFD);  
-    } else if(strcmp(buffer, "set_active_mission") == 0) {
-        SetActiveMission(socketFD);  
-    } else if(strcmp(buffer, "request_optimization_service") == 0) {
-        /* Receive optimization request and current environment */
-        //GetOptimalParametersService(socketFD);  
-    }
+    } 
 
     return ret;