QcepAllocator Class Reference

#include <qcepallocator.h>

Inheritance diagram for QcepAllocator:

Collaboration diagram for QcepAllocator:

Public Types
enum	AllocationStrategy { WaitTillAvailable, NullIfNotAvailable, AllocateFromReserve, AlwaysAllocate }
enum	{ MegaBytes = 0x100000 }

Public Member Functions
	QcepAllocator (QcepSettingsSaverPtr saver)
virtual	~QcepAllocator ()
void	readSettings (QSettings *settings, QString section)
void	writeSettings (QSettings *settings, QString section)
int	int16SizeMB (int width, int height)
int	int32SizeMB (int width, int height)
int	doubleSizeMB (int width, int height)
int	maskSizeMB (int width, int height)
int	integratedSizeMB (int nrows)
double	allocatedMemoryMB ()
double	maximumMemoryMB ()
double	maximumMemory ()
void	changedSizeMB (int newMB)
QMutex *	mutex ()
Public Member Functions inherited from QcepObject
	QcepObject (QString name, QcepObject *parent)
virtual	~QcepObject ()
QString	get_Name () const
void	set_Name (QString name)

Static Public Member Functions
static QcepInt16ImageDataPtr	newInt16Image (AllocationStrategy strat, int width, int height, QcepObject *parent)
static QcepInt32ImageDataPtr	newInt32Image (AllocationStrategy strat, int width, int height, QcepObject *parent)
static QcepDoubleImageDataPtr	newDoubleImage (AllocationStrategy strat, int width, int height, QcepObject *parent)
static QcepMaskDataPtr	newMask (AllocationStrategy strat, int width, int height, int def, QcepObject *parent)
static QcepIntegratedDataPtr	newIntegratedData (AllocationStrategy strat, QcepDoubleImageDataPtr image, QcepObject *parent)
static QcepDoubleImageDataPtr	newDoubleImage (QString name, int width, int height, QcepObject *parent)
static QcepIntegratedDataPtr	newIntegratedData (QString name, int size, QcepObject *parent)
static void	newDoubleImageAndIntegratedData (AllocationStrategy strat, int width, int height, QcepObject *parent, QcepDoubleImageDataPtr &img, QcepIntegratedDataPtr &integ)
static void	allocate (int sz, int width, int height)
static void	deallocate (int sz, int width, int height)
static void	allocate (quint64 amt)
static void	deallocate (quint64 amt)
static quint64	allocatedMemory ()
Static Public Member Functions inherited from QcepObject
static int	allocatedObjects ()
static int	deletedObjects ()
static QSet< QcepObject * >	allocatedObjectsSet ()
static QString	addSlashes (QString str)

Protected Member Functions
void	allocateBytes (quint64 amt)
void	deallocateBytes (quint64 amt)

Properties
int	max
int	totalBufferSizeMB32
int	totalBufferSizeMB64
int	reserve
int	allocated
Properties inherited from QcepObject
QString	name

Private Slots
void	allocatorHeartbeat ()

Private Member Functions
int	waitTillAvailable (AllocationStrategy strat, int sizeMB)

Private Attributes
QMutex	m_Mutex
QTimer	m_Timer
QAtomicInt	m_AllocatedMemoryMB

Additional Inherited Members
Public Slots inherited from QcepObject
virtual void	printLine (QString line)
virtual void	printMessage (QString msg, QDateTime dt=QDateTime::currentDateTime()) const
virtual void	criticalMessage (QString msg, QDateTime ts=QDateTime::currentDateTime()) const
virtual void	statusMessage (QString msg, QDateTime ts=QDateTime::currentDateTime()) const
virtual QString	settingsScript ()
QString	scriptValueLiteral (QVariant v)

Detailed Description

Definition at line 17 of file qcepallocator.h.

Member Enumeration Documentation

anonymous enum

Enumerator
MegaBytes

Definition at line 89 of file qcepallocator.h.

{ MegaBytes = 0x100000 };

enum QcepAllocator::AllocationStrategy

Enumerator
WaitTillAvailable
NullIfNotAvailable
AllocateFromReserve
AlwaysAllocate

