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

Timestamp:

04/02/09 17:35:03 (15 years ago)

Author:

trnewman

Message:

Added sending current parameters in the libvt request optimization function.

Added guts to the CBR so it actually creates an sql db and searches it.

Files:

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

vtcross/trunk/src/cognitive_engines/CognitiveEngine.cpp

@@ -19 +19 @@
 #include "vtcross/error.h"
 #include "vtcross/socketcomm.h"
-
+#include "vtcross/cbr.h"
+
+#include "cbr.c"
+
+#include <sqlite3.h>
+#include <sqlite3ext.h>
+
+
+
+static cbr myCBR;
 
 CognitiveEngine::CognitiveEngine()
@@ -31 +40 @@
 CognitiveEngine::~CognitiveEngine()
 {
+        cbr_free(myCBR);
     delete [] pList;
     delete [] oList;
@@ -82 +92 @@
     }
 }
-
 
 void 
@@ -101 +110 @@
         // MUCH faster since instead of donig string compares we can simply
         // switch on the integer value...
-        if(strcmp(buffer, "get_solution") == 0) {
+        if(strcmp(buffer, "request_optimization") == 0) {
             
             /* Receive Set of Observables */
@@ -122 +131 @@
             }  
 
+            /* Receive Set of current Parameters */
+                        LOG("Cognitive Engine:: Receiving Current Transmission Parameters\n");
+
+            memset(buffer, 0, 256);
+            ReadMessage(commandSocketFD,buffer);
+            uint32_t numCurrentParameters = atoi(buffer);
+   
+            Parameter *cp = new Parameter[numCurrentParameters];
+ 
+            for(size_t i = 0; i < numCurrentParameters; i++) {
+                memset(buffer, 0, 256);
+                ReadMessage(commandSocketFD, buffer);
+                cp[i].name = std::string(buffer);
+    
+                memset(buffer, 0, 256);
+                ReadMessage(commandSocketFD, buffer);
+                cp[i].value = atof(buffer);
+            }  
                         LOG("Cognitive Engine:: Processing parameters....\n");
+
+            Parameter *solutionSet;
+                        
+                        solutionSet = GetSolution(o,cp);
 
             // TODO need to actually do something with the observables here
             
                         LOG("Cognitive Engine:: Sending Optimal Parameters to Application.\n");
-
-            SendMessage(commandSocketFD,"1");
-            SendMessage(commandSocketFD,"txPower");
-            SendMessage(commandSocketFD,"10");
+                        char numParametersChar[10];
+                        char solutionValue[50];
+                        sprintf(numParametersChar,"%i",radioInfo->numParameters);
+                        SendMessage(commandSocketFD,numParametersChar);
+            for(size_t i = 0; i < radioInfo->numParameters; i++) {
+                SendMessage(commandSocketFD,solutionSet[i].name.c_str());
+                memset(solutionValue, 0, 50);
+                            sprintf(solutionValue,"%f",solutionSet[i].value);
+                SendMessage(commandSocketFD,solutionValue);
+                        }
 
             delete [] o;
+            delete [] cp;
         }
         else if(strcmp(buffer, "query_component_type") == 0) {
@@ -295 +333 @@
         ReadMessage(commandSocketFD,buffer);
         uList[i].name = std::string(buffer);
-    
+   
         memset(buffer, 0, 256);
         ReadMessage(commandSocketFD,buffer);
@@ -386 +424 @@
 
     SendMessage(commandSocketFD, "receive_config_ack");
+
+        BuildCognitiveEngine();
 }
 
@@ -405 +445 @@
 }
 
