Changeset 554 for vtcross/branches/nikhil/crossmodel1/src/cognitive_engines/CBR_CE/CBR_CE.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/cognitive_engines/CBR_CE/CBR_CE.cpp (modified) (12 diffs)

vtcross/branches/nikhil/crossmodel1/src/cognitive_engines/CBR_CE/CBR_CE.cpp

@@ -20 +20 @@
 
 #include "CBR_CE.h"
-
+#include <iostream>
 
 using namespace std;
@@ -33 +33 @@
 
 
-void 
-CBR_CE::RegisterServices()
-{
-    LOG("Cognitive Engine:: Registering services.\n");
-
-    SendMessage(commandSocketFD, "register_service");
-    SendMessage(commandSocketFD, "test_srv");
-
-    SendMessage(commandSocketFD, "register_service");
-    SendMessage(commandSocketFD, "test_srv1");
-
-    SendMessage(commandSocketFD, "register_service");
-    SendMessage(commandSocketFD, "test_srv2");
-
-    SendMessage(commandSocketFD, "register_service");
-    SendMessage(commandSocketFD, "test_srv3");
-
-}
-
-
-void 
-CBR_CE::DeregisterServices()
-{
-    LOG("Cognitive Engine:: Deregistering services.\n");
-
-    SendMessage(commandSocketFD, "deregister_service");
-    SendMessage(commandSocketFD, "test_srv");
-
-    SendMessage(commandSocketFD, "deregister_service");
-    SendMessage(commandSocketFD, "test_srv1");
-
-    SendMessage(commandSocketFD, "deregister_service");
-    SendMessage(commandSocketFD, "test_srv2");
-
-    SendMessage(commandSocketFD, "deregister_service");
-    SendMessage(commandSocketFD, "test_srv3");
-
-}
-
-
 Parameter* 
-CBR_CE::GetSolution(Observable *observables, Parameter *currentParameters)
+CBR_CE::GetSolution(Observable *observables, Parameter *currentParameters, Utility *utilities)
 {
     LOG("Cognitive Engine:: Generating solution.\n");
@@ -81 +41 @@
 
     for(size_t i = 0; i < radioInfo->numUtilities; i++) {
-        searchNames[i] = observables[i].name;
+        searchNames[i] = uList[i].name;
     }
 
@@ -90 +50 @@
     }
 
-    uint32_t numberColumns = radioInfo->numUtilities + radioInfo->numParameters \
-                             + radioInfo->numObservables + 1;
+    uint32_t numberColumns = radioInfo->numParameters + radioInfo->numUtilities + radioInfo->numObservables + 1;
     
     float returnValues[numberColumns];
@@ -129 +88 @@
         LOG("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) {
         LOG("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;
-        
-    } else {
-        LOG("Cognitive Engine:: Search return an invalid value.\n");
-    }
+
+        for (int i = 0; i < radioInfo->numParameters; i++) {
+            returnValues[i] = currentParameters[i].value + pList[i].step;
+            if (returnValues[i] > pList[i].max) {
+                std::cout << "SORRY CANT EXCEED MAX VALUE" << std::endl;
+                returnValues[i] = returnValues[i] - pList[i].step;
+            }
+            if (returnValues[i] < pList[i].min) {
+                std::cout << "SORRY CANT GO BELOW MIN VALUE" << std::endl;
+                returnValues[i] = returnValues[i] + pList[i].step ;              
+            }
+        }
+
+        for (int i = 0; i < radioInfo->numUtilities; i++)
+            returnValues[radioInfo->numParameters + i] = uList[i].value;
+
+        for (int i = 0; i < radioInfo->numObservables; i++)
+            returnValues[radioInfo->numParameters + radioInfo->numUtilities + i] = oList[i].value;
 
     size_t returnValueIndex = 0;
     for(size_t i = 0; i < radioInfo->numUtilities; i++) {
+        pList[i].value = returnValues[returnValueIndex];
+        returnValueIndex++;
+    }
+    for(size_t i = 0; i < radioInfo->numParameters; i++) {
         uList[i].value = returnValues[returnValueIndex];
-        returnValueIndex++;
-    }
-    for(size_t i = 0; i < radioInfo->numParameters; i++) {
-        pList[i].value = returnValues[returnValueIndex];
         returnValueIndex++;
     }
@@ -165 +128 @@
     string allNames[numberColumns];
     size_t allNameIndex = 0;
-    for(size_t i = 0; i < radioInfo->numUtilities; i++) {
-        allNames[allNameIndex] = uList[i].name;
-        returnValues[allNameIndex] = uList[i].target;
-        allNameIndex++;
-    }
     for(size_t i = 0; i < radioInfo->numParameters; i++) {
         allNames[allNameIndex] = pList[i].name;
         allNameIndex++;
     }
+    for(size_t i = 0; i < radioInfo->numUtilities; i++) {
+        allNames[allNameIndex] = uList[i].name;
+        allNameIndex++;
+    }
     for(size_t i = 0; i < radioInfo->numObservables; i++) {
         allNames[allNameIndex] = oList[i].name;
-        returnValues[allNameIndex] = 0;
         allNameIndex++;
     }
-    allNames[allNameIndex] = "utility";
+    allNames[allNameIndex] = "TotalWeight";
 
     // Add row to CBR. 
     myCBR->AddRow(allNames, returnValues, returnValueIndex + 1);
 
+        } else {
+        LOG("Cognitive Engine:: Search return an invalid value.\n");
+    }
+
+
     return pList;
 }
 
 