Definition at line 30 of file qcepallocator.h.

                          {
    WaitTillAvailable,
    NullIfNotAvailable,
    AllocateFromReserve,
    AlwaysAllocate
  };

Constructor & Destructor Documentation

QcepAllocator::QcepAllocator

(

QcepSettingsSaverPtr

saver

)

Definition at line 15 of file qcepallocator.cpp.

References allocatorHeartbeat(), DEBUG_ALLOCATOR, DEBUG_CONSTRUCTORS, g_Application, HEXARG, m_Timer, QcepApplication::printMessage(), and qcepDebug().

  : QcepObject("allocator", NULL),
    m_Mutex(QMutex::Recursive),
    m_AllocatedMemoryMB(0),
    m_Max(saver, this, "max", 800, "Maximum Image Memory (MB)"),
    m_TotalBufferSizeMB32(saver, this,"totalBufferSizeMB32", 800, "Maximum Image Memory in 32 bit system (MB)"),
    m_TotalBufferSizeMB64(saver, this,"totalBufferSizeMB64", 2000,"Maximum Image Memory in 64 bit system (MB)"),
    m_Reserve(saver, this,"reserve",100, "Extra Reserved Memory (MB)"),
    m_Allocated(QcepSettingsSaverPtr(), this, "allocated", 0, "Allocated Memory (MB)")
{
  if (g_Allocator) {
    printf("Only one allocator can be created\n");
  } else {
    g_Allocator = this;
  }

  if (qcepDebug(DEBUG_CONSTRUCTORS)) {
    printf("QcepAllocator::QcepAllocator(%p)\n", this);
  }

  if (g_Application && qcepDebug(DEBUG_ALLOCATOR)) {
    g_Application->printMessage(tr("allocator %1 constructed").HEXARG(this));
  };

  connect(&m_Timer, SIGNAL(timeout()), this, SLOT(allocatorHeartbeat()));

  m_Timer.start(100);

  allocatorHeartbeat();
}

Here is the call graph for this function:

QcepAllocator::~QcepAllocator ( )

virtual

Definition at line 46 of file qcepallocator.cpp.

References DEBUG_ALLOCATOR, DEBUG_CONSTRUCTORS, g_Application, HEXARG, QcepApplication::printMessage(), and qcepDebug().

{
#ifndef QT_NO_DEBUG
  printf("Deleting allocator\n");
#endif

  g_Allocator = NULL;

  if (qcepDebug(DEBUG_CONSTRUCTORS)) {
    printf("QcepAllocator::~QcepAllocator(%p)\n", this);
  }

  if (g_Application && qcepDebug(DEBUG_ALLOCATOR)) {
    g_Application->printMessage(tr("allocator %1 deleted").HEXARG(this));
  };
}

Here is the call graph for this function:

Member Function Documentation

void QcepAllocator::allocate ( int  sz, int  width, int  height  )

static

Definition at line 308 of file qcepallocator.cpp.

Referenced by QcepDataArray::QcepDataArray(), QcepDataColumn::QcepDataColumn(), QcepImageDataBase::QcepImageDataBase(), QcepIntegratedData::QcepIntegratedData(), QcepIntegratedData::resize(), QcepDataColumn::resize(), and QcepImageData< T >::resize().

{
  if (g_Allocator) {
    g_Allocator -> allocate((quint64) sz*width*height);
  }
}

Here is the caller graph for this function:

void QcepAllocator::allocate ( quint64  amt )

static

Definition at line 316 of file qcepallocator.cpp.

References allocateBytes().

{
  if (g_Allocator) {
    g_Allocator -> allocateBytes(amt);
  }
}

Here is the call graph for this function:

void QcepAllocator::allocateBytes ( quint64  amt )

protected

Definition at line 323 of file qcepallocator.cpp.

References g_AllocatedMemory, m_AllocatedMemoryMB, m_Mutex, and MegaBytes.

Referenced by allocate().

{
  QcepMutexLocker lock(__FILE__, __LINE__, &m_Mutex);

  g_AllocatedMemory += amt;

  m_AllocatedMemoryMB.fetchAndStoreOrdered(g_AllocatedMemory/MegaBytes);
}

Here is the caller graph for this function:

quint64 QcepAllocator::allocatedMemory ( )

static

