diff options
Diffstat (limited to 'gr-blocks/lib/tcp_connection.cc')
| -rw-r--r-- | gr-blocks/lib/tcp_connection.cc | 12 |
1 files changed, 5 insertions, 7 deletions
diff --git a/gr-blocks/lib/tcp_connection.cc b/gr-blocks/lib/tcp_connection.cc index 4ead6442d8..33bb6f10f1 100644 --- a/gr-blocks/lib/tcp_connection.cc +++ b/gr-blocks/lib/tcp_connection.cc @@ -26,9 +26,7 @@ #include "tcp_connection.h" #include <gr_basic_block.h> -#include <gr_pdu.h> -//#include <boost/asio.hpp> -//#include <boost/bind.hpp> +#include <blocks/pdu.h> namespace gr { namespace blocks { @@ -46,10 +44,10 @@ namespace gr { void tcp_connection::send(pmt::pmt_t vector) { - size_t len = pmt::pmt_length(vector); + size_t len = pmt::length(vector); size_t offset(0); boost::array<char, 10000> txbuf; - memcpy(&txbuf[0], pmt::pmt_uniform_vector_elements(vector, offset), len); + memcpy(&txbuf[0], pmt::uniform_vector_elements(vector, offset), len); boost::asio::async_write(d_socket, boost::asio::buffer(txbuf, len), boost::bind(&tcp_connection::handle_write, this, boost::asio::placeholders::error, @@ -70,8 +68,8 @@ namespace gr { tcp_connection::handle_read(const boost::system::error_code& error, size_t bytes_transferred) { if (!error) { - pmt::pmt_t vector = pmt::pmt_init_u8vector(bytes_transferred, (const uint8_t*)&d_buf[0]); - pmt::pmt_t pdu = pmt::pmt_cons( pmt::PMT_NIL, vector); + pmt::pmt_t vector = pmt::init_u8vector(bytes_transferred, (const uint8_t*)&d_buf[0]); + pmt::pmt_t pdu = pmt::cons( pmt::PMT_NIL, vector); d_block->message_port_pub(PDU_PORT_ID, pdu); |