- self.snk = gr.null_sink(gr.sizeof_gr_complex)

- self.head = gr.head(gr.sizeof_gr_complex, 1000000)

- self.head = gr.head(gr.sizeof_gr_complex, 1000000)

- It merges together the documentation for the generator function (e.g. gr.head)

- with the wrapped sptr (e.g. gr.gr_head_sptr) to keep the documentation

- gnuradio.gr.null_source

- gnuradio.gr.vector_source_b

- gnuradio.gr.vector_source_c

- gnuradio.gr.vector_source_f

- gnuradio.gr.vector_source_i

- gnuradio.gr.vector_source_s

- gnuradio.gr.null_sink

- gnuradio.gr.vector_sink_b

- gnuradio.gr.vector_sink_c

- gnuradio.gr.vector_sink_f

- gnuradio.gr.vector_sink_i

- gnuradio.gr.vector_sink_s

- gnuradio.gr.copy

- gnuradio.gr.kludge_copy

- gnuradio.gr.nop

- gnuradio.gr.channel_model

-

-Slicing and Dicing Streams

-^^^^^^^^^^^^^^^^^^^^^^^^^^

-

-.. autosummary::

- :nosignatures:

-

- gnuradio.gr.head

- gnuradio.gr.skiphead

-.. autooldblock:: gnuradio.gr.copy

-.. autooldblock:: gnuradio.gr.kludge_copy

-.. autooldblock:: gnuradio.gr.nop

-.. autooldblock:: gnuradio.gr.channel_model

-.. autooldblock:: gnuradio.gr.null_sink

-.. autooldblock:: gnuradio.gr.vector_sink_b

-.. autooldblock:: gnuradio.gr.vector_sink_c

-.. autooldblock:: gnuradio.gr.vector_sink_f

-.. autooldblock:: gnuradio.gr.vector_sink_i

-.. autooldblock:: gnuradio.gr.vector_sink_s

-gnuradio.gr: Slicing and Dicing Streams

-=======================================

-

-.. autooldblock:: gnuradio.gr.head

-.. autooldblock:: gnuradio.gr.skiphead

-.. autooldblock:: gnuradio.gr.null_source

-.. autooldblock:: gnuradio.gr.vector_source_b

-.. autooldblock:: gnuradio.gr.vector_source_c

-.. autooldblock:: gnuradio.gr.vector_source_f

-.. autooldblock:: gnuradio.gr.vector_source_i

-.. autooldblock:: gnuradio.gr.vector_source_s

- ${CMAKE_CURRENT_BINARY_DIR}/src/lib/gengen

- ${CMAKE_CURRENT_SOURCE_DIR}/src/lib/gengen

- <key>gr_vector_source_x</key>

- <value>gr_vector_source_x_0</value>

- <key>gr_null_sink</key>

- <value>gr_null_sink_0</value>

- <sink_block_id>gr_null_sink_0</sink_block_id>

- <source_block_id>gr_vector_source_x_0</source_block_id>

- <key>gr_null_sink</key>

- <value>gr_null_sink_0</value>

- <sink_block_id>gr_null_sink_0</sink_block_id>

- self.gr_null_source_0 = gr.null_source(gr.sizeof_gr_complex*vec_len)

- self.gr_null_sink_0 = gr.null_sink(gr.sizeof_gr_complex*vec_len)

- self.gr_filt_0 = gr.fir_filter_ccc(1, 40000*[0.2+0.3j,])

- self.gr_filt_1 = gr.fir_filter_ccc(1, 40000*[0.2+0.3j,])

- self.gr_filt_0.set_processor_affinity([0,])

- self.gr_filt_1.set_processor_affinity([0,1])

- self.connect((self.gr_null_source_0, 0), (self.blocks_throttle_0, 0))

- self.connect((self.gr_filt_0, 0), (self.gr_filt_1, 0))

- self.connect((self.gr_filt_1, 0), (self.gr_null_sink_0, 0))

-# Copyright 2008 Free Software Foundation, Inc.

- terminating in a gr.null_sink.

- self.connect(upstream, gr.null_sink(gr.sizeof_float))

- src = gr.null_source(gr.sizeof_float)

- head = gr.head(gr.sizeof_float, int(options.nsamples))

-# Copyright 2006,2010 Free Software Foundation, Inc.

- vec = gr.vector_source_f(data, True)

- self.head = gr.head(isizeof, N)

- self.srcs.append(gr.null_source(isizeof))

- self.snks.append(gr.null_sink(osizeof))

-GR_INCLUDE_SUBDIRECTORY(gengen)

- ${CMAKE_CURRENT_SOURCE_DIR}/gr_rotator.h

-/* -*- c++ -*- */

-/*

- * Copyright 2003,2008 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 _GR_ROTATOR_H_

-#define _GR_ROTATOR_H_

-

-#include <gr_core_api.h>

-#include <gr_complex.h>

-

-class /*GR_CORE_API*/ gr_rotator {

- gr_complex d_phase;

- gr_complex d_phase_incr;

- unsigned int d_counter;

-

- public:

- gr_rotator () : d_phase (1), d_phase_incr (1), d_counter(0) { }

-

- void set_phase (gr_complex phase) { d_phase = phase / abs(phase); }

- void set_phase_incr (gr_complex incr) { d_phase_incr = incr / abs(incr); }

-

- gr_complex rotate (gr_complex in){

- d_counter++;

-

- gr_complex z = in * d_phase; // rotate in by phase

- d_phase *= d_phase_incr; // incr our phase (complex mult == add phases)

-

- if ((d_counter % 512) == 0)

- d_phase /= abs(d_phase); // Normalize to ensure multiplication is rotation

-

- return z;

- }

-

-};

-

-#endif /* _GR_ROTATOR_H_ */

-/* -*- c++ -*- */

-/*

- * Copyright 2002,2012 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 <gruel/attributes.h>

-#include <cppunit/TestAssert.h>

-#include <qa_rotator.h>

-#include <analog/rotator.h>

-#include <stdio.h>

-#include <cmath>

-#include <gr_expj.h>

-

-namespace gr {

- namespace analog {

-

- // error vector magnitude

- __GR_ATTR_UNUSED static float

- error_vector_mag(gr_complex a, gr_complex b)

- {

- return abs(a-b);

- }

-

- void

- qa_rotator::t1()

- {

- static const unsigned int N = 100000;

-

- rotator r;

-

- double phase_incr = 2*M_PI / 1003;

- double phase = 0;

-

- // Old code: We increment then return the rotated value, thus we

- // need to start one tick back

- // r.set_phase(gr_complex(1,0) * conj(gr_expj(phase_incr)));

-

- r.set_phase(gr_complex(1,0));

- r.set_phase_incr(gr_expj(phase_incr));

-

- for(unsigned i = 0; i < N; i++) {

- gr_complex expected = gr_expj(phase);

- gr_complex actual = r.rotate(gr_complex(1, 0));

-

-#if 0

- float evm = error_vector_mag(expected, actual);

- printf("[%6d] expected: (%8.6f, %8.6f) actual: (%8.6f, %8.6f) evm: %8.6f\n",

- i, expected.real(), expected.imag(), actual.real(), actual.imag(), evm);

-#endif

-

- CPPUNIT_ASSERT_COMPLEXES_EQUAL(expected, actual, 0.0001);

-

- phase += phase_incr;

- if(phase >= 2*M_PI)

- phase -= 2*M_PI;

- }

- }

-

- } /* namespace analog */

-} /* namespace gr */

-/* -*- c++ -*- */

-/*

- * Copyright 2008,2012 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 _QA_ANALOG_ROTATOR_H_

-#define _QA_ANALOG_ROTATOR_H_

-

-#include <cppunit/extensions/HelperMacros.h>

-#include <cppunit/TestCase.h>

-

-namespace gr {

- namespace analog {

-

- class qa_rotator : public CppUnit::TestCase

- {

- CPPUNIT_TEST_SUITE(qa_rotator);

- CPPUNIT_TEST(t1);

- CPPUNIT_TEST_SUITE_END();

-

- private:

- void t1();

- };

-

- } /* namespace analog */

