uhd

struct usrp1_send_state {

    uhd::transport::managed_send_buffer::sptr send_buff;

    size_t bytes_written;

    size_t underrun_poll_samp_count;

};

struct usrp1_recv_state {

    uhd::transport::managed_recv_buffer::sptr recv_buff;

    size_t bytes_read;

    size_t overrun_poll_samp_count;

};

/***********************************************************************

        if (send_state.send_buff == NULL)

            return false;

        send_state.bytes_written = 0;

    }

                                                    const io_type_t io_type,

                                                    otw_type_t otw_type)

{

    size_t copy_samps = std::min(num_samps - sample_offset, samps_free); 

    const boost::uint8_t *io_mem =

                                copy_samps);

    send_state.bytes_written += copy_samps * otw_type.get_sample_size();

    send_state.underrun_poll_samp_count += copy_samps;

    return copy_samps;

    if (send_state.bytes_written % 512)

        return false;

        send_state.send_buff->commit(send_state.bytes_written);

        send_state.send_buff = uhd::transport::managed_send_buffer::sptr();

        return true;

 **********************************************************************/

bool usrp1_impl::io_impl::get_recv_buffer(zero_copy_if::sptr zc_if)

{

        recv_state.recv_buff = zc_if->get_recv_buff();

        if (recv_state.recv_buff == NULL)

            return false;

        recv_state.bytes_read = 0;

    }

    return true;

                                                    const io_type_t io_type,

                                                    otw_type_t otw_type)

{

    size_t copy_samps = std::min(num_samps - sample_offset, samps_avail); 

    const boost::uint8_t *otw_mem =

                                copy_samps);

    recv_state.bytes_read += copy_samps * otw_type.get_sample_size();

    recv_state.overrun_poll_samp_count += copy_samps;

    return copy_samps;