blob: 1a3c7893c76edf1248f91b2b44558493c52bdc60 (
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
|
/* -*- C++ -*- */
/**
* @file Supplier.h
*
* $Id$
*
* @author Pradeep Gore <pradeep@oomworks.com>
*
*
*/
#ifndef TAO_Notify_SUPPLIER_H
#define TAO_Notify_SUPPLIER_H
#include /**/ "ace/pre.h"
#include "ORB_Objects.h"
#include "tao/RTCORBA/RTCORBA.h"
#include "orbsvcs/CosNotifyChannelAdminS.h"
#include "orbsvcs/CosNotifyCommC.h"
#include "ace/Condition_Thread_Mutex.h"
#if defined(_MSC_VER)
#if (_MSC_VER >= 1200)
#pragma warning(push)
#endif /* _MSC_VER >= 1200 */
#pragma warning(disable:4250)
#endif /* _MSC_VER */
#define TEST_MAX_CONSUMERS 10
/**
* @class TAO_Notify_ThreadPool_Supplier
*
* @brief Implement a Structured Supplier.
*
*/
class TAO_Notify_ThreadPool_Supplier : public POA_CosNotifyComm::StructuredPushSupplier, public PortableServer::RefCountServantBase
{
public:
// = Initialization and Termination code
/// Constructor.
TAO_Notify_ThreadPool_Supplier (TAO_Notify_ORB_Objects& orb_objects);
/// Init
void init (CosNotifyChannelAdmin::SupplierAdmin_var& admin, int expected_consumer_count, int max_events,
int proxy_consumer_thread_count ACE_ENV_ARG_DECL);
/// Run
void run (ACE_ENV_SINGLE_ARG_DECL);
protected:
// = Protected Methods
/// Connect the Supplier to the EventChannel.
/// Creates a new proxy consumer and connects to it.
void connect (ACE_ENV_SINGLE_ARG_DECL);
/// Disconnect the supplier.
void disconnect (ACE_ENV_SINGLE_ARG_DECL);
/// Deactivate.
void deactivate (ACE_ENV_SINGLE_ARG_DECL);
/// Send one event.
virtual void send_event (const CosNotification::StructuredEvent& event ACE_ENV_ARG_DECL);
/// Destructor
virtual ~TAO_Notify_ThreadPool_Supplier ();
// = NotifySubscribe
virtual void subscription_change (
const CosNotification::EventTypeSeq & added,
const CosNotification::EventTypeSeq & removed
ACE_ENV_ARG_DECL
)
ACE_THROW_SPEC ((
CORBA::SystemException,
CosNotifyComm::InvalidEventType
));
// = StructuredPushSupplier method
virtual void disconnect_structured_push_supplier (ACE_ENV_SINGLE_ARG_DECL)
ACE_THROW_SPEC ((
CORBA::SystemException
));
/// = Data members
/// ORB Objects.
TAO_Notify_ORB_Objects orb_objects_;
/// The proxy that we are connected to.
CosNotifyChannelAdmin::StructuredProxyPushConsumer_var proxy_consumer_;
/// This supplier's id.
CosNotifyChannelAdmin::ProxyID proxy_consumer_id_;
/// Number of Consumers expected to connect.
int expected_consumer_count_;
// The ORB that we use.
CORBA::ORB_var orb_;
// The Supplier Admin
CosNotifyChannelAdmin::SupplierAdmin_var admin_;
/// Lock to serialize internal state.
TAO_SYNCH_MUTEX lock_;
/// Condition that consumers are connected.
TAO_SYNCH_CONDITION consumers_connected_;
/// Number of consumers connected.
int consumer_count_;
/// Number of events to send.
int max_events_;
/// Number of Threads at the ProxyConsumer.
int proxy_consumer_thread_count_;
/// Array of events to send.
CosNotification::StructuredEvent event_[TEST_MAX_CONSUMERS];
};
#if defined(_MSC_VER) && (_MSC_VER >= 1200)
#pragma warning(pop)
#endif /* _MSC_VER */
#include /**/ "ace/post.h"
#endif /* TAO_Notify_SUPPLIER_H */
|