-} /* namespace gr */

-

-#endif /* _QA_ANALOG_ROTATOR_H_ */

- gr_copy

- gr_endian_swap

- gr_head

- gr_kludge_copy

- gr_nop

- gr_null_sink

- gr_null_source

- gr_skiphead

- gr_vector_map

- gr_annotator_alltoall

- gr_annotator_1to1

- gr_annotator_raw

-#include <gr_nop.h>

-#include <gr_null_sink.h>

-#include <gr_null_source.h>

-#include <gr_head.h>

-#include <gr_skiphead.h>

-//#include <gr_endianness.h>

-#include <gr_endian_swap.h>

-#include <gr_kludge_copy.h>

-#include <gr_copy.h>

-#include <gr_annotator_alltoall.h>

-#include <gr_annotator_1to1.h>

-#include <gr_annotator_raw.h>

-#include <gr_vector_map.h>

-%include "gr_nop.i"

-%include "gr_null_sink.i"

-%include "gr_null_source.i"

-%include "gr_head.i"

-%include "gr_skiphead.i"

-//%include "gr_endianness.i"

-%include "gr_endian_swap.i"

-%include "gr_kludge_copy.i"

-%include "gr_copy.i"

-%include "gr_annotator_alltoall.i"

-%include "gr_annotator_1to1.i"

-%include "gr_annotator_raw.i"

-%include "gr_vector_map.i"

-

-//

-// This file is machine generated. All edits will be overwritten

-//

-%{

-#include <gr_vector_sink_b.h>

-#include <gr_vector_sink_c.h>

-#include <gr_vector_sink_f.h>

-#include <gr_vector_sink_i.h>

-#include <gr_vector_sink_s.h>

-#include <gr_vector_source_b.h>

-#include <gr_vector_source_c.h>

-#include <gr_vector_source_f.h>

-#include <gr_vector_source_i.h>

-#include <gr_vector_source_s.h>

-%}

-

-%include <gr_vector_sink_b.i>

-%include <gr_vector_sink_c.i>

-%include <gr_vector_sink_f.i>

-%include <gr_vector_sink_i.i>

-%include <gr_vector_sink_s.i>

-%include <gr_vector_source_b.i>

-%include <gr_vector_source_c.i>

-%include <gr_vector_source_f.i>

-%include <gr_vector_source_i.i>

-%include <gr_vector_source_s.i>

-/* -*- c++ -*- */

-/*

- * Copyright 2010 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 <gr_annotator_1to1.h>

-#include <gr_io_signature.h>

-#include <string.h>

-#include <iostream>

-#include <iomanip>

-

-gr_annotator_1to1_sptr

-gr_make_annotator_1to1 (int when, size_t sizeof_stream_item)

-{

- return gnuradio::get_initial_sptr (new gr_annotator_1to1

- (when, sizeof_stream_item));

-}

-

-gr_annotator_1to1::gr_annotator_1to1 (int when, size_t sizeof_stream_item)

- : gr_sync_block ("annotator_1to1",

- gr_make_io_signature (1, -1, sizeof_stream_item),

- gr_make_io_signature (1, -1, sizeof_stream_item)),

- d_itemsize(sizeof_stream_item), d_when((uint64_t)when)

-{

- set_tag_propagation_policy(TPP_ONE_TO_ONE);

-

- d_tag_counter = 0;

- set_relative_rate(1.0);

-}

-

-gr_annotator_1to1::~gr_annotator_1to1 ()

-{

-}

-

-int

-gr_annotator_1to1::work (int noutput_items,

- gr_vector_const_void_star &input_items,

- gr_vector_void_star &output_items)

-{

- const float *in = (const float*)input_items[0];

- float *out = (float*)output_items[0];

-

- std::stringstream str;

- str << name() << unique_id();

-

- uint64_t abs_N = 0;

- int ninputs = input_items.size();

- for(int i = 0; i < ninputs; i++) {

- abs_N = nitems_read(i);

-

- std::vector<gr_tag_t> all_tags;

- get_tags_in_range(all_tags, i, abs_N, abs_N + noutput_items);

-

- std::vector<gr_tag_t>::iterator itr;

- for(itr = all_tags.begin(); itr != all_tags.end(); itr++) {

- d_stored_tags.push_back(*itr);

- }

- }

-

- // Storing the current noutput_items as the value to the "noutput_items" key

- pmt::pmt_t srcid = pmt::string_to_symbol(str.str());

- pmt::pmt_t key = pmt::string_to_symbol("seq");

-

- // Work does nothing to the data stream; just copy all inputs to outputs

- // Adds a new tag when the number of items read is a multiple of d_when

- abs_N = nitems_read(0);

- int noutputs = output_items.size();

- for(int j = 0; j < noutput_items; j++) {

- // the min() is a hack to make sure this doesn't segfault if there are a

- // different number of ins and outs. This is specifically designed to test

- // the 1-to-1 propagation policy.

- for(int i = 0; i < std::min(noutputs, ninputs); i++) {

- if(abs_N % d_when == 0) {

- pmt::pmt_t value = pmt::from_uint64(d_tag_counter++);

- add_item_tag(i, abs_N, key, value, srcid);

- }

-

- in = (const float*)input_items[i];

- out = (float*)output_items[i];

- out[j] = in[j];

- }

- abs_N++;

- }

-

- return noutput_items;

-}

-/* -*- c++ -*- */

-/*

- * Copyright 2010 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_ANNOTATOR_1TO1_H

-#define INCLUDED_GR_ANNOTATOR_1TO1_H

-

-#include <gr_core_api.h>

-#include <gr_sync_block.h>

-

-class gr_annotator_1to1;

-typedef boost::shared_ptr<gr_annotator_1to1> gr_annotator_1to1_sptr;

-

-// public constructor

-GR_CORE_API gr_annotator_1to1_sptr

-gr_make_annotator_1to1 (int when, size_t sizeof_stream_item);

-

-/*!

- * \brief 1-to-1 stream annotator testing block. FOR TESTING PURPOSES ONLY.

- *

- * This block creates tags to be sent downstream every 10,000 items it sees. The

- * tags contain the name and ID of the instantiated block, use "seq" as a key,

- * and have a counter that increments by 1 for every tag produced that is used

- * as the tag's value. The tags are propagated using the 1-to-1 policy.

- *

- * It also stores a copy of all tags it sees flow past it. These tags can be

- * recalled externally with the data() member.

- *

- * This block is only meant for testing and showing how to use the tags.

- */

-class GR_CORE_API gr_annotator_1to1 : public gr_sync_block

-{

- public:

- ~gr_annotator_1to1 ();

- int work (int noutput_items,

- gr_vector_const_void_star &input_items,

- gr_vector_void_star &output_items);

-

- std::vector<gr_tag_t> data() const

- {

- return d_stored_tags;

- }

-

-protected:

- gr_annotator_1to1 (int when, size_t sizeof_stream_item);

-

- private:

- size_t d_itemsize;

- uint64_t d_when;

- uint64_t d_tag_counter;

- std::vector<gr_tag_t> d_stored_tags;

-

- friend GR_CORE_API gr_annotator_1to1_sptr

- gr_make_annotator_1to1 (int when, size_t sizeof_stream_item);

-};

-

-#endif

-/* -*- c++ -*- */

-/*

- * Copyright 2010-2011 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.

- */

-

-GR_SWIG_BLOCK_MAGIC(gr,annotator_1to1);

-

-%include <gr_annotator_1to1.h>

-/* -*- c++ -*- */

