Changeset 3759 in Sophya for trunk/AddOn/TAcq/racqueth.cc

Timestamp:

Apr 30, 2010, 11:04:59 PM (15 years ago)

Author:

ansari

Message:

Suite debug des classes PCIEToEthernet et EthernetReader , Reza 30/04/2010

File:

• trunk/AddOn/TAcq/racqueth.cc (modified) (8 diffs)

trunk/AddOn/TAcq/racqueth.cc

@@ -59 +59 @@
   }
   totrdsnd_ = 0;
+  SetEthSendBlockSize();
+  SetPrintLevel();
 }
 
@@ -149 +151 @@
     // Byte* nextdma = locdata+((kmz%memgr.NbZones())*(paqsz*memgr.NbPaquets()));
   uint_4 npaqfaitg = 0; 
+  uint_4 prtmod = par_.BlocPerFile()*par_.MMgrNbPaquet();
+  if (prtmod < 500) prtmod=500;
+
   while (npaqfaitg < nmaxpaq_) {  // Boucle global G 
     if (fgarret) break;
@@ -171 +176 @@
     }
     if (fgbaddma) continue;  
-
+    if ((prtlev_>0)&&(npaqfaitg%prtmod==0)) 
+      cout << " PCIEToEthernet::run()/Info NPaqFait= " << npaqfaitg << endl;
     if (fgdirectsend) {  // Pas de copie / reduction de taille de paquet, on rebalance tel quel ...
       for (int fib=0; fib<(int) nbDma_ ;fib++) {
@@ -306 +312 @@
 size_t PCIEToEthernet::SendToTargets(int fib, Byte* data, size_t len)
 {
-  //DBG   cout << " SendToTargets/DBG" << cnt_prt << " len=" << len << " data=" << hex << (unsigned long)data << dec << endl; cnt_prt++; 
+  //  cout << " SendToTargets/DBG" << cnt_prt << " len=" << len << " data=" << hex << (unsigned long)data << dec << endl; cnt_prt++; 
   vector<ClientSocket>& vskt = vvec_skt_[fib];
   size_t rc=0;
-  for(size_t j=0; j<vskt.size(); j++) {
-    rc += vskt[j].Send((const char *)data, len);
-    totrdsnd_ += len;
+  size_t nblk = len/eths_bsz_;
+  size_t fblk = len%eths_bsz_;
+  size_t off = 0;
+  if (nblk>0) {
+    for(size_t i=0; i<nblk; i++) {
+      for(size_t j=0; j<vskt.size(); j++) {
+        rc += vskt[j].Send((const char *)data+off, eths_bsz_);
+        totrdsnd_ += eths_bsz_;
+      }
+      off += eths_bsz_;
+    }
+  }
+  if (fblk>0) {
+    for(size_t j=0; j<vskt.size(); j++) {
+      rc += vskt[j].Send((const char *)data+off, fblk);
+      totrdsnd_ += fblk;
+    }
   }
   return rc;
@@ -323 +343 @@
   :  memgr_(mem), par_(par), stop_(false), rdsamefc_(rdsamefc), tcpportid_(portid)
 {
-  SetPrintLevel();
   totnbytesrd_ = 0;
   totnpaqrd_ = 0;
@@ -359 +378 @@
     cout << " EthernetReader/Info connection/link" << fib << " established." << endl; 
   }
+
+  SetEthRecvBlockSize();
+  SetPrintLevel();
 }
 
@@ -476 +498 @@
   bool fggood=false;
   while(!fggood) { 
-    vsok_[fib].Receive((char *)vpaq_[fib].Begin(), packsize_);
+    ReceiveFromSocket(fib, (char *)vpaq_[fib].Begin(), packsize_);
     totnbytesrd_+=packsize_;
     totnpqrd_[fib]++;
@@ -483 +505 @@
   totnpqok_[fib]++;
   return false;
+}
+
+/* --Methode-- */
+size_t EthernetReader::ReceiveFromSocket(int fib, char* data, size_t len)
+{
+  size_t nblk = len/ethr_bsz_;
+  size_t fblk = len%ethr_bsz_;
+  size_t off = 0;
+  size_t rc =0;
+  if (nblk>0) {
+    for(size_t i=0; i<nblk; i++)  {
+      rc += vsok_[fib].Receive(data+off, ethr_bsz_);
+      off += ethr_bsz_;  
+    }
+  }
+  if (fblk>0) {
+    rc += vsok_[fib].Receive(data+off, fblk);
+  }
+  return rc;
 }