Added tests

1 files changed, 247 insertions, 0 deletions

diff --git a/Tests/TestApp/src/MTResourceCreationTest.cpp b/Tests/TestApp/src/MTResourceCreationTest.cpp
new file mode 100644
index 0000000..f202ba4
--- /dev/null
+++ b/Tests/TestApp/src/MTResourceCreationTest.cpp
@@ -0,0 +1,247 @@
+/*     Copyright 2015-2017 Egor Yusov
+ *  
+ *  Licensed under the Apache License, Version 2.0 (the "License");
+ *  you may not use this file except in compliance with the License.
+ *  You may obtain a copy of the License at
+ * 
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ * 
+ *  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 OF ANY PROPRIETARY RIGHTS.
+ *
+ *  In no event and under no legal theory, whether in tort (including negligence), 
+ *  contract, or otherwise, unless required by applicable law (such as deliberate 
+ *  and grossly negligent acts) or agreed to in writing, shall any Contributor be
+ *  liable for any damages, including any direct, indirect, special, incidental, 
+ *  or consequential damages of any character arising as a result of this License or 
+ *  out of the use or inability to use the software (including but not limited to damages 
+ *  for loss of goodwill, work stoppage, computer failure or malfunction, or any and 
+ *  all other commercial damages or losses), even if such Contributor has been advised 
+ *  of the possibility of such damages.
+ */
+
+// EngineSandbox.cpp : Defines the entry point for the application.
+//
+
+#include "pch.h"
+#include "MTResourceCreationTest.h"
+#include "Errors.h"
+
+using namespace Diligent;
+
+static const char g_ShaderSource[] = 
+"void VSMain(out float4 pos : SV_POSITION) \n"
+"{                              \n"
+"	pos = float4(0,0,0,0);      \n"
+"}                              \n"
+"                               \n"
+"void PSMain(out float4 col : SV_TARGET)\n"
+"{                              \n"
+"	col = float4(0,0,0,0);      \n"
+"}                              \n"
+;
+
+MTResourceCreationTest::MTResourceCreationTest(IRenderDevice *pDevice, IDeviceContext *pContext, Uint32 NumThreads) : 
+    m_pDevice(pDevice),
+    m_pContext(pContext)
+{
+    m_NumThreadsCompleted = 0;
+    m_NumBuffersCreated = 0;
+    m_NumTexturesCreated = 0;
+    m_NumPSOCreated = 0;
+
+    auto &DevCaps = m_pDevice->GetDeviceCaps();
+    if (DevCaps.bMultithreadedResourceCreationSupported)
+    {
+        m_Threads.resize(NumThreads);
+    }
+    else
+    {
+        LOG_WARNING_MESSAGE("Multithreaded resource creation is not supported on this device");
+    }
+}
+
+void MTResourceCreationTest::WaitForThreadStart(int VarId)
+{
+    std::unique_lock<std::mutex> lk(m_Mtx);
+    m_CondVar.wait(lk, [&]{return m_bReleaseThread[VarId];});
+}
+
+void MTResourceCreationTest::WaitThreads(int VarId)
+{
+    while((size_t)m_NumThreadsCompleted < m_Threads.size())
+        std::this_thread::yield();
+    m_bReleaseThread[VarId] = false;
+    VERIFY_EXPR(m_NumThreadsCompleted == m_Threads.size());
+}
+
+void MTResourceCreationTest::StartThreads(int VarId)
+{
+    {
+        std::unique_lock<std::mutex> lk(m_Mtx);
+        m_bReleaseThread[VarId] = true;
+        m_NumThreadsCompleted = 0;
+    }
+    m_CondVar.notify_all();
+}
+
+static Uint8 RawBufferData[1024];
+static Uint8 RawTextureData[1024*1024*4];
+
+void MTResourceCreationTest::ThreadWorkerFunc(bool bIsMasterThread)
+{
+    while (!m_bStopThreadsFlagInternal)
+    {
+        if (bIsMasterThread)
+            StartThreads(0);
+        else
+            WaitForThreadStart(0);
+        
+        RefCntAutoPtr<IBuffer> pBuffer1, pBuffer2,pBuffer3,pBuffer4;
+        {
+            BufferDesc BuffDesc;
+            BuffDesc.Usage = USAGE_DEFAULT;
+            BuffDesc.BindFlags = BIND_UNIFORM_BUFFER;
+            BuffDesc.Mode = BUFFER_MODE_FORMATTED;
+            BuffDesc.Format.NumComponents = 4;
+            BuffDesc.Format.IsNormalized = False;
+            BuffDesc.Format.ValueType = VT_FLOAT32;
+            BuffDesc.Name = "MT test buffer";
+
+            BuffDesc.uiSizeInBytes = sizeof(RawBufferData);
+
+            BufferData BuffData;
+            BuffData.DataSize = BuffDesc.uiSizeInBytes;
+            BuffData.pData = RawBufferData;
+
+            m_pDevice->CreateBuffer(BuffDesc, BuffData, &pBuffer1);
+
+            BuffDesc.BindFlags = BIND_SHADER_RESOURCE|BIND_UNORDERED_ACCESS;
+            m_pDevice->CreateBuffer(BuffDesc, BuffData, &pBuffer2);
+
+            BuffDesc.BindFlags = BIND_VERTEX_BUFFER|BIND_UNORDERED_ACCESS;
+            m_pDevice->CreateBuffer(BuffDesc, BuffData, &pBuffer3);
+
+            BuffDesc.BindFlags = BIND_INDEX_BUFFER|BIND_UNORDERED_ACCESS;
+            m_pDevice->CreateBuffer(BuffDesc, BuffData, &pBuffer4);
+            
+            m_NumBuffersCreated += 4;
+
+            ++m_NumThreadsCompleted;
+        }
+        
+        if (bIsMasterThread)
+        {
+            WaitThreads(0);
+
+            // This is the sync point. All threads must reach this point before
+            // master thread can proceed. Othre threads are now waiting for StartThreads(1);
+            // When we set m_bStopThreadsFlagInternal here,
+            // we make sure all threads will exit simultaneously
+            m_bStopThreadsFlagInternal = m_bStopThreadsFlag;
+
+            StartThreads(1);
+        }
+        else
+            WaitForThreadStart(1);
+
+        RefCntAutoPtr<ITexture> pTexture;
+        {
+            TextureDesc TexDesc;
+            TexDesc.BindFlags = BIND_SHADER_RESOURCE | BIND_RENDER_TARGET | BIND_UNORDERED_ACCESS;
+            TexDesc.Type = RESOURCE_DIM_TEX_2D;
+            TexDesc.Width = 1024;
+            TexDesc.Height = 1024;
+            TexDesc.Format = TEX_FORMAT_RGBA8_UNORM;
+            TexDesc.MipLevels = 1;
+
+            
+            TextureSubResData SubResData;
+            SubResData.pData = RawTextureData;
+            SubResData.Stride = TexDesc.Width*4;
+
+            TextureData TexData;
+            TexData.NumSubresources = 1;
+            TexData.pSubResources = &SubResData;
+
+            m_pDevice->CreateTexture(TexDesc, TexData, &pTexture);
+            ++m_NumTexturesCreated;
+
+            ++m_NumThreadsCompleted;
+        }
+
+
+        if (bIsMasterThread)
+        {
+            WaitThreads(1);
+            StartThreads(0);
+        }
+        else
+            WaitForThreadStart(0);
+
+
+        RefCntAutoPtr<IShader> pTrivialVS, pTrivialPS;
+        RefCntAutoPtr<IPipelineState> pPSO;
+        {
+            ShaderCreationAttribs Attrs;
+            Attrs.Source = g_ShaderSource;
+            Attrs.EntryPoint = "VSMain";
+            Attrs.Desc.ShaderType = SHADER_TYPE_VERTEX;
+            Attrs.Desc.Name = "TrivialVS";
+            Attrs.SourceLanguage = SHADER_SOURCE_LANGUAGE_HLSL;
+            m_pDevice->CreateShader(Attrs, &pTrivialVS);
+
+            Attrs.EntryPoint = "PSMain";
+            Attrs.Desc.ShaderType = SHADER_TYPE_PIXEL;
+            Attrs.Desc.Name = "TrivialPS";
+            m_pDevice->CreateShader(Attrs, &pTrivialPS);
+
+            PipelineStateDesc PSODesc;
+            PSODesc.GraphicsPipeline.pVS = pTrivialVS;
+            PSODesc.GraphicsPipeline.pPS = pTrivialPS;
+            PSODesc.GraphicsPipeline.PrimitiveTopologyType = PRIMITIVE_TOPOLOGY_TYPE_TRIANGLE;
+            PSODesc.GraphicsPipeline.NumRenderTargets = 1;
+            PSODesc.GraphicsPipeline.RTVFormats[0] = TEX_FORMAT_RGBA8_UNORM;
+            PSODesc.GraphicsPipeline.DSVFormat = TEX_FORMAT_D32_FLOAT;
+            
+            m_pDevice->CreatePipelineState(PSODesc, &pPSO);
+            ++m_NumPSOCreated;
+
+            ++m_NumThreadsCompleted;
+        }
+
+        if (bIsMasterThread)
+        {
+            WaitThreads(0);
+            StartThreads(1);
+        }
+        else
+            WaitForThreadStart(1);
+
+
+        {
+
+            ++m_NumThreadsCompleted;
+        }
+
+        std::this_thread::sleep_for(std::chrono::milliseconds(1));
+
+        if (bIsMasterThread)
+            WaitThreads(1);
+    }
+}
+
+void MTResourceCreationTest::StartThreads()
+{
+    for(size_t t=0; t < m_Threads.size(); ++t)
+        m_Threads[t] = std::thread(&MTResourceCreationTest::ThreadWorkerFunc, this, t == 0);
+}
+
+void MTResourceCreationTest::StopThreads()
+{
+    m_bStopThreadsFlag = true;
+    for(auto &t : m_Threads)
+        t.join();
+    LOG_INFO_MESSAGE("MTResourceCreationTest: Buffers created: ", m_NumBuffersCreated, " Textures created: ", m_NumTexturesCreated, " PSO Created: ", m_NumPSOCreated);
+}