-/*

- * Copyright 2010 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 <gr_annotator_alltoall.h>

-#include <gr_io_signature.h>

-#include <string.h>

-#include <iostream>

-#include <iomanip>

-

-gr_annotator_alltoall_sptr

-gr_make_annotator_alltoall (int when, size_t sizeof_stream_item)

-{

- return gnuradio::get_initial_sptr (new gr_annotator_alltoall

- (when, sizeof_stream_item));

-}

-

-gr_annotator_alltoall::gr_annotator_alltoall (int when,

- size_t sizeof_stream_item)

- : gr_sync_block ("annotator_alltoall",

- gr_make_io_signature (1, -1, sizeof_stream_item),

- gr_make_io_signature (1, -1, sizeof_stream_item)),

- d_itemsize(sizeof_stream_item), d_when((uint64_t)when)

-{

- set_tag_propagation_policy(TPP_ALL_TO_ALL);

-

- d_tag_counter = 0;

-}

-

-gr_annotator_alltoall::~gr_annotator_alltoall ()

-{

-}

-

-int

-gr_annotator_alltoall::work (int noutput_items,

- gr_vector_const_void_star &input_items,

- gr_vector_void_star &output_items)

-{

- const float *in = (const float *) input_items[0];

- float *out = (float *) output_items[0];

-

- std::stringstream str;

- str << name() << unique_id();

-

- uint64_t abs_N = 0, end_N;

- int ninputs = input_items.size();

- for(int i = 0; i < ninputs; i++) {

- abs_N = nitems_read(i);

- end_N = abs_N + (uint64_t)(noutput_items);

-

- std::vector<gr_tag_t> all_tags;

- get_tags_in_range(all_tags, i, abs_N, end_N);

-

- std::vector<gr_tag_t>::iterator itr;

- for(itr = all_tags.begin(); itr != all_tags.end(); itr++) {

- d_stored_tags.push_back(*itr);

- }

- }

-

- // Source ID and key for any tag that might get applied from this block

- pmt::pmt_t srcid = pmt::string_to_symbol(str.str());

- pmt::pmt_t key = pmt::string_to_symbol("seq");

-

- // Work does nothing to the data stream; just copy all inputs to outputs

- // Adds a new tag when the number of items read is a multiple of d_when

- abs_N = nitems_written(0);

- int noutputs = output_items.size();

-

- for(int j = 0; j < noutput_items; j++) {

- for(int i = 0; i < noutputs; i++) {

- if(abs_N % d_when == 0) {

- pmt::pmt_t value = pmt::from_uint64(d_tag_counter++);

- add_item_tag(i, abs_N, key, value, srcid);

- }

-

- // Sum all of the inputs together for each output. Just 'cause.

- out = (float*)output_items[i];

- out[j] = 0;

- for(int ins = 0; ins < ninputs; ins++) {

- in = (const float*)input_items[ins];

- out[j] += in[j];

- }

- }

- abs_N++;

- }

-

- return noutput_items;

-}

-/* -*- c++ -*- */

-/*

- * Copyright 2010 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_ANNOTATOR_ALLTOALL_H

-#define INCLUDED_GR_ANNOTATOR_ALLTOALL_H

-

-#include <gr_core_api.h>

-#include <gr_sync_block.h>

-

-class gr_annotator_alltoall;

-typedef boost::shared_ptr<gr_annotator_alltoall> gr_annotator_alltoall_sptr;

-

-// public constructor

-GR_CORE_API gr_annotator_alltoall_sptr

-gr_make_annotator_alltoall (int when, size_t sizeof_stream_item);

-

-/*!

- * \brief All-to-all stream annotator testing block. FOR TESTING PURPOSES ONLY.

- *

- * This block creates tags to be sent downstream every 10,000 items it sees. The

- * tags contain the name and ID of the instantiated block, use "seq" as a key,

- * and have a counter that increments by 1 for every tag produced that is used

- * as the tag's value. The tags are propagated using the all-to-all policy.

- *

- * It also stores a copy of all tags it sees flow past it. These tags can be

- * recalled externally with the data() member.

- *

- * This block is only meant for testing and showing how to use the tags.

- */

-class GR_CORE_API gr_annotator_alltoall : public gr_sync_block

-{

- public:

- ~gr_annotator_alltoall ();

-

- int work (int noutput_items,

- gr_vector_const_void_star &input_items,

- gr_vector_void_star &output_items);

-

- std::vector<gr_tag_t> data() const

- {

- return d_stored_tags;

- }

-

-protected:

- gr_annotator_alltoall (int when, size_t sizeof_stream_item);

-

- private:

- size_t d_itemsize;

- uint64_t d_when;

- uint64_t d_tag_counter;

- std::vector<gr_tag_t> d_stored_tags;

-

- friend GR_CORE_API gr_annotator_alltoall_sptr

- gr_make_annotator_alltoall (int when, size_t sizeof_stream_item);

-};

-

-#endif

-/* -*- c++ -*- */

-/*

- * Copyright 2010-2011 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.

- */

-

-GR_SWIG_BLOCK_MAGIC(gr,annotator_alltoall);

-

-%include <gr_annotator_alltoall.h>

-/* -*- c++ -*- */

-/*

- * Copyright 2010 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 <gr_annotator_raw.h>

-#include <gr_io_signature.h>

-#include <string.h>

-#include <iostream>

-#include <iomanip>

-#include <stdexcept>

-

-using namespace pmt;

-

-gr_annotator_raw_sptr

-gr_make_annotator_raw(size_t sizeof_stream_item)

-{

- return gnuradio::get_initial_sptr(new gr_annotator_raw

- (sizeof_stream_item));

-}

-

-gr_annotator_raw::gr_annotator_raw(size_t sizeof_stream_item)

- : gr_sync_block("annotator_raw",

- gr_make_io_signature(1, 1, sizeof_stream_item),

- gr_make_io_signature(1, 1, sizeof_stream_item)),

- d_itemsize(sizeof_stream_item)

-{

- set_tag_propagation_policy(TPP_ONE_TO_ONE);

- set_relative_rate(1.0);

-}

-

-void gr_annotator_raw::add_tag(uint64_t offset, pmt_t key, pmt_t val)

-{

- gruel::scoped_lock l(d_mutex);

-

- gr_tag_t tag;

- tag.srcid = pmt::intern(name());

- tag.key = key;

- tag.value = val;

- tag.offset = offset;

-

- // add our new tag

- d_queued_tags.push_back(tag);

- // make sure our tags are in offset order

- std::sort(d_queued_tags.begin(), d_queued_tags.end(),

- gr_tag_t::offset_compare);

- // make sure we are not adding an item in the past!

- if(tag.offset > nitems_read(0)) {

- throw std::runtime_error("gr_annotator_raw::add_tag: item added too far in the past\n.");

- }

-}

-

-gr_annotator_raw::~gr_annotator_raw()

-{

-}

-

-int

-gr_annotator_raw::work(int noutput_items,

- gr_vector_const_void_star &input_items,

- gr_vector_void_star &output_items)

-{

- gruel::scoped_lock l(d_mutex);

-

- const char *in = (const char*)input_items[0];

- char *out = (char*)output_items[0];

-

- uint64_t start_N = nitems_read(0);

- uint64_t end_N = start_N + (uint64_t)(noutput_items);

-

- // locate queued tags that fall in this range and insert them when appropriate

- std::vector<gr_tag_t>::iterator i = d_queued_tags.begin();

- while( i != d_queued_tags.end() ) {

- if( (*i).offset >= start_N && (*i).offset < end_N) {

- add_item_tag(0, (*i).offset,(*i).key, (*i).value, (*i).srcid);

- i = d_queued_tags.erase(i);

- }

- else {

- break;

- }

- }

-

- // copy data across

- memcpy(out, in, noutput_items*d_itemsize);

- return noutput_items;

-}

-/* -*- c++ -*- */

