CoreV2.h

Go to the documentation of this file.

 
#ifndef __ROGUE_PROTOCOLS_BATCHER_CORE_V2_H__
#define __ROGUE_PROTOCOLS_BATCHER_CORE_V2_H__
#include "rogue/Directives.h"
 
#include <stdint.h>
 
#include <memory>
#include <thread>
#include <vector>
 
#include "rogue/Logging.h"
#include "rogue/interfaces/stream/Frame.h"
 
namespace rogue {
namespace protocols {
namespace batcher {
 
class Data;
 
class CoreV2 {
    std::shared_ptr<rogue::Logging> log_;
 
    // Most recently parsed frame.
    std::shared_ptr<rogue::interfaces::stream::Frame> frame_;
 
    // Parsed record descriptors.
    std::vector<std::shared_ptr<rogue::protocols::batcher::Data> > list_;
 
    // Parsed super-header size in bytes.
    uint32_t headerSize_;
 
    // Parsed per-record tail size in bytes.
    uint32_t tailSize_;
 
    // Iterators pointing to each parsed tail.
    std::vector<rogue::interfaces::stream::FrameIterator> tails_;
 
    // Parsed frame sequence number.
    uint32_t seq_;
 
  public:
    static void setup_python();
 
    static std::shared_ptr<rogue::protocols::batcher::CoreV2> create();
 
    CoreV2();
 
    ~CoreV2();
 
    void initSize(uint32_t size);
 
    uint32_t count();
 
    uint32_t headerSize();
 
    rogue::interfaces::stream::FrameIterator beginHeader();
 
    rogue::interfaces::stream::FrameIterator endHeader();
 
    uint32_t tailSize();
 
    rogue::interfaces::stream::FrameIterator beginTail(uint32_t index);
 
    rogue::interfaces::stream::FrameIterator endTail(uint32_t index);
 
    std::shared_ptr<rogue::protocols::batcher::Data>& record(uint32_t index);
 
    uint32_t sequence();
 
    bool processFrame(std::shared_ptr<rogue::interfaces::stream::Frame> frame);
 
    void reset();
};
 
// Convienence
typedef std::shared_ptr<rogue::protocols::batcher::CoreV2> CoreV2Ptr;
}  // namespace batcher
}  // namespace protocols
}  // namespace rogue
#endif