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
|
// $Id$
#include "EventType.h"
#if ! defined (__ACE_INLINE__)
#include "EventType.inl"
#endif /* __ACE_INLINE__ */
ACE_RCSID(RT_Notify, TAO_NS_EventType, "$Id$")
TAO_NS_EventType
TAO_NS_EventType::special (void)
{
return TAO_NS_EventType ("*", "%ALL");
}
TAO_NS_EventType::TAO_NS_EventType (void)
{
}
void
TAO_NS_EventType::init_i (const char* domain_name, const char* type_name)
{
this->event_type_.domain_name = domain_name;
this->event_type_.type_name = type_name;
if (this->is_special () == 1)
{
this->event_type_.domain_name = (const char* )"*";
this->event_type_.type_name = (const char* )"%ALL";
}
this->recompute_hash ();
}
TAO_NS_EventType::TAO_NS_EventType (const char* domain_name, const char* type_name)
{
this->init_i (domain_name, type_name);
}
TAO_NS_EventType::TAO_NS_EventType (const CosNotification::EventType& event_type)
{
this->init_i (event_type.domain_name.in (), event_type.type_name.in ());
}
TAO_NS_EventType::~TAO_NS_EventType ()
{
}
void
TAO_NS_EventType::recompute_hash (void)
{
// @@ Pradeep: this code is bound to crash someday if the strings
// are too long.... See if the hash_pjw () function can be modified
// to take accumulate multiple strings, as in:
// hash = ACE::hash_pjw_accummulate (0, str1);
// hash = ACE::hash_pjw_accummulate (hash, str2);
//
// @@ Or use grow the buffer when needed, or just add the two hash
// values or something, but fix this code!
//
char buffer[BUFSIZ];
ACE_OS::strcpy (buffer, this->event_type_.domain_name.in ());
ACE_OS::strcat (buffer, this->event_type_.type_name.in ());
this->hash_value_ = ACE::hash_pjw (buffer);
}
TAO_NS_EventType&
TAO_NS_EventType::operator=(const CosNotification::EventType& event_type)
{
this->init_i (event_type.domain_name.in (),event_type.type_name.in ());
return *this;
}
TAO_NS_EventType&
TAO_NS_EventType::operator=(const TAO_NS_EventType& event_type)
{
if (this == &event_type)
return *this;
this->init_i (event_type.event_type_.domain_name.in (),event_type.event_type_.type_name.in ());
return *this;
}
int
TAO_NS_EventType::operator==(const TAO_NS_EventType& event_type) const
{
if (this->hash () != event_type.hash ())
return 0;
else // compare the strings
return (ACE_OS::strcmp (this->event_type_.type_name, event_type.event_type_.type_name) == 0 &&
ACE_OS::strcmp (this->event_type_.domain_name, event_type.event_type_.domain_name) == 0
);
}
int
TAO_NS_EventType::operator!=(const TAO_NS_EventType& event_type) const
{
if (this->hash () != event_type.hash ())
return 1;
else // compare the strings
return (ACE_OS::strcmp (this->event_type_.type_name, event_type.event_type_.type_name) != 0 ||
ACE_OS::strcmp (this->event_type_.domain_name, event_type.event_type_.domain_name) != 0
);
}
CORBA::Boolean
TAO_NS_EventType::is_special (void) const
{
if ((this->event_type_.domain_name == 0 ||
ACE_OS::strcmp (this->event_type_.domain_name, "") == 0 ||
ACE_OS::strcmp (this->event_type_.domain_name, "*") == 0) &&
(this->event_type_.type_name == 0 ||
ACE_OS::strcmp (this->event_type_.type_name, "") == 0 ||
ACE_OS::strcmp (this->event_type_.type_name, "*") == 0 ||
ACE_OS::strcmp (this->event_type_.type_name, "%ALL") == 0))
return 1;
else
return 0;
}
void
TAO_NS_EventType::dump (void)
{
ACE_DEBUG ((LM_DEBUG, "(%s,%s)", this->event_type_.domain_name.in (), this->event_type_.type_name.in ()));
}
|
