EvioReader.h

Go to the documentation of this file.

//
// Copyright 2020, Jefferson Science Associates, LLC.
// Subject to the terms in the LICENSE file found in the top-level directory.
//
// EPSCI Group
// Thomas Jefferson National Accelerator Facility
// 12000, Jefferson Ave, Newport News, VA 23606
// (757)-269-7100


#ifndef EVIO_6_0_EVIOREADER_H
#define EVIO_6_0_EVIOREADER_H


#include <memory>
#include <fstream>


#include "ByteOrder.h"
#include "ByteBuffer.h"
#include "IEvioReader.h"
#include "EvioReaderV4.h"
#include "EvioReaderV6.h"
#include "IBlockHeader.h"
#include "BlockHeaderV2.h"
#include "BlockHeaderV4.h"
#include "RecordHeader.h"

namespace evio {


    class EvioReader : public IEvioReader {

    private:

        uint32_t evioVersion = 4;

        ByteOrder byteOrder {ByteOrder::ENDIAN_LOCAL};

        std::shared_ptr<ByteBuffer> byteBuffer;

        size_t initialPosition = 0;

        std::shared_ptr<IEvioReader> reader;

    public:

        //   File constructor
        explicit EvioReader(std::string const & path, bool checkRecNumSeq = false, bool synced = false);

        //   Buffer constructor
        explicit EvioReader(std::shared_ptr<ByteBuffer> & bb, bool checkRecNumSeq = false, bool synced = false);

        //------------------------------------------

        void setBuffer(std::shared_ptr<ByteBuffer> & buf) override;
        bool isClosed () override;
        bool checkBlockNumberSequence() override;
        ByteOrder & getByteOrder() override;
        uint32_t getEvioVersion() override;
        std::string getPath() override;
        std::shared_ptr<EventParser> & getParser() override;
        void setParser(std::shared_ptr<EventParser> & evParser) override;

        std::string getDictionaryXML() override;
        bool hasDictionaryXML() override;
        std::shared_ptr<EvioEvent> getFirstEvent() override;
        bool hasFirstEvent() override;

        size_t getNumEventsRemaining() override;
        std::shared_ptr<ByteBuffer> getByteBuffer() override;
        size_t fileSize() override;
        std::shared_ptr<IBlockHeader> getFirstBlockHeader() override;


        std::shared_ptr<EvioEvent> getEvent(size_t index) override;
        std::shared_ptr<EvioEvent> parseEvent(size_t index) override;
        std::shared_ptr<EvioEvent> nextEvent() override;
        std::shared_ptr<EvioEvent> parseNextEvent() override;
        void parseEvent(std::shared_ptr<EvioEvent> evioEvent) override;


        static std::shared_ptr<EvioEvent> getEvent(uint8_t * src, size_t len, ByteOrder const & order);
        static std::shared_ptr<EvioEvent> parseEvent(uint8_t * src, size_t len, ByteOrder const & order) ;


        uint32_t getEventArray(size_t evNumber, std::vector<uint8_t> & vec) override;
        uint32_t getEventBuffer(size_t evNumber, ByteBuffer & buf) override;

        void rewind() override;
        ssize_t position() override;
        void close() override;

        std::shared_ptr<IBlockHeader> getCurrentBlockHeader() override;
        std::shared_ptr<EvioEvent> gotoEventNumber(size_t evNumber) override;
        size_t getEventCount() override;
        size_t getBlockCount() override;
    };

}


#endif //EVIO_6_0_EVIOREADER_H