blob: c33b963a13ea2b266ab6207107414a2a6eac69d3 (
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
|
/* -*- C++ -*- */
// $Id$
//
// ============================================================================
//
// = LIBRARY
// ORBSVCS Cos Event Channel testsuite
//
// = FILENAME
// Counting_Supplier
//
// = AUTHOR
// Carlos O'Ryan (coryan@cs.wustl.edu)
//
// ============================================================================
#ifndef CEC_COUNTING_SUPPLIER_H
#define CEC_COUNTING_SUPPLIER_H
#include "cectest_export.h"
#if !defined (ACE_LACKS_PRAGMA_ONCE)
# pragma once
#endif /* ACE_LACKS_PRAGMA_ONCE */
#include "orbsvcs/orbsvcs/CosEventCommS.h"
#include "orbsvcs/orbsvcs/CosEventChannelAdminC.h"
#include "ace/Task.h"
class CEC_Test_Export CEC_Counting_Supplier : public POA_CosEventComm::PushSupplier
{
// = TITLE
// Simple supplier object
//
// = DESCRIPTION
// This class is a supplier of events.
//
public:
CEC_Counting_Supplier (void);
// Constructor
// = The CosEventComm::PushSupplier methods
void connect (CosEventChannelAdmin::SupplierAdmin_ptr supplier_admin
ACE_ENV_ARG_DECL);
void disconnect (ACE_ENV_SINGLE_ARG_DECL);
// Simple connect/disconnect methods..
void push (const CORBA::Any& events
ACE_ENV_ARG_DECL)
ACE_THROW_SPEC ((CORBA::SystemException));
// Push an event.
virtual void disconnect_push_supplier (ACE_ENV_SINGLE_ARG_DECL_NOT_USED)
ACE_THROW_SPEC ((CORBA::SystemException));
// The skeleton methods.
CORBA::ULong event_count;
// Count the number of events sent
CORBA::ULong disconnect_count;
// Count the number of disconnect_push_supplier calls
private:
CosEventChannelAdmin::ProxyPushConsumer_var consumer_proxy_;
// Our proxy
};
class CEC_Test_Export CEC_Counting_Supplier_Task : public ACE_Task_Base
{
public:
CEC_Counting_Supplier_Task (CEC_Counting_Supplier *supplier,
int milliseconds = 0);
// Create the task...
// = Check the ACE_Task_Base documentation.
int svc (void);
void stop (void);
CORBA::ULong push_count (void);
void run (ACE_ENV_SINGLE_ARG_DECL);
// Run a single iteration of the test
private:
CEC_Counting_Supplier *supplier_;
// The supplier we are turning into an active object
int stop_flag_;
// Set to 1 when the test must stop
CORBA::ULong push_count_;
// Count the number of push() calls
int milliseconds_;
// If not zero then pause for <milliseconds> before sending each
// event.
TAO_SYNCH_MUTEX lock_;
};
// ****************************************************************
class CEC_Test_Export CEC_Pull_Counting_Supplier : public POA_CosEventComm::PullSupplier
{
// = TITLE
// Simple supplier object
//
// = DESCRIPTION
// This class is a supplier of events.
//
public:
CEC_Pull_Counting_Supplier (void);
// Constructor
// = The CosEventComm::PullSupplier methods
void connect (CosEventChannelAdmin::SupplierAdmin_ptr supplier_admin
ACE_ENV_ARG_DECL);
void disconnect (ACE_ENV_SINGLE_ARG_DECL);
// Simple connect/disconnect methods..
// The PullSupplier methods.
CORBA::Any* pull (ACE_ENV_SINGLE_ARG_DECL)
ACE_THROW_SPEC ((CORBA::SystemException,CosEventComm::Disconnected));
CORBA::Any* try_pull (CORBA::Boolean_out has_event
ACE_ENV_ARG_DECL)
ACE_THROW_SPEC ((CORBA::SystemException,CosEventComm::Disconnected));
virtual void disconnect_pull_supplier (ACE_ENV_SINGLE_ARG_DECL_NOT_USED)
ACE_THROW_SPEC ((CORBA::SystemException));
CORBA::ULong event_count;
// Count the number of events sent
CORBA::ULong disconnect_count;
// Count the number of disconnect_pull_supplier calls
private:
CosEventChannelAdmin::ProxyPullConsumer_var consumer_proxy_;
// Our proxy
};
#endif /* ECT_SUPPLIER_H */
|
