diff options
Diffstat (limited to 'gr-blocks/lib/message_source_impl.cc')
| -rw-r--r-- | gr-blocks/lib/message_source_impl.cc | 30 |
1 files changed, 15 insertions, 15 deletions
diff --git a/gr-blocks/lib/message_source_impl.cc b/gr-blocks/lib/message_source_impl.cc index 818cd336f1..05ec2f248b 100644 --- a/gr-blocks/lib/message_source_impl.cc +++ b/gr-blocks/lib/message_source_impl.cc @@ -25,7 +25,7 @@ #endif #include "message_source_impl.h" -#include <gr_io_signature.h> +#include <gnuradio/io_signature.h> #include <cstdio> #include <errno.h> #include <sys/types.h> @@ -45,14 +45,14 @@ namespace gr { } message_source::sptr - message_source::make(size_t itemsize, gr_msg_queue_sptr msgq) + message_source::make(size_t itemsize, msg_queue::sptr msgq) { return gnuradio::get_initial_sptr (new message_source_impl(itemsize, msgq)); } message_source::sptr - message_source::make(size_t itemsize, gr_msg_queue_sptr msgq, + message_source::make(size_t itemsize, msg_queue::sptr msgq, const std::string& lengthtagname) { return gnuradio::get_initial_sptr @@ -60,28 +60,28 @@ namespace gr { } message_source_impl::message_source_impl(size_t itemsize, int msgq_limit) - : gr_sync_block("message_source", - gr_make_io_signature(0, 0, 0), - gr_make_io_signature(1, 1, itemsize)), - d_itemsize(itemsize), d_msgq(gr_make_msg_queue(msgq_limit)), + : sync_block("message_source", + io_signature::make(0, 0, 0), + io_signature::make(1, 1, itemsize)), + d_itemsize(itemsize), d_msgq(msg_queue::make(msgq_limit)), d_msg_offset(0), d_eof(false), d_tags(false) { } - message_source_impl::message_source_impl(size_t itemsize, gr_msg_queue_sptr msgq) - : gr_sync_block("message_source", - gr_make_io_signature(0, 0, 0), - gr_make_io_signature(1, 1, itemsize)), + message_source_impl::message_source_impl(size_t itemsize, msg_queue::sptr msgq) + : sync_block("message_source", + io_signature::make(0, 0, 0), + io_signature::make(1, 1, itemsize)), d_itemsize(itemsize), d_msgq(msgq), d_msg_offset(0), d_eof(false), d_tags(false) { } - message_source_impl::message_source_impl(size_t itemsize, gr_msg_queue_sptr msgq, + message_source_impl::message_source_impl(size_t itemsize, msg_queue::sptr msgq, const std::string& lengthtagname) - : gr_sync_block("message_source", - gr_make_io_signature(0, 0, 0), - gr_make_io_signature(1, 1, itemsize)), + : sync_block("message_source", + io_signature::make(0, 0, 0), + io_signature::make(1, 1, itemsize)), d_itemsize(itemsize), d_msgq(msgq), d_msg_offset(0), d_eof(false), d_tags(true), d_lengthtagname(lengthtagname) { |