Definition at line 392 of file qcepallocator.cpp.

References g_AllocatedMemory.

Referenced by main().

{
  return g_AllocatedMemory;
}

Here is the caller graph for this function:

double QcepAllocator::allocatedMemoryMB

(

)

Definition at line 387 of file qcepallocator.cpp.

References m_AllocatedMemoryMB.

Referenced by newDoubleImage(), newDoubleImageAndIntegratedData(), newInt16Image(), newInt32Image(), newIntegratedData(), and newMask().

{
  return m_AllocatedMemoryMB.fetchAndAddOrdered(0);
}

Here is the caller graph for this function:

void QcepAllocator::allocatorHeartbeat ( )

privateslot

Definition at line 382 of file qcepallocator.cpp.

References m_AllocatedMemoryMB.

Referenced by QcepAllocator().

{
  set_Allocated(m_AllocatedMemoryMB.fetchAndAddOrdered(0));
}

Here is the caller graph for this function:

void QcepAllocator::changedSizeMB

(

int

newMB

)

Definition at line 407 of file qcepallocator.cpp.

{
  set_Max(newMB);
}

void QcepAllocator::deallocate ( int  sz, int  width, int  height  )

static

Definition at line 333 of file qcepallocator.cpp.

Referenced by QcepDataArray::~QcepDataArray(), QcepDataColumn::~QcepDataColumn(), QcepImageDataBase::~QcepImageDataBase(), and QcepIntegratedData::~QcepIntegratedData().

{
  if (g_Allocator) {
    g_Allocator -> deallocate((quint64) sz*width*height);
  }
}

Here is the caller graph for this function:

void QcepAllocator::deallocate ( quint64  amt )

static

Definition at line 341 of file qcepallocator.cpp.

References deallocateBytes().

{
  if (g_Allocator) {
    g_Allocator -> deallocateBytes(amt);
  }
}

Here is the call graph for this function:

void QcepAllocator::deallocateBytes ( quint64  amt )

protected

Definition at line 348 of file qcepallocator.cpp.

References g_AllocatedMemory, m_AllocatedMemoryMB, m_Mutex, and MegaBytes.

Referenced by deallocate().

{
  QcepMutexLocker lock(__FILE__, __LINE__, &m_Mutex);

  g_AllocatedMemory -= amt;

  m_AllocatedMemoryMB.fetchAndStoreOrdered(g_AllocatedMemory/MegaBytes);
}

Here is the caller graph for this function:

int QcepAllocator::doubleSizeMB	(	int	width,
		int	height
	)

Definition at line 367 of file qcepallocator.cpp.

References MegaBytes.

Referenced by newDoubleImage(), and newDoubleImageAndIntegratedData().

{
  return sizeof(double)*width*height/MegaBytes;
}

Here is the caller graph for this function:

int QcepAllocator::int16SizeMB	(	int	width,
		int	height
	)

Definition at line 357 of file qcepallocator.cpp.

References MegaBytes.

Referenced by newInt16Image().

{
  return sizeof(quint16)*width*height/MegaBytes;
}

Here is the caller graph for this function:

int QcepAllocator::int32SizeMB	(	int	width,
		int	height
	)

Definition at line 362 of file qcepallocator.cpp.

References MegaBytes.

Referenced by newInt32Image().

{
  return sizeof(quint32)*width*height/MegaBytes;
}

Here is the caller graph for this function:

int QcepAllocator::integratedSizeMB

(

int

nrows

)

Definition at line 377 of file qcepallocator.cpp.

References MegaBytes.

Referenced by newDoubleImageAndIntegratedData(), and newIntegratedData().

{
  return (sizeof(double)*4*nrows)/MegaBytes;
}

Here is the caller graph for this function:

int QcepAllocator::maskSizeMB	(	int	width,
		int	height
	)

Definition at line 372 of file qcepallocator.cpp.

References MegaBytes.

Referenced by newMask().

{
  return sizeof(quint16)*width*height/MegaBytes;
}

Here is the caller graph for this function:

double QcepAllocator::maximumMemory

(

)

Definition at line 402 of file qcepallocator.cpp.

References MegaBytes.

{
  return get_Max()*MegaBytes;
}

double QcepAllocator::maximumMemoryMB

