diff options
| author | Johnathan Corgan <johnathan@corganlabs.com> | 2013-02-28 14:31:39 -0800 |
|---|---|---|
| committer | Johnathan Corgan <johnathan@corganlabs.com> | 2013-02-28 14:31:39 -0800 |
| commit | 1d093decc5bf37b8d173ce7769a14af6765f45a6 (patch) | |
| tree | d0d45936b81a8a429746cff573aa7c9c5f9d179f /gr-blocks/lib/random_pdu_impl.cc | |
| parent | 4a99e708ad0dd54bae4a4275ae2c06e44decbebf (diff) | |
blocks: added gr::blocks::random_pdu
Diffstat (limited to 'gr-blocks/lib/random_pdu_impl.cc')
| -rw-r--r-- | gr-blocks/lib/random_pdu_impl.cc | 80 |
1 files changed, 80 insertions, 0 deletions
diff --git a/gr-blocks/lib/random_pdu_impl.cc b/gr-blocks/lib/random_pdu_impl.cc new file mode 100644 index 0000000000..0b194a0537 --- /dev/null +++ b/gr-blocks/lib/random_pdu_impl.cc @@ -0,0 +1,80 @@ +/* -*- c++ -*- */ +/* + * Copyright 2013 Free Software Foundation, Inc. + * + * This file is part of GNU Radio + * + * GNU Radio is free software; you can redistribute it and/or modify + * it under the terms of the GNU General Public License as published by + * the Free Software Foundation; either version 3, or (at your option) + * any later version. + * + * GNU Radio is distributed in the hope that it will be useful, + * but WITHOUT ANY WARRANTY; without even the implied warranty of + * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the + * GNU General Public License for more details. + * + * You should have received a copy of the GNU General Public License + * along with GNU Radio; see the file COPYING. If not, write to + * the Free Software Foundation, Inc., 51 Franklin Street, + * Boston, MA 02110-1301, USA. + */ + +#ifdef HAVE_CONFIG_H +#include "config.h" +#endif + +#include "random_pdu_impl.h" +#include <gr_io_signature.h> +#include <blocks/pdu.h> + +namespace gr { + namespace blocks { + + random_pdu::sptr + random_pdu::make(int min_items, int max_items) + { + return gnuradio::get_initial_sptr(new random_pdu_impl(min_items, max_items)); + } + + random_pdu_impl::random_pdu_impl(int min_items, int max_items) + : gr_block("random_pdu", + gr_make_io_signature (0, 0, 0), + gr_make_io_signature (0, 0, 0)), + d_urange(min_items, max_items), + d_brange(0, 255), + d_rvar(d_rng, d_urange), + d_bvar(d_rng, d_brange) + { + message_port_register_out(PDU_PORT_ID); + message_port_register_in(pmt::mp("generate")); + set_msg_handler(pmt::mp("generate"), boost::bind(&random_pdu_impl::generate_pdu, this, _1)); + } + + bool + random_pdu_impl::start() + { + output_random(); + return true; + } + + void + random_pdu_impl::output_random() + { + // pick a random vector length + int len = d_rvar(); + + // fill it with random bytes + std::vector<unsigned char> vec; + for (int i=0; i<len; i++) + vec.push_back((unsigned char) d_bvar()); + + // send the vector + pmt::pmt_t vecpmt(pmt::make_blob(&vec[0], len)); + pmt::pmt_t pdu(pmt::cons(pmt::PMT_NIL, vecpmt)); + + message_port_pub(PDU_PORT_ID, pdu); + } + + } /* namespace blocks */ +}/* namespace gr */ |