Data.h

Go to the documentation of this file.

 
#ifndef __ROGUE_PROTOCOLS_BATCHER_DATA_H__
#define __ROGUE_PROTOCOLS_BATCHER_DATA_H__
#include "rogue/Directives.h"
 
#include <stdint.h>
 
#include <memory>
#include <thread>
 
#include "rogue/interfaces/stream/Frame.h"
#include "rogue/interfaces/stream/FrameIterator.h"
 
namespace rogue {
namespace protocols {
namespace batcher {
 
class Data {
    // Iterator to beginning of record payload in source frame.
    rogue::interfaces::stream::FrameIterator it_;
 
    // Record payload size in bytes.
    uint32_t size_;
 
    // Destination/channel field from record tail.
    uint8_t dest_;
 
    // First-user metadata byte from record tail.
    uint8_t fUser_;
 
    // Last-user metadata byte from record tail.
    uint8_t lUser_;
 
  public:
    static void setup_python();
 
    static std::shared_ptr<rogue::protocols::batcher::Data> create(rogue::interfaces::stream::FrameIterator it,
                                                                   uint32_t size,
                                                                   uint8_t dest,
                                                                   uint8_t fUser,
                                                                   uint8_t lUser);
 
    Data(rogue::interfaces::stream::FrameIterator it, uint32_t size, uint8_t dest, uint8_t fUser, uint8_t lUser);
 
    ~Data();
 
    rogue::interfaces::stream::FrameIterator begin();
 
    rogue::interfaces::stream::FrameIterator end();
 
    uint32_t size();
 
    uint8_t dest();
 
    uint8_t fUser();
 
    uint8_t lUser();
};
 
// Convienence
typedef std::shared_ptr<rogue::protocols::batcher::Data> DataPtr;
}  // namespace batcher
}  // namespace protocols
}  // namespace rogue
#endif