(

)

Definition at line 397 of file qcepallocator.cpp.

{
  return get_Max();
}

QMutex * QcepAllocator::mutex

(

)

Definition at line 85 of file qcepallocator.cpp.

References m_Mutex.

Referenced by newDoubleImage(), newDoubleImageAndIntegratedData(), newInt16Image(), newInt32Image(), newIntegratedData(), and newMask().

{
  return &m_Mutex;
}

Here is the caller graph for this function:

QcepDoubleImageDataPtr QcepAllocator::newDoubleImage ( AllocationStrategy  strat, int  width, int  height, QcepObject *  parent  )

static

Definition at line 169 of file qcepallocator.cpp.

References allocatedMemoryMB(), DEBUG_ALLOCATOR, doubleSizeMB(), g_Application, HEXARG, mutex(), QcepApplication::printMessage(), qcepDebug(), and waitTillAvailable().

Referenced by QxrdDetectorProcessor::doDarkSubtraction(), QxrdGenerateTestImage::generateChiImage(), QxrdGenerateTestImage::generateTTHImage(), newDoubleImage(), QxrdDetectorProcessor::onBadPixelsPathChanged(), QxrdIntegratorCache::performIntegration(), and QxrdDataProcessorBase::takeNextFreeImage().

{
  if (g_Allocator) {
    QcepMutexLocker lock(__FILE__, __LINE__, g_Allocator->mutex());

    if (g_Allocator->waitTillAvailable(strat, g_Allocator->doubleSizeMB(width, height))) {
      QcepDoubleImageDataPtr res(new QcepDoubleImageData(QcepSettingsSaverPtr(), width, height, 0, parent));

      res -> moveToThread(NULL);

      if (g_Application && qcepDebug(DEBUG_ALLOCATOR)) {
        g_Application->printMessage(tr("QcepAllocator::newDoubleImage() succeeded [%1] [%2]").HEXARG(res.data()).arg(g_Allocator->allocatedMemoryMB()));
      }

      return res;
    }
  }

  if (g_Application && qcepDebug(DEBUG_ALLOCATOR)) {
    g_Application->printMessage("QcepAllocator::newDoubleImage() returned NULL");
  }

  return QcepDoubleImageDataPtr(NULL);
}

Here is the call graph for this function:

Here is the caller graph for this function:

QcepDoubleImageDataPtr QcepAllocator::newDoubleImage ( QString  name, int  width, int  height, QcepObject *  parent  )

static

Definition at line 194 of file qcepallocator.cpp.

References g_Application, newDoubleImage(), and NullIfNotAvailable.

{
  QcepDoubleImageDataPtr img;

  if (g_Application) {
   img = newDoubleImage(QcepAllocator::NullIfNotAvailable, width, height, parent);

   if (img) {
     img->set_Name(name);
     img->moveToThread(NULL);
   }
  }

  return img;
}

Here is the call graph for this function:

void QcepAllocator::newDoubleImageAndIntegratedData ( QcepAllocator::AllocationStrategy  strat, int  width, int  height, QcepObject *  parent, QcepDoubleImageDataPtr &  img, QcepIntegratedDataPtr &  integ  )

static

Definition at line 281 of file qcepallocator.cpp.

References allocatedMemoryMB(), DEBUG_ALLOCATOR, doubleSizeMB(), g_Application, HEXARG, integratedSizeMB(), mutex(), QcepApplication::printMessage(), qcepDebug(), and waitTillAvailable().

Referenced by QxrdDataProcessorThreaded::integrateData().

{
  if (g_Allocator) {
    QcepMutexLocker lock(__FILE__, __LINE__, g_Allocator->mutex());

    if (g_Allocator->waitTillAvailable(strat, g_Allocator->doubleSizeMB(width, height) + g_Allocator->integratedSizeMB(10000))) {
      img = QcepDoubleImageDataPtr(new QcepDoubleImageData(QcepSettingsSaverPtr(), width, height, 0, parent));
      integ = QcepIntegratedDataPtr(new QcepIntegratedData(QcepSettingsSaverPtr(), "", img, 10000, parent));

      img->moveToThread(NULL);
      integ->moveToThread(NULL);

      if (g_Application && qcepDebug(DEBUG_ALLOCATOR)) {
        g_Application->printMessage(tr("QcepAllocator::newDoubleImageAndIntegratedData() succeeded [%1] [%2] [%3]")
                          .HEXARG(img.data()).HEXARG(integ.data()).arg(g_Allocator->allocatedMemoryMB()));
      }
    }
  }

  if (g_Application && qcepDebug(DEBUG_ALLOCATOR)) {
    g_Application->printMessage("QcepAllocator::newDoubleImageAndIntegratedData() returned NULL");
  }
}

