Changeset 191 for vtcross/trunk/src/policy_engines/PolicyEngine.cpp
- Timestamp:
- 03/23/09 10:52:00 (15 years ago)
- Files:
-
- 1 modified
Legend:
- Unmodified
- Added
- Removed
-
vtcross/trunk/src/policy_engines/PolicyEngine.cpp
r188 r191 41 41 SML_present = SML; 42 42 43 socketFD = ClientSocket(serverName, portNumber);43 commandSocketFD = ClientSocket(serverName, portNumber); 44 44 45 45 if(SML_present) { … … 72 72 73 73 // TODO should this be a GetRequest call or something else? 74 if(GetRequest( socketFD, pList, &ce_info)) {74 if(GetRequest(commandSocketFD, pList, &ce_info)) { 75 75 LOG("Policy Engine:: Validating Transmission Parameters.\n"); 76 76 ValidateParameters(pList, &ce_info, decision_array); … … 97 97 LOG("Resetting Policy Engine.\n"); 98 98 SML_present = false; 99 socketFD = -1;99 commandSocketFD = -1; 100 100 LoadPolicies(); 101 101 } … … 105 105 PolicyEngine::RegisterComponent() 106 106 { 107 SendMessage( socketFD, "register_engine_policy");107 SendMessage(commandSocketFD, "register_engine_policy"); 108 108 LOG("Policy Engine:: Registration message sent.\n"); 109 109 … … 114 114 PolicyEngine::DeregisterComponent() 115 115 { 116 SendMessage( socketFD, "deregister_engine_policy");116 SendMessage(commandSocketFD, "deregister_engine_policy"); 117 117 LOG("Policy Engine:: Registration message sent.\n"); 118 118 } … … 123 123 { 124 124 LOG("Policy Engine:: Registering services.\n"); 125 SendMessage( socketFD, "register_service_pe_geo");126 SendMessage( socketFD, "register_service_pe_time");127 SendMessage( socketFD, "register_service_pe_spectrum");128 SendMessage( socketFD, "register_service_pe_spacial");125 SendMessage(commandSocketFD, "register_service_pe_geo"); 126 SendMessage(commandSocketFD, "register_service_pe_time"); 127 SendMessage(commandSocketFD, "register_service_pe_spectrum"); 128 SendMessage(commandSocketFD, "register_service_pe_spacial"); 129 129 } 130 130 … … 134 134 { 135 135 LOG("Policy Engine:: Deregistering services.\n"); 136 SendMessage( socketFD, "deregister_service_pe_geo");137 SendMessage( socketFD, "deregister_service_pe_time");138 SendMessage( socketFD, "deregister_service_pe_spectrum");139 SendMessage( socketFD, "deregister_service_pe_spacial");136 SendMessage(commandSocketFD, "deregister_service_pe_geo"); 137 SendMessage(commandSocketFD, "deregister_service_pe_time"); 138 SendMessage(commandSocketFD, "deregister_service_pe_spectrum"); 139 SendMessage(commandSocketFD, "deregister_service_pe_spacial"); 140 140 } 141 141 … … 163 163 for (size_t i = 0; i < ce_info->numParameters; i++) { 164 164 sprintf(var, "%i", decision_array[i]); 165 SendMessage( socketFD, var);165 SendMessage(commandSocketFD, var); 166 166 } 167 167 }