Changeset 227 for vtcross/trunk/src/shell/CognitiveRadioShell.cpp

Timestamp:

03/31/09 18:38:58 (15 years ago)

Author:

bhilburn

Message:

Memory leaks, style fixes, variable scoping.

Files:

• vtcross/trunk/src/shell/CognitiveRadioShell.cpp (modified) (10 diffs)

vtcross/trunk/src/shell/CognitiveRadioShell.cpp

@@ -129 +129 @@
         SendMessage(socketfd, utils[i].goal.c_str());
         sprintf(var,"%f", utils[i].target);
-        SendMessage(socketfd,var);
+        SendMessage(socketfd, var);
     }
 
@@ -136 +136 @@
     SendMessage(socketfd,counter);
     for(i = 0; i < radio_info->numParameters; i++) {
-        SendMessage(socketfd,params[i].name.c_str());
-        SendMessage(socketfd,params[i].units.c_str());
-        sprintf(var,"%f",params[i].min);
+        SendMessage(socketfd, params[i].name.c_str());
+        SendMessage(socketfd, params[i].units.c_str());
+        sprintf(var, "%f", params[i].min);
         SendMessage(socketfd,var);
-        sprintf(var,"%f",params[i].max);
-        SendMessage(socketfd,var);
-        sprintf(var,"%f",params[i].step);
-        SendMessage(socketfd,var);
-
-        sprintf(counter,"%i",params[i].numAffects); 
-        SendMessage(socketfd,counter);
+        sprintf(var, "%f", params[i].max);
+        SendMessage(socketfd, var);
+        sprintf(var, "%f", params[i].step);
+        SendMessage(socketfd, var);
+
+        sprintf(counter, "%i", params[i].numAffects); 
+        SendMessage(socketfd, counter);
         for(j = 0; j < params[i].numAffects; j++) {
-            SendMessage(socketfd,params[i].affection_list[j].u->name.c_str());
-            SendMessage(socketfd,params[i].affection_list[j].relation.c_str());
+            SendMessage(socketfd, params[i].affection_list[j].u->name.c_str());
+            SendMessage(socketfd, params[i].affection_list[j].relation.c_str());
         }
     }
@@ -155 +155 @@
     // observables
     sprintf(counter,"%i",radio_info->numObservables);
-    SendMessage(socketfd,counter);
+    SendMessage(socketfd, counter);
     for(i = 0; i < radio_info->numObservables; i++) {
-        SendMessage(socketfd,observables[i].name.c_str());
+        SendMessage(socketfd, observables[i].name.c_str());
                 
-        sprintf(counter,"%i",observables[i].numAffects); 
-        SendMessage(socketfd,counter);
+        sprintf(counter, "%i", observables[i].numAffects); 
+        SendMessage(socketfd, counter);
         for(j = 0; j < observables[i].numAffects; j++) {
-            SendMessage(socketfd,observables[i].affection_list[j].u->name.c_str());
-            SendMessage(socketfd,observables[i].affection_list[j].relation.c_str());
+            SendMessage(socketfd, observables[i].affection_list[j].u->name.c_str());
+            SendMessage(socketfd, observables[i].affection_list[j].relation.c_str());
         }
     }
@@ -173 +173 @@
 
     if(strcmp(buffer, "receive_config_ack") != 0) {
-        LOG("Cognitive Radio Shell:: Unexpected response: %s\n",buffer);
+        LOG("Cognitive Radio Shell:: Unexpected response: %s\n", buffer);
         return 0;
     }
+
     return 1;
 
