2.0. Fixed rendering stalls caused by ogl frame allocation delays.

[casparcg] / core / mixer / gpu / ogl_device.cpp

diff --git a/core/mixer/gpu/ogl_device.cpp b/core/mixer/gpu/ogl_device.cpp
index ba7db7ea09cddd89d066145584038999c299057e..9f83317d91f2645e33e13530e6c354d93c549ee5 100644 (file)
--- a/core/mixer/gpu/ogl_device.cpp
+++ b/core/mixer/gpu/ogl_device.cpp
@@ -75,6 +75,32 @@ ogl_device::~ogl_device()
                glDeleteFramebuffersEXT(1, &fbo_);\r
        });\r
 }\r
+\r
+safe_ptr<device_buffer> ogl_device::allocate_device_buffer(size_t width, size_t height, size_t stride)\r
+{\r
+       std::shared_ptr<device_buffer> buffer;\r
+       try\r
+       {\r
+               buffer.reset(new device_buffer(width, height, stride));\r
+       }\r
+       catch(...)\r
+       {\r
+               try\r
+               {\r
+                       yield();\r
+                       gc().wait();\r
+                                       \r
+                       // Try again\r
+                       buffer.reset(new device_buffer(width, height, stride));\r
+               }\r
+               catch(...)\r
+               {\r
+                       CASPAR_LOG(error) << L"ogl: create_device_buffer failed!";\r
+                       throw;\r
+               }\r
+       }\r
+       return make_safe(buffer);\r
+}\r
                                \r
 safe_ptr<device_buffer> ogl_device::create_device_buffer(size_t width, size_t height, size_t stride)\r
 {\r
@@ -83,39 +109,51 @@ safe_ptr<device_buffer> ogl_device::create_device_buffer(size_t width, size_t he
        auto& pool = device_pools_[stride-1][((width << 16) & 0xFFFF0000) | (height & 0x0000FFFF)];\r
        std::shared_ptr<device_buffer> buffer;\r
        if(!pool->items.try_pop(buffer))                \r
-       {\r
-               executor_.invoke([&]\r
-               {       \r
-                       try\r
-                       {\r
-                               buffer.reset(new device_buffer(width, height, stride));\r
-                       }\r
-                       catch(...)\r
-                       {\r
-                               try\r
-                               {\r
-                                       yield();\r
-                                       gc().wait();\r
-                                       \r
-                                       // Try again\r
-                                       buffer.reset(new device_buffer(width, height, stride));\r
-                               }\r
-                               catch(...)\r
-                               {\r
-                                       CASPAR_LOG(error) << L"ogl: create_device_buffer failed!";\r
-                                       throw;\r
-                               }\r
-                       }\r
-               }, high_priority);      \r
-       }\r
+               buffer = executor_.invoke([&]{return allocate_device_buffer(width, height, stride);}, high_priority);                   \r
        \r
-       ++pool->usage_count;\r
+       //++pool->usage_count;\r
 \r
        return safe_ptr<device_buffer>(buffer.get(), [=](device_buffer*) mutable\r
        {               \r
                pool->items.push(buffer);       \r
        });\r
 }\r
+\r
+safe_ptr<host_buffer> ogl_device::allocate_host_buffer(size_t size, host_buffer::usage_t usage)\r
+{\r
+       std::shared_ptr<host_buffer> buffer;\r
+\r
+       try\r
+       {\r
+               buffer.reset(new host_buffer(size, usage));\r
+               if(usage == host_buffer::write_only)\r
+                       buffer->map();\r
+               else\r
+                       buffer->unmap();                        \r
+       }\r
+       catch(...)\r
+       {\r
+               try\r
+               {\r
+                       yield();\r
+                       gc().wait();\r
+\r
+                       // Try again\r
+                       buffer.reset(new host_buffer(size, usage));\r
+                       if(usage == host_buffer::write_only)\r
+                               buffer->map();\r
+                       else\r
+                               buffer->unmap();        \r
+               }\r
+               catch(...)\r
+               {\r
+                       CASPAR_LOG(error) << L"ogl: create_host_buffer failed!";\r
+                       throw;          \r
+               }\r
+       }\r
+\r
+       return make_safe(buffer);\r
+}\r
        \r
 safe_ptr<host_buffer> ogl_device::create_host_buffer(size_t size, host_buffer::usage_t usage)\r
 {\r
@@ -123,42 +161,10 @@ safe_ptr<host_buffer> ogl_device::create_host_buffer(size_t size, host_buffer::u
        CASPAR_VERIFY(size > 0);\r
        auto& pool = host_pools_[usage][size];\r
        std::shared_ptr<host_buffer> buffer;\r
-       if(!pool->items.try_pop(buffer))\r
-       {\r
-               executor_.invoke([&]\r
-               {\r
-                       try\r
-                       {\r
-                               buffer.reset(new host_buffer(size, usage));\r
-                               if(usage == host_buffer::write_only)\r
-                                       buffer->map();\r
-                               else\r
-                                       buffer->unmap();                        \r
-                       }\r
-                       catch(...)\r
-                       {\r
-                               try\r
-                               {\r
-                                       yield();\r
-                                       gc().wait();\r
-\r
-                                       // Try again\r
-                                       buffer.reset(new host_buffer(size, usage));\r
-                                       if(usage == host_buffer::write_only)\r
-                                               buffer->map();\r
-                                       else\r
-                                               buffer->unmap();        \r
-                               }\r
-                               catch(...)\r
-                               {\r
-                                       CASPAR_LOG(error) << L"ogl: create_host_buffer failed!";\r
-                                       throw;          \r
-                               }\r
-                       }\r
-               }, high_priority);      \r
-       }\r
+       if(!pool->items.try_pop(buffer))        \r
+               buffer = executor_.invoke([=]{return allocate_host_buffer(size, usage);}, high_priority);       \r
        \r
-       ++pool->usage_count;\r
+       //++pool->usage_count;\r
 \r
        return safe_ptr<host_buffer>(buffer.get(), [=](host_buffer*) mutable\r
        {\r
@@ -174,43 +180,43 @@ safe_ptr<host_buffer> ogl_device::create_host_buffer(size_t size, host_buffer::u
        });\r
 }\r
 \r
-template<typename T>\r
-void flush_pool(buffer_pool<T>& pool)\r
-{      \r
-       if(pool.flush_count.fetch_and_increment() < 16)\r
-               return;\r
-\r
-       if(pool.usage_count.fetch_and_store(0) < pool.items.size())\r
-       {\r
-               std::shared_ptr<T> buffer;\r
-               pool.items.try_pop(buffer);\r
-       }\r
-\r
-       pool.flush_count = 0;\r
-       pool.usage_count = 0;\r
-}\r
+//template<typename T>\r
+//void flush_pool(buffer_pool<T>& pool)\r
+//{    \r
+//     if(pool.flush_count.fetch_and_increment() < 16)\r
+//             return;\r
+//\r
+//     if(pool.usage_count.fetch_and_store(0) < pool.items.size())\r
+//     {\r
+//             std::shared_ptr<T> buffer;\r
+//             pool.items.try_pop(buffer);\r
+//     }\r
+//\r
+//     pool.flush_count = 0;\r
+//     pool.usage_count = 0;\r
+//}\r
 \r
 void ogl_device::flush()\r
 {\r
        GL(glFlush());  \r
                \r
-       try\r
-       {\r
-               BOOST_FOREACH(auto& pools, device_pools_)\r
-               {\r
-                       BOOST_FOREACH(auto& pool, pools)\r
-                               flush_pool(*pool.second);\r
-               }\r
-               BOOST_FOREACH(auto& pools, host_pools_)\r
-               {\r
-                       BOOST_FOREACH(auto& pool, pools)\r
-                               flush_pool(*pool.second);\r
-               }\r
-       }\r
-       catch(...)\r
-       {\r
-               CASPAR_LOG_CURRENT_EXCEPTION();\r
-       }\r
+       //try\r
+       //{\r
+       //      BOOST_FOREACH(auto& pools, device_pools_)\r
+       //      {\r
+       //              BOOST_FOREACH(auto& pool, pools)\r
+       //                      flush_pool(*pool.second);\r
+       //      }\r
+       //      BOOST_FOREACH(auto& pools, host_pools_)\r
+       //      {\r
+       //              BOOST_FOREACH(auto& pool, pools)\r
+       //                      flush_pool(*pool.second);\r
+       //      }\r
+       //}\r
+       //catch(...)\r
+       //{\r
+       //      CASPAR_LOG_CURRENT_EXCEPTION();\r
+       //}\r
 }\r
 \r
 void ogl_device::yield()\r