Changeset 391 for vtcross/trunk/src/cognitive_engines/DSA_CE/DSA_CognitiveEngine.cpp

Timestamp:

07/29/09 16:10:39 (15 years ago)

Author:

trnewman

Message:

Fleshed out DSA reference implementation

Files:

• vtcross/trunk/src/cognitive_engines/DSA_CE/DSA_CognitiveEngine.cpp (modified) (12 diffs)

vtcross/trunk/src/cognitive_engines/DSA_CE/DSA_CognitiveEngine.cpp

@@ -29 +29 @@
 
 #define INTERFERENCE 0
+
+#define CHANNEL 1
+
+#define ENERGY 0
 #define COMMUNICATION_TIME 1
-#define CHANNEL 2
-#define ENERGY 3
-#define FITNESS 4
+
+#define UTILITY 4
 
 
@@ -111 +114 @@
     
     uint32_t numberColumns = 
-        radioInfo->numParameters +
-        radioInfo->numUtilities;
+        radioInfo->numParameters;
 
     uint32_t obsColumns = radioInfo->numObservables + 1;
+    uint32_t numberTotalColumns = radioInfo->numUtilities +
+                                radioInfo->numParameters +
+                                radioInfo->numObservables + 1;
 
     float valList[numberColumns];
@@ -120 +125 @@
     char *nameList[numberColumns];
     char *obsList[obsColumns];
+    char *searchNames[1];
+    float searchVals[1];
+    int searchOps[1];
+    float returnValues[numberTotalColumns];
 
     size_t columnObsIndex = 0;
@@ -126 +135 @@
         columnObsIndex++;
     }  
-    obsList[columnObsIndex] = "utility";
+   
+    std::string utility_name = "utility"; 
+    obsList[columnObsIndex] = (char*) utility_name.c_str();
 
     size_t columnIndex = 0;
@@ -133 +144 @@
         columnIndex++;
     }   
-    for (size_t i = 0; i < radioInfo->numUtilities; i++){
-        nameList[columnIndex] = (char*)uList[i].name.c_str();
-        columnIndex++;
-    }   
 
     size_t obsValueIndex = 0;
@@ -144 +151 @@
     }
 
+    /* Make sure we do not return any entries for the current channel */
+    std::string channel_name = "channel";
+    searchNames[0] = (char *) channel_name.c_str();
+    searchOps[0] = EQ;
+    searchVals[0] = parameters[0].value; 
+
+    /* Execute CBR search and put output into returnValues */
+    cbr_search(myCBR, searchNames, searchOps, searchVals,
+            1, returnValues);
+
     /* Calculate Utility */
-    float newUtilityValue = 0;
-
-    for(size_t i = 0; i < radioInfo->numUtilities; i++) {
-        newUtilityValue = newUtilityValue + (uList[i].target - observables[i].value);
-    }
+    float oldUtilityValue = returnValues[UTILITY];
+    
+    // Set DSA utility to take into account both the previously sensed
+    //  energy and the average communication time.
+
+    
+
+    float newUtilityValue = oldUtilityValue + ( -observables[ENERGY].value + observables[COMMUNICATION_TIME].value);
+
+    // If communication time value is set, we know we need to change channels because of PU.
+    // So we should lower the utility for this channel.
+
+    if(observables[COMMUNICATION_TIME].value != 0) { 
+        newUtilityValue = newUtilityValue - 100;
+    } else {
+        newUtilityValue = newUtilityValue + 20;
+    }
+
+
+    if(newUtilityValue <= 0)
+        newUtilityValue = 0;
+
     obsVals[obsValueIndex] = newUtilityValue;
 
@@ -155 +189 @@
     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++;
     }
@@ -641 +671 @@
     /* Put together the CBR search array */
 
+    uint32_t channel = 0;
     char *searchNames[1];
+    char *sumSearchName;
     float searchVals[1];
+    float utilArray[(int)pList[0].max];
     int searchOps[1];
     uint32_t numberColumns = radioInfo->numUtilities +
@@ -648 +681 @@
                                 radioInfo->numObservables + 1;
 
-    /* Make sure we do not return any entries for the current channel */
-    searchNames[0] = "channel";
-    searchOps[0] = NE;
-    searchVals[0] = currentParameters[0].value; 
- 
     float returnValues[numberColumns];
