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
|
/* -*- C++ -*- */
// $Id$
//
// ============================================================================
//
// = LIBRARY
// ORBSVCS Real-time Event Channel testsuite
//
// = FILENAME
// Connect
//
// = AUTHOR
// Carlos O'Ryan (coryan@cs.wustl.edu)
//
// ============================================================================
#ifndef EC_CONNECT_H
#define EC_CONNECT_H
#include "Consumer.h"
#include "Supplier.h"
#if !defined (ACE_LACKS_PRAGMA_ONCE)
# pragma once
#endif /* ACE_LACKS_PRAGMA_ONCE */
class EC_Connect : public EC_Driver
{
//
// = TITLE
// Test the EC connection feature
//
// = DESCRIPTION
// The EC can be configured to allow re-connection of suppliers
// and consumers, this test verifies that:
// + The EC does *not* allow connections if the feature is
// disabled (the default)
// + The EC does allow connections if the feature is enabled
// and:
// - There are no memory leaks
// - Compares the time required for a connection vs a complete
// connect/disconnect cycle, specially as the number of
// suppliers and consumers increases.
//
public:
EC_Connect (void);
// Constructor
// = The EC_Driver methods
virtual int parse_args (int& argc, char* argv[]);
virtual void print_usage (void);
virtual void print_args (void) const;
void execute_test (CORBA::Environment& ACE_TRY_ENV);
// Don't run the suppliers, just test connect and disconnect calls.
virtual void dump_results (void);
virtual void connect_consumer (
RtecEventChannelAdmin::ConsumerAdmin_ptr consumer_admin,
int i,
CORBA::Environment &ACE_TRY_ENV);
virtual void connect_supplier (
RtecEventChannelAdmin::SupplierAdmin_ptr supplier_admin,
int i,
CORBA::Environment &ACE_TRY_ENV);
virtual void disconnect_consumers (CORBA::Environment& env);
virtual void disconnect_suppliers (CORBA::Environment& env);
virtual EC_Consumer* allocate_consumer (int i);
virtual EC_Supplier* allocate_supplier (int i);
virtual void connect_clients (CORBA::Environment&);
virtual void disconnect_clients (CORBA::Environment&);
private:
ACE_hrtime_t start_time_;
ACE_Throughput_Stats consumer_connect_;
ACE_Throughput_Stats supplier_connect_;
ACE_Throughput_Stats consumer_disconnect_;
ACE_Throughput_Stats supplier_disconnect_;
int order_;
// What is connected first?
};
// ****************************************************************
class ECC_Consumer : public EC_Consumer
{
public:
ECC_Consumer (EC_Driver *driver, void* cookie);
virtual void connect (
RtecEventChannelAdmin::ConsumerAdmin_ptr consumer_admin,
const RtecEventChannelAdmin::ConsumerQOS& qos,
int shutdown_event_type,
CORBA::Environment &ACE_TRY_ENV);
virtual void connect (
const RtecEventChannelAdmin::ConsumerQOS& qos,
int shutdown_event_type,
CORBA::Environment &ACE_TRY_ENV);
virtual void dump_results (const char* name,
ACE_UINT32 global_scale_factor);
private:
ACE_Throughput_Stats connect_time_;
};
// ****************************************************************
class ECC_Supplier : public EC_Supplier
{
public:
ECC_Supplier (EC_Driver *driver, void* cookie);
virtual void connect (
RtecEventChannelAdmin::SupplierAdmin_ptr supplier_admin,
const RtecEventChannelAdmin::SupplierQOS& qos,
int shutdown_event_type,
CORBA::Environment& ACE_TRY_ENV);
virtual void connect (
const RtecEventChannelAdmin::SupplierQOS& qos,
int shutdown_event_type,
CORBA::Environment &ACE_TRY_ENV);
virtual void dump_results (const char* name,
ACE_UINT32 global_scale_factor);
private:
ACE_Throughput_Stats connect_time_;
};
#endif /* EC_CONNECT_H */
|