@@ -453 +454 @@
 {
     char buffer[256];
-    uint32_t numObservables,numParameters;
     char counter[55];
-    uint16_t i;
     char var[50];
 
@@ -461 +460 @@
     LOG("Cognitive Radio Shell:: Got request for optimization.\n");
     memset(buffer, 0, 256);
-    ReadMessage(commandSocketFD,buffer);
-    numObservables = atoi(buffer);
+    ReadMessage(commandSocketFD, buffer);
+    uint32_t numObservables = atoi(buffer);
   
-        LOG("Cognitive Radio Shell:: Attempting to get %i observables.\n",numObservables);
-    Observable * o = new Observable[numObservables];
+        LOG("Cognitive Radio Shell:: Attempting to get %i observables.\n", numObservables);
+    Observable *o = new Observable[numObservables];
  
-    for (i = 0; i < numObservables; i++){
+    for(size_t i = 0; i < numObservables; i++) {
         memset(buffer, 0, 256);
-        ReadMessage(commandSocketFD,buffer);
+        ReadMessage(commandSocketFD, buffer);
         o[i].name = std::string(buffer);
     
         memset(buffer, 0, 256);
-        ReadMessage(commandSocketFD,buffer);
+        ReadMessage(commandSocketFD, buffer);
         o[i].value = atof(buffer);
     }
@@ -483 +482 @@
 
         LOG("Cognitive Radio Shell:: Passing on observables to Cognitive Engine\n");
-    SendMessage(ceSocketFD,"get_solution");
-    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);
+    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);
     }
 
@@ -496 +495 @@
     /* Receive Set of Parameters */
     memset(buffer, 0, 256);
-    ReadMessage(ceSocketFD,buffer);
-    numParameters = atoi(buffer);
+    ReadMessage(ceSocketFD, buffer);
+    uint32_t numParameters = atoi(buffer);
    
-    Parameter * p = new Parameter[numParameters];
+    Parameter *p = new Parameter[numParameters];
  
-    for (i = 0; i < numParameters; i++){
+    for(size_t i = 0; i < numParameters; i++) {
         memset(buffer, 0, 256);
-        ReadMessage(ceSocketFD,buffer);
+        ReadMessage(ceSocketFD, buffer);
         p[i].name = std::string(buffer);
     
         memset(buffer, 0, 256);
-        ReadMessage(ceSocketFD,buffer);
+        ReadMessage(ceSocketFD, buffer);
         p[i].value = atof(buffer);
     }
@@ -515 +514 @@
         LOG("Cognitive Radio Shell:: Sending optimized parameters to Application.\n");
     memset(counter, 0, 55);
-    sprintf(counter,"%i",numParameters);
-    SendMessage(commandSocketFD,counter);
-    for(i = 0; i < numParameters; i++) {
-        SendMessage(commandSocketFD,p[i].name.c_str());
-        sprintf(var,"%f",p[i].value);
-            SendMessage(commandSocketFD,var);
-    }
+    sprintf(counter, "%i", numParameters);
+    SendMessage(commandSocketFD, counter);
+    for(size_t i = 0; i < numParameters; i++) {
+        SendMessage(commandSocketFD, p[i].name.c_str());
+        sprintf(var, "%f", p[i].value);
+            SendMessage(commandSocketFD, var);
+    }
+
+    delete [] o;
+    delete [] p;
 }
 
@@ -532 +534 @@
     ReadMessage(socketFD, buffer);
 
-    if(strcmp(buffer,"register_engine_cognitive") == 0) { 
+    if(strcmp(buffer, "register_engine_cognitive") == 0) { 
         RegisterCognitiveEngine(socketFD);
-    } else if(strcmp(buffer,"deregister_engine_cognitive") == 0) {
+    } else if(strcmp(buffer, "deregister_engine_cognitive") == 0) {
         DeregisterCognitiveEngine(socketFD);
-    } else if(strcmp(buffer,"register_engine_policy") == 0) {
+    } else if(strcmp(buffer, "register_engine_policy") == 0) {
         RegisterPolicyEngine(socketFD);
-    } else if(strcmp(buffer,"deregister_engine_policy") == 0) {
+    } else if(strcmp(buffer, "deregister_engine_policy") == 0) {
         DeregisterPolicyEngine(socketFD);
-    } else if(strcmp(buffer,"register_sml") == 0) {
+    } else if(strcmp(buffer, "register_sml") == 0) {
         RegisterSML(socketFD);
-    } else if(strcmp(buffer,"deregister_sml") == 0) {
+    } else if(strcmp(buffer, "deregister_sml") == 0) {
         DeregisterSML(socketFD);
-    } else if(strcmp(buffer,"request_optimization") == 0) {
+    } else if(strcmp(buffer, "request_optimization") == 0) {
         /* Receive optimization request and current environment */
         GetOptimalParameters(socketFD);