#include <FFTDataServer.h>

Collaboration diagram for FFTDataServer:

Classes
struct	CacheBlock
class	FillThread
Public Member Functions
const DenseTimeValueModel *	getModel () const
int	getChannel () const
WindowType	getWindowType () const
int	getWindowSize () const
int	getWindowIncrement () const
int	getFFTSize () const
bool	getPolar () const
int	getWidth () const
int	getHeight () const
float	getMagnitudeAt (int x, int y)
float	getNormalizedMagnitudeAt (int x, int y)
float	getMaximumMagnitudeAt (int x)
float	getPhaseAt (int x, int y)
void	getValuesAt (int x, int y, float &real, float &imaginary)
bool	isColumnReady (int x)
bool	getMagnitudesAt (int x, float *values, int minbin=0, int count=0, int step=1)
bool	getNormalizedMagnitudesAt (int x, float *values, int minbin=0, int count=0, int step=1)
bool	getPhasesAt (int x, float *values, int minbin=0, int count=0, int step=1)
bool	getValuesAt (int x, float reals, float imaginaries, int minbin=0, int count=0, int step=1)
void	suspend ()
void	suspendWrites ()
void	resume ()
bool	isLocalPeak (int x, int y)
bool	isOverThreshold (int x, int y, float threshold)
QString	getError () const
int	getFillCompletion () const
int	getFillExtent () const
Static Public Member Functions
static FFTDataServer *	getInstance (const DenseTimeValueModel *model, int channel, WindowType windowType, int windowSize, int windowIncrement, int fftSize, bool polar, StorageAdviser::Criteria criteria=StorageAdviser::NoCriteria, int fillFromColumn=0)
static FFTDataServer *	getFuzzyInstance (const DenseTimeValueModel *model, int channel, WindowType windowType, int windowSize, int windowIncrement, int fftSize, bool polar, StorageAdviser::Criteria criteria=StorageAdviser::NoCriteria, int fillFromColumn=0)
static void	claimInstance (FFTDataServer *)
static void	releaseInstance (FFTDataServer *)
static void	modelAboutToBeDeleted (Model *)
Private Types
typedef float	fftsample
typedef std::vector< CacheBlock * >	CacheVector
typedef std::pair < FFTDataServer *, int >	ServerCountPair
typedef std::map< QString, ServerCountPair >	ServerMap
typedef std::deque < FFTDataServer * >	ServerQueue
Private Member Functions
	FFTDataServer (QString fileBaseName, const DenseTimeValueModel *model, int channel, WindowType windowType, int windowSize, int windowIncrement, int fftSize, bool polar, StorageAdviser::Criteria criteria, int fillFromColumn=0)
virtual	~FFTDataServer ()
	FFTDataServer (const FFTDataServer &)
FFTDataServer &	operator= (const FFTDataServer &)
FFTCacheReader *	getCacheReader (int x, int &col)
FFTCacheWriter *	getCacheWriter (int x, int &col)
bool	haveCache (int x)
bool	makeCache (int c)
bool	makeCacheReader (int c)
void	getStorageAdvice (int w, int h, bool &memory, bool &compact)
void	deleteProcessingData ()
void	fillColumn (int x)
void	fillComplete ()
QString	generateFileBasename () const
Static Private Member Functions
static QString	generateFileBasename (const DenseTimeValueModel *model, int channel, WindowType windowType, int windowSize, int windowIncrement, int fftSize, bool polar)
static FFTDataServer *	findServer (QString)
static void	purgeLimbo (int maxSize=3)
static void	claimInstance (FFTDataServer *, bool needLock)
static void	releaseInstance (FFTDataServer *, bool needLock)
Private Attributes
QString	m_fileBaseName
const DenseTimeValueModel *	m_model
int	m_channel
Window< fftsample >	m_windower
int	m_windowSize
int	m_windowIncrement
int	m_fftSize
bool	m_polar
int	m_width
int	m_height
int	m_cacheWidth
int	m_cacheWidthPower
int	m_cacheWidthMask
CacheVector	m_caches
QReadWriteLock	m_cacheVectorLock
QMutex	m_cacheCreationMutex
StorageAdviser::Criteria	m_criteria
QMutex	m_fftBuffersLock
QWaitCondition	m_condition
fftsample *	m_fftInput
fftf_complex *	m_fftOutput
float *	m_workbuffer
fftf_plan	m_fftPlan
bool	m_exiting
bool	m_suspended
FillThread *	m_fillThread
QString	m_error
Static Private Attributes
static ServerMap	m_servers
static ServerQueue	m_releasedServers
static QMutex	m_serverMapMutex

