fossilize.hpp

/* Copyright (c) 2018 Hans-Kristian Arntzen
 *
 * 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.
 */

#pragma once

#include "vulkan.h"
#include <stddef.h>
#include "fossilize_types.hpp"

#if defined(__GNUC__)
#define FOSSILIZE_WARN_UNUSED __attribute__((warn_unused_result))
#else
#define FOSSILIZE_WARN_UNUSED
#endif

namespace Fossilize
{
class DatabaseInterface;
class Hasher;
class ApplicationInfoFilter;

class ScratchAllocator
{
public:
	ScratchAllocator();
	~ScratchAllocator();

	// alignof(T) doesn't work on MSVC 2013.
	template <typename T>
	T *allocate()
	{
		return static_cast<T *>(allocate_raw(sizeof(T), 16));
	}

	template <typename T>
	T *allocate_cleared()
	{
		return static_cast<T *>(allocate_raw_cleared(sizeof(T), 16));
	}

	template <typename T>
	T *allocate_n(size_t count)
	{
		if (count == 0)
			return nullptr;
		return static_cast<T *>(allocate_raw(sizeof(T) * count, 16));
	}

	template <typename T>
	T *allocate_n_cleared(size_t count)
	{
		if (count == 0)
			return nullptr;
		return static_cast<T *>(allocate_raw_cleared(sizeof(T) * count, 16));
	}

	void *allocate_raw(size_t size, size_t alignment);
	void *allocate_raw_cleared(size_t size, size_t alignment);

	void reset();
	size_t get_peak_memory_consumption() const;

	// Disable copies (and moves).
	ScratchAllocator(const ScratchAllocator &) = delete;
	void operator=(const ScratchAllocator &) = delete;

private:
	struct Impl;
	Impl *impl;
};

class StateCreatorInterface
{
public:
	virtual ~StateCreatorInterface() = default;

	// Generally, this is only called when parsing standalone blogs with type RESOURCE_APPLICATION_INFO.

	// If using stand-alone JSON format, all future calls to enqueue_create_* were created using this application info.
	// app can be nullptr, in which case no pApplicationInfo was used (allowed in Vulkan 1.0).
	// The pointer provided in app is persistent as long as StateReplayer lives.
	// A physical device features 2 structure is also passed in, as it could affect compilation.
	// For now, only robustBufferAccess and some other feature bits in pNext is used.
	// physical_device_features can also be nullptr, in
	// which case the relevant feature robustBufferAccess and features are assumed to be turned off.
	virtual void set_application_info(Hash /*application_feature_hash*/, const VkApplicationInfo * /*app*/, const VkPhysicalDeviceFeatures2 * /*physical_device_features*/) {}

	// Called at the beginning of the state replayer to mark which application/feature hash
	// was used for the following objects.
	// This is only called if the blob was hashed using the older method of keying based on application info hash.
	virtual void set_current_application_info(Hash /*hash*/) {}

	// Called when parsing blobs of type RESOURCE_APPLICATION_BLOB_LINK.
	// Marks that a blob of type "tag" and hash "hash" was seen for application hash "application_feature_hash".
	virtual void notify_application_info_link(Hash /*application_info_link_hash*/,
	                                          Hash /*application_feature_hash*/,
	                                          ResourceTag /*blob_tag*/,
	                                          Hash /*blob_hash*/) {}