-void 
-CognitiveEngine::GetSolution(Observable *observables)
+Parameter* 
+CognitiveEngine::GetSolution(Observable *observables, Parameter *currentParameters)
 {
     LOG("Cognitive Engine:: Generating solution.\n");
-}
-
-void 
-CognitiveEngine::GetSolution(Observable *observables, std::string service)
+
+    char *searchNames[radioInfo->numUtilities];
+
+    for(size_t i = 0; i < radioInfo->numUtilities; i++) {
+        searchNames[i] = (char*)uList[i].name.c_str();
+        }
+
+    float searchVals[radioInfo->numUtilities];
+
+        for(size_t i = 0; i < radioInfo->numUtilities; i++) {
+                searchVals[i] = uList[i].target;
+    }
+
+    uint32_t numberColumns = 
+                radioInfo->numUtilities +
+                radioInfo->numParameters +
+                radioInfo->numObservables + 1;
+        
+        float returnValues[numberColumns];
+        
+        int searchOps[radioInfo->numUtilities];
+    for(size_t i = 0; i < radioInfo->numUtilities; i++) {
+
+        /* If the goal is to maximum, set the search operation to
+                 * return values greater than the target.
+                 *
+                 * If the goal is to minimize, set the search operation to
+                 * return values less than the target.
+                 */
+
+                if(strcmp(uList[i].goal.c_str(),"max") == 0) {
+                    searchOps[i] = GT;
+                } else if(strcmp(uList[i].goal.c_str(),"min") == 0) {
+                        searchOps[i] = LT;
+                }
+        }
+
+        /* CBR specific call */
+        uint32_t rc = cbr_search(myCBR, searchNames, searchOps, searchVals,
+                        radioInfo->numUtilities, returnValues);
+
+        if(rc == 0){
+        /* Adapt the returned parameters to meet the objective */
+
+    } else if(rc == 31337){
+                /* 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;
+        
+        } else {
+        WARNING("Cognitive Engine:: Search return an invalid value.\n");
+        }
+
+        size_t returnValueIndex = 0;
+    for(size_t i = 0; i < radioInfo->numUtilities; i++) {
+                uList[i].value = returnValues[returnValueIndex];
+                returnValueIndex++;
+        }
+    for(size_t i = 0; i < radioInfo->numParameters; i++) {
+                pList[i].value = returnValues[returnValueIndex];
+                returnValueIndex++;
+        }
+    for(size_t i = 0; i < radioInfo->numObservables; i++) {
+                oList[i].value = returnValues[returnValueIndex];
+                returnValueIndex++;
+        }
+
+        // Add row to CBR. 
+
+        return pList;
+
+}
+
+
+Parameter* 
+CognitiveEngine::GetSolution(Observable *observables, Parameter *currentParameters, std::string service)
 {
     LOG("Cognitive Engine:: Generating solution for %s service.\n",service.c_str());
-}
+
+    return pList;
+}
+
 
 void 
@@ -424 +540 @@
 }
 
+
 void 
 CognitiveEngine::ReceiveFeedback(Observable *observables, Parameter *parameters, \
@@ -430 +547 @@
     LOG("Cognitive Engine:: Receiving feedback.\n");
 }
+
+
+void
+CognitiveEngine::BuildCognitiveEngine()
+{
+        char filename[] = {"ex1"};
+        char tablename[] = {"data"};
+
+    uint32_t numberColumns = 
+                radioInfo->numUtilities +
+                radioInfo->numParameters +
+                radioInfo->numObservables + 1;
+
+    char *cols[numberColumns];
+
+    size_t columnIndex = 0;
+    for (size_t i = 0; i < radioInfo->numUtilities; i++){
+                cols[columnIndex] = (char*)uList[i].name.c_str();
+        columnIndex++;
+    }   
+    for (size_t i = 0; i < radioInfo->numParameters; i++){
+                cols[columnIndex] = (char*)pList[i].name.c_str();
+        columnIndex++;
+    }   
+    for (size_t i = 0; i < radioInfo->numObservables; i++){
+                cols[columnIndex] = (char*)oList[i].name.c_str();
+        columnIndex++;
+    }   
+    cols[columnIndex] = "utility";
+
+    myCBR = cbr_create(filename, tablename, cols, numberColumns);
+}
+