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