Changeset 3764 in Sophya for trunk/AddOn/TAcq/racqueth.cc
- Timestamp:
- May 3, 2010, 9:11:20 AM (15 years ago)
- File:
-
- 1 edited
Legend:
- Unmodified
- Added
- Removed
-
trunk/AddOn/TAcq/racqueth.cc
r3763 r3764 64 64 } 65 65 totrdsnd_ = 0; 66 SetEthSendBlockSize();67 66 SetPrintLevel(); 68 67 } … … 336 335 for(size_t j=0; j<vskt.size(); j++) { 337 336 rc += vskt[j].SendAll((const char *)data, len); 338 totrdsnd_ += eths_bsz_;337 totrdsnd_ += len; 339 338 } 340 339 vec_cntpaq_[fib]++; 341 340 return rc; 342 /*343 if (eths_bsz_<16) {344 for(size_t j=0; j<vskt.size(); j++) {345 rc += vskt[j].SendAll((const char *)data, len);346 totrdsnd_ += eths_bsz_;347 }348 vec_cntpaq_[fib]++;349 return rc;350 }351 size_t nblk = len/eths_bsz_;352 size_t fblk = len%eths_bsz_;353 size_t off = 0;354 if (nblk>0) {355 for(size_t i=0; i<nblk; i++) {356 for(size_t j=0; j<vskt.size(); j++) {357 rc += vskt[j].SendAll((const char *)data+off, eths_bsz_);358 totrdsnd_ += eths_bsz_;359 }360 off += eths_bsz_;361 }362 }363 if (fblk>0) {364 for(size_t j=0; j<vskt.size(); j++) {365 rc += vskt[j].SendAll((const char *)data+off, fblk);366 totrdsnd_ += fblk;367 }368 }369 vec_cntpaq_[fib]++;370 return rc;371 */372 341 } 373 342 //------------------------------------------------------------------ … … 423 392 } 424 393 425 SetEthRecvBlockSize();426 394 SetPrintLevel(); 427 395 } … … 565 533 vec_cntpaq_[fib]++; 566 534 567 /* 568 if (ethr_bsz_<16) { 569 rc += vsok_[fib].ReceiveAll(data, len); 570 } 571 else { 572 size_t nblk = len/ethr_bsz_; 573 size_t fblk = len%ethr_bsz_; 574 size_t off = 0; 575 if (nblk>0) { 576 for(size_t i=0; i<nblk; i++) { 577 rc += vsok_[fib].ReceiveAll(data+off, ethr_bsz_); 578 off += ethr_bsz_; 579 } 580 } 581 if (fblk>0) { 582 rc += vsok_[fib].ReceiveAll(data+off, fblk); 583 } 584 } 535 /* 536 size_t nblk = len/ethr_bsz_; 537 size_t fblk = len%ethr_bsz_; 538 size_t off = 0; 539 if (nblk>0) { 540 for(size_t i=0; i<nblk; i++) { 541 rc += vsok_[fib].ReceiveAll(data+off, ethr_bsz_); 542 off += ethr_bsz_; 543 } 544 } 545 if (fblk>0) { 546 rc += vsok_[fib].ReceiveAll(data+off, fblk); 547 } 585 548 vec_cntpaq_[fib]++; 586 549 */ 587 550 588 551 if (vec_cntpaq_[fib]%par_.MMgrNbPaquet() == 0) {
Note:
See TracChangeset
for help on using the changeset viewer.