Changeset 87 for vtcross

Timestamp:

11/26/08 19:34:48 (16 years ago)

Author:

ahe

Message:

send experience to ce

Files:

• vtcross/branches/trnewman/CR_shell/src/main_cognitive_radio.cpp (modified) (4 diffs)

vtcross/branches/trnewman/CR_shell/src/main_cognitive_radio.cpp

@@ -338 +338 @@
 }
 
-void UpdateCEExperience(float * exp[]) {
-
+void UpdateCEExperience(int socketfd, int num_rows, int num_cols, 
+        float * past_exp[]) 
+{
+    char buffer[256];
+    int i, j;
+        char counter[55];
+        char var[50];
+
+    for (i = 0; i < num_rows; i++){
+        for (j = 0; j< num_cols; j++){
+                sprintf(var,"%f",past_exp[i][j]);
+        printf("%f, \n", past_exp[i][j]);
+        printf("%s, \n", var);
+        }
+    }
+    
+    // send the number of rows to the ce first
+        sprintf(counter,"%d",num_rows);
+        SendMessage(socketfd,counter);
+    // send the number of columns to the ce
+        sprintf(counter,"%d",num_cols);
+        SendMessage(socketfd,counter);
+    // update ce with experience
+    for (i = 0; i < num_rows; i++){
+        for (j = 0; j< num_cols; j++){
+                sprintf(var,"%f",past_exp[i][j]);
+                SendMessage(socketfd,var);
+        }
+    }
 }
 
@@ -348 +375 @@
 // Update operating settings
 // This function will interact with the hardware "drivers"
-void UpdateRadioSettings() {
-
+void UpdateRadioSettings() 
+{
 }
 
@@ -356 +383 @@
         CE_Info *ce_info)
 {
-    string message;
     char buffer[256];
     int i;
@@ -399 +425 @@
         
         float **past_exp;
+    int num_rows, num_cols;
 
         // Set fake current environment params = current environment
-        //RequestCEOptimization();
         RequestCEOptimization(socketfd, uList, pList, oList, ce_info);
 
         // Act like we are updating the hardware tranmission settings
-        //UpdateRadioSettings(socketfd, uList, pList, oList, ce_info);
         UpdateRadioSettings();
 
         // Send back fake utility values
-        UpdateCEExperience(past_exp);   
-}
-
-void StartMessaging(int socketfd, Utility * uList[], Parameter * pList[], Observable * oList[], CE_Info * ce_info) {
-
-        float **past_exp;
-
+    // need to initialize
+        //UpdateCEExperience(socketfd, num_rows, num_cols, past_exp);   
+}
+
+void StartMessaging(int socketfd, Utility * uList[], Parameter * pList[], Observable * oList[], CE_Info * ce_info) 
+{
         LoadCEConfiguration(socketfd, uList, pList, oList, ce_info);
         
-        UpdateCEExperience(past_exp);   
+    // cr experience
+    float **past_exp;
+        int num_cols;
+    // get number of columns
+    num_cols = ce_info->numUtilities + ce_info->numParameters;
+    num_cols = num_cols + ce_info->numObservables;
+    num_cols = num_cols + 1;    // overall utility
+    int num_rows = 1;
+    past_exp = (float **)malloc(sizeof(float)*num_rows);
+    int i;
+    for (i=0; i<num_rows; i++){
+        past_exp[i] = (float*)malloc(sizeof(float)*num_cols);
+    }
+    // sample experience #1
+    past_exp[0][0] = 1e3f;  // throughput
+    past_exp[0][1] = 1;     // spectral_efficiency
+    past_exp[0][2] = -3.5;  // log10_ber
+    past_exp[0][3] = 1;     // mod_scheme
+    past_exp[0][4] = -3.5;  // tx_power
+    past_exp[0][5] = 10.0;  // SNR
+    past_exp[0][6] = 0.762; // overall utility
+    /*// sample experience #2
+    past_exp[1][0] = 1e2f;  // throughput
+    past_exp[1][1] = 1;     // spectral_efficiency
+    past_exp[1][2] = -3.5;  // log10_ber
+    past_exp[1][3] = 1;     // mod_scheme
+    past_exp[1][4] = -3.5;  // tx_power
+    past_exp[1][5] = 3.0;  // SNR
+    past_exp[1][6] = 0.462; // overall utility*/
+
+
+        // update ce with experience
+    UpdateCEExperience(socketfd, num_rows, num_cols, past_exp); 
 
         RunSimulator(socketfd, uList, pList, oList, ce_info);