RasterSourceSubscription.cpp

#include "RasterSourceSubscription.h"
 
Cogs::RasterSourceSubscription::RasterSourceSubscription(RasterSourceSubscription && other)
{
  std::lock_guard<std::mutex> lock(other.responseMutex);
 
  std::swap(rasterSource, other.rasterSource);
  std::swap(responses, other.responses);
}
 
void Cogs::RasterSourceSubscription::setup(RasterSourcePtr source)
{
  assert(!rasterSource && "Raster source already setup.");
 
  std::lock_guard<std::mutex> lock(source->subscriberMutex);
 
  source->addSubscriber(this);
 
  rasterSource = source;
}
 
void Cogs::RasterSourceSubscription::teardown()
{
  if (rasterSource) {
    std::lock_guard<std::mutex> lock(rasterSource->subscriberMutex);
 
    rasterSource->removeSubscriber(this);
  }
 
  rasterSource.reset();
}
 
void Cogs::RasterSourceSubscription::postResponse(const TileLoadResponse & response)
{
  std::lock_guard<std::mutex> lock(responseMutex);
 
  responses.push_back(response);
}
 
void Cogs::RasterSourceSubscription::getResponses(std::vector<TileLoadResponse> & results, size_t maxResponses)
{
  std::lock_guard<std::mutex> lock(responseMutex);
 
  if (responses.size() < maxResponses) {
    std::swap(responses, results);
  } else {
    results.reserve(maxResponses);
 
    auto i = maxResponses;
    while (i--) {
      results.push_back(responses.back());
      responses.pop_back();
    }
  }
}