| [3537] | 1 | #ifndef  PCIEWRAP_H_SEEN | 
|---|
|  | 2 | #define  PCIEWRAP_H_SEEN | 
|---|
| [3623] | 3 | #include "brtypes.h" | 
|---|
| [3537] | 4 | #include "machdefs.h" | 
|---|
| [3623] | 5 | #include "racqumem.h" | 
|---|
|  | 6 | #include "brpaqu.h" | 
|---|
| [3537] | 7 | #include <string> | 
|---|
| [3645] | 8 | #include "randr48.h"  // Generateur aleatoire SOPHYA pour simulation perte de paquets | 
|---|
| [3537] | 9 |  | 
|---|
|  | 10 | /* | 
|---|
|  | 11 | Classe interface aux fonctions d'I/O PCIExpress | 
|---|
|  | 12 | pour la carte de reception optique BAORadio | 
|---|
|  | 13 | R. Ansari                        Juin 2008 | 
|---|
|  | 14 | */ | 
|---|
|  | 15 |  | 
|---|
|  | 16 | using namespace std; | 
|---|
|  | 17 |  | 
|---|
| [4016] | 18 | /*! | 
|---|
|  | 19 | \class PCIEWException | 
|---|
|  | 20 | \ingroup TAcq | 
|---|
|  | 21 |  | 
|---|
|  | 22 | \brief exception class for PCI-express operations. | 
|---|
|  | 23 | */ | 
|---|
|  | 24 |  | 
|---|
| [3537] | 25 | class PCIEWException { | 
|---|
|  | 26 | public: | 
|---|
|  | 27 | explicit PCIEWException(const char * m) { msg = m; } | 
|---|
|  | 28 | explicit PCIEWException(const string& m) { msg = m; } | 
|---|
| [3623] | 29 | virtual ~PCIEWException() { } | 
|---|
| [3537] | 30 | virtual string const& Msg() const  {return msg;} | 
|---|
|  | 31 | virtual const char* what() {return msg.c_str(); } | 
|---|
|  | 32 | private: | 
|---|
|  | 33 | string msg; | 
|---|
|  | 34 | }; | 
|---|
|  | 35 |  | 
|---|
|  | 36 |  | 
|---|
| [3623] | 37 | // Classe definissant l'interface des operations transfert DMA/PCIExpress | 
|---|
| [3628] | 38 | class PCIEWrapperInterface { | 
|---|
| [3623] | 39 | public: | 
|---|
|  | 40 | // Constructeur - fait l'initialisation | 
|---|
| [3909] | 41 | PCIEWrapperInterface(); | 
|---|
| [3623] | 42 | // destructeur - libere la memoire allouee | 
|---|
| [3909] | 43 | virtual ~PCIEWrapperInterface(); | 
|---|
| [3537] | 44 |  | 
|---|
| [3623] | 45 | virtual UInt32 TransferSize() = 0; | 
|---|
| [3643] | 46 | virtual void   StartTransfers() { return; }; | 
|---|
|  | 47 | virtual Byte*  GetData() = 0; | 
|---|
| [3623] | 48 | virtual UInt64 TotTransferBytes() = 0; | 
|---|
|  | 49 | virtual void PrintStatus(ostream& os) = 0; | 
|---|
| [3909] | 50 | // Identification de fibres / voies | 
|---|
|  | 51 | inline void SetFiberNumId(int fibnum=1, int fibid=1) | 
|---|
|  | 52 | { fiber_num_=fibnum;  fiber_id_=fibid; } | 
|---|
|  | 53 | inline int FiberNum() { return fiber_num_; } | 
|---|
|  | 54 | inline int FiberId() { return fiber_id_; } | 
|---|
|  | 55 | // Parametre de controle de la boucle d'attente de fin de DMA (en unite de 1000 pour maxkwedma) | 
|---|
|  | 56 | virtual unsigned long SetMaxWaitEndDMA(unsigned int maxkwedma=1000, unsigned int nretry=3); | 
|---|
|  | 57 | protected: | 
|---|
|  | 58 | unsigned long maxwaitenddmaloop_;  // Nombre d'iterations de la boucle d'attente de fin de DMA | 
|---|
|  | 59 | unsigned int maxretryenddma_;      // nombre maxi de tentatives pour terminer le DMA | 
|---|
|  | 60 | int fiber_num_;                    // numero de fibre sur la machine | 
|---|
|  | 61 | int fiber_id_;                     // identificateur de fibre - numero absolu sur l'ensemble des machines | 
|---|
| [3623] | 62 | }; | 
|---|
| [3537] | 63 |  | 
|---|
| [3623] | 64 | // Classe de test Implementant l'interface PCIEWrapper sans DMA | 
|---|
| [3628] | 65 | class TestPCIWrapperNODMA : public PCIEWrapperInterface { | 
|---|
| [3623] | 66 | public: | 
|---|
| [3909] | 67 | // lossrate_=partie_fractionnaire[lossrate], max_frcount_=partie entiere[lossrate] | 
|---|
| [3645] | 68 | TestPCIWrapperNODMA(UInt32 sz, double lossrate=0.); | 
|---|
| [3623] | 69 | virtual ~TestPCIWrapperNODMA(); | 
|---|
|  | 70 |  | 
|---|
|  | 71 | virtual UInt32 TransferSize() ; | 
|---|
| [3643] | 72 | virtual Byte*  GetData() ; | 
|---|
| [3623] | 73 | virtual UInt64 TotTransferBytes() ; | 
|---|
|  | 74 | virtual void PrintStatus(ostream& os) ; | 
|---|
|  | 75 |  | 
|---|
|  | 76 | protected: | 
|---|
|  | 77 | Byte* data_; | 
|---|
| [3631] | 78 | Byte* srcdata_; | 
|---|
| [3623] | 79 | UInt32 size_; | 
|---|
|  | 80 | UInt32 frame_counter_; | 
|---|
|  | 81 | UInt64 timetag_; | 
|---|
|  | 82 | UInt64 tottransfer_; | 
|---|
| [3645] | 83 | double lossrate_; | 
|---|
| [3909] | 84 | UInt32 max_frcount_; | 
|---|
| [3623] | 85 | BRPaqChecker pchk_; | 
|---|
| [3645] | 86 | //  FMTRandGen rg_; | 
|---|
| [3683] | 87 | SOPHYA::ThSDR48RandGen rg_; | 
|---|
| [3537] | 88 | }; | 
|---|
|  | 89 |  | 
|---|
|  | 90 | #endif | 
|---|