Changeset 248

Timestamp:

05/13/09 16:40:44 (15 years ago)

Author:

wrodgers

Message:

s

Files:

• vtcross/branches/wrodgers/ServiceManagementLayer.cpp (modified) (12 diffs)

vtcross/branches/wrodgers/ServiceManagementLayer.cpp

@@ -6 +6 @@
 
 /* DESCRIPTION OF FILE.
- */ multiple clients
+ */
 
 
@@ -13 +13 @@
 #include <stdint.h>
 
-#include "../include/vtcross/common.h"
-#include "../include/vtcross/components.h"
-#include "../include/vtcross/containers.h"
-#include "../include/vtcross/debug.h"
-#include "../include/vtcross/error.h"
-#include "../include/vtcross/socketcomm.h"
+#include "../../trunk/src/include/vtcross/common.h"
+#include "../../trunk/src/include/vtcross/components.h"
+#include "../../trunk/src/include/vtcross/containers.h"
+#include "../../trunk/src/include/vtcross/debug.h"
+#include "../../trunk/src/include/vtcross/error.h"
+#include "../../trunk/src/include/vtcross/socketcomm.h"
+
+
+#include <cstdlib>
+#include <cstring>
+#include <stdint.h>
+#include <math.h>
+
+
+#include <arpa/inet.h>
+#include <iostream>
+#include <netinet/in.h>
+#include <netdb.h>
+#include <fcntl.h>
+#include <sys/ioctl.h>
+#include <sys/mman.h>
+#include <sys/socket.h>
+#include <sys/types.h>
+#include <sys/wait.h>
+
+#include "tinyxml/tinyxml.h"
+#include "tinyxml/tinystr.h"
+
+#include <sqlite3.h>
+#include <sqlite3ext.h>
 
 uint32_t Current_ID = 0;
@@ -30 +54 @@
     shellSocketFD = -1;
     LoadConfiguration();
+    numberOfCognitiveEngines = 0;
 }
 
@@ -102 +127 @@
     else if(strcmp(buffer, "query_component_type") == 0) {
         SendComponentType();
-     }
+    }
+    else if(strcmp(buffer, "reset_sml") == 0) {
+        Reset();
+    }
+    else if(strcmp(buffer, "shutdown_sml") == 0) {
+        Shutdown();
+    }
 }
 
@@ -120 +151 @@
 
 void
-CognitiveRadioShell::RegisterCognitiveEngine(int32_t ID)
+ServiceManagementLayer::RegisterCognitiveEngine(int32_t ID)
 {
     LOG("Cognitive Radio Shell:: Received registration message from Cognitive Engine.\n");
    
     TransferRadioConfiguration(ID);
-    TransferRadioExperience(ID);
+    TransferExperience(ID);
 
     numberOfCognitiveEngines++;
@@ -133 +164 @@
 
 void 
-CognitiveRadioShell::DeregisterCognitiveEngine(int32_t socketFD)
+ServiceManagementLayer::DeregisterCognitiveEngine(int32_t socketFD)
 {
     LOG("Cognitive Radio Shell:: Received deregistration message from Cognitive Engine.\n");
@@ -146 +177 @@
     LOG("Cognitive Radio Shell:: Socket closed.\n");
 }
-        }
-        else if(strcmp(buffer, "reset_sml") == 0) {
-            Reset();
-        }
-        else if(strcmp(buffer, "shutdown_sml") == 0) {
-            Shutdown();
-        }
-    }
-}
 
 
@@ -237 +259 @@
 
 void
-CognitiveRadioShell::RegisterCognitiveEngine(int32_t socketFD)
+ServiceManagementLayer::RegisterCognitiveEngine(int32_t socketFD)
 {
     SendMessage(commandSocketFD, "register_engine_cognitive");
@@ -243 +265 @@
 
     TransferRadioConfiguration(socketFD);
-    TransferRadioExperience(socketFD);
+    TransferExperience(socketFD);
 
     numberOfCognitiveEngines++;
@@ -251 +273 @@
 
 void 
-CognitiveRadioShell::DeregisterCognitiveEngine(int32_t socketFD)
+ServiceManagementLayer::DeregisterCognitiveEngine(int32_t socketFD)
 {
     LOG("Cognitive Radio Shell:: Received deregistration message from Cognitive Engine.\n");
@@ -266 +288 @@
 
 void
-CognitiveRadioShell::StartSMLServer()
+ServiceManagementLayer::StartSMLServer()
 {
     struct timeval selTimeout;
@@ -278 +300 @@
     int32_t maxDescriptor = cogEngSrv;
 
-    if(InitializeTCPServerPort(cogEngSrv) == -1)
+    if(InitianumberOfCognitiveEngineslizeTCPServerPort(cogEngSrv) == -1)
         ERROR(1,"Error initializing primary port\n");