[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 | }
|
---|