blob: 5996fc6908ff3f6aac983a85f0cf385636050f0d (
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
|
/* -*- C++ -*- */
// $Id$
// ==========================================================================
//
// = FILENAME
// Events_Test.h
//
// = DESCRIPTION
// Test to check if events are received by all 3 types of consumers.
// This is intended to be a simple test without any filters with default subscription (all events).
//
// = AUTHOR
// Pradeep Gore <pradeep@cs.wustl.edu>
//
// ==========================================================================
#ifndef NOTIFY_TESTS_EventS_H
#define NOTIFY_TESTS_EventS_H
#include "Notify_Test_Client.h"
#include "Notify_StructuredPushConsumer.h"
#include "Notify_StructuredPushSupplier.h"
#if defined(_MSC_VER)
#if (_MSC_VER >= 1200)
#pragma warning(push)
#endif /* _MSC_VER >= 1200 */
#pragma warning(disable:4250)
#endif /* _MSC_VER */
class Events_Test;
class Event_StructuredPushConsumer : public TAO_Notify_StructuredPushConsumer
{
public:
Event_StructuredPushConsumer (Events_Test *test_client);
// Contructor.
// = StructuredPushSupplier methods.
virtual void push_structured_event (
const CosNotification::StructuredEvent & notification
TAO_ENV_ARG_DECL
)
ACE_THROW_SPEC ((CORBA::SystemException,
CosEventComm::Disconnected));
protected:
Events_Test * test_client_;
};
/***************************************************************************/
class Event_StructuredPushSupplier : public TAO_Notify_StructuredPushSupplier
{
public:
Event_StructuredPushSupplier (Events_Test * test_client);
// Constructor.
virtual ~Event_StructuredPushSupplier (void);
// Destructor.
protected:
Events_Test* test_client_;
};
/***************************************************************************/
class Events_Test : public Notify_Test_Client
{
public:
// Initialization and termination code.
Events_Test (void);
virtual ~Events_Test (void);
int parse_args (int argc,
char *argv[]) ;
int init (int argc,
char *argv []
TAO_ENV_ARG_DECL);
// Initialization.
void on_event_received (void);
// Called when an event is received.
void run_test (TAO_ENV_SINGLE_ARG_DECL);
// Run the test.
void end_test (TAO_ENV_SINGLE_ARG_DECL);
// End the test.
int check_results (void);
// check if we got the expected results.
protected:
void create_EC (TAO_ENV_SINGLE_ARG_DECL);
// Create EC
ACE_Atomic_Op <TAO_SYNCH_MUTEX, int> result_count_;
// Number of events received so far.
int event_count_;
// Number of events to send
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 Event_StructuredPushSupplier;
friend class Event_StructuredPushConsumer;
};
/***************************************************************************/
#if defined(_MSC_VER) && (_MSC_VER >= 1200)
#pragma warning(pop)
#endif /* _MSC_VER */
#endif /* NOTIFY_TESTS_EventS_H */
|
