- added block "message debug "

git-svn-id: http://moon:8086/svn/software/trunk/projects/GnuRadio@482 b431acfa-c32f-4a4a-93f1-934dc6c82436
This commit is contained in:
2019-05-27 19:27:01 +00:00
parent 1435ef5e0b
commit 7508e1b665
4 changed files with 228 additions and 0 deletions
+21
View File
@@ -0,0 +1,21 @@
<?xml version="1.0"?>
<block>
<name>Message Debug</name>
<key>jay_message_debug</key>
<category>[jay]</category>
<import>import jay</import>
<make>jay.message_debug()</make>
<sink>
<name>control</name>
<type>message</type>
<optional>1</optional>
</sink>
<source>
<name>status</name>
<type>message</type>
<optional>1</optional>
</source>
</block>
+56
View File
@@ -0,0 +1,56 @@
/* -*- c++ -*- */
/*
* Copyright 2019 Jay Arrowfield.
*
* This 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.
*
* This software 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 this software; see the file COPYING. If not, write to
* the Free Software Foundation, Inc., 51 Franklin Street,
* Boston, MA 02110-1301, USA.
*/
#ifndef INCLUDED_JAY_MESSAGE_DEBUG_H
#define INCLUDED_JAY_MESSAGE_DEBUG_H
#include <jay/api.h>
#include <gnuradio/block.h>
namespace gr {
namespace jay {
/*!
* \brief <+description of block+>
* \ingroup jay
*
*/
class JAY_API message_debug : virtual public gr::block
{
public:
typedef boost::shared_ptr<message_debug> sptr;
/*!
* \brief Return a shared_ptr to a new instance of jay::message_debug.
*
* To avoid accidental use of raw pointers, jay::message_debug's
* constructor is in a private implementation
* class. jay::message_debug::make is the public interface for
* creating new instances.
*/
static sptr make();
};
} // namespace jay
} // namespace gr
#endif /* INCLUDED_JAY_MESSAGE_DEBUG_H */
+86
View File
@@ -0,0 +1,86 @@
/* -*- c++ -*- */
/*
* Copyright 2019 Jay Arrowfield.
*
* This 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.
*
* This software 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 this software; 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 <gnuradio/io_signature.h>
#include "message_debug_impl.h"
namespace gr {
namespace jay {
message_debug::sptr
message_debug::make()
{
return gnuradio::get_initial_sptr
(new message_debug_impl());
}
/*
* The private constructor
*/
message_debug_impl::message_debug_impl()
: gr::block("message_debug",
gr::io_signature::make(0, 0, sizeof(int)),
gr::io_signature::make(0, 0, sizeof(int)))
{
m_msg_port_in = pmt::mp("control");
m_msg_port_out = pmt::mp("status");
message_port_register_in(m_msg_port_in);
message_port_register_out(m_msg_port_out);
set_msg_handler(m_msg_port_in, boost::bind(&message_debug_impl::set_msg, this, _1));
}
/*
* Our virtual destructor.
*/
message_debug_impl::~message_debug_impl()
{
}
void
message_debug_impl::forecast (int noutput_items, gr_vector_int &ninput_items_required)
{
ninput_items_required[0] = noutput_items;
}
int
message_debug_impl::general_work (int noutput_items,
gr_vector_int &ninput_items,
gr_vector_const_void_star &input_items,
gr_vector_void_star &output_items)
{
const int *in = (const int *) input_items[0];
int *out = (int *) output_items[0];
// Do <+signal processing+>
// Tell runtime system how many input items we consumed on
// each input stream.
consume_each (noutput_items);
// Tell runtime system how many output items we produced.
return noutput_items;
}
} /* namespace jay */
} /* namespace gr */
+65
View File
@@ -0,0 +1,65 @@
/* -*- c++ -*- */
/*
* Copyright 2019 Jay Arrowfield.
*
* This 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.
*
* This software 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 this software; see the file COPYING. If not, write to
* the Free Software Foundation, Inc., 51 Franklin Street,
* Boston, MA 02110-1301, USA.
*/
#ifndef INCLUDED_JAY_MESSAGE_DEBUG_IMPL_H
#define INCLUDED_JAY_MESSAGE_DEBUG_IMPL_H
#include <jay/message_debug.h>
namespace gr {
namespace jay {
class message_debug_impl : public message_debug
{
private:
// Nothing to declare in this block.
pmt::pmt_t m_msg_port_in;
pmt::pmt_t m_msg_port_out;
void set_msg(pmt::pmt_t msg)
{
if (pmt::is_dict(msg))
{
fprintf(stderr, "Is dictionary\n!");
}
else
{
fprintf(stderr, "Sym: %s\n", pmt::symbol_to_string(msg).c_str());
}
}
public:
message_debug_impl();
~message_debug_impl();
// Where all the action really happens
void forecast (int noutput_items, gr_vector_int &ninput_items_required);
int general_work(int noutput_items,
gr_vector_int &ninput_items,
gr_vector_const_void_star &input_items,
gr_vector_void_star &output_items);
};
} // namespace jay
} // namespace gr
#endif /* INCLUDED_JAY_MESSAGE_DEBUG_IMPL_H */