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
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
|
// $Id$
// ============================================================================
//
// = LIBRARY
// TAO/examples/Advanced/ch_21
//
// = FILENAME
// server.h
//
// = AUTHORS
// Source code used in TAO has been modified and adapted from the code
// provided in the book, "Advanced CORBA Programming with C++" by Michi
// Henning and Steve Vinoski. Copyright 1999. Addison-Wesley, Reading,
// MA.
//
// Modified for TAO by Mike Moran <mm4@cs.wustl.edu>
//
// ============================================================================
#ifndef server_HH_
#define server_HH_
#include "CCSS.h"
#include "icp.h"
#include <ace/Synch_T.h>
#include <set>
#include <list>
#include <map>
#include <assert.h>
// #include <corba/poaS.h>
#include "CCSS.h"
using namespace std;
class Controller_impl;
class Thermometer_impl : public virtual POA_CCS::Thermometer {
public:
// CORBA attributes
virtual CCS::ModelType model();
virtual CCS::AssetType asset_num();
virtual CCS::TempType temperature();
virtual CCS::LocType location();
virtual void location(const char *loc);
virtual void remove();
// Constructor & destructor
Thermometer_impl(CCS::AssetType anum);
virtual ~Thermometer_impl();
static Controller_impl * m_ctrl; // My controller
const CCS::AssetType m_anum; // My asset number
void _add_ref();
void _remove_ref();
private:
// Helper functions
CCS::ModelType get_model();
CCS::TempType get_temp();
CCS::LocType get_loc();
void set_loc(const char * new_loc);
ACE_Mutex m_count_mutex;
CORBA::ULong m_ref_count;
bool m_removed;
// Copy and assignment not supported
Thermometer_impl(const Thermometer_impl &);
void operator=(const Thermometer_impl &);
};
class Thermostat_impl :
public virtual POA_CCS::Thermostat,
public virtual Thermometer_impl {
public:
// CORBA operations
virtual CCS::TempType get_nominal();
virtual CCS::TempType set_nominal(CCS::TempType new_temp));
// Constructor and destructor
Thermostat_impl(CCS::AssetType anum);
virtual ~Thermostat_impl();
private:
// Helper functions
CCS::TempType get_nominal_temp();
CCS::TempType set_nominal_temp(CCS::TempType new_temp);
// Copy and assignment not supported
Thermostat_impl(const Thermostat_impl &);
void operator=(const Thermostat_impl &);
};
class Controller_impl : public virtual POA_CCS::Controller {
public:
// CORBA operations
virtual CCS::Controller::ThermometerSeq* list();
virtual void find(CCS::Controller::SearchSeq & slist);
virtual void change(const CCS::Controller::ThermostatSeq & tlist,
CORBA::Short delta));
virtual CCS::Thermometer_ptr create_thermometer(CCS::AssetType anum,
const char* loc);
virtual CCS::Thermostat_ptr create_thermostat(CCS::AssetType anum,
const char* loc,
CCS::TempType temp);
// Constructor and destructor
Controller_impl(PortableServer::POA_ptr poa,
const char * asset_file);
virtual ~Controller_impl();
// Helper functions to allow access to the object map
void add_impl(CCS::AssetType anum);
void remove_impl(CCS::AssetType anum);
bool exists(CCS::AssetType anum);
ACE_Mutex m_assets_mutex;
private:
typedef set<CCS::AssetType> AssetSet;
AssetSet m_assets;
// POA for thermometers and thermostats
PortableServer::POA_var m_poa;
// Name of asset number file
CORBA::String_var m_asset_file;
// Copy and assignment not supported
Controller_impl(const Controller_impl &);
void operator=(const Controller_impl &);
// Function object for the find_if algorithm to search for
// devices by location and model string.
class StrFinder {
public:
StrFinder(
CCS::Controller::SearchCriterion sc,
const char * str
) : m_sc(sc), m_str(str) {}
bool operator()(
CCS::AssetType anum
) const
{
char buf[32];
switch (m_sc) {
case CCS::Controller::LOCATION:
ICP_get(anum, "location", buf, sizeof(buf));
break;
case CCS::Controller::MODEL:
ICP_get(anum, "model", buf, sizeof(buf));
break;
default:
assert(0); // Precondition violation
}
return strcmp(buf, m_str) == 0;
}
private:
CCS::Controller::SearchCriterion m_sc;
const char * m_str;
};
};
class DeviceLocator_impl :
public virtual PortableServer::ServantLocator {
public:
DeviceLocator_impl(Controller_impl * ctrl);
virtual PortableServer::Servant
preinvoke(
const PortableServer::ObjectId & oid,
PortableServer::POA_ptr /* poa */ ,
const char * operation,
void * & /* cookie */
);
virtual void
postinvoke(
const PortableServer::ObjectId & /* oid */ ,
PortableServer::POA_ptr /* poa */ ,
const char * /* operation */ ,
void * /* cookie */ ,
PortableServer::Servant /* servant */
) {}
private:
Controller_impl * m_ctrl;
typedef list<Thermometer_impl *> EvictorQueue;
typedef map<CCS::AssetType, EvictorQueue::iterator>
ActiveObjectMap;
static const unsigned int MAX_EQ_SIZE;// = 100;
EvictorQueue m_eq;
ActiveObjectMap m_aom;
// Copy and assignment not supported
DeviceLocator_impl(const DeviceLocator_impl &);
void operator=(const DeviceLocator_impl &);
};
#endif
|
