rogue
Loading...
Searching...
No Matches
StreamZip.h
Go to the documentation of this file.
1
17#ifndef __ROGUE_UTILITIES_STREAM_ZIP_H__
18#define __ROGUE_UTILITIES_STREAM_ZIP_H__
19#include "rogue/Directives.h"
20
21#include <stdint.h>
22
23#include <memory>
24#include <thread>
25
28namespace rogue {
29namespace utilities {
30
50 public:
61 static std::shared_ptr<rogue::utilities::StreamZip> create();
62
64 static void setup_python();
65
73 StreamZip();
74
76 ~StreamZip();
77
82 void acceptFrame(std::shared_ptr<rogue::interfaces::stream::Frame> frame);
83
90 std::shared_ptr<rogue::interfaces::stream::Frame> acceptReq(uint32_t size, bool zeroCopyEn);
91};
92
93// Convienence
94typedef std::shared_ptr<rogue::utilities::StreamZip> StreamZipPtr;
95} // namespace utilities
96} // namespace rogue
97#endif
Stream master endpoint.
Definition Master.h:65
Stream slave endpoint and default frame pool.
Definition Slave.h:72
Stream module that compresses frame payloads using bzip2.
Definition StreamZip.h:49
~StreamZip()
Destroys stream compressor.
Definition StreamZip.cpp:54
void acceptFrame(std::shared_ptr< rogue::interfaces::stream::Frame > frame)
Accepts a frame, compresses its payload, and forwards the result.
Definition StreamZip.cpp:57
static std::shared_ptr< rogue::utilities::StreamZip > create()
Creates a stream compressor instance.
Definition StreamZip.cpp:45
std::shared_ptr< rogue::interfaces::stream::Frame > acceptReq(uint32_t size, bool zeroCopyEn)
Forwards frame-allocation requests upstream.
static void setup_python()
Registers Python bindings for this class.
StreamZip()
Constructs a stream compressor.
Definition StreamZip.cpp:51
std::shared_ptr< rogue::utilities::StreamZip > StreamZipPtr
Definition StreamZip.h:94