-Parameter* 
-CBR_CE::GetSolution(Observable *observables, \
-        Parameter *currentParameters, std::string service)
-{
-    LOG("Cognitive Engine:: Generating solution for %s service.\n", service.c_str());
-
-    return pList;
-}
-
-
 void 
-CBR_CE::ReceiveFeedback(Observable *observables, Parameter *parameters)
+CBR_CE::ReceiveFeedback(Observable *observables, Parameter *parameters, Utility *utilities)
 { 
     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];
-    string nameList[numberColumns];
-    string obsList[obsColumns];
-
-    size_t columnObsIndex = 0;
-    for (size_t i = 0; i < radioInfo->numObservables; i++){
-        obsList[columnObsIndex] = observables[i].name;
-        columnObsIndex++;
-    }  
-    obsList[columnObsIndex] = "utility";
-
-    size_t columnIndex = 0;
-    for (size_t i = 0; i < radioInfo->numParameters; i++){
-        nameList[columnIndex] = parameters[i].name;
-        columnIndex++;
-    }   
-    for (size_t i = 0; i < radioInfo->numUtilities; i++){
-        nameList[columnIndex] = uList[i].name;
-        columnIndex++;
-    }   
-
-    size_t obsValueIndex = 0;
+    uint32_t numberColumns = radioInfo->numParameters + radioInfo->numUtilities + radioInfo->numObservables + 1;
+
+    uint32_t whereLen = radioInfo->numParameters;
+    uint32_t setLen = radioInfo->numUtilities + radioInfo->numObservables;
+
+
+    float whereValue[whereLen];
+    float setValue[setLen];
+    string whereList[whereLen];
+    string setList[setLen];
+
+
+    for(size_t i = 0; i < radioInfo->numParameters; i++) {
+        whereList[i] = parameters[i].name;
+        whereValue[i] = parameters[i].value;
+    }
+
+    size_t returnValueIndex = 0;
+    for(size_t i = 0; i < radioInfo->numUtilities; i++) {
+        setList[returnValueIndex] = utilities[i].name;
+        setValue[returnValueIndex] = utilities[i].value;   
+        returnValueIndex++;
+    }
     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++;
-    }
-}
-
-
-void 
-CBR_CE::ReceiveFeedback(Observable *observables, Parameter *parameters, \
-    std::string service)
-{
-    LOG("Cognitive Engine:: Receiving feedback.\n");
+        setList[returnValueIndex] = observables[i].name;
+        setValue[returnValueIndex] = observables[i].value;
+        returnValueIndex++;
+    }
+
+
+myCBR->Update(whereList,setList,whereValue,setValue,whereLen,setLen);
+
 }
 
@@ -267 +198 @@
 {
     string filename = "ex1";
+    string filename2 = "ex2";
     string tablename = "data";
 
-    uint32_t numberColumns = radioInfo->numUtilities + radioInfo->numParameters \
+    uint32_t numberColumns = radioInfo->numParameters + radioInfo->numUtilities \
                              + radioInfo->numObservables + 1;
 
+    uint32_t numberParameters = radioInfo->numParameters;
+    uint32_t numberUtilities = radioInfo->numUtilities;
+
     string cols[numberColumns];
+    string Plist[numberParameters];
+    string Ulist[numberUtilities];
+    float Utarget[numberUtilities];
+    string Ugoal[numberUtilities];
 
     size_t columnIndex = 0;
+    size_t Pindex = 0;              // new
+    size_t Uindex = 0;              // new
+
+
+    for (size_t i = 0; i < radioInfo->numParameters; i++){
+        cols[columnIndex] = pList[i].name;
+        columnIndex++;
+        Plist[Pindex] = pList[i].name;   // new
+        Pindex++;                        // new
+    }
     for (size_t i = 0; i < radioInfo->numUtilities; i++){
         cols[columnIndex] = uList[i].name;
         columnIndex++;
-    }   
-    for (size_t i = 0; i < radioInfo->numParameters; i++){
-        cols[columnIndex] = pList[i].name;
-        columnIndex++;
-    }   
-    for (size_t i = 0; i < radioInfo->numObservables; i++){
+        Ulist[Uindex] = uList[i].name;     // new
+        Utarget[Uindex] = uList[i].target; // new
+        Ugoal[Uindex] = uList[i].goal;     // new
+        Uindex++;                          // new
+
+    }      
+    for (size_t i = 0; i < radioInfo->numObservables; i++){   
         cols[columnIndex] = oList[i].name;
-        columnIndex++;
-    }   
-    cols[columnIndex] = "utility";
+        columnIndex++;
+    }
+    cols[columnIndex] = "TotalWeight";  
 
     myCBR = new CBR(filename, tablename, cols, numberColumns);
