blob: ebff1041c480a8cc269f37a196022220bff03e76 (
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
|
/* -*- C++ -*- */
//=============================================================================
/**
* @file Sequence.h
*
* Test Sequence support in Notification.
*
* @author Pradeep Gore <pradeep@cs.wustl.edu>
*/
//=============================================================================
#ifndef NOTIFY_TESTS_SEQUENCE_H
#define NOTIFY_TESTS_SEQUENCE_H
#include "Notify_Test_Client.h"
#include "Notify_SequencePushConsumer.h"
#include "Notify_SequencePushSupplier.h"
#include "orbsvcs/TimeBaseC.h"
#if defined(_MSC_VER)
#pragma warning(push)
#pragma warning(disable:4250)
#endif /* _MSC_VER */
class Sequence;
class SequencePushConsumer : public TAO_Notify_Tests_SequencePushConsumer
{
public:
SequencePushConsumer (Sequence* client);
// = SequencePushConsumer methods
virtual void push_structured_events (
const CosNotification::EventBatch & notifications);
protected:
Sequence* test_client_;
};
/***************************************************************************/
class SequencePushSupplier : public TAO_Notify_Tests_SequencePushSupplier
{
public:
/// Constructor.
SequencePushSupplier (Sequence * test_client);
/// Destructor.
virtual ~SequencePushSupplier (void);
protected:
Sequence* test_client_;
};
/***************************************************************************/
class Sequence : public Notify_Test_Client
{
public:
// Initialization and termination code.
Sequence (void);
virtual ~Sequence (void);
int parse_args (int argc,
ACE_TCHAR *argv[]) ;
/// Initialization.
int init (int argc,
ACE_TCHAR *argv []);
/// Called when an event is received.
void on_event_received (void);
/// Run the test.
void run_test (void);
/// End the test.
void end_test (void);
/// check if we got the expected results.
int check_results (void);
protected:
/// Create EC
void create_EC (void);
/// Number of events to send
int event_count_;
/// Batch size send by supplier.
CORBA::ULong supplier_batch_size_;
/// Max Batch size expected by consumer.
CORBA::ULong consumer_batch_size_;
TimeBase::TimeT pacing_;
CORBA::Short order_policy_;
/// Count the number of events received by the consumer.
ACE_Atomic_Op <TAO_SYNCH_MUTEX, int> events_received_;
ACE_Time_Value consumer_delay_;
/// The one channel that we create using the factory.
CosNotifyChannelAdmin::EventChannel_var ec_;
/// The consumer admin used by consumers.
CosNotifyChannelAdmin::ConsumerAdmin_var consumer_admin_;
/// The supplier admin used by suppliers.
CosNotifyChannelAdmin::SupplierAdmin_var supplier_admin_;
/// Consumer
TAO_Notify_Tests_SequencePushConsumer* consumer_;
/// Supplier
TAO_Notify_Tests_SequencePushSupplier* supplier_;
private:
friend class SequencePushSupplier;
friend class SequencePushConsumer;
};
/***************************************************************************/
#if defined(_MSC_VER)
#pragma warning(pop)
#endif /* _MSC_VER */
#endif /* NOTIFY_TESTS_SEQUENCE_H */
|
