FieldSynchroManager.h

Go to the documentation of this file.

// Copyright CERN 2012 - Developed in collaboration with GSI

#ifndef FIELD_SYNCHRO_MANAGER_H_
#define FIELD_SYNCHRO_MANAGER_H_

#include <fesa-core/Utilities/Mutex.h>

#include <map>
#include <set>

namespace fesa
{

class DataStore;
class FieldValueBase;
class MultiplexingContext;

class FieldSynchroManager
{
  public:
    static FieldSynchroManager* getInstance();

    void
    registerModifiedField(MultiplexingContext* pContext, DataStore* pDataStore, bool isShared, FieldValueBase* pFieldValue);

    void commitModifiedFieldSynchronization(MultiplexingContext* context);

    void abortModifiedFieldSynchronization(MultiplexingContext* context);

    void commitModifiedFieldSynchronization();

  protected:
    FieldSynchroManager();

    static FieldSynchroManager* theInstance_;

  private:
    typedef std::pair<FieldValueBase*, bool> PairFieldValueShared;

    typedef std::set<PairFieldValueShared> SetPairFieldValueShared;
    typedef std::map<DataStore*, SetPairFieldValueShared> MapDataStoreSetOfPairs;

    typedef std::map<const MultiplexingContext*, MapDataStoreSetOfPairs> MapModifiedFields;

    MapModifiedFields recentlyModifiedFields_;

    Mutex mutex_;
};

} // fesa

#endif // FIELD_SYNCHRO_MANAGER_H_