blob: b7c07a2a2680e43d2d0eec3549ff18d2bd5c78eb (
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
|
/* -*- C++ -*- */
//=============================================================================
/**
* @file Random.h
*
* @author Carlos O'Ryan (coryan@cs.wustl.edu)
*/
//=============================================================================
#ifndef EC_RANDOM_H
#define EC_RANDOM_H
#include "orbsvcs/CosEventCommS.h"
#include "orbsvcs/CosEventChannelAdminS.h"
#include "ace/Task.h"
#if !defined (ACE_LACKS_PRAGMA_ONCE)
# pragma once
#endif /* ACE_LACKS_PRAGMA_ONCE */
#if defined(_MSC_VER)
#pragma warning(push)
#pragma warning(disable:4250)
#endif /* _MSC_VER */
class RND_Driver;
/// Simple consumer object
class RND_Consumer
: public POA_CosEventComm::PushConsumer
{
public:
/// Constructor
RND_Consumer (RND_Driver *driver);
void push (const CORBA::Any &event);
void disconnect_push_consumer (void);
void connect (CosEventChannelAdmin::ConsumerAdmin_ptr admin);
void disconnect (void);
protected:
/// The driver
RND_Driver *driver_;
/// The supplier.
CosEventChannelAdmin::ProxyPushSupplier_var proxy_;
/// Synch
TAO_SYNCH_MUTEX lock_;
};
inline
RND_Consumer::RND_Consumer (RND_Driver *driver)
: driver_ (driver)
{
}
// ****************************************************************
// ****************************************************************
/// Simple supplier object
class RND_Supplier
: public POA_CosEventComm::PushSupplier
, public ACE_Task_Base
{
public:
/// Constructor
RND_Supplier (void);
void connect (CosEventChannelAdmin::SupplierAdmin_ptr admin);
void disconnect (void);
/// Push a single event...
void push_new_event (void);
void push (CORBA::Any &event);
virtual void disconnect_push_supplier (void);
/// Active method
virtual int svc (void);
private:
/// The supplier.
CosEventChannelAdmin::ProxyPushConsumer_var proxy_;
/// Synch
TAO_SYNCH_MUTEX lock_;
};
inline
RND_Supplier::RND_Supplier (void)
{
}
// ****************************************************************
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 CORBA::Any &e);
/// One of the consumers has received an event
void event (const CORBA::Any &e);
private:
RND_Driver (const RND_Driver &);
RND_Driver& operator= (const RND_Driver &);
private:
/// 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_;
CosEventChannelAdmin::ConsumerAdmin_var consumer_admin_;
CosEventChannelAdmin::SupplierAdmin_var supplier_admin_;
};
#if defined(_MSC_VER)
#pragma warning(pop)
#endif /* _MSC_VER */
#endif /* EC_RANDOM_H */
|
