diff options
| author | Tim O'Shea <tim.oshea753@gmail.com> | 2014-02-15 22:21:44 -0500 |
|---|---|---|
| committer | Tom Rondeau <tom@trondeau.com> | 2014-02-16 14:35:12 -0500 |
| commit | 246ec97757c69d5296ebf56a273bf8e0e782a0b4 (patch) | |
| tree | 878f08052223c54338a00f4526ca4bab3795a194 /gr-blocks/lib/message_strobe_random_impl.h | |
| parent | abdc4fcb6cade9442aceb36e5ec7e0c93210b9f1 (diff) | |
blocks: random_pdu (speedup, also allow a byte mask), message_strobe_random (new block, send messages with a known timing distribution)
Diffstat (limited to 'gr-blocks/lib/message_strobe_random_impl.h')
| -rw-r--r-- | gr-blocks/lib/message_strobe_random_impl.h | 73 |
1 files changed, 73 insertions, 0 deletions
diff --git a/gr-blocks/lib/message_strobe_random_impl.h b/gr-blocks/lib/message_strobe_random_impl.h new file mode 100644 index 0000000000..a91c6604a4 --- /dev/null +++ b/gr-blocks/lib/message_strobe_random_impl.h @@ -0,0 +1,73 @@ +/* -*- c++ -*- */ +/* + * Copyright 2012-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. + */ + +#ifndef INCLUDED_GR_MESSAGE_STROBE_IMPL_H +#define INCLUDED_GR_MESSAGE_STROBE_IMPL_H + +#include <gnuradio/blocks/message_strobe_random.h> +#include <boost/random/variate_generator.hpp> +#include <boost/random/mersenne_twister.hpp> +#include <boost/random/poisson_distribution.hpp> +#include <boost/random/normal_distribution.hpp> +#include <boost/random/uniform_real.hpp> + +namespace gr { + namespace blocks { + + class BLOCKS_API message_strobe_random_impl : public message_strobe_random + { + private: + boost::shared_ptr<boost::thread> d_thread; + bool d_finished; + float d_mean_ms; + float d_std_ms; + message_strobe_random_distribution_t d_dist; + pmt::pmt_t d_msg; + void run(); + float next_delay(); + + boost::random::mt19937 d_rng; + boost::shared_ptr< boost::variate_generator <boost::mt19937, boost::poisson_distribution<> > > d_variate_poisson; + boost::shared_ptr< boost::variate_generator <boost::mt19937, boost::normal_distribution<> > > d_variate_normal; + boost::shared_ptr< boost::variate_generator <boost::mt19937, boost::uniform_real<> > > d_variate_uniform; + + void update_dist(); + + public: + message_strobe_random_impl(pmt::pmt_t msg, message_strobe_random_distribution_t dist, float mean_ms, float std_ms); + ~message_strobe_random_impl(); + + void set_msg(pmt::pmt_t msg) { d_msg = msg; } + pmt::pmt_t msg() const { return d_msg; } + void set_mean(float mean_ms) { d_mean_ms = mean_ms; update_dist(); } + float mean() const { return d_mean_ms; } + void set_std(float std_ms) { d_std_ms = std_ms; update_dist(); } + float std() const { return d_std_ms; } + void set_dist(message_strobe_random_distribution_t dist){ d_dist = dist; } + message_strobe_random_distribution_t dist() const { return d_dist; } + + }; + + } /* namespace blocks */ +} /* namespace gr */ + +#endif /* INCLUDED_GR_MESSAGE_STROBE_IMPL_H */ |