Yas jpeg benchmark

68_JpegLoading/CMakeLists.txt

@@ -0,0 +1,27 @@
+include(common RESULT_VARIABLE RES)
+if(NOT RES)
+	message(FATAL_ERROR "common.cmake not found. Should be in {repo_root}/cmake directory")
+endif()
+
+nbl_create_executable_project("" "" "" "" "${NBL_EXECUTABLE_PROJECT_CREATION_PCH_TARGET}")
+
+if(NBL_EMBED_BUILTIN_RESOURCES)
+	set(_BR_TARGET_ ${EXECUTABLE_NAME}_builtinResourceData)
+	set(RESOURCE_DIR "app_resources")
+
+	get_filename_component(_SEARCH_DIRECTORIES_ "${CMAKE_CURRENT_SOURCE_DIR}" ABSOLUTE)
+	get_filename_component(_OUTPUT_DIRECTORY_SOURCE_ "${CMAKE_CURRENT_BINARY_DIR}/src" ABSOLUTE)
+	get_filename_component(_OUTPUT_DIRECTORY_HEADER_ "${CMAKE_CURRENT_BINARY_DIR}/include" ABSOLUTE)
+
+    file(GLOB_RECURSE BUILTIN_RESOURCE_FILES RELATIVE "${CMAKE_CURRENT_SOURCE_DIR}/${RESOURCE_DIR}" CONFIGURE_DEPENDS "${CMAKE_CURRENT_SOURCE_DIR}/${RESOURCE_DIR}/*")
+    foreach(RES_FILE ${BUILTIN_RESOURCE_FILES})
+      LIST_BUILTIN_RESOURCE(RESOURCES_TO_EMBED "${RES_FILE}")
+    endforeach()
+
+	ADD_CUSTOM_BUILTIN_RESOURCES(${_BR_TARGET_} RESOURCES_TO_EMBED "${_SEARCH_DIRECTORIES_}" "${RESOURCE_DIR}" "nbl::this_example::builtin" "${_OUTPUT_DIRECTORY_HEADER_}" "${_OUTPUT_DIRECTORY_SOURCE_}")
+
+	LINK_BUILTIN_RESOURCES_TO_TARGET(${EXECUTABLE_NAME} ${_BR_TARGET_})
+endif() 
+
+add_dependencies(${EXECUTABLE_NAME} argparse)
+target_include_directories(${EXECUTABLE_NAME} PUBLIC $<TARGET_PROPERTY:argparse,INTERFACE_INCLUDE_DIRECTORIES>)

68_JpegLoading/main.cpp

@@ -0,0 +1,142 @@
+// Copyright (C) 2018-2024 - DevSH GrapMonoAssetManagerAndBuiltinResourceApplicationhics Programming Sp. z O.O.
+// This file is part of the "Nabla Engine".
+// For conditions of distribution and use, see copyright notice in nabla.h
+#include "nbl/application_templates/MonoAssetManagerAndBuiltinResourceApplication.hpp"
+
+#include <thread>
+#include <atomic>
+#include <mutex>
+#include <queue>
+#include <functional>
+#include <condition_variable>
+
+#include "nlohmann/json.hpp"
+#include "argparse/argparse.hpp"
+
+using json = nlohmann::json;
+
+using namespace nbl;
+using namespace core;
+using namespace hlsl;
+using namespace system;
+using namespace asset;
+using namespace ui;
+using namespace video;
+
+class ThreadPool {
+public:
+	using task_t = std::function<void()>;
+
+	ThreadPool() {
+		for (size_t i = 0; i < m_maxWorkers; i++) {
+			m_threads.emplace_back([this]() {
+				while (true) {
+					task_t task;
+
+					{
+						std::unique_lock<std::mutex> lock(m_queueMutex);
+						m_taskAvailable.wait(lock, [&]() { return !m_tasks.empty() || m_stop; });
+
+						if (m_stop && m_tasks.empty())
+							return;
+
+						task = std::move(m_tasks.front());
+						m_tasks.pop();
+					}
+
+					task();
+				}
+				});
+		}
+	}
+
+	~ThreadPool() {
+		{
+			std::lock_guard<std::mutex> lock(m_queueMutex);
+			m_stop = true;
+		}
+
+		m_taskAvailable.notify_all();
+
+		for (auto& thread : m_threads) {
+			thread.join();
+		}
+	}
+
+	void addTask(task_t task) {
+		std::lock_guard<std::mutex> queueLock(m_queueMutex);
+		m_tasks.emplace(std::move(task));
+		m_taskAvailable.notify_one();
+	}
+private:
+	const size_t m_maxWorkers = std::thread::hardware_concurrency();
+	std::vector<std::thread> m_threads;
+	std::condition_variable m_taskAvailable;
+	bool m_stop = false; // stops the threads on object destruction
+
+	std::queue<task_t> m_tasks;
+	std::mutex m_queueMutex;
+};
+
+class JpegLoaderApp final : public application_templates::MonoAssetManagerAndBuiltinResourceApplication
+{
+	using base_t = application_templates::MonoAssetManagerAndBuiltinResourceApplication;
+	using clock_t = std::chrono::steady_clock;
+	constexpr static inline uint32_t m_maxWorkers = 8;
+public:
+	using base_t::base_t;
+
+	inline bool onAppInitialized(smart_refctd_ptr<ISystem>&& system) override
+	{
+		argparse::ArgumentParser program("Color Space");
+
+		program.add_argument<std::string>("--directory")
+			.required()
+			.help("Path to a directory where all JPEG files are stored (not recursive)");
+
+		program.add_argument<std::string>("--output")
+			.default_value("output.json")
+			.help("Path to the file where the benchmark result will be stored");
+
+		try
+		{
+			program.parse_args({ argv.data(), argv.data() + argv.size() });
+		}
+		catch (const std::exception& err)
+		{
+			std::cerr << err.what() << std::endl << program; // NOTE: std::cerr because logger isn't initialized yet
+			return 1;
+		}
+
+		if (!base_t::onAppInitialized(std::move(system)))
+			return false;
+
+		options.directory = program.get<std::string>("--directory");
+		options.outputFile = program.get<std::string>("--output");
+
+
+		ThreadPool threadPool;
+		// TODO: Load JPEGs
+		// TODO: Measure the time
+
+		return true;
+	}
+
+	inline bool keepRunning() override
+	{
+		return false;
+	}
+
+	inline void workLoopBody() override
+	{
+
+	}
+private:
+	struct NBL_APP_OPTIONS
+	{
+		std::string directory;
+		std::string outputFile;
+	} options;
+};
+
+NBL_MAIN_FUNC(JpegLoaderApp)

68_JpegLoading/pipeline.groovy

@@ -0,0 +1,50 @@
+import org.DevshGraphicsProgramming.Agent
+import org.DevshGraphicsProgramming.BuilderInfo
+import org.DevshGraphicsProgramming.IBuilder
+
+class CJpegLoading extends IBuilder
+{
+	public CJpegLoading(Agent _agent, _info)
+	{
+		super(_agent, _info)
+	}
+
+	@Override
+	public boolean prepare(Map axisMapping)
+	{
+		return true
+	}
+
+	@Override
+  	public boolean build(Map axisMapping)
+	{
+		IBuilder.CONFIGURATION config = axisMapping.get("CONFIGURATION")
+		IBuilder.BUILD_TYPE buildType = axisMapping.get("BUILD_TYPE")
+
+		def nameOfBuildDirectory = getNameOfBuildDirectory(buildType)
+		def nameOfConfig = getNameOfConfig(config)
+
+		agent.execute("cmake --build ${info.rootProjectPath}/${nameOfBuildDirectory}/${info.targetProjectPathRelativeToRoot} --target ${info.targetBaseName} --config ${nameOfConfig} -j12 -v")
+
+		return true
+	}
+
+	@Override
+  	public boolean test(Map axisMapping)
+	{
+		return true
+	}
+
+	@Override
+	public boolean install(Map axisMapping)
+	{
+		return true
+	}
+}
+
+def create(Agent _agent, _info)
+{
+	return new CJpegLoading(_agent, _info)
+}
+
+return this

CMakeLists.txt

@@ -83,6 +83,7 @@ if(NBL_BUILD_EXAMPLES)
 	add_subdirectory(0_ImportanceSamplingEnvMaps EXCLUDE_FROM_ALL) #TODO: integrate back into 42
 
 	add_subdirectory(67_RayQueryGeometry EXCLUDE_FROM_ALL)
+	add_subdirectory(68_JpegLoading EXCLUDE_FROM_ALL)
 
 	NBL_HOOK_COMMON_API("${NBL_COMMON_API_TARGETS}")
 endif()