CombinerV1.h

Go to the documentation of this file.

 
#ifndef __ROGUE_PROTOCOLS_BATCHER_COMBINER_V1_H__
#define __ROGUE_PROTOCOLS_BATCHER_COMBINER_V1_H__
#include "rogue/Directives.h"
 
#include <stdint.h>
 
#include <memory>
#include <mutex>
#include <vector>
 
#include "rogue/Logging.h"
#include "rogue/interfaces/stream/Frame.h"
#include "rogue/interfaces/stream/Master.h"
#include "rogue/interfaces/stream/Slave.h"
 
namespace rogue {
namespace protocols {
namespace batcher {
 
class CombinerV1 : public rogue::interfaces::stream::Master, public rogue::interfaces::stream::Slave {
    std::shared_ptr<rogue::Logging> log_;
 
    // Queued frames waiting to be batched.
    std::vector<std::shared_ptr<rogue::interfaces::stream::Frame> > queue_;
 
    // Width encoding (0-5).
    uint8_t width_;
 
    // Header size in bytes.
    uint32_t headerSize_;
 
    // Tail size in bytes.
    uint32_t tailSize_;
 
    // Sequence counter.
    uint8_t seq_;
 
    // Mutex for queue access.
    std::mutex mtx_;
 
  public:
    static void setup_python();
 
    static std::shared_ptr<rogue::protocols::batcher::CombinerV1> create(uint8_t width);
 
    explicit CombinerV1(uint8_t width);
 
    ~CombinerV1();
 
    void acceptFrame(std::shared_ptr<rogue::interfaces::stream::Frame> frame);
 
    void sendBatch();
 
    uint32_t getCount();
};
 
// Convenience
typedef std::shared_ptr<rogue::protocols::batcher::CombinerV1> CombinerV1Ptr;
}  // namespace batcher
}  // namespace protocols
}  // namespace rogue
#endif