Mercurial > gftp.yaz
annotate lib/rfc959.c @ 14:83090328581e
* More largefile support. Hopefully all that is left is the configure stuff
* Sanity checking on the fdopen() calls. Also make sure that all of them have a + in their open mode. Doesn't affect UNIX, but it does affect Windows
* HTTP fixes when running under Solaris. Read from request->sockfd and write to request->sockfd_write (Solaris doesn't like it when you read/write to the same FILE structure)
* Display major/minor properly for a device when connected with the local protocol
author | masneyb |
---|---|
date | Wed, 04 Sep 2002 11:45:56 +0000 |
parents | 5551ab2301fe |
children | 82fabd6ef1c4 |
rev | line source |
---|---|
1 | 1 /*****************************************************************************/ |
2 /* rfc959.c - General purpose routines for the FTP protocol (RFC 959) */ | |
3 /* Copyright (C) 1998-2002 Brian Masney <masneyb@gftp.org> */ | |
4 /* */ | |
5 /* This program is free software; you can redistribute it and/or modify */ | |
6 /* it under the terms of the GNU General Public License as published by */ | |
7 /* the Free Software Foundation; either version 2 of the License, or */ | |
8 /* (at your option) any later version. */ | |
9 /* */ | |
10 /* This program is distributed in the hope that it will be useful, */ | |
11 /* but WITHOUT ANY WARRANTY; without even the implied warranty of */ | |
12 /* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the */ | |
13 /* GNU General Public License for more details. */ | |
14 /* */ | |
15 /* You should have received a copy of the GNU General Public License */ | |
16 /* along with this program; if not, write to the Free Software */ | |
17 /* Foundation, Inc., 59 Temple Place - Suite 330, Boston, MA 02111 USA */ | |
18 /*****************************************************************************/ | |
19 | |
20 #include "gftp.h" | |
21 | |
22 static int rfc959_connect ( gftp_request * request ); | |
23 static void rfc959_disconnect ( gftp_request * request ); | |
24 static long rfc959_get_file ( gftp_request * request, | |
25 const char *filename, | |
26 FILE * fd, | |
27 off_t startsize ); | |
28 static int rfc959_put_file ( gftp_request * request, | |
29 const char *filename, | |
30 FILE * fd, | |
31 off_t startsize, | |
32 off_t totalsize ); | |
33 static long rfc959_transfer_file ( gftp_request *fromreq, | |
34 const char *fromfile, | |
35 off_t fromsize, | |
36 gftp_request *toreq, | |
37 const char *tofile, | |
38 off_t tosize ); | |
39 static int rfc959_end_transfer ( gftp_request * request ); | |
40 static int rfc959_list_files ( gftp_request * request ); | |
41 static int rfc959_set_data_type ( gftp_request * request, | |
42 int data_type ); | |
43 static off_t rfc959_get_file_size ( gftp_request * request, | |
44 const char *filename ); | |
45 static int rfc959_data_connection_new ( gftp_request * request ); | |
46 static int rfc959_accept_active_connection ( gftp_request * request ); | |
47 static int rfc959_send_command ( gftp_request * request, | |
48 const char *command ); | |
49 static int write_to_socket ( gftp_request *request, | |
50 const char *command ); | |
51 static int rfc959_read_response ( gftp_request * request ); | |
52 static int rfc959_chdir ( gftp_request * request, | |
53 const char *directory ); | |
54 static int rfc959_rmdir ( gftp_request * request, | |
55 const char *directory ); | |
56 static int rfc959_rmfile ( gftp_request * request, | |
57 const char *file ); | |
58 static int rfc959_mkdir ( gftp_request * request, | |
59 const char *directory ); | |
60 static int rfc959_rename ( gftp_request * request, | |
61 const char *oldname, | |
62 const char *newname ); | |
63 static int rfc959_chmod ( gftp_request * request, | |
64 const char *file, | |
65 int mode ); | |
66 static int rfc959_site ( gftp_request * request, | |
67 const char *command ); | |
68 static char *parse_ftp_proxy_string ( gftp_request * request ); | |
69 | |
70 void | |
71 rfc959_init (gftp_request * request) | |
72 { | |
73 g_return_if_fail (request != NULL); | |
74 | |
75 request->protonum = GFTP_FTP_NUM; | |
76 request->init = rfc959_init; | |
77 request->destroy = NULL; | |
78 request->connect = rfc959_connect; | |
79 request->disconnect = rfc959_disconnect; | |
80 request->get_file = rfc959_get_file; | |
81 request->put_file = rfc959_put_file; | |
82 request->transfer_file = rfc959_transfer_file; | |
83 request->get_next_file_chunk = NULL; | |
84 request->put_next_file_chunk = NULL; | |
85 request->end_transfer = rfc959_end_transfer; | |
86 request->list_files = rfc959_list_files; | |
87 request->get_next_file = rfc959_get_next_file; | |
88 request->set_data_type = rfc959_set_data_type; | |
89 request->get_file_size = rfc959_get_file_size; | |
90 request->chdir = rfc959_chdir; | |
91 request->rmdir = rfc959_rmdir; | |
92 request->rmfile = rfc959_rmfile; | |
93 request->mkdir = rfc959_mkdir; | |
94 request->rename = rfc959_rename; | |
95 request->chmod = rfc959_chmod; | |
96 request->set_file_time = NULL; | |
97 request->site = rfc959_site; | |
98 request->parse_url = NULL; | |
99 request->url_prefix = "ftp"; | |
100 request->protocol_name = "FTP"; | |
101 request->need_hostport = 1; | |
102 request->need_userpass = 1; | |
103 request->use_cache = 1; | |
104 request->use_threads = 1; | |
105 request->always_connected = 0; | |
106 gftp_set_config_options (request); | |
107 } | |
108 | |
109 | |
110 static int | |
111 rfc959_connect (gftp_request * request) | |
112 { | |
113 char tempchar, *startpos, *endpos, *tempstr, *dir; | |
114 int sock, ret, resp; | |
115 | |
116 g_return_val_if_fail (request != NULL, -2); | |
117 g_return_val_if_fail (request->protonum == GFTP_FTP_NUM, -2); | |
118 g_return_val_if_fail (request->hostname != NULL, -2); | |
119 | |
7 | 120 if (request->username == NULL || *request->username == '\0') |
121 { | |
122 gftp_set_username (request, "anonymous"); | |
123 gftp_set_password (request, emailaddr); | |
124 } | |
125 else if (strcasecmp (request->username, "anonymous") == 0) | |
126 gftp_set_password (request, emailaddr); | |
127 | |
1 | 128 if (request->sockfd != NULL) |
129 return (0); | |
130 | |
131 if ((sock = gftp_connect_server (request, "ftp")) < 0) | |
132 return (-1); | |
133 | |
14
83090328581e
* More largefile support. Hopefully all that is left is the configure stuff
masneyb
parents:
7
diff
changeset
|
134 if ((request->sockfd = fdopen (sock, "rb+")) == NULL) |
1 | 135 { |
136 request->logging_function (gftp_logging_error, request->user_data, | |
137 _("Cannot fdopen() socket: %s\n"), | |
138 g_strerror (errno)); | |
139 close (sock); | |
140 return (-2); | |
141 } | |
142 | |
14
83090328581e
* More largefile support. Hopefully all that is left is the configure stuff
masneyb
parents:
7
diff
changeset
|
143 if ((request->sockfd_write = fdopen (dup (sock), "wb+")) == NULL) |
1 | 144 { |
145 request->logging_function (gftp_logging_error, request->user_data, | |
146 _("Cannot fdopen() socket: %s\n"), | |
147 g_strerror (errno)); | |
148 gftp_disconnect (request); | |
149 return (-2); | |
150 } | |
151 | |
152 /* Get the banner */ | |
153 if (rfc959_read_response (request) != '2') | |
154 { | |
155 gftp_disconnect (request); | |
156 return (-2); | |
157 } | |
158 | |
159 /* Login the proxy server if available */ | |
160 if (request->use_proxy) | |
161 { | |
162 resp = '3'; | |
163 startpos = endpos = tempstr = parse_ftp_proxy_string (request); | |
164 while ((resp == '3' || resp == '2') && *startpos != '\0') | |
165 { | |
166 if (*endpos == '\n' || *endpos == '\0') | |
167 { | |
168 tempchar = *(endpos + 1); | |
169 if (*endpos != '\0') | |
170 *(endpos + 1) = '\0'; | |
171 if ((resp = rfc959_send_command (request, startpos)) < 0) | |
172 return (-2); | |
173 if (*endpos != '\0') | |
174 *(endpos + 1) = tempchar; | |
175 else | |
176 break; | |
177 startpos = endpos + 1; | |
178 } | |
179 endpos++; | |
180 } | |
181 g_free (tempstr); | |
182 } | |
183 else | |
184 { | |
185 tempstr = g_strconcat ("USER ", request->username, "\r\n", NULL); | |
186 resp = rfc959_send_command (request, tempstr); | |
187 g_free (tempstr); | |
188 if (resp < 0) | |
189 return (-2); | |
190 if (resp == '3') | |
191 { | |
192 tempstr = g_strconcat ("PASS ", request->password, "\r\n", NULL); | |
193 resp = rfc959_send_command (request, tempstr); | |
194 g_free (tempstr); | |
195 if (resp < 0) | |
196 return (-2); | |
197 } | |
198 if (resp == '3' && request->account) | |
199 { | |
200 tempstr = g_strconcat ("ACCT ", request->account, "\r\n", NULL); | |
201 resp = rfc959_send_command (request, tempstr); | |
202 g_free (tempstr); | |
203 if (resp < 0) | |
204 return (-2); | |
205 } | |
206 } | |
207 | |
208 if (resp != '2') | |
209 { | |
210 gftp_disconnect (request); | |
211 return (-2); | |
212 } | |
213 | |
214 if (request->data_type == GFTP_TYPE_BINARY) | |
215 tempstr = "TYPE I\r\n"; | |
216 else | |
217 tempstr = "TYPE A\r\n"; | |
218 | |
219 if (rfc959_send_command (request, tempstr) < 0) | |
220 return (-2); | |
221 | |
222 ret = -1; | |
223 if (request->directory != NULL && *request->directory != '\0') | |
224 { | |
225 ret = rfc959_chdir (request, request->directory); | |
226 if (request->sockfd == NULL) | |
227 return (-2); | |
228 } | |
229 | |
230 if (ret != 0) | |
231 { | |
232 if (rfc959_send_command (request, "PWD\r\n") != '2' || | |
233 request->sockfd == NULL) | |
234 { | |
235 gftp_disconnect (request); | |
236 return (-2); | |
237 } | |
238 | |
239 if ((tempstr = strchr (request->last_ftp_response, '"')) == NULL) | |
240 { | |
241 gftp_disconnect (request); | |
242 return (-2); | |
243 } | |
244 dir = tempstr + 1; | |
245 | |
246 if ((tempstr = strchr (dir, '"')) == NULL) | |
247 { | |
248 gftp_disconnect (request); | |
249 return (0); | |
250 } | |
251 if (tempstr != NULL) | |
252 *tempstr = '\0'; | |
253 | |
254 request->directory = g_malloc (strlen (dir) + 1); | |
255 strcpy (request->directory, dir); | |
256 } | |
257 | |
258 if (request->sockfd == NULL) | |
259 return (-2); | |
260 | |
261 return (0); | |
262 } | |
263 | |
264 | |
265 static void | |
266 rfc959_disconnect (gftp_request * request) | |
267 { | |
268 g_return_if_fail (request != NULL); | |
269 g_return_if_fail (request->protonum == GFTP_FTP_NUM); | |
270 | |
271 if (request->sockfd != NULL) | |
272 { | |
273 request->logging_function (gftp_logging_misc, request->user_data, | |
274 _("Disconnecting from site %s\n"), | |
275 request->hostname); | |
276 fclose (request->sockfd); | |
277 fclose (request->sockfd_write); | |
278 request->sockfd = request->sockfd_write = NULL; | |
279 if (request->datafd) | |
280 { | |
281 fclose (request->datafd); | |
282 request->datafd = NULL; | |
283 } | |
284 } | |
285 } | |
286 | |
287 | |
288 static long | |
289 rfc959_get_file (gftp_request * request, const char *filename, FILE * fd, | |
290 off_t startsize) | |
291 { | |
292 char *command, *tempstr, resp; | |
293 int ret, flags; | |
294 | |
295 g_return_val_if_fail (request != NULL, -2); | |
296 g_return_val_if_fail (request->protonum == GFTP_FTP_NUM, -2); | |
297 g_return_val_if_fail (filename != NULL, -2); | |
298 g_return_val_if_fail (request->sockfd != NULL, -2); | |
299 | |
300 if (fd != NULL) | |
301 request->datafd = fd; | |
302 | |
303 if (request->datafd == NULL && | |
304 (ret = rfc959_data_connection_new (request)) < 0) | |
305 return (ret); | |
306 | |
307 flags = fcntl (fileno (request->datafd), F_GETFL, 0); | |
308 if (fcntl (fileno (request->datafd), F_SETFL, flags | O_NONBLOCK) < 0) | |
309 { | |
310 fclose (request->datafd); | |
311 request->datafd = NULL; | |
312 return (-1); | |
313 } | |
314 | |
315 if (startsize > 0) | |
316 { | |
14
83090328581e
* More largefile support. Hopefully all that is left is the configure stuff
masneyb
parents:
7
diff
changeset
|
317 #if defined (_LARGEFILE_SOURCE) |
83090328581e
* More largefile support. Hopefully all that is left is the configure stuff
masneyb
parents:
7
diff
changeset
|
318 command = g_strdup_printf ("REST %lld\r\n", startsize); |
83090328581e
* More largefile support. Hopefully all that is left is the configure stuff
masneyb
parents:
7
diff
changeset
|
319 #else |
1 | 320 command = g_strdup_printf ("REST %ld\r\n", startsize); |
14
83090328581e
* More largefile support. Hopefully all that is left is the configure stuff
masneyb
parents:
7
diff
changeset
|
321 #endif |
1 | 322 resp = rfc959_send_command (request, command); |
323 g_free (command); | |
324 | |
325 if (resp != '3') | |
326 { | |
327 fclose (request->datafd); | |
328 request->datafd = NULL; | |
329 return (-2); | |
330 } | |
331 } | |
332 | |
333 tempstr = g_strconcat ("RETR ", filename, "\r\n", NULL); | |
334 ret = rfc959_send_command (request, tempstr); | |
335 g_free (tempstr); | |
336 | |
337 if (ret != '1') | |
338 { | |
339 fclose (request->datafd); | |
340 request->datafd = NULL; | |
341 return (-2); | |
342 } | |
343 | |
344 if (request->transfer_type == gftp_transfer_active && | |
345 (ret = rfc959_accept_active_connection (request)) < 0) | |
346 return (ret); | |
347 | |
348 if ((tempstr = strrchr (request->last_ftp_response, '(')) == NULL) | |
349 { | |
350 tempstr = request->last_ftp_response + 4; | |
351 while (!isdigit ((int) *tempstr) && *tempstr != '\0') | |
352 tempstr++; | |
353 } | |
354 else | |
355 tempstr++; | |
356 | |
357 return (strtol (tempstr, NULL, 10) + startsize); | |
358 } | |
359 | |
360 | |
361 static int | |
362 rfc959_put_file (gftp_request * request, const char *filename, FILE * fd, | |
363 off_t startsize, off_t totalsize) | |
364 { | |
365 char *command, *tempstr, resp; | |
366 int ret, flags; | |
367 | |
368 g_return_val_if_fail (request != NULL, -2); | |
369 g_return_val_if_fail (request->protonum == GFTP_FTP_NUM, -2); | |
370 g_return_val_if_fail (filename != NULL, -2); | |
371 g_return_val_if_fail (request->sockfd != NULL, -2); | |
372 | |
373 if (fd != NULL) | |
374 fd = request->datafd; | |
375 | |
376 if (request->datafd == NULL && | |
377 (ret = rfc959_data_connection_new (request)) < 0) | |
378 return (ret); | |
379 | |
380 flags = fcntl (fileno (request->datafd), F_GETFL, 0); | |
381 if (fcntl (fileno (request->datafd), F_SETFL, flags | O_NONBLOCK) < 0) | |
382 { | |
383 fclose (request->datafd); | |
384 request->datafd = NULL; | |
385 return (-1); | |
386 } | |
387 | |
388 if (startsize > 0) | |
389 { | |
14
83090328581e
* More largefile support. Hopefully all that is left is the configure stuff
masneyb
parents:
7
diff
changeset
|
390 #if defined (_LARGEFILE_SOURCE) |
83090328581e
* More largefile support. Hopefully all that is left is the configure stuff
masneyb
parents:
7
diff
changeset
|
391 command = g_strdup_printf ("REST %lld\r\n", startsize); |
83090328581e
* More largefile support. Hopefully all that is left is the configure stuff
masneyb
parents:
7
diff
changeset
|
392 #else |
83090328581e
* More largefile support. Hopefully all that is left is the configure stuff
masneyb
parents:
7
diff
changeset
|
393 command = g_strdup_printf ("REST %ld\r\n", startsize); |
83090328581e
* More largefile support. Hopefully all that is left is the configure stuff
masneyb
parents:
7
diff
changeset
|
394 #endif |
1 | 395 resp = rfc959_send_command (request, command); |
396 g_free (command); | |
397 if (resp != '3') | |
398 { | |
399 fclose (request->datafd); | |
400 request->datafd = NULL; | |
401 return (-2); | |
402 } | |
403 } | |
404 | |
405 tempstr = g_strconcat ("STOR ", filename, "\r\n", NULL); | |
406 ret = rfc959_send_command (request, tempstr); | |
407 g_free (tempstr); | |
408 if (ret != '1') | |
409 { | |
410 fclose (request->datafd); | |
411 request->datafd = NULL; | |
412 return (-2); | |
413 } | |
414 | |
415 if (request->transfer_type == gftp_transfer_active && | |
416 (ret = rfc959_accept_active_connection (request)) < 0) | |
417 return (ret); | |
418 | |
419 return (0); | |
420 } | |
421 | |
422 static long | |
423 rfc959_transfer_file (gftp_request *fromreq, const char *fromfile, | |
424 off_t fromsize, gftp_request *toreq, | |
425 const char *tofile, off_t tosize) | |
426 { | |
427 char *tempstr, *pos, *endpos; | |
428 | |
429 g_return_val_if_fail (fromreq != NULL, -2); | |
430 g_return_val_if_fail (fromfile != NULL, -2); | |
431 g_return_val_if_fail (toreq != NULL, -2); | |
432 g_return_val_if_fail (tofile != NULL, -2); | |
433 g_return_val_if_fail (fromreq->sockfd != NULL, -2); | |
434 g_return_val_if_fail (toreq->sockfd != NULL, -2); | |
435 | |
436 fromreq->transfer_type = gftp_transfer_passive; | |
437 toreq->transfer_type = gftp_transfer_active; | |
438 | |
439 if (rfc959_send_command (fromreq, "PASV\r\n") != '2' || | |
440 fromreq->sockfd == NULL) | |
441 return (-2); | |
442 | |
443 pos = fromreq->last_ftp_response + 4; | |
444 while (!isdigit ((int) *pos) && *pos != '\0') | |
445 pos++; | |
446 if (*pos == '\0') | |
447 return (-2); | |
448 | |
449 endpos = pos; | |
450 while (*endpos != ')' && *endpos != '\0') | |
451 endpos++; | |
452 if (*endpos == ')') | |
453 *endpos = '\0'; | |
454 | |
455 tempstr = g_strconcat ("PORT ", pos, "\r\n", NULL); | |
456 g_free (tempstr); | |
457 if (rfc959_send_command (toreq, tempstr) != '2') | |
458 return (-2); | |
459 | |
460 tempstr = g_strconcat ("RETR ", fromfile, "\r\n", NULL); | |
461 g_free (tempstr); | |
462 if (write_to_socket (fromreq, tempstr) < 0) | |
463 return (-1); | |
464 | |
465 tempstr = g_strconcat ("STOR ", tofile, "\r\n", NULL); | |
466 g_free (tempstr); | |
467 if (write_to_socket (toreq, tempstr) < 0) | |
468 return (-1); | |
469 | |
470 if (rfc959_read_response (fromreq) < 0) | |
471 return (-2); | |
472 if (rfc959_read_response (toreq) < 0) | |
473 return (-2); | |
474 | |
475 return (0); | |
476 } | |
477 | |
478 | |
479 static int | |
480 rfc959_end_transfer (gftp_request * request) | |
481 { | |
482 g_return_val_if_fail (request != NULL, -2); | |
483 g_return_val_if_fail (request->protonum == GFTP_FTP_NUM, -2); | |
484 g_return_val_if_fail (request->sockfd != NULL, -2); | |
485 | |
486 if (request->datafd) | |
487 { | |
488 fclose (request->datafd); | |
489 request->datafd = NULL; | |
490 } | |
491 return (rfc959_read_response (request) == '2' ? 0 : -2); | |
492 } | |
493 | |
494 | |
495 static int | |
496 rfc959_list_files (gftp_request * request) | |
497 { | |
498 char *tempstr, parms[3]; | |
499 int ret; | |
500 | |
501 g_return_val_if_fail (request != NULL, -2); | |
502 g_return_val_if_fail (request->protonum == GFTP_FTP_NUM, -2); | |
503 g_return_val_if_fail (request->sockfd != NULL, -2); | |
504 | |
505 if ((ret = rfc959_data_connection_new (request)) < 0) | |
506 return (ret); | |
507 | |
508 *parms = '\0'; | |
509 strcat (parms, show_hidden_files ? "a" : ""); | |
510 strcat (parms, resolve_symlinks ? "L" : ""); | |
511 tempstr = g_strconcat ("LIST", *parms != '\0' ? " -" : "", parms, "\r\n", | |
512 NULL); | |
513 | |
514 ret = rfc959_send_command (request, tempstr); | |
515 g_free (tempstr); | |
516 | |
517 if (ret != '1') | |
518 return (-2); | |
519 | |
520 ret = 0; | |
521 if (request->transfer_type == gftp_transfer_active) | |
522 ret = rfc959_accept_active_connection (request); | |
523 | |
524 return (ret); | |
525 } | |
526 | |
527 | |
528 int | |
529 rfc959_get_next_file (gftp_request * request, gftp_file * fle, FILE * fd) | |
530 { | |
531 char tempstr[255]; | |
532 size_t len; | |
533 | |
534 g_return_val_if_fail (request != NULL, -2); | |
535 g_return_val_if_fail (request->protonum == GFTP_FTP_NUM, -2); | |
536 g_return_val_if_fail (fle != NULL, -2); | |
537 g_return_val_if_fail (fd != NULL, -2); | |
538 | |
539 if (request->last_dir_entry) | |
540 { | |
541 g_free (request->last_dir_entry); | |
542 request->last_dir_entry = NULL; | |
543 } | |
544 do | |
545 { | |
546 /* I don't run select() here because select could return | |
547 successfully saying there is data, but the fgets call could block if | |
548 there is no carriage return */ | |
549 if (!fgets (tempstr, sizeof (tempstr), fd)) | |
550 { | |
551 gftp_file_destroy (fle); | |
552 if (ferror (fd)) | |
553 gftp_disconnect (request); | |
554 return (-2); | |
555 } | |
556 tempstr[sizeof (tempstr) - 1] = '\0'; | |
557 | |
558 if (gftp_parse_ls (tempstr, fle) != 0) | |
559 { | |
560 if (strncmp (tempstr, "total", strlen("total")) != 0 && | |
561 strncmp (tempstr, _("total"), strlen(_("total"))) != 0) | |
562 request->logging_function (gftp_logging_misc, request->user_data, | |
563 _("Warning: Cannot parse listing %s\n"), | |
564 tempstr); | |
565 gftp_file_destroy (fle); | |
566 continue; | |
567 } | |
568 else | |
569 break; | |
570 } | |
571 while (1); | |
572 | |
573 len = strlen (tempstr); | |
574 if (!request->cached) | |
575 { | |
576 request->last_dir_entry = g_malloc (len + 1); | |
577 strcpy (request->last_dir_entry, tempstr); | |
578 request->last_dir_entry_len = len; | |
579 } | |
580 return (len); | |
581 } | |
582 | |
583 | |
584 static int | |
585 rfc959_set_data_type (gftp_request * request, int data_type) | |
586 { | |
587 char *tempstr; | |
588 | |
589 g_return_val_if_fail (request != NULL, -2); | |
590 g_return_val_if_fail (request->protonum == GFTP_FTP_NUM, -2); | |
591 | |
592 if (request->sockfd != NULL && request->data_type != data_type) | |
593 { | |
594 if (data_type == GFTP_TYPE_BINARY) | |
595 tempstr = "TYPE I\r\n"; | |
596 else | |
597 tempstr = "TYPE A\r\n"; | |
598 | |
599 if (rfc959_send_command (request, tempstr) != '2') | |
600 return (-2); | |
601 } | |
602 request->data_type = data_type; | |
603 return (0); | |
604 } | |
605 | |
606 | |
607 static off_t | |
608 rfc959_get_file_size (gftp_request * request, const char *filename) | |
609 { | |
610 char *tempstr; | |
611 int ret; | |
612 | |
613 g_return_val_if_fail (request != NULL, 0); | |
614 g_return_val_if_fail (request->protonum == GFTP_FTP_NUM, -2); | |
615 g_return_val_if_fail (filename != NULL, 0); | |
616 g_return_val_if_fail (request->sockfd != NULL, 0); | |
617 | |
618 tempstr = g_strconcat ("SIZE ", filename, "\r\n", NULL); | |
619 ret = rfc959_send_command (request, tempstr); | |
620 g_free (tempstr); | |
621 if (ret < 0) | |
622 return (-2); | |
623 | |
624 if (*request->last_ftp_response != '2') | |
625 return (0); | |
626 return (strtol (request->last_ftp_response + 4, NULL, 10)); | |
627 } | |
628 | |
629 | |
630 static int | |
631 rfc959_data_connection_new (gftp_request * request) | |
632 { | |
633 char *pos, *pos1, resp, *command; | |
634 struct sockaddr_in data_addr; | |
635 size_t data_addr_len; | |
636 unsigned int temp[6]; | |
637 unsigned char ad[6]; | |
638 int i, sock; | |
639 | |
640 g_return_val_if_fail (request != NULL, -2); | |
641 g_return_val_if_fail (request->protonum == GFTP_FTP_NUM, -2); | |
642 g_return_val_if_fail (request->sockfd != NULL, -2); | |
643 | |
644 if ((sock = socket (AF_INET, SOCK_STREAM, IPPROTO_TCP)) < 0) | |
645 { | |
646 request->logging_function (gftp_logging_error, request->user_data, | |
647 _("Failed to create a socket: %s\n"), | |
648 g_strerror (errno)); | |
649 gftp_disconnect (request); | |
650 return (-1); | |
651 } | |
652 | |
653 data_addr_len = sizeof (data_addr); | |
654 memset (&data_addr, 0, data_addr_len); | |
655 data_addr.sin_family = AF_INET; | |
656 | |
657 if (request->transfer_type == gftp_transfer_passive) | |
658 { | |
659 if ((resp = rfc959_send_command (request, "PASV\r\n")) != '2') | |
660 { | |
661 if (request->sockfd == NULL) | |
662 return (-2); | |
663 | |
664 request->transfer_type = gftp_transfer_active; | |
665 return (rfc959_data_connection_new (request)); | |
666 } | |
667 pos = request->last_ftp_response + 4; | |
668 while (!isdigit ((int) *pos) && *pos != '\0') | |
669 pos++; | |
670 if (*pos == '\0') | |
671 { | |
672 gftp_disconnect (request); | |
673 close (sock); | |
674 return (-2); | |
675 } | |
676 if (sscanf (pos, "%u,%u,%u,%u,%u,%u", &temp[0], &temp[1], &temp[2], | |
677 &temp[3], &temp[4], &temp[5]) != 6) | |
678 { | |
679 gftp_disconnect (request); | |
680 close (sock); | |
681 return (-2); | |
682 } | |
683 for (i = 0; i < 6; i++) | |
684 ad[i] = (unsigned char) (temp[i] & 0xff); | |
685 | |
686 memcpy (&data_addr.sin_addr, &ad[0], 4); | |
687 memcpy (&data_addr.sin_port, &ad[4], 2); | |
688 if (connect (sock, (struct sockaddr *) &data_addr, data_addr_len) == -1) | |
689 { | |
690 request->logging_function (gftp_logging_error, request->user_data, | |
691 _("Cannot create a data connection: %s\n"), | |
692 g_strerror (errno)); | |
693 gftp_disconnect (request); | |
694 close (sock); | |
695 return (-1); | |
696 } | |
697 } | |
698 else | |
699 { | |
700 getsockname (fileno (request->sockfd), (struct sockaddr *) &data_addr, | |
701 &data_addr_len); | |
702 data_addr.sin_port = 0; | |
703 if (bind (sock, (struct sockaddr *) &data_addr, data_addr_len) == -1) | |
704 { | |
705 request->logging_function (gftp_logging_error, request->user_data, | |
706 _("Cannot bind a port: %s\n"), | |
707 g_strerror (errno)); | |
708 gftp_disconnect (request); | |
709 close (sock); | |
710 return (-1); | |
711 } | |
712 | |
713 getsockname (sock, (struct sockaddr *) &data_addr, &data_addr_len); | |
714 if (listen (sock, 1) == -1) | |
715 { | |
716 request->logging_function (gftp_logging_error, request->user_data, | |
717 _("Cannot listen on port %d: %s\n"), | |
718 ntohs (data_addr.sin_port), | |
719 g_strerror (errno)); | |
720 gftp_disconnect (request); | |
721 close (sock); | |
722 return (-1); | |
723 } | |
724 pos = (char *) &data_addr.sin_addr; | |
725 pos1 = (char *) &data_addr.sin_port; | |
726 command = g_strdup_printf ("PORT %u,%u,%u,%u,%u,%u\r\n", | |
727 pos[0] & 0xff, pos[1] & 0xff, pos[2] & 0xff, | |
728 pos[3] & 0xff, pos1[0] & 0xff, | |
729 pos1[1] & 0xff); | |
730 resp = rfc959_send_command (request, command); | |
731 g_free (command); | |
732 if (resp != '2') | |
733 { | |
734 gftp_disconnect (request); | |
735 close (sock); | |
736 return (-2); | |
737 } | |
738 } | |
739 | |
740 if ((request->datafd = fdopen (sock, "rb+")) == NULL) | |
741 { | |
742 request->logging_function (gftp_logging_error, request->user_data, | |
743 _("Cannot fdopen() socket: %s\n"), | |
744 g_strerror (errno)); | |
745 gftp_disconnect (request); | |
746 return (-2); | |
747 } | |
748 | |
749 return (0); | |
750 } | |
751 | |
752 | |
753 static int | |
754 rfc959_accept_active_connection (gftp_request * request) | |
755 { | |
756 struct sockaddr_in cli_addr; | |
757 size_t cli_addr_len; | |
758 int infd; | |
759 | |
760 g_return_val_if_fail (request != NULL, -2); | |
761 g_return_val_if_fail (request->protonum == GFTP_FTP_NUM, -2); | |
762 g_return_val_if_fail (request->datafd != NULL, -2); | |
763 g_return_val_if_fail (request->transfer_type == gftp_transfer_active, -2); | |
764 | |
765 cli_addr_len = sizeof (cli_addr); | |
766 if ((infd = accept (fileno (request->datafd), (struct sockaddr *) &cli_addr, | |
767 &cli_addr_len)) == -1) | |
768 { | |
769 request->logging_function (gftp_logging_error, request->user_data, | |
770 _("Cannot accept connection from server: %s\n"), | |
771 g_strerror (errno)); | |
772 gftp_disconnect (request); | |
773 return (-1); | |
774 } | |
775 | |
776 fclose (request->datafd); | |
777 | |
778 if ((request->datafd = fdopen (infd, "rb+")) == NULL) | |
779 { | |
780 request->logging_function (gftp_logging_error, request->user_data, | |
781 _("Cannot fdopen() socket: %s\n"), | |
782 g_strerror (errno)); | |
783 gftp_disconnect (request); | |
784 return (-2); | |
785 } | |
786 return (0); | |
787 } | |
788 | |
789 | |
790 static int | |
791 rfc959_send_command (gftp_request * request, const char *command) | |
792 { | |
793 g_return_val_if_fail (request != NULL, -2); | |
794 g_return_val_if_fail (request->protonum == GFTP_FTP_NUM, -2); | |
795 g_return_val_if_fail (command != NULL, -2); | |
796 g_return_val_if_fail (request->sockfd != NULL, -2); | |
797 | |
798 if (strncmp (command, "PASS", 4) == 0) | |
799 { | |
800 request->logging_function (gftp_logging_send, request->user_data, | |
801 "PASS xxxx\n"); | |
802 } | |
803 else if (strncmp (command, "ACCT", 4) == 0) | |
804 { | |
805 request->logging_function (gftp_logging_send, request->user_data, | |
806 "ACCT xxxx\n"); | |
807 } | |
808 else | |
809 { | |
810 request->logging_function (gftp_logging_send, request->user_data, "%s", | |
811 command); | |
812 } | |
813 | |
814 if (write_to_socket (request, command) < 0) | |
815 { | |
816 gftp_disconnect (request); | |
817 return (-1); | |
818 } | |
819 | |
820 return (rfc959_read_response (request)); | |
821 } | |
822 | |
823 static int | |
824 write_to_socket (gftp_request *request, const char *command) | |
825 { | |
826 struct timeval tv; | |
827 fd_set fset; | |
828 | |
829 FD_ZERO (&fset); | |
830 FD_SET (fileno (request->sockfd_write), &fset); | |
831 tv.tv_sec = request->network_timeout; | |
832 tv.tv_usec = 0; | |
833 if (!select (fileno (request->sockfd_write) + 1, NULL, &fset, NULL, &tv)) | |
834 { | |
835 request->logging_function (gftp_logging_error, request->user_data, | |
836 _("Connection to %s timed out\n"), | |
837 request->hostname); | |
838 gftp_disconnect (request); | |
839 return (-1); | |
840 } | |
841 | |
842 fwrite (command, strlen (command), 1, request->sockfd_write); | |
843 if (ferror (request->sockfd_write)) | |
844 { | |
845 request->logging_function (gftp_logging_error, request->user_data, | |
846 _("Error: Could not write to socket: %s\n"), | |
847 g_strerror (errno)); | |
848 gftp_disconnect (request); | |
849 return (-1); | |
850 } | |
851 | |
852 fflush (request->sockfd_write); | |
853 if (ferror (request->sockfd_write)) | |
854 { | |
855 request->logging_function (gftp_logging_error, request->user_data, | |
856 _("Error: Could not write to socket: %s\n"), | |
857 g_strerror (errno)); | |
858 gftp_disconnect (request); | |
859 return (-1); | |
860 } | |
861 | |
862 return (0); | |
863 } | |
864 | |
865 | |
866 | |
867 static int | |
868 rfc959_read_response (gftp_request * request) | |
869 { | |
870 char tempstr[255], code[4]; | |
871 | |
872 g_return_val_if_fail (request != NULL, -2); | |
873 g_return_val_if_fail (request->protonum == GFTP_FTP_NUM, -2); | |
874 g_return_val_if_fail (request->sockfd != NULL, -2); | |
875 | |
876 *code = '\0'; | |
877 if (request->last_ftp_response) | |
878 { | |
879 g_free (request->last_ftp_response); | |
880 request->last_ftp_response = NULL; | |
881 } | |
882 | |
883 do | |
884 { | |
885 /* I don't run select() here because select could return | |
886 successfully saying there is data, but the fgets call could block if | |
887 there is no carriage return */ | |
888 if (!fgets (tempstr, sizeof (tempstr), request->sockfd)) | |
889 break; | |
890 tempstr[strlen (tempstr) - 1] = '\0'; | |
891 if (tempstr[strlen (tempstr) - 1] == '\r') | |
892 tempstr[strlen (tempstr) - 1] = '\0'; | |
893 if (isdigit ((int) *tempstr) && isdigit ((int) *(tempstr + 1)) | |
894 && isdigit ((int) *(tempstr + 2))) | |
895 { | |
896 strncpy (code, tempstr, 3); | |
897 code[3] = ' '; | |
898 } | |
899 request->logging_function (gftp_logging_recv, request->user_data, | |
900 "%s\n", tempstr); | |
901 } | |
902 while (strncmp (code, tempstr, 4) != 0); | |
903 | |
904 if (ferror (request->sockfd)) | |
905 { | |
906 request->logging_function (gftp_logging_send, request->user_data, | |
907 "Error reading from socket: %s\n", | |
908 g_strerror (errno)); | |
909 gftp_disconnect (request); | |
910 return (-1); | |
911 } | |
912 | |
913 request->last_ftp_response = g_malloc (strlen (tempstr) + 1); | |
914 strcpy (request->last_ftp_response, tempstr); | |
915 | |
916 if (*request->last_ftp_response == '4') | |
917 gftp_disconnect (request); | |
918 | |
919 return (*request->last_ftp_response); | |
920 } | |
921 | |
922 | |
923 static int | |
924 rfc959_chdir (gftp_request * request, const char *directory) | |
925 { | |
926 char ret, *tempstr, *dir; | |
927 | |
928 g_return_val_if_fail (request != NULL, -2); | |
929 g_return_val_if_fail (request->protonum == GFTP_FTP_NUM, -2); | |
930 g_return_val_if_fail (directory != NULL, -2); | |
931 | |
932 if (strcmp (directory, "..") == 0) | |
933 ret = rfc959_send_command (request, "CDUP\r\n"); | |
934 else | |
935 { | |
936 tempstr = g_strconcat ("CWD ", directory, "\r\n", NULL); | |
937 ret = rfc959_send_command (request, tempstr); | |
938 g_free (tempstr); | |
939 } | |
940 | |
941 if (ret != '2') | |
942 return (-2); | |
943 | |
944 if (directory != request->directory) | |
945 { | |
946 if (request->directory) | |
947 { | |
948 g_free (request->directory); | |
949 request->directory = NULL; | |
950 } | |
951 | |
952 if (rfc959_send_command (request, "PWD\r\n") != '2') | |
953 return (-2); | |
954 | |
955 tempstr = strchr (request->last_ftp_response, '"'); | |
956 if (tempstr != NULL) | |
957 dir = tempstr + 1; | |
958 else | |
959 return (-2); | |
960 | |
961 tempstr = strchr (dir, '"'); | |
962 if (tempstr != NULL) | |
963 *tempstr = '\0'; | |
964 else | |
965 { | |
966 gftp_disconnect (request); | |
967 return (-2); | |
968 } | |
969 | |
970 request->directory = g_malloc (strlen (dir) + 1); | |
971 strcpy (request->directory, dir); | |
972 } | |
973 | |
974 return (0); | |
975 } | |
976 | |
977 | |
978 static int | |
979 rfc959_rmdir (gftp_request * request, const char *directory) | |
980 { | |
981 char *tempstr, ret; | |
982 | |
983 g_return_val_if_fail (request != NULL, -2); | |
984 g_return_val_if_fail (request->protonum == GFTP_FTP_NUM, -2); | |
985 g_return_val_if_fail (directory != NULL, -2); | |
986 g_return_val_if_fail (request->sockfd != NULL, -2); | |
987 | |
988 tempstr = g_strconcat ("RMD ", directory, "\r\n", NULL); | |
989 ret = rfc959_send_command (request, tempstr); | |
990 g_free (tempstr); | |
991 return (ret == '2' ? 0 : -2); | |
992 } | |
993 | |
994 | |
995 static int | |
996 rfc959_rmfile (gftp_request * request, const char *file) | |
997 { | |
998 char *tempstr, ret; | |
999 | |
1000 g_return_val_if_fail (request != NULL, -2); | |
1001 g_return_val_if_fail (request->protonum == GFTP_FTP_NUM, -2); | |
1002 g_return_val_if_fail (file != NULL, -2); | |
1003 g_return_val_if_fail (request->sockfd != NULL, -2); | |
1004 | |
1005 tempstr = g_strconcat ("DELE ", file, "\r\n", NULL); | |
1006 ret = rfc959_send_command (request, tempstr); | |
1007 g_free (tempstr); | |
1008 return (ret == '2' ? 0 : -2); | |
1009 } | |
1010 | |
1011 | |
1012 static int | |
1013 rfc959_mkdir (gftp_request * request, const char *directory) | |
1014 { | |
1015 char *tempstr, ret; | |
1016 | |
1017 g_return_val_if_fail (request != NULL, -2); | |
1018 g_return_val_if_fail (request->protonum == GFTP_FTP_NUM, -2); | |
1019 g_return_val_if_fail (directory != NULL, -2); | |
1020 g_return_val_if_fail (request->sockfd != NULL, -2); | |
1021 | |
1022 tempstr = g_strconcat ("MKD ", directory, "\r\n", NULL); | |
1023 ret = rfc959_send_command (request, tempstr); | |
1024 g_free (tempstr); | |
1025 return (ret == '2' ? 0 : -2); | |
1026 } | |
1027 | |
1028 | |
1029 static int | |
1030 rfc959_rename (gftp_request * request, const char *oldname, | |
1031 const char *newname) | |
1032 { | |
1033 char *tempstr, ret; | |
1034 | |
1035 g_return_val_if_fail (request != NULL, -2); | |
1036 g_return_val_if_fail (request->protonum == GFTP_FTP_NUM, -2); | |
1037 g_return_val_if_fail (oldname != NULL, -2); | |
1038 g_return_val_if_fail (newname != NULL, -2); | |
1039 g_return_val_if_fail (request->sockfd != NULL, -2); | |
1040 | |
1041 tempstr = g_strconcat ("RNFR ", oldname, "\r\n", NULL); | |
1042 ret = rfc959_send_command (request, tempstr); | |
1043 g_free (tempstr); | |
1044 if (ret != '3') | |
1045 return (-2); | |
1046 | |
1047 tempstr = g_strconcat ("RNTO ", newname, "\r\n", NULL); | |
1048 ret = rfc959_send_command (request, tempstr); | |
1049 g_free (tempstr); | |
1050 return (ret == '2' ? 0 : -2); | |
1051 } | |
1052 | |
1053 | |
1054 static int | |
1055 rfc959_chmod (gftp_request * request, const char *file, int mode) | |
1056 { | |
1057 char *tempstr, ret; | |
1058 | |
1059 g_return_val_if_fail (request != NULL, -2); | |
1060 g_return_val_if_fail (request->protonum == GFTP_FTP_NUM, -2); | |
1061 g_return_val_if_fail (file != NULL, -2); | |
1062 g_return_val_if_fail (request->sockfd != NULL, -2); | |
1063 | |
1064 tempstr = g_malloc (strlen (file) + (mode / 10) + 16); | |
1065 sprintf (tempstr, "SITE CHMOD %d %s\r\n", mode, file); | |
1066 ret = rfc959_send_command (request, tempstr); | |
1067 g_free (tempstr); | |
1068 return (ret == '2' ? 0 : -2); | |
1069 } | |
1070 | |
1071 | |
1072 static int | |
1073 rfc959_site (gftp_request * request, const char *command) | |
1074 { | |
1075 char *tempstr, ret; | |
1076 | |
1077 g_return_val_if_fail (request != NULL, -2); | |
1078 g_return_val_if_fail (request->protonum == GFTP_FTP_NUM, -2); | |
1079 g_return_val_if_fail (command != NULL, -2); | |
1080 g_return_val_if_fail (request->sockfd != NULL, -2); | |
1081 | |
1082 tempstr = g_strconcat ("SITE ", command, "\r\n", NULL); | |
1083 ret = rfc959_send_command (request, tempstr); | |
1084 g_free (tempstr); | |
1085 return (request->sockfd != NULL ? ret : -2); | |
1086 } | |
1087 | |
1088 | |
1089 static char * | |
1090 parse_ftp_proxy_string (gftp_request * request) | |
1091 { | |
1092 char *startpos, *endpos, *oldstr, *newstr, *newval, *tempport; | |
1093 | |
1094 g_return_val_if_fail (request != NULL, NULL); | |
1095 g_return_val_if_fail (request->protonum == GFTP_FTP_NUM, NULL); | |
1096 | |
1097 newstr = g_malloc (1); | |
1098 *newstr = '\0'; | |
1099 startpos = endpos = request->proxy_config; | |
1100 while (*endpos != '\0') | |
1101 { | |
1102 tempport = NULL; | |
1103 if (*endpos == '%' && tolower ((int) *(endpos + 1)) == 'p') | |
1104 { | |
1105 switch (tolower ((int) *(endpos + 2))) | |
1106 { | |
1107 case 'u': | |
1108 newval = request->proxy_username; | |
1109 break; | |
1110 case 'p': | |
1111 newval = request->proxy_password; | |
1112 break; | |
1113 case 'h': | |
1114 newval = request->proxy_hostname; | |
1115 break; | |
1116 case 'o': | |
1117 tempport = g_strdup_printf ("%d", request->proxy_port); | |
1118 newval = tempport; | |
1119 break; | |
1120 case 'a': | |
1121 newval = request->proxy_account; | |
1122 break; | |
1123 default: | |
1124 endpos++; | |
1125 continue; | |
1126 } | |
1127 } | |
1128 else if (*endpos == '%' && tolower ((int) *(endpos + 1)) == 'h') | |
1129 { | |
1130 switch (tolower ((int) *(endpos + 2))) | |
1131 { | |
1132 case 'u': | |
1133 newval = request->username; | |
1134 break; | |
1135 case 'p': | |
1136 newval = request->password; | |
1137 break; | |
1138 case 'h': | |
1139 newval = request->hostname; | |
1140 break; | |
1141 case 'o': | |
1142 tempport = g_strdup_printf ("%d", request->port); | |
1143 newval = tempport; | |
1144 break; | |
1145 case 'a': | |
1146 newval = request->account; | |
1147 break; | |
1148 default: | |
1149 endpos++; | |
1150 continue; | |
1151 } | |
1152 } | |
1153 else if (*endpos == '%' && tolower ((int) *(endpos + 1)) == 'n') | |
1154 { | |
1155 *endpos = '\0'; | |
1156 oldstr = newstr; | |
1157 newstr = g_strconcat (oldstr, startpos, "\r\n", NULL); | |
1158 g_free (oldstr); | |
1159 endpos += 2; | |
1160 startpos = endpos; | |
1161 continue; | |
1162 } | |
1163 else | |
1164 { | |
1165 endpos++; | |
1166 continue; | |
1167 } | |
1168 | |
1169 *endpos = '\0'; | |
1170 oldstr = newstr; | |
1171 if (!newval) | |
1172 newstr = g_strconcat (oldstr, startpos, NULL); | |
1173 else | |
1174 newstr = g_strconcat (oldstr, startpos, newval, NULL); | |
1175 if (tempport) | |
1176 { | |
1177 g_free (tempport); | |
1178 tempport = NULL; | |
1179 } | |
1180 g_free (oldstr); | |
1181 endpos += 3; | |
1182 startpos = endpos; | |
1183 } | |
1184 return (newstr); | |
1185 } | |
1186 |