	// SAMPLER_YCBCR_CONVERSION_CREATE_INFO is added as a pNext here, instead of YCBCR_CONVERSION_INFO.
	// Replaying application needs to detect that pNext, create its own YCbCr object and replace the struct
	// with a YCBCR_CONVERSION_INFO.
	// See Device::create_sampler_with_ycbcr_remap().
	virtual bool enqueue_create_sampler(Hash hash, const VkSamplerCreateInfo *create_info, VkSampler *sampler) = 0;
	virtual bool enqueue_create_descriptor_set_layout(Hash hash, const VkDescriptorSetLayoutCreateInfo *create_info, VkDescriptorSetLayout *layout) = 0;
	virtual bool enqueue_create_pipeline_layout(Hash hash, const VkPipelineLayoutCreateInfo *create_info, VkPipelineLayout *layout) = 0;
	virtual bool enqueue_create_shader_module(Hash hash, const VkShaderModuleCreateInfo *create_info, VkShaderModule *module) = 0;
	virtual bool enqueue_create_render_pass(Hash hash, const VkRenderPassCreateInfo *create_info, VkRenderPass *render_pass) = 0;
	virtual bool enqueue_create_render_pass2(Hash hash, const VkRenderPassCreateInfo2 *create_info, VkRenderPass *render_pass) = 0;
	virtual bool enqueue_create_compute_pipeline(Hash hash, const VkComputePipelineCreateInfo *create_info, VkPipeline *pipeline) = 0;
	virtual bool enqueue_create_graphics_pipeline(Hash hash, const VkGraphicsPipelineCreateInfo *create_info, VkPipeline *pipeline) = 0;
	virtual bool enqueue_create_raytracing_pipeline(Hash hash, const VkRayTracingPipelineCreateInfoKHR *create_info,
	                                                VkPipeline *pipeline) = 0;

	// Hard dependency, replayer must sync all its workers. This is only called for derived pipelines,
	// which need to have their parent be compiled before we can create the derived one.
	virtual void sync_threads() {}

	// Wait for all shader modules to be ready.
	virtual void sync_shader_modules() {}

	// Notifies the replayer that we are done replaying a type.
	// Replay can ignore this if it deals with synchronization between replayed types.
	virtual void notify_replayed_resources_for_type() {}
};

class StateReplayer
{
public:
	StateReplayer();
	~StateReplayer();
	bool parse(StateCreatorInterface &iface, DatabaseInterface *database, const void *buffer, size_t size) FOSSILIZE_WARN_UNUSED;

	// Default is true. If true, the replayer will make sure the derivative pipeline handles provided to
	// the API is a correct VkPipeline. If false, pipelines with VK_PIPELINE_CREATE_DERIVATIVE_BIT will have its basePipelineHandle
	// set to the hash of the pipeline. It is up to the caller to resolve this hash to a real pipeline later.
	// Setting to false can help improve replay performance in multi-threaded scenarios.
	void set_resolve_derivative_pipeline_handles(bool enable);

	// Default is true. If true, the replayer will make sure the shader module handle is a valid VkShaderModule.
	// If false, VkShaderModule handles are filled with the object hash instead.
	// It is up to the application to overwrite the correct VkShaderModule later.
	void set_resolve_shader_module_handles(bool enable);

	// Lets other StateReplayers have the same references to objects.
	void copy_handle_references(const StateReplayer &replayer);

	void forget_handle_references();

	ScratchAllocator &get_allocator();

	// Disable copies (and moves).
	StateReplayer(const StateReplayer &) = delete;
	void operator=(const StateReplayer &) = delete;

private:
	struct Impl;
	Impl *impl;
};

struct StateRecorderApplicationFeatureHash
{
	Hash application_info_hash = 0;
	Hash physical_device_features_hash = 0;
};

class StateRecorder
{
public:
	StateRecorder();
	~StateRecorder();
	ScratchAllocator &get_allocator();

	// Call before init_recording_thread.
	void set_database_enable_compression(bool enable);
	void set_database_enable_checksum(bool enable);

	// These methods should only be called at the very beginning of the application lifetime.
	// It will affect the hash of all create info structures.
	// These are never recorded in a thread, so it's safe to query the application/feature hash right after calling these methods.
	bool record_application_info(const VkApplicationInfo &info) FOSSILIZE_WARN_UNUSED;

	// device_pnext must contain a PDF2 struct in the pNext chain.
	// This function takes const void* since PDF2 might not be chained as the first struct in VkDeviceCreateInfo::pNext.
	// A reorder occurs as part of the copy operation which normalizes the pNext chain.
	bool record_physical_device_features(const void *device_pnext) FOSSILIZE_WARN_UNUSED;
	bool record_physical_device_features(const VkPhysicalDeviceFeatures &device_features) FOSSILIZE_WARN_UNUSED;
	void set_application_info_filter(ApplicationInfoFilter *filter);

