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
135
|
// -*- C++ -*-
//=============================================================================
/**
* @file FT_PG_Object_Group_Storable.h
*
*
* Contains declaration for class FT_PG_Object_Group_Storable.
*
* @author Byron Harris <harrisb@ociweb.com>
*/
//=============================================================================
#ifndef FT_TAO_PG_OBJECT_GROUP_STORABLE_H_
#define FT_TAO_PG_OBJECT_GROUP_STORABLE_H_
#include /**/ "ace/pre.h"
#include "orbsvcs/Naming/FaultTolerant/ftnaming_export.h"
#if !defined (ACE_LACKS_PRAGMA_ONCE)
#pragma once
#endif /* ACE_LACKS_PRAGMA_ONCE */
/////////////////////////////////
// Includes needed by this header
#include "orbsvcs/PortableGroup/PG_Object_Group_Storable.h"
#include "orbsvcs/FT_NamingReplicationC.h"
TAO_BEGIN_VERSIONED_NAMESPACE_DECL
class TAO_FT_Naming_Replication_Manager;
////////////////
// Class declarations
namespace TAO
{
/**
* An object group whose state persists to a stream so that its state
* can be saved/retrieved between processes that use the group.
*/
class TAO_FtNaming_Export FT_PG_Object_Group_Storable
: public PG_Object_Group_Storable
{
/////////////////////
// Construct/Destruct
public:
/**
* This constructor is suitable for creating an object group from
* scratch.
*/
FT_PG_Object_Group_Storable (
CORBA::ORB_ptr orb,
PortableGroup::FactoryRegistry_ptr factory_registry,
TAO::PG_Object_Group_Manipulator & manipulator,
CORBA::Object_ptr empty_group,
const PortableGroup::TagGroupTaggedComponent & tagged_component,
const char * type_id,
const PortableGroup::Criteria & the_criteria,
const TAO::PG_Property_Set_var & type_properties,
TAO::Storable_Factory & storable_factory,
TAO_FT_Naming_Replication_Manager *replicator);
/**
* This constructor is suitable for creating an object group from
* persistent store.
*/
FT_PG_Object_Group_Storable (
PortableGroup::ObjectGroupId group_id,
CORBA::ORB_ptr orb,
PortableGroup::FactoryRegistry_ptr factory_registry,
TAO::PG_Object_Group_Manipulator & manipulator,
TAO::Storable_Factory & storable_factory,
TAO_FT_Naming_Replication_Manager *replicator);
/// Destructor
virtual ~FT_PG_Object_Group_Storable ();
/////////////////
// public methods
public:
virtual void stale (bool is_stale);
virtual bool stale ();
protected:
virtual void state_written ();
virtual bool is_obsolete (time_t stored_time);
/// Provide support for modifying the object group type_id when first
/// member is added to the group.
virtual PortableGroup::ObjectGroup_ptr add_member_to_iogr(
CORBA::Object_ptr member);
private:
/////////////////////////
// Forbidden methods
FT_PG_Object_Group_Storable ();
FT_PG_Object_Group_Storable (const FT_PG_Object_Group_Storable & rhs);
FT_PG_Object_Group_Storable & operator = (
const FT_PG_Object_Group_Storable & rhs);
/// Replication persistence support
bool stale_;
/// Track if the persistent file used for storage has been created yet
/// so can know if we should propagate a change type of NEW.
bool file_created_;
TAO_FT_Naming_Replication_Manager *replicator_;
/**
* Although it is assumed for replication that services
* using object groups share the persistent store, a
* CORBA message is sent upon update from one replica to
* another so the object group data can be marked as stale.
* This is because using the file time stamp to detect
* if the data has been updated only provides one second
* resolution.
*/
int propagate_update_notification (FT_Naming::ChangeType change_type);
};
} // namespace TAO
TAO_END_VERSIONED_NAMESPACE_DECL
#include /**/ "ace/post.h"
#endif // FT_TAO_PG_OBJECT_GROUP_STORABLE_H_
|
