summaryrefslogtreecommitdiffstats
path: root/src/dabInputZmq.h
diff options
context:
space:
mode:
Diffstat (limited to 'src/dabInputZmq.h')
-rw-r--r--src/dabInputZmq.h34
1 files changed, 21 insertions, 13 deletions
diff --git a/src/dabInputZmq.h b/src/dabInputZmq.h
index 7420c4b..97dd911 100644
--- a/src/dabInputZmq.h
+++ b/src/dabInputZmq.h
@@ -60,21 +60,16 @@
// Maximum frame_buffer size in number of elements
#define INPUT_ZMQ_MAX_BUFFER_SIZE (5*8) // 960ms
-
-class DabInputZmq : public DabInputBase, public RemoteControllable {
+class DabInputZmqBase : public DabInputBase, public RemoteControllable {
public:
- DabInputZmq(const std::string name)
+ DabInputZmqBase(const std::string name)
: RemoteControllable(name),
m_name(name), m_zmq_context(1),
m_zmq_sock(m_zmq_context, ZMQ_SUB),
- m_prebuffering(INPUT_ZMQ_PREBUFFERING),
- m_bitrate(0) {
- RC_ADD_PARAMETER(buffer,
- "Size of the input buffer [aac superframes]");
- }
+ m_bitrate(0) { }
virtual int open(const std::string inputUri);
- virtual int readFrame(void* buffer, int size);
+ virtual int readFrame(void* buffer, int size) = 0;
virtual int setBitrate(int bitrate);
virtual int close();
@@ -84,15 +79,28 @@ class DabInputZmq : public DabInputBase, public RemoteControllable {
/* Getting a parameter always returns a string. */
virtual string get_parameter(string parameter);
- private:
- int readFromSocket(int framesize);
-
+ protected:
std::string m_name;
zmq::context_t m_zmq_context;
zmq::socket_t m_zmq_sock; // handle for the zmq socket
+ int m_bitrate;
+};
+
+class DabInputZmqAAC : public DabInputZmqBase {
+ public:
+ DabInputZmqAAC(const std::string name)
+ : DabInputZmqBase(name),
+ m_prebuffering(INPUT_ZMQ_PREBUFFERING) {
+ RC_ADD_PARAMETER(buffer,
+ "Size of the input buffer [aac superframes]");
+ }
+
+ virtual int readFrame(void* buffer, int size);
+ private:
+ int readFromSocket(int framesize);
+
int m_prebuffering;
std::list<char*> m_frame_buffer; //stores elements of type char[<framesize>]
- int m_bitrate;
};
#endif // HAVE_INPUT_ZMQ