test_usrp_rx::test_usrp_rx(mb_runtime *runtime, const std::string &instance_name, pmt_t user_arg)

  : mb_mblock(runtime, instance_name, user_arg),

    d_samples_recvd(0),

{ 

  d_rx = define_port("rx0", "usrp-rx", false, mb_port::INTERNAL);

  d_cs = define_port("cs", "usrp-server-cs", false, mb_port::INTERNAL);

  // Pass a dictionary to usrp_server which specifies which interface to use, the stub or USRP

  pmt_t usrp_dict = pmt_make_dict();

  // Specify the RBF to use

  pmt_dict_set(usrp_dict,

               pmt_intern("rbf"),

  pmt_dict_set(usrp_dict,

               pmt_intern("decim-rx"),

  define_component("server", "usrp_server", usrp_dict);

void

test_usrp_rx::close_usrp()

{

  d_cs->send(s_cmd_close, pmt_list1(PMT_NIL));

  d_state = CLOSING_USRP;

  pmt_t status = pmt_nth(1, data);

  pmt_t v_samples = pmt_nth(2, data);

  pmt_t timestamp = pmt_nth(3, data);

  d_samples_recvd += pmt_length(v_samples) / 4;

test_usrp_rx::enter_closing_channel()

{

  d_state = CLOSING_CHANNEL;

  d_rx->send(s_cmd_deallocate_channel, pmt_list2(PMT_NIL, d_rx_chan));

  if(verbose)

int

main (int argc, char **argv)

{

  mb_runtime_sptr rt = mb_make_runtime();

  pmt_t result = PMT_NIL;

  rt->run("top", "test_usrp_rx", PMT_F, &result);

}