Method initStep

src_cpp/yaafe-core/Engine.cpp:257–306

  }

  inline bool Engine::initStep(ProcessFlow::Node& node) {
    if (node.v.m_id == "Input") {
      node.v.m_component = NULL;
      StreamInfo outStreamInfo;
      outStreamInfo.size = 1;
      outStreamInfo.sampleStep = 1;
      outStreamInfo.frameLength = 1;
      // get samplerate
      ParameterMap::const_iterator it = node.v.m_params.find("SampleRate");
      if (it==node.v.m_params.end()) {
        cerr << "WARNING: no SampleRate parameter specified for input !" << endl;
        outStreamInfo.sampleRate = 44100;
      } else {
        outStreamInfo.sampleRate = atof(it->second.c_str());
      }
      node.v.m_output.add(new OutputBuffer(outStreamInfo));
      return true;
    }
    Ports<StreamInfo> inStreamInfo;
    for (ProcessFlow::LinkListCIt it=node.sources().begin();it!=node.sources().end();it++)
    {
      const ProcessFlow::Link* l = *it;
      const Ports<OutputBuffer*>& outInfo = l->source->v.m_output;
      //		if (outInfo.size()!=1) {
      //			cerr << "ERROR: node " << node.v.m_id << " has multiple output stream info !" << endl;
      //			return false;
      //		}
      inStreamInfo.add(l->targetInputPort, outInfo[l->sourceOutputPort].data->info());
    }
    if (node.v.m_id == "Output") {
      node.v.m_component = NULL;
    } else {
      node.v.m_component = node.v.m_pool->get(node.v.m_id,node.v.m_params,inStreamInfo);
      if (!node.v.m_component) {
        cerr << "ERROR: cannot initialize component " << node.v.m_id << " !" << endl;
        return false;
      }
    }
    for (int i=0;i<node.sources().size();i++)
    {
      const ProcessFlow::Link* l = node.sources()[i];
      InputBuffer* source = new InputBuffer(l->source->v.m_output[l->sourceOutputPort].data->info());
      l->source->v.m_output[l->sourceOutputPort].data->bindInputBuffer(source);
      node.v.m_input.add(l->targetInputPort, source);
    }
    if (node.v.m_id != "Output") {
      node.v.m_output = node.v.m_component->getOutStreamInfo().map(buildOutputBufferFromInfo);
    }
    return true;
  }

  inline bool Engine::resetStep(ProcessFlow::Node& step) {
    for (int i=0;i<step.v.m_input.size();++i)