modules/gapi/src/streaming/onevpl/accelerators/surface/surface_pool.cpp - 4.x - Alx89/OpenCV

modules/gapi/src/streaming/onevpl/accelerators/surface/surface_pool.cpp

86 строк2 KB

Sergey

Merge pull request #21883 from SergeyIvanov87:gapi_vpl_linux

12 май 2022, 11:42

12 май 2022, 11:42eff5605

#include <opencv2/gapi/own/assert.hpp>
#include "streaming/onevpl/accelerators/surface/surface_pool.hpp"
#include "streaming/onevpl/accelerators/surface/surface.hpp"
#include "logger.hpp"

#ifdef HAVE_ONEVPL

namespace cv {
namespace gapi {
namespace wip {
namespace onevpl {

CachedPool::CachedPool(size_t reserved_size/* = 0 */) {
    reserve(reserved_size);
}

void CachedPool::reserve(size_t size) {
    surfaces.reserve(size);
}

size_t CachedPool::total_size() const {
    return surfaces.size();
}

void CachedPool::clear() {
    surfaces.clear();
    next_free_it = surfaces.begin();
    cache.clear();
}

void CachedPool::push_back(surface_ptr_t &&surf) {
    cache.insert(std::make_pair(surf->get_handle(), surf));
    surfaces.push_back(std::move(surf));
    next_free_it = surfaces.begin();
}

size_t CachedPool::available_size() const {
    size_t free_surf_count =
        std::count_if(surfaces.begin(), surfaces.end(),
                     [](const surface_ptr_t& val) {
            GAPI_DbgAssert(val && "Pool contains empty surface");
            return (val->get_locks_count() == 0);
        });
    return free_surf_count;
}

CachedPool::surface_ptr_t CachedPool::find_free() {
    auto it =
        std::find_if(next_free_it, surfaces.end(),
                     [](const surface_ptr_t& val) {
            GAPI_DbgAssert(val && "Pool contains empty surface");
            return (val->get_locks_count() == 0);
        });

    // Limitation realloc pool might be a future extension
    if (it == surfaces.end()) {
        it = std::find_if(surfaces.begin(), next_free_it,
                          [](const surface_ptr_t& val) {
                GAPI_DbgAssert(val && "Pool contains empty surface");
                return (val->get_locks_count() == 0);
            });
        if (it == next_free_it) {
            std::stringstream ss;
            ss << "cannot get free surface from pool, size: " << surfaces.size();
            const std::string& str = ss.str();
            GAPI_LOG_WARNING(nullptr, str);
            throw std::runtime_error(std::string(__FUNCTION__) + " - " + str);
        }
    }

    next_free_it = it;
    ++next_free_it;

    return *it;
}

CachedPool::surface_ptr_t CachedPool::find_by_handle(mfxFrameSurface1* handle) {
    auto it = cache.find(handle);
    GAPI_Assert(it != cache.end() && "Cannot find cached surface from pool. Data corruption is possible");
    return it->second;
}
} // namespace onevpl
} // namespace wip
} // namespace gapi
} // namespace cv
#endif // HAVE_ONEVPL