/dports/comms/gnuradio/gnuradio-3.8.4.0/gnuradio-runtime/lib/pmt/ |
H A D | qa_pmt_prims.cc | 174 pmt::pmt_t c1 = pmt::cons(s1, pmt::PMT_NIL); in BOOST_AUTO_TEST_CASE() 181 pmt::pmt_t c3 = pmt::cons(s3, pmt::PMT_NIL); in BOOST_AUTO_TEST_CASE() 308 pmt::pmt_t list0 = pmt::cons(s0, pmt::cons(s1, pmt::cons(s2, pmt::PMT_NIL))); in BOOST_AUTO_TEST_CASE() 309 pmt::pmt_t list1 = pmt::cons(s0, pmt::cons(s1, pmt::cons(s2, pmt::PMT_NIL))); in BOOST_AUTO_TEST_CASE() 357 pmt::pmt_t alist = pmt::cons(p0, pmt::cons(p1, pmt::cons(p2, pmt::PMT_NIL))); in BOOST_AUTO_TEST_CASE() 361 pmt::pmt_t keys = pmt::cons(k0, pmt::cons(k1, pmt::cons(k2, pmt::PMT_NIL))); in BOOST_AUTO_TEST_CASE() 362 pmt::pmt_t vals = pmt::cons(v0, pmt::cons(v1, pmt::cons(v2, pmt::PMT_NIL))); in BOOST_AUTO_TEST_CASE() 380 pmt::pmt_t not_found = pmt::cons(pmt::PMT_NIL, pmt::PMT_NIL); in BOOST_AUTO_TEST_CASE() 410 pmt::pmt_t dict = pmt::dict_add(pmt::make_dict(), pmt::mp("k0"), pmt::mp("v0")); in BOOST_AUTO_TEST_CASE() 544 pmt::serialize(pmt::cons(pmt::PMT_NIL, pmt::PMT_NIL), sb); in BOOST_AUTO_TEST_CASE() [all …]
|
H A D | qa_pmt_unv.cc | 37 pmt::pmt_t v1 = pmt::make_u8vector(N, 0); in BOOST_AUTO_TEST_CASE() 71 pmt::pmt_t v1 = pmt::make_s8vector(N, 0); in BOOST_AUTO_TEST_CASE() 105 pmt::pmt_t v1 = pmt::make_u16vector(N, 0); in BOOST_AUTO_TEST_CASE() 139 pmt::pmt_t v1 = pmt::make_s16vector(N, 0); in BOOST_AUTO_TEST_CASE() 173 pmt::pmt_t v1 = pmt::make_u32vector(N, 0); in BOOST_AUTO_TEST_CASE() 207 pmt::pmt_t v1 = pmt::make_s32vector(N, 0); in BOOST_AUTO_TEST_CASE() 241 pmt::pmt_t v1 = pmt::make_u64vector(N, 0); in BOOST_AUTO_TEST_CASE() 275 pmt::pmt_t v1 = pmt::make_s64vector(N, 0); in BOOST_AUTO_TEST_CASE() 309 pmt::pmt_t v1 = pmt::make_f32vector(N, 0); in BOOST_AUTO_TEST_CASE() 343 pmt::pmt_t v1 = pmt::make_f64vector(N, 0); in BOOST_AUTO_TEST_CASE() [all …]
|
/dports/comms/gnuradio/gnuradio-3.8.4.0/docs/sphinx/source/ |
H A D | pmt.rst | 1 gnuradio.pmt 4 .. autofunction:: pmt.acons 5 .. autofunction:: pmt.any_ref 6 .. autofunction:: pmt.any_set 7 .. autofunction:: pmt.assoc 8 .. autofunction:: pmt.assq 9 .. autofunction:: pmt.assv 18 .. autofunction:: pmt.caar 22 .. autofunction:: pmt.car 25 .. autofunction:: pmt.cdr [all …]
|
H A D | index.rst | 8 pmt <pmt> 111 pmt.assq 112 pmt.assv 121 pmt.caar 124 pmt.cadr 125 pmt.car 128 pmt.cdr 141 pmt.eq 143 pmt.eqv 231 pmt.map [all …]
|
/dports/net/mptsd/mptsd-1.1/libtsfuncs/ |
H A D | pmt.c | 20 pmt->streams = calloc(pmt->streams_max, sizeof(void *)); in ts_pmt_alloc() 21 return pmt; in ts_pmt_alloc() 35 if (!pmt) in ts_pmt_clear() 56 if (pmt) { in ts_pmt_free() 105 return pmt; in ts_pmt_push_packet() 108 ts_pmt_clear(pmt); in ts_pmt_push_packet() 109 return pmt; in ts_pmt_push_packet() 128 pmt->program_info = malloc(pmt->program_info_size); in ts_pmt_parse() 130 memcpy(pmt->program_info, stream_data - pmt->program_info_size, pmt->program_info_size); in ts_pmt_parse() 135 if (pmt->streams_num == pmt->streams_max) { in ts_pmt_parse() [all …]
|
/dports/comms/gnuradio/gnuradio-3.8.4.0/gnuradio-runtime/python/pmt/ |
H A D | qa_pmt.py | 26 import pmt 34 a = pmt.intern("a") 36 d1 = pmt.make_dict() 50 s = pmt.serialize_str(v) 57 s = pmt.serialize_str(v) 63 s = pmt.serialize_str(v) 69 s = pmt.serialize_str(v) 75 s = pmt.serialize_str(v) 81 s = pmt.serialize_str(v) 87 s = pmt.serialize_str(v) [all …]
|
H A D | pmt_to_python.py | 76 numpy.dtype(numpy.int8): (pmt.init_s8vector, int, pmt.s8vector_elements, pmt.is_s8vector), 77 numpy.dtype(numpy.int16): (pmt.init_s16vector, int, pmt.s16vector_elements, pmt.is_s16vector), 78 numpy.dtype(numpy.int32): (pmt.init_s32vector, int, pmt.s32vector_elements, pmt.is_s32vector), 80 numpy.dtype(numpy.uint8): (pmt.init_u8vector, int, pmt.u8vector_elements, pmt.is_u8vector), 84 numpy.dtype(numpy.byte): (pmt.init_u8vector, int, pmt.u8vector_elements, pmt.is_u8vector), 108 (bool, pmt.is_bool, pmt.to_bool, pmt.from_bool), 109 (str, pmt.is_symbol, pmt.symbol_to_string, pmt.string_to_symbol), 111 (int, pmt.is_integer, pmt.to_long, pmt.from_long), 112 (int, pmt.is_uint64, lambda x: int(pmt.to_uint64(x)), pmt.from_uint64), 113 (float, pmt.is_real, pmt.to_double, pmt.from_double), [all …]
|
/dports/comms/gnuradio/gnuradio-3.8.4.0/gr-uhd/lib/ |
H A D | usrp_block_impl.cc | 42 static const pmt::pmt_t val = pmt::mp("chan"); in cmd_chan_key() 47 static const pmt::pmt_t val = pmt::mp("gain"); in cmd_gain_key() 52 static const pmt::pmt_t val = pmt::mp("freq"); in cmd_freq_key() 62 static const pmt::pmt_t val = pmt::mp("tune"); in cmd_tune_key() 77 static const pmt::pmt_t val = pmt::mp("rate"); in cmd_rate_key() 107 static const pmt::pmt_t val = pmt::mp("tag"); in cmd_tag_key() 119 static const pmt::pmt_t val = pmt::mp("RX"); in ant_direction_rx() 124 static const pmt::pmt_t val = pmt::mp("TX"); in ant_direction_tx() 522 msg = pmt::dict_add(pmt::make_dict(), pmt::car(msg), pmt::cdr(msg)); in msg_handler_command() 721 pmt::symbol_to_string(pmt::dict_ref(gpio_attr, pmt::mp("bank"), pmt::mp(""))); in _cmd_handler_gpio() [all …]
|
/dports/comms/gnuradio/gnuradio-3.8.4.0/gnuradio-runtime/lib/ |
H A D | basic_block.cc | 95 pmt::pmt_t port_names = pmt::make_vector(msg_queue.size(), pmt::PMT_NIL); in message_ports_in() 119 pmt::pmt_t port_names = pmt::make_vector(len, pmt::PMT_NIL); in message_ports_out() 120 pmt::pmt_t keys = pmt::dict_keys(d_message_subscribers); in message_ports_out() 122 pmt::vector_set(port_names, i, pmt::nth(i, keys)); in message_ports_out() 134 pmt::pmt_t currlist = pmt::dict_ref(d_message_subscribers, port_id, pmt::PMT_NIL); in message_port_pub() 137 pmt::pmt_t target = pmt::car(currlist); in message_port_pub() 139 pmt::pmt_t block = pmt::car(target); in message_port_pub() 140 pmt::pmt_t port = pmt::cdr(target); in message_port_pub() 158 pmt::pmt_t currlist = pmt::dict_ref(d_message_subscribers, port_id, pmt::PMT_NIL); in message_port_sub() 176 pmt::pmt_t currlist = pmt::dict_ref(d_message_subscribers, port_id, pmt::PMT_NIL); in message_port_unsub() [all …]
|
H A D | block.cc | 611 pmt::pmt_t op = pmt::car(msg); in system_handler() 613 d_finished = pmt::to_long(pmt::cdr(msg)); in system_handler() 633 pmt::pmt_t port_names = pmt::make_vector(len, pmt::PMT_NIL); in notify_msg_neighbors() 634 pmt::pmt_t keys = pmt::dict_keys(d_message_subscribers); in notify_msg_neighbors() 637 pmt::pmt_t oport = pmt::nth(i, keys); in notify_msg_neighbors() 640 pmt::pmt_t currlist = pmt::dict_ref(d_message_subscribers, oport, pmt::PMT_NIL); in notify_msg_neighbors() 644 pmt::pmt_t target = pmt::car(currlist); in notify_msg_neighbors() 646 pmt::pmt_t block = pmt::car(target); in notify_msg_neighbors() 800 pmt::mp(0), in setup_pc_rpc() 801 pmt::mp(1e9), in setup_pc_rpc() [all …]
|
/dports/comms/gnuradio/gnuradio-3.8.4.0/gr-blocks/lib/ |
H A D | qa_block_tags.cc | 49 gr::tag_t make_tag(uint64_t offset, pmt::pmt_t key, pmt::pmt_t value, pmt::pmt_t srcid) in make_tag() 133 expected_tags3[0] = make_tag(0, pmt::mp(str1.str()), pmt::mp("seq"), pmt::mp(0)); in BOOST_AUTO_TEST_CASE() 134 expected_tags3[1] = make_tag(0, pmt::mp(str0.str()), pmt::mp("seq"), pmt::mp(0)); in BOOST_AUTO_TEST_CASE() 143 expected_tags4[0] = make_tag(0, pmt::mp(str2.str()), pmt::mp("seq"), pmt::mp(0)); in BOOST_AUTO_TEST_CASE() 144 expected_tags4[1] = make_tag(0, pmt::mp(str0.str()), pmt::mp("seq"), pmt::mp(1)); in BOOST_AUTO_TEST_CASE() 229 expected_tags2[0] = make_tag(0, pmt::mp(str1.str()), pmt::mp("seq"), pmt::mp(0)); in BOOST_AUTO_TEST_CASE() 230 expected_tags2[1] = make_tag(0, pmt::mp(str0.str()), pmt::mp("seq"), pmt::mp(0)); in BOOST_AUTO_TEST_CASE() 231 expected_tags2[2] = make_tag(0, pmt::mp(str0.str()), pmt::mp("seq"), pmt::mp(1)); in BOOST_AUTO_TEST_CASE() 243 expected_tags4[0] = make_tag(0, pmt::mp(str1.str()), pmt::mp("seq"), pmt::mp(2)); in BOOST_AUTO_TEST_CASE() 244 expected_tags4[1] = make_tag(0, pmt::mp(str0.str()), pmt::mp("seq"), pmt::mp(0)); in BOOST_AUTO_TEST_CASE() [all …]
|
H A D | file_meta_sink_impl.cc | 112 pmt::pmt_t timestamp = pmt::make_tuple(pmt::from_uint64(0), pmt::from_double(0)); in file_meta_sink_impl() 120 d_extra = pmt::dict_add(d_extra, pmt::nth(i, keys), pmt::nth(i, vals)); in file_meta_sink_impl() 126 d_header = pmt::dict_add(d_header, pmt::mp("version"), pmt::mp(METADATA_VERSION)); in file_meta_sink_impl() 127 d_header = pmt::dict_add(d_header, pmt::mp("rx_rate"), pmt::mp(samp_rate)); in file_meta_sink_impl() 129 d_header = pmt::dict_add(d_header, pmt::mp("size"), pmt::from_long(d_itemsize)); in file_meta_sink_impl() 130 d_header = pmt::dict_add(d_header, pmt::mp("type"), pmt::from_long(type)); in file_meta_sink_impl() 132 pmt::dict_add(d_header, pmt::mp("cplx"), complex ? pmt::PMT_T : pmt::PMT_F); in file_meta_sink_impl() 311 pmt::pmt_t s = pmt::from_uint64(seg_size); in update_last_header_inline() 343 pmt::pmt_t s = pmt::from_uint64(0); in write_and_update() 361 pmt::pmt_t r = pmt::dict_ref(d_header, rx_time, pmt::PMT_NIL); in update_rx_time() [all …]
|
H A D | message_debug_impl.cc | 40 void message_debug_impl::print(pmt::pmt_t msg) in print() 43 pmt::print(msg); in print() 47 void message_debug_impl::store(pmt::pmt_t msg) in store() 55 if (pmt::is_null(pdu) || !pmt::is_pair(pdu)) { in print_pdu() 60 pmt::pmt_t meta = pmt::car(pdu); in print_pdu() 61 pmt::pmt_t vector = pmt::cdr(pdu); in print_pdu() 63 pmt::print(meta); in print_pdu() 64 size_t len = pmt::blob_length(vector); in print_pdu() 102 set_msg_handler(pmt::mp("print"), [this](pmt::pmt_t msg) { this->print(msg); }); in message_debug_impl() 105 set_msg_handler(pmt::mp("store"), [this](pmt::pmt_t msg) { this->store(msg); }); in message_debug_impl() [all …]
|
/dports/comms/gnuradio/gnuradio-3.8.4.0/gr-blocks/python/blocks/ |
H A D | parse_file_metadata.py | 29 import pmt 68 if(pmt.dict_has_key(p, pmt.string_to_symbol("version"))): 78 if(pmt.dict_has_key(p, pmt.string_to_symbol("rx_rate"))): 89 if(pmt.dict_has_key(p, pmt.string_to_symbol("rx_time"))): 104 if(pmt.dict_has_key(p, pmt.string_to_symbol("size"))): 105 r = pmt.dict_ref(p, pmt.string_to_symbol("size"), dump) 115 if(pmt.dict_has_key(p, pmt.string_to_symbol("type"))): 127 if(pmt.dict_has_key(p, pmt.string_to_symbol("cplx"))): 138 if(pmt.dict_has_key(p, pmt.string_to_symbol("strt"))): 153 if(pmt.dict_has_key(p, pmt.string_to_symbol("bytes"))): [all …]
|
H A D | qa_pdu.py | 27 import pmt 61 port = pmt.intern("pdus") 62 msg = pmt.cons( pmt.PMT_NIL, pmt.make_u8vector(16, 0xFF)) 67 pmt.cons(pmt.intern("done"), pmt.from_long(1))) 78 msg_vec = pmt.cdr(result_msg) 97 port = pmt.intern("pdus") 99 msg = pmt.cons( pmt.PMT_NIL, pmt.init_f32vector(10, src_data)) 102 pmt.cons(pmt.intern("done"), pmt.from_long(1))) 116 tag1.value = pmt.from_long(23) 130 metadata = pmt.to_python(pmt.car(result_msg)) [all …]
|
/dports/devel/py-gevent/gevent-21.8.0/src/gevent/tests/ |
H A D | test___monitor.py | 73 self.pmt.kill() 88 proc = self.pmt._get_process() 98 self.assertIsNone(self.pmt.hub) 136 self.pmt.inactive_sleep_time, 144 self.pmt.monitoring_functions() 161 self.pmt() 170 self.pmt() 179 self.pmt() 190 self.pmt() 195 self.pmt.pid = -1 [all …]
|
/dports/multimedia/tstools/tstools-1.11/ |
H A D | pidint.c | 466 if (pmt == NULL) in add_stream_to_pmt() 487 if (pmt->num_streams == pmt->streams_size) in add_stream_to_pmt() 498 pmt->streams[pmt->num_streams].stream_type = stream_type; in add_stream_to_pmt() 499 pmt->streams[pmt->num_streams].elementary_PID = elementary_PID; in add_stream_to_pmt() 500 pmt->streams[pmt->num_streams].ES_info_length = ES_info_length; in add_stream_to_pmt() 504 if (pmt->streams[pmt->num_streams].ES_info == NULL) in add_stream_to_pmt() 512 pmt->streams[pmt->num_streams].ES_info = NULL; in add_stream_to_pmt() 557 pmt->streams[ii] = pmt->streams[ii+1]; in remove_stream_from_pmt() 587 free(*pmt); in free_pmt() 588 *pmt = NULL; in free_pmt() [all …]
|
/dports/multimedia/minisatip/minisatip-1.1.52/src/ |
H A D | pmt.c | 76 if (p && p->pmt >= 0 && p->pmt < npmts && pmts[p->pmt] && in get_pmt_for_existing_pid() 78 pmt = pmts[p->pmt]; in get_pmt_for_existing_pid() 893 cw_decrypt_stream(pmt->cw, pmt->batch, pmt->blen); in decrypt_batch() 896 pmt->id, pmt->blen, pmt->cw->id, old_cw ? old_cw->id : -1, pmt->parity, in decrypt_batch() 1275 pmt = cpmt->pmt; in clean_psi() 1690 p->pmt = -pmt->id; in process_pmt() 1703 memset(pmt->pmt, 0, sizeof(pmt->pmt)); in process_pmt() 1704 memcpy(pmt->pmt, b, len); in process_pmt() 1954 pmt->master_pmt, pmt->pid, pmt->sid, pmt->name); in start_pmt() 1969 pmt->pid, pmt->sid, pmt->master_pmt, pmt->name); in stop_pmt() [all …]
|
H A D | tables.c | 177 __FUNCTION__, pmt->ca[i].id, i, pmt->caids, caid, mask); in match_caid() 199 if (!pmt || !pmt->ca_mask) in close_pmt_for_cas() 228 !(pmt->disabled_ca_mask & mask) && !(pmt->ca_mask & mask)) { in send_pmt_to_ca() 248 disable_cw(pmt->id); in send_pmt_to_ca() 252 pmt->id, i, send, result, pmt->ca_mask, pmt->disabled_ca_mask); in send_pmt_to_ca() 259 if (!ad || (ad->ca_mask == (pmt->disabled_ca_mask | pmt->ca_mask))) { in send_pmt_to_cas() 262 pmt->id, ad ? ad->ca_mask : -2, pmt->ca_mask, in send_pmt_to_cas() 269 pmt->id, ad ? ad->ca_mask : -2, pmt->ca_mask, pmt->disabled_ca_mask); in send_pmt_to_cas() 279 SPMT *pmt; in send_pmt_to_ca_for_device() local 282 if ((pmt = get_pmt(i)) && pmt->adapter == ad->id && pmt->state) in send_pmt_to_ca_for_device() [all …]
|
/dports/comms/gnuradio/gnuradio-3.8.4.0/gnuradio-runtime/include/gnuradio/ |
H A D | basic_block.h | 71 typedef std::map<pmt::pmt_t, msg_queue_t, pmt::comparator> msg_queue_map_t; 72 typedef std::map<pmt::pmt_t, msg_queue_t, pmt::comparator>::iterator 135 virtual void dispatch_msg(pmt::pmt_t which_port, pmt::pmt_t msg) in dispatch_msg() 147 pmt::pmt_t message_subscribers(pmt::pmt_t port); 183 pmt::pmt_t alias_pmt() const { return pmt::intern(alias()); } in alias_pmt() 195 void message_port_pub(pmt::pmt_t port_id, pmt::pmt_t msg); 196 void message_port_sub(pmt::pmt_t port_id, pmt::pmt_t target); 197 void message_port_unsub(pmt::pmt_t port_id, pmt::pmt_t target); 234 void _post(pmt::pmt_t which_port, pmt::pmt_t msg); 275 void insert_tail(pmt::pmt_t which_port, pmt::pmt_t msg); [all …]
|
/dports/net/mediastreamer/mediastreamer-2.16.1/src/ |
H A D | dxfilter.cpp | 186 CheckPointer(pmt,E_POINTER); in CheckInputType() 199 if( g != *pmt->Type( ) ) in CheckInputType() 205 VIDEOINFO *pvi = (VIDEOINFO *)pmt->Format(); in CheckInputType() 213 if( MEDIASUBTYPE_RGB24 == *pmt->Subtype( ) ) in CheckInputType() 283 if( MEDIASUBTYPE_Avi == *pmt->Subtype( ) ) in CheckInputType() 301 if( MEDIASUBTYPE_AU == *pmt->Subtype( ) ) in CheckInputType() 323 if( g != *pmt->Subtype( ) ) in CheckInputType() 335 if( g != *pmt->FormatType( ) ) in CheckInputType() 473 if( !pmt ) in SetAcceptedMediaType() 481 hr = CopyMediaType( &m_mtAccept, pmt ); in SetAcceptedMediaType() [all …]
|
/dports/comms/gnuradio/gnuradio-3.8.4.0/gnuradio-runtime/lib/controlport/thrift/ |
H A D | rpcpmtconverters_thrift.cc | 30 if (pmt::is_real(knob)) { in from_pmt() 35 } else if (pmt::is_symbol(knob)) { in from_pmt() 41 } else if (pmt::is_integer(knob)) { in from_pmt() 46 } else if (pmt::is_bool(knob)) { in from_pmt() 51 } else if (pmt::is_uint64(knob)) { in from_pmt() 56 } else if (pmt::is_complex(knob)) { in from_pmt() 143 return pmt::mp(knob.value.a_int); in operator ()() 164 return pmt::PMT_T; in operator ()() 166 return pmt::PMT_F; in operator ()() 172 return pmt::from_complex(cpx); in operator ()() [all …]
|
/dports/comms/gnuradio/gnuradio-3.8.4.0/gr-uhd/examples/c++/ |
H A D | tag_source_demo.h | 58 const pmt::pmt_t key = pmt::string_to_symbol("tx_time"); in make_time_tag() 60 pmt::make_tuple(pmt::from_uint64(_time_secs), pmt::from_double(_time_fracs)); in make_time_tag() 61 const pmt::pmt_t srcid = pmt::string_to_symbol(this->name()); in make_time_tag() 67 const pmt::pmt_t key = pmt::string_to_symbol("tx_sob"); in make_sob_tag() 68 const pmt::pmt_t value = pmt::PMT_T; in make_sob_tag() 69 const pmt::pmt_t srcid = pmt::string_to_symbol(this->name()); in make_sob_tag() 75 const pmt::pmt_t key = pmt::string_to_symbol("tx_eob"); in make_eob_tag() 76 const pmt::pmt_t value = pmt::PMT_T; in make_eob_tag() 77 const pmt::pmt_t srcid = pmt::string_to_symbol(this->name()); in make_eob_tag() 89 const pmt::pmt_t value = pmt::from_long((long)burst_len); in make_length_tag() [all …]
|
/dports/comms/gnuradio/gnuradio-3.8.4.0/gr-digital/lib/ |
H A D | qa_header_format.cc | 71 pmt::pmt_t output; in BOOST_AUTO_TEST_CASE() 72 pmt::pmt_t info = pmt::make_dict(); in BOOST_AUTO_TEST_CASE() 128 std::vector<pmt::pmt_t> info; in BOOST_AUTO_TEST_CASE() 134 pmt::pmt_t dict = info[0]; in BOOST_AUTO_TEST_CASE() 136 pmt::dict_ref(dict, pmt::intern("payload symbols"), pmt::from_long(-1))); in BOOST_AUTO_TEST_CASE() 161 pmt::pmt_t output; in BOOST_AUTO_TEST_CASE() 162 pmt::pmt_t info = pmt::make_dict(); in BOOST_AUTO_TEST_CASE() 244 pmt::pmt_t dict = info[0]; in BOOST_AUTO_TEST_CASE() 246 pmt::dict_ref(dict, pmt::intern("payload symbols"), pmt::from_long(-1))); in BOOST_AUTO_TEST_CASE() 247 int bps = pmt::to_long(pmt::dict_ref(dict, pmt::intern("bps"), pmt::from_long(-1))); in BOOST_AUTO_TEST_CASE() [all …]
|
H A D | crc32_async_bb_impl.cc | 44 d_in_port = pmt::mp("in"); in crc32_async_bb_impl() 45 d_out_port = pmt::mp("out"); in crc32_async_bb_impl() 58 void crc32_async_bb_impl::calc(pmt::pmt_t msg) in calc() 61 pmt::pmt_t meta(pmt::car(msg)); in calc() 62 pmt::pmt_t bytes(pmt::cdr(msg)); in calc() 78 pmt::pmt_t output = pmt::init_u8vector( in calc() 81 pmt::pmt_t msg_pair = pmt::cons(meta, output); in calc() 89 pmt::pmt_t meta(pmt::car(msg)); in check() 90 pmt::pmt_t bytes(pmt::cdr(msg)); in check() 105 pmt::pmt_t output = pmt::init_u8vector(pkt_len - 4, bytes_in); in check() [all …]
|