qa_vector_sink_source.py	\

	qa_stream_to_vector_overlap.py

	gr_stream_to_vector_overlap.cc  \

	gr_stream_to_vector_overlap.h   \

	gr_stream_to_vector_overlap.i   \

#include <gr_stream_to_vector_overlap.h>

%include "gr_stream_to_vector_overlap.i"

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

/*

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

#define INCLUDED_GR_STREAM_TO_VECTOR_OVERLAP_H

#include <gr_sync_decimator.h>

class gr_stream_to_vector_overlap;

typedef boost::shared_ptr<gr_stream_to_vector_overlap> gr_stream_to_vector_overlap_sptr;

gr_stream_to_vector_overlap_sptr

gr_make_stream_to_vector_overlap (size_t item_size, size_t nitems_per_block, unsigned overlap);

/*!

 * \brief Convert a stream of items into a stream of overlapping blocks containing nitems_per_block.

 *

 * The i-th block will start with the same \p overlap items as the i-1-th block ended. The first

 * block is prepended with \p overlap zeros to ensure synchronicity.

 * \ingroup converter

 */

class gr_stream_to_vector_overlap : public gr_sync_decimator

{

  friend gr_stream_to_vector_overlap_sptr

    gr_make_stream_to_vector_overlap (size_t item_size, size_t nitems_per_block, unsigned overlap);

 protected:

  gr_stream_to_vector_overlap (size_t item_size, size_t nitems_per_block, unsigned overlap);

  int d_bytes_overlap;

 public:

  int work (int noutput_items,

	    gr_vector_const_void_star &input_items,

	    gr_vector_void_star &output_items);

  unsigned overlap() { return history() - 1; };

};

#endif /* INCLUDED_GR_STREAM_TO_VECTOR_OVERLAP_H */

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

/*

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

 */

%include "exception.i"

%{

#include <stdexcept>

%}

GR_SWIG_BLOCK_MAGIC(gr,stream_to_vector_overlap)

gr_stream_to_vector_overlap_sptr 

gr_make_stream_to_vector_overlap (size_t itemsize, size_t nitems_per_block, unsigned overlap)

        throw (std::invalid_argument);

class gr_stream_to_vector_overlap : public gr_sync_decimator

{

 protected:

  gr_stream_to_vector_overlap (size_t itemsize, size_t nitems_per_block, unsigned overlap);

 public:

  unsigned overlap();

};

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

/*

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

 */

#ifdef HAVE_CONFIG_H

#include "config.h"

#endif

#include <gr_stream_to_vector_overlap.h>

#include <gr_io_signature.h>

#include <string.h>

#include <stdexcept>

gr_stream_to_vector_overlap_sptr

gr_make_stream_to_vector_overlap (size_t item_size, size_t nitems_per_block, unsigned overlap)

{

  return gr_stream_to_vector_overlap_sptr (new gr_stream_to_vector_overlap (item_size, nitems_per_block, overlap));

}

gr_stream_to_vector_overlap::gr_stream_to_vector_overlap (size_t item_size, size_t nitems_per_block, unsigned overlap)

  : gr_sync_decimator ("stream_to_vector_overlap",

		       gr_make_io_signature (1, 1, item_size),

		       gr_make_io_signature (1, 1, item_size * nitems_per_block),

		       nitems_per_block - overlap),

	d_bytes_overlap(overlap * item_size)

{

	if (overlap + 1 >= nitems_per_block) {

		throw std::invalid_argument("gr_stream_to_vector_overlap: overlap must be smaller than the number of items per block.");

	}

	set_history(overlap + 1);

}

int

gr_stream_to_vector_overlap::work (int noutput_items,

			     gr_vector_const_void_star &input_items,

			     gr_vector_void_star &output_items)

{

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

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

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

  for (int i = 0; i < noutput_items; i++) {

	  memcpy(out, in, block_size);

	  out += block_size;

	  in += block_size - d_bytes_overlap;

  }

  return noutput_items;

}