Detailed Description

Definition at line 40 of file FFTDataServer.h.

Member Typedef Documentation

typedef float FFTDataServer::fftsample [private]

Definition at line 130 of file FFTDataServer.h.

typedef std::vector<CacheBlock *> FFTDataServer::CacheVector [private]

Definition at line 165 of file FFTDataServer.h.

typedef std::pair<FFTDataServer *, int> FFTDataServer::ServerCountPair [private]

Definition at line 279 of file FFTDataServer.h.

typedef std::map<QString, ServerCountPair> FFTDataServer::ServerMap [private]

Definition at line 280 of file FFTDataServer.h.

typedef std::deque<FFTDataServer *> FFTDataServer::ServerQueue [private]

Definition at line 281 of file FFTDataServer.h.

Constructor & Destructor Documentation

FFTDataServer::FFTDataServer	(	QString	fileBaseName,
		const DenseTimeValueModel *	model,
		int	channel,
		WindowType	windowType,
		int	windowSize,
		int	windowIncrement,
		int	fftSize,
		bool	polar,
		StorageAdviser::Criteria	criteria,
		int	fillFromColumn = `0`
	)		`[private]`

!! end is not correct until model finished reading -- what to do???

Definition at line 482 of file FFTDataServer.cpp.

References fftf_complex, fftf_malloc, fftf_plan_dft_r2c_1d, Model::getEndFrame(), Model::getStartFrame(), StorageAdviser::LongRetentionLikely, m_caches, m_cacheWidth, m_cacheWidthMask, m_cacheWidthPower, m_criteria, m_fftInput, m_fftOutput, m_fftPlan, m_fftSize, m_fillThread, m_height, m_model, m_polar, m_width, m_windowIncrement, m_windowSize, m_workbuffer, StorageAdviser::NoCriteria, StorageAdviser::PrecisionCritical, and StorageAdviser::SpeedCritical.

Referenced by getInstance().

FFTDataServer::~FFTDataServer ( ) [private, virtual]

Definition at line 591 of file FFTDataServer.cpp.

References deleteProcessingData(), m_caches, m_cacheVectorLock, m_condition, m_exiting, m_fftBuffersLock, m_fillThread, and m_suspended.

FFTDataServer::FFTDataServer ( const FFTDataServer & ) [private]

Member Function Documentation

FFTDataServer * FFTDataServer::getInstance	(	const DenseTimeValueModel *	model,
		int	channel,
		WindowType	windowType,
		int	windowSize,
		int	windowIncrement,
		int	fftSize,
		bool	polar,
		StorageAdviser::Criteria	criteria = `StorageAdviser::NoCriteria`,
		int	fillFromColumn = `0`
	)		`[static]`

Definition at line 48 of file FFTDataServer.cpp.

References FFTDataServer(), findServer(), generateFileBasename(), m_serverMapMutex, and m_servers.

Referenced by getFuzzyInstance().

FFTDataServer * FFTDataServer::getFuzzyInstance	(	const DenseTimeValueModel *	model,
		int	channel,
		WindowType	windowType,
		int	windowSize,
		int	windowIncrement,
		int	fftSize,
		bool	polar,
		StorageAdviser::Criteria	criteria = `StorageAdviser::NoCriteria`,
		int	fillFromColumn = `0`
	)		`[static]`

Definition at line 110 of file FFTDataServer.cpp.

References claimInstance(), getChannel(), DenseTimeValueModel::getChannelCount(), getFFTSize(), getFillCompletion(), getInstance(), getModel(), getPolar(), getWindowIncrement(), getWindowSize(), getWindowType(), m_serverMapMutex, and m_servers.

Referenced by FFTFuzzyAdapter::FFTFuzzyAdapter(), and FFTModel::getServer().

void FFTDataServer::claimInstance ( FFTDataServer * server ) [static]

Definition at line 255 of file FFTDataServer.cpp.

Referenced by FFTModel::FFTModel(), findServer(), and getFuzzyInstance().

void FFTDataServer::releaseInstance ( FFTDataServer * server ) [static]

Definition at line 300 of file FFTDataServer.cpp.

Referenced by FFTModel::sourceModelAboutToBeDeleted(), FFTFuzzyAdapter::~FFTFuzzyAdapter(), and FFTModel::~FFTModel().

void FFTDataServer::modelAboutToBeDeleted ( Model * model ) [static]

Definition at line 436 of file FFTDataServer.cpp.

References getModel(), m_releasedServers, m_serverMapMutex, m_servers, and suspendWrites().

Referenced by FFTModel::sourceModelAboutToBeDeleted().

const DenseTimeValueModel* FFTDataServer::getModel ( ) const [inline]

