/*
- * Copyright (c) 2014 Samsung Electronics Co., Ltd.
+ * Copyright (c) 2023 Samsung Electronics Co., Ltd.
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
// CLASS HEADER
#include <dali/internal/event/common/thread-local-storage.h>
-// EXTERNAL INCLUDES
-#include <boost/thread/tss.hpp>
-#include <memory>
-
// INTERNAL INCLUDES
+#include <dali/integration-api/gl-abstraction.h>
+#include <dali/integration-api/processor-interface.h>
#include <dali/internal/common/core-impl.h>
-#include <dali/internal/update/manager/update-manager.h>
-#include <dali/internal/render/common/render-manager.h>
-#include <dali/integration-api/platform-abstraction.h>
+#include <dali/internal/event/common/event-thread-services.h>
#include <dali/public-api/common/dali-common.h>
-#include <dali/public-api/math/vector2.h>
+
+#if defined(DEBUG_ENABLED)
+#include <dali/integration-api/debug.h>
+Debug::Filter* gSingletonServiceLogFilter = Debug::Filter::New(Debug::NoLogging, false, "LOG_SINGLETON_SERVICE");
+
+// Need to define own macro as the log function is not installed when this object is created so no logging is shown with DALI_LOG_INFO at construction and destruction
+#define DALI_LOG_SINGLETON_SERVICE_DIRECT(level, message) \
+ if(gSingletonServiceLogFilter && gSingletonServiceLogFilter->IsEnabledFor(level)) \
+ { \
+ std::string string(message); \
+ Dali::TizenPlatform::LogMessage(Debug::INFO, string); \
+ }
+
+#define DALI_LOG_SINGLETON_SERVICE(level, format, ...) DALI_LOG_INFO(gSingletonServiceLogFilter, level, format, ##__VA_ARGS__)
+#else
+
+#define DALI_LOG_SINGLETON_SERVICE_DIRECT(level, message)
+#define DALI_LOG_SINGLETON_SERVICE(level, format, ...)
+
+#endif
namespace Dali
{
-
namespace Internal
{
-
namespace
{
-#ifdef EMSCRIPTEN
- std::auto_ptr<ThreadLocalStorage> threadLocal;
-#else
- boost::thread_specific_ptr<ThreadLocalStorage> threadLocal;
-#endif
-}
+thread_local ThreadLocalStorage* threadLocal = nullptr;
+thread_local bool isShuttingDown = false;
+} // namespace
ThreadLocalStorage::ThreadLocalStorage(Core* core)
: mCore(core)
{
- DALI_ASSERT_ALWAYS( threadLocal.get() == NULL && "Cannot create more than one ThreadLocalStorage object" );
-
- // reset is used to store a new value associated with this thread
- threadLocal.reset(this);
+ DALI_ASSERT_ALWAYS(threadLocal == nullptr && "Cannot create more than one ThreadLocalStorage object");
+ threadLocal = this;
+ isShuttingDown = false;
}
-ThreadLocalStorage::~ThreadLocalStorage()
-{
-}
+ThreadLocalStorage::~ThreadLocalStorage() = default;
void ThreadLocalStorage::Remove()
{
- threadLocal.reset();
+ threadLocal = nullptr;
+ isShuttingDown = true;
}
ThreadLocalStorage& ThreadLocalStorage::Get()
{
- ThreadLocalStorage* tls = threadLocal.get();
+ DALI_ASSERT_ALWAYS(threadLocal);
- DALI_ASSERT_ALWAYS(tls);
+ return *threadLocal;
+}
- return *tls;
+Dali::SingletonService ThreadLocalStorage::GetSingletonService()
+{
+ Dali::SingletonService singletonService;
+ if(threadLocal)
+ {
+ singletonService = Dali::SingletonService(threadLocal);
+ }
+ return singletonService;
}
bool ThreadLocalStorage::Created()
{
// see if the TLS has been set yet
- return (threadLocal.get() != NULL);
+ return (threadLocal != nullptr);
+}
+
+bool ThreadLocalStorage::IsShuttingDown()
+{
+ return isShuttingDown;
+}
+
+ThreadLocalStorage* ThreadLocalStorage::GetInternal()
+{
+ return threadLocal;
}
Dali::Integration::PlatformAbstraction& ThreadLocalStorage::GetPlatformAbstraction()
return mCore->GetNotificationManager();
}
-ResourceManager& ThreadLocalStorage::GetResourceManager()
+ShaderFactory& ThreadLocalStorage::GetShaderFactory()
{
- return mCore->GetResourceManager();
+ return mCore->GetShaderFactory();
}
-ResourceClient& ThreadLocalStorage::GetResourceClient()
+StagePtr ThreadLocalStorage::GetCurrentStage()
{
- return mCore->GetResourceClient();
+ return mCore->GetCurrentStage();
}
-ImageFactory& ThreadLocalStorage::GetImageFactory()
+GestureEventProcessor& ThreadLocalStorage::GetGestureEventProcessor()
{
- return mCore->GetImageFactory();
+ return mCore->GetGestureEventProcessor();
}
-ModelFactory& ThreadLocalStorage::GetModelFactory()
+RelayoutController& ThreadLocalStorage::GetRelayoutController()
{
- return mCore->GetModelFactory();
+ return mCore->GetRelayoutController();
}
-ShaderFactory& ThreadLocalStorage::GetShaderFactory()
+ObjectRegistry& ThreadLocalStorage::GetObjectRegistry()
{
- return mCore->GetShaderFactory();
+ return mCore->GetObjectRegistry();
}
-StagePtr ThreadLocalStorage::GetCurrentStage()
+EventThreadServices& ThreadLocalStorage::GetEventThreadServices()
{
- return mCore->GetCurrentStage();
+ return mCore->GetEventThreadServices();
}
-EventToUpdate& ThreadLocalStorage::GetEventToUpdate()
+PropertyNotificationManager& ThreadLocalStorage::GetPropertyNotificationManager()
{
- return GetUpdateManager().GetEventToUpdate();
+ return mCore->GetPropertyNotificationManager();
}
-GestureEventProcessor& ThreadLocalStorage::GetGestureEventProcessor()
+AnimationPlaylist& ThreadLocalStorage::GetAnimationPlaylist()
{
- return mCore->GetGestureEventProcessor();
+ return mCore->GetAnimationPlaylist();
+}
+
+bool ThreadLocalStorage::IsBlendEquationSupported(DevelBlendEquation::Type blendEquation)
+{
+ return mCore->GetGlAbstraction().IsBlendEquationSupported(blendEquation);
+}
+
+std::string ThreadLocalStorage::GetShaderVersionPrefix()
+{
+ return mCore->GetGlAbstraction().GetShaderVersionPrefix();
+}
+
+std::string ThreadLocalStorage::GetVertexShaderPrefix()
+{
+ return mCore->GetGlAbstraction().GetVertexShaderPrefix();
+}
+
+std::string ThreadLocalStorage::GetFragmentShaderPrefix()
+{
+ return mCore->GetGlAbstraction().GetFragmentShaderPrefix();
+}
+
+void ThreadLocalStorage::AddScene(Scene* scene)
+{
+ mCore->AddScene(scene);
+}
+
+void ThreadLocalStorage::RemoveScene(Scene* scene)
+{
+ mCore->RemoveScene(scene);
+}
+
+void ThreadLocalStorage::Register(const std::type_info& info, BaseHandle singleton)
+{
+ if(singleton)
+ {
+ DALI_LOG_SINGLETON_SERVICE(Debug::General, "Singleton Added: %s\n", info.name());
+ mSingletonContainer.push_back(SingletonPair(info.name(), singleton));
+
+ Integration::Processor* processor = dynamic_cast<Integration::Processor*>(&singleton.GetBaseObject());
+ if(processor)
+ {
+ mCore->RegisterProcessor(*processor);
+ }
+ }
+}
+
+void ThreadLocalStorage::UnregisterAll()
+{
+ mSingletonContainer.clear();
+}
+
+BaseHandle ThreadLocalStorage::GetSingleton(const std::type_info& info) const
+{
+ BaseHandle object;
+
+ const SingletonContainer::const_iterator end = mSingletonContainer.end();
+ for(SingletonContainer::const_iterator iter = mSingletonContainer.begin(); iter != end; ++iter)
+ {
+ // comparing the addresses as these are allocated statically per library
+ if((*iter).first == info.name())
+ {
+ object = (*iter).second;
+ }
+ }
+
+ return object;
}
} // namespace Internal