Changeset 155 for vtcross/branches/bhilburn/src/policy_engines/PolicyEngine.cpp

Timestamp:

03/13/09 13:59:34 (15 years ago)

Author:

bhilburn

Message:

Implemented the old default policy engine in our new PolicyEngine? class. Doesn't
link properly due to redefinitions of socket functions... might need to change
the way that is laid out to fix it.

Files:

• vtcross/branches/bhilburn/src/policy_engines/PolicyEngine.cpp (modified) (2 diffs)

vtcross/branches/bhilburn/src/policy_engines/PolicyEngine.cpp

@@ -9 +9 @@
 
 
+#include <cstdlib>
+#include <cstring>
+#include <stdint.h>
+
 #include "vtcross/common.h"
 #include "vtcross/components.h"
@@ -17 +21 @@
 
 
-void PolicyEngine::GetRemoteComponentType()
+PolicyEngine::PolicyEngine()
+{
+    LOG("Creating Policy Engine.\n");
+    LoadPolicies();
+}
+
+
+PolicyEngine::~PolicyEngine()
 {
 }
 
 
-void PolicyEngine::WaitForSignal()
+void 
+PolicyEngine::GetRemoteComponentType(int32_t socketFD)
 {
 }
 
 
-void PolicyEngine::Shutdown()
+void 
+PolicyEngine::WaitForSignal(int32_t socketFD)
+{
+    LOG("Policy Engine:: Waiting for Policy Check Request.\n");
+
+    int32_t decision_array[10];
+    struct Parameter pList[10];
+    struct CE_Info ce_info;
+    int32_t ret = GetRequest(socketFD, pList, &ce_info);
+   
+    if(ret == 1) {
+        LOG("Policy Engine:: Validating Transmission Parameters.\n");
+        ValidateParameters(pList, &ce_info, decision_array);    
+
+        LOG("Policy Engine:: Sending Policy decision to Server.\n");
+        SendPEDecision(socketFD, pList, &ce_info, decision_array);
+    }
+}
+
+
+void 
+PolicyEngine::Shutdown()
 {
 }
 
 
-void PolicyEngine::Reset()
+void
+PolicyEngine::Reset()
 {
 }
 
 
-void PolicyEngine::RegisterComponent(socketFD, compType)
+void
+PolicyEngine::RegisterComponent(int32_t socketFD)
+{
+    SendMessage(socketFD, "p_register");
+    LOG("Policy Engine:: Registration message sent.\n");
+}
+
+
+void 
+PolicyEngine::DeregisterComponent(int32_t socketFD)
 {
 }
 
 
-void PolicyEngine::DeregisterComponent()
+void 
+PolicyEngine::RegisterServices(int32_t socketFD)
 {
 }
 
 
-void PolicyEngine::RegisterServices()
+void 
+PolicyEngine::DeregisterServices(int32_t socketFD)
 {
 }
 
 
-void PolicyEngine::DeregisterServices()
+void 
+PolicyEngine::LoadPolicies()
+{
+    LOG("PolicyEngine:: Loading policies.\n");
+}
+
+
+void 
+PolicyEngine::ReloadPolicies()
 {
 }
 
 
-void PolicyEngine::ReloadPolicies()
+void 
+PolicyEngine::SendPEDecision(int32_t socketFD, struct Parameter pList[], \
+        struct CE_Info *ce_info, int32_t decision_array[])
 {
-}
-
-void PolicyEngine::LoadPolicies()
-{
+    char var[50];
+ 
+    for (size_t i = 0; i < ce_info->numParameters; i++) {
+        sprintf(var, "%i", decision_array[i]);
+        SendMessage(socketFD, var);
+    }
 }
 
 
-void PolicyEngine::ValidateParameters()
+void 
+PolicyEngine::ValidateParameters(struct Parameter pList[], \
+        struct CE_Info *ce_info, int decision_array[])
 {
+    LOG("Policy Engine:: Policies Validated.\n");
+    for (size_t i = 0; i < ce_info->numParameters; i++)
+        decision_array[i] = 1;
 }