	const StateRecorderApplicationFeatureHash &get_application_feature_hash() const;

	bool record_descriptor_set_layout(VkDescriptorSetLayout set_layout, const VkDescriptorSetLayoutCreateInfo &layout_info,
	                                  Hash custom_hash = 0) FOSSILIZE_WARN_UNUSED;
	bool record_pipeline_layout(VkPipelineLayout pipeline_layout, const VkPipelineLayoutCreateInfo &layout_info,
	                            Hash custom_hash = 0) FOSSILIZE_WARN_UNUSED;
	bool record_shader_module(VkShaderModule module, const VkShaderModuleCreateInfo &create_info,
	                          Hash custom_hash = 0) FOSSILIZE_WARN_UNUSED;
	bool record_graphics_pipeline(VkPipeline pipeline, const VkGraphicsPipelineCreateInfo &create_info,
	                              const VkPipeline *base_pipelines, uint32_t base_pipeline_count,
	                              Hash custom_hash = 0) FOSSILIZE_WARN_UNUSED;
	bool record_compute_pipeline(VkPipeline pipeline, const VkComputePipelineCreateInfo &create_info,
	                             const VkPipeline *base_pipelines, uint32_t base_pipeline_count,
	                             Hash custom_hash = 0) FOSSILIZE_WARN_UNUSED;
	bool record_render_pass(VkRenderPass render_pass, const VkRenderPassCreateInfo &create_info,
	                        Hash custom_hash = 0) FOSSILIZE_WARN_UNUSED;
	bool record_render_pass2(VkRenderPass render_pass, const VkRenderPassCreateInfo2 &create_info,
	                         Hash custom_hash = 0) FOSSILIZE_WARN_UNUSED;
	bool record_sampler(VkSampler sampler, const VkSamplerCreateInfo &create_info,
	                    Hash custom_hash = 0) FOSSILIZE_WARN_UNUSED;
	bool record_raytracing_pipeline(VkPipeline pipeline, const VkRayTracingPipelineCreateInfoKHR &create_info,
	                                const VkPipeline *base_pipelines, uint32_t base_pipeline_count,
	                                Hash custom_hash = 0) FOSSILIZE_WARN_UNUSED;
	// YCbCr conversion objects are treated somewhat differently and their create infos
	// are inlined into a sampler create info.
	// In a replay scenario, the YCbCr create info is fished out of the pNext chain and replaced
	// with a Conversion Info.
	bool record_ycbcr_conversion(VkSamplerYcbcrConversion conv,
	                             const VkSamplerYcbcrConversionCreateInfo &create_info) FOSSILIZE_WARN_UNUSED;

	// Used by hashing functions in Hashing namespace. Should be considered an implementation detail.
	bool get_hash_for_descriptor_set_layout(VkDescriptorSetLayout layout, Hash *hash) const FOSSILIZE_WARN_UNUSED;
	bool get_hash_for_pipeline_layout(VkPipelineLayout layout, Hash *hash) const FOSSILIZE_WARN_UNUSED;
	bool get_hash_for_shader_module(VkShaderModule module, Hash *hash) const FOSSILIZE_WARN_UNUSED;
	bool get_hash_for_graphics_pipeline_handle(VkPipeline pipeline, Hash *hash) const FOSSILIZE_WARN_UNUSED;
	bool get_hash_for_compute_pipeline_handle(VkPipeline pipeline, Hash *hash) const FOSSILIZE_WARN_UNUSED;
	bool get_hash_for_raytracing_pipeline_handle(VkPipeline pipeline, Hash *hash) const FOSSILIZE_WARN_UNUSED;
	bool get_hash_for_render_pass(VkRenderPass render_pass, Hash *hash) const FOSSILIZE_WARN_UNUSED;
	bool get_hash_for_sampler(VkSampler sampler, Hash *hash) const FOSSILIZE_WARN_UNUSED;

