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
|
// $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"
ACE_RCSID(Default_Servant, File_i, "$Id$")
// 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_TRY_ENV);
ACE_CHECK;
}
FileImpl::System::~System (void)
{
}
PortableServer::POA_ptr
FileImpl::System::_default_POA (CORBA::Environment &)
{
return PortableServer::POA::_duplicate (this->poa_.in ());
}
File::Descriptor_ptr
FileImpl::System::open (const char *file_name,
CORBA::Long flags,
CORBA::Environment &ACE_TRY_ENV)
ACE_THROW_SPEC ((CORBA::SystemException,
File::IOError))
{
// Do an ACE_OS::open
ACE_HANDLE file_descriptor = ACE_OS::open (file_name,
flags,
0644);
if (file_descriptor == ACE_INVALID_HANDLE)
{
//CORBA::Exception exception = File::IOError (errno);
ACE_THROW_RETURN (File::IOError (), 0);
/* ACE_NEW_THROW_EX (exception,
File::IOError (errno),
exception);
ACE_CHECK_RETURN (0);*/
}
char file_descriptor_buffer[BUFSIZ];
// convert ACE_HANDLE to a string
ACE_OS::sprintf (file_descriptor_buffer,
"%ld",
(CORBA::Long) 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_TRY_ENV);
ACE_CHECK_RETURN (File::Descriptor::_nil ());
// Narrow the object reference to a File Descriptor
File::Descriptor_var fd =
File::Descriptor::_narrow (obj.in (), ACE_TRY_ENV);
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 (CORBA::Environment &)
{
return PortableServer::POA::_duplicate (this->poa_.in ());
}
//Extracts the ACE_HANDLE from the passed object reference
ACE_HANDLE
FileImpl::Descriptor::fd (CORBA::Environment &ACE_TRY_ENV)
{
// Get a reference to myself
File::Descriptor_var me = this->_this (ACE_TRY_ENV);
ACE_CHECK_RETURN (ACE_INVALID_HANDLE);
// Get the ObjectId from the reference
PortableServer::ObjectId_var oid =
this->poa_->reference_to_id (me.in (), ACE_TRY_ENV);
ACE_CHECK_RETURN (ACE_INVALID_HANDLE);
// Convert the ObjectId to a string
CORBA::String_var s =
PortableServer::ObjectId_to_string (oid.in ());
// Get the ACE_HANDLE from the string
return (ACE_HANDLE) ::atol (s.in ());
}
CORBA::Long
FileImpl::Descriptor::write (const File::Descriptor::DataBuffer &buffer,
CORBA::Environment &ACE_TRY_ENV)
ACE_THROW_SPEC ((CORBA::SystemException,
File::IOError))
{
ACE_HANDLE file_descriptor = this->fd (ACE_TRY_ENV);
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,
CORBA::Environment &ACE_TRY_ENV)
ACE_THROW_SPEC ((CORBA::SystemException,
File::IOError))
{
ACE_HANDLE file_descriptor = this->fd (ACE_TRY_ENV);
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,
CORBA::Environment &ACE_TRY_ENV)
ACE_THROW_SPEC ((CORBA::SystemException,
File::IOError))
{
ACE_HANDLE file_descriptor = this->fd (ACE_TRY_ENV);
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 (CORBA::Environment &ACE_TRY_ENV)
ACE_THROW_SPEC ((CORBA::SystemException))
{
// Get the ACE_HANDLE for this object reference
ACE_HANDLE file_descriptor = this->fd (ACE_TRY_ENV);
ACE_CHECK;
// Close the file corresponding to this object reference.
ACE_OS::close (file_descriptor);
}
|
