Home
last modified time | relevance | path

Searched refs:pmt (Results 1 – 25 of 2221) sorted by relevance

12345678910>>...89

/dports/comms/gnuradio/gnuradio-3.8.4.0/gnuradio-runtime/lib/pmt/
H A Dqa_pmt_prims.cc174 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 Dqa_pmt_unv.cc37 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 Dpmt.rst1 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 Dindex.rst8 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 Dpmt.c20 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 Dqa_pmt.py26 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 Dpmt_to_python.py76 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 Dusrp_block_impl.cc42 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 Dbasic_block.cc95 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 Dblock.cc611 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 Dqa_block_tags.cc49 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 Dfile_meta_sink_impl.cc112 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 Dmessage_debug_impl.cc40 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 Dparse_file_metadata.py29 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 Dqa_pdu.py27 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 Dtest___monitor.py73 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 Dpidint.c466 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 Dpmt.c76 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 Dtables.c177 __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 Dbasic_block.h71 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 Ddxfilter.cpp186 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 Drpcpmtconverters_thrift.cc30 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 Dtag_source_demo.h58 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 Dqa_header_format.cc71 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 Dcrc32_async_bb_impl.cc44 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 …]

12345678910>>...89