summaryrefslogtreecommitdiff
path: root/TAO/orbsvcs/orbsvcs/Notify/Standard_Event_Persistence.h
diff options
context:
space:
mode:
Diffstat (limited to 'TAO/orbsvcs/orbsvcs/Notify/Standard_Event_Persistence.h')
-rw-r--r--TAO/orbsvcs/orbsvcs/Notify/Standard_Event_Persistence.h186
1 files changed, 93 insertions, 93 deletions
diff --git a/TAO/orbsvcs/orbsvcs/Notify/Standard_Event_Persistence.h b/TAO/orbsvcs/orbsvcs/Notify/Standard_Event_Persistence.h
index fe8bb7cddf2..ae450d415da 100644
--- a/TAO/orbsvcs/orbsvcs/Notify/Standard_Event_Persistence.h
+++ b/TAO/orbsvcs/orbsvcs/Notify/Standard_Event_Persistence.h
@@ -27,100 +27,100 @@
#include "Routing_Slip_Persistence_Manager.h"
#include <ace/SString.h>
-namespace TAO_NOTIFY
+namespace TAO_Notify
{
-static const ACE_UINT32 ROUTING_SLIP_ROOT_BLOCK_NUMBER = 0;
-static const ACE_UINT64 ROUTING_SLIP_ROOT_SERIAL_NUMBER = 1;
-
-/// \brief Standard (i.e. default) implementation of Event_Persistence_Factory interface
-class TAO_Notify_Serv_Export Standard_Event_Persistence_Factory :
- public Event_Persistence_Factory
-{
-public:
- /// Constructor
- Standard_Event_Persistence_Factory ();
- /// Destructor
- virtual ~Standard_Event_Persistence_Factory();
-
- /// Open persistence file and initialize.
- /// /param filename the fully qualified path/name of the file to contain
- /// persistent information.
- /// /param block_size the size of a physical block on the device containing
- /// the file.
- bool open (const char * filename, ACE_UINT32 block_size = 512);
-
- //////////////////////////////////////////////////////
- // Implement Event_Persistence_Factory virtual methods.
- virtual Routing_Slip_Persistence_Manager*
- create_routing_slip_persistence_manager(Persistent_Callback* callback);
-
- virtual Routing_Slip_Persistence_Manager * first_reload_manager();
-
- /// reloading process complete. Where should the chain continue?
- void done_reloading(
- Persistent_Storage_Block * next_psb,
- ACE_UINT64 current_serial_number);
-
- /// return current serial # and a psb containing current record#
- /// allocate new serial # and record number, and return those, too.
- void preallocate_next_record(
- ACE_UINT64& current_serial_number,
- Persistent_Storage_Block*& current_psb,
- ACE_UINT64& next_serial_number,
- ACE_UINT32& next_block_number);
-
- // return block pointer info for the
- void get_preallocated_pointer(
- ACE_UINT64& next_serial_number,
- ACE_UINT32& next_block_number);
-
- /// Accessor for file allocator.
- /// Intended for use only by the Routing Slip Persistence Manager
- Persistent_File_Allocator* allocator();
-
- /// Access root record.
- /// Intended for use only by the Routing Slip Persistence Manager
- Routing_Slip_Persistence_Manager & root();
-
-public:
- ACE_SYNCH_MUTEX lock;
-
-private:
- Persistent_File_Allocator allocator_;
- Routing_Slip_Persistence_Manager root_;
- Persistent_Storage_Block* psb_;
- ACE_UINT64 serial_number_;
- bool is_reloading_;
-};
-
-/// \brief The standard implementation of the
-/// Event_Persistence_Strategy interface.
-class TAO_Notify_Serv_Export Standard_Event_Persistence :
- public Event_Persistence_Strategy
-{
-public :
- /// Constructor.
- Standard_Event_Persistence ();
- /// Destructor.
- virtual ~Standard_Event_Persistence ();
- /////////////////////////////////////////////
- // Override Event_Persistent_Strategy methods
- // Parse arguments and initialize.
- virtual int init(int argc, ACE_TCHAR *argv[]);
- // Prepare for shutdown
- virtual int fini ();
-
- // get the current factory, creating it if necessary
- virtual Event_Persistence_Factory * get_factory ();
-
- // release the current factory so a new one can be created
- virtual void reset ();
-
-private:
- ACE_CString filename_; // set via -file_path
- ACE_UINT32 block_size_; // set via -block_size
- Standard_Event_Persistence_Factory * factory_;
-};
+ static const ACE_UINT32 ROUTING_SLIP_ROOT_BLOCK_NUMBER = 0;
+ static const ACE_UINT64 ROUTING_SLIP_ROOT_SERIAL_NUMBER = 1;
+
+ /// \brief Standard (i.e. default) implementation of Event_Persistence_Factory interface
+ class TAO_Notify_Serv_Export Standard_Event_Persistence_Factory :
+ public Event_Persistence_Factory
+ {
+ public:
+ /// Constructor
+ Standard_Event_Persistence_Factory ();
+ /// Destructor
+ virtual ~Standard_Event_Persistence_Factory();
+
+ /// Open persistence file and initialize.
+ /// /param filename the fully qualified path/name of the file to contain
+ /// persistent information.
+ /// /param block_size the size of a physical block on the device containing
+ /// the file.
+ bool open (const char * filename, ACE_UINT32 block_size = 512);
+
+ //////////////////////////////////////////////////////
+ // Implement Event_Persistence_Factory virtual methods.
+ virtual Routing_Slip_Persistence_Manager*
+ create_routing_slip_persistence_manager(Persistent_Callback* callback);
+
+ virtual Routing_Slip_Persistence_Manager * first_reload_manager();
+
+ /// reloading process complete. Where should the chain continue?
+ void done_reloading(
+ Persistent_Storage_Block * next_psb,
+ ACE_UINT64 current_serial_number);
+
+ /// return current serial # and a psb containing current record#
+ /// allocate new serial # and record number, and return those, too.
+ void preallocate_next_record(
+ ACE_UINT64& current_serial_number,
+ Persistent_Storage_Block*& current_psb,
+ ACE_UINT64& next_serial_number,
+ ACE_UINT32& next_block_number);
+
+ // return block pointer info for the
+ void get_preallocated_pointer(
+ ACE_UINT64& next_serial_number,
+ ACE_UINT32& next_block_number);
+
+ /// Accessor for file allocator.
+ /// Intended for use only by the Routing Slip Persistence Manager
+ Persistent_File_Allocator* allocator();
+
+ /// Access root record.
+ /// Intended for use only by the Routing Slip Persistence Manager
+ Routing_Slip_Persistence_Manager & root();
+
+ public:
+ ACE_SYNCH_MUTEX lock;
+
+ private:
+ Persistent_File_Allocator allocator_;
+ Routing_Slip_Persistence_Manager root_;
+ Persistent_Storage_Block* psb_;
+ ACE_UINT64 serial_number_;
+ bool is_reloading_;
+ };
+
+ /// \brief The standard implementation of the
+ /// Event_Persistence_Strategy interface.
+ class TAO_Notify_Serv_Export Standard_Event_Persistence :
+ public Event_Persistence_Strategy
+ {
+ public :
+ /// Constructor.
+ Standard_Event_Persistence ();
+ /// Destructor.
+ virtual ~Standard_Event_Persistence ();
+ /////////////////////////////////////////////
+ // Override Event_Persistent_Strategy methods
+ // Parse arguments and initialize.
+ virtual int init(int argc, ACE_TCHAR *argv[]);
+ // Prepare for shutdown
+ virtual int fini ();
+
+ // get the current factory, creating it if necessary
+ virtual Event_Persistence_Factory * get_factory ();
+
+ // release the current factory so a new one can be created
+ virtual void reset ();
+
+ private:
+ ACE_CString filename_; // set via -file_path
+ ACE_UINT32 block_size_; // set via -block_size
+ Standard_Event_Persistence_Factory * factory_;
+ };
}