Changes in classes/DelphesPileUpReader.cc [1716933:cab38f6] in git

File:

• classes/DelphesPileUpReader.cc (modified) (9 diffs)

classes/DelphesPileUpReader.cc

@@ -33 +33 @@
 
 #include <stdio.h>
-#include <stdint.h>
-
-#include "classes/DelphesXDRReader.h"
+#include <rpc/types.h>
+#include <rpc/xdr.h>
 
 using namespace std;
@@ -48 +47 @@
   fEntries(0), fEntrySize(0), fCounter(0),
   fPileUpFile(0), fIndex(0), fBuffer(0),
-  fInputReader(0), fIndexReader(0), fBufferReader(0)
+  fInputXDR(0), fIndexXDR(0), fBufferXDR(0)
 {
   stringstream message;
 
-  fIndex = new uint8_t[kIndexSize*8];
-  fBuffer = new uint8_t[kBufferSize*kRecordSize*4];
-  fInputReader = new DelphesXDRReader;
-  fIndexReader = new DelphesXDRReader;
-  fBufferReader = new DelphesXDRReader;
-
-  fIndexReader->SetBuffer(fIndex);
-  fBufferReader->SetBuffer(fBuffer);
+  fIndex = new char[kIndexSize*8];
+  fBuffer = new char[kBufferSize*kRecordSize*4];
+  fInputXDR = new XDR;
+  fIndexXDR = new XDR;
+  fBufferXDR = new XDR;
+  xdrmem_create(fIndexXDR, fIndex, kIndexSize*8, XDR_DECODE);
+  xdrmem_create(fBufferXDR, fBuffer, kBufferSize*kRecordSize*4, XDR_DECODE);
 
   fPileUpFile = fopen(fileName, "r");
@@ -69 +67 @@
   }
 
-  fInputReader->SetFile(fPileUpFile);
+  xdrstdio_create(fInputXDR, fPileUpFile, XDR_DECODE);
 
   // read number of events
   fseeko(fPileUpFile, -8, SEEK_END);
-  fInputReader->ReadValue(&fEntries, 8);
+  xdr_hyper(fInputXDR, &fEntries);
 
   if(fEntries >= kIndexSize)
@@ -83 +81 @@
   // read index of events
   fseeko(fPileUpFile, -8 - 8*fEntries, SEEK_END);
-  fInputReader->ReadRaw(fIndex, fEntries*8);
+  xdr_opaque(fInputXDR, fIndex, fEntries*8);
 }
 
@@ -90 +88 @@
 DelphesPileUpReader::~DelphesPileUpReader()
 {
+  xdr_destroy(fInputXDR);
   if(fPileUpFile) fclose(fPileUpFile);
-  if(fBufferReader) delete fBufferReader;
-  if(fIndexReader) delete fIndexReader;
-  if(fInputReader) delete fInputReader;
+  xdr_destroy(fBufferXDR);
+  xdr_destroy(fIndexXDR);
+  if(fBufferXDR) delete fBufferXDR;
+  if(fIndexXDR) delete fIndexXDR;
+  if(fInputXDR) delete fInputXDR;
   if(fBuffer) delete[] fBuffer;
   if(fIndex) delete[] fIndex;
@@ -100 +101 @@
 //------------------------------------------------------------------------------
 
-bool DelphesPileUpReader::ReadParticle(int32_t &pid,
+bool DelphesPileUpReader::ReadParticle(int &pid,
   float &x, float &y, float &z, float &t,
   float &px, float &py, float &pz, float &e)
@@ -106 +107 @@
   if(fCounter >= fEntrySize) return false;
 
-  fBufferReader->ReadValue(&pid, 4);
-  fBufferReader->ReadValue(&x, 4);
-  fBufferReader->ReadValue(&y, 4);
-  fBufferReader->ReadValue(&z, 4);
-  fBufferReader->ReadValue(&t, 4);
-  fBufferReader->ReadValue(&px, 4);
-  fBufferReader->ReadValue(&py, 4);
-  fBufferReader->ReadValue(&pz, 4);
-  fBufferReader->ReadValue(&e, 4);
+  xdr_int(fBufferXDR, &pid);
+  xdr_float(fBufferXDR, &x);
+  xdr_float(fBufferXDR, &y);
+  xdr_float(fBufferXDR, &z);
+  xdr_float(fBufferXDR, &t);
+  xdr_float(fBufferXDR, &px);
+  xdr_float(fBufferXDR, &py);
+  xdr_float(fBufferXDR, &pz);
+  xdr_float(fBufferXDR, &e);
 
   ++fCounter;
@@ -123 +124 @@
 //------------------------------------------------------------------------------
 
-bool DelphesPileUpReader::ReadEntry(int64_t entry)
+bool DelphesPileUpReader::ReadEntry(quad_t entry)
 {
-  int64_t offset;
+  quad_t offset;
 
   if(entry >= fEntries) return false;
 
   // read event position
-  fIndexReader->SetOffset(8*entry);
-  fIndexReader->ReadValue(&offset, 8);
+  xdr_setpos(fIndexXDR, 8*entry);
+  xdr_hyper(fIndexXDR, &offset);
 
   // read event
   fseeko(fPileUpFile, offset, SEEK_SET);
-  fInputReader->ReadValue(&fEntrySize, 4);
+  xdr_int(fInputXDR, &fEntrySize);
 
   if(fEntrySize >= kBufferSize)
@@ -142 +143 @@
   }
 
-  fInputReader->ReadRaw(fBuffer, fEntrySize*kRecordSize*4);
-  fBufferReader->SetOffset(0);
+  xdr_opaque(fInputXDR, fBuffer, fEntrySize*kRecordSize*4);
+  xdr_setpos(fBufferXDR, 0);
   fCounter = 0;