mirror of
https://github.com/Telecominfraproject/wlan-cloud-lib-poco.git
synced 2026-01-28 02:22:36 +00:00
4efaa99fff
* Logger & Channel classes now using AutoPtr<Channel> instead of Channel* (API improvement) * fix CachingChannel * more fixes * Configuration: remove raw pointers from interfaces #2077 * Add WeakPtr to Foundation #2246 * Add WeakPtr to Foundation #2246 (buildsystems files) * Add WeakPtr to Foundation #2246 (x64 VS project files) * backtrace and Event fixes * add ordered map * add ordered set * add sanitize makefiles * update RefPtr doc * fix AtomicCounter includes * add ordered containers tests * fix xml test compile error * remove operator bool rom smart pointers * Poco::strToInt<> fails for values right above the type's boundary / limit #2250 * add g++ -ftrapv config * remove Version.h includes (now included from Config.h) * comment out offending SQLite test (TODO) * add AtomicFlag and SpinlockMutex * remove RefCountedObject include from RefPtr and WeakRefPtr mutex template param * add WeakRef SpinLockMutex threading test * WeakRefPtr, backtrace, NDC, refcount DC fixes * SQL fixes * update RCO documentation * XML/DOM: Remove raw pointers from public interfaces #2075 * few fixes * PocoDoc - make logger non-static reference member * remove path char array initialization * Fix failing unit test, adding d in debug mode for TestApp and TestLibrary * fix application config pointer * fix some crypto warnings * fix Process tests and consolidate TestApp name building * define PathImpl::selfImpl for WinCE * restore WinCE test app name extension * attempt to passify 32 bit clang * fix failing Active* tests * Add POCO_OS_ANDROID support for Path::self() * Add build dependencies between Foundation-testrunner and TestApp, TestLibrary in cmake build * Remove to set LD_LIBRARY_PATH on foundation test * revert to develop XML * fix VS150 env not found (hardcode it) * undef min/max
117 lines
2.0 KiB
C++
117 lines
2.0 KiB
C++
//
|
|
// PoolableConnectionFactory.h
|
|
//
|
|
// Library: Redis
|
|
// Package: Redis
|
|
// Module: PoolableConnectionFactory
|
|
//
|
|
// Definition of the PoolableConnectionFactory class.
|
|
//
|
|
// Copyright (c) 2015, Applied Informatics Software Engineering GmbH.
|
|
// and Contributors.
|
|
//
|
|
// SPDX-License-Identifier: BSL-1.0
|
|
//
|
|
|
|
|
|
#ifndef Redis_PoolableConnectionFactory_INCLUDED
|
|
#define Redis_PoolableConnectionFactory_INCLUDED
|
|
|
|
|
|
#include "Poco/Redis/Client.h"
|
|
#include "Poco/ObjectPool.h"
|
|
|
|
|
|
namespace Poco {
|
|
|
|
|
|
template<>
|
|
class PoolableObjectFactory<Redis::Client, Redis::Client::Ptr>
|
|
/// PoolableObjectFactory specialisation for Client. New connections
|
|
/// are created with the given address.
|
|
{
|
|
public:
|
|
PoolableObjectFactory(Net::SocketAddress& address):
|
|
_address(address)
|
|
{
|
|
}
|
|
|
|
PoolableObjectFactory(const std::string& address):
|
|
_address(address)
|
|
{
|
|
}
|
|
|
|
Redis::Client::Ptr createObject()
|
|
{
|
|
return new Redis::Client(_address);
|
|
}
|
|
|
|
bool validateObject(Redis::Client::Ptr pObject)
|
|
{
|
|
return true;
|
|
}
|
|
|
|
void activateObject(Redis::Client::Ptr pObject)
|
|
{
|
|
}
|
|
|
|
void deactivateObject(Redis::Client::Ptr pObject)
|
|
{
|
|
}
|
|
|
|
void destroyObject(Redis::Client::Ptr pObject)
|
|
{
|
|
}
|
|
|
|
private:
|
|
Net::SocketAddress _address;
|
|
};
|
|
|
|
|
|
namespace Redis {
|
|
|
|
|
|
class PooledConnection
|
|
/// Helper class for borrowing and returning a connection automatically from a pool.
|
|
{
|
|
public:
|
|
PooledConnection(ObjectPool<Client, Client::Ptr>& pool, long timeoutMilliseconds = 0) : _pool(pool)
|
|
{
|
|
#if POCO_VERSION >= 0x01080000
|
|
_client = _pool.borrowObject(timeoutMilliseconds);
|
|
#else
|
|
_client = _pool.borrowObject();
|
|
#endif
|
|
}
|
|
|
|
virtual ~PooledConnection()
|
|
{
|
|
try
|
|
{
|
|
if (_client)
|
|
{
|
|
_pool.returnObject(_client);
|
|
}
|
|
}
|
|
catch (...)
|
|
{
|
|
poco_unexpected();
|
|
}
|
|
}
|
|
|
|
operator Client::Ptr()
|
|
{
|
|
return _client;
|
|
}
|
|
|
|
private:
|
|
ObjectPool<Client, Client::Ptr>& _pool;
|
|
Client::Ptr _client;
|
|
};
|
|
|
|
|
|
} } // namespace Poco::Redis
|
|
|
|
|
|
#endif // Redis_PoolableConnectionFactory_INCLUDED
|