-    
-    /* Execute CBR search and put output into returnValues */
-    uint32_t rc = cbr_search(myCBR, searchNames, searchOps, searchVals,
+    float sumRetVals[numberColumns];
+   
+    // Total sum of utilities in sumRetVals[0]
+
+    std::string channel_name = "channel";
+    std::string utility_name = "utility";
+
+    for( int i = 0 ; i < pList[0].max ; i++ ) {
+
+        searchNames[0] = (char*) pList[0].name.c_str();
+        searchOps[0] = EQ;
+        searchVals[0] = i+1; 
+    
+        uint32_t rc = cbr_search(myCBR, searchNames, searchOps, searchVals,
             1, returnValues);
 
-    if(rc == 0){
-        /* Similiar environment was found. Adapt the returned parameters to 
-           meet the objective */
-
-        LOG("Cognitive Engine:: Previous similar environment found\n");
-
-        /* generate random channel */
-        returnValues[CHANNEL] = rand() % (int)pList[0].max + (int)pList[0].min; 
+        if(rc == 31337) {
+                // No entry - must add
+                
+                char *rowNames[numberColumns];
+                size_t rowIndex = 0;
+                for(size_t j = 0; j < radioInfo->numUtilities; j++) {
+                        rowNames[rowIndex] = (char*)uList[j].name.c_str();
+                        rowIndex++;
+                }
+                for(size_t j = 0; j < radioInfo->numParameters; j++) {
+                        rowNames[rowIndex] = (char*)pList[j].name.c_str();
+                        if(pList[j].name == "channel")
+                                returnValues[rowIndex] = i+1;
+                        rowIndex++;
+                }
+                for(size_t j = 0; j < radioInfo->numObservables; j++) {
+                        rowNames[rowIndex] = (char*)oList[j].name.c_str();
+                        rowIndex++;
+                }
+   
+                rowNames[rowIndex] = (char *) utility_name.c_str();
+                returnValues[rowIndex] = 500;
+
+                /* Add the new optimized set to the CBR database */
+
+                cbr_add_row(myCBR, rowNames, returnValues, numberColumns);
+        }
+
+        utilArray[i] = returnValues[UTILITY]; 
+    }
+
+        printf("1: %f\t2: %f\t3: %f\t4: %f\n",utilArray[0],utilArray[1],utilArray[2],utilArray[3]);    
+    // Get sum of all the channel utilities.
+    sumSearchName = (char *) utility_name.c_str();
+    uint32_t rc = cbr_search_sum(myCBR, sumSearchName, sumRetVals);
+
+    // Psuedo random channel selection based upon utility.
+    int k = rand() % (int)sumRetVals[0];
+    int cdf_total(0);
+
+    for ( int i = 0; i < pList[0].max; i++ ) {
+        cdf_total += utilArray[i];
+        if(k < cdf_total) {
+                channel = i + 1;
+                break;
+        }
+    }
         
-        if(returnValues[numberColumns-1] < 0) {
-        
-        } else {
-       
-        }
-    } else if(rc == 31337) {
-        /* No previous similar solution was found, use default. */
-        LOG("Cognitive Engine:: No previous similar environment found.\n");
-     
-        /* generate random channel */
-        returnValues[CHANNEL] = rand() % (int)pList[0].max + (int)pList[0].min; 
-    } else {
-        LOG("Cognitive Engine:: Search return an invalid value.\n");
-    }
-
-
+    searchNames[0] = (char*) pList[0].name.c_str();
+    searchOps[0] = EQ;
+    searchVals[0] = channel; 
+  
+    rc = cbr_search(myCBR, searchNames, searchOps, searchVals,
+        1, returnValues);
+
+
+    //returnValues[CHANNEL] = rand() % (int)pList[0].max + (int)pList[0].min; 
+    returnValues[CHANNEL] = channel;
+ 
     /* Package up the new set of parameters in order to add
        the new entry into the CBR database.  */
@@ -700 +773 @@
         returnValueIndex++;
     }
-    returnValues[returnValueIndex] = 0;
+    //returnValues[returnValueIndex] = 0;
 
     char *allNames[numberColumns];
@@ -715 +788 @@
     for(size_t i = 0; i < radioInfo->numObservables; i++) {
         allNames[allNameIndex] = (char*)oList[i].name.c_str();
-        returnValues[allNameIndex] = 0;
+    //    returnValues[allNameIndex] = 0;
         allNameIndex++;
     }
-    allNames[allNameIndex] = "utility";
+   
+    allNames[allNameIndex] = (char *) utility_name.c_str();
 
     /* Add the new optimized set to the CBR database */
     cbr_add_row(myCBR, allNames, returnValues, returnValueIndex+1);
+
 
     /* Return the set of new parameter values.  */
@@ -764 +839 @@
         columnIndex++;
     }   
+
+    char *paramCols[radioInfo->numParameters];
+    size_t paramColumnIndex = 0;
+    // Also need to make parameters the unique key 
     for (size_t i = 0; i < radioInfo->numParameters; i++){
         cols[columnIndex] = (char*)pList[i].name.c_str();
+        paramCols[paramColumnIndex] = (char*)pList[i].name.c_str();
         columnIndex++;
-    }   
+        paramColumnIndex++;
+    }  
+
     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);
-}
-
+   
+    std::string utility_name = "utility"; 
+    cols[columnIndex] = (char *)utility_name.c_str();
+
+    myCBR = cbr_create_with_primary(filename, tablename, cols, paramCols, numberColumns, radioInfo->numParameters);
+}
+