Here is the call graph for this function:

Here is the caller graph for this function:

QcepInt16ImageDataPtr QcepAllocator::newInt16Image ( AllocationStrategy  strat, int  width, int  height, QcepObject *  parent  )

static

Definition at line 119 of file qcepallocator.cpp.

References allocatedMemoryMB(), DEBUG_ALLOCATOR, g_Application, HEXARG, int16SizeMB(), mutex(), QcepApplication::printMessage(), qcepDebug(), and waitTillAvailable().

Referenced by QxrdDetectorPerkinElmer::onEndFrame(), and QxrdDetectorSimulated::onTimerTimeout().

{
  if (g_Allocator) {
    QcepMutexLocker lock(__FILE__, __LINE__, g_Allocator->mutex());

    if (g_Allocator->waitTillAvailable(strat, g_Allocator->int16SizeMB(width, height))) {
      QcepInt16ImageDataPtr res(new QcepInt16ImageData(QcepSettingsSaverPtr(), width, height, 0, parent));

      res->moveToThread(NULL);

      if (g_Application && qcepDebug(DEBUG_ALLOCATOR)) {
        g_Application->printMessage(tr("QcepAllocator::newInt16Image() succeeded [%1] [%2]").HEXARG(res.data()).arg(g_Allocator->allocatedMemoryMB()));
      }

      return res;
    }
  }

  if (g_Application && qcepDebug(DEBUG_ALLOCATOR)) {
    g_Application->printMessage("QcepAllocator::newInt16Image() returned NULL");
  }

  return QcepInt16ImageDataPtr(NULL);
}

Here is the call graph for this function:

Here is the caller graph for this function:

QcepInt32ImageDataPtr QcepAllocator::newInt32Image ( AllocationStrategy  strat, int  width, int  height, QcepObject *  parent  )

static

Definition at line 144 of file qcepallocator.cpp.

References allocatedMemoryMB(), DEBUG_ALLOCATOR, g_Application, HEXARG, int32SizeMB(), mutex(), QcepApplication::printMessage(), qcepDebug(), and waitTillAvailable().

Referenced by QxrdAcquisition::doAcquire(), QxrdAcquisition::doAcquireDark(), QxrdDetectorPilatus::loadAndPush(), QxrdDetectorProcessor::onDarkImagePathChanged(), and QxrdIntegratorCache::performIntegration().

{
  if (g_Allocator) {
    QcepMutexLocker lock(__FILE__, __LINE__, g_Allocator->mutex());

    if (g_Allocator->waitTillAvailable(strat, g_Allocator->int32SizeMB(width, height))) {
      QcepInt32ImageDataPtr res(new QcepInt32ImageData(QcepSettingsSaverPtr(), width, height, 0, parent));

      res->moveToThread(NULL);

      if (g_Application && qcepDebug(DEBUG_ALLOCATOR)) {
        g_Application->printMessage(tr("QcepAllocator::newInt32Image() succeeded [%1] [%2]").HEXARG(res.data()).arg(g_Allocator->allocatedMemoryMB()));
      }

      return res;
    }
  }

  if (g_Application && qcepDebug(DEBUG_ALLOCATOR)) {
    g_Application->printMessage("QcepAllocator::newInt32Image() returned NULL");
  }

  return QcepInt32ImageDataPtr(NULL);
}

Here is the call graph for this function:

Here is the caller graph for this function:

QcepIntegratedDataPtr QcepAllocator::newIntegratedData ( AllocationStrategy  strat, QcepDoubleImageDataPtr  image, QcepObject *  parent  )

static

Definition at line 235 of file qcepallocator.cpp.

