blob: 995577d761ac1e44969fb915eeb536f8badef23a (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
|
// -*- C++ -*-
//=============================================================================
/**
* \file Event_Persistence_Factory.h
*
* $Id$
*
* The standard implementation of Event_Persistence_Factory.
*
* \author Jonathan Pollack <pollack_j@ociweb.com>
*/
//=============================================================================
#ifndef STANDARD_EVENT_PERSISTENCE_H
#define STANDARD_EVENT_PERSISTENCE_H
#include /**/ "ace/pre.h"
#include /**/ "ace/config-all.h"
#if !defined (ACE_LACKS_PRAGMA_ONCE)
#pragma once
#endif /* ACE_LACKS_PRAGMA_ONCE */
#include "orbsvcs/Notify/Event_Persistence_Strategy.h"
#include "orbsvcs/Notify/Event_Persistence_Factory.h"
#include "orbsvcs/Notify/Persistent_File_Allocator.h"
#include "orbsvcs/Notify/Routing_Slip_Persistence_Manager.h"
#include <ace/SString.h>
TAO_BEGIN_VERSIONED_NAMESPACE_DECL
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 ACE_TCHAR* 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 ();
private:
// release the current factory so a new one can be created
virtual void reset ();
ACE_TString filename_; // set via -file_path
ACE_UINT32 block_size_; // set via -block_size
Standard_Event_Persistence_Factory * factory_;
};
}
TAO_END_VERSIONED_NAMESPACE_DECL
ACE_FACTORY_DECLARE (TAO_Notify_Serv, TAO_Notify_Standard_Event_Persistence)
#include /**/ "ace/post.h"
#endif /* STANDARD_EVENT_PERSISTENCE_H */
|
