blob: 22fd387192b27427010f152ee72d6062798fd416 (
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
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
|
/* -*- C++ -*- */
//=============================================================================
/**
* @file Random.h
*
* $Id$
*
* @author Carlos O'Ryan (coryan@cs.wustl.edu)
*/
//=============================================================================
#ifndef EC_RANDOM_H
#define EC_RANDOM_H
#include "orbsvcs/RtecEventCommS.h"
#include "orbsvcs/RtecEventChannelAdminS.h"
#include "ace/Task.h"
#if !defined (ACE_LACKS_PRAGMA_ONCE)
# pragma once
#endif /* ACE_LACKS_PRAGMA_ONCE */
#if defined(_MSC_VER)
#if (_MSC_VER >= 1200)
#pragma warning(push)
#endif /* _MSC_VER >= 1200 */
#pragma warning(disable:4250)
#endif /* _MSC_VER */
class RND_Driver;
class RND_Consumer
: public POA_RtecEventComm::PushConsumer
, public PortableServer::RefCountServantBase
{
// = TITLE
// Simple consumer object
//
// = DESCRIPTION
//
public:
/// Constructor
RND_Consumer (RND_Driver *driver);
void push (const RtecEventComm::EventSet &event
ACE_ENV_ARG_DECL)
ACE_THROW_SPEC ((CORBA::SystemException));
void disconnect_push_consumer (ACE_ENV_SINGLE_ARG_DECL)
ACE_THROW_SPEC ((CORBA::SystemException));
void connect (RtecEventChannelAdmin::ConsumerAdmin_ptr admin,
const RtecEventChannelAdmin::ConsumerQOS &qos
ACE_ENV_ARG_DECL);
void disconnect (ACE_ENV_SINGLE_ARG_DECL);
protected:
/// The driver
RND_Driver *driver_;
/// The supplier.
RtecEventChannelAdmin::ProxyPushSupplier_var proxy_;
/// Synch
TAO_SYNCH_MUTEX lock_;
};
inline
RND_Consumer::RND_Consumer (RND_Driver *driver)
: driver_ (driver)
{
}
// ****************************************************************
class RND_Timer : public RND_Consumer
{
public:
RND_Timer (RND_Driver *driver);
void push (const RtecEventComm::EventSet &event
ACE_ENV_ARG_DECL)
ACE_THROW_SPEC ((CORBA::SystemException));
};
inline
RND_Timer::RND_Timer (RND_Driver *driver)
: RND_Consumer (driver)
{
}
// ****************************************************************
class RND_Supplier
: public POA_RtecEventComm::PushSupplier
, public PortableServer::RefCountServantBase
, public ACE_Task_Base
{
// = TITLE
// Simple supplier object
//
// = DESCRIPTION
//
public:
/// Constructor
RND_Supplier (int verbose);
void connect (RtecEventChannelAdmin::SupplierAdmin_ptr admin,
const RtecEventChannelAdmin::SupplierQOS &qos
ACE_ENV_ARG_DECL);
void disconnect (ACE_ENV_SINGLE_ARG_DECL);
/// Push a single event...
void push_new_event (ACE_ENV_SINGLE_ARG_DECL);
void push (RtecEventComm::EventSet &event
ACE_ENV_ARG_DECL);
virtual void disconnect_push_supplier (ACE_ENV_SINGLE_ARG_DECL)
ACE_THROW_SPEC ((CORBA::SystemException));
/// Active method
virtual int svc (void);
private:
/// The supplier.
RtecEventChannelAdmin::ProxyPushConsumer_var proxy_;
/// Synch
TAO_SYNCH_MUTEX lock_;
/// Be verbose about the progress of the test
int verbose_;
};
inline
RND_Supplier::RND_Supplier (int verbose)
: verbose_ (verbose)
{
}
// ****************************************************************
class RND_Driver
{
public:
RND_Driver (void);
/// Run the test
int run (int argc, char *argv[]);
/// The main timer has expired
void timer (const RtecEventComm::Event &e
ACE_ENV_ARG_DECL);
/// One of the consumers has received an event
void event (const RtecEventComm::Event &e
ACE_ENV_ARG_DECL);
private:
RND_Driver (const RND_Driver &);
RND_Driver& operator= (const RND_Driver &);
private:
/// The main timer
RND_Timer timer_;
/// The supplier
RND_Supplier supplier_;
/// Number of suppliers
int nsuppliers_;
/// The suppliers
RND_Supplier **suppliers_;
/// Number of consumers
int nconsumers_;
/// The consumers
RND_Consumer **consumers_;
/// Maximum recursion
int max_recursion_;
/// Be verbose about the progress of the test
int verbose_;
RtecEventChannelAdmin::ConsumerAdmin_var consumer_admin_;
RtecEventChannelAdmin::SupplierAdmin_var supplier_admin_;
};
#if defined(_MSC_VER) && (_MSC_VER >= 1200)
#pragma warning(pop)
#endif /* _MSC_VER */
#endif /* EC_RANDOM_H */
|
