Files
OpenSpace/src/engine/openspaceengine.cpp

1572 lines
53 KiB
C++

/*****************************************************************************************
* *
* OpenSpace *
* *
* Copyright (c) 2014-2020 *
* *
* Permission is hereby granted, free of charge, to any person obtaining a copy of this *
* software and associated documentation files (the "Software"), to deal in the Software *
* without restriction, including without limitation the rights to use, copy, modify, *
* merge, publish, distribute, sublicense, and/or sell copies of the Software, and to *
* permit persons to whom the Software is furnished to do so, subject to the following *
* conditions: *
* *
* The above copyright notice and this permission notice shall be included in all copies *
* or substantial portions of the Software. *
* *
* THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR IMPLIED, *
* INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY, FITNESS FOR A *
* PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT *
* HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN AN ACTION OF *
* CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION WITH THE SOFTWARE *
* OR THE USE OR OTHER DEALINGS IN THE SOFTWARE. *
****************************************************************************************/
#include <openspace/engine/openspaceengine.h>
#include <openspace/openspace.h>
#include <openspace/documentation/core_registration.h>
#include <openspace/documentation/documentationengine.h>
#include <openspace/engine/configuration.h>
#include <openspace/engine/globals.h>
#include <openspace/engine/globalscallbacks.h>
#include <openspace/engine/logfactory.h>
#include <openspace/engine/moduleengine.h>
#include <openspace/engine/syncengine.h>
#include <openspace/engine/virtualpropertymanager.h>
#include <openspace/engine/windowdelegate.h>
#include <openspace/interaction/interactionmonitor.h>
#include <openspace/interaction/keybindingmanager.h>
#include <openspace/interaction/sessionrecording.h>
#include <openspace/interaction/navigationhandler.h>
#include <openspace/interaction/orbitalnavigator.h>
#include <openspace/network/parallelpeer.h>
#include <openspace/performance/performancemeasurement.h>
#include <openspace/performance/performancemanager.h>
#include <openspace/rendering/dashboard.h>
#include <openspace/rendering/dashboarditem.h>
#include <openspace/rendering/helper.h>
#include <openspace/rendering/loadingscreen.h>
#include <openspace/rendering/luaconsole.h>
#include <openspace/rendering/renderable.h>
#include <openspace/scene/assetmanager.h>
#include <openspace/scene/assetloader.h>
#include <openspace/scene/scene.h>
#include <openspace/scene/rotation.h>
#include <openspace/scene/scale.h>
#include <openspace/scene/timeframe.h>
#include <openspace/scene/lightsource.h>
#include <openspace/scene/sceneinitializer.h>
#include <openspace/scene/translation.h>
#include <openspace/scene/scenelicensewriter.h>
#include <openspace/scripting/scriptscheduler.h>
#include <openspace/scripting/scriptengine.h>
#include <openspace/util/camera.h>
#include <openspace/util/factorymanager.h>
#include <openspace/util/spicemanager.h>
#include <openspace/util/task.h>
#include <openspace/util/timemanager.h>
#include <openspace/util/transformationmanager.h>
#include <ghoul/ghoul.h>
#include <ghoul/filesystem/filesystem.h>
#include <ghoul/font/fontmanager.h>
#include <ghoul/font/fontrenderer.h>
#include <ghoul/logging/consolelog.h>
#include <ghoul/logging/logmanager.h>
#include <ghoul/logging/visualstudiooutputlog.h>
#include <ghoul/misc/profiling.h>
#include <ghoul/misc/stringconversion.h>
#include <ghoul/opengl/debugcontext.h>
#include <ghoul/opengl/shaderpreprocessor.h>
#include <ghoul/opengl/texture.h>
#include <ghoul/systemcapabilities/generalcapabilitiescomponent.h>
#include <ghoul/systemcapabilities/openglcapabilitiescomponent.h>
#include <glbinding/glbinding.h>
#include <glbinding-aux/types_to_string.h>
#include <numeric>
#include <sstream>
#if defined(_MSC_VER) && defined(OPENSPACE_ENABLE_VLD)
#include <vld.h>
#endif
#ifdef __APPLE__
#include <openspace/interaction/touchbar.h>
#endif // __APPLE__
#include "openspaceengine_lua.inl"
namespace {
constexpr const char* _loggerCat = "OpenSpaceEngine";
constexpr const int CacheVersion = 1;
constexpr const char* ProfileToSceneConverter
= "${BASE}/scripts/convert_profile_to_scene.lua";
} // namespace
namespace openspace {
class Scene;
OpenSpaceEngine::OpenSpaceEngine() {
FactoryManager::initialize();
FactoryManager::ref().addFactory(
std::make_unique<ghoul::TemplateFactory<Renderable>>(),
"Renderable"
);
FactoryManager::ref().addFactory(
std::make_unique<ghoul::TemplateFactory<Translation>>(),
"Translation"
);
FactoryManager::ref().addFactory(
std::make_unique<ghoul::TemplateFactory<Rotation>>(),
"Rotation"
);
FactoryManager::ref().addFactory(
std::make_unique<ghoul::TemplateFactory<Scale>>(),
"Scale"
);
FactoryManager::ref().addFactory(
std::make_unique<ghoul::TemplateFactory<TimeFrame>>(),
"TimeFrame"
);
FactoryManager::ref().addFactory(
std::make_unique<ghoul::TemplateFactory<LightSource>>(),
"LightSource"
);
FactoryManager::ref().addFactory(
std::make_unique<ghoul::TemplateFactory<Task>>(),
"Task"
);
FactoryManager::ref().addFactory(
std::make_unique<ghoul::TemplateFactory<ResourceSynchronization>>(),
"ResourceSynchronization"
);
FactoryManager::ref().addFactory(
std::make_unique<ghoul::TemplateFactory<DashboardItem>>(),
"DashboardItem"
);
SpiceManager::initialize();
TransformationManager::initialize();
}
OpenSpaceEngine::~OpenSpaceEngine() {} // NOLINT
void OpenSpaceEngine::registerPathTokens() {
LTRACE("OpenSpaceEngine::initialize(begin)");
// Registering Path tokens. If the BASE path is set, it is the only one that will
// overwrite the default path of the cfg directory
using T = std::string;
for (const std::pair<const T, T>& path : global::configuration.pathTokens) {
std::string fullKey = ghoul::filesystem::FileSystem::TokenOpeningBraces +
path.first +
ghoul::filesystem::FileSystem::TokenClosingBraces;
LDEBUG(fmt::format("Registering path {}: {}", fullKey, path.second));
const bool overrideBase = (fullKey == "${BASE}");
if (overrideBase) {
LINFO(fmt::format("Overriding base path with '{}'", path.second));
}
const bool overrideTemporary = (fullKey == "${TEMPORARY}");
using Override = ghoul::filesystem::FileSystem::Override;
FileSys.registerPathToken(
std::move(fullKey),
std::move(path.second),
Override(overrideBase || overrideTemporary)
);
}
LTRACE("OpenSpaceEngine::initialize(end)");
}
void OpenSpaceEngine::initialize() {
ZoneScoped
LTRACE("OpenSpaceEngine::initialize(begin)");
global::initialize();
const std::string versionCheckUrl = global::configuration.versionCheckUrl;
if (!versionCheckUrl.empty()) {
global::versionChecker.requestLatestVersion(versionCheckUrl);
}
std::string cacheFolder = absPath("${CACHE}");
if (global::configuration.usePerSceneCache) {
std::string scene = global::configuration.asset;
cacheFolder += "-" + ghoul::filesystem::File(scene).baseName();
LINFO(fmt::format("Old cache: {}", absPath("${CACHE}")));
LINFO(fmt::format("New cache: {}", cacheFolder));
FileSys.registerPathToken(
"${CACHE}",
cacheFolder,
ghoul::filesystem::FileSystem::Override::Yes
);
}
// Create directories that doesn't exist
for (const std::string& token : FileSys.tokens()) {
if (!FileSys.directoryExists(token)) {
std::string p = absPath(token);
FileSys.createDirectory(p, ghoul::filesystem::FileSystem::Recursive::Yes);
}
}
try {
FileSys.createCacheManager(cacheFolder, CacheVersion);
}
catch (const ghoul::RuntimeError& e) {
LFATAL("Could not create Cache Manager");
LFATALC(e.component, e.message);
}
// Initialize the requested logs from the configuration file
// We previously initialized the LogManager with a console log to provide some logging
// until we know which logs should be added
if (ghoul::logging::LogManager::isInitialized()) {
ghoul::logging::LogManager::deinitialize();
}
ghoul::logging::LogLevel level = ghoul::from_string<ghoul::logging::LogLevel>(
global::configuration.logging.level
);
bool immediateFlush = global::configuration.logging.forceImmediateFlush;
using ImmediateFlush = ghoul::logging::LogManager::ImmediateFlush;
ghoul::logging::LogManager::initialize(level, ImmediateFlush(immediateFlush));
LogMgr.addLog(std::make_unique<ghoul::logging::ConsoleLog>());
for (const ghoul::Dictionary& log : global::configuration.logging.logs) {
try {
LogMgr.addLog(createLog(log));
}
catch (const documentation::SpecificationError& e) {
LERROR("Failed loading of log");
for (const documentation::TestResult::Offense& o : e.result.offenses) {
LERRORC(o.offender, ghoul::to_string(o.reason));
}
for (const documentation::TestResult::Warning& w : e.result.warnings) {
LWARNINGC(w.offender, ghoul::to_string(w.reason));
}
throw;
}
}
#ifdef WIN32
if (IsDebuggerPresent()) {
LogMgr.addLog(std::make_unique<ghoul::logging::VisualStudioOutputLog>());
}
#endif // WIN32
#ifndef GHOUL_LOGGING_ENABLE_TRACE
LogLevel level = ghoul::logging::levelFromString(_configuration->logging.level);
if (level == ghoul::logging::LogLevel::Trace) {
LWARNING(
"Desired logging level is set to 'Trace' but application was " <<
"compiled without Trace support"
);
}
#endif // GHOUL_LOGGING_ENABLE_TRACE
LINFOC("OpenSpace Version", std::string(OPENSPACE_VERSION_STRING_FULL));
LINFOC("Commit", std::string(OPENSPACE_GIT_FULL));
// Register modules
global::moduleEngine.initialize(global::configuration.moduleConfigurations);
// After registering the modules, the documentations for the available classes
// can be added as well
for (OpenSpaceModule* m : global::moduleEngine.modules()) {
for (const documentation::Documentation& doc : m->documentations()) {
DocEng.addDocumentation(doc);
}
}
DocEng.addDocumentation(configuration::Configuration::Documentation);
// Register the provided shader directories
ghoul::opengl::ShaderPreprocessor::addIncludePath(absPath("${SHADERS}"));
// Register Lua script functions
LDEBUG("Registering Lua libraries");
registerCoreClasses(global::scriptEngine);
// Convert profile to scene file (if was provided in configuration file)
if (!global::configuration.profile.empty()) {
LINFO(
fmt::format("Run Lua script to convert {}.profile to scene",
global::configuration.profile)
);
ghoul::lua::LuaState lState;
// We can't use the absPath function here because we pass the path into the Lua
// function, which requires additional escaping
std::string inputProfilePath = generateFilePath("${ASSETS}");
std::string outputScenePath = generateFilePath("${TEMPORARY}");
std::string setProfileFilenameInLuaState = fmt::format(R"(
openspace = {{}}
openspace.profile = {{}}
function openspace.profile.getFilename()
return "{}.profile"
end
function openspace.profile.getProfileInputPath()
return "{}"
end
function openspace.profile.getSceneOutputPath()
return "{}"
end
)",
global::configuration.profile,
inputProfilePath,
outputScenePath
);
ghoul::lua::runScript(lState, setProfileFilenameInLuaState);
ghoul::lua::runScriptFile(lState, absPath(ProfileToSceneConverter));
// Set asset name to that of the profile because a new scene file will be
// created with that name, and also because the profile name will override
// an asset name if both are provided.
global::configuration.asset =
absPath("${TEMPORARY}/") + global::configuration.profile;
}
// Set up asset loader
std::unique_ptr<SynchronizationWatcher> w =
std::make_unique<SynchronizationWatcher>();
SynchronizationWatcher* rawWatcher = w.get();
global::openSpaceEngine._assetManager = std::make_unique<AssetManager>(
std::make_unique<AssetLoader>(
global::scriptEngine.luaState(),
rawWatcher,
FileSys.absPath("${ASSETS}")
),
std::move(w)
);
global::scriptEngine.addLibrary(global::openSpaceEngine._assetManager->luaLibrary());
for (OpenSpaceModule* module : global::moduleEngine.modules()) {
global::scriptEngine.addLibrary(module->luaLibrary());
for (scripting::LuaLibrary& l : module->luaLibraries()) {
global::scriptEngine.addLibrary(l);
}
}
global::scriptEngine.initialize();
// To be concluded
_documentationJson.clear();
_documentationJson += "{\"documentation\":[";
writeStaticDocumentation();
_shutdown.waitTime = global::configuration.shutdownCountdown;
global::navigationHandler.initialize();
global::renderEngine.initialize();
for (const std::function<void()>& func : global::callback::initialize) {
ZoneScopedN("[Module] initialize")
func();
}
global::openSpaceEngine._assetManager->initialize();
scheduleLoadSingleAsset(global::configuration.asset);
LTRACE("OpenSpaceEngine::initialize(end)");
}
std::string OpenSpaceEngine::generateFilePath(std::string openspaceRelativePath) {
std::string path = absPath(openspaceRelativePath);
// Needs to handle either windows (which seems to require double back-slashes)
// or unix path slashes.
const std::string search = "\\";
const std::string replace = "\\\\";
if (path.find(search) != std::string::npos) {
size_t start_pos = 0;
while ((start_pos = path.find(search, start_pos)) != std::string::npos) {
path.replace(start_pos, search.length(), replace);
start_pos += replace.length();
}
path.append(replace);
}
else {
path.append("/");
}
return path.append(global::configuration.profile);
}
void OpenSpaceEngine::initializeGL() {
ZoneScoped
LTRACE("OpenSpaceEngine::initializeGL(begin)");
glbinding::Binding::initialize(global::windowDelegate.openGLProcedureAddress);
//glbinding::Binding::useCurrentContext();
rendering::helper::initialize();
// clear the screen so the user doesn't have to see old buffer contents left on the
// graphics card
LDEBUG("Clearing all Windows");
global::windowDelegate.clearAllWindows(glm::vec4(0.f, 0.f, 0.f, 1.f));
LDEBUG("Adding system components");
// Detect and log OpenCL and OpenGL versions and available devices
SysCap.addComponent(
std::make_unique<ghoul::systemcapabilities::GeneralCapabilitiesComponent>()
);
SysCap.addComponent(
std::make_unique<ghoul::systemcapabilities::OpenGLCapabilitiesComponent>()
);
// @BUG: This will call OpenGL functions, should it should be in the initializeGL
LDEBUG("Detecting capabilities");
SysCap.detectCapabilities();
using Verbosity = ghoul::systemcapabilities::SystemCapabilitiesComponent::Verbosity;
Verbosity verbosity = ghoul::from_string<Verbosity>(
global::configuration.logging.capabilitiesVerbosity
);
SysCap.logCapabilities(verbosity);
// Check the required OpenGL versions of the registered modules
ghoul::systemcapabilities::Version version =
global::moduleEngine.requiredOpenGLVersion();
LINFO(fmt::format("Required OpenGL version: {}", ghoul::to_string(version)));
if (OpenGLCap.openGLVersion() < version) {
throw ghoul::RuntimeError(
"An included module required a higher OpenGL version than is supported on "
"this system",
"OpenSpaceEngine"
);
}
{
// Check the available OpenGL extensions against the required extensions
using OCC = ghoul::systemcapabilities::OpenGLCapabilitiesComponent;
for (OpenSpaceModule* m : global::moduleEngine.modules()) {
for (const std::string& ext : m->requiredOpenGLExtensions()) {
if (!SysCap.component<OCC>().isExtensionSupported(ext)) {
LFATAL(fmt::format(
"Module {} required OpenGL extension {} which is not available "
"on this system. Some functionality related to this module will "
"probably not work.", m->guiName(), ext
));
}
}
}
}
loadFonts();
_loadingScreen = std::make_unique<LoadingScreen>(
LoadingScreen::ShowMessage(global::configuration.loadingScreen.isShowingMessages),
LoadingScreen::ShowNodeNames(
global::configuration.loadingScreen.isShowingNodeNames
),
LoadingScreen::ShowProgressbar(
global::configuration.loadingScreen.isShowingProgressbar
)
);
_loadingScreen->render();
LTRACE("OpenSpaceEngine::initializeGL::Console::initialize(begin)");
try {
global::luaConsole.initialize();
}
catch (ghoul::RuntimeError& e) {
LERROR("Error initializing Console with error:");
LERRORC(e.component, e.message);
}
LTRACE("OpenSpaceEngine::initializeGL::Console::initialize(end)");
LTRACE("OpenSpaceEngine::initializeGL::DebugContext(begin)");
bool debugActive = global::configuration.openGLDebugContext.isActive;
// Debug output is not available before 4.3
const ghoul::systemcapabilities::Version minVersion = { 4, 3, 0 };
if (debugActive && OpenGLCap.openGLVersion() < minVersion) {
LINFO("OpenGL Debug context requested, but insufficient version available");
debugActive = false;
}
if (debugActive) {
using namespace ghoul::opengl::debug;
bool synchronous = global::configuration.openGLDebugContext.isSynchronous;
setDebugOutput(DebugOutput(debugActive), SynchronousOutput(synchronous));
for (const configuration::Configuration::OpenGLDebugContext::IdentifierFilter&f :
global::configuration.openGLDebugContext.identifierFilters)
{
setDebugMessageControl(
ghoul::from_string<Source>(f.source),
ghoul::from_string<Type>(f.type),
{ f.identifier },
Enabled::No
);
}
for (const std::string& sev :
global::configuration.openGLDebugContext.severityFilters)
{
setDebugMessageControl(
Source::DontCare,
Type::DontCare,
ghoul::from_string<Severity>(sev),
Enabled::No
);
}
auto callback = [](Source source, Type type, Severity severity,
unsigned int id, std::string message) -> void
{
const std::string s = ghoul::to_string(source);
const std::string t = ghoul::to_string(type);
const std::string category =
"OpenGL (" + s + ") [" + t + "] {" + std::to_string(id) + "}";
switch (severity) {
case Severity::High:
LERRORC(category, message);
break;
case Severity::Medium:
LWARNINGC(category, message);
break;
case Severity::Low:
LINFOC(category, message);
break;
case Severity::Notification:
LDEBUGC(category, message);
break;
default:
throw ghoul::MissingCaseException();
}
};
ghoul::opengl::debug::setDebugCallback(callback);
}
LTRACE("OpenSpaceEngine::initializeGL::DebugContext(end)");
// The ordering of the KeyCheckOpenGLState and KeyLogEachOpenGLCall are important as
// the callback mask in glbinding is stateful for each context, and since
// KeyLogEachOpenGLCall is more specific, we want it to be able to overwrite the
// state from KeyCheckOpenGLState
if (global::configuration.isCheckingOpenGLState) {
using namespace glbinding;
// Infinite loop -- welcome to the danger zone
setCallbackMaskExcept(CallbackMask::After, { "glGetError" });
setAfterCallback([](const FunctionCall& f) {
const GLenum error = glGetError();
switch (error) {
case GL_NO_ERROR:
break;
case GL_INVALID_ENUM:
LERRORC(
"OpenGL Invalid State",
fmt::format("Function {}: GL_INVALID_ENUM", f.function->name())
);
break;
case GL_INVALID_VALUE:
LERRORC(
"OpenGL Invalid State",
fmt::format("Function {}: GL_INVALID_VALUE", f.function->name())
);
break;
case GL_INVALID_OPERATION:
LERRORC(
"OpenGL Invalid State",
fmt::format(
"Function {}: GL_INVALID_OPERATION", f.function->name()
));
break;
case GL_INVALID_FRAMEBUFFER_OPERATION:
LERRORC(
"OpenGL Invalid State",
fmt::format(
"Function {}: GL_INVALID_FRAMEBUFFER_OPERATION",
f.function->name()
)
);
break;
case GL_OUT_OF_MEMORY:
LERRORC(
"OpenGL Invalid State",
fmt::format("Function {}: GL_OUT_OF_MEMORY", f.function->name())
);
break;
default:
LERRORC(
"OpenGL Invalid State",
fmt::format("Unknown error code: {0:x}", static_cast<int>(error))
);
}
});
}
if (global::configuration.isLoggingOpenGLCalls) {
using namespace ghoul::logging;
LogLevel lvl = ghoul::from_string<LogLevel>(global::configuration.logging.level);
if (lvl > LogLevel::Trace) {
LWARNING(
"Logging OpenGL calls is enabled, but the selected log level does "
"not include TRACE, so no OpenGL logs will be printed");
}
else {
using namespace glbinding;
setCallbackMask(CallbackMask::After | CallbackMask::ParametersAndReturnValue);
glbinding::setAfterCallback([](const glbinding::FunctionCall& call) {
std::string arguments = std::accumulate(
call.parameters.begin(),
call.parameters.end(),
std::string("("),
[](std::string a, const std::unique_ptr<AbstractValue>& v) {
std::stringstream s;
s << v.get();
return a + s.str() + ", ";
}
);
// Remove the final ", "
arguments = arguments.substr(0, arguments.size() - 2) + ")";
std::string returnValue;
std::stringstream s;
if (call.returnValue) {
s << call.returnValue.get();
returnValue = " -> " + s.str();
}
LTRACEC(
"OpenGL",
call.function->name() + std::move(arguments) + std::move(returnValue)
);
});
}
}
LDEBUG("Initializing Rendering Engine");
global::renderEngine.initializeGL();
global::moduleEngine.initializeGL();
for (const std::function<void()>& func : global::callback::initializeGL) {
ZoneScopedN("[Module] initializeGL")
func();
}
LINFO("Finished initializing OpenGL");
LTRACE("OpenSpaceEngine::initializeGL(end)");
}
void OpenSpaceEngine::scheduleLoadSingleAsset(std::string assetPath) {
_hasScheduledAssetLoading = true;
_scheduledAssetPathToLoad = std::move(assetPath);
}
void OpenSpaceEngine::loadSingleAsset(const std::string& assetPath) {
ZoneScoped
LTRACE("OpenSpaceEngine::loadSingleAsset(begin)");
global::windowDelegate.setBarrier(false);
global::windowDelegate.setSynchronization(false);
defer {
global::windowDelegate.setSynchronization(true);
global::windowDelegate.setBarrier(true);
};
if (assetPath.empty()) {
return;
}
if (_scene) {
ZoneScopedN("Reset scene")
global::syncEngine.removeSyncables(global::timeManager.getSyncables());
if (_scene && _scene->camera()) {
global::syncEngine.removeSyncables(_scene->camera()->getSyncables());
}
global::renderEngine.setScene(nullptr);
global::renderEngine.setCamera(nullptr);
global::navigationHandler.setCamera(nullptr);
_scene->clear();
global::rootPropertyOwner.removePropertySubOwner(_scene.get());
}
std::unique_ptr<SceneInitializer> sceneInitializer;
if (global::configuration.useMultithreadedInitialization) {
unsigned int nAvailableThreads = std::thread::hardware_concurrency();
unsigned int nThreads = nAvailableThreads == 0 ? 2 : nAvailableThreads - 1;
sceneInitializer = std::make_unique<MultiThreadedSceneInitializer>(nThreads);
} else {
sceneInitializer = std::make_unique<SingleThreadedSceneInitializer>();
}
_scene = std::make_unique<Scene>(std::move(sceneInitializer));
global::renderEngine.setScene(_scene.get());
global::rootPropertyOwner.addPropertySubOwner(_scene.get());
_scene->setCamera(std::make_unique<Camera>());
Camera* camera = _scene->camera();
camera->setParent(_scene->root());
global::renderEngine.setCamera(camera);
global::navigationHandler.setCamera(camera);
const SceneGraphNode* parent = camera->parent();
if (parent) {
global::navigationHandler.orbitalNavigator().setFocusNode(parent->identifier());
} else {
global::navigationHandler.orbitalNavigator().setFocusNode(
_scene->root()->identifier()
);
}
_assetManager->removeAll();
_assetManager->add(assetPath);
_loadingScreen->setPhase(LoadingScreen::Phase::Construction);
_loadingScreen->postMessage("Loading assets");
_assetManager->update();
_loadingScreen->setPhase(LoadingScreen::Phase::Synchronization);
_loadingScreen->postMessage("Synchronizing assets");
std::vector<std::shared_ptr<const Asset>> allAssets =
_assetManager->rootAsset()->subTreeAssets();
std::unordered_set<std::shared_ptr<ResourceSynchronization>> resourceSyncs;
for (const std::shared_ptr<const Asset>& a : allAssets) {
std::vector<std::shared_ptr<ResourceSynchronization>> syncs =
a->ownSynchronizations();
for (const std::shared_ptr<ResourceSynchronization>& s : syncs) {
ZoneScopedN("Update resource synchronization")
if (s->state() == ResourceSynchronization::State::Syncing) {
LoadingScreen::ProgressInfo progressInfo;
progressInfo.progress = s->progress();
resourceSyncs.insert(s);
_loadingScreen->updateItem(
s->name(),
s->name(),
LoadingScreen::ItemStatus::Started,
progressInfo
);
}
}
}
_loadingScreen->setItemNumber(static_cast<int>(resourceSyncs.size()));
bool loading = true;
while (loading) {
if (_shouldAbortLoading) {
global::windowDelegate.terminate();
break;
}
_loadingScreen->render();
_assetManager->update();
loading = false;
auto it = resourceSyncs.begin();
while (it != resourceSyncs.end()) {
if ((*it)->state() == ResourceSynchronization::State::Syncing) {
LoadingScreen::ProgressInfo progressInfo;
progressInfo.progress = (*it)->progress();
if ((*it)->nTotalBytesIsKnown()) {
progressInfo.currentSize = static_cast<uint64_t>(
(*it)->nSynchronizedBytes()
);
progressInfo.totalSize = static_cast<uint64_t>(
(*it)->nTotalBytes()
);
}
loading = true;
_loadingScreen->updateItem(
(*it)->name(),
(*it)->name(),
LoadingScreen::ItemStatus::Started,
progressInfo
);
++it;
} else {
LoadingScreen::ProgressInfo progressInfo;
progressInfo.progress = 1.f;
_loadingScreen->tickItem();
_loadingScreen->updateItem(
(*it)->name(),
(*it)->name(),
LoadingScreen::ItemStatus::Finished,
progressInfo
);
it = resourceSyncs.erase(it);
}
}
}
if (_shouldAbortLoading) {
_loadingScreen = nullptr;
return;
}
_loadingScreen->setPhase(LoadingScreen::Phase::Initialization);
_loadingScreen->postMessage("Initializing scene");
while (_scene->isInitializing()) {
_loadingScreen->render();
}
_loadingScreen->postMessage("Initializing OpenGL");
_loadingScreen->finalize();
_loadingScreen = nullptr;
global::renderEngine.updateScene();
global::syncEngine.addSyncables(global::timeManager.getSyncables());
if (_scene && _scene->camera()) {
global::syncEngine.addSyncables(_scene->camera()->getSyncables());
}
#ifdef __APPLE__
showTouchbar();
#endif // APPLE
runGlobalCustomizationScripts();
writeSceneDocumentation();
LTRACE("OpenSpaceEngine::loadSingleAsset(end)");
}
void OpenSpaceEngine::deinitialize() {
ZoneScoped
LTRACE("OpenSpaceEngine::deinitialize(begin)");
for (const std::function<void()>& func : global::callback::deinitialize) {
func();
}
global::navigationHandler.deinitialize();
LTRACE("deinitialize(begin)");
if (global::parallelPeer.status() != ParallelConnection::Status::Disconnected) {
global::parallelPeer.disconnect();
}
if (global::renderEngine.scene() && global::renderEngine.scene()->camera()) {
global::syncEngine.removeSyncables(
global::renderEngine.scene()->camera()->getSyncables()
);
}
global::sessionRecording.deinitialize();
global::versionChecker.cancel();
_assetManager = nullptr;
global::deinitialize();
FactoryManager::deinitialize();
TransformationManager::deinitialize();
SpiceManager::deinitialize();
ghoul::fontrendering::FontRenderer::deinitialize();
ghoul::logging::LogManager::deinitialize();
LTRACE("deinitialize(end)");
LTRACE("OpenSpaceEngine::deinitialize(end)");
}
void OpenSpaceEngine::deinitializeGL() {
ZoneScoped
LTRACE("OpenSpaceEngine::deinitializeGL(begin)");
// We want to render an image informing the user that we are shutting down
global::renderEngine.renderEndscreen();
global::windowDelegate.swapBuffer();
global::openSpaceEngine.assetManager().deinitialize();
global::openSpaceEngine._scene = nullptr;
global::renderEngine.setScene(nullptr);
for (const std::function<void()>& func : global::callback::deinitializeGL) {
func();
}
global::deinitializeGL();
rendering::helper::deinitialize();
LTRACE("OpenSpaceEngine::deinitializeGL(end)");
}
void OpenSpaceEngine::writeStaticDocumentation() {
std::string path = global::configuration.documentation.path;
if (!path.empty()) {
DocEng.addHandlebarTemplates(global::scriptEngine.templatesToRegister());
DocEng.addHandlebarTemplates(FactoryManager::ref().templatesToRegister());
DocEng.addHandlebarTemplates(DocEng.templatesToRegister());
_documentationJson += "{\"name\":\"Scripting\",";
_documentationJson += "\"identifier\":\"" + global::scriptEngine.jsonName();
_documentationJson += "\",\"data\":" + global::scriptEngine.generateJson();
_documentationJson += "},";
_documentationJson += "{\"name\":\"Top Level\",";
_documentationJson += "\"identifier\":\"" + DocEng.jsonName();
_documentationJson += "\",\"data\":" + DocEng.generateJson();
_documentationJson += "},";
_documentationJson += "{\"name\":\"Factory\",";
_documentationJson += "\"identifier\":\"" + FactoryManager::ref().jsonName();
_documentationJson += "\",\"data\":" + FactoryManager::ref().generateJson();
_documentationJson += "},";
}
}
void OpenSpaceEngine::runGlobalCustomizationScripts() {
ZoneScoped
LINFO("Running Global initialization scripts");
ghoul::lua::LuaState state;
global::scriptEngine.initializeLuaState(state);
for (const std::string& script : global::configuration.globalCustomizationScripts) {
std::string s = absPath(script);
if (FileSys.fileExists(s)) {
try {
LINFO(fmt::format("Running global customization script: {}", s));
ghoul::lua::runScriptFile(state, s);
} catch (const ghoul::RuntimeError& e) {
LERRORC(e.component, e.message);
}
}
else {
LDEBUG(fmt::format("Ignoring non-existing script file: {}", s));
}
}
}
void OpenSpaceEngine::loadFonts() {
global::fontManager.initialize();
using T = std::string;
for (const std::pair<const T, T>& font : global::configuration.fonts) {
std::string key = font.first;
std::string fontName = absPath(font.second);
if (!FileSys.fileExists(fontName)) {
LERROR(fmt::format("Could not find font '{}' for key '{}'", fontName, key));
continue;
}
LDEBUG(fmt::format("Registering font '{}' with key '{}'", fontName, key));
bool success = global::fontManager.registerFontPath(key, fontName);
if (!success) {
LERROR(fmt::format(
"Error registering font '{}' with key '{}'", fontName, key
));
}
}
try {
bool initSuccess = ghoul::fontrendering::FontRenderer::initialize();
if (!initSuccess) {
LERROR("Error initializing default font renderer");
}
}
catch (const ghoul::RuntimeError& err) {
LERRORC(err.component, err.message);
}
}
void OpenSpaceEngine::writeSceneDocumentation() {
ZoneScoped
// Write documentation to json files if config file supplies path for doc files
std::string path = global::configuration.documentation.path;
if (!path.empty()) {
path = absPath(path) + "/";
_documentationJson += "{\"name\":\"Keybindings\",\"identifier\":\"";
_documentationJson += global::keybindingManager.jsonName() + "\",";
_documentationJson += "\"data\":";
_documentationJson += global::keybindingManager.generateJson();
_documentationJson += "},";
_documentationJson += "{\"name\":\"Scene License Information\",";
_documentationJson += "\"identifier\":\"sceneLicense";
_documentationJson += "\",\"data\":";
_documentationJson += _scene->generateSceneLicenseDocumentationJson();
_documentationJson += "},";
_documentationJson += "{\"name\":\"Scene Properties\",";
_documentationJson += "\"identifier\":\"propertylist";// + _scene->jsonName();
_documentationJson += "\",\"data\":" + global::rootPropertyOwner.generateJson();
_documentationJson += "},";
_documentationJson += "{\"name\":\"Scene Graph Information\",";
_documentationJson += "\"identifier\":\"propertylist";
_documentationJson += "\",\"data\":" + _scene->generateJson();
_documentationJson += "}";
//add templates for the jsons we just registered
DocEng.addHandlebarTemplates(global::keybindingManager.templatesToRegister());
//TODO this is in efficaiant, here i am just instaning the class to get
//at a member variable which is staticly defined. How do i just get that
const std::vector<SceneLicense> licenses;
SceneLicenseWriter writer(licenses);
DocEng.addHandlebarTemplates(writer.templatesToRegister());
DocEng.addHandlebarTemplates(global::rootPropertyOwner.templatesToRegister());
//the static documentation shoudl be finished already
//so now that we wrote the static and secene json files
//we should write the html file that uses them.
_documentationJson += "]}";
DocEng.writeDocumentationHtml(path, _documentationJson);
}
//no else, if path was empty, that means that no documentation is requested
}
void OpenSpaceEngine::preSynchronization() {
ZoneScoped
LTRACE("OpenSpaceEngine::preSynchronization(begin)");
//std::this_thread::sleep_for(std::chrono::milliseconds(10));
std::unique_ptr<performance::PerformanceMeasurement> perf;
if (global::performanceManager.isEnabled()) {
perf = std::make_unique<performance::PerformanceMeasurement>(
"OpenSpaceEngine::preSynchronization"
);
}
FileSys.triggerFilesystemEvents();
if (_hasScheduledAssetLoading) {
LINFO(fmt::format("Loading asset: {}", _scheduledAssetPathToLoad));
loadSingleAsset(_scheduledAssetPathToLoad);
_hasScheduledAssetLoading = false;
_scheduledAssetPathToLoad.clear();
}
if (_isFirstRenderingFirstFrame) {
global::windowDelegate.setSynchronization(false);
}
bool master = global::windowDelegate.isMaster();
global::syncEngine.preSynchronization(SyncEngine::IsMaster(master));
if (master) {
double dt = global::windowDelegate.deltaTime();
if (global::sessionRecording.isSavingFramesDuringPlayback()) {
dt = global::sessionRecording.fixedDeltaTimeDuringFrameOutput();
}
global::timeManager.preSynchronization(dt);
using Iter = std::vector<std::string>::const_iterator;
std::pair<Iter, Iter> scheduledScripts = global::scriptScheduler.progressTo(
global::timeManager.time().j2000Seconds()
);
for (Iter it = scheduledScripts.first; it != scheduledScripts.second; ++it) {
global::scriptEngine.queueScript(
*it,
scripting::ScriptEngine::RemoteScripting::Yes
);
}
global::renderEngine.updateScene();
if (_scene) {
Camera* camera = _scene->camera();
if (camera) {
global::navigationHandler.updateCamera(dt);
camera->invalidateCache();
}
}
global::sessionRecording.preSynchronization();
global::parallelPeer.preSynchronization();
global::interactionMonitor.updateActivityState();
}
for (const std::function<void()>& func : global::callback::preSync) {
ZoneScopedN("[Module] preSync")
func();
}
LTRACE("OpenSpaceEngine::preSynchronization(end)");
}
void OpenSpaceEngine::postSynchronizationPreDraw() {
ZoneScoped
LTRACE("OpenSpaceEngine::postSynchronizationPreDraw(begin)");
std::unique_ptr<performance::PerformanceMeasurement> perf;
if (global::performanceManager.isEnabled()) {
perf = std::make_unique<performance::PerformanceMeasurement>(
"OpenSpaceEngine::postSynchronizationPreDraw"
);
}
bool master = global::windowDelegate.isMaster();
global::syncEngine.postSynchronization(SyncEngine::IsMaster(master));
// This probably doesn't have to be done here every frame, but doing it earlier gives
// weird results when using side_by_side stereo --- abock
using FR = ghoul::fontrendering::FontRenderer;
FR::defaultRenderer().setFramebufferSize(global::renderEngine.fontResolution());
FR::defaultProjectionRenderer().setFramebufferSize(
global::renderEngine.renderingResolution()
);
if (_shutdown.inShutdown) {
if (_shutdown.timer <= 0.f) {
global::windowDelegate.terminate();
return;
}
_shutdown.timer -= static_cast<float>(global::windowDelegate.averageDeltaTime());
}
const bool updated = _assetManager->update();
if (updated) {
writeSceneDocumentation();
}
global::renderEngine.updateScene();
global::renderEngine.updateRenderer();
global::renderEngine.updateScreenSpaceRenderables();
global::renderEngine.updateShaderPrograms();
if (!master) {
_scene->camera()->invalidateCache();
}
for (const std::function<void()>& func : global::callback::postSyncPreDraw) {
ZoneScopedN("[Module] postSyncPreDraw")
func();
}
// Testing this every frame has minimal impact on the performance --- abock
// Debug build: 1-2 us ; Release build: <= 1 us
using ghoul::logging::LogManager;
int warningCounter = LogMgr.messageCounter(ghoul::logging::LogLevel::Warning);
int errorCounter = LogMgr.messageCounter(ghoul::logging::LogLevel::Error);
int fatalCounter = LogMgr.messageCounter(ghoul::logging::LogLevel::Fatal);
if (warningCounter > 0) {
LWARNINGC("Logging", fmt::format("Number of Warnings: {}", warningCounter));
}
if (errorCounter > 0) {
LWARNINGC("Logging", fmt::format("Number of Errors: {}", errorCounter));
}
if (fatalCounter > 0) {
LWARNINGC("Logging", fmt::format("Number of Fatals: {}", fatalCounter));
}
LogMgr.resetMessageCounters();
LTRACE("OpenSpaceEngine::postSynchronizationPreDraw(end)");
}
void OpenSpaceEngine::render(const glm::mat4& sceneMatrix, const glm::mat4& viewMatrix,
const glm::mat4& projectionMatrix)
{
ZoneScoped
LTRACE("OpenSpaceEngine::render(begin)");
std::unique_ptr<performance::PerformanceMeasurement> perf;
if (global::performanceManager.isEnabled()) {
perf = std::make_unique<performance::PerformanceMeasurement>(
"OpenSpaceEngine::render"
);
}
const bool isGuiWindow =
global::windowDelegate.hasGuiWindow() ?
global::windowDelegate.isGuiWindow() :
true;
if (isGuiWindow) {
global::luaConsole.update();
}
global::renderEngine.render(sceneMatrix, viewMatrix, projectionMatrix);
for (const std::function<void()>& func : global::callback::render) {
ZoneScopedN("[Module] render")
func();
}
LTRACE("OpenSpaceEngine::render(end)");
}
void OpenSpaceEngine::drawOverlays() {
ZoneScoped
LTRACE("OpenSpaceEngine::drawOverlays(begin)");
std::unique_ptr<performance::PerformanceMeasurement> perf;
if (global::performanceManager.isEnabled()) {
perf = std::make_unique<performance::PerformanceMeasurement>(
"OpenSpaceEngine::drawOverlays"
);
}
const bool isGuiWindow =
global::windowDelegate.hasGuiWindow() ?
global::windowDelegate.isGuiWindow() :
true;
if (isGuiWindow) {
global::renderEngine.renderOverlays(_shutdown);
global::luaConsole.render();
}
for (const std::function<void()>& func : global::callback::draw2D) {
ZoneScopedN("[Module] draw2D")
func();
}
LTRACE("OpenSpaceEngine::drawOverlays(end)");
}
void OpenSpaceEngine::postDraw() {
ZoneScoped
LTRACE("OpenSpaceEngine::postDraw(begin)");
std::unique_ptr<performance::PerformanceMeasurement> perf;
if (global::performanceManager.isEnabled()) {
perf = std::make_unique<performance::PerformanceMeasurement>(
"OpenSpaceEngine::postDraw"
);
}
global::renderEngine.postDraw();
for (const std::function<void()>& func : global::callback::postDraw) {
ZoneScopedN("[Module] postDraw")
func();
}
if (_isFirstRenderingFirstFrame) {
global::windowDelegate.setSynchronization(true);
_isFirstRenderingFirstFrame = false;
}
LTRACE("OpenSpaceEngine::postDraw(end)");
}
void OpenSpaceEngine::keyboardCallback(Key key, KeyModifier mod, KeyAction action) {
ZoneScoped
if (_loadingScreen) {
// If the loading screen object exists, we are currently loading and want key
// presses to behave differently
if (key == Key::Escape) {
_shouldAbortLoading = true;
}
return;
}
using F = std::function<bool (Key, KeyModifier, KeyAction)>;
for (const F& func : global::callback::keyboard) {
const bool isConsumed = func(key, mod, action);
if (isConsumed) {
return;
}
}
if (!global::configuration.isConsoleDisabled) {
bool isConsoleConsumed = global::luaConsole.keyboardCallback(key, mod, action);
if (isConsoleConsumed) {
return;
}
}
global::navigationHandler.keyboardCallback(key, mod, action);
global::keybindingManager.keyboardCallback(key, mod, action);
global::interactionMonitor.markInteraction();
}
void OpenSpaceEngine::charCallback(unsigned int codepoint, KeyModifier modifier) {
ZoneScoped
using F = std::function<bool (unsigned int, KeyModifier)>;
for (const F& func : global::callback::character) {
bool isConsumed = func(codepoint, modifier);
if (isConsumed) {
return;
}
}
global::luaConsole.charCallback(codepoint, modifier);
global::interactionMonitor.markInteraction();
}
void OpenSpaceEngine::mouseButtonCallback(MouseButton button,
MouseAction action,
KeyModifier mods)
{
ZoneScoped
using F = std::function<bool (MouseButton, MouseAction, KeyModifier)>;
for (const F& func : global::callback::mouseButton) {
bool isConsumed = func(button, action, mods);
if (isConsumed) {
// If the mouse was released, we still want to forward it to the navigation
// handler in order to reliably terminate a rotation or zoom. Accidentally
// moving the cursor over a UI window is easy to miss and leads to weird
// continuing movement
if (action == MouseAction::Release) {
break;
}
else {
return;
}
}
}
// Check if the user clicked on one of the 'buttons' the RenderEngine is drawing
if (action == MouseAction::Press) {
bool isConsumed = global::renderEngine.mouseActivationCallback(
global::windowDelegate.mousePosition()
);
if (isConsumed) {
return;
}
}
global::navigationHandler.mouseButtonCallback(button, action);
global::interactionMonitor.markInteraction();
}
void OpenSpaceEngine::mousePositionCallback(double x, double y) {
ZoneScoped
using F = std::function<void (double, double)>;
for (const F& func : global::callback::mousePosition) {
func(x, y);
}
global::navigationHandler.mousePositionCallback(x, y);
global::interactionMonitor.markInteraction();
}
void OpenSpaceEngine::mouseScrollWheelCallback(double posX, double posY) {
ZoneScoped
using F = std::function<bool (double, double)>;
for (const F& func : global::callback::mouseScrollWheel) {
bool isConsumed = func(posX, posY);
if (isConsumed) {
return;
}
}
global::navigationHandler.mouseScrollWheelCallback(posY);
global::interactionMonitor.markInteraction();
}
void OpenSpaceEngine::touchDetectionCallback(TouchInput input) {
ZoneScoped
using F = std::function<bool (TouchInput)>;
for (const F& func : global::callback::touchDetected) {
bool isConsumed = func(input);
if (isConsumed) {
return;
}
}
}
void OpenSpaceEngine::touchUpdateCallback(TouchInput input) {
ZoneScoped
using F = std::function<bool(TouchInput)>;
for (const F& func : global::callback::touchUpdated) {
bool isConsumed = func(input);
if (isConsumed) {
return;
}
}
}
void OpenSpaceEngine::touchExitCallback(TouchInput input) {
ZoneScoped
using F = std::function<void(TouchInput)>;
for (const F& func : global::callback::touchExit) {
func(input);
}
}
std::vector<char> OpenSpaceEngine::encode() {
ZoneScoped
std::vector<char> buffer = global::syncEngine.encodeSyncables();
return buffer;
}
void OpenSpaceEngine::decode(std::vector<char> data) {
ZoneScoped
global::syncEngine.decodeSyncables(std::move(data));
}
void OpenSpaceEngine::toggleShutdownMode() {
if (_shutdown.inShutdown) {
// If we are already in shutdown mode, we want to disable it
_shutdown.inShutdown = false;
}
else {
// Else, we have to enable it
_shutdown.timer = _shutdown.waitTime;
_shutdown.inShutdown = true;
}
}
scripting::LuaLibrary OpenSpaceEngine::luaLibrary() {
return {
"",
{
{
"toggleShutdown",
&luascriptfunctions::toggleShutdown,
{},
"",
"Toggles the shutdown mode that will close the application after the "
"count down timer is reached"
},
{
"writeDocumentation",
&luascriptfunctions::writeDocumentation,
{},
"",
"Writes out documentation files"
},
{
"downloadFile",
&luascriptfunctions::downloadFile,
{},
"",
"Downloads a file from Lua scope"
},
{
"addVirtualProperty",
&luascriptfunctions::addVirtualProperty,
{},
"type, name, identifier,"
"[description, value, minimumValue, maximumValue]",
"Adds a virtual property that will set a group of properties"
},
{
"removeVirtualProperty",
&luascriptfunctions::removeVirtualProperty,
{},
"string",
"Removes a previously added virtual property"
},
{
"removeAllVirtualProperties",
&luascriptfunctions::removeAllVirtualProperties,
{},
"",
"Remove all registered virtual properties"
},
{
"addTag",
&luascriptfunctions::addTag,
{},
"string, string",
"Adds a tag (second argument) to a scene graph node (first argument)"
},
{
"removeTag",
&luascriptfunctions::removeTag,
{},
"string, string",
"Removes a tag (second argument) from a scene graph node (first argument)"
},
{
"isMaster",
&luascriptfunctions::isMaster,
{},
"",
"Returns whether the current OpenSpace instance is the master node of a "
"cluster configuration. If this instance is not part of a cluster, this "
"function also returns 'true'."
},
{
"clusterId",
&luascriptfunctions::clusterId,
{},
"",
"Returns the zero-based identifier for this OpenSpace instance in a "
"cluster configuration. If this instance is not part of a cluster, this "
"identifier is always 0."
}
},
{
absPath("${SCRIPTS}/core_scripts.lua")
}
};
}
LoadingScreen* OpenSpaceEngine::loadingScreen() {
return _loadingScreen.get();
}
AssetManager& OpenSpaceEngine::assetManager() {
ghoul_assert(_assetManager, "Asset Manager must not be nullptr");
return *_assetManager;
}
} // namespace openspace