+
 }
 
@@ -296 +247 @@
 CBR_CE::PerformUpdatePerformance()
 {
+
     /* Receive Set of current Parameters */
     char buffer[256];
@@ -314 +266 @@
     } 
 
+
     /* Receive Set of Observables */
     memset(buffer, 0, 256);
@@ -329 +282 @@
         ReadMessage(commandSocketFD, buffer);
         o[i].value = atof(buffer);
-    }  
-
-    ReceiveFeedback(o, p);
+    }
+
+
+    /* 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);
+    }
+ 
+    ReceiveFeedback(o, p, u);
 
     delete [] o;
     delete [] p;
+    delete [] u;
 }
 
 
 void
-CBR_CE::PerformRequestOptimizationService()
-{
-   // THIS IS CURRENTLY IN DEMO MODE            
-
+CBR_CE::PerformRequestOptimization()
+{
     /* Receive Set of Observables */
-    LOG("\nCognitive Engine:: Receiving service name\n");
+    LOG("\nCognitive Engine:: Receiving Observables\n");
 
     char buffer[256];
-    memset(buffer, 0, 256);
-    ReadMessage(commandSocketFD,buffer);
-    LOG("\nCognitive Engine:: Got service name, %s\n", buffer);
-
-    /* Receive Set of Observables */
-    LOG("\nCognitive Engine:: Receiving Observable Parameters\n");
-
     memset(buffer, 0, 256);
     ReadMessage(commandSocketFD,buffer);
@@ -387 +350 @@
         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");
-    char numParametersChar[10];
-    //char solutionValue[50];
-    sprintf(numParametersChar, "%i", radioInfo->numParameters);
-    SendMessage(commandSocketFD, numParametersChar);
-    for(size_t i = 0; i < radioInfo->numParameters; i++) {
-        // TODO What's with all the commented-out code?
-        //SendMessage(commandSocketFD, solutionSet[i].name.c_str());
-        SendMessage(commandSocketFD, "test");
-        //memset(solutionValue, 0, 50);
-        //sprintf(solutionValue, "%f", solutionSet[i].value);
-        //SendMessage(commandSocketFD, solutionValue);
-        SendMessage(commandSocketFD, "00");
-    }
-
-    delete [] o;
-    delete [] cp;
-
-}
-
-
-void
-CBR_CE::PerformRequestOptimization()
-{
-    /* Receive Set of Observables */
-    LOG("\nCognitive Engine:: Receiving Observable Parameters\n");
-
-    char buffer[256];
-    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");
+    }
+
+    /* Receive Set of Utilities */
+    LOG("Cognitive Engine:: Receiving Utilities\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);
-    }  
+    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);
+    }
+
+
+
+  
     LOG("Cognitive Engine:: Processing parameters....\n");
 
     Parameter *solutionSet;
     
-    solutionSet = GetSolution(o,cp);
-
-    // TODO need to actually do something with the observables here
+    solutionSet = GetSolution(o,cp,u);
+
+ 
    
     LOG("Cognitive Engine:: Sending Optimal Parameters to Application.\n");
@@ -480 +396 @@
     delete [] o;
     delete [] cp;
-}
-
-
-void
-CBR_CE::PerformQueryComponentType()
-{
-    SendComponentType();
-}
-
-
-void
-CBR_CE::PerformConnectSML()
-{
-    /* This command implies that we are disconnecting from the shell and
-     * connecting to a SML component. */
-    char serverName[256];
-    char serverPort[256];
-
-    // TODO is this going to end up being too slow?
-    memset(serverName, 0, 256);
-    memset(serverPort, 0, 256);
-
-    ReadMessage(commandSocketFD, serverName);
-    ReadMessage(commandSocketFD, serverPort);
-
-    /* Only continue if we are currently connected to a shell. */
-    if(!SML_present) {
-        DeregisterComponent();
-
-        shutdown(commandSocketFD, 2);
-        close(commandSocketFD);
-
-        ConnectToRemoteComponent(serverName, serverPort, true);
-    }
-}
-
-
-void
-CBR_CE::PerformDisconnectSML()
-{
-    /* This command implies that we are disconnecting from the SML and
-     * connecting to a shell component. */
-    char serverName[256];
-    char serverPort[256];
-
-    // TODO is this going to end up being too slow?
-    memset(serverName, 0, 256);
-    memset(serverPort, 0, 256);
-
-    ReadMessage(commandSocketFD, serverName);
-    ReadMessage(commandSocketFD, serverPort);
-
-    /* We only want to do this if we are actually connected to an SML
-     * currently. */
-    if(SML_present) {
-        DeregisterServices();
-
-        shutdown(commandSocketFD, 2);
-        close(commandSocketFD);
-
-        ConnectToRemoteComponent(serverName, serverPort, false);
-    }
+    delete [] u;
 }