blob: a2cc8ae170bcd5bf7d3d520de2ff38fb61c9aafd (
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
// 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"
#if defined(_MSC_VER)
#pragma warning(push)
#pragma warning(disable:4250)
#endif /* _MSC_VER */
class Updates;
class Updates_StructuredPushConsumer : public TAO_Notify_Tests_StructuredPushConsumer
{
public:
Updates_StructuredPushConsumer (Updates *test_client);
// Contructor.
virtual void offer_change (const CosNotification::EventTypeSeq & added,
const CosNotification::EventTypeSeq & removed
ACE_ENV_ARG_DECL)
ACE_THROW_SPEC ((CORBA::SystemException,
CosNotifyComm::InvalidEventType));
// Offer change is conveyed here.
protected:
Updates * test_client_;
};
/***************************************************************************/
class Updates_StructuredPushSupplier : public TAO_Notify_Tests_StructuredPushSupplier
{
public:
Updates_StructuredPushSupplier (Updates * test_client);
// Constructor.
virtual ~Updates_StructuredPushSupplier ();
// Destructor.
virtual void subscription_change (
const CosNotification::EventTypeSeq & added,
const CosNotification::EventTypeSeq & removed
ACE_ENV_ARG_DECL
)
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 init (int argc, char *argv[] ACE_ENV_ARG_DECL);
// initialization.
void run_test (ACE_ENV_SINGLE_ARG_DECL);
// Run the test.
/// print_event_types
void print_event_types (const CosNotification::EventTypeSeq &types);
/// Invoked by Supplier and Consumer when they receive updates
void types_changed (const CosNotification::EventTypeSeq & added, const CosNotification::EventTypeSeq & removed);
/// Wait for expected count of updates.
void wait_for_updates (int expected_added, int expected_removed);
protected:
void create_EC (ACE_ENV_SINGLE_ARG_DECL);
// Create EC
/// Helper to add types.
void add_type (CosNotification::EventTypeSeq& type_seq, const char* type);
// test subscription_change
void test_subscription_change (ACE_ENV_SINGLE_ARG_DECL);
// test offer_change
void test_offer_change (ACE_ENV_SINGLE_ARG_DECL);
/// Reset the counts.
void reset_counts (void);
/// Lock to serialize internal state.
TAO_SYNCH_MUTEX lock_;
/// Count of added updates received
int added_count_;
/// Count of removed updates received
int removed_count_;
// 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_Tests_StructuredPushConsumer* consumer_;
// Consumer
TAO_Notify_Tests_StructuredPushSupplier* supplier_;
// Supplier
private:
friend class Updates_StructuredPushSupplier;
friend class Updates_StructuredPushConsumer;
};
/***************************************************************************/
#if defined(_MSC_VER)
#pragma warning(pop)
#endif /* _MSC_VER */
#endif /* NOTIFY_TESTS_UPDATES_H */
|