-/*

- * Copyright 2010 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_ANNOTATOR_RAW_H

-#define INCLUDED_GR_ANNOTATOR_RAW_H

-

-#include <gr_core_api.h>

-#include <gr_sync_block.h>

-#include <gr_tags.h>

-#include <gruel/thread.h>

-

-class gr_annotator_raw;

-typedef boost::shared_ptr<gr_annotator_raw> gr_annotator_raw_sptr;

-

-// public constructor

-GR_CORE_API gr_annotator_raw_sptr

-gr_make_annotator_raw(size_t sizeof_stream_item);

-

-/*!

- * \brief raw stream annotator testing block.

- *

- * This block creates arbitrary tags to be sent downstream

- * blocks to be sent are set manually via accessor methods and are sent only once.

- *

- * This block is intended for testing of tag related blocks

- */

-class GR_CORE_API gr_annotator_raw : public gr_sync_block

-{

- public:

- ~gr_annotator_raw();

- int work(int noutput_items,

- gr_vector_const_void_star &input_items,

- gr_vector_void_star &output_items);

-

- // insert a tag to be added

- void add_tag(uint64_t offset, pmt::pmt_t key, pmt::pmt_t val);

-

-protected:

- gr_annotator_raw(size_t sizeof_stream_item);

-

- private:

- size_t d_itemsize;

- std::vector<gr_tag_t> d_queued_tags;

- gruel::mutex d_mutex;

-

- friend GR_CORE_API gr_annotator_raw_sptr

- gr_make_annotator_raw(size_t sizeof_stream_item);

-};

-

-#endif

-/* -*- c++ -*- */

-/*

- * Copyright 2010-2011 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.

- */

-

-GR_SWIG_BLOCK_MAGIC(gr,annotator_raw);

-

-%include <gr_tags.i>

-%include <gr_annotator_raw.h>

-/* -*- c++ -*- */

-/*

- * Copyright 2006,2009 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 <gr_copy.h>

-#include <gr_io_signature.h>

-#include <string.h>

-

-gr_copy_sptr

-gr_make_copy(size_t itemsize)

-{

- return gnuradio::get_initial_sptr(new gr_copy(itemsize));

-}

-

-gr_copy::gr_copy(size_t itemsize)

- : gr_block ("copy",

- gr_make_io_signature (1, 1, itemsize),

- gr_make_io_signature (1, 1, itemsize)),

- d_itemsize(itemsize),

- d_enabled(true)

-{

-}

-

-bool

-gr_copy::check_topology(int ninputs, int noutputs)

-{

- return ninputs == noutputs;

-}

-

-int

-gr_copy::general_work(int noutput_items,

- gr_vector_int &ninput_items,

- gr_vector_const_void_star &input_items,

- gr_vector_void_star &output_items)

-{

- const uint8_t *in = (const uint8_t *) input_items[0];

- uint8_t *out = (uint8_t *) output_items[0];

-

- int n = std::min<int>(ninput_items[0], noutput_items);

- int j = 0;

-

- if (d_enabled) {

- memcpy(out, in, n*d_itemsize);

- j = n;

- }

-

- consume_each(n);

- return j;

-}

-/* -*- c++ -*- */

-/*

- * Copyright 2006,2009 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_COPY_H

-#define INCLUDED_GR_COPY_H

-

-#include <gr_core_api.h>

-#include <gr_block.h>

-

-class gr_copy;

-typedef boost::shared_ptr<gr_copy> gr_copy_sptr;

-

-GR_CORE_API gr_copy_sptr gr_make_copy(size_t itemsize);

-

-/*!

- * \brief output[i] = input[i]

- * \ingroup misc_blk

- *

- * When enabled (default), this block copies its input to its output.

- * When disabled, this block drops its input on the floor.

- *

- */

-class GR_CORE_API gr_copy : public gr_block

-{

- size_t d_itemsize;

- bool d_enabled;

-

- friend GR_CORE_API gr_copy_sptr gr_make_copy(size_t itemsize);

- gr_copy(size_t itemsize);

-

- public:

-

- bool check_topology(int ninputs, int noutputs);

-

- void set_enabled(bool enable) { d_enabled = enable; }

- bool enabled() const { return d_enabled;}

-

- int general_work(int noutput_items,

- gr_vector_int &ninput_items,

- gr_vector_const_void_star &input_items,

- gr_vector_void_star &output_items);

-};

-

-#endif

-/* -*- c++ -*- */

-/*

- * Copyright 2006,2009 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.

- */

-

-GR_SWIG_BLOCK_MAGIC(gr,copy)

-

-gr_copy_sptr gr_make_copy(size_t itemsize);

-

-class gr_copy : public gr_block

-{

- private:

- gr_copy(size_t itemsize);

-

-public:

-

- void set_enabled(bool enabled);

- bool enabled();

-};

-/* -*- c++ -*- */

-/*

- * Copyright 2004,2010,2012 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 <gr_endian_swap.h>

-#include <gr_io_signature.h>

-#include <volk/volk.h>

-

-gr_endian_swap_sptr

-gr_make_endian_swap (size_t item_size_bytes)

-{

- return gnuradio::get_initial_sptr(new gr_endian_swap (item_size_bytes));

-}

-

-gr_endian_swap::gr_endian_swap (size_t item_size_bytes)

- : gr_sync_block ("gr_endian_swap",

- gr_make_io_signature (1, 1, item_size_bytes),

- gr_make_io_signature (1, 1, item_size_bytes))

-{

- const int alignment_multiple = volk_get_alignment();

- set_alignment(std::max(1,alignment_multiple));

-}

-

-int

-gr_endian_swap::work (int noutput_items,

- gr_vector_const_void_star &input_items,

- gr_vector_void_star &output_items)

-{

- const char *in = (const char *) input_items[0];

- char *out = (char *) output_items[0];

-

- int nbytes( output_signature()->sizeof_stream_item(0) );

- if(is_unaligned()) {

- switch(nbytes){

- case 1:

- memcpy(out,in,noutput_items);

- break;

- case 2:

- memcpy(out,in,2*noutput_items);

- volk_16u_byteswap_u((uint16_t*)out,noutput_items);

- break;

- case 4:

- memcpy(out,in,4*noutput_items);

- volk_32u_byteswap_u((uint32_t*)out,noutput_items);

- break;

- case 8:

- memcpy(out,in,8*noutput_items);

- volk_64u_byteswap_u((uint64_t*)out,noutput_items);

- break;

- default:

- throw std::runtime_error("itemsize is not valid for gr_endian_swap!");

- }

- } else {

- switch(nbytes){

- case 1:

- memcpy(out,in,noutput_items);

- break;

- case 2:

- memcpy(out,in,2*noutput_items);

- volk_16u_byteswap_a((uint16_t*)out,noutput_items);

- break;

- case 4:

- memcpy(out,in,4*noutput_items);

- volk_32u_byteswap_a((uint32_t*)out,noutput_items);

- break;

- case 8:

- memcpy(out,in,8*noutput_items);

- volk_64u_byteswap_a((uint64_t*)out,noutput_items);

- break;

- default:

- throw std::runtime_error("itemsize is not valid for gr_endian_swap!");

- }

- }

-

- return noutput_items;

-}

-

-

-

-/* -*- c++ -*- */

-/*

- * Copyright 2004,2012 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_ENDIAN_SWAP_H

-#define INCLUDED_GR_ENDIAN_SWAP_H

-

-#include <gr_core_api.h>

-#include <gr_sync_block.h>

-

-class gr_endian_swap;

-typedef boost::shared_ptr<gr_endian_swap> gr_endian_swap_sptr;

-

-GR_CORE_API gr_endian_swap_sptr

-gr_make_endian_swap (size_t item_size_bytes=1);

-

-/*!

- * \brief Convert stream of items into thier byte swapped version

- *

- * \param item_size_bytes number of bytes per item, 1=no-op,2=uint16_t,4=uint32_t,8=uint64_t

- */

-

-class GR_CORE_API gr_endian_swap : public gr_sync_block

-{

- private:

- friend GR_CORE_API gr_endian_swap_sptr

- gr_make_endian_swap (size_t item_size_bytes);

- gr_endian_swap (size_t item_size_bytes);

-

- size_t item_size_bytes;

-

- public:

- virtual int work (int noutput_items,

- gr_vector_const_void_star &input_items,

- gr_vector_void_star &output_items);

-};

