Method load

io/EptReader.cpp:532–582

Start a thread to read an overlap. When the data has been read, stick the tile on the queue and notify the main thread.

// Start a thread to read an overlap.  When the data has been read,
// stick the tile on the queue and notify the main thread.
void EptReader::load(const ept::Overlap& overlap)
{
    using namespace std::chrono_literals;

    m_p->pool->add([this, overlap]()
        {
            // Read the tile.
            ept::TileContents tile(overlap, *m_p->info, *m_p->connector, m_p->addons);

            tile.read();

            if (tile.error().size())
            {
                log()->get(LogLevel::Warning) << "Failed to read " <<
                    tile.key().toString() << ": " << tile.error() << std::endl;
            }

            if (tile.error().empty() || !m_args->m_ignoreUnreadable)
            {
                // Put the tile on the output queue.  Note that if the tile has
                // an error and ignoreUnreadable isn't set, this will be fatal
                // but that will occur downstream outside of this pool thread.

                while (!m_p->done)
                {
                    {
                        std::lock_guard<std::mutex> l(m_p->mutex);
                        if (m_p->contents.size() < m_p->pool->numThreads())
                        {
                            m_p->contents.push(std::move(tile));
                            break;
                        }
                    }
                    // No room on queue, sleep. Could do a condition variable but that's
                    // more complex and probably makes no difference in most cases where
                    // this would come up.
                    std::this_thread::sleep_for(50ms);
                }
            }
            else
            {
                // If the tile has an error, and the ignoreUnreadable option is
                // set, then we just skip this tile.
                std::lock_guard<std::mutex> l(m_p->mutex);
                --m_tileCount;
            }

            m_p->contentsCv.notify_one();
        }
    );
}


void EptReader::ready(PointTableRef table)