Changeset 222 for vtcross/trunk/src/cognitive_engines/CognitiveEngine.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/cognitive_engines/CognitiveEngine.cpp (modified) (9 diffs)

vtcross/trunk/src/cognitive_engines/CognitiveEngine.cpp

@@ -88 +88 @@
 {
     char buffer[256];
+    uint16_t i;
 
     while(true) {
@@ -102 +103 @@
         // switch on the integer value...
         if(strcmp(buffer, "get_solution") == 0) {
-        
-
+            
+            /* Receive Set of Observables */
+                        LOG("Cognitive Engine:: Receiving observables.\n");
+
+            memset(buffer, 0, 256);
+            ReadMessage(commandSocketFD,buffer);
+            uint32_t numObservables = atoi(buffer);
+   
+            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);
+            }  
+
+                        LOG("Cognitive Engine:: Sending Optimal Parameters.\n");
+            SendMessage(commandSocketFD,"1");
+            SendMessage(commandSocketFD,"txPower");
+            SendMessage(commandSocketFD,"10");
         }
         else if(strcmp(buffer, "query_component_type") == 0) {
@@ -266 +289 @@
         memset(buffer, 0, 256);
         ReadMessage(commandSocketFD,buffer);
-        LOG("socket_comm::Get Utility - Name: %s\n", buffer);
         uList[i].name = std::string(buffer);
     
@@ -286 +308 @@
     ReadMessage(commandSocketFD, buffer);
     radioInfo->numParameters = atoi(buffer);
-    LOG("socket_comm::GetParameter - Number of parameters: %d\n", \
-            radioInfo->numParameters);
     
     for(size_t i = 0; i < radioInfo->numParameters; i++) {
         memset(buffer, 0, 256);
         ReadMessage(commandSocketFD, buffer);
-        LOG("socket_comm::GetParameter - Name: %s\n", buffer);
         pList[i].name = std::string(buffer);
     
         memset(buffer, 0, 256);
         ReadMessage(commandSocketFD, buffer);
-        LOG("socket_comm::GetParameter - Units: %s\n", buffer);
         pList[i].units = std::string(buffer);
 
         memset(buffer, 0, 256);
         ReadMessage(commandSocketFD, buffer);
-        LOG("socket_comm::GetParameter - Min: %s\n", buffer);
         pList[i].min = atof(buffer);
     
         memset(buffer, 0, 256);
         ReadMessage(commandSocketFD, buffer);
-        LOG("socket_comm::GetParameter - Max: %s\n", buffer);
         pList[i].max = atof(buffer);
     
         memset(buffer, 0, 256);
         ReadMessage(commandSocketFD, buffer);
-        LOG("socket_comm::GetParameter - Step: %s\n", buffer);
         pList[i].step = atof(buffer);
     
         memset(buffer, 0, 256);
         ReadMessage(commandSocketFD,buffer);
-        LOG("socket_comm::GetParameter - Number of Affects: %s\n", buffer);
         pList[i].numAffects = atoi(buffer);
     
@@ -323 +337 @@
             memset(buffer, 0, 256);
             ReadMessage(commandSocketFD,buffer);
-            LOG("socket_comm::GetParameter - Affect Name: %s\n", buffer);
             for (k = 0; k < radioInfo->numUtilities; k++){
                 if(uList[k].name == std::string(buffer)){    
@@ -333 +346 @@
             memset(buffer, 0, 256);
             ReadMessage(commandSocketFD,buffer);
-            LOG("socket_comm::GetParameter - Affect Relation: %s\n", buffer);
             pList[i].affection_list[j].relation = std::string(buffer);   
         }
@@ -346 +358 @@
         memset(buffer, 0, 256);
         ReadMessage(commandSocketFD,buffer);
-        LOG("socket_comm::Get Observable - Name: %s\n", buffer);
         oList[i].name = std::string(buffer);
     
         memset(buffer, 0, 256);
         ReadMessage(commandSocketFD,buffer);
-        LOG("socket_comm::Get Observable - Number Affects: %s\n", buffer);
         oList[i].numAffects = atoi(buffer);
     
@@ -357 +367 @@
             memset(buffer, 0, 256);
             ReadMessage(commandSocketFD,buffer);
-            LOG("socket_comm::Get Observable - Affect Name: %s\n", buffer);
             for (k = 0; k < radioInfo->numUtilities; k++){
                 if(uList[k].name == std::string(buffer)){    
@@ -367 +376 @@
             memset(buffer, 0, 256);
             ReadMessage(commandSocketFD,buffer);
-            LOG("socket_comm::Get Observable - Affect Relation: %s\n", buffer);
             oList[i].affection_list[j].relation = std::string(buffer);   
         }