blob: 7648731fe48a92eb66761b45184b6e37c37959ee (
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
|
/* -*- C++ -*- */
// $Id$
// ==========================================================================
//
// = FILENAME
// ConnectDisconnect.h
//
// = DESCRIPTION
// Test connect-disconnect methods of Notify.
//
// = AUTHOR
// Pradeep Gore <pradeep@cs.wustl.edu>
//
// ==========================================================================
#ifndef NOTIFY_CONNECT_DISCONNECT_H
#define NOTIFY_CONNECT_DISCONNECT_H
#include "Notify_Test_Client.h"
#include "Notify_StructuredPushConsumer.h"
#include "Notify_StructuredPushSupplier.h"
#include "Notify_PushConsumer.h"
#include "Notify_PushSupplier.h"
#include "Notify_SequencePushConsumer.h"
#include "Notify_SequencePushSupplier.h"
#if defined(_MSC_VER)
#pragma warning(push)
#pragma warning(disable:4250)
#endif /* _MSC_VER */
class ConnectDisconnect;
class CD_Entity
{
// The entity that connects/disconnects.
public:
CD_Entity (ConnectDisconnect* cd, int id);
~CD_Entity ();
private:
int id_;
ConnectDisconnect* cd_;
};
#define CD_DECLARE_ENTITY(X) \
class CD_##X : public TAO_Notify_##X, public CD_Entity \
{ \
public: \
CD_##X (ConnectDisconnect* cd, int id); \
};
CD_DECLARE_ENTITY(PushConsumer)
CD_DECLARE_ENTITY(StructuredPushConsumer)
CD_DECLARE_ENTITY(SequencePushConsumer)
CD_DECLARE_ENTITY(PushSupplier)
CD_DECLARE_ENTITY(StructuredPushSupplier)
CD_DECLARE_ENTITY(SequencePushSupplier)
/***************************************************************************/
class ConnectDisconnect : public Notify_Test_Client
{
public:
// Initialization and termination code.
ConnectDisconnect (void);
virtual ~ConnectDisconnect ();
void on_entity_destroyed (void);
// Keeps track of how many objects were destroyed.
int parse_args (int argc,
char *argv[]);
int init (int argc,
char *argv[]
ACE_ENV_ARG_DECL);
// initialization.
void run_test (ACE_ENV_SINGLE_ARG_DECL);
// Run the test.
void end_test (ACE_ENV_SINGLE_ARG_DECL);
// End the test.
int check_results (void);
// Check if we got the expected results.
protected:
void create_EC (ACE_ENV_SINGLE_ARG_DECL);
// Create EC.
CosNotifyChannelAdmin::EventChannel_var ec_;
// The one channel that we create using the factory.
CosNotifyChannelAdmin::ConsumerAdmin_var consumer_admin_;
// The consumer admin used by consumers.
CosNotifyChannelAdmin::SupplierAdmin_var supplier_admin_;
// The supplier admin used by suppliers.
TAO_Notify_Tests_PushConsumer** any_consumer_;
TAO_Notify_Tests_StructuredPushConsumer** structured_consumer_;
TAO_Notify_Tests_SequencePushConsumer** sequence_consumer_;
// Arrays of Consumers.
TAO_Notify_Tests_PushSupplier** any_supplier_;
TAO_Notify_Tests_StructuredPushSupplier** structured_supplier_;
TAO_Notify_Tests_SequencePushSupplier** sequence_supplier_;
// arrays of Suppliers
ACE_Atomic_Op <TAO_SYNCH_MUTEX, int> result_count_;
// Count of clients destroyed. for c consumers, s suppliers and for t times.
// this should be (s+c)*t.
int expected_count_; // (s+c)*t
// = command line params
int count_;
// The number of iterations to connect disconnect.
int consumers_;
// The number of counsumers to create.
int suppliers_;
// The number of suppliers to create.
};
/***************************************************************************/
#if defined(_MSC_VER)
#pragma warning(pop)
#endif /* _MSC_VER */
#endif /* NOTIFY_TESTS_UPDATES_H */
|
