Changeset 230 for vtcross/trunk/src/shell/CognitiveRadioShell.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/shell/CognitiveRadioShell.cpp (modified) (2 diffs)

vtcross/trunk/src/shell/CognitiveRadioShell.cpp

@@ -552 +552 @@
 }
 
-
+bool
+CognitiveRadioShell::UpdateParameterPerformance(int32_t socketFD)
+{
+    char counter[55];
+    uint32_t numObservables,numParameters;
+    char var[50];
+    char buffer[256];
+
+        /* Receive Set of Parameters */
+    memset(buffer, 0, 256);
+    ReadMessage(commandSocketFD,buffer);
+    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 */
+    memset(buffer, 0, 256);
+    ReadMessage(commandSocketFD, buffer);
+    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);
+    }
+
+
+    SendMessage(ceSocketFD, "update_performance");
+   
+    // Send Parameters 
+    memset(counter, 0, 55);
+    sprintf(counter, "%i", numParameters);
+    SendMessage(ceSocketFD, counter);
+    
+    for(size_t i = 0; i < numParameters; i++) {
+        SendMessage(ceSocketFD,p[i].name.c_str());
+        sprintf(var,"%f",p[i].value);
+        SendMessage(ceSocketFD,var);  
+    }   
+    
+    // Send Observables
+    sprintf(counter, "%i", numObservables);
+    SendMessage(ceSocketFD, counter);
+    for(size_t i = 0; i < numObservables; i++) {
+        SendMessage(ceSocketFD, o[i].name.c_str());
+        sprintf(var, "%f", o[i].value);
+        SendMessage(ceSocketFD, var); 
+    }   
+    
+    return 1;
+}
 void
 CognitiveRadioShell::HandleMessage(int32_t socketFD)
@@ -572 +637 @@
     } else if(strcmp(buffer, "deregister_sml") == 0) {
         DeregisterSML(socketFD);
+    } else if(strcmp(buffer, "update_performance") == 0) {
+        UpdateParameterPerformance(socketFD);
+    } else if(strcmp(buffer,"get_number_utilities") == 0) {
+                char numUtilities[20];
+                sprintf(numUtilities,"%i",radio_info->numUtilities);
+        SendMessage(commandSocketFD,numUtilities);
+    } else if(strcmp(buffer,"get_number_observables") == 0) {
+                char numObservables[20];
+                sprintf(numObservables,"%i",radio_info->numObservables);
+        SendMessage(commandSocketFD,numObservables);
     } else if(strcmp(buffer,"get_number_parameters") == 0) {
                 char numParameters[20];