base_renderer.hpp

#pragma once

#include "drape_frontend/message_acceptor.hpp"
#include "drape_frontend/threads_commutator.hpp"
#include "drape_frontend/tile_utils.hpp"

#include "drape/oglcontextfactory.hpp"

#include "base/thread.hpp"

#include "std/atomic.hpp"
#include "std/condition_variable.hpp"
#include "std/function.hpp"
#include "std/mutex.hpp"

namespace df
{

class BaseRenderer : public MessageAcceptor
{
public:
  using TCompletionHandler = function<void()>;

  BaseRenderer(ThreadsCommutator::ThreadName name,
               dp::RefPointer<ThreadsCommutator> commutator,
               dp::RefPointer<dp::OGLContextFactory> oglcontextfactory);

  void SetRenderingEnabled(bool const isEnabled);

protected:
  dp::RefPointer<ThreadsCommutator> m_commutator;
  dp::RefPointer<dp::OGLContextFactory> m_contextFactory;

  void StartThread();
  void StopThread();

  void CheckRenderingEnabled();
  void ProcessStopRenderingMessage();

  virtual unique_ptr<threads::IRoutine> CreateRoutine() = 0;

private:
  bool CanReceiveMessage() override;

private:
  threads::Thread m_selfThread;
  ThreadsCommutator::ThreadName m_threadName;

  mutex m_renderingEnablingMutex;
  condition_variable m_renderingEnablingCondition;
  atomic<bool> m_isEnabled;
  TCompletionHandler m_renderingEnablingCompletionHandler;
  bool m_wasNotified;

  void SetRenderingEnabled(bool const isEnabled, TCompletionHandler completionHandler);
  void Notify();
  void WakeUp();
};

} // namespace df