/*
|
* Copyright (c) 2019 Rockchip Corporation
|
*
|
* 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
|
*
|
* Unless required by applicable law or agreed to in writing, software
|
* distributed under the License is distributed on an "AS IS" BASIS,
|
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
|
* See the License for the specific language governing permissions and
|
* limitations under the License.
|
*
|
*/
|
|
#include "shared_item_pool.h"
|
|
namespace RkCam {
|
|
template<typename T>
|
SharedItemPool<T>::SharedItemPool(const char* name, uint32_t max_count)
|
: BufferPool()
|
,_name(name ? name : "default")
|
, _max_count(max_count)
|
{
|
LOG1("ENTER SharedItemPool<%s>:%s", _name, __FUNCTION__);
|
if (_max_count > 0)
|
reserve (_max_count);
|
LOG1("EXIT SharedItemPool<%s>:%s", _name, __FUNCTION__);
|
}
|
|
template<typename T>
|
SharedItemPool<T>::~SharedItemPool()
|
{
|
LOG1("ENTER SharedItemPool<%s>:%s", _name, __FUNCTION__);
|
LOG1("EXIT SharedItemPool<%s>:%s", _name, __FUNCTION__);
|
}
|
|
template<typename T>
|
int8_t SharedItemPool<T>::init(uint32_t max_count)
|
{
|
if (_max_count > 0)
|
return -1;
|
if (!reserve (max_count))
|
return -1;
|
|
_max_count = get_free_buffer_size ();
|
|
return 0;
|
}
|
|
template<typename T>
|
SmartPtr<SharedItemProxy<T>>
|
SharedItemPool<T>::get_item()
|
{
|
#if 0 // dynamic_cast_ptr has performance issue
|
SmartPtr<VideoBuffer> buf = get_buffer();
|
SmartPtr<SharedItemProxy<T>> proxy =
|
buf.dynamic_cast_ptr<SharedItemProxy<T>>() ;
|
return proxy;
|
#else
|
// get buf directly, save one call of dynamic_cast_ptr
|
SmartPtr<SharedItemProxy<T>> ret_buf;
|
SmartPtr<BufferData> data;
|
|
{
|
SmartLock lock (_mutex);
|
if (!_started)
|
return NULL;
|
}
|
|
data = _buf_list.pop ();
|
if (!data.ptr ()) {
|
XCAM_LOG_DEBUG ("BufferPool failed to get buffer");
|
return NULL;
|
}
|
SmartPtr<T> data_t = data.dynamic_cast_ptr<T>();
|
ret_buf = new SharedItemProxy<T> (data_t);;
|
ret_buf->set_buf_pool (SmartPtr<BufferPool>(this));
|
|
return ret_buf;
|
#endif
|
}
|
|
template<typename T>
|
SmartPtr<BufferData> SharedItemPool<T>::allocate_data (const VideoBufferInfo &buffer_info)
|
{
|
return new T();
|
}
|
|
template<typename T>
|
SmartPtr<BufferProxy> SharedItemPool<T>::create_buffer_from_data (SmartPtr<BufferData> &data)
|
{
|
XCAM_ASSERT (data.ptr ());
|
SmartPtr<T> data_t = data.dynamic_cast_ptr<T>();
|
return new SharedItemProxy<T> (data_t);
|
}
|
|
};
|