-

-

-#endif /* INCLUDED_GR_ENDIAN_SWAP_H */

-/* -*- c++ -*- */

-/*

- * Copyright 2004,2012 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.

- */

-

-GR_SWIG_BLOCK_MAGIC(gr,endian_swap)

-

-gr_endian_swap_sptr

-gr_make_endian_swap (size_t bytes_per_item=1);

-

-class gr_endian_swap : public gr_sync_block

-{

-public:

-};

-/* -*- c++ -*- */

-/*

- * Copyright 2004,2009 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 <gr_head.h>

-#include <gr_io_signature.h>

-#include <string.h>

-#include <iostream>

-

-gr_head::gr_head (size_t sizeof_stream_item, unsigned long long nitems)

- : gr_sync_block ("head",

- gr_make_io_signature (1, 1, sizeof_stream_item),

- gr_make_io_signature (1, 1, sizeof_stream_item)),

- d_nitems (nitems), d_ncopied_items (0)

-{

-}

-

-gr_head_sptr

-gr_make_head (size_t sizeof_stream_item, unsigned long long nitems)

-{

- return gnuradio::get_initial_sptr(new gr_head (sizeof_stream_item, nitems));

-}

-

-int

-gr_head::work (int noutput_items,

- gr_vector_const_void_star &input_items,

- gr_vector_void_star &output_items)

-{

- if (d_ncopied_items >= d_nitems)

- return -1; // Done!

-

- unsigned n = std::min (d_nitems - d_ncopied_items, (unsigned long long) noutput_items);

-

- if (n == 0)

- return 0;

-

- memcpy (output_items[0], input_items[0], n * input_signature()->sizeof_stream_item (0));

- d_ncopied_items += n;

-

- return n;

-}

-/* -*- c++ -*- */

-/*

- * Copyright 2004,2009,2012 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_HEAD_H

-#define INCLUDED_GR_HEAD_H

-

-#include <gr_core_api.h>

-#include <gr_sync_block.h>

-#include <stddef.h> // size_t

-

-class gr_head;

-typedef boost::shared_ptr<gr_head> gr_head_sptr;

-

-/*!

- * \brief copies the first N items to the output then signals done

- * \ingroup slicedice_blk

- *

- * Useful for building test cases

- */

-

-class GR_CORE_API gr_head : public gr_sync_block

-{

- friend GR_CORE_API gr_head_sptr gr_make_head (size_t sizeof_stream_item, unsigned long long nitems);

- gr_head (size_t sizeof_stream_item, unsigned long long nitems);

-

- unsigned long long d_nitems;

- unsigned long long d_ncopied_items;

-

- public:

- int work (int noutput_items,

- gr_vector_const_void_star &input_items,

- gr_vector_void_star &output_items);

-

- void reset() { d_ncopied_items = 0; }

- void set_length(int nitems) { d_nitems = nitems; }

-};

-

-GR_CORE_API gr_head_sptr

-gr_make_head (size_t sizeof_stream_item, unsigned long long nitems);

-

-

-#endif /* INCLUDED_GR_HEAD_H */

-/* -*- c++ -*- */

-/*

- * Copyright 2004,2009,2012 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.

- */

-

-GR_SWIG_BLOCK_MAGIC(gr,head);

-

-gr_head_sptr gr_make_head(size_t sizeof_stream_item, unsigned long long nitems);

-

-class gr_head : public gr_block {

- gr_head();

-public:

- void reset();

- void set_length(int nitems);

-};

-

-/* -*- c++ -*- */

-/*

- * Copyright 2006 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 <gr_kludge_copy.h>

-#include <gr_io_signature.h>

-#include <string.h>

-

-gr_kludge_copy_sptr

-gr_make_kludge_copy(size_t itemsize)

-{

- return gnuradio::get_initial_sptr(new gr_kludge_copy(itemsize));

-}

-

-gr_kludge_copy::gr_kludge_copy(size_t itemsize)

- : gr_sync_block ("kludge_copy",

- gr_make_io_signature (1, -1, itemsize),

- gr_make_io_signature (1, -1, itemsize)),

- d_itemsize(itemsize)

-{

-}

-

-bool

-gr_kludge_copy::check_topology(int ninputs, int noutputs)

-{

- return ninputs == noutputs;

-}

-

-int

-gr_kludge_copy::work(int noutput_items,

- gr_vector_const_void_star &input_items,

- gr_vector_void_star &output_items)

-{

- const float **in = (const float **) &input_items[0];

- float **out = (float **) &output_items[0];

-

- int ninputs = input_items.size();

- for (int i = 0; i < ninputs; i++){

- memcpy(out[i], in[i], noutput_items * d_itemsize);

- }

- return noutput_items;

-}

-/* -*- c++ -*- */

-/*

- * Copyright 2006 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_KLUDGE_COPY_H

-#define INCLUDED_GR_KLUDGE_COPY_H

-

-#include <gr_core_api.h>

-#include <gr_sync_block.h>

-

-class gr_kludge_copy;

-typedef boost::shared_ptr<gr_kludge_copy> gr_kludge_copy_sptr;

-

-GR_CORE_API gr_kludge_copy_sptr gr_make_kludge_copy(size_t itemsize);

-

-/*!

- * \brief output[i] = input[i]

- * \ingroup misc_blk

- *

- * This is a short term kludge to work around a problem with the hierarchical block impl.

- */

-class GR_CORE_API gr_kludge_copy : public gr_sync_block

-{

- size_t d_itemsize;

-

- friend GR_CORE_API gr_kludge_copy_sptr gr_make_kludge_copy(size_t itemsize);

- gr_kludge_copy(size_t itemsize);

-

- public:

-

- bool check_topology(int ninputs, int noutputs);

-

- int work(int noutput_items,

- gr_vector_const_void_star &input_items,

- gr_vector_void_star &output_items);

-};

-

-#endif

-/* -*- c++ -*- */

-/*

- * Copyright 2006 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.

- */

-

-GR_SWIG_BLOCK_MAGIC(gr,kludge_copy)

-

-gr_kludge_copy_sptr gr_make_kludge_copy(size_t itemsize);

-

-class gr_kludge_copy : public gr_sync_block

-{

- private:

- gr_kludge_copy(size_t itemsize);

-};

-/* -*- c++ -*- */

-/*

- * Copyright 2004,2010 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 <gr_nop.h>

-#include <gr_io_signature.h>

-#include <boost/bind.hpp>

-

-#ifdef GR_CTRLPORT

-#include <rpcregisterhelpers.h>

-#endif

-

-gr_nop_sptr

-gr_make_nop (size_t sizeof_stream_item)

-{

- return gnuradio::get_initial_sptr (new gr_nop (sizeof_stream_item));

-}

-

-gr_nop::gr_nop (size_t sizeof_stream_item)

- : gr_block ("nop",

- gr_make_io_signature (0, -1, sizeof_stream_item),

- gr_make_io_signature (0, -1, sizeof_stream_item)),

- d_nmsgs_recvd(0), d_ctrlport_test(0)

-{

- // Arrange to have count_received_msgs called when messages are received.

- message_port_register_in(pmt::mp("port"));

- set_msg_handler(pmt::mp("port"), boost::bind(&gr_nop::count_received_msgs, this, _1));

-}

-

-// Trivial message handler that just counts them.

-// (N.B., This feature is used in qa_set_msg_handler)

-void

-gr_nop::count_received_msgs(pmt::pmt_t msg)

-{

- d_nmsgs_recvd++;

-}

-

-int

-gr_nop::general_work (int noutput_items,

- gr_vector_int &ninput_items,

- gr_vector_const_void_star &input_items,

- gr_vector_void_star &output_items)

-{

- // eat any input that's available

- for (unsigned i = 0; i < ninput_items.size (); i++)

- consume (i, ninput_items[i]);

-

- return noutput_items;

-}

-

-void

-gr_nop::setup_rpc()

-{

-#ifdef GR_CTRLPORT

- d_rpc_vars.push_back(

- rpcbasic_sptr(new rpcbasic_register_get<gr_nop, int>(

- alias(), "test",

- &gr_nop::ctrlport_test,

- pmt::mp(-256), pmt::mp(255), pmt::mp(0),

- "", "Simple testing variable",

- RPC_PRIVLVL_MIN, DISPNULL)));

-

- d_rpc_vars.push_back(

- rpcbasic_sptr(new rpcbasic_register_set<gr_nop, int>(

- alias(), "test",

- &gr_nop::set_ctrlport_test,

- pmt::mp(-256), pmt::mp(255), pmt::mp(0),

- "", "Simple testing variable",

- RPC_PRIVLVL_MIN, DISPNULL)));

-#endif /* GR_CTRLPORT */

