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
|
/**
* @file FTP_ClientRequestHandler.h
*
* @author Martin Corino <mcorino@remedy.nl>
*/
#ifndef ACE_FTP_CLIENT_REQUEST_HANDLER_H
#define ACE_FTP_CLIENT_REQUEST_HANDLER_H
#include /**/ "ace/pre.h"
#include /**/ "ace/config-all.h"
#if !defined (ACE_LACKS_PRAGMA_ONCE)
# pragma once
#endif /* ACE_LACKS_PRAGMA_ONCE */
#include "ace/Synch_Traits.h"
#include "ace/Thread_Mutex.h"
#include "ace/INet/INet_Export.h"
#include "ace/INet/IOS_util.h"
#include "ace/INet/StreamInterceptor.h"
#include "ace/INet/ClientRequestHandler.h"
#include "ace/INet/FTP_Request.h"
#include "ace/INet/FTP_Response.h"
#include "ace/INet/FTP_Session.h"
#include "ace/INet/FTP_URL.h"
#include "ace/INet/FTP_IOStream.h"
#include "ace/INet/Sock_IOStream.h"
ACE_BEGIN_VERSIONED_NAMESPACE_DECL
namespace ACE
{
namespace FTP
{
/**
* @class ACE_FTP_ClientRequestHandler
*
* @brief This class implements clientside request handling
* for FTP URLs.
*
* The class supports the FTP protocol as specified in RFCs 959
* and 2428.
*/
class ACE_INET_Export ClientRequestHandler
: public ACE::INet::ClientINetRequestHandler,
public ACE::IOS::StreamInterceptor
{
public:
ClientRequestHandler (bool passive_mode = true);
virtual ~ClientRequestHandler ();
bool uses_passive_mode () const;
void use_passive_mode ();
void use_active_mode (u_short port = 0);
u_short uses_active_port () const;
virtual Request& request ();
virtual const Request& request () const;
virtual Response& response ();
virtual const Response& response () const;
std::ostream& request_stream ();
virtual std::istream& response_stream ();
virtual bool is_response_ok () const;
virtual std::istream& handle_open_request (const ACE::INet::URL_Base& url);
virtual std::istream& handle_get_request (const URL& url, bool binary=true);
/*
virtual std::ostream& start_put_request (const URL& url, bool binary=true);
virtual bool finish_put_request ();
*/
void quit_connection ();
static const ACE_CString anonymous_user_;
protected:
static const ACE_CString empty_;
typedef Session_T<ACE_SYNCH>::connection_type connection_type;
typedef ACE::IOS::Sock_IOStreamBase<ACE_SYNCH> stream_type;
virtual void on_eof ();
class Authentication
: public ACE::INet::AuthenticationBase
{
public:
Authentication (const ACE_CString& realm,
ACE_CString& user,
ACE_CString& pw);
virtual ~Authentication ();
virtual const ACE_CString& scheme () const;
virtual const ACE_CString& realm () const;
virtual const ACE_CString& user () const;
virtual void user (const ACE_CString& usr);
virtual const ACE_CString& password () const;
virtual void password (const ACE_CString& pw);
private:
const ACE_CString& realm_;
ACE_CString& user_;
ACE_CString& password_;
};
class SessionHolder
: public ACE::INet::ConnectionHolder
{
public:
typedef Session_T<ACE_SYNCH> session_type;
SessionHolder ();
virtual ~SessionHolder();
session_type& operator *();
session_type* operator ->();
private:
session_type session_;
};
class SessionFactory
: public ACE::INet::ConnectionFactory
{
public:
SessionFactory ();
virtual ~SessionFactory ();
virtual ACE::INet::ConnectionHolder* create_connection (
const ACE::INet::ConnectionKey& key) const;
};
SessionHolder& session ();
void session (SessionHolder* session);
virtual bool initialize_connection (const ACE_CString& host,
u_short port);
virtual bool handle_credentials (const URL& url,
ACE_CString& user,
ACE_CString& password);
virtual void handle_request_error (const URL& url);
virtual void handle_connection_error (const URL& url);
void release_connection ();
void close_connection ();
/*
* FTP protocol helpers
*/
bool login (const ACE_CString& user, const ACE_CString& password);
bool logout ();
bool is_valid_path (const ACE_CString& path);
bool is_file (const ACE_CString& path);
bool is_dir (const ACE_CString& path);
bool set_filetype (bool binary);
stream_type* start_download (const ACE_CString& path, bool binary);
stream_type* start_upload (const ACE_CString& path, bool binary);
bool finish_transfer ();
bool abort_transfer ();
Response::StatusType process_command (const ACE_CString& cmd,
const ACE_CString& arg = empty_);
stream_type* open_data_connection (const ACE_CString& cmd,
const ACE_CString& arg);
bool get_passive_address (ACE_INET_Addr& addr);
bool parse_address (const ACE_CString& str, ACE_INET_Addr& addr);
bool parse_ext_address (const ACE_CString& str, ACE_INET_Addr& addr);
bool send_active_address (const ACE_INET_Addr& addr);
private:
Request request_;
Response response_;
SessionHolder* session_;
bool use_passive_mode_;
u_short active_port_;
OStream out_data_stream_;
IStream in_data_stream_;
bool transfer_active_;
ACE_CString current_user_;
};
}
}
ACE_END_VERSIONED_NAMESPACE_DECL
#if defined (__ACE_INLINE__)
#include "ace/INet/FTP_ClientRequestHandler.inl"
#endif
#include /**/ "ace/post.h"
#endif /* ACE_INET_CLIENT_REQUEST_HANDLER_H */
|