References allocatedMemoryMB(), DEBUG_ALLOCATOR, g_Application, HEXARG, integratedSizeMB(), mutex(), QcepApplication::printMessage(), qcepDebug(), and waitTillAvailable().

Referenced by QxrdDataProcessorThreaded::integrateSaveAndDisplay(), newIntegratedData(), QxrdDataProcessorBase::newOutputScan(), QxrdDataProcessorThreaded::onCorrectedImageAvailable(), QxrdIntegrator::performIntegration(), and QxrdDataProcessorThreaded::slicePolygon().

{
  if (g_Allocator) {
    QcepMutexLocker lock(__FILE__, __LINE__, g_Allocator->mutex());

    if (g_Allocator->waitTillAvailable(strat, g_Allocator->integratedSizeMB(10000))) {
      QcepIntegratedDataPtr res(new QcepIntegratedData(QcepSettingsSaverPtr(),
                                                       "",
                                                       data,
                                                       10000,
                                                       parent));

      res->moveToThread(NULL);

      if (g_Application && qcepDebug(DEBUG_ALLOCATOR)) {
        g_Application->printMessage(tr("QcepAllocator::newIntegratedData() succeeded [%1] [%2]").HEXARG(res.data()).arg(g_Allocator->allocatedMemoryMB()));
      }

      return res;
    }
  }

  if (g_Application && qcepDebug(DEBUG_ALLOCATOR)) {
    g_Application->printMessage("QcepAllocator::newIntegratedData() returned NULL");
  }

  return QcepIntegratedDataPtr(NULL);
}

Here is the call graph for this function:

Here is the caller graph for this function:

QcepIntegratedDataPtr QcepAllocator::newIntegratedData ( QString  name, int  size, QcepObject *  parent  )

static

Definition at line 264 of file qcepallocator.cpp.

References g_Application, newIntegratedData(), and NullIfNotAvailable.

{
  QcepIntegratedDataPtr integ;

  if (g_Application) {
    integ = newIntegratedData(QcepAllocator::NullIfNotAvailable, QcepDoubleImageDataPtr(), parent);

    if (integ) {
      integ->set_Name(name);
      integ->moveToThread(NULL);
      integ->resize(size);
    }
  }

  return integ;
}

Here is the call graph for this function:

QcepMaskDataPtr QcepAllocator::newMask ( AllocationStrategy  strat, int  width, int  height, int  def, QcepObject *  parent  )

static

Definition at line 210 of file qcepallocator.cpp.

References allocatedMemoryMB(), DEBUG_ALLOCATOR, g_Application, HEXARG, maskSizeMB(), mutex(), QcepApplication::printMessage(), qcepDebug(), and waitTillAvailable().

Referenced by QcepMaskData::copyMask(), QxrdAcquisition::doAcquire(), QxrdAcquisition::doAcquireDark(), QxrdDataProcessorBase::findZingers(), QxrdDataProcessorBase::loadMask(), QxrdDataProcessorBase::newMaskStack(), QxrdDetectorProcessor::onMaskPathChanged(), and QxrdDataProcessorBase::pushMaskStack().

{
  if (g_Allocator) {
    QcepMutexLocker lock(__FILE__, __LINE__, g_Allocator->mutex());

    if (g_Allocator->waitTillAvailable(strat, g_Allocator->maskSizeMB(width, height))) {
      QcepMaskDataPtr res(new QcepMaskData(QcepSettingsSaverPtr(), width, height, def, parent));

      res->moveToThread(NULL);

      if (g_Application && qcepDebug(DEBUG_ALLOCATOR)) {
        g_Application->printMessage(tr("QcepAllocator::newMask() succeeded [%1] [%2]").HEXARG(res.data()).arg(g_Allocator->allocatedMemoryMB()));
      }

      return res;
    }
  }

  if (g_Application && qcepDebug(DEBUG_ALLOCATOR)) {
    g_Application->printMessage("QcepAllocator::newMask() returned NULL");
  }

  return QcepMaskDataPtr(NULL);
}

Here is the call graph for this function:

Here is the caller graph for this function:

void QcepAllocator::readSettings ( QSettings *  settings, QString  section  )

virtual

Reimplemented from QcepObject.

Definition at line 70 of file qcepallocator.cpp.

