| [3537] | 1 | #include "pciewrap.h" | 
|---|
| [3623] | 2 | #include "brpaqu.h" | 
|---|
| [3537] | 3 |  | 
|---|
| [3623] | 4 | #include "racqumem.h" | 
|---|
|  | 5 |  | 
|---|
| [3537] | 6 | #include <stdlib.h> | 
|---|
|  | 7 | #include <stdio.h> | 
|---|
| [3639] | 8 | #include <string.h> | 
|---|
| [3537] | 9 | #include <math.h> | 
|---|
|  | 10 | #include <iostream> | 
|---|
|  | 11 |  | 
|---|
| [3683] | 12 | using namespace SOPHYA; | 
|---|
|  | 13 |  | 
|---|
| [3628] | 14 | /* --Methode-- */ | 
|---|
| [3645] | 15 | TestPCIWrapperNODMA::TestPCIWrapperNODMA(UInt32 sz, double lossrate) | 
|---|
| [3628] | 16 | : PCIEWrapperInterface() , size_(sz) | 
|---|
| [3537] | 17 | { | 
|---|
| [3623] | 18 | data_ = new Byte[size_]; | 
|---|
| [3631] | 19 | srcdata_ = new Byte[10*size_]; | 
|---|
|  | 20 | for(UInt32 kk=0; kk<10*size_; kk++) | 
|---|
|  | 21 | srcdata_[kk] = (Byte)(kk%200+20); | 
|---|
| [3623] | 22 | frame_counter_ = 0; | 
|---|
|  | 23 | timetag_ = 0; | 
|---|
| [3645] | 24 | tottransfer_ = 0; | 
|---|
|  | 25 | lossrate_ = lossrate; | 
|---|
|  | 26 | cout << " TestPCIWrapperNODMA(PaqSz=" << sz << ",LossRate=" << lossrate << ")" << endl; | 
|---|
| [3537] | 27 | } | 
|---|
|  | 28 |  | 
|---|
| [3628] | 29 | /* --Methode-- */ | 
|---|
| [3623] | 30 | TestPCIWrapperNODMA::~TestPCIWrapperNODMA() | 
|---|
| [3537] | 31 | { | 
|---|
| [3631] | 32 | delete[] data_; | 
|---|
|  | 33 | delete[] srcdata_; | 
|---|
| [3537] | 34 | } | 
|---|
|  | 35 |  | 
|---|
| [3628] | 36 | /* --Methode-- */ | 
|---|
| [3623] | 37 | UInt32 TestPCIWrapperNODMA::TransferSize() | 
|---|
|  | 38 | { | 
|---|
|  | 39 | return size_; | 
|---|
|  | 40 | } | 
|---|
| [3537] | 41 |  | 
|---|
| [3628] | 42 | /* --Methode-- */ | 
|---|
| [3623] | 43 | UInt64 TestPCIWrapperNODMA::TotTransferBytes() | 
|---|
|  | 44 | { | 
|---|
|  | 45 | return tottransfer_; | 
|---|
|  | 46 | } | 
|---|
| [3537] | 47 |  | 
|---|
| [3628] | 48 | /* --Methode-- */ | 
|---|
| [3643] | 49 | Byte* TestPCIWrapperNODMA::GetData() | 
|---|
| [3537] | 50 | { | 
|---|
| [3645] | 51 | if (lossrate_ > 1.e-19) { | 
|---|
|  | 52 | UInt32 dfc = 1; | 
|---|
|  | 53 | while (rg_.Flat01()<lossrate_)  dfc++; | 
|---|
|  | 54 | frame_counter_ += dfc; | 
|---|
|  | 55 | } | 
|---|
|  | 56 | else frame_counter_ ++; | 
|---|
| [3623] | 57 | timetag_ = frame_counter_ * size_ / 2; | 
|---|
|  | 58 | BRPaquet paq(data_, size_); | 
|---|
|  | 59 | paq.SetHDRMarker64(pchk_.HDRTag()); | 
|---|
|  | 60 | paq.SetTRLMarker64(pchk_.TRLTag()); | 
|---|
| [3671] | 61 | UInt16 cfc = (frame_counter_%65535); | 
|---|
|  | 62 | paq.SetFrameCounter(cfc); | 
|---|
| [3623] | 63 | paq.SetTimeTag(timetag_); | 
|---|
|  | 64 | paq.SetPaqLen((UInt16)((size_ - BRHDRSIZE - BRTRLSIZE)/4)); | 
|---|
|  | 65 | Byte* bp = paq.Data1(); | 
|---|
| [3625] | 66 | /* | 
|---|
| [3623] | 67 | for(UInt32 kk=0; kk<paq.DataSize(); kk++) | 
|---|
|  | 68 | bp[kk] = (Byte)(sin(0.0345*kk)*78.+127.5); | 
|---|
| [3626] | 69 | UInt32 kkmax = paq.DataSize(); | 
|---|
|  | 70 | for(UInt32 kk=0; kk<kkmax; kk++) | 
|---|
| [3625] | 71 | bp[kk] = (Byte)(kk%200+20); | 
|---|
| [3631] | 72 | */ | 
|---|
|  | 73 | UInt32 off = (frame_counter_*size_/3)%(9*size_); | 
|---|
|  | 74 | memcpy(bp, srcdata_+off, paq.DataSize()); | 
|---|
| [3623] | 75 | tottransfer_ += size_; | 
|---|
|  | 76 | return data_; | 
|---|
| [3537] | 77 | } | 
|---|
|  | 78 |  | 
|---|
| [3628] | 79 | /* --Methode-- */ | 
|---|
| [3623] | 80 | void TestPCIWrapperNODMA::PrintStatus(ostream& os) | 
|---|
| [3537] | 81 | { | 
|---|
| [3623] | 82 | os << "TestPCIWrapperNODMA::Status, FrameCounter=" << frame_counter_ | 
|---|
|  | 83 | << " TimeTag=" << timetag_ << endl; | 
|---|
| [3639] | 84 | } | 
|---|