Definition at line 70 of file FFTDataServer.h.

References m_model.

Referenced by FFTModel::estimateStableFrequency(), getFuzzyInstance(), FFTModel::getSampleRate(), FFTModel::isOK(), and modelAboutToBeDeleted().

int FFTDataServer::getChannel ( ) const [inline]

Definition at line 71 of file FFTDataServer.h.

References m_channel.

Referenced by getFuzzyInstance().

WindowType FFTDataServer::getWindowType ( ) const [inline]

Definition at line 72 of file FFTDataServer.h.

References Window< T >::getType(), and m_windower.

Referenced by getFuzzyInstance().

int FFTDataServer::getWindowSize ( ) const [inline]

Definition at line 73 of file FFTDataServer.h.

References m_windowSize.

Referenced by getFuzzyInstance().

int FFTDataServer::getWindowIncrement ( ) const [inline]

Definition at line 74 of file FFTDataServer.h.

References m_windowIncrement.

Referenced by FFTFuzzyAdapter::FFTFuzzyAdapter(), FFTModel::FFTModel(), getFuzzyInstance(), and FFTModel::getResolution().

int FFTDataServer::getFFTSize ( ) const [inline]

Definition at line 75 of file FFTDataServer.h.

References m_fftSize.

Referenced by FFTModel::estimateStableFrequency(), FFTFuzzyAdapter::FFTFuzzyAdapter(), FFTModel::FFTModel(), getFuzzyInstance(), FFTModel::getPeakFrequencies(), and FFTModel::getPeakPickWindowSize().

bool FFTDataServer::getPolar ( ) const [inline]

Definition at line 76 of file FFTDataServer.h.

References m_polar.

Referenced by getFuzzyInstance().

int FFTDataServer::getWidth ( ) const [inline]

Definition at line 78 of file FFTDataServer.h.

References m_width.

Referenced by FFTFuzzyAdapter::getWidth(), and FFTModel::getWidth().

int FFTDataServer::getHeight ( ) const [inline]

Definition at line 79 of file FFTDataServer.h.

References m_height.

Referenced by FFTFuzzyAdapter::getHeight(), FFTModel::getHeight(), and isLocalPeak().

float FFTDataServer::getMagnitudeAt	(	int	x,
		int	y
	)

Definition at line 888 of file FFTDataServer.cpp.

References fillColumn(), getCacheReader(), FFTCacheReader::getMagnitudeAt(), FFTCacheReader::haveSetColumnAt(), m_error, m_height, and m_width.

Referenced by FFTFuzzyAdapter::getMagnitudeAt(), FFTModel::getMagnitudeAt(), isLocalPeak(), and isOverThreshold().

float FFTDataServer::getNormalizedMagnitudeAt	(	int	x,
		int	y
	)

Definition at line 953 of file FFTDataServer.cpp.

References fillColumn(), getCacheReader(), FFTCacheReader::getNormalizedMagnitudeAt(), FFTCacheReader::haveSetColumnAt(), m_error, m_height, and m_width.

Referenced by FFTFuzzyAdapter::getNormalizedMagnitudeAt(), and FFTModel::getNormalizedMagnitudeAt().

float FFTDataServer::getMaximumMagnitudeAt ( int x )

Definition at line 1017 of file FFTDataServer.cpp.

References fillColumn(), getCacheReader(), FFTCacheReader::getMaximumMagnitudeAt(), FFTCacheReader::haveSetColumnAt(), m_error, and m_width.

Referenced by FFTFuzzyAdapter::getMaximumMagnitudeAt(), and FFTModel::getMaximumMagnitudeAt().

float FFTDataServer::getPhaseAt	(	int	x,
		int	y
	)

Definition at line 1045 of file FFTDataServer.cpp.

References fillColumn(), getCacheReader(), FFTCacheReader::getPhaseAt(), FFTCacheReader::haveSetColumnAt(), m_error, m_height, and m_width.

Referenced by FFTFuzzyAdapter::getPhaseAt(), and FFTModel::getPhaseAt().

void FFTDataServer::getValuesAt	(	int	x,
		int	y,
		float &	real,
		float &	imaginary
	)

Definition at line 1109 of file FFTDataServer.cpp.

References fillColumn(), getCacheReader(), FFTCacheReader::getValuesAt(), FFTCacheReader::haveSetColumnAt(), m_error, m_height, and m_width.

Referenced by FFTFuzzyAdapter::getValuesAt(), and FFTModel::getValuesAt().

bool FFTDataServer::isColumnReady ( int x )

