BaseGlobalDeviceState.cpp

// Copyright 2022-2024 The Khronos Group
// SPDX-License-Identifier: Apache-2.0

#include "BaseGlobalDeviceState.h"

namespace helium {

BaseGlobalDeviceState::BaseGlobalDeviceState(ANARIDevice d)
{
  messageFunction = [&, d](ANARIStatusSeverity severity,
                        const std::string &msg,
                        anari::DataType objType,
                        const void *obj) {
    if (!statusCB)
      return;
    statusCB(statusCBUserPtr,
        d,
        (ANARIObject)obj,
        objType,
        severity,
        severity <= ANARI_SEVERITY_WARNING ? ANARI_STATUS_NO_ERROR
                                           : ANARI_STATUS_UNKNOWN_ERROR,
        msg.c_str());
  };
}

void BaseGlobalDeviceState::commitBufferAddObject(BaseObject *o)
{
  std::lock_guard<std::mutex> guard(m_mutex);
  m_commitBuffer.addObject(o);
}

void BaseGlobalDeviceState::commitBufferFlush()
{
  std::lock_guard<std::mutex> guard(m_mutex);
  m_commitBuffer.flush();
}

void BaseGlobalDeviceState::commitBufferClear()
{
  std::lock_guard<std::mutex> guard(m_mutex);
  m_commitBuffer.clear();
}

TimeStamp BaseGlobalDeviceState::commitBufferLastFlush() const
{
  std::lock_guard<std::mutex> guard(m_mutex);
  return m_commitBuffer.lastFlush();
}

} // namespace helium