Changeset 191
- Timestamp:
- 03/23/09 10:52:00 (15 years ago)
- Location:
- vtcross/trunk/src
- Files:
-
- 2 modified
Legend:
- Unmodified
- Added
- Removed
-
vtcross/trunk/src/include/vtcross/components.h
r190 r191 77 77 * inherit (e.g. cognitive and policy engines). Inherits all functions from the 78 78 * ABC Component publically. 79 *80 * TODO perhaps this shouldn't be an abstract base class? Some functions, like81 * GetRemoteComponentType, are going to be the same for all child classes82 * anyways...83 79 */ 84 80 class Engine : public Component … … 148 144 * is connected to. 149 145 */ 150 int32_t s ocketFD;146 int32_t shellSocketFD; 151 147 }; 152 148 … … 204 200 */ 205 201 bool SML_present; 206 int32_t socketFD;202 int32_t commandSocketFD; 207 203 }; 208 204 … … 264 260 */ 265 261 bool SML_present; 266 int32_t socketFD;262 int32_t commandSocketFD; 267 263 }; 268 264 -
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 }