Changeset 548
- Timestamp:
- 02/10/11 17:52:24 (16 months ago)
- File:
-
- 1 edited
-
trunk/avango-core/src/avango/network/Msg.cpp (modified) (20 diffs)
Legend:
- Unmodified
- Added
- Removed
-
trunk/avango-core/src/avango/network/Msg.cpp
r541 r548 177 177 int32_t* arrayStart = const_cast<int32_t*>(&buf[0]); // ugly, but necessary 178 178 179 xdr_vector(xdr.getXDR(), reinterpret_cast<char*>(arrayStart), buf.size(), sizeof(int32_t),179 xdr_vector(xdr.getXDR(), reinterpret_cast<char*>(arrayStart), static_cast<uint32_t>(buf.size()), sizeof(int32_t), 180 180 (xdrproc_t)xdr_int); 181 181 182 182 msg.push(&tmpBuf[0], sizeof(int32_t)*buf.size()); 183 av_pushMsg(msg, buf.size());183 av_pushMsg(msg, static_cast<uint32_t>(buf.size())); 184 184 } 185 185 … … 187 187 av::av_popMsg(av::Msg& msg, std::vector<int32_t>& buf) 188 188 { 189 u nsigned int arraySize;189 uint32_t arraySize; 190 190 av_popMsg(msg, arraySize); 191 191 … … 197 197 msg.pop(&tmpVec[0], sizeof(int32_t)*arraySize); 198 198 199 xdr_vector(xdr.getXDR(), reinterpret_cast<char*>(&buf[0]), buf.size(), sizeof(int32_t),199 xdr_vector(xdr.getXDR(), reinterpret_cast<char*>(&buf[0]), static_cast<uint32_t>(buf.size()), sizeof(int32_t), 200 200 (xdrproc_t)xdr_int); 201 201 } … … 238 238 uint32_t* arrayStart = const_cast<uint32_t*>(&buf[0]); // ugly, but necessary 239 239 240 xdr_vector(xdr.getXDR(), reinterpret_cast<char*>(arrayStart), buf.size(), sizeof(uint32_t),240 xdr_vector(xdr.getXDR(), reinterpret_cast<char*>(arrayStart), static_cast<uint32_t>(buf.size()), sizeof(uint32_t), 241 241 (xdrproc_t)xdr_u_int); 242 242 243 243 msg.push(&tmpVec[0], sizeof(uint32_t)*buf.size()); 244 av_pushMsg(msg, buf.size());244 av_pushMsg(msg, static_cast<uint32_t>(buf.size())); 245 245 } 246 246 … … 248 248 av::av_popMsg(av::Msg& msg, std::vector<uint32_t>& buf) 249 249 { 250 u nsigned int arraySize;250 uint32_t arraySize; 251 251 av_popMsg(msg, arraySize); 252 252 … … 258 258 msg.pop(&tmpVec[0], sizeof(uint32_t)*arraySize); 259 259 260 xdr_vector(xdr.getXDR(), reinterpret_cast<char*>(&buf[0]), buf.size(), sizeof(uint32_t),260 xdr_vector(xdr.getXDR(), reinterpret_cast<char*>(&buf[0]), static_cast<uint32_t>(buf.size()), sizeof(uint32_t), 261 261 (xdrproc_t)xdr_u_int); 262 262 } … … 299 299 int64_t* arrayStart = const_cast<int64_t*>(&buf[0]); // ugly, but necessary 300 300 301 xdr_vector(xdr.getXDR(), reinterpret_cast<char*>(arrayStart), buf.size(), sizeof(int64_t),301 xdr_vector(xdr.getXDR(), reinterpret_cast<char*>(arrayStart), static_cast<uint32_t>(buf.size()), sizeof(int64_t), 302 302 (xdrproc_t)xdr_longlong_t); 303 303 304 304 msg.push(&tmpVec[0], sizeof(int64_t)*buf.size()); 305 av_pushMsg(msg, buf.size());305 av_pushMsg(msg, static_cast<uint32_t>(buf.size())); 306 306 } 307 307 … … 309 309 av::av_popMsg(av::Msg& msg, std::vector<int64_t>& buf) 310 310 { 311 u nsigned int arraySize;311 uint32_t arraySize; 312 312 av_popMsg(msg, arraySize); 313 313 … … 319 319 msg.pop(&tmpVec[0], sizeof(int64_t)*arraySize); 320 320 321 xdr_vector(xdr.getXDR(), reinterpret_cast<char*>(&buf[0]), buf.size(), sizeof(int64_t),321 xdr_vector(xdr.getXDR(), reinterpret_cast<char*>(&buf[0]), static_cast<uint32_t>(buf.size()), sizeof(int64_t), 322 322 (xdrproc_t)xdr_longlong_t); 323 323 } … … 361 361 uint64_t* arrayStart = const_cast<uint64_t*>(&buf[0]); // ugly, but necessary 362 362 363 xdr_vector(xdr.getXDR(), reinterpret_cast<char*>(arrayStart), buf.size(), sizeof(uint64_t),363 xdr_vector(xdr.getXDR(), reinterpret_cast<char*>(arrayStart), static_cast<uint32_t>(buf.size()), sizeof(uint64_t), 364 364 (xdrproc_t)xdr_u_longlong_t); 365 365 366 366 msg.push(&tmpVec[0], sizeof(uint64_t)*buf.size()); 367 av_pushMsg(msg, buf.size());367 av_pushMsg(msg, static_cast<uint32_t>(buf.size())); 368 368 } 369 369 … … 371 371 av::av_popMsg(av::Msg& msg, std::vector<uint64_t>& buf) 372 372 { 373 u nsigned int arraySize;373 uint32_t arraySize; 374 374 av_popMsg(msg, arraySize); 375 375 … … 381 381 msg.pop(&tmpVec[0], sizeof(uint64_t)*arraySize); 382 382 383 xdr_vector(xdr.getXDR(), reinterpret_cast<char*>(&buf[0]), buf.size(), sizeof(uint64_t),383 xdr_vector(xdr.getXDR(), reinterpret_cast<char*>(&buf[0]), static_cast<uint32_t>(buf.size()), sizeof(uint64_t), 384 384 (xdrproc_t)xdr_u_longlong_t); 385 385 } … … 423 423 float* arrayStart = const_cast<float*>(&buf[0]); // ugly, but necessary 424 424 425 xdr_vector(xdr.getXDR(), (char*)arrayStart, buf.size(), sizeof(float), (xdrproc_t)xdr_float);425 xdr_vector(xdr.getXDR(), (char*)arrayStart, static_cast<uint32_t>(buf.size()), sizeof(float), (xdrproc_t)xdr_float); 426 426 427 427 msg.push(&tmpVec[0], sizeof(float)*buf.size()); 428 av_pushMsg(msg, buf.size());428 av_pushMsg(msg, static_cast<uint32_t>(buf.size())); 429 429 430 430 AVANGO_LOG(logger, logging::TRACE, boost::str(boost::format("push: (vector<float>) [%1%]") % buf.size())) … … 434 434 av::av_popMsg(av::Msg& msg, std::vector<float>& buf) 435 435 { 436 u nsigned int arraySize;436 uint32_t arraySize; 437 437 av_popMsg(msg, arraySize); 438 438 … … 445 445 msg.pop(&tmpVec[0], sizeof(float)*arraySize); 446 446 447 xdr_vector(xdr.getXDR(), (char*)&buf[0], buf.size(), sizeof(float), (xdrproc_t)xdr_float);447 xdr_vector(xdr.getXDR(), (char*)&buf[0], static_cast<uint32_t>(buf.size()), sizeof(float), (xdrproc_t)xdr_float); 448 448 449 449 AVANGO_LOG(logger, logging::TRACE, boost::str(boost::format("pop: (vector<float>) [%1%]") % buf.size())) … … 488 488 double* arrayStart = const_cast<double*>(&buf[0]); // ugly, but necessary 489 489 490 xdr_vector(xdr.getXDR(), reinterpret_cast<char*>(arrayStart), buf.size(), sizeof(double),490 xdr_vector(xdr.getXDR(), reinterpret_cast<char*>(arrayStart), static_cast<uint32_t>(buf.size()), sizeof(double), 491 491 (xdrproc_t)xdr_double); 492 492 493 493 msg.push(&tmpVec[0], sizeof(double)*buf.size()); 494 av_pushMsg(msg, buf.size());494 av_pushMsg(msg, static_cast<uint32_t>(buf.size())); 495 495 496 496 AVANGO_LOG(logger, logging::TRACE, boost::str(boost::format("push: (vector<double>) [%1%]") % buf.size())) … … 500 500 av::av_popMsg(av::Msg& msg, std::vector<double>& buf) 501 501 { 502 u nsigned int arraySize;502 uint32_t arraySize; 503 503 av_popMsg(msg, arraySize); 504 504 … … 511 511 msg.pop(&tmpVec[0], sizeof(double)*arraySize); 512 512 513 xdr_vector(xdr.getXDR(), reinterpret_cast<char*>(&buf[0]), buf.size(), sizeof(double),513 xdr_vector(xdr.getXDR(), reinterpret_cast<char*>(&buf[0]), static_cast<uint32_t>(buf.size()), sizeof(double), 514 514 (xdrproc_t)xdr_double); 515 515 … … 664 664 AVANGO_LOG(logger, logging::TRACE, boost::str(boost::format("push: (std::string) [%1%]") % str)); 665 665 666 int length = str.size();666 uint32_t length = str.size(); 667 667 if (length) 668 668 { … … 675 675 av::av_popMsg(av::Msg& msg, std::string& str) 676 676 { 677 int length = 0;677 uint32_t length = 0; 678 678 av_popMsg(msg, length); 679 679 if (length)
Note: See TracChangeset
for help on using the changeset viewer.
