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
136
137
138
139
140
141
142
|
#include "orbsvcs/Log/NotifyLog_i.h"
#include "orbsvcs/Log/LogMgr_i.h"
#include "orbsvcs/Log/LogNotification.h"
ACE_RCSID (Log,
NotifyLogConsumer,
"$Id$")
TAO_Notify_LogConsumer::TAO_Notify_LogConsumer (TAO_NotifyLog_i *log)
: log_ (log)
{
// No-Op.
}
TAO_Notify_LogConsumer::~TAO_Notify_LogConsumer (void)
{
// No-Op.
}
void
TAO_Notify_LogConsumer::connect (CosNotifyChannelAdmin::ConsumerAdmin_ptr consumer_admin ACE_ENV_ARG_DECL)
{
// Activate the consumer with the default_POA_
CosNotifyComm::PushConsumer_var objref =
this->_this (ACE_ENV_SINGLE_ARG_PARAMETER);
ACE_CHECK;
CosNotifyChannelAdmin::ProxySupplier_var proxysupplier =
consumer_admin->obtain_notification_push_supplier (CosNotifyChannelAdmin::ANY_EVENT, proxy_supplier_id_ ACE_ENV_ARG_PARAMETER);
ACE_CHECK;
ACE_ASSERT (!CORBA::is_nil (proxysupplier.in ()));
// narrow
this->proxy_supplier_ =
CosNotifyChannelAdmin::ProxyPushSupplier::
_narrow (proxysupplier.in () ACE_ENV_ARG_PARAMETER);
ACE_CHECK;
ACE_ASSERT (!CORBA::is_nil (proxy_supplier_.in ()));
proxy_supplier_->connect_any_push_consumer (objref.in ()
ACE_ENV_ARG_PARAMETER);
ACE_CHECK;
}
void
TAO_Notify_LogConsumer::disconnect (ACE_ENV_SINGLE_ARG_DECL)
{
this->proxy_supplier_->
disconnect_push_supplier(ACE_ENV_SINGLE_ARG_PARAMETER);
ACE_CHECK;
}
void
TAO_Notify_LogConsumer::offer_change
(const CosNotification::EventTypeSeq & /*added*/,
const CosNotification::EventTypeSeq & /*removed*/
ACE_ENV_ARG_DECL_NOT_USED)
ACE_THROW_SPEC ((
CORBA::SystemException,
CosNotifyComm::InvalidEventType
))
{
// No-Op.
}
void
TAO_Notify_LogConsumer::push
(const CORBA::Any& event
ACE_ENV_ARG_DECL)
ACE_THROW_SPEC ((
CORBA::SystemException,
CosEventComm::Disconnected
))
{
// create a record list...
DsLogAdmin::RecordList recList (1);
recList.length (1);
recList [0].info = event;
// @@ The current revision of the specification (formal/03-07-01)
// states:
//
// * When a push operation is invoked and a log is full, then a
// NO_RESOURCE (sic) SystemException is raised with a LOGFULL
// minor code.
//
// * When a push operation is invoked on a log that is off-duty,
// then a NO_RESOURCE (sic) SystemException is raised with a
// LOGOFFDUTY minor code.
//
// * When a push operation is invoked on a log that is locked, then
// a NO_PERMISSIONS (sic) SystemException is raised with a LOGLOCKED
// minor code.
//
// * When a push operation is invoked on a log that is disabled,
// then a TRANSIENT SystemException is raised with a LOGDISABLED
// minor code.
//
// But neither the Telecom Logging or the CORBA specification define
// the values for these minor codes.
//
// I have submitted a defect report to the OMG for clarification.
// --jtc
ACE_TRY
{
// log the RecordList.
this->log_->write_recordlist (recList ACE_ENV_ARG_PARAMETER);
ACE_TRY_CHECK;
}
ACE_CATCH (DsLogAdmin::LogFull, ex)
{
ACE_THROW (CORBA::NO_RESOURCES ());
}
ACE_CATCH (DsLogAdmin::LogOffDuty, ex)
{
ACE_THROW (CORBA::NO_RESOURCES ());
}
ACE_CATCH (DsLogAdmin::LogLocked, ex)
{
ACE_THROW (CORBA::NO_PERMISSION ());
}
ACE_CATCH (DsLogAdmin::LogDisabled, ex)
{
ACE_THROW (CORBA::TRANSIENT ());
}
ACE_ENDTRY;
}
void
TAO_Notify_LogConsumer::disconnect_push_consumer
(ACE_ENV_SINGLE_ARG_DECL_NOT_USED)
ACE_THROW_SPEC ((
CORBA::SystemException
))
{
// No-Op.
}
|
