blob: 485055ef799300cff96fc7ab4972e392a5d5cbe6 (
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
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
|
/* -*- C++ -*- */
//=============================================================================
/**
* @file Supplier.h
*
* Test Supplier reconnect to existing channel/admin/proxy Notification Service
*
* @author Dale Wilson <wilson_d@ociweb.com>
*/
//=============================================================================
#ifndef RECONNECTNG_SUPPLIER_H
#define RECONNECTNG_SUPPLIER_H
#include "orbsvcs/CosNotifyChannelAdminC.h"
#include "orbsvcs/CosNamingC.h"
#include "orbsvcs/NotifyExtS.h"
#include <ace/SString.h>
class Supplier_Main;
class StructuredPushSupplier_i : public virtual POA_CosNotifyComm::StructuredPushSupplier
{
virtual void subscription_change (
const CosNotification::EventTypeSeq & added,
const CosNotification::EventTypeSeq & removed);
virtual void disconnect_structured_push_supplier (void);
};
class SequencePushSupplier_i : public virtual POA_CosNotifyComm::SequencePushSupplier
{
virtual void subscription_change (
const CosNotification::EventTypeSeq & added,
const CosNotification::EventTypeSeq & removed);
virtual void disconnect_sequence_push_supplier (void);
};
class AnyPushSupplier_i : public virtual POA_CosNotifyComm::PushSupplier
{
virtual void subscription_change (
const CosNotification::EventTypeSeq & added,
const CosNotification::EventTypeSeq & removed);
virtual void disconnect_push_supplier (void);
};
class ReconnectionCallback_i : public virtual POA_NotifyExt::ReconnectionCallback
{
public:
ReconnectionCallback_i (Supplier_Main & supplier_main);
virtual ~ReconnectionCallback_i ();
void init (
PortableServer::POA_ptr poa,
CosNotifyChannelAdmin::EventChannelFactory_ptr ecf_);
void fini (void);
size_t reconnect_count () const;
virtual void reconnect (CORBA::Object_ptr reconnection);
virtual CORBA::Boolean is_alive (void);
private:
Supplier_Main & supplier_main_;
bool id_is_valid_;
NotifyExt::ReconnectionRegistry::ReconnectionID callback_id_;
CosNotifyChannelAdmin::EventChannelFactory_var ecf_;
size_t reconnect_count_;
};
class Supplier_Main
{
public:
Supplier_Main ();
~Supplier_Main ();
int parse_args (int argc, ACE_TCHAR *argv[]);
int parse_single_arg (int argc, ACE_TCHAR *argv[]);
int init (int argc, ACE_TCHAR *argv[]);
int run (void);
int fini (void);
void usage (FILE * log) const;
void reconnect (
CosNotifyChannelAdmin::EventChannelFactory_ptr dest_factory);
private:
/// Find naming service.
int resolve_naming_service (void);
/// Resolve the Notify factory from the Naming service.
int find_notify_factory (void);
/// Resolve the Notify factory using resolve_initial_reference ("NotifyEventChannelFactory")
int resolve_notify_factory (void);
void init_event_channel (void);
void init_supplier_admin (void);
void init_structured_proxy_consumer (void);
void init_sequence_proxy_consumer (void);
void init_any_proxy_consumer (void);
/// send events.
void send_structured_event (void);
void send_sequence_event (void);
void send_any_event (void);
void save_ids();
bool load_ids();
////////////////////
// forbidden methods
private:
Supplier_Main (const Supplier_Main & rhs);
Supplier_Main & operator = (const Supplier_Main & rhs);
////////////////
// Data members
private:
// set by command line parameters
bool verbose_; // -v make a glorious noise
enum Mode_T {
MODE_ANY,
MODE_STRUCTURED,
MODE_SEQUENCE} mode_; // -any, -structured, or -sequence
ACE_TString channel_file_; // -channel filename
size_t send_; // -send n
bool use_naming_service_; // -nonamesvc
size_t serial_number_; // -serial_number
bool disconnect_on_exit_; // -disconnect
ACE_TString id_file_; // -ids
size_t pause_; // -pause n (pause after sending n messages)
CORBA::ORB_var orb_;
PortableServer::POA_var root_poa_;
CosNaming::NamingContext_var naming_context_;
CosNotifyChannelAdmin::EventChannelFactory_var ecf_;
CosNotifyChannelAdmin::EventChannel_var ec_;
CosNotifyChannelAdmin::ChannelID ec_id_;
CosNotifyChannelAdmin::SupplierAdmin_var sa_;
CosNotifyChannelAdmin::AdminID sa_id_;
CosNotifyChannelAdmin::StructuredProxyPushConsumer_var structured_proxy_push_consumer_;
CosNotifyChannelAdmin::ProxyID structured_proxy_id_;
StructuredPushSupplier_i structured_push_supplier_;
CosNotifyComm::StructuredPushSupplier_var structured_push_supplier_ref_;
CosNotifyChannelAdmin::SequenceProxyPushConsumer_var sequence_proxy_push_consumer_;
CosNotifyChannelAdmin::ProxyID sequence_proxy_id_;
SequencePushSupplier_i sequence_push_supplier_;
CosNotifyComm::SequencePushSupplier_var sequence_push_supplier_ref_;
CosNotifyChannelAdmin::ProxyPushConsumer_var any_proxy_push_consumer_;
CosNotifyChannelAdmin::ProxyID any_proxy_id_;
AnyPushSupplier_i any_push_supplier_;
CosNotifyComm::PushSupplier_var any_push_supplier_ref_;
ReconnectionCallback_i reconnection_callback_;
bool reconnecting_;
};
#endif /* RECONNECTNG_SUPPLIER_H */
|
