Observer::Impl Struct Reference

Classes
struct	FilterData
struct	FilterQueueData
struct	WorkerUpdate

Public Types
using	ChannelRegistryHistory
using	FilterDataPtr = IceUtil::Handle<FilterData>
using	FilterUpdateQueue = std::unordered_map<std::string, FilterQueueData>

Public Attributes
StringConditionCheckMap	availableChecks
ChannelRegistryHistory	channelHistory
std::map< std::string, std::set< std::string > >	channelQueue
std::mutex	channelQueueMutex
ConditionCheck::ChannelRegistry	channelRegistry
RunningTask< Observer >::pointer_type	channelUpdateTask
std::map< std::string, IceUtil::Time >	channelUpdateTimestamps
std::mutex	checksMutex
int	currentId
std::map< std::string, FilterDataPtr >	filteredToOriginal
std::recursive_mutex	filterMutex
FilterUpdateQueue	filterQueue
std::mutex	filterQueueMutex
RunningTask< Observer >::pointer_type	filterUpdateTask
std::recursive_mutex	historyMutex
std::condition_variable	idleChannelCondition
std::condition_variable	idleCondition
std::mutex	idMutex
bool	logChannelUpdateRate = false
float	maxHistoryRecordFrequency
int	maxHistorySize
PeriodicTask< Observer >::pointer_type	metaTask
std::multimap< std::string, FilterDataPtr >	orignalToFiltered
std::atomic_bool	stopWorker
std::thread	worker
std::deque< WorkerUpdate >	workerUpdates
std::recursive_mutex	workerUpdatesMutex

Member Typedef Documentation

ChannelRegistryHistory

using ChannelRegistryHistory

Initial value:

 
        std::unordered_map<std::string,
                           boost::circular_buffer<std::pair<IceUtil::Time, ChannelRegistryEntry>>>

FilterDataPtr

using FilterDataPtr = IceUtil::Handle<FilterData>

FilterUpdateQueue

using FilterUpdateQueue = std::unordered_map<std::string, FilterQueueData>

Member Data Documentation

availableChecks

StringConditionCheckMap availableChecks

channelHistory

ChannelRegistryHistory channelHistory

channelQueue

std::map<std::string, std::set<std::string> > channelQueue

channelQueueMutex

std::mutex channelQueueMutex

channelRegistry

ConditionCheck::ChannelRegistry channelRegistry

channelUpdateTask

RunningTask<Observer>::pointer_type channelUpdateTask

channelUpdateTimestamps

std::map<std::string, IceUtil::Time> channelUpdateTimestamps

checksMutex

std::mutex checksMutex

currentId

int currentId

filteredToOriginal

std::map<std::string, FilterDataPtr> filteredToOriginal

filterMutex

std::recursive_mutex filterMutex

filterQueue

FilterUpdateQueue filterQueue

filterQueueMutex

std::mutex filterQueueMutex

filterUpdateTask

RunningTask<Observer>::pointer_type filterUpdateTask

historyMutex

std::recursive_mutex historyMutex

mutable

idleChannelCondition

std::condition_variable idleChannelCondition

idleCondition

std::condition_variable idleCondition

idMutex

std::mutex idMutex

logChannelUpdateRate

bool logChannelUpdateRate = false

maxHistoryRecordFrequency

float maxHistoryRecordFrequency

maxHistorySize

int maxHistorySize

metaTask

PeriodicTask<Observer>::pointer_type metaTask

orignalToFiltered

std::multimap<std::string, FilterDataPtr> orignalToFiltered

stopWorker

std::atomic_bool stopWorker

worker

std::thread worker

workerUpdates

std::deque<WorkerUpdate> workerUpdates

mutable

workerUpdatesMutex

std::recursive_mutex workerUpdatesMutex

---

The documentation for this struct was generated from the following file:

• ArmarXCore/observers/Observer.cpp