!! if (m_lastUsedCache == -1) { if (m_suspended) { std::cerr << "FFTDataServer::isColumnReady(" << x << "): no cache, calling resume" << std::endl; resume(); } m_fillThread->start(); }

Definition at line 1182 of file FFTDataServer.cpp.

References getCacheReader(), haveCache(), FFTCacheReader::haveSetColumnAt(), m_error, and m_width.

Referenced by FFTModel::isColumnAvailable(), and FFTFuzzyAdapter::isColumnReady().

bool FFTDataServer::getMagnitudesAt	(	int	x,
		float *	values,
		int	minbin = `0`,
		int	count = `0`,
		int	step = `1`
	)

Definition at line 920 of file FFTDataServer.cpp.

References fillColumn(), getCacheReader(), FFTCacheReader::getMagnitudesAt(), FFTCacheReader::haveSetColumnAt(), m_error, m_height, and m_width.

Referenced by FFTModel::getColumn(), and FFTModel::getMagnitudesAt().

bool FFTDataServer::getNormalizedMagnitudesAt	(	int	x,
		float *	values,
		int	minbin = `0`,
		int	count = `0`,
		int	step = `1`
	)

Definition at line 981 of file FFTDataServer.cpp.

References fillColumn(), getCacheReader(), FFTCacheReader::getNormalizedMagnitudeAt(), FFTCacheReader::haveSetColumnAt(), m_error, m_height, and m_width.

Referenced by FFTModel::getNormalizedMagnitudesAt().

bool FFTDataServer::getPhasesAt	(	int	x,
		float *	values,
		int	minbin = `0`,
		int	count = `0`,
		int	step = `1`
	)

Definition at line 1073 of file FFTDataServer.cpp.

References fillColumn(), getCacheReader(), FFTCacheReader::getPhaseAt(), FFTCacheReader::haveSetColumnAt(), m_error, m_height, and m_width.

Referenced by FFTModel::getPhasesAt().

bool FFTDataServer::getValuesAt	(	int	x,
		float *	reals,
		float *	imaginaries,
		int	minbin = `0`,
		int	count = `0`,
		int	step = `1`
	)

Definition at line 1146 of file FFTDataServer.cpp.

References fillColumn(), getCacheReader(), FFTCacheReader::getValuesAt(), FFTCacheReader::haveSetColumnAt(), m_error, m_height, and m_width.

void FFTDataServer::suspend ( )

Definition at line 636 of file FFTDataServer.cpp.

References m_fftBuffersLock, and m_suspended.

Referenced by releaseInstance(), and FFTModel::suspend().

void FFTDataServer::suspendWrites ( )

Definition at line 648 of file FFTDataServer.cpp.

References m_suspended.

Referenced by modelAboutToBeDeleted(), and FFTModel::suspendWrites().

void FFTDataServer::resume ( )

Definition at line 659 of file FFTDataServer.cpp.

References deleteProcessingData(), m_condition, m_fillThread, m_suspended, and Thread::start().

Referenced by FFTModel::resume().

bool FFTDataServer::isLocalPeak	(	int	x,
		int	y
	)		`[inline]`

Definition at line 99 of file FFTDataServer.h.

References getHeight(), and getMagnitudeAt().

bool FFTDataServer::isOverThreshold	(	int	x,
		int	y,
		float	threshold
	)		`[inline]`

Definition at line 105 of file FFTDataServer.h.

References getMagnitudeAt().

QString FFTDataServer::getError ( ) const

Definition at line 1393 of file FFTDataServer.cpp.

References FFTDataServer::FillThread::getError(), m_error, and m_fillThread.

Referenced by FFTModel::getError().

int FFTDataServer::getFillCompletion ( ) const

Definition at line 1401 of file FFTDataServer.cpp.

References FFTDataServer::FillThread::getCompletion(), and m_fillThread.

Referenced by FFTModel::getCompletion(), FFTFuzzyAdapter::getFillCompletion(), and getFuzzyInstance().

int FFTDataServer::getFillExtent ( ) const

Definition at line 1408 of file FFTDataServer.cpp.

References Model::getEndFrame(), FFTDataServer::FillThread::getExtent(), m_fillThread, and m_model.

Referenced by FFTFuzzyAdapter::getFillExtent(), and FFTModel::getFillExtent().

FFTDataServer& FFTDataServer::operator= ( const FFTDataServer & ) [private]

FFTCacheReader* FFTDataServer::getCacheReader	(	int	x,
		int &	col
	)		`[inline, private]`

Definition at line 170 of file FFTDataServer.h.

References m_caches, m_cacheVectorLock, m_cacheWidthMask, m_cacheWidthPower, makeCache(), and makeCacheReader().

