StreamWriterChannel.h

Go to the documentation of this file.

 
#ifndef __ROGUE_UTILITIES_FILEIO_STREAM_WRITER_CHANNEL_H__
#define __ROGUE_UTILITIES_FILEIO_STREAM_WRITER_CHANNEL_H__
#include "rogue/Directives.h"
 
#include <stdint.h>
 
#include <memory>
#include <thread>
 
#include "rogue/interfaces/stream/Slave.h"
 
namespace rogue {
namespace utilities {
namespace fileio {
 
class StreamWriter;
 
class StreamWriterChannel : public rogue::interfaces::stream::Slave {
    // Associated stream writer instance.
    std::shared_ptr<rogue::utilities::fileio::StreamWriter> writer_;
 
    // Fixed output channel, or 0 to use incoming frame channel.
    uint8_t channel_;
 
    // Number of frames accepted by this channel.
    uint32_t frameCount_;
 
    // Lock protecting frame counter and wait condition.
    std::mutex mtx_;
 
    // Condition signaled when frameCount_ changes.
    std::condition_variable cond_;
 
  public:
    static std::shared_ptr<rogue::utilities::fileio::StreamWriterChannel> create(
        std::shared_ptr<rogue::utilities::fileio::StreamWriter> writer,
        uint8_t channel);
 
    static void setup_python();
 
    StreamWriterChannel(std::shared_ptr<rogue::utilities::fileio::StreamWriter> writer, uint8_t channel);
 
    ~StreamWriterChannel();
 
    void acceptFrame(std::shared_ptr<rogue::interfaces::stream::Frame> frame);
 
    uint32_t getFrameCount();
 
    void setFrameCount(uint32_t count);
 
    bool waitFrameCount(uint32_t count, uint64_t timeout);
};
 
// Convenience
typedef std::shared_ptr<rogue::utilities::fileio::StreamWriterChannel> StreamWriterChannelPtr;
}  // namespace fileio
}  // namespace utilities
}  // namespace rogue
 
#endif