recoveryStore.h

Go to the documentation of this file.

#ifndef recoveryStore_H
#define recoveryStore_H

/*******************************************************************
* E.S.O. - ACS project
*
* "@(#) $Id: recoveryStore.h,v 1.9 2012/01/21 22:48:11 tstaig Exp $"
*
* who       when      what
* --------  --------  ----------------------------------------------
* msekoran  18/02/01  created
*/

#ifndef __cplusplus
#error This is a C++ include file and cannot be used from plain C
#endif

#include <acsutil.h>
#include <recoveryExport.h>

#include <ace/pre.h>
#include <ace/SString.h>
#include <ace/Hash_Map_Manager.h>
#include <ace/Thread_Mutex.h>
#include <ace/Recursive_Thread_Mutex.h>

namespace recovery {

#define MAX_RECORD_SIZE 1500

#define SEPARATOR_CHAR 1

class recovery_EXPORT RecoveryStore
{
public:

  RecoveryStore (const ACE_CString& file_name, bool load = true, ACE_UINT32 max_size = 0);

  ~RecoveryStore (void);

  int open (void);

  int close (void);

  ACE_UINT32 get_max_size (void);

  void set_max_size (ACE_UINT32 size);

  ACE_UINT32 get_current_size (void);

  ACE_UINT32 get_n_records (void);

  int log (const ACE_CString& id, const ACE_CString& data, bool bsave=true);

  int exists (const ACE_CString& id);

  int retrieve (const ACE_CString& id, ACE_CString& data);

  int update (const ACE_CString& id, const ACE_CString& data, bool bsave=true);

  int remove (const ACE_CString& id, bool bsave=true);

  typedef ACE_Hash_Map_Manager <ACE_CString, ACE_CString, ACE_Thread_Mutex> STORE_HASH_MAP;
  typedef ACE_Hash_Map_Iterator <ACE_CString, ACE_CString, ACE_Thread_Mutex> STORE_HASH_MAP_ITER;
  typedef ACE_Hash_Map_Entry <ACE_CString, ACE_CString> STORE_HASH_MAP_ENTRY;

  STORE_HASH_MAP_ITER get_iterator (void);

  int save(void); 

  int load(void); 

  int unlink(void); 

protected:

  RecoveryStore::STORE_HASH_MAP rec_hash_;

  ACE_CString file_name_;

  ACE_UINT32 max_size_;

  ACE_UINT32 current_size_;

  ACE_UINT32 num_records_;

  ACE_Recursive_Thread_Mutex mutex_;
};

#include <ace/post.h>

 }; 

#endif /* recoveryStore_H */

// ************************************************************************
//
// REVISION HISTORY:
//
// $Log: recoveryStore.h,v $
// Revision 1.9  2012/01/21 22:48:11  tstaig
// Backport from branches ACS-9_0_0-windows-B and ACS-9_1_0-windows-B to support
// ACS on Windows under Cygwin. This commit corresponds to several CommonSoftware
// modules.
//
// Revision 1.8  2006/09/01 02:20:55  cparedes
// small change, NAMESPACE_BEGIN / NAMESPACE_END / NAMESPACE_USE macross to clean up a little the cpp code
//
// Revision 1.7  2004/03/17 07:39:50  bjeram
// ported to ACE 5.4 and TAO 1.4
//
// Revision 1.6  2002/02/08 14:21:44  vltsccm
// bgustafs: Removed chmod for VxWorks
//
// Revision 1.5  2001/12/27 19:00:18  vltsccm
// recovery1.5
//
// Revision 1.4  2001/07/12 07:07:22  vltsccm
// recovery1.4
//
// Revision 1.3  2001/07/11 09:15:08  vltsccm
// recovery1.3
//
//
// ************************************************************************