-}

-/* -*- c++ -*- */

-/*

- * Copyright 2004,2010 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_NOP_H

-#define INCLUDED_GR_NOP_H

-

-#include <gr_core_api.h>

-#include <gr_block.h>

-#include <stddef.h> // size_t

-

-class gr_nop;

-typedef boost::shared_ptr<gr_nop> gr_nop_sptr;

-

-GR_CORE_API gr_nop_sptr

-gr_make_nop (size_t sizeof_stream_item);

-

-/*!

- * \brief Does nothing. Used for testing only.

- * \ingroup misc_blk

- */

-class GR_CORE_API gr_nop : public gr_block

-{

- friend GR_CORE_API gr_nop_sptr gr_make_nop (size_t sizeof_stream_item);

- gr_nop (size_t sizeof_stream_item);

-

- std::vector<boost::any> d_rpc_vars;

- void setup_rpc();

-

-protected:

- int d_nmsgs_recvd;

- int d_ctrlport_test;

-

- // Method that just counts any received messages.

- void count_received_msgs(pmt::pmt_t msg);

-

- public:

- virtual int general_work (int noutput_items,

- gr_vector_int &ninput_items,

- gr_vector_const_void_star &input_items,

- gr_vector_void_star &output_items);

-

- int nmsgs_received() const { return d_nmsgs_recvd; }

-

- int ctrlport_test() { return d_ctrlport_test; }

- void set_ctrlport_test(int x) { d_ctrlport_test = x; }

-};

-

-#endif /* INCLUDED_GR_NOP_H */

-/* -*- c++ -*- */

-/*

- * Copyright 2004,2010 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.

- */

-

-GR_SWIG_BLOCK_MAGIC(gr,nop)

-

-gr_nop_sptr gr_make_nop (size_t sizeof_stream_item);

-

-class gr_nop : public gr_block {

-public:

- int ctrlport_test();

- void set_ctrlport_test(int x);

-private:

- gr_nop (size_t sizeof_stream_item);

-};

-

-/* -*- c++ -*- */

-/*

- * Copyright 2004,2010 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 <gr_null_sink.h>

-#include <gr_io_signature.h>

-

-gr_null_sink::gr_null_sink (size_t sizeof_stream_item)

- : gr_sync_block ("null_sink",

- gr_make_io_signature (1, 1, sizeof_stream_item),

- gr_make_io_signature (0, 0, 0))

-{

-}

-

-gr_null_sink_sptr

-gr_make_null_sink (size_t sizeof_stream_item)

-{

- return gnuradio::get_initial_sptr (new gr_null_sink (sizeof_stream_item));

-}

-

-int

-gr_null_sink::work (int noutput_items,

- gr_vector_const_void_star &input_items,

- gr_vector_void_star &output_items)

-{

- return noutput_items;

-}

-/* -*- c++ -*- */

-/*

- * Copyright 2004,2010 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_NULL_SINK_H

-#define INCLUDED_GR_NULL_SINK_H

-

-#include <gr_core_api.h>

-#include <gr_sync_block.h>

-#include <stddef.h> // size_t

-

-class gr_null_sink;

-typedef boost::shared_ptr<gr_null_sink> gr_null_sink_sptr;

-

-GR_CORE_API gr_null_sink_sptr

-gr_make_null_sink (size_t sizeof_stream_item);

-

-/*!

- * \brief Bit bucket

- * \ingroup sink_blk

- */

-class GR_CORE_API gr_null_sink : public gr_sync_block

-{

- friend GR_CORE_API gr_null_sink_sptr gr_make_null_sink (size_t sizeof_stream_item);

- gr_null_sink (size_t sizeof_stream_item);

-

- public:

-

- virtual int work (int noutput_items,

- gr_vector_const_void_star &input_items,

- gr_vector_void_star &output_items);

-

-};

-

-#endif /* INCLUDED_GR_NULL_SINK_H */

-/* -*- c++ -*- */

-/*

- * Copyright 2004,2010 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.

- */

-

-GR_SWIG_BLOCK_MAGIC(gr,null_sink)

-

-gr_null_sink_sptr gr_make_null_sink (size_t sizeof_stream_item);

-

-class gr_null_sink : public gr_sync_block {

-private:

- gr_null_sink (size_t sizeof_stream_item);

-};

-

-/* -*- c++ -*- */

-/*

- * Copyright 2004,2010 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 <gr_null_source.h>

-#include <gr_io_signature.h>

-#include <string.h>

-

-gr_null_source::gr_null_source (size_t sizeof_stream_item)

- : gr_sync_block ("null_source",

- gr_make_io_signature (0, 0, 0),

- gr_make_io_signature (1, 1, sizeof_stream_item))

-{

-}

-

-gr_null_source_sptr

-gr_make_null_source (size_t sizeof_stream_item)

-{

- return gnuradio::get_initial_sptr (new gr_null_source (sizeof_stream_item));

-}

-

-int

-gr_null_source::work (int noutput_items,

- gr_vector_const_void_star &input_items,

- gr_vector_void_star &output_items)

-{

- void *optr = (void *) output_items[0];

- memset (optr, 0, noutput_items * output_signature()->sizeof_stream_item (0));

- return noutput_items;

-}

-/* -*- c++ -*- */

-/*

- * Copyright 2004,2010 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_NULL_SOURCE_H

-#define INCLUDED_GR_NULL_SOURCE_H

-

-#include <gr_core_api.h>

-#include <gr_sync_block.h>

-

-class gr_null_source;

-typedef boost::shared_ptr<gr_null_source> gr_null_source_sptr;

-

-GR_CORE_API gr_null_source_sptr

-gr_make_null_source (size_t sizeof_stream_item);

-

-/*!

- * \brief A source of zeros.

- * \ingroup source_blk

- */

-class GR_CORE_API gr_null_source : public gr_sync_block

-{

- friend GR_CORE_API gr_null_source_sptr gr_make_null_source (size_t sizeof_stream_item);

-

- gr_null_source (size_t sizeof_stream_item);

-

- public:

- virtual int work (int noutput_items,

- gr_vector_const_void_star &input_items,

- gr_vector_void_star &output_items);

-

-};

-

-#endif /* INCLUDED_GR_NULL_SOURCE_H */

-/* -*- c++ -*- */

-/*

- * Copyright 2004,2010 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.

- */

-

-GR_SWIG_BLOCK_MAGIC(gr,null_source)

-

-gr_null_source_sptr gr_make_null_source (size_t sizeof_stream_item);

-

-class gr_null_source : public gr_sync_block {

-private:

- gr_null_source (size_t sizeof_stream_item);

-};

-

-/* -*- c++ -*- */

