blob: 9a74a888f9c17f1c76476950b849da9d23a14e39 (
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
|
/* -*- C++ -*- */
// $Id$
// ==========================================================================
//
// = FILENAME
// AdminProperties.h
//
// = DESCRIPTION
// Test for EC Admin QoS properties.
//
// = AUTHOR
// Pradeep Gore <pradeep@cs.wustl.edu>
//
// ==========================================================================
#ifndef ADMINPROPERTIES
#define ADMINPROPERTIES
#include "ace/Task.h"
#include "Notify_Test_Client.h"
#include "Notify_StructuredPushConsumer.h"
#include "Notify_StructuredPushSupplier.h"
class AdminProperties;
/***************************************************************************/
class AdminProperties_StructuredPushConsumer : public TAO_Notify_Tests_StructuredPushConsumer
{
friend class AdminProperties;
public:
AdminProperties_StructuredPushConsumer (AdminProperties* client);
// = StructuredPushSupplier methods
virtual void push_structured_event (const CosNotification::StructuredEvent & notification
);
protected:
AdminProperties* client_;
ACE_Atomic_Op <TAO_SYNCH_MUTEX, CORBA::Long> events_received_;
};
class AdminProperties_Task : public ACE_Task_Base
{
// = TITLE
// Run a thread to dispatch events.
//
// = DESCRIPTION
// Use the ACE_Task_Base class.
//
public:
AdminProperties_Task (void);
// Constructor.
/// Init this object.
void init (TAO_Notify_Tests_StructuredPushSupplier *supplier, AdminProperties* client);
virtual int init (int argc, ACE_TCHAR *argv []);
virtual int svc (void);
// The thread entry point.
private:
/// Supplier
TAO_Notify_Tests_StructuredPushSupplier *supplier_;
/// Client Object.
AdminProperties* client_;
};
/***************************************************************************/
class AdminProperties : public Notify_Test_Client
{
// = TITLE
// AdminProperties
//
// = DESCRIPTION
// Test for Notify EC properties -
// max_queue_length
// max_consumers
// max_suppliers
// reject_new_events
//
friend class AdminProperties_StructuredPushConsumer;
friend class AdminProperties_Task;
public:
AdminProperties (void);
~AdminProperties (void);
int parse_args (int argc, ACE_TCHAR *argv[]) ;
// Initialization.
void run_test (void);
// Run the test.
private:
void create_suppliers (void);
void create_consumers (void);
void create_channel(bool reject);
/// Test MaxSuppliers and MaxConsumers
void test_max_clients (void);
/// Test MaxQueueLength properties
void test_max_queue_length (bool reject);
// Data Members
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.
CORBA::Long max_queue_length_;
CORBA::Long max_consumers_;
CORBA::Long max_suppliers_;
CORBA::Boolean reject_new_events_;
// Values for Admin Properties supplied by user.
/// Number of consumers to connect to check MaxConsumers property.
CORBA::Long consumers_;
/// Number of suppliers to connect to check MaxSuppliers property.
CORBA::Long suppliers_;
CORBA::Long event_count_;
// Number of events to send to the channel.
/// Count of consumers successfully connect to the EC.
int suppliers_connected_count_;
/// Count of consumers successfully connect to the EC.
int consumers_connected_count_;
// Number of supplier pushes that resulted in an IMP_LIMIT exception
int rejections_;
};
#endif /* ADMINPROPERTIES */
|
