 |
GNU Radio Manual and C++ API Reference
3.9.1.0
The Free & Open Software Radio Ecosystem
|
|
Go to the documentation of this file.
11 #ifndef INCLUDED_MSG_QUEUE_H
12 #define INCLUDED_MSG_QUEUE_H
23 typedef std::shared_ptr<msg_queue> msg_queue_sptr;
38 std::deque<pmt::pmt_t> d_msgs;
68 bool empty_p()
const {
return d_msgs.empty(); }
71 bool full_p()
const {
return d_limit != 0 && count() >= d_limit; }
74 unsigned int count()
const {
return d_msgs.size(); }
77 unsigned int limit()
const {
return d_limit; }
unsigned int limit() const
return limit on number of message in queue. 0 -> unbounded
Definition: messages/msg_queue.h:77
boost::condition_variable condition_variable
Definition: thread.h:39
bool full_p() const
is the queue full?
Definition: messages/msg_queue.h:71
#define GR_RUNTIME_API
Definition: gnuradio-runtime/include/gnuradio/api.h:18
boost::mutex mutex
Definition: thread.h:37
msg_queue_sptr make_msg_queue(unsigned int limit=0)
std::shared_ptr< pmt_base > pmt_t
typedef for shared pointer (transparent reference counting).
Definition: pmt.h:84
unsigned int count() const
return number of messages in queue
Definition: messages/msg_queue.h:74
GNU Radio logging wrapper for log4cpp library (C++ port of log4j)
Definition: basic_block.h:29
thread-safe message queue
Definition: messages/msg_queue.h:30
bool empty_p() const
is the queue empty?
Definition: messages/msg_queue.h:68