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
|
//=============================================================================
/**
* @file File_i.cpp
*
* 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"
#include "ace/Truncate.h"
// IDL File::System constructor
FileImpl::System::System (PortableServer::POA_ptr poa)
: poa_ (PortableServer::POA::_duplicate (poa)),
// Create the Default Descriptor Servant
fd_servant_ (poa)
{
// set the default servant of the POA
poa->set_servant (&this->fd_servant_);
}
FileImpl::System::~System (void)
{
}
PortableServer::POA_ptr
FileImpl::System::_default_POA (void)
{
return PortableServer::POA::_duplicate (this->poa_.in ());
}
File::Descriptor_ptr
FileImpl::System::open (const char *file_name,
CORBA::Long flags)
{
// 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)
{
throw File::IOError ();
}
char file_descriptor_buffer[BUFSIZ];
// convert ACE_HANDLE to a string
ACE_OS::sprintf (file_descriptor_buffer,
"%ld",
ACE_Utils::truncate_cast<long int> ((intptr_t)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");
// Narrow the object reference to a File Descriptor
File::Descriptor_var fd =
File::Descriptor::_narrow (obj.in ());
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 (void)
{
return PortableServer::POA::_duplicate (this->poa_.in ());
}
//Extracts the ACE_HANDLE from the passed object reference
ACE_HANDLE
FileImpl::Descriptor::fd (void)
{
//
// One way of getting our id.
//
// Get a reference to myself
File::Descriptor_var me = this->_this ();
// Get the ObjectId from the reference
PortableServer::ObjectId_var oid1 =
this->poa_->reference_to_id (me.in ());
//
// Another way of getting our id.
//
PortableServer::ObjectId_var oid2 =
this->poa_->servant_to_id (this);
//
// Yet another way of getting our id.
//
int argc = 0;
ACE_TCHAR **argv = 0;
CORBA::ORB_var orb = CORBA::ORB_init (argc, argv);
// Get the POA Current object reference
CORBA::Object_var obj =
orb->resolve_initial_references ("POACurrent");
// Narrow the object reference to a POA Current reference
PortableServer::Current_var poa_current =
PortableServer::Current::_narrow (obj.in ());
PortableServer::ObjectId_var oid3 =
poa_current->get_object_id ();
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)(intptr_t)ACE_OS::atol (s.in ());
}
CORBA::Long
FileImpl::Descriptor::write (const File::Descriptor::DataBuffer &buffer)
{
ACE_HANDLE file_descriptor = this->fd ();
const CORBA::Octet *data = &buffer[0];
ssize_t len = ACE_OS::write (file_descriptor,
data,
buffer.length ());
if (len > 0)
return len;
throw File::IOError ();
}
File::Descriptor::DataBuffer *
FileImpl::Descriptor::read (CORBA::Long num_bytes)
{
ACE_HANDLE file_descriptor = this->fd ();
CORBA::Octet *buffer = File::Descriptor::DataBuffer::allocbuf (num_bytes);
ssize_t 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);
throw File::IOError ();
}
CORBA::ULong
FileImpl::Descriptor::lseek (CORBA::ULong offset,
CORBA::Long whence)
{
ACE_HANDLE file_descriptor = this->fd ();
CORBA::Long result = (CORBA::Long) ACE_OS::lseek (file_descriptor,
offset,
whence);
if (result == -1)
throw File::IOError ();
return (CORBA::ULong) result;
}
void
FileImpl::Descriptor::destroy (void)
{
// Get the ACE_HANDLE for this object reference
ACE_HANDLE file_descriptor = this->fd ();
// Close the file corresponding to this object reference.
ACE_OS::close (file_descriptor);
}
|