-/*

- * Copyright 2005,2007,2010 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 <gr_skiphead.h>

-#include <gr_io_signature.h>

-#include <string.h>

-

-gr_skiphead::gr_skiphead (size_t itemsize, uint64_t nitems_to_skip)

- : gr_block ("skiphead",

- gr_make_io_signature(1, 1, itemsize),

- gr_make_io_signature(1, 1, itemsize)),

- d_nitems_to_skip(nitems_to_skip), d_nitems(0)

-{

-}

-

-gr_skiphead_sptr

-gr_make_skiphead (size_t itemsize, uint64_t nitems_to_skip)

-{

- return gnuradio::get_initial_sptr(new gr_skiphead (itemsize, nitems_to_skip));

-}

-

-void

-gr_skiphead::set_nitems_to_skip(uint64_t nitems_to_skip)

-{

- d_nitems_to_skip = nitems_to_skip;

- reset();

-}

-

-uint64_t

-gr_skiphead::nitems_to_skip() const

-{

- return d_nitems_to_skip;

-}

-

-uint64_t

-gr_skiphead::nitems_skiped() const

-{

- return d_nitems;

-}

-

-void

-gr_skiphead::reset()

-{

- d_nitems = 0;

-}

-

-int

-gr_skiphead::general_work(int noutput_items,

- gr_vector_int &ninput_items_,

- gr_vector_const_void_star &input_items,

- gr_vector_void_star &output_items)

-{

- const char *in = (const char *) input_items[0];

- char *out = (char *) output_items[0];

-

- int ninput_items = std::min(ninput_items_[0], noutput_items);

- int ii = 0; // input index

-

- while (ii < ninput_items){

-

- uint64_t ni_total = ii + d_nitems; // total items processed so far

- if (ni_total < d_nitems_to_skip){ // need to skip some more

-

- int n_to_skip = (int) std::min(d_nitems_to_skip - ni_total,

- (uint64_t)(ninput_items - ii));

- ii += n_to_skip;

- }

-

- else { // nothing left to skip. copy away

-

- int n_to_copy = ninput_items - ii;

- if (n_to_copy > 0){

- size_t itemsize = output_signature()->sizeof_stream_item(0);

- memcpy(out, in + (ii*itemsize), n_to_copy*itemsize);

- }

-

- d_nitems += ninput_items;

- consume_each(ninput_items);

- return n_to_copy;

- }

- }

-

- d_nitems += ninput_items;

- consume_each(ninput_items);

- return 0;

-}

-/* -*- c++ -*- */

-/*

- * Copyright 2005 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_SKIPHEAD_H

-#define INCLUDED_GR_SKIPHEAD_H

-

-#include <gr_core_api.h>

-#include <gr_sync_block.h>

-#include <stddef.h> // size_t

-

-class gr_skiphead;

-typedef boost::shared_ptr<gr_skiphead> gr_skiphead_sptr;

-

-GR_CORE_API gr_skiphead_sptr

-gr_make_skiphead (size_t itemsize, uint64_t nitems_to_skip);

-

-

-/*!

- * \brief skips the first N items, from then on copies items to the output

- * \ingroup slicedice_blk

- *

- * Useful for building test cases and sources which have metadata or junk at the start

- */

-

-class GR_CORE_API gr_skiphead : public gr_block

-{

- friend GR_CORE_API gr_skiphead_sptr gr_make_skiphead (size_t itemsize, uint64_t nitems_to_skip);

- gr_skiphead (size_t itemsize, uint64_t nitems_to_skip);

-

- uint64_t d_nitems_to_skip;

- uint64_t d_nitems; // total items seen

-

- public:

-

- /*!

- * \brief Sets number of items to skip; resets current skip count to 0.

- */

- void set_nitems_to_skip(uint64_t nitems_to_skip);

-

- /*!

- * \brief Gets the number of items to skip.

- */

- uint64_t nitems_to_skip() const;

-

- /*!

- * \brief Gets the number of items already skipped.

- */

- uint64_t nitems_skiped() const;

-

- /*!

- * \brief Resets number of items skipped to 0.

- */

- void reset();

-

- int general_work(int noutput_items,

- gr_vector_int &ninput_items,

- gr_vector_const_void_star &input_items,

- gr_vector_void_star &output_items);

-};

-

-#endif /* INCLUDED_GR_SKIPHEAD_H */

-/* -*- c++ -*- */

-/*

- * Copyright 2005,2007,2010 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.

- */

-

-GR_SWIG_BLOCK_MAGIC(gr,skiphead);

-

-gr_skiphead_sptr gr_make_skiphead(size_t itemsize,

- uint64_t nitems_to_skip);

-

-class gr_skiphead : public gr_block

-{

-public:

- void set_nitems_to_skip(uint64_t nitems_to_skip);

- uint64_t nitems_to_skip() const;

- uint64_t nitems_skiped() const;

- void reset();

-};

-/* -*- c++ -*- */

-/*

- * Copyright 2012 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 <gr_vector_map.h>

-#include <gr_io_signature.h>

-#include <string.h>

-

-std::vector<int>

-get_in_sizeofs(size_t item_size, std::vector<size_t> in_vlens)

-{

- std::vector<int> in_sizeofs;

- for(unsigned int i = 0; i < in_vlens.size(); i++) {

- in_sizeofs.push_back(in_vlens[i]*item_size);

- }

- return in_sizeofs;

-}

-

-std::vector<int>

-get_out_sizeofs(size_t item_size,

- std::vector< std::vector< std::vector<size_t> > > mapping)

-{

- std::vector<int> out_sizeofs;

- for(unsigned int i = 0; i < mapping.size(); i++) {

- out_sizeofs.push_back(mapping[i].size()*item_size);

- }

- return out_sizeofs;

-}

-

-gr_vector_map_sptr

-gr_make_vector_map (size_t item_size, std::vector<size_t> in_vlens,

- std::vector< std::vector< std::vector<size_t> > > mapping)

-{

- return gnuradio::get_initial_sptr(new gr_vector_map(item_size,

- in_vlens,

- mapping));

-}

-

-gr_vector_map::gr_vector_map(size_t item_size, std::vector<size_t> in_vlens,

- std::vector< std::vector< std::vector<size_t> > > mapping)

- : gr_sync_block("vector_map",

- gr_make_io_signaturev(in_vlens.size(), in_vlens.size(),

- get_in_sizeofs(item_size, in_vlens)),

- gr_make_io_signaturev(mapping.size(), mapping.size(),

- get_out_sizeofs(item_size, mapping))),

- d_item_size(item_size), d_in_vlens(in_vlens)

-{

- set_mapping(mapping);

-}

-

-void

-gr_vector_map::set_mapping(std::vector< std::vector< std::vector<size_t> > > mapping) {

- // Make sure the contents of the mapping vectors are possible.

- for(unsigned int i=0; i<mapping.size(); i++) {

- for(unsigned int j=0; j<mapping[i].size(); j++) {

- if(mapping[i][j].size() != 2) {

- throw std::runtime_error("Mapping must be of the form (out_mapping_stream1, out_mapping_stream2, ...), where out_mapping_stream1 is of the form (mapping_element1, mapping_element2, ...), where mapping_element1 is of the form (input_stream, input_element). This error is raised because a mapping_element vector does not contain exactly 2 items.");

- }

- unsigned int s = mapping[i][j][0];

- unsigned int index = mapping[i][j][1];

- if(s >= d_in_vlens.size()) {

- throw std::runtime_error("Stream numbers in mapping must be less than the number of input streams.");

- }

- if((index < 0) || (index >= d_in_vlens[s])) {

- throw std::runtime_error ("Indices in mapping must be greater than 0 and less than the input vector lengths.");

- }

- }

- }

- gruel::scoped_lock guard(d_mutex);

- d_mapping = mapping;

-}

-

-int

-gr_vector_map::work(int noutput_items,

- gr_vector_const_void_star &input_items,

- gr_vector_void_star &output_items)

-{

- const char **inv = (const char **) &input_items[0];

- char **outv = (char **) &output_items[0];

-

- for(unsigned int n = 0; n < (unsigned int)(noutput_items); n++) {

- for(unsigned int i = 0; i < d_mapping.size(); i++) {

- unsigned int out_vlen = d_mapping[i].size();

- for(unsigned int j = 0; j < out_vlen; j++) {

- unsigned int s = d_mapping[i][j][0];

- unsigned int k = d_mapping[i][j][1];

- memcpy(outv[i] + out_vlen*d_item_size*n +

- d_item_size*j, inv[s] + d_in_vlens[s]*d_item_size*n +

- k*d_item_size, d_item_size);

- }

- }

- }

-

- return noutput_items;

-}

-/* -*- c++ -*- */

