Method LoadOrInitChunks

libs/platform/chunks_download_strategy.cpp:111–161

}

int64_t ChunksDownloadStrategy::LoadOrInitChunks(std::string const & fName, int64_t fileSize, int64_t chunkSize)
{
  ASSERT(fileSize > 0, ());

  if (Platform::IsFileExistsByFullPath(fName))
  {
    try
    {
      FileReader r(fName);
      ReaderSource<FileReader> src(r);

      int64_t const readSize = ReadVarInt<int64_t>(src);
      if (readSize == fileSize)
      {
        // Load chunks.
        uint64_t const size = src.Size();
        int const stSize = sizeof(ChunkT);
        auto const count = static_cast<size_t>(size / stSize);
        ASSERT_EQUAL(size, stSize * count, ());

        m_chunks.resize(count);
        src.Read(&m_chunks[0], stSize * count);

        // Reset status "downloading" to "free".
        int64_t downloadedSize = 0;
        size_t completed = 0;
        for (size_t i = 0; i < count - 1; ++i)
        {
          if (m_chunks[i].m_status != CHUNK_COMPLETE)
            m_chunks[i].m_status = CHUNK_FREE;
          else
          {
            downloadedSize += (m_chunks[i + 1].m_pos - m_chunks[i].m_pos);
            ++completed;
          }
        }
        LOG(LINFO, ("Resumed file: downloaded", downloadedSize / 1024 / 1024, "out of", fileSize / 1024 / 1024,
                    "MB; completed chunks", completed, "out of", count - 1));

        return downloadedSize;
      }
    }
    catch (FileReader::Exception const & e)
    {
      LOG(LDEBUG, (e.Msg()));
    }
  }

  InitChunks(fileSize, chunkSize);
  return 0;
}

std::string ChunksDownloadStrategy::ChunkFinished(bool success, RangeT const & range)
{