Changeset 209

Timestamp:

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

Author:

bhilburn

Message:

Simply whitespace fixes.

Location:

vtcross/trunk/src

Files:

• include/vtcross/components.h (modified) (17 diffs)
• shell/CognitiveRadioShell.cpp (modified) (23 diffs)

vtcross/trunk/src/include/vtcross/components.h

@@ -49 +49 @@
         }
 
-        
         /* Send an indentfying string for this object's component type in
          * response to a GetRemoteComponentType query.
@@ -55 +54 @@
         virtual void SendComponentType() = 0;
 
-
         /* Wait for a command signal containing task instructions.
          */
         virtual void WaitForSignal() = 0;
 
-
         /* Completely shutdown the radio and all operations.
          */
         virtual void Shutdown() = 0;
-
 
         /* Reset the radio and reload all configuration files.
@@ -71 +67 @@
          */
         virtual void Reset() = 0;
-
 
         /* Register or deregister a component with the primary radio shell.
@@ -97 +92 @@
                 const char* serverPort, const bool SML) = 0;
 
-
         /* Register or deregister services that this engine provides with the
          * service management layer.
@@ -140 +134 @@
         void TransferRadioConfiguration();
 
-        
         /* Receive information regarding a completed 'experience' and pass it on
          * to the appropriate cognitive engine.
          */
         void TransferExperience();
-
         
         /* Listen for other components registering their available services with
@@ -152 +144 @@
         void ReceiveServices();
 
-
         /* Change the active mission of the radio to a new one and adjust radio
          * behavoir appropriately.
@@ -158 +149 @@
         void SetActiveMission();
 
-
         /* List all services provided to the radio by registered components.
          */
         void ListServices();
-
 
         /* Load/Relead the XML configuration file. 
@@ -169 +158 @@
         void LoadConfiguration();
 
-
         /* The socket file descriptor information for the shell which this SML
          * is connected to.
@@ -185 +173 @@
         PolicyEngine();
         ~PolicyEngine();
-
 
         /* Overloaded constructor that creates a policy engine object and
@@ -211 +198 @@
         void ReloadPolicies();
 
-        
         /* Return a decision made by the policy engine regarding a certain set
          * of transmission parameters.
@@ -218 +204 @@
                 int32_t decision_array[]);
 
-
         /* Validate a set of transmission parameters received from the radio.
          */
         void ValidateParameters();
-
 
         /* The SML_present bool reflects whether or not the remote component
@@ -261 +245 @@
         void ReceiveRadioConfiguration();
 
-
         /* Receive an 'experience' report from the radio.
          */
         void ReceiveExperience();
-
 
         /* Find the most optimal set of transmission parameters given certain
@@ -273 +255 @@
         void GetSolution(Observable *observables);
         void GetSolution(Observable *observables, std::string service);
-
 
         /* Receive a feedback from the radio regarding the performance of a
@@ -303 +284 @@
         ~CognitiveRadioShell();
 
-
-        /* Overloaded constructor that creates a CR Shell object */ 
+        /* Overloaded constructor that creates a CR Shell object and loads the
+         * passed radio configuration XML file.
+         */
         CognitiveRadioShell(const char* radioConfig, int16_t primaryPort, \
             int16_t policyPort, int16_t commandPort);
@@ -314 +296 @@
         /* Start all the socket servers */
         void StartShellServer();
+
         int32_t LoadRadioConfiguration(const char* radioConfig, Parameter* &pList, \
             Utility* &uList, Observable* &oList, Radio_Info* radioInfo);
@@ -322 +305 @@
         void ReloadPolicies();
 
-        /* Register and Deregister the different components */
+        /* Register and Deregister the different components.
+         */
         void RegisterCognitiveEngine(int32_t socketFD);
         void DeregisterCognitiveEngine(int32_t socketFD);
@@ -330 +314 @@
         void DeregisterSML(int32_t socketFD);
 
-        /* Handle a message that is received from a component */
+        /* Handle a message that is received from a component.
+         */
         void HandleMessage(int32_t socketFD);
        
-        /* Send optimization request to primary port FD*/
+        /* Send optimization request to primary port FD.
+         */
         void GetOptimalParameters(int32_t socketFD);
 

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);