Changeset 181 for vtcross/trunk/src/policy_engines/PolicyEngine.cpp

Timestamp:

03/22/09 00:38:35 (15 years ago)

Author:

bhilburn

Message:

Implemented a more standard way of registering/deregistering components and
engines.

Files:

• vtcross/trunk/src/policy_engines/PolicyEngine.cpp (modified) (5 diffs)

vtcross/trunk/src/policy_engines/PolicyEngine.cpp

@@ -24 +24 @@
 {
     LOG("Creating Policy Engine.\n");
+    SML = NULL;
     LoadPolicies();
 }
@@ -30 +31 @@
 PolicyEngine::~PolicyEngine()
 {
+    if(SML)
+        delete SML;
+}
+
+
+PolicyEngine::PolicyEngine(const char* serverName, const char* portNumber)
+{
+    LOG("Creating Policy Engine.\n");
+
+    SML = new SML_Info;
+    SML->hostname = std::string(serverName);
+    SML->port = std::string(portNumber);
+
+    SML->socketFD = ClientSocket(serverName, portNumber);
+    RegisterServices(SML->socketFD);
+
+    LOG("Policy Engine connected to SML at %s.\n", serverName);
+
+    LoadPolicies();
 }
 
@@ -74 +94 @@
 PolicyEngine::RegisterComponent(int32_t socketFD)
 {
-    SendMessage(socketFD, "p_register");
+    SendMessage(socketFD, "register_engine_policy");
     LOG("Policy Engine:: Registration message sent.\n");
+
 }
 
@@ -88 +109 @@
 PolicyEngine::RegisterServices(int32_t socketFD)
 {
+    LOG("Policy Engine:: Registering services.\n");
+    SendMessage(socketFD, "register_service_pe_geo");
+    SendMessage(socketFD, "register_service_pe_time");
+    SendMessage(socketFD, "register_service_pe_spectrum");
+    SendMessage(socketFD, "register_service_pe_spacial");
 }
 
@@ -94 +120 @@
 PolicyEngine::DeregisterServices(int32_t socketFD)
 {
+    LOG("Policy Engine:: Deregistering services.\n");
+    SendMessage(socketFD, "deregister_service_pe_geo");
+    SendMessage(socketFD, "deregister_service_pe_time");
+    SendMessage(socketFD, "deregister_service_pe_spectrum");
+    SendMessage(socketFD, "deregister_service_pe_spacial");
 }