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
210
211
212
213
214
215
216
217
218
219
220
221
222
223
224
225
226
227
228
229
230
231
232
233
234
235
236
237
238
|
// $Id$
//===================================================================
//
// = FILENAME
// File_i.cpp
//
// = DESCRIPTION
// Implementation of the File IDL module and the interfaces
// Descriptor and System in it.
//
// = AUTHOR
// Irfan Pyarali
//
//====================================================================
#include "File_i.h"
#include "ace/OS_NS_stdio.h"
#include "ace/OS_NS_fcntl.h"
#include "ace/OS_NS_unistd.h"
ACE_RCSID(Default_Servant, File_i, "File_i.cpp,v 1.14 2001/03/04 19:27:53 irfan Exp")
// IDL File::System constructor
FileImpl::System::System (PortableServer::POA_ptr poa)
: poa_ (PortableServer::POA::_duplicate (poa)),
// Create the Default Descriptor Servant
fd_servant_ (poa)
{
ACE_DECLARE_NEW_CORBA_ENV;
// set the default servant of the POA
poa->set_servant (&this->fd_servant_ ACE_ENV_ARG_PARAMETER);
ACE_CHECK;
}
FileImpl::System::~System (void)
{
}
PortableServer::POA_ptr
FileImpl::System::_default_POA (ACE_ENV_SINGLE_ARG_DECL_NOT_USED)
{
return PortableServer::POA::_duplicate (this->poa_.in ());
}
File::Descriptor_ptr
FileImpl::System::open (const char *file_name,
CORBA::Long flags
ACE_ENV_ARG_DECL)
ACE_THROW_SPEC ((CORBA::SystemException,
File::IOError))
{
// Do an ACE_OS::open
ACE_HANDLE file_descriptor = ACE_OS::open (file_name,
flags,
ACE_DEFAULT_FILE_PERMS);
if (file_descriptor == ACE_INVALID_HANDLE)
{
ACE_THROW_RETURN (File::IOError (), 0);
}
char file_descriptor_buffer[BUFSIZ];
// convert ACE_HANDLE to a string
ACE_OS::sprintf (file_descriptor_buffer,
"%ld",
(long int) file_descriptor);
//Create an objectID from the ACE_HANDLE string
PortableServer::ObjectId_var oid =
PortableServer::string_to_ObjectId (file_descriptor_buffer);
// create an object reference with the specified ObjectID got
// from ACE_HANDLE string
CORBA::Object_var obj =
this->poa_->create_reference_with_id (oid.in (),
"IDL:File/Descriptor:1.0"
ACE_ENV_ARG_PARAMETER);
ACE_CHECK_RETURN (File::Descriptor::_nil ());
// Narrow the object reference to a File Descriptor
File::Descriptor_var fd =
File::Descriptor::_narrow (obj.in () ACE_ENV_ARG_PARAMETER);
ACE_CHECK_RETURN (File::Descriptor::_nil ());
return fd._retn ();
}
// IDL File::Descriptor constructor
FileImpl::Descriptor::Descriptor (PortableServer::POA_ptr poa)
: poa_ (PortableServer::POA::_duplicate (poa))
{
}
FileImpl::Descriptor::~Descriptor (void)
{
}
PortableServer::POA_ptr
FileImpl::Descriptor::_default_POA (ACE_ENV_SINGLE_ARG_DECL_NOT_USED)
{
return PortableServer::POA::_duplicate (this->poa_.in ());
}
//Extracts the ACE_HANDLE from the passed object reference
ACE_HANDLE
FileImpl::Descriptor::fd (ACE_ENV_SINGLE_ARG_DECL)
{
//
// One way of getting our id.
//
// Get a reference to myself
File::Descriptor_var me = this->_this (ACE_ENV_SINGLE_ARG_PARAMETER);
ACE_CHECK_RETURN (ACE_INVALID_HANDLE);
// Get the ObjectId from the reference
PortableServer::ObjectId_var oid1 =
this->poa_->reference_to_id (me.in () ACE_ENV_ARG_PARAMETER);
ACE_CHECK_RETURN (ACE_INVALID_HANDLE);
//
// Another way of getting our id.
//
PortableServer::ObjectId_var oid2 =
this->poa_->servant_to_id (this ACE_ENV_ARG_PARAMETER);
ACE_CHECK_RETURN (ACE_INVALID_HANDLE);
//
// Yet another way of getting our id.
//
int argc = 0;
CORBA::ORB_var orb = CORBA::ORB_init (argc, 0, 0 ACE_ENV_ARG_PARAMETER);
ACE_CHECK_RETURN (ACE_INVALID_HANDLE);
// Get the POA Current object reference
CORBA::Object_var obj =
orb->resolve_initial_references ("POACurrent"
ACE_ENV_ARG_PARAMETER);
ACE_CHECK_RETURN (ACE_INVALID_HANDLE);
// Narrow the object reference to a POA Current reference
PortableServer::Current_var poa_current =
PortableServer::Current::_narrow (obj.in ()
ACE_ENV_ARG_PARAMETER);
ACE_CHECK_RETURN (ACE_INVALID_HANDLE);
PortableServer::ObjectId_var oid3 =
poa_current->get_object_id (ACE_ENV_SINGLE_ARG_PARAMETER);
ACE_CHECK_RETURN (ACE_INVALID_HANDLE);
ACE_ASSERT (oid1.in () == oid2.in ());
ACE_ASSERT (oid2.in () == oid3.in ());
// Convert the ObjectId to a string
CORBA::String_var s =
PortableServer::ObjectId_to_string (oid1.in ());
// Get the ACE_HANDLE from the string
return (ACE_HANDLE) ::atol (s.in ());
}
CORBA::Long
FileImpl::Descriptor::write (const File::Descriptor::DataBuffer &buffer
ACE_ENV_ARG_DECL)
ACE_THROW_SPEC ((CORBA::SystemException,
File::IOError))
{
ACE_HANDLE file_descriptor = this->fd (ACE_ENV_SINGLE_ARG_PARAMETER);
ACE_CHECK_RETURN (0);
const CORBA::Octet *data = &buffer[0];
ssize_t len = ACE_OS::write (file_descriptor,
data,
buffer.length ());
if (len > 0)
return len;
ACE_THROW_RETURN (File::IOError (), 0);
}
File::Descriptor::DataBuffer *
FileImpl::Descriptor::read (CORBA::Long num_bytes
ACE_ENV_ARG_DECL)
ACE_THROW_SPEC ((CORBA::SystemException,
File::IOError))
{
ACE_HANDLE file_descriptor = this->fd (ACE_ENV_SINGLE_ARG_PARAMETER);
ACE_CHECK_RETURN (0);
CORBA::Octet *buffer = File::Descriptor::DataBuffer::allocbuf (num_bytes);
int length = ACE_OS::read (file_descriptor, buffer, num_bytes);
if (length > 0)
return new File::Descriptor::DataBuffer (length,
length,
buffer,
1);
File::Descriptor::DataBuffer::freebuf (buffer);
ACE_THROW_RETURN (File::IOError (), 0);
}
CORBA::ULong
FileImpl::Descriptor::lseek (CORBA::ULong offset,
CORBA::Long whence
ACE_ENV_ARG_DECL)
ACE_THROW_SPEC ((CORBA::SystemException,
File::IOError))
{
ACE_HANDLE file_descriptor = this->fd (ACE_ENV_SINGLE_ARG_PARAMETER);
ACE_CHECK_RETURN (0);
CORBA::Long result = (CORBA::Long) ACE_OS::lseek (file_descriptor,
offset,
whence);
if (result == -1)
ACE_THROW_RETURN (File::IOError (), 0);
return (CORBA::ULong) result;
}
void
FileImpl::Descriptor::destroy (ACE_ENV_SINGLE_ARG_DECL)
ACE_THROW_SPEC ((CORBA::SystemException))
{
// Get the ACE_HANDLE for this object reference
ACE_HANDLE file_descriptor = this->fd (ACE_ENV_SINGLE_ARG_PARAMETER);
ACE_CHECK;
// Close the file corresponding to this object reference.
ACE_OS::close (file_descriptor);
}
|
