/usr/include/cppdb/pool.h is in libcppdb-dev 0.3.1+dfsg-3build1.
This file is owned by root:root, with mode 0o644.
The actual contents of the file can be viewed below.
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 105 106 107 108 109 110 111 | ///////////////////////////////////////////////////////////////////////////////
//
// Copyright (C) 2010-2011 Artyom Beilis (Tonkikh) <artyomtnk@yahoo.com>
//
// Distributed under:
//
// the Boost Software License, Version 1.0.
// (See accompanying file LICENSE_1_0.txt or copy at
// http://www.boost.org/LICENSE_1_0.txt)
//
// or (at your opinion) under:
//
// The MIT License
// (See accompanying file MIT.txt or a copy at
// http://www.opensource.org/licenses/mit-license.php)
//
///////////////////////////////////////////////////////////////////////////////
#ifndef CPPDB_POOL_H
#define CPPDB_POOL_H
#include <cppdb/defs.h>
#include <cppdb/ref_ptr.h>
#include <cppdb/mutex.h>
#include <cppdb/utils.h>
#include <memory>
#include <list>
namespace cppdb {
class connection_info;
namespace backend {
class connection;
}
///
/// \brief Connections pool, allows to handle multiple connections for specific connection string.
///
/// Note \ref connections_manager provide more generic interface and hides pools inside it. So you
/// generally should use this class only when you prefer to avoid using some global singleton object.
///
/// Unlike \ref connections_manager, it uses pool by default unless its size defined as 0.
///
/// All this class member functions are thread safe to use from several threads for the same object
///
class CPPDB_API pool : public ref_counted {
pool();
pool(pool const &);
void operator=(pool const &);
pool(connection_info const &ci);
public:
/// Create new pool for \a connection_string
static ref_ptr<pool> create(std::string const &connection_string);
/// Create new pool for a parsed connection string \a ci
static ref_ptr<pool> create(connection_info const &ci);
///
/// Shortcut of cppdb::ref_ptr<cppdb::pool> as cppdb::pool::pointer.
///
/// The pointer that is used to handle pool object
///
typedef ref_ptr<pool> pointer;
~pool();
///
/// Get a open a connection, it may be fetched either from pool or new one may be created
///
ref_ptr<backend::connection> open();
///
/// Collect connections that were not used for a long time (close them)
///
void gc();
///
/// Remove all connections from the pool
///
void clear();
/// \cond INTERNAL
void put(backend::connection *c_in);
/// \endcond
private:
ref_ptr<backend::connection> get();
struct data;
std::auto_ptr<data> d;
struct entry {
entry() : last_used(0) {}
ref_ptr<backend::connection> conn;
std::time_t last_used;
};
typedef std::list<entry> pool_type;
// non-mutable members
size_t limit_;
int life_time_;
connection_info ci_;
// mutex protected begin
mutex lock_;
size_t size_;
pool_type pool_;
// mutex protected end
};
}
#endif
|