Changeset 285 for vtcross/trunk/src/cognitive_engines/CognitiveEngine.cpp

Timestamp:

06/16/09 16:12:04 (15 years ago)

Author:

wrodgers

Message:

updating SML demo

Files:

• vtcross/trunk/src/cognitive_engines/CognitiveEngine.cpp (modified) (6 diffs)

vtcross/trunk/src/cognitive_engines/CognitiveEngine.cpp

@@ -81 +81 @@
 
     if(SML) {
-        RegisterServices();
+        
         RegisterComponent();
         LOG("Cognitive Engine connected to SML at %s.\n", serverName);
         ReceiveRadioConfiguration();
         ReceiveExperience();
+        
+        RegisterServices();
     }
     else {
@@ -215 +217 @@
             delete [] p;
         } 
+        else if(strcmp(buffer, "request_optimization_service") == 0) {
+            // THIS IS CURRENTLY IN DEMO MODE            
+
+
+            /* Receive Set of Observables */
+            LOG("\nCognitive Engine:: Receiving service name\n");
+
+            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);
+            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");
+
+            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);
+            }  
+            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++) {
+                //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;
+        }
         else if(strcmp(buffer, "request_optimization") == 0) {
             
@@ -367 +442 @@
 CognitiveEngine::RegisterComponent()
 {
+    char buffer[256];
     SendMessage(commandSocketFD, "register_engine_cognitive");
     LOG("Cognitive Engine:: Registration message sent to shell.\n");
+
+    memset(buffer, 0, 256);
+    ReadMessage(commandSocketFD, buffer);
 }
 
@@ -390 +469 @@
 
     SendMessage(commandSocketFD, "register_service");
-    SendMessage(commandSocketFD, "jam_wifi");
+    SendMessage(commandSocketFD, "test_srv");
 
     SendMessage(commandSocketFD, "register_service");
-    SendMessage(commandSocketFD, "signal_detection");
+    SendMessage(commandSocketFD, "test_srv1");
 
     SendMessage(commandSocketFD, "register_service");
-    SendMessage(commandSocketFD, "max_throughput");
+    SendMessage(commandSocketFD, "test_srv2");
 
     SendMessage(commandSocketFD, "register_service");
-    SendMessage(commandSocketFD, "jam_bluetooth");
+    SendMessage(commandSocketFD, "test_srv3");
+
 }
 
@@ -409 +489 @@
 
     SendMessage(commandSocketFD, "deregister_service");
-    SendMessage(commandSocketFD, "jam_wifi");
+    SendMessage(commandSocketFD, "test_srv");
 
     SendMessage(commandSocketFD, "deregister_service");
-    SendMessage(commandSocketFD, "signal_detection");
+    SendMessage(commandSocketFD, "test_srv1");
 
     SendMessage(commandSocketFD, "deregister_service");
-    SendMessage(commandSocketFD, "max_throughput");
+    SendMessage(commandSocketFD, "test_srv2");
 
     SendMessage(commandSocketFD, "deregister_service");
-    SendMessage(commandSocketFD, "jam_bluetooth");
+    SendMessage(commandSocketFD, "test_srv3");
 
 }
@@ -433 +513 @@
     ReadMessage(commandSocketFD, buffer);
     radioInfo->numUtilities = atoi(buffer);
-    
+    LOG("Cognitive Engine:: Receiving Radio Configuration. %s\n",buffer);
+
+
     for(size_t i = 0; i < radioInfo->numUtilities; i++) {
         memset(buffer, 0, 256);