Changeset 230 for vtcross/trunk/src/cognitive_engines/CognitiveEngine.cpp

Timestamp:

04/03/09 13:05:41 (15 years ago)

Author:

trnewman

Message:

Added a loop in the demo to actually adapt.

Added simple adaptation functionality and proper db querying in the CE.

Files:

• vtcross/trunk/src/cognitive_engines/CognitiveEngine.cpp (modified) (9 diffs)

vtcross/trunk/src/cognitive_engines/CognitiveEngine.cpp

@@ -12 +12 @@
 #include <cstring>
 #include <stdint.h>
+#include <math.h>
 
 #include "vtcross/common.h"
@@ -94 +95 @@
 
 void 
+CognitiveEngine::ReceiveFeedback(Observable *observables, Parameter *parameters)
+{ 
+   LOG("Cognitive Engine:: Receiving feedback.\n");
+        
+        uint32_t numberColumns = 
+                radioInfo->numParameters +
+                radioInfo->numUtilities;
+
+        uint32_t obsColumns = radioInfo->numObservables + 1;
+
+        float valList[numberColumns];
+        float obsVals[numberColumns];
+    char *nameList[numberColumns];
+    char *obsList[obsColumns];
+
+    size_t columnObsIndex = 0;
+    for (size_t i = 0; i < radioInfo->numObservables; i++){
+                obsList[columnObsIndex] = (char*)observables[i].name.c_str();
+        columnObsIndex++;
+    }  
+    obsList[columnObsIndex] = "utility";
+
+    size_t columnIndex = 0;
+    for (size_t i = 0; i < radioInfo->numParameters; i++){
+                nameList[columnIndex] = (char*)parameters[i].name.c_str();
+        columnIndex++;
+    }   
+    for (size_t i = 0; i < radioInfo->numUtilities; i++){
+                nameList[columnIndex] = (char*)uList[i].name.c_str();
+        columnIndex++;
+    }   
+
+        size_t obsValueIndex = 0;
+    for(size_t i = 0; i < radioInfo->numObservables; i++) {
+                obsVals[obsValueIndex] = observables[i].value;
+                obsValueIndex++;
+        }
+        // Calculate Utility
+        float newUtilityValue = 0;
+
+    for(size_t i = 0; i < radioInfo->numUtilities; i++) {
+                newUtilityValue = newUtilityValue + (uList[i].target - observables[i].value);
+        }
+        obsVals[obsValueIndex] = newUtilityValue;
+
+        size_t returnValueIndex = 0;
+    for(size_t i = 0; i < radioInfo->numParameters; i++) {
+                valList[returnValueIndex] = parameters[i].value;
+                returnValueIndex++;
+        }
+    for(size_t i = 0; i < radioInfo->numUtilities; i++) {
+                valList[returnValueIndex] = uList[i].target;
+                returnValueIndex++;
+        }
+
+
+        cbr_update(myCBR, nameList, obsList, valList, obsVals, 
+                        numberColumns, obsColumns);
+}
+
+
+void 
 CognitiveEngine::WaitForSignal()
 {
@@ -110 +173 @@
         // MUCH faster since instead of donig string compares we can simply
         // switch on the integer value...
-        if(strcmp(buffer, "request_optimization") == 0) {
+        if(strcmp(buffer, "update_performance") == 0) {
             
+            /* Receive Set of current Parameters */
+            memset(buffer, 0, 256);
+            ReadMessage(commandSocketFD,buffer);
+            uint32_t numParameters = atoi(buffer);
+   
+            Parameter *p = new Parameter[numParameters];
+ 
+            for(size_t i = 0; i < numParameters; i++) {
+                memset(buffer, 0, 256);
+                ReadMessage(commandSocketFD, buffer);
+                p[i].name = std::string(buffer);
+    
+                memset(buffer, 0, 256);
+                ReadMessage(commandSocketFD, buffer);
+                p[i].value = atof(buffer);
+            } 
+
             /* Receive Set of Observables */
-                        LOG("Cognitive Engine:: Receiving Observable Parameters\n");
-
             memset(buffer, 0, 256);
             ReadMessage(commandSocketFD,buffer);
@@ -131 +209 @@
             }  
 
+                        ReceiveFeedback(o,p);
+
+            delete [] o;
+            delete [] p;
+                } 
+                else if(strcmp(buffer, "request_optimization") == 0) {
+            
+            /* Receive Set of Observables */
+                        LOG("\nCognitive Engine:: Receiving Observable Parameters\n");
+
+            memset(buffer, 0, 256);
+            ReadMessage(commandSocketFD,buffer);
+            uint32_t numObservables = atoi(buffer);
+   
+            Observable *o = new Observable[numObservables];
+ 
+            for(size_t 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);
+            }  
+
             /* Receive Set of current Parameters */
                         LOG("Cognitive Engine:: Receiving Current Transmission Parameters\n");
@@ -156 +260 @@
 
             // TODO need to actually do something with the observables here
-            
+           
                         LOG("Cognitive Engine:: Sending Optimal Parameters to Application.\n");
                         char numParametersChar[10];
@@ -453 +557 @@
 
     for(size_t i = 0; i < radioInfo->numUtilities; i++) {
-        searchNames[i] = (char*)uList[i].name.c_str();
+        searchNames[i] = (char*)observables[i].name.c_str();
         }
 
@@ -492 +596 @@
         if(rc == 0){
         /* Adapt the returned parameters to meet the objective */
-
+            
+        WARNING("Cognitive Engine:: Found\n");
+
+                // Should do a random adaptation.. 
+                if(returnValues[numberColumns-1] < 0) {
+                        returnValues[2] = returnValues[2] - 15;
+                        returnValues[3] = returnValues[3] - 2;
+        } else {
+                        returnValues[2] = returnValues[2] + 15;
+                        returnValues[3] = returnValues[3] + 2;
+                }
     } else if(rc == 31337){
+        WARNING("Cognitive Engine:: Not Found.\n");
                 /* No rows in the CBR, pick default parameters */
                 // Currently this is hard coded and implementation specific!
-            //returnValues[2] = currentParameters[0].value + 5;
-            //returnValues[3] = currentParameters[1].value + 10;
+            returnValues[2] = currentParameters[0].value + 5;
+            returnValues[3] = currentParameters[1].value + 10;
         
         } else {
@@ -516 +631 @@
                 returnValueIndex++;
         }
+    returnValues[returnValueIndex] = 0;
+
+    char *allNames[numberColumns];
+        size_t allNameIndex = 0;
+    for(size_t i = 0; i < radioInfo->numUtilities; i++) {
+        allNames[allNameIndex] = (char*)uList[i].name.c_str();
+                returnValues[allNameIndex] = uList[i].target;
+                allNameIndex++;
+        }
+    for(size_t i = 0; i < radioInfo->numParameters; i++) {
+        allNames[allNameIndex] = (char*)pList[i].name.c_str();
+                allNameIndex++;
+        }
+    for(size_t i = 0; i < radioInfo->numObservables; i++) {
+        allNames[allNameIndex] = (char*)oList[i].name.c_str();
+                returnValues[allNameIndex] = 0;
+                allNameIndex++;
+        }
+    allNames[allNameIndex] = "utility";
 
         // Add row to CBR. 
+        cbr_add_row(myCBR, allNames, returnValues, returnValueIndex+1);
 
         return pList;
@@ -535 +670 @@
 void 
 CognitiveEngine::ReceiveFeedback(Observable *observables, Parameter *parameters, \
-    Utility *utilities)
-{
-    LOG("Cognitive Engine:: Receiving feedback.\n");
-}
-
-
-void 
-CognitiveEngine::ReceiveFeedback(Observable *observables, Parameter *parameters, \
-    Utility *utilities, std::string service)
+    std::string service)
 {
     LOG("Cognitive Engine:: Receiving feedback.\n");