summaryrefslogtreecommitdiff
path: root/gr-uhd/lib/amsg_source_impl.cc
diff options
context:
space:
mode:
authorBen Reynwar <ben@reynwar.net>2013-05-19 02:55:33 -0700
committerBen Reynwar <ben@reynwar.net>2013-05-19 02:55:33 -0700
commitbb01988e75d50d82cbb44c1a49c86c1d08f05665 (patch)
tree0528dac14476d37f2cde7374a8fcb3428f879c69 /gr-uhd/lib/amsg_source_impl.cc
parente4f0319eced22c112f7e6a4cc45bc2036d285332 (diff)
parent0fa219774dcf9141ae91204f948c029b05673f3f (diff)
Merged in next_docs branch.
Diffstat (limited to 'gr-uhd/lib/amsg_source_impl.cc')
-rw-r--r--gr-uhd/lib/amsg_source_impl.cc12
1 files changed, 6 insertions, 6 deletions
diff --git a/gr-uhd/lib/amsg_source_impl.cc b/gr-uhd/lib/amsg_source_impl.cc
index cf344db202..deaff232d1 100644
--- a/gr-uhd/lib/amsg_source_impl.cc
+++ b/gr-uhd/lib/amsg_source_impl.cc
@@ -29,7 +29,7 @@ namespace gr {
amsg_source::sptr
amsg_source::make(const ::uhd::device_addr_t &device_addr,
- gr_msg_queue_sptr msgq)
+ msg_queue::sptr msgq)
{
check_abi();
return amsg_source::sptr
@@ -37,13 +37,13 @@ namespace gr {
}
::uhd::async_metadata_t
- amsg_source::msg_to_async_metadata_t(const gr_message_sptr msg)
+ amsg_source::msg_to_async_metadata_t(const message::sptr msg)
{
return *(::uhd::async_metadata_t *)msg->msg();
}
amsg_source_impl::amsg_source_impl(const ::uhd::device_addr_t &device_addr,
- gr_msg_queue_sptr msgq)
+ msg_queue::sptr msgq)
: _msgq(msgq), _running(true)
{
_dev = ::uhd::usrp::multi_usrp::make(device_addr);
@@ -60,11 +60,11 @@ namespace gr {
void
amsg_source_impl::recv_loop()
{
- gr_message_sptr msg;
+ message::sptr msg;
::uhd::async_metadata_t *md;
while(_running) {
- msg = gr_make_message(0, 0.0, 0.0, sizeof(::uhd::async_metadata_t));
+ msg = message::make(0, 0.0, 0.0, sizeof(::uhd::async_metadata_t));
md = (::uhd::async_metadata_t*) msg->msg();
while(!_dev->get_device()->recv_async_msg(*md, 0.1)) {
@@ -77,7 +77,7 @@ namespace gr {
}
void
- amsg_source_impl::post(gr_message_sptr msg)
+ amsg_source_impl::post(message::sptr msg)
{
_msgq->insert_tail(msg);
}