Method run

src/libfreenect2.cpp:1551–1613

}

void Freenect2ReplayDevice::run()
{
  size_t timestamp_sequence[2] = {0};
    
  for (size_t i = 0; i < frame_filenames_.size() && running_; i++)
  {
    std::string frame = frame_filenames_[i];

    if(parseFrameFilename(frame, timestamp_sequence) == false)
    {
      LOG_ERROR << "could not parse replay frame filename " << frame << ", skipping...";
      continue;
    }

    if (hasSuffix(frame, ".depth"))
    {
      std::ifstream fd(frame.c_str());
      
      if(!fd)
      {
        LOG_ERROR << "failed to open replay frame: " << frame << ", skipping...";
        continue;
      }

      fd.seekg(0, fd.end);
      size_t length = fd.tellg();
      fd.seekg(0, fd.beg);

      if(length != buffer_size_)
      {
        LOG_ERROR << "file length: " << length
                  << "exceeds depth image buffer size: "
                  << buffer_size_ << "; skipping...";
        continue;
      }

      fd.read(reinterpret_cast<char*>(packet_.memory->data), length);
      if(!fd || (size_t)fd.gcount() != length)
      {
        LOG_ERROR << "failed to read replay frame: " << frame << ": "
                  << fd.gcount() << " vs. " << length << " bytes";
        continue;
      }

      if(pipeline_->getDepthPacketProcessor()->ready())
      {
        packet_.timestamp = timestamp_sequence[0];
        packet_.sequence = timestamp_sequence[1];
        packet_.buffer = packet_.memory->data;
        packet_.buffer_length = length;

        pipeline_->getDepthPacketProcessor()->process(packet_);
        pipeline_->getDepthPacketProcessor()->allocateBuffer(packet_, buffer_size_);
      }
      else
      {
        LOG_DEBUG
          << "skipping a replay depth packet for " << frame