blob: 2db23e8c8a3f4d32ab7b8b4c81a8fb9ba2d905e0 (
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
|
/* -*- C++ -*- */
//=============================================================================
/**
* @file Random.h
*
* @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 */
class RND_Driver;
/**
* Simple consumer object
*/
class RND_Consumer
: public POA_RtecEventComm::PushConsumer
{
public:
/// Constructor
RND_Consumer (RND_Driver *driver);
void push (const RtecEventComm::EventSet &event);
void disconnect_push_consumer (void);
void connect (RtecEventChannelAdmin::ConsumerAdmin_ptr admin,
const RtecEventChannelAdmin::ConsumerQOS &qos);
void disconnect (void);
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);
};
inline
RND_Timer::RND_Timer (RND_Driver *driver)
: RND_Consumer (driver)
{
}
// ****************************************************************
/**
* Simple supplier object
*/
class RND_Supplier
: public POA_RtecEventComm::PushSupplier
, public ACE_Task_Base
{
public:
/// Constructor
RND_Supplier (int verbose);
void connect (RtecEventChannelAdmin::SupplierAdmin_ptr admin,
const RtecEventChannelAdmin::SupplierQOS &qos);
void disconnect (void);
/// Push a single event...
void push_new_event (void);
void push (RtecEventComm::EventSet &event);
virtual void disconnect_push_supplier (void);
/// Active method
virtual int svc ();
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, ACE_TCHAR *argv[]);
/// The main timer has expired
void timer (const RtecEventComm::Event &e);
/// One of the consumers has received an event
void event (const RtecEventComm::Event &e);
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_;
};
#endif /* EC_RANDOM_H */
|
