rogue
Loading...
Searching...
No Matches
StreamUnZip.h
Go to the documentation of this file.
1
17#ifndef __ROGUE_UTILITIES_STREAM_UN_ZIP_H__
18#define __ROGUE_UTILITIES_STREAM_UN_ZIP_H__
19#include "rogue/Directives.h"
20
21#include <stdint.h>
22
23#include <memory>
24#include <thread>
25
28
29namespace rogue {
30namespace utilities {
31
52 public:
63 static std::shared_ptr<rogue::utilities::StreamUnZip> create();
64
66 static void setup_python();
67
76
79
84 void acceptFrame(std::shared_ptr<rogue::interfaces::stream::Frame> frame);
85
92 std::shared_ptr<rogue::interfaces::stream::Frame> acceptReq(uint32_t size, bool zeroCopyEn);
93};
94
95// Convenience
96typedef std::shared_ptr<rogue::utilities::StreamUnZip> StreamUnZipPtr;
97} // namespace utilities
98} // namespace rogue
99#endif
Stream master endpoint.
Definition Master.h:65
Stream slave endpoint and default frame pool.
Definition Slave.h:72
Stream module that decompresses bzip2-compressed frame payloads.
Definition StreamUnZip.h:51
~StreamUnZip()
Destroys stream decompressor.
std::shared_ptr< rogue::interfaces::stream::Frame > acceptReq(uint32_t size, bool zeroCopyEn)
Forwards frame-allocation requests upstream.
static std::shared_ptr< rogue::utilities::StreamUnZip > create()
Creates a stream decompressor instance.
void acceptFrame(std::shared_ptr< rogue::interfaces::stream::Frame > frame)
Accepts a compressed frame, decompresses payload, and forwards it.
static void setup_python()
Registers Python bindings for this class.
StreamUnZip()
Constructs a stream decompressor.
std::shared_ptr< rogue::utilities::StreamUnZip > StreamUnZipPtr
Definition StreamUnZip.h:96