push_sample()

void datrw::tsoft::Channeldata::push_sample	(	const libtime::TAbsoluteTime &	time,
		const double &	value,
		const double &	undetval,
		const libtime::TRelativeTime &	dt,
		const ReaderConfig &	rc,
		const bool &	debug = false
	)

push a sample

Definition at line 228 of file tsoftdata.cc.

References datrw::tsoft::Datasequence::append(), datrw::tsoft::ReaderConfig::bridgeflagvalue, datrw::tsoft::ReaderConfig::bridgesamples, datrw::tsoft::ReaderConfig::bridgetime, datrw::tsoft::Datasequence::date(), DATRW_report_assert, datrw::hpmo::dt(), datrw::tsoft::ReaderConfig::flagbridged, datrw::tsoft::ReaderConfig::flagvalue, flushcollector(), datrw::tsoft::Datasequence::interval(), datrw::tsoft::ReaderConfig::keepundetval, Mcollector, datrw::tsoft::Datasequence::nsamples(), datrw::tsoft::ReaderConfig::setundetval, and datrw::tsoft::Datasequence::timeofnextsample().

Referenced by datrw::tsoft::Datacontainer::push_data().

    {
      // copy value to allow modification
      double value=invalue;
      libtime::TAbsoluteTime time=intime;
      // replace flag value if requested
      if ((value == undetval) && (rc.setundetval))
      {
        value=rc.flagvalue;
      }
      // handle value if valid or if UNDETVAL values are requested to be read
      if ((value != undetval) || (rc.keepundetval))
      {
        if (debug)
        {
          std::cout << "  yes, take this sample" << std::endl;
        }
        // check, whether collector is already in use
        bool insequence = (Mcollector.nsamples() > 0);
        // bridge sample if requested
        if (rc.bridgesamples)
        {
          if (time == rc.bridgetime)
          {
            if (insequence)
            {
              time = Mcollector.timeofnextsample();
              if (rc.flagbridged)
              {
                value=rc.bridgeflagvalue;
              }
            }
            else
            {
              DATRW_report_assert(insequence,
                "WARNING (Channeldata::push_sample): TSOFT reading\n"
                "User requested to bridge data entries labelled with time: "
                << rc.bridgetime.timestring() << "\n"
                << "This time label is present in the first entry of the"
                << "input data.\n"
                << "First input lines cannot be bridged.");
            }
          }
        }
        // if collector is in use, then check is current value matches
        if (insequence)
        {
          insequence = ((time == Mcollector.timeofnextsample(debug))
            && (dt == Mcollector.interval()));
        }
        // if current value does not match: flush collector and start new
        if (!insequence)
        {
          this->flushcollector();
          Mcollector.date(time);
          Mcollector.interval(dt);
        }
        Mcollector.append(value);
      }
    } // void Channeldata::push_sample

Here is the call graph for this function:

Here is the caller graph for this function: