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
// Updates.h
//
// = DESCRIPTION
// Test to check if <offer_change> and <subscription_change> messages are
// received correctly.
//
// = AUTHOR
// Pradeep Gore <pradeep@cs.wustl.edu>
//
// ==========================================================================
#ifndef NOTIFY_TESTS_UPDATES_H
#define NOTIFY_TESTS_UPDATES_H
#include "Notify_Test_Client.h"
#include "Notify_StructuredPushConsumer.h"
#include "Notify_StructuredPushSupplier.h"
class Updates;
class Update_StructuredPushConsumer : public TAO_Notify_StructuredPushConsumer
{
public:
Update_StructuredPushConsumer (Updates *test_client);
// Contructor.
virtual void offer_change (
const CosNotification::EventTypeSeq & added,
const CosNotification::EventTypeSeq & removed,
CORBA::Environment &ACE_TRY_ENV
)
ACE_THROW_SPEC ((
CORBA::SystemException,
CosNotifyComm::InvalidEventType
));
// Offer change is conveyed here.
protected:
Updates * test_client_;
};
/***************************************************************************/
class Update_StructuredPushSupplier : public TAO_Notify_StructuredPushSupplier
{
public:
Update_StructuredPushSupplier (Updates * test_client);
// Constructor.
virtual ~Update_StructuredPushSupplier ();
// Destructor.
virtual void subscription_change (
const CosNotification::EventTypeSeq & added,
const CosNotification::EventTypeSeq & removed,
CORBA::Environment &ACE_TRY_ENV
)
ACE_THROW_SPEC ((
CORBA::SystemException,
CosNotifyComm::InvalidEventType
));
// Subscription change is conveyed here.
protected:
Updates* test_client_;
};
/***************************************************************************/
class Updates : public Notify_Test_Client
{
public:
// Initialization and termination code
Updates (void);
virtual ~Updates ();
int parse_args(int argc, char *argv[]) ;
void init (int argc, char *argv [], CORBA::Environment &ACE_TRY_ENV);
// initialization.
void run_test (CORBA::Environment &ACE_TRY_ENV);
// Run the test.
void end_test (CORBA::Environment &ACE_TRY_ENV);
// End the test.
int check_results (void);
// check if we got the expected results.
protected:
void create_EC (CORBA::Environment &ACE_TRY_ENV);
// Create EC
ACE_Atomic_Op <ACE_SYNCH_MUTEX, int> result_count_;
// we are waiting for 4 events to happen.
const char* domain_name_;
const char* type_name_;
int update_count_;
// Number of updates to test.
int offers_added_, offers_removed_;
// Check if these are equal to <update_count_> at the end of the test.
int subscriptions_added_, subscriptions_removed_;
// Check if these are equal to <update_count_> at the end of the test.
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_StructuredPushConsumer* consumer_;
// Consumer
TAO_Notify_StructuredPushSupplier* supplier_;
// Supplier
private:
friend class Update_StructuredPushSupplier;
friend class Update_StructuredPushConsumer;
};
/***************************************************************************/
#endif /* NOTIFY_TESTS_UPDATES_H */
|
