GNU Radio 输入和输出缓冲区如何工作？

Question

我是 GNU Radio 的新手，在理解输入和输出缓冲区的工作方式时遇到问题。

我想制作一个有 1 个输入和 2 个输出端口的模块。此外，我想将固定大小的输入分成 2 个具有相同项目数的输出流。

一开始，我做了一个有 1 个输入和 1 个输出端口的块。它接收 4 个元素并且应该将每个其他元素放在输出端口上，即对于输入值 1、2、3 和 4，它应该输出 1 和 3。我已经按以下方式覆盖了预测和一般工作方法（添加更容易调试的 printf 函数):

void test_block_impl::forecast (int noutput_items, gr_vector_int &ninput_items_required)
    {
      printf("Forcast, number of noutput_items %d\n", noutput_items);
      ninput_items_required[0] = noutput_items * 2;
      printf("Forcast, required input items %d\n", ninput_items_required[0]);
    }


int test_block_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 float *in = (const float *) input_items[0];
      float *out = (float *) output_items[0];
      int num_inputitems = ninput_items[0];

      printf("General work, number of input items %d, number of output items %d\n", num_inputitems, noutput_items);
      for (int i = 0; i < num_inputitems ; i++)
      {
        if (i % 2 == 0)
        {
          out[ i/2 ] = in[i];
          printf("out %f, in %f\n", out[i/2], in[i]);
        }
      }
      consume_each (noutput_items*2); // or should I put num_inputitems

      // Tell runtime system how many output items we produced.
      return noutput_items*2;
    }

我也在构造函数中调用了set_max_noutput_items(2)。我希望预测函数会告诉块它需要大小为 4 的输入，然后一般工作函数将处理这些项目并仅每隔一秒输出一次。

不幸的是，在编写 Python 测试后，我得到了很多意想不到的结果，所以我认为我没有正确理解缓冲区的概念。对于测试：

    src_data = array ( [ 1.0, 2.0, 3.0, 4.0, 5.0, 6.0])

    expected_result1 = (1.0, 3.0, 5.0)

    src = blocks.vector_source_f(src_data)
    dmx = tutorial.test_block(number)
    dst1 = blocks.vector_sink_f()

    self.tb.connect(src, dmx)
    self.tb.connect(dmx, dst1)
    self.tb.run (4)

我收到了：

4: Forcast, number of noutput_items 2
4: Forcast, required input items 4
4: Forcast, number of noutput_items 1
4: Forcast, required input items 2
4: Forcast, number of noutput_items 2
4: Forcast, required input items 4
4: General work, number of input items 6, number of output items 2
4: out 1.000000, in 1.000000
4: out 3.000000, in 3.000000
4: out 5.000000, in 5.000000
4: Forcast, number of noutput_items 2
4: Forcast, required input items 4
4: Forcast, number of noutput_items 1
4: Forcast, required input items 2
4: General work, number of input items 2, number of output items 1
4: out 5.000000, in 5.000000
4: Forcast, number of noutput_items 2
4: Forcast, required input items 4
4: Forcast, number of noutput_items 1
4: Forcast, required input items 2
4: (1.0, 3.0, 5.0, 0.0, 5.0, 0.0)

如果有人能帮助我理解 GNU Radio 从哪里获得这些零以及为什么它按顺序调用预测方法？ :)

Answer 1

我意识到 general_work 应该 return 在此方法调用中产生的输出数量，并且 consume 应该接收它将处理的数量或输入元素。因此，在我获得预期结果的情况下，我应该使用 ninput_items (consume_each(ninput_items)) 和 return ninput_items/2

调用 consume_each

GNU Radio 输入和输出缓冲区如何工作？

How do GNU Radio input and output buffers work?

python

c++

buffer

gnuradio