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

Timestamp:

03/26/09 12:53:27 (15 years ago)

Author:

bhilburn

Message:

Simply whitespace fixes.

Files:

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

vtcross/trunk/src/shell/CognitiveRadioShell.cpp

@@ -62 +62 @@
     radio_info = new Radio_Info;
 
-
     LoadRadioConfiguration(radioConfig,p,u,o,radio_info);
 
@@ -78 +77 @@
 }
 
+
 void 
 CognitiveRadioShell::Shutdown()
@@ -98 +98 @@
 }
 
+
 void
 CognitiveRadioShell::SendRadioExperience(int32_t socketFD)
@@ -104 +105 @@
     LOG("Cognitive Radio Shell:: Sending radio experience to Cognitive Engine.\n");
 }
+
 
 void
@@ -117 +119 @@
 }
 
+
 void 
 CognitiveRadioShell::DeregisterCognitiveEngine(int32_t socketFD)
@@ -124 +127 @@
     numberOfCognitiveEngines--;
     if(numberOfCognitiveEngines == 0)
-    CE_present = false;
+        CE_present = false;
 
     SendMessage(socketFD, "deregister_ack");
@@ -132 +135 @@
 }
 
+
 void
 CognitiveRadioShell::RegisterPolicyEngine(int32_t socketFD)
@@ -138 +142 @@
     PE_present = true;
 }
+
 
 void 
@@ -152 +157 @@
 }
 
+
 void
 CognitiveRadioShell::RegisterSML(int32_t socketFD)
@@ -159 +165 @@
     SML_present = true;
 }
+
 
 void 
@@ -173 +180 @@
 }
 
+
 int32_t 
-CognitiveRadioShell::LoadRadioConfiguration(const char* radioConfig, Parameter* &pList, \
-    Utility* &uList, Observable* &oList, Radio_Info * radioInfo)
+CognitiveRadioShell::LoadRadioConfiguration(const char* radioConfig, \
+        Parameter* &pList, Utility* &uList, Observable* &oList, \
+        Radio_Info* radioInfo)
 {
     TiXmlElement *pElem;
@@ -193 +202 @@
     TiXmlDocument doc( radioConfig );
     bool loadOkay = doc.LoadFile();
-    if(!loadOkay)
-    {
+    if(!loadOkay) {
         ERROR(1,"Loading radio configuration failed: %s\n", radioConfig);
         return -1;
@@ -212 +220 @@
 
     for(pChild = pChild1->FirstChildElement("utility"); pChild; \
-        pChild = pChild->NextSiblingElement()) 
-    {
+        pChild = pChild->NextSiblingElement()) {
+
         const char *uName = pChild->Attribute("name");
         if(uName)
@@ -240 +248 @@
 
     for(pChild = pChild1->FirstChildElement("observable"); pChild; \
-        pChild = pChild->NextSiblingElement()) 
-    {
+        pChild = pChild->NextSiblingElement()) {
+
         const char *oName = pChild->Attribute("name");
         if(oName) 
@@ -248 +256 @@
         affect_count = 0;
         for(pSecondChild = pChild->FirstChildElement("affect"); pSecondChild; \
-            pSecondChild = pSecondChild->NextSiblingElement()) 
-        {
+            pSecondChild = pSecondChild->NextSiblingElement()) {
+
             const char *oUtilName = pSecondChild->Attribute("utility");
-            if(oUtilName) 
-            {
-                for(attribute_count = 0; attribute_count < radio_info->numUtilities; attribute_count++ ) 
-                {
-                    if(uList[attribute_count].name == oUtilName) 
-                    {
+            if(oUtilName) {
+                for(attribute_count = 0; attribute_count < radio_info->numUtilities; attribute_count++ ) {
+                    if(uList[attribute_count].name == oUtilName) {
+
                         oList[item_count].affection_list[affect_count].u = &uList[attribute_count];
                         const char *oRelate = pSecondChild->Attribute("relationship");
                         if(oRelate) 
                             oList[item_count].affection_list[affect_count].relation = oRelate;
+
                         affect_count++;
                         match_found = true;
@@ -287 +294 @@
     item_count = 0;
     for(pChild = pChild1->FirstChildElement("parameter"); pChild; \
-        pChild = pChild->NextSiblingElement()) 
-    {
+        pChild = pChild->NextSiblingElement()) {
+
         const char *pName = pChild->Attribute("name");
         if(pName) 
@@ -308 +315 @@
         affect_count = 0;
         for(pSecondChild = pChild->FirstChildElement("affect"); pSecondChild; \
-            pSecondChild = pSecondChild->NextSiblingElement()) 
-        {
+
+            pSecondChild = pSecondChild->NextSiblingElement()) {
             const char *pUtilName = pSecondChild->Attribute("utility");
-            if(pUtilName) 
-            {
-                for(attribute_count = 0; attribute_count < radio_info->numUtilities; attribute_count++) 
-                {
-                    if(uList[attribute_count].name == pUtilName) 
-                    {
+            if(pUtilName) {
+                for(attribute_count = 0; attribute_count < radio_info->numUtilities; attribute_count++) {
+                    if(uList[attribute_count].name == pUtilName) {
                         pList[item_count].affection_list[affect_count].u = &uList[attribute_count];    
 
@@ -332 +336 @@
             }
 
-            if(!match_found) 
-            {
+            if(!match_found) {
                 ERROR(1, "Error: %s: %s is not a valid utility.\n", \
                     pList[item_count].name.c_str(), pUtilName);
@@ -352 +355 @@
 }
 
+
 void
 CognitiveRadioShell::GetOptimalParameters(int32_t socketFD)
 {
-
-
-}
+}
+
 
 void
@@ -384 +387 @@
 }
 
+
 void
 CognitiveRadioShell::StartShellServer()
@@ -421 +425 @@
     }
 
-    while (running)
-    {
+    while (running) {
         /* Zero socket descriptor vector and set for server sockets */
         /* This must be reset every time select() is called */
@@ -437 +440 @@
         /* Suspend program until descriptor is ready or timeout */
         rc = select(maxDescriptor + 1, &sockSet, NULL, NULL, &selTimeout); 
-        if (rc == 0)
+        if(rc == 0)
             LOG("No echo requests for %i secs...Server still alive\n", timeout);
-        else 
-        {
+        else {
             desc_ready = rc;
 
-            for (port = 0; port <= maxDescriptor && desc_ready > 0; port++) {
-                if (FD_ISSET(port, &sockSet))
-                {
-                desc_ready -= 1;
+            for(port = 0; port <= maxDescriptor && desc_ready > 0; port++) {
+                if(FD_ISSET(port, &sockSet)) {
+                    desc_ready -= 1;
 
                     /* Check if request is new or on an existing open descriptor */
-                    if( (port == servSock[primary]) || (port == servSock[policy]) || (port == servSock[command])) { 
-                        do
-                        { 
+                    if((port == servSock[primary]) || (port == servSock[policy]) || (port == servSock[command])) { 
+                        do {
                             new_sd = AcceptTCPConnection(port);
                             if(new_sd < 0) 
-                            {
                                 break;
-                            }
                             
                             HandleMessage(new_sd);
@@ -464 +462 @@
                             //LOG("New incoming connection - %i\n\n",new_sd);
                         } while(new_sd != -1);
-                    } else {
-                        
+                    } 
+                    else {
                         //LOG("Request on already open descriptor.\n\n");
                         HandleMessage(port);