References m_Mutex, MegaBytes, and QcepObject::readSettings().

{
  QcepMutexLocker lock(__FILE__, __LINE__, &m_Mutex);

  QcepObject::readSettings(settings, section);

  if (get_TotalBufferSizeMB32() > 100000000) {
    set_TotalBufferSizeMB32(get_TotalBufferSizeMB32()/MegaBytes);
  }

  if (get_TotalBufferSizeMB64() > 100000000) {
    set_TotalBufferSizeMB64(get_TotalBufferSizeMB64()/MegaBytes);
  }
}

Here is the call graph for this function:

int QcepAllocator::waitTillAvailable ( AllocationStrategy  strat, int  sizeMB  )

private

Definition at line 90 of file qcepallocator.cpp.

References AllocateFromReserve, AlwaysAllocate, DEBUG_ALLOCATOR, g_Application, m_AllocatedMemoryMB, m_Mutex, QcepThread::msleep(), NullIfNotAvailable, QcepApplication::printMessage(), qcepDebug(), and WaitTillAvailable.

Referenced by newDoubleImage(), newDoubleImageAndIntegratedData(), newInt16Image(), newInt32Image(), newIntegratedData(), and newMask().

{
  if (strat == QcepAllocator::WaitTillAvailable) {
    while((m_AllocatedMemoryMB.fetchAndAddOrdered(0) + sizeMB) > get_Max()) {
      m_Mutex.unlock();

      if (qcepDebug(DEBUG_ALLOCATOR)) {
        if (g_Application) {
          g_Application->printMessage("QcepAllocator::waitTillAvailable() sleeping 100msec");
        }
      }

      QcepThread::msleep(100);

      m_Mutex.lock();
    }

    return true;
  } else if (strat == QcepAllocator::NullIfNotAvailable) {
    return ((m_AllocatedMemoryMB.fetchAndAddOrdered(0) + sizeMB) < get_Max());
  } else if (strat == QcepAllocator::AllocateFromReserve) {
    return ((m_AllocatedMemoryMB.fetchAndAddOrdered(0) + sizeMB) < (get_Max() + get_Reserve()));
  } else if (strat == QcepAllocator::AlwaysAllocate) {
    return true;
  } else {
    return false;
  }
}

Here is the call graph for this function:

Here is the caller graph for this function:

void QcepAllocator::writeSettings ( QSettings *  settings, QString  section  )

virtual

Reimplemented from QcepObject.

Definition at line 63 of file qcepallocator.cpp.

References m_Mutex, and QcepObject::writeSettings().

{
  QcepMutexLocker lock(__FILE__, __LINE__, &m_Mutex);

  QcepObject::writeSettings(settings, section);
}

Here is the call graph for this function:

Member Data Documentation

QAtomicInt QcepAllocator::m_AllocatedMemoryMB

private

Definition at line 86 of file qcepallocator.h.

Referenced by allocateBytes(), allocatedMemoryMB(), allocatorHeartbeat(), deallocateBytes(), and waitTillAvailable().

QMutex QcepAllocator::m_Mutex

private

Definition at line 84 of file qcepallocator.h.

Referenced by allocateBytes(), deallocateBytes(), mutex(), readSettings(), waitTillAvailable(), and writeSettings().

QTimer QcepAllocator::m_Timer

private

Definition at line 85 of file qcepallocator.h.

Referenced by QcepAllocator().

Property Documentation

int QcepAllocator::allocated

readwrite

Definition at line 103 of file qcepallocator.h.

int QcepAllocator::max

readwrite

Definition at line 91 of file qcepallocator.h.

int QcepAllocator::reserve

readwrite

Definition at line 100 of file qcepallocator.h.

int QcepAllocator::totalBufferSizeMB32

readwrite

Definition at line 94 of file qcepallocator.h.

int QcepAllocator::totalBufferSizeMB64

readwrite

Definition at line 97 of file qcepallocator.h.

---

The documentation for this class was generated from the following files:

• qcepallocator.h (Commit a65ccc9... : jennings : 2016-03-15 14:00:18 -0500)
• qcepallocator.cpp (Commit a65ccc9... : jennings : 2016-03-15 14:00:18 -0500)