/usr/include/ossim/base/ossimPool.h is in libossim-dev 1.7.21-3ubuntu2.
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 112 113 114 115 116 117 118 119 120 121 122 123 124 125 126 127 128 129 130 131 132 133 134 135 136 | //*******************************************************************
//
// License: See top level LICENSE.txt file.
//
// Author: Garrett Potts
//
//**********************************************************************
// $Id: ossimPool.h 9968 2006-11-29 14:01:53Z gpotts $
#ifndef ossimPool_HEADER
#define ossimPool_HEADER
#include <iostream>
#include <vector>
#include <exception>
#include <stdexcept>
#include <ossim/base/ossimCommon.h>
#include <ossim/base/ossimConstants.h>
#include <ossim/base/ossimPoolObject.h>
#include <ossim/base/ossimNotifyContext.h>
#define OSSIM_DEFAULT_POOL_SIZE (ossim_uint32)10
/**
* Container pool to be used for things like threads.
*/
template <class T>
class ossimPool
{
public:
/**
* Contructor
* @param n Number of pooled objects to create.
*/
ossimPool(ossim_uint32 n=OSSIM_DEFAULT_POOL_SIZE) throw(std::bad_alloc)
: thePool(n)
{
for(ossim_uint32 idx = 0; idx < n; ++idx)
{
try
{
ossimPoolObject<T>* poolObject = new ossimPoolObject<T>();
poolObject->theAvailableFlag = true;
poolObject->theObjectPtr = new T();
thePool[idx] = poolObject;
}
catch(std::bad_alloc)
{
ossimNotify(ossimNotifyLevel_FATAL)
<< "FATAL ossimPool::ossimPool(): Bad allocation" << endl;
}
}
}
/**
* Destructor
*/
~ossimPool()
{
thePool.clear();
}
/**
* @return A pooled object of type T*. Will return null if the pool is
* used up or pool size is zero.
*/
T* checkout()
{
T* t = NULL;
theCriticalSectionMutex.lock();
for (ossim_uint32 idx = 0; idx < thePool.size(); ++idx)
{
if (thePool[idx]->theAvailableFlag == true)
{
thePool[idx]->theAvailableFlag = false;
t = thePool[idx]->theObjectPtr;
break;
}
}
theCriticalSectionMutex.unlock();
return t;
}
/**
* Resets and eturns object to the pool.
* @param obj Object to be returned to the pool.
*
* @note The object is required to have a "reset()" method.
*
* @return Returns void unless object was not from pool then throws
* a std::out_of_range error.
*/
void checkin(T* obj) throw(std::out_of_range)
{
theCriticalSectionMutex.lock();
for (ossim_uint32 idx = 0; idx < thePool.size(); ++idx)
{
if (obj == thePool[idx]->theObjectPtr)
{
obj->reset();
thePool[idx]->theAvailableFlag = true;
theCriticalSectionMutex.unlock();
return;
}
}
theCriticalSectionMutex.unlock();
throw std::out_of_range(string("ossimPool<T>::checkin Error Object not managed by this pool!"));
}
/**
* Outputs object addresses and theAvailableFlag.
*/
std::ostream& print(std::ostream& out) const
{
for (ossim_uint32 idx = 0; idx < thePool.size(); ++idx)
{
out << "obj address: " << (hex) << thePool[idx]->theObjectPtr
<< " is "
<< (thePool[idx]->theAvailableFlag ? "available":"unavailable")
<< endl;
}
return out;
}
template <class C> friend std::ostream& operator<<(std::ostream& out,
const ossimPool<C>& obj)
{
return obj.print(out);
}
protected:
std::vector<ossimPoolObject<T>*> thePool;
};
#endif /* #ifndef ossimPool_HEADER */
|