-/*

- * Copyright 2012 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_VECTOR_MAP_H

-#define INCLUDED_GR_VECTOR_MAP_H

-

-#include <vector>

-#include <gr_core_api.h>

-#include <gr_sync_interpolator.h>

-#include <gruel/thread.h>

-

-class gr_vector_map;

-typedef boost::shared_ptr<gr_vector_map> gr_vector_map_sptr;

-

-GR_CORE_API gr_vector_map_sptr

-gr_make_vector_map (size_t item_size, std::vector<size_t> in_vlens,

- std::vector< std::vector< std::vector<size_t> > > mapping);

-

-/*!

- * \brief Maps elements from a set of input vectors to a set of output vectors.

- *

- * If in[i] is the input vector in the i'th stream then the output

- * vector in the j'th stream is:

- *

- * out[j][k] = in[mapping[j][k][0]][mapping[j][k][1]]

- *

- * That is mapping is of the form (out_stream1_mapping,

- * out_stream2_mapping, ...) and out_stream1_mapping is of the form

- * (element1_mapping, element2_mapping, ...) and element1_mapping is

- * of the form (in_stream, in_element).

- *

- * \param item_size (integer) size of vector elements

- *

- * \param in_vlens (vector of integers) number of elements in each

- * input vector

- *

- * \param mapping (vector of vectors of vectors of integers) how to

- * map elements from input to output vectors

- *

- * \ingroup slicedice_blk

- */

-class GR_CORE_API gr_vector_map : public gr_sync_block

-{

- friend GR_CORE_API gr_vector_map_sptr

- gr_make_vector_map(size_t item_size, std::vector<size_t> in_vlens,

- std::vector< std::vector< std::vector<size_t> > > mapping);

- size_t d_item_size;

- std::vector<size_t> d_in_vlens;

- std::vector< std::vector< std::vector<size_t> > > d_mapping;

- gruel::mutex d_mutex; // mutex to protect set/work access

-

- protected:

- gr_vector_map(size_t item_size, std::vector<size_t> in_vlens,

- std::vector< std::vector< std::vector<size_t> > > mapping);

-

- public:

- int work(int noutput_items,

- gr_vector_const_void_star &input_items,

- gr_vector_void_star &output_items);

-

- void set_mapping(std::vector< std::vector< std::vector<size_t> > > mapping);

-};

-

-#endif /* INCLUDED_GR_VECTOR_MAP_H */

-/* -*- c++ -*- */

-/*

- * Copyright 2012 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.

- */

-

-GR_SWIG_BLOCK_MAGIC(gr, vector_map);

-

-%template() std::vector<size_t>;

-%template() std::vector< std::vector< std::vector<size_t> > >;

-

-%include "gr_vector_map.h"

-# Copyright 2010-2011 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.

-

-########################################################################

-# This file included, use CMake directory variables

-########################################################################

-include(GrPython)

-

-########################################################################

-# generate the python helper script which calls into the build utils

-########################################################################

-file(WRITE ${CMAKE_CURRENT_BINARY_DIR}/generate_helper.py "

-#!${PYTHON_EXECUTABLE}

-

-import sys, os, re

-sys.path.append('${GR_CORE_PYTHONPATH}')

-os.environ['srcdir'] = '${CMAKE_CURRENT_SOURCE_DIR}'

-os.chdir('${CMAKE_CURRENT_BINARY_DIR}')

-

-if __name__ == '__main__':

- import build_utils

- root, inp = sys.argv[1:3]

- for sig in sys.argv[3:]:

- name = re.sub ('X+', sig, root)

- d = build_utils.standard_dict(name, sig)

- build_utils.expand_template(d, inp)

-

-")

-

-########################################################################

-# generation helper macro to generate various files from template

-########################################################################

-macro(expand_h_cc_i root)

-

- foreach(ext h cc i)

- #make a list of all the generated files

- unset(expanded_files_${ext})

- foreach(sig ${ARGN})

- string(REGEX REPLACE "X+" ${sig} name ${root})

- list(APPEND expanded_files_${ext} ${CMAKE_CURRENT_BINARY_DIR}/${name}.${ext})

- endforeach(sig)

-

- #create a command to generate the files

- add_custom_command(

- OUTPUT ${expanded_files_${ext}}

- DEPENDS ${CMAKE_CURRENT_SOURCE_DIR}/${root}.${ext}.t

- COMMAND ${PYTHON_EXECUTABLE} ${PYTHON_DASH_B}

- ${CMAKE_CURRENT_BINARY_DIR}/generate_helper.py

- ${root} ${root}.${ext}.t ${ARGN}

- )

- endforeach(ext)

-

- #make source files depends on headers to force generation

- set_source_files_properties(${expanded_files_cc}

- PROPERTIES OBJECT_DEPENDS "${expanded_files_h}"

- )

-

- #install rules for the generated cc, h, and i files

- list(APPEND generated_gengen_sources ${expanded_files_cc})

- list(APPEND generated_gengen_includes ${expanded_files_h})

- list(APPEND generated_gengen_swigs ${expanded_files_i})

-

-endmacro(expand_h_cc_i)

-

-########################################################################

-# Invoke macro to generate various sources

-########################################################################

-expand_h_cc_i(gr_vector_source_X b s i f c)

-expand_h_cc_i(gr_vector_insert_X b)

-expand_h_cc_i(gr_vector_sink_X b s i f c)

-

-add_custom_target(gengen_generated DEPENDS

- ${generated_gengen_includes}

- ${generated_gengen_swigs}

-)

-

-########################################################################

-# Create the master gengen swig include files

-########################################################################

-set(generated_index ${CMAKE_CURRENT_BINARY_DIR}/gengen_generated.i.in)

-file(WRITE ${generated_index} "

-//

-// This file is machine generated. All edits will be overwritten

-//

-")

-

-file(APPEND ${generated_index} "%{\n")

-foreach(swig_file ${generated_gengen_swigs})

- get_filename_component(name ${swig_file} NAME_WE)

- file(APPEND ${generated_index} "#include<${name}.h>\n")

-endforeach(swig_file)

-file(APPEND ${generated_index} "%}\n")

-

-foreach(swig_file ${generated_gengen_swigs})

- get_filename_component(name ${swig_file} NAME)

- file(APPEND ${generated_index} "%include<${name}>\n")

-endforeach(swig_file)

-

-execute_process(

- COMMAND ${CMAKE_COMMAND} -E copy_if_different

- ${generated_index} ${CMAKE_CURRENT_BINARY_DIR}/gengen_generated.i

-)

-

-########################################################################

-# Handle the generated sources + a few non-generated ones

-########################################################################

-list(APPEND gnuradio_core_sources

- ${generated_gengen_sources}

-)

-

-install(FILES

- ${generated_gengen_includes}

- ${CMAKE_CURRENT_SOURCE_DIR}/gr_endianness.h

- DESTINATION ${GR_INCLUDE_DIR}/gnuradio

- COMPONENT "core_devel"

-)

-

-if(ENABLE_PYTHON)

- install(FILES

- ${generated_gengen_swigs}

- ${CMAKE_CURRENT_SOURCE_DIR}/gr_endianness.i

- ${CMAKE_CURRENT_SOURCE_DIR}/gengen.i

- ${CMAKE_CURRENT_BINARY_DIR}/gengen_generated.i

- DESTINATION ${GR_INCLUDE_DIR}/gnuradio/swig

- COMPONENT "core_swig"

- )

-endif(ENABLE_PYTHON)

-#!/usr/bin/env python

-#

-# Copyright 2004 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.

-#

-

-from build_utils import output_glue

-