Method myTick

src/core/vectorProcessor.cpp:290–394

}

eTickResult cVectorProcessor::myTick(long long t)
{
  SMILE_IDBG(4,"tick # %i, running vector processor",t);

  if (!(writer_->checkWrite(1))) return TICK_DEST_NO_SPACE;
  // printf("'%s' checkwrite ok\n",getInstName());

  // get next frame from dataMemory
  cVector *vec = reader_->getNextFrame();
  int i;
  int iO = 0;
  int toSet = 1;
  int ret = 1;
  int res;

  if (vecO == NULL)
    vecO = new cVector(No);
  if (customVecProcess(vec, vecO)) {
    if (vec != NULL) vecO->setTimeMeta(vec->tmeta);
    // save the output to dataMemory
    writer_->setNextFrame(vecO);
    return TICK_SUCCESS;
  }

  // NOTE: this might break upsamling components if they rely on flush??
  if (vec == NULL && !isEOI())
    return TICK_SOURCE_NOT_AVAIL;

  FLOAT_DMEM *dFi = NULL;
  if (vec != NULL) {
    dFi = vec->data;
  }
  FLOAT_DMEM *dFo = vecO->data;
  if (processArrayFields == 2) {
    if (Nfo != Nfi) {
      SMILE_IERR(1, "Number of input fields (%i) != Number of output fields (%i) - "
          "not yet supported in mode processArrayFields=2 (transposed).", Nfi, Nfo);
      COMP_ERR("aborting");
    }
    for (i = 0; i < fieldLength_; i++) {
      if (vec != NULL) {
        // assemble bufTransposedInput from dFi buffer (vec->data)
        for (int j = 0; j < Nfi; j++) {
          bufTransposeInput_[j] = dFi[j * fieldLength_ + i];
        }
        res = processVector(bufTransposeInput_, bufTransposeOutput_,
            Nfi, Nfo, i);
      } else {
        res = flushVector(bufTransposeOutput_, Nfi, Nfo, i);
      }
      if (res == 0)
        ret = 0;
      else
        if (res < 0)
          toSet = 0;
      // save bufTransposedOutput to dFo buffer (vecO->data)
      for (int j = 0; j < Nfo; j++) {
        dFo[j * fieldLength_ + i] = bufTransposeOutput_[j];