ReadMezzAFP.h

Go to the documentation of this file.

/***************************************************************************
 *   Copyright (C) 2004 by Olivier Stezowski                               *
 *   stezow(AT)ipnl.in2p3.fr                                               *
 *                                                                         *
 *   This program is free software; you can redistribute it and/or modify  *
 *   it under the terms of the GNU General Public License as published by  *
 *   the Free Software Foundation; either version 2 of the License, or     *
 *   (at your option) any later version.                                   *
 *                                                                         *
 *   This program is distributed in the hope that it will be useful,       *
 *   but WITHOUT ANY WARRANTY; without even the implied warranty of        *
 *   MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the         *
 *   GNU General Public License for more details.                          *
 *                                                                         *
 *   You should have received a copy of the GNU General Public License     *
 *   along with this program; if not, write to the                         *
 *   Free Software Foundation, Inc.,                                       *
 *   59 Temple Place - Suite 330, Boston, MA  02111-1307, USA.             *
 ***************************************************************************/
 
#ifndef _ReadMezzAFP
#define _ReadMezzAFP

#include "NarvalInterface.h"
#include "CrystalFrame.h"
#include "FrameBlock.h"
#include "Trigger.h"

#include "AgataFrameFactory.h"
#include "AgataKeyFactory.h"


class BashColor;

//using namespace ADF;

class ReadMezzAFP : public ADF::NarvalProducer
{
public:
  static const int kNCC = ADF::CrystalInterface::kNbCores;
  static const int kNSG = ADF::CrystalInterface::kNbSegments;

private:
    ADF::FileBlock fSourceOfFrames;
private:
    std::string fPath;
    std::string fBaseForName;
    FILE *fCurrentFile;
    unsigned int fCurrentFileNumber;
    unsigned int fMaxSize;
        
    short fConfMode;
    std::vector< std::string > fListOfFile;

    bool NewCrystal;
        
private:
    ADF::AgataFrameTrigger fEndOfFrame;

    std::vector<std::string> split(std::string s, char c);
    bool replace(std::string& str, const std::string& from, const std::string& to);
    bool contains(std::string s1, std::string s2);
    unsigned int uncompress_single_trace_AB(unsigned char* compr, unsigned int csize, unsigned short* trace);

public:
    void PrintStats();
    void ResetStats();
    bool IsUsingFiler() {return fUseKeyFilter;}

protected:
    unsigned short  crystal_id;
    unsigned short  crystal_status;
    unsigned int    evnumber;
    unsigned long long timestamp;
    unsigned long long FirstTimeStamp;
    unsigned long long LastTimeStamp;

    unsigned int fTraceLengthRaw;

    unsigned short *SegmentTraces[kNSG];
    unsigned short *CoreTraces[kNCC];

    float SegE[kNSG];
    unsigned short SegStatus[kNSG];
    unsigned short SegID[kNSG];

    float CoreE[kNCC];
    unsigned short CoreStatus[kNSG];
    unsigned short CoreID[kNSG];

    ADF::GeSegment *segMezz;    //
    ADF::GeCore    *coreMezz;   //

protected:
    ADF::SharedFP         *fFrameCrystal_Out;
    ADF::AgataFrameTrigger fTrigger;        

protected:
    static const int mezzanineMezzHeader =  16;   // fixed header length (short)
    static const int mezzanineChanHeader =   8;   // fixed header length of the mezzanine channels

    static const int MIN_1x6     = -32;
    static const int TOK_BINSIZE =  32;    // normalmente 32

private:
    bool fdebug;
    BashColor *fBashColor;

protected:
    FILE * fKeyFilterFile;
    bool fUseKeyFilter;
    bool fLastKeyIsRead;

    ADF::AgataKey *fKeyToLink;

    ADF::BufferIO *fKeyFilterBuffer;

    unsigned int  fNextEvtNbr;
    unsigned long long fNextTS;
    void NextKeyToFind();

private:
    unsigned int fNEvts;
    unsigned int fNIgnoredEvts;
    unsigned int fBitFlipMezzLength;
    unsigned int fBitFlipTraceLength;
    unsigned int fBitFlipSegId;
    unsigned int fBitFlipTS;

    std::string fCrystalName;

    unsigned long TotalEntryFileSize;
    unsigned long ReadEntryFileSize;
    unsigned long LastReadEntryFileSize;

private:
    void ProcessConvToBinary(unsigned long long n, std::ostringstream *str);
    std::string ConvertToBinary(unsigned long long n);

protected:
    bool NewFile();

    int ReadEvent();


public:
    ReadMezzAFP();
    virtual ~ReadMezzAFP();

    static void process_config (const char *, unsigned int *) ;
        
    virtual     void process_initialise (unsigned int *error_code);
        
    virtual     void process_reset (unsigned int *error_code);
                
    virtual unsigned int ProcessBlock (ADF::FrameBlock &) ;
};

#endif