Changeset 229
- Timestamp:
- 04/02/09 18:33:22 (15 years ago)
- Location:
- vtcross/trunk/src
- Files:
-
- 3 modified
Legend:
- Unmodified
- Added
- Removed
-
vtcross/trunk/src/lib/socketcomm/socketcomm.cpp
r227 r229 44 44 ERROR(1, "Error reading from socket.\n"); 45 45 if(msgLength == 0) 46 ERROR(1, "Remote component closed connection. \n");46 ERROR(1, "Remote component closed connection. 1\n"); 47 47 48 48 size_t i; … … 57 57 ERROR(1, "Error reading from socket.\n"); 58 58 if(msgLength == 0) 59 ERROR(1, "Remote component closed connection. \n");59 ERROR(1, "Remote component closed connection. 2\n"); 60 60 } 61 61 … … 124 124 ssize_t numSentBytes = send(socketFD, message, (strlen(message) + 1), 0); 125 125 if(numSentBytes < 0) { 126 ERROR(1, "Error sending to server .\n");126 ERROR(1, "Error sending to server %i (%i): %s\n",socketFD, numSentBytes, message); 127 127 } 128 128 else if(numSentBytes == 0) { -
vtcross/trunk/src/libvtcross/libvtcross.cpp
r228 r229 76 76 } 77 77 78 // Send Observables78 // Send Parameters 79 79 memset(counter, 0, 55); 80 sprintf(counter,"%i",numCurrentParameters); 81 SendMessage(socketfd,counter); 82 for(i = 0; i < numCurrentParameters; i++) { 83 SendMessage(socketfd,currentParameters[i].name.c_str()); 80 sprintf(counter, "%i", numCurrentParameters); 81 SendMessage(socketFD, counter); 82 83 for(i = 0; i < numCurrentParameters; i++) { 84 SendMessage(socketFD,currentParameters[i].name.c_str()); 84 85 sprintf(var,"%f",currentParameters[i].value); 85 SendMessage(socket fd,var);86 SendMessage(socketFD,var); 86 87 } 88 87 89 /* Receive Set of Parameters */ 88 90 memset(buffer, 0, 256); 89 91 ReadMessage(socketFD, buffer); 90 int32_tnumParameters = atoi(buffer);92 numParameters = atoi(buffer); 91 93 Parameter *pList = new Parameter[numParameters]; 92 94 -
vtcross/trunk/src/shell/CognitiveRadioShell.cpp
r228 r229 462 462 memset(buffer, 0, 256); 463 463 ReadMessage(commandSocketFD, buffer); 464 uint32_tnumObservables = atoi(buffer);464 numObservables = atoi(buffer); 465 465 466 466 LOG("Cognitive Radio Shell:: Attempting to get %i observables.\n", numObservables); … … 471 471 ReadMessage(commandSocketFD, buffer); 472 472 o[i].name = std::string(buffer); 473 473 474 474 memset(buffer, 0, 256); 475 475 ReadMessage(commandSocketFD, buffer); 476 476 o[i].value = atof(buffer); 477 477 } 478 479 /* Receive Set of Current Parameters */ 478 /* Receive Set of Current Parameters */ 480 479 memset(buffer, 0, 256); 481 480 ReadMessage(commandSocketFD,buffer); … … 484 483 LOG("Cognitive Radio Shell:: Attempting to get %i parameters.\n",numCurrentParameters); 485 484 Parameter * cp = new Parameter[numCurrentParameters]; 486 487 for ( i = 0; i < numCurrentParameters; i++){485 486 for (size_t i = 0; i < numCurrentParameters; i++){ 488 487 memset(buffer, 0, 256); 489 488 ReadMessage(commandSocketFD,buffer); 490 489 cp[i].name = std::string(buffer); 491 492 490 memset(buffer, 0, 256); 493 491 ReadMessage(commandSocketFD,buffer); … … 504 502 sprintf(counter,"%i",numObservables); 505 503 SendMessage(ceSocketFD,counter); 506 for( i = 0; i < numObservables; i++) {504 for(size_t i = 0; i < numObservables; i++) { 507 505 SendMessage(ceSocketFD,o[i].name.c_str()); 508 506 sprintf(var,"%f",o[i].value); … … 513 511 sprintf(counter,"%i",numCurrentParameters); 514 512 SendMessage(ceSocketFD,counter); 515 for( i = 0; i < numCurrentParameters; i++) {513 for(size_t i = 0; i < numCurrentParameters; i++) { 516 514 SendMessage(ceSocketFD,cp[i].name.c_str()); 517 515 sprintf(var,"%f",cp[i].value); … … 524 522 memset(buffer, 0, 256); 525 523 ReadMessage(ceSocketFD, buffer); 526 uint32_tnumParameters = atoi(buffer);524 numParameters = atoi(buffer); 527 525 528 526 Parameter *p = new Parameter[numParameters];