Changeset 3760 in Sophya for trunk/AddOn/TAcq

Timestamp:

Apr 30, 2010, 11:26:02 PM (15 years ago)

Author:

ansari

Message:

Ajout parametre taille de bloc de transfert sur ethernet _{Reza 30/04/2010}

Location:

trunk/AddOn/TAcq

Files:

• acqparam_exemple.d (modified) (1 diff)
• brparam.cc (modified) (3 diffs)
• brparam.h (modified) (1 diff)
• mfacq.cc (modified) (2 diffs)

trunk/AddOn/TAcq/acqparam_exemple.d

@@ -49 +49 @@
 #  @ethrnlink 4
 ethrnlink 4
+## No de port TCP/IP et taille des blocs lors des transferts sur ethernet  
+#  @tcpportid 6912
+#  @ethtrbsz 1024
+tcpportid 6912
+ethtrbsz 1024
 #  Pour desactiver l'ecriture des fichiers FITS
 #  @nosavesigfits

trunk/AddOn/TAcq/brparam.cc

@@ -134 +134 @@
 
   tcpportid=BRSPORTID;
+  eth_transfer_blksz=1024;
   pci2eth_fgdirect=false;
   ethr_nlink = 0;
@@ -190 +191 @@
   reducoffset=p.reducoffset;
 
+  tcpportid=p.tcpportid;
+  eth_transfer_blksz=p.eth_transfer_blksz;
   pci2eth_fgdirect=p.pci2eth_fgdirect;
   eths_targets=p.eths_targets;
@@ -229 +232 @@
   // Mot cle pour le mode envoi-reception sur ethernet 
   tcpportid=conf.IParam("tcpportid",0,BRSPORTID);
+  eth_transfer_blksz=(size_t)conf.IParam("ethtrbsz",0,1024);
   if (conf.HasKey("pci2ethdirect"))  pci2eth_fgdirect = true;   // Transfer direct DMA -> Ethernet
   if (conf.HasKey("ethrtargets")) {    // Machines destinations des paquets 

trunk/AddOn/TAcq/brparam.h

@@ -159 +159 @@
 
   // ---- Variables specifiques em mode transfert DMA vers Ethernet 
-  int tcpportid; 
+  int tcpportid;     // No de port TCP/IP
+  size_t eth_transfer_blksz;    //taille des blocs pour le transfert a travers ethernet
   // Cote Send DMA -> Ethernet 
   bool pci2eth_fgdirect;   // true -> direct transfer DMA to Ethernet  

trunk/AddOn/TAcq/mfacq.cc

@@ -295 +295 @@
   PCIEToEthernet pci2eth(vec_pciw, bpar.GetParams().GetEthTargets(), bpar.GetParams());
   pci2eth.SetPrintLevel(1);
+  pci2eth.SetEthSendBlockSize(bpar.GetParams().eth_transfer_blksz);
   //  usleep(200);  attente au cas ou ...
   pPcie2Eth=&pci2eth;
@@ -347 +348 @@
   cout << "mfacq[3] Creating   EthernetReader thread object     " << endl;
   EthernetReader ethrdr(mmgr, bpar.GetParams(), bpar.GetParams().tcpportid, false);
+  ethrdr.SetEthRecvBlockSize(acpar.eth_transfer_blksz);
+
   //  usleep(200);  attente au cas ou ...
   pEthRdr=&ethrdr;