Referenced by getMagnitudeAt(), getMagnitudesAt(), getMaximumMagnitudeAt(), getNormalizedMagnitudeAt(), getNormalizedMagnitudesAt(), getPhaseAt(), getPhasesAt(), getValuesAt(), and isColumnReady().

FFTCacheWriter* FFTDataServer::getCacheWriter	(	int	x,
		int &	col
	)		`[inline, private]`

Definition at line 203 of file FFTDataServer.h.

References m_caches, m_cacheVectorLock, m_cacheWidthMask, m_cacheWidthPower, makeCache(), and FFTDataServer::CacheBlock::memoryCache.

Referenced by fillColumn().

bool FFTDataServer::haveCache ( int x ) [inline, private]

Definition at line 221 of file FFTDataServer.h.

References m_caches, and m_cacheWidthPower.

Referenced by isColumnReady().

bool FFTDataServer::makeCache ( int c ) [private]

Definition at line 740 of file FFTDataServer.cpp.

References FFTCache::Compact, FFTDataServer::CacheBlock::fileCacheWriter, getStorageAdvice(), m_cacheCreationMutex, m_caches, m_cacheVectorLock, m_cacheWidth, m_fileBaseName, m_height, m_polar, m_width, FFTDataServer::CacheBlock::memoryCache, FFTCache::Polar, and FFTCache::Rectangular.

Referenced by getCacheReader(), and getCacheWriter().

bool FFTDataServer::makeCacheReader ( int c ) [private]

Definition at line 839 of file FFTDataServer.cpp.

References FFTDataServer::CacheBlock::fileCacheReader, m_caches, and m_cacheVectorLock.

Referenced by getCacheReader().

void FFTDataServer::getStorageAdvice	(	int	w,
		int	h,
		bool &	memory,
		bool &	compact
	)		`[private]`

Definition at line 681 of file FFTDataServer.cpp.

References StorageAdviser::ConserveSpace, m_criteria, m_polar, m_width, StorageAdviser::PrecisionCritical, StorageAdviser::PreferMemory, purgeLimbo(), StorageAdviser::recommend(), and StorageAdviser::UseMemory.

Referenced by makeCache().

void FFTDataServer::deleteProcessingData ( ) [private]

Definition at line 621 of file FFTDataServer.cpp.

References fftf_destroy_plan, fftf_free, m_fftInput, m_fftOutput, m_fftPlan, and m_workbuffer.

Referenced by resume(), and ~FFTDataServer().

void FFTDataServer::fillColumn ( int x ) [private]

void FFTDataServer::fillComplete ( ) [private]

Definition at line 1379 of file FFTDataServer.cpp.

References m_caches.

Referenced by FFTDataServer::FillThread::run().

QString FFTDataServer::generateFileBasename ( ) const [private]

Definition at line 1415 of file FFTDataServer.cpp.

References Window< T >::getType(), m_channel, m_fftSize, m_model, m_polar, m_windower, m_windowIncrement, and m_windowSize.

Referenced by getInstance().

QString FFTDataServer::generateFileBasename	(	const DenseTimeValueModel *	model,
		int	channel,
		WindowType	windowType,
		int	windowSize,
		int	windowIncrement,
		int	fftSize,
		bool	polar
	)		`[static, private]`

Definition at line 1423 of file FFTDataServer.cpp.

References XmlExportable::getObjectExportId().

FFTDataServer * FFTDataServer::findServer ( QString n ) [static, private]

Definition at line 228 of file FFTDataServer.cpp.

References claimInstance(), and m_servers.

Referenced by getInstance().

void FFTDataServer::purgeLimbo ( int maxSize = 3 ) [static, private]

Definition at line 378 of file FFTDataServer.cpp.

References m_releasedServers, and m_servers.

Referenced by getStorageAdvice(), and releaseInstance().

void FFTDataServer::claimInstance	(	FFTDataServer *	server,
		bool	needLock
	)		`[static, private]`

Definition at line 261 of file FFTDataServer.cpp.

References m_releasedServers, m_serverMapMutex, and m_servers.

void FFTDataServer::releaseInstance	(	FFTDataServer *	server,
		bool	needLock
	)		`[static, private]`

!! if (server->m_lastUsedCache == -1) { // never used #ifdef DEBUG_FFT_SERVER std::cerr << "FFTDataServer::releaseInstance: instance " << server << " has never been used, erasing" << std::endl; #endif delete server; m_servers.erase(i); } else {

!! }

Definition at line 306 of file FFTDataServer.cpp.

References m_releasedServers, m_serverMapMutex, m_servers, purgeLimbo(), and suspend().