Changeset 71 for vtcross/branches/trnewman/CR_shell
- Timestamp:
- 11/22/08 21:14:44 (16 years ago)
- Location:
- vtcross/branches/trnewman/CR_shell/src
- Files:
-
- 2 modified
Legend:
- Unmodified
- Added
- Removed
-
vtcross/branches/trnewman/CR_shell/src/main_cognitive_engine.cpp
r70 r71 25 25 26 26 struct Affect { 27 Utility *u;27 Utility u; 28 28 //string relation; 29 char relation[ 20];29 char relation[50]; 30 30 }; 31 31 … … 61 61 n = recv(socket,buffer,256,MSG_PEEK); 62 62 for(i=0;i<256;i++){ 63 if(strcmp(&buffer[i],"\0") == 0) break;63 if(strcmp(&buffer[i],"\0") == 0) break; 64 64 } 65 65 n = recv(socket,buffer,i+1,0); 66 66 if (n < 0) 67 67 error("ERROR reading from socket"); 68 //printf("ReadMessage:%s %d\n",buffer,n);68 // printf("ReadMessage:%s %d\n",buffer,n); 69 69 } 70 70 … … 102 102 error("ERROR connecting"); 103 103 104 int i ;104 int i, j; 105 105 Utility uList[10]; 106 106 Parameter pList[10]; … … 117 117 for (i = 0; i < ce_info.numUtilities; i++){ 118 118 bzero(buffer,256); 119 ReadMessage(sockfd,buffer);120 printf("Name: %s\n", buffer);119 ReadMessage(sockfd,buffer); 120 printf("Name: %s\n", buffer); 121 121 strcpy(uList[i].name, buffer); 122 122 123 123 bzero(buffer,256); 124 ReadMessage(sockfd,buffer);125 printf("Units: %s\n", buffer);124 ReadMessage(sockfd,buffer); 125 printf("Units: %s\n", buffer); 126 126 strcpy(uList[i].units, buffer); 127 127 128 128 bzero(buffer,256); 129 ReadMessage(sockfd,buffer);129 ReadMessage(sockfd,buffer); 130 130 printf("Goal: %s\n", buffer); 131 131 strcpy(uList[i].goal, buffer); 132 132 133 bzero(buffer,256);134 ReadMessage(sockfd,buffer);133 bzero(buffer,256); 134 ReadMessage(sockfd,buffer); 135 135 printf("Target: %s\n", buffer); 136 136 uList[i].target = atof(buffer); 137 137 } 138 138 139 //for (i = 0; i < ce_info->numUtilities; i++){ 140 /*for (i = 0; i < 1; i++){ 141 printf("%s ", uList[i]); 142 }*/ 143 printf("\n"); 144 145 146 return 0; 139 // read parameters 140 // numParameters 141 bzero(buffer,256); 142 ReadMessage(sockfd,buffer); 143 ce_info.numParameters = atoi(buffer); 144 printf("number of parameters: %d\n", ce_info.numParameters); 145 146 for (i = 0; i < ce_info.numParameters; i++){ 147 bzero(buffer,256); 148 ReadMessage(sockfd,buffer); 149 printf("Name: %s\n", buffer); 150 strcpy(pList[i].name, buffer); 151 152 bzero(buffer,256); 153 ReadMessage(sockfd,buffer); 154 printf("Units: %s\n", buffer); 155 strcpy(pList[i].units, buffer); 156 157 bzero(buffer,256); 158 ReadMessage(sockfd,buffer); 159 printf("Min: %s\n", buffer); 160 pList[i].min = atof(buffer); 161 162 bzero(buffer,256); 163 ReadMessage(sockfd,buffer); 164 printf("Max: %s\n", buffer); 165 pList[i].max = atof(buffer); 166 167 bzero(buffer,256); 168 ReadMessage(sockfd,buffer); 169 printf("Step: %s\n", buffer); 170 pList[i].step = atof(buffer); 171 172 // numAffects 173 bzero(buffer,256); 174 ReadMessage(sockfd,buffer); 175 pList[i].numAffects = atoi(buffer); 176 printf("number of affects: %d\n", pList[i].numAffects); 177 178 for (j = 0; j < pList[i].numAffects; j++){ 179 bzero(buffer,256); 180 ReadMessage(sockfd,buffer); 181 printf("Utility name: %s\n", buffer); 182 strcpy(pList[i].affection_list[j].u.name, buffer); 183 184 bzero(buffer,256); 185 ReadMessage(sockfd,buffer); 186 printf("Relation: %s\n", buffer); 187 strcpy(pList[i].affection_list[j].relation, buffer); 188 } 189 190 } 191 192 // read obervables 193 // numParameters 194 bzero(buffer,256); 195 ReadMessage(sockfd,buffer); 196 ce_info.numObservables = atoi(buffer); 197 printf("number of observables: %d\n", ce_info.numObservables); 198 199 for (i = 0; i < ce_info.numObservables; i++){ 200 bzero(buffer,256); 201 ReadMessage(sockfd,buffer); 202 printf("Name: %s\n", buffer); 203 strcpy(pList[i].name, buffer); 204 205 // numAffects 206 bzero(buffer,256); 207 ReadMessage(sockfd,buffer); 208 oList[i].numAffects = atoi(buffer); 209 printf("number of affects: %d\n", oList[i].numAffects); 210 211 for (j = 0; j < oList[i].numAffects; j++){ 212 bzero(buffer,256); 213 ReadMessage(sockfd,buffer); 214 printf("Utility name: %s\n", buffer); 215 strcpy(oList[i].affection_list[j].u.name, buffer); 216 217 bzero(buffer,256); 218 ReadMessage(sockfd,buffer); 219 printf("Relation: %s\n", buffer); 220 strcpy(oList[i].affection_list[j].relation, buffer); 221 } 222 } 223 224 225 printf("xml transmission done\n"); 226 227 228 return 0; 147 229 } -
vtcross/branches/trnewman/CR_shell/src/main_cognitive_radio.cpp
r70 r71 224 224 225 225 // Wait for incoming message 226 n = re cv(socketfd,buffer,255,0);226 n = read(socketfd,buffer,256); 227 227 228 228 // Print message 229 229 if (n > 0) 230 printf("Here is the message: %s\n",buffer);230 printf("Here is the received meessage: %s\n",buffer); 231 231 //printf("n = %d\n",n); 232 232 … … 236 236 int SendMessage(int socketfd, string message) { 237 237 int n; 238 int len; 239 240 char LEN[8]; 241 char * temp; 238 242 239 243 message.append("\0000"); … … 251 255 char counter[55]; 252 256 char var[50]; 253 254 257 255 258 // while(1) { 256 // Send parameters from struct259 // Send number of utilities 257 260 sprintf(counter,"%d",ce_info->numUtilities); 258 261 SendMessage(socketfd,counter); … … 268 271 } 269 272 270 / *// parameters273 // parameters 271 274 sprintf(counter,"%i",ce_info->numParameters); 272 275 SendMessage(socketfd,counter); … … 301 304 SendMessage(socketfd,oList[i]->affection_list[j].relation); 302 305 } 303 }*/ 304 305 306 } 307 306 308 // Receive a message 307 309 string message; 308 310 n = ReceiveMessage(socketfd, message); 309 //cout << message << endl;311 cout << message << endl; 310 312 311 313 … … 394 396 if(pid == 0) { 395 397 // In child process - open policy engine port. 396 // StartShell(3000 3,uList, pList, oList, &ce_info);398 // StartShell(30000,uList, pList, oList, &ce_info); 397 399 } else { 398 400 // In parent process - open cognitive engine port. … … 402 404 403 405 return 1; 404 } 406 }