Method queueNextStandardChunk

io/LasReader.cpp:574–613

}

void LasReader::queueNextStandardChunk()
{
    const uint64_t chunkSize = 50'000;

    if (d->nextFetchPoint >= d->end)
        return;

    int chunk = d->nextFetchChunk;
    uint64_t start = d->nextFetchPoint;
    uint64_t count = (std::min)(chunkSize, d->end - start);
    d->pool.add([this, chunk, count, start]()
    {
        LasStreamPtr lasStream = createStream();
        std::istream& in(*lasStream);

        las::TilePtr tile = std::make_unique<las::Tile>(chunk, count * d->header.pointSize);
        in.seekg(d->header.pointOffset + start * d->header.pointSize);
        in.read(tile->data(), tile->size());

        {
            std::unique_lock l(d->mutex);
            for (las::TilePtr& t : d->tiles)
                if (!t)
                {
                    t = std::move(tile);
                    goto done;
                }
            d->tiles.push_back(std::move(tile));
        }
        done:
        d->processedCv.notify_one();
    });

    // This check is just to prevent overflow.
    if (d->nextFetchPoint > (std::numeric_limits<uint64_t>::max)() - chunkSize)
        d->nextFetchPoint = d->end;
    else
        d->nextFetchPoint += chunkSize;
    d->nextFetchChunk++;
}

void LasReader::readExtraBytesVlr()
{