	struct SubpassMeta
	{
		bool uses_color;
		bool uses_depth_stencil;
	};
	bool get_subpass_meta_for_pipeline(const VkGraphicsPipelineCreateInfo &create_info,
	                                   Hash render_pass_hash,
	                                   SubpassMeta *meta) const FOSSILIZE_WARN_UNUSED;

	// If database is non-null, serialize cannot be called later, as the implementation will not retain
	// memory for the create info structs, but rather rely on the database interface to make objects persist.
	// The database interface will be fed with all information on the fly.
	//
	// This call can be omitted, in which case all recording calls will be called inline instead.
	// This is mostly useful for testing purposes.
	//
	// NOTE: If iface is non-null,
	// prepare() will be called asynchronously on the DatabaseInterface to hide the cost of up-front file I/O.
	// Do not attempt to call prepare() on the calling thread!
	void init_recording_thread(DatabaseInterface *iface);

	// Uses a recording database, but this is used for debugging scenarios when sigsegv capture does not work robustly.
	// Every call will record directly and flush any writes to disk before returning.
	void init_recording_synchronized(DatabaseInterface *iface);

	// Serializes and allocates data for it. This can only be used if a database interface was not used.
	// The result is a monolithic JSON document which contains all recorded state.
	// Free with free_serialized() to make sure alloc/frees happens in same module.
	// This is the "legacy" way of doing things. Ideally, use the DatabaseInterface.
	bool serialize(uint8_t **serialized, size_t *serialized_size) FOSSILIZE_WARN_UNUSED;
	static void free_serialized(uint8_t *serialized);

	// Stops the recording thread and joins with it.
	// Should only be used in emergency situations, e.g. for FOSSILIZE_DUMP_SIGSEGV=1.
	void tear_down_recording_thread();

	// Disable copies (and moves).
	StateRecorder(const StateRecorder &) = delete;
	void operator=(const StateRecorder &) = delete;

private:
	struct Impl;
	Impl *impl;
};

namespace Hashing
{
// Computes a base hash which can be used to compute some other hashes without having to create a full StateRecorder.
// application_info and/or physical_device_features can be nullptr.
StateRecorderApplicationFeatureHash compute_application_feature_hash(const VkApplicationInfo *application_info,
                                                                     const void *device_pnext);

Hash compute_combined_application_feature_hash(const StateRecorderApplicationFeatureHash &base_hash);

// Shader modules, samplers and render passes are standalone modules, so they can be hashed in isolation.
bool compute_hash_shader_module(const VkShaderModuleCreateInfo &create_info, Hash *hash);
bool compute_hash_sampler(const VkSamplerCreateInfo &create_info, Hash *hash);
bool compute_hash_render_pass(const VkRenderPassCreateInfo &create_info, Hash *hash);
bool compute_hash_render_pass2(const VkRenderPassCreateInfo2 &create_info, Hash *hash);

// If you are recording in threaded mode, these must only be called from the recording thread,
// as the dependent objects might not have been recorded yet, and thus the mapping of dependent objects is unknown.
// If you need to use these for whatever reason, you cannot use StateRecorder in the threaded mode.
bool compute_hash_descriptor_set_layout(const StateRecorder &recorder, const VkDescriptorSetLayoutCreateInfo &layout, Hash *hash) FOSSILIZE_WARN_UNUSED;
bool compute_hash_pipeline_layout(const StateRecorder &recorder, const VkPipelineLayoutCreateInfo &layout, Hash *hash) FOSSILIZE_WARN_UNUSED;
bool compute_hash_graphics_pipeline(const StateRecorder &recorder, const VkGraphicsPipelineCreateInfo &create_info, Hash *hash) FOSSILIZE_WARN_UNUSED;
bool compute_hash_compute_pipeline(const StateRecorder &recorder, const VkComputePipelineCreateInfo &create_info, Hash *hash) FOSSILIZE_WARN_UNUSED;
bool compute_hash_raytracing_pipeline(const StateRecorder &recorder, const VkRayTracingPipelineCreateInfoKHR &create_info, Hash *hash) FOSSILIZE_WARN_UNUSED;
}

}