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

vtcross/trunk/src/shell/CognitiveRadioShell.cpp

@@ -454 +454 @@
 {
     char buffer[256];
+    uint32_t numObservables,numParameters,numCurrentParameters;
     char counter[55];
     char var[50];
@@ -476 +477 @@
     }
 
+    /* Receive Set of Current Parameters */
+    memset(buffer, 0, 256);
+    ReadMessage(commandSocketFD,buffer);
+    numCurrentParameters = atoi(buffer);
+  
+        LOG("Cognitive Radio Shell:: Attempting to get %i parameters.\n",numCurrentParameters);
+    Parameter * cp = new Parameter[numCurrentParameters];
+ 
+    for (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);
+    }
     /* Send to Cognitive Engine 
          * TODO: With multiple CEs we need to make a decision about where
@@ -481 +499 @@
          */
 
-        LOG("Cognitive Radio Shell:: Passing on observables to Cognitive Engine\n");
-    SendMessage(ceSocketFD, "get_solution");
-    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);
-    }
-
+        if(!SML_present) { 
+            LOG("Cognitive Radio Shell:: Passing on observables to Cognitive Engine\n");
+        SendMessage(ceSocketFD,"request_optimization");
+        sprintf(counter,"%i",numObservables);
+        SendMessage(ceSocketFD,counter);
+        for(i = 0; i < numObservables; i++) {
+            SendMessage(ceSocketFD,o[i].name.c_str());
+            sprintf(var,"%f",o[i].value);
+                SendMessage(ceSocketFD,var);
+        }
+            
+                LOG("Cognitive Radio Shell:: Passing on current parameters to Cognitive Engine\n");
+        sprintf(counter,"%i",numCurrentParameters);
+        SendMessage(ceSocketFD,counter);
+        for(i = 0; i < numCurrentParameters; i++) {
+            SendMessage(ceSocketFD,cp[i].name.c_str());
+            sprintf(var,"%f",cp[i].value);
+                SendMessage(ceSocketFD,var);
+        }
+        }
 
         LOG("Cognitive Radio Shell:: Receiving optimized parameters from Cognitive Engine.\n");
@@ -546 +574 @@
     } else if(strcmp(buffer, "deregister_sml") == 0) {
         DeregisterSML(socketFD);
-    } else if(strcmp(buffer, "request_optimization") == 0) {
+    } else if(strcmp(buffer,"get_number_parameters") == 0) {
+                char numParameters[20];
+                sprintf(numParameters,"%i",radio_info->numParameters);
+        SendMessage(commandSocketFD,numParameters);
+    } else if(strcmp(buffer,"request_optimization") == 0) {
         /* Receive optimization request and current environment */
         GetOptimalParameters(socketFD);  
+    } else if(strcmp(buffer,"request_optimization_service") == 0) {
+        /* Receive optimization request and current environment */
+        //GetOptimalParametersService(socketFD);  
     }
 }