Annotation of libwww/Library/src/HTFTP.c, revision 1.98
1.46 frystyk 1: /* HTFTP.c
2: ** FILE TRANSFER PROTOCOL (FTP) CLIENT
3: **
1.52 frystyk 4: ** (c) COPYRIGHT MIT 1995.
1.46 frystyk 5: ** Please first read the full copyright statement in the file COPYRIGH.
1.98 ! frystyk 6: ** @(#) $Id: HTFTP.c,v 1.97 1998/05/19 16:49:25 frystyk Exp $
1.1 timbl 7: **
8: ** A cache of control connections is kept.
9: **
10: ** Note: Port allocation
11: **
12: ** It is essential that the port is allocated by the system, rather
1.79 frystyk 13: ** than chosen in rotation by us (FTP_POLL_PORTS), or the following
1.1 timbl 14: ** problem occurs.
15: **
16: ** It seems that an attempt by the server to connect to a port which has
17: ** been used recently by a listen on the same socket, or by another
18: ** socket this or another process causes a hangup of (almost exactly)
19: ** one minute. Therefore, we have to use a rotating port number.
20: ** The problem remains that if the application is run twice in quick
21: ** succession, it will hang for what remains of a minute.
22: **
23: ** Authors
1.54 frystyk 24: ** TBL Tim Berners-lee <timbl@w3.org>
1.1 timbl 25: ** DD Denis DeLaRoca 310 825-4580 <CSP1DWD@mvs.oac.ucla.edu>
1.22 frystyk 26: ** LM Lou Montulli <montulli@ukanaix.cc.ukans.edu>
27: ** FM Foteos Macrides <macrides@sci.wfeb.edu>
1.54 frystyk 28: ** HF Henrik Frystyk <frystyk@w3.org>
1.30 luotonen 29: ** AL Ari Luotonen <luotonen@www.cern.ch>
1.23 frystyk 30: **
1.1 timbl 31: ** History:
32: ** 2 May 91 Written TBL, as a part of the WorldWideWeb project.
33: ** 15 Jan 92 Bug fix: close() was used for NETCLOSE for control soc
34: ** 10 Feb 92 Retry if cached connection times out or breaks
35: ** 8 Dec 92 Bug fix 921208 TBL after DD
36: ** 17 Dec 92 Anon FTP password now just WWWuser@ suggested by DD
1.2 timbl 37: ** fails on princeton.edu!
1.22 frystyk 38: ** 27 Dec 93 (FM) Fixed up so FTP now works with VMS hosts. Path
39: ** must be Unix-style and cannot include the device
40: ** or top directory.
41: ** ?? ??? ?? (LM) Added code to prompt and send passwords for non
42: ** anonymous FTP
43: ** 25 Mar 94 (LM) Added code to recognize different ftp server types
44: ** and code to parse dates and sizes on most hosts.
45: ** 27 Mar 93 (FM) Added code for getting dates and sizes on VMS hosts.
1.23 frystyk 46: ** 27 Apr 94 (HF) The module is basically rewritten to conform with
47: ** rfc 959, 1123 and 1579 and turned into a state
48: ** machine. New semantics of ftp URLs are supported.
1.30 luotonen 49: ** 2 May 94 (AL) Fixed possible security hole when the URL contains
50: ** a newline, that could cause multiple commands to be
51: ** sent to an FTP server.
1.60 frystyk 52: ** Sep 95 HFN Rewritten to support streams and persistent conenctions
53: ** and multiplexed IO
1.95 frystyk 54: ** Mar 1998 NG Neil Griffin - Bug fixes and additions for FTP support on NT.
1.22 frystyk 55: ** Notes:
56: ** Portions Copyright 1994 Trustees of Dartmouth College
57: ** Code for recognizing different FTP servers and
58: ** parsing "ls -l" output taken from Macintosh Fetch
59: ** program with permission from Jim Matthews,
60: ** Dartmouth Software Development Team.
1.23 frystyk 61: */
1.1 timbl 62:
1.22 frystyk 63: /* Library include files */
1.96 frystyk 64: #include "wwwsys.h"
1.81 frystyk 65: #include "WWWUtil.h"
66: #include "WWWCore.h"
1.93 frystyk 67: #include "WWWStream.h"
68: #include "WWWTrans.h"
1.58 frystyk 69: #include "HTReqMan.h"
1.98 ! frystyk 70: #include "HTNetMan.h"
1.63 frystyk 71: #include "HTFTPDir.h"
1.22 frystyk 72: #include "HTFTP.h" /* Implemented here */
73:
74: /* Macros and other defines */
1.60 frystyk 75: #if 0
76: /* Only use this if ABSOLUTELY necessary! */
1.79 frystyk 77: #define FTP_POLL_PORTS /* If allocation does not work, poll ourselves.*/
1.1 timbl 78: #endif
79:
1.79 frystyk 80: #ifdef FTP_POLL_PORTS
1.23 frystyk 81: #define FIRST_TCP_PORT 1024 /* Region to try for a listening port */
82: #define LAST_TCP_PORT 5999
1.60 frystyk 83: PRIVATE int DataPort = FIRST_TCP_PORT;
1.1 timbl 84: #endif
85:
1.60 frystyk 86: #ifndef FTP_PORT
87: #define FTP_PORT 21
88: #define FTP_DATA 20
1.1 timbl 89: #endif
1.60 frystyk 90:
91: #define WWW_FTP_CLIENT "libwww@" /* If can't get user-info, use this */
92: #define FTP_DIR(me) ((me)->type=='L' || (me)->type=='N')
1.1 timbl 93:
1.58 frystyk 94: /*
95: ** Local context structure used in the HTNet object.
96: */
1.45 frystyk 97: typedef enum _HTFTPState {
1.60 frystyk 98: FTP_SUCCESS = -2,
99: FTP_ERROR = -1,
1.58 frystyk 100: FTP_BEGIN = 0,
101: FTP_NEED_CCON, /* Control connection */
1.60 frystyk 102: FTP_NEED_LOGIN,
1.58 frystyk 103: FTP_NEED_DCON, /* Data connection */
1.60 frystyk 104: FTP_NEED_DATA,
105: FTP_NEED_SERVER /* For directory listings */
1.39 frystyk 106: } HTFTPState;
107:
1.58 frystyk 108: typedef struct _ftp_ctrl {
1.60 frystyk 109: HTChunk * cmd;
110: int repcode;
111: char * reply;
112: char * uid;
1.58 frystyk 113: char * passwd;
1.60 frystyk 114: char * account;
1.58 frystyk 115: HTFTPState state; /* State of the connection */
1.60 frystyk 116: int substate; /* For hierarchical states */
117: BOOL sent; /* Read or write command */
118: BOOL cwd; /* Done cwd */
119: BOOL reset; /* Expect greeting */
1.63 frystyk 120: FTPServerType server; /* Type of server */
1.93 frystyk 121: HTNet * cnet; /* Control connection */
1.60 frystyk 122: HTNet * dnet; /* Data connection */
1.95 frystyk 123: /* begin _GM_ */
124: /* Note: libwww bug ID: GM3 */
125: BOOL alreadyLoggedIn;
126: /* end _GM_ */
1.58 frystyk 127: } ftp_ctrl;
1.39 frystyk 128:
1.58 frystyk 129: typedef struct _ftp_data {
1.60 frystyk 130: char host[30]; /* Host to contact for data */
131: char * file; /* File or dir name */
132: char * offset; /* offset into file */
133: BOOL pasv; /* Active or passive */
134: char type; /* 'A', 'I', 'L'(IST), 'N'(LST) */
1.93 frystyk 135: int complete; /* Check if both ctrl and data is loaded */
1.76 frystyk 136: BOOL stream_error;
1.58 frystyk 137: } ftp_data;
1.39 frystyk 138:
1.60 frystyk 139: struct _HTStream {
1.79 frystyk 140: const HTStreamClass * isa;
1.60 frystyk 141: HTStream * target;
142: HTRequest * request;
143: ftp_ctrl * ctrl;
1.80 frystyk 144: HTEOLState state;
1.60 frystyk 145: HTChunk * welcome;
1.62 frystyk 146: BOOL junk; /* For too long lines */
1.60 frystyk 147: BOOL first_line;
1.63 frystyk 148: char buffer[MAX_FTP_LINE+1];
1.60 frystyk 149: int buflen;
1.92 eric 150: HTHost * host;
1.60 frystyk 151: };
152:
1.81 frystyk 153: struct _HTInputStream {
154: const HTInputStreamClass * isa;
155: };
156:
1.60 frystyk 157: typedef enum _FTPDataCon {
158: FTP_DATA_PASV = 0x1,
159: FTP_DATA_PORT = 0x2
160: } FTPDataCon;
161:
162: PRIVATE FTPDataCon FTPMode = FTP_DATA_PASV;
1.39 frystyk 163:
1.95 frystyk 164: /* Added by Neil Griffin */
165: PRIVATE FTPTransferMode g_FTPTransferMode = FTP_DEFAULT_TRANSFER_MODE;
1.97 frystyk 166: PRIVATE FTPControlMode g_FTPControlMode = FTP_DEFAULT_CONTROL_MODE;
1.95 frystyk 167:
1.23 frystyk 168: /* ------------------------------------------------------------------------- */
1.60 frystyk 169: /* FTP Status Line Stream */
1.22 frystyk 170: /* ------------------------------------------------------------------------- */
1.60 frystyk 171:
172: /* FTPCleanup
173: ** ----------
174: ** This function closes the connection and frees memory.
175: ** Returns YES on OK, else NO
176: */
1.65 frystyk 177: PRIVATE int FTPCleanup (HTRequest * request, int status)
1.60 frystyk 178: {
1.75 frystyk 179: if (request) {
1.84 frystyk 180: HTNet * cnet = HTRequest_net(request);
181: ftp_ctrl * ctrl = (ftp_ctrl *) HTNet_context(cnet);
182: HTStream * input = HTRequest_inputStream(request);
1.98 ! frystyk 183:
! 184: if (status == HT_INTERRUPTED) {
! 185: HTAlertCallback * cbf = HTAlert_find(HT_PROG_INTERRUPT);
! 186: if (cbf) (*cbf)(request, HT_PROG_INTERRUPT,
! 187: HT_MSG_NULL, NULL, NULL, NULL);
! 188: } else if (status == HT_TIMEOUT) {
! 189: HTAlertCallback * cbf = HTAlert_find(HT_PROG_TIMEOUT);
! 190: if (cbf) (*cbf)(request, HT_PROG_TIMEOUT,
! 191: HT_MSG_NULL, NULL, NULL, NULL);
! 192: } else if (status == HT_LOADED) {
! 193: HTAlertCallback * cbf = HTAlert_find(HT_PROG_DONE);
! 194: if (cbf) (*cbf)(request, HT_PROG_DONE,
! 195: HT_MSG_NULL, NULL, NULL, NULL);
! 196: }
! 197:
1.93 frystyk 198: /* Free control stream with data TO network */
1.84 frystyk 199: if (!HTRequest_isDestination(request) && input) {
1.75 frystyk 200: if (status == HT_INTERRUPTED)
1.84 frystyk 201: (*input->isa->abort)(input, NULL);
1.75 frystyk 202: else
1.84 frystyk 203: (*input->isa->_free)(input);
1.75 frystyk 204: }
205:
206: /* Remove the request object and our own context structure for http */
1.84 frystyk 207: if (cnet && ctrl) {
1.75 frystyk 208: HTNet * dnet = ctrl->dnet;
1.84 frystyk 209: ftp_data * data = (ftp_data *) HTNet_context(dnet);
1.75 frystyk 210: HTChunk_delete(ctrl->cmd);
1.77 frystyk 211: HT_FREE(ctrl->reply);
212: HT_FREE(ctrl->uid);
213: HT_FREE(ctrl->passwd);
214: HT_FREE(ctrl->account);
215: HT_FREE(ctrl);
1.84 frystyk 216: if (dnet && data) {
1.77 frystyk 217: HT_FREE(data->file);
218: HT_FREE(data);
1.75 frystyk 219: }
1.93 frystyk 220: #if 0
1.88 frystyk 221: HTNet_setPersistent(dnet, NO, HT_TP_SINGLE);
1.93 frystyk 222: #endif
1.98 ! frystyk 223: /* See if we got a content length */
! 224: if (status == HT_LOADED)
! 225: HTAnchor_setLength(HTRequest_anchor(request), HTNet_bytesRead(dnet));
! 226:
! 227: HTNet_delete(dnet, HT_IGNORE);
1.75 frystyk 228: }
229: HTNet_delete(cnet, status);
230: return YES;
1.60 frystyk 231: }
1.75 frystyk 232: return NO;
1.60 frystyk 233: }
234:
235: /* ScanResponse
236: ** ------------
237: ** Analyzes the response from the FTP server.
238: ** Returns HT_LOADED if OK, HT_OK if more, HT_ERROR if error
239: ** the control connection.
1.33 frystyk 240: */
1.65 frystyk 241: PRIVATE int ScanResponse (HTStream * me)
1.33 frystyk 242: {
1.60 frystyk 243: int reply = 0;
244: char cont = '\0';
245: char *ptr = me->buffer+4;
246: *(me->buffer+me->buflen) = '\0';
1.95 frystyk 247: /* begin _GM_ */
248: /* Note: libwww bug ID: GM3 */
249: me->ctrl->alreadyLoggedIn = NO;
250: /* end _GM_ */
1.94 frystyk 251: if (isdigit((int) *(me->buffer))) sscanf(me->buffer, "%d%c", &reply, &cont);
1.60 frystyk 252: if (me->first_line) {
1.78 eric 253: if (PROT_TRACE) HTTrace("FTP Rx...... `%s\'\n", me->buffer);
1.60 frystyk 254: if (!reply) return HT_ERROR;
255: me->first_line = NO;
256: me->ctrl->repcode = reply;
257: StrAllocCopy(me->ctrl->reply, ptr);
1.95 frystyk 258: /* begin _GM_ */
259: /* Note: libwww bug ID: GM3 */
260: if ( (reply == 530) && (strcasestr(me->buffer, "already") != NULL) ) {
261: me->ctrl->alreadyLoggedIn = YES;
262: } else {
263: me->ctrl->alreadyLoggedIn = NO;
264: }
265: /* end _GM_ */
1.60 frystyk 266: } else {
1.73 frystyk 267: HTChunk_puts(me->welcome, ptr);
268: HTChunk_putc(me->welcome, '\n');
1.33 frystyk 269: }
1.60 frystyk 270: me->buflen = 0;
1.68 frystyk 271: me->state = EOL_BEGIN;
1.60 frystyk 272: if (cont != '-') {
273: me->first_line = YES;
274: return HT_LOADED;
1.33 frystyk 275: }
1.60 frystyk 276: return HT_OK;
1.33 frystyk 277: }
278:
1.60 frystyk 279: /*
280: ** Searches for FTP header line until buffer fills up or a CRLF or LF
281: ** is found
1.23 frystyk 282: */
1.79 frystyk 283: PRIVATE int FTPStatus_put_block (HTStream * me, const char * b, int l)
1.92 eric 284: {
1.60 frystyk 285: int status;
1.93 frystyk 286: HTHost_setConsumed(me->host, l);
1.60 frystyk 287: while (l-- > 0) {
288: if (me->state == EOL_FCR) {
289: if (*b == LF) {
1.62 frystyk 290: if (!me->junk) {
1.93 frystyk 291: if ((status = ScanResponse(me)) != HT_OK) return status;
1.62 frystyk 292: } else {
293: me->buflen = 0;
294: me->junk = NO;
295: }
1.60 frystyk 296: }
297: } else if (*b == CR) {
298: me->state = EOL_FCR;
299: } else if (*b == LF) {
1.62 frystyk 300: if (!me->junk) {
1.93 frystyk 301: if ((status = ScanResponse(me)) != HT_OK) return status;
1.62 frystyk 302: } else {
303: me->buflen = 0;
304: me->junk = NO;
305: }
1.60 frystyk 306: } else {
307: *(me->buffer+me->buflen++) = *b;
1.63 frystyk 308: if (me->buflen >= MAX_FTP_LINE) {
1.93 frystyk 309: if (PROT_TRACE) HTTrace("FTP Status.. Line too long - chopped\n");
1.62 frystyk 310: me->junk = YES;
311: if ((status = ScanResponse(me)) != HT_OK) {
312: me->junk = NO;
313: return status;
314: }
1.23 frystyk 315: }
316: }
1.60 frystyk 317: b++;
1.25 frystyk 318: }
1.60 frystyk 319: return HT_OK;
1.25 frystyk 320: }
321:
1.79 frystyk 322: PRIVATE int FTPStatus_put_string (HTStream * me, const char * s)
1.60 frystyk 323: {
324: return FTPStatus_put_block(me, s, (int) strlen(s));
325: }
1.25 frystyk 326:
1.65 frystyk 327: PRIVATE int FTPStatus_put_character (HTStream * me, char c)
1.25 frystyk 328: {
1.60 frystyk 329: return FTPStatus_put_block(me, &c, 1);
330: }
1.25 frystyk 331:
1.65 frystyk 332: PRIVATE int FTPStatus_flush (HTStream * me)
1.60 frystyk 333: {
334: return (*me->target->isa->flush)(me->target);
1.23 frystyk 335: }
1.22 frystyk 336:
1.65 frystyk 337: PRIVATE int FTPStatus_free (HTStream * me)
1.22 frystyk 338: {
1.60 frystyk 339: int status = HT_OK;
340: if (me->target) {
341: if ((status = (*me->target->isa->_free)(me->target)) == HT_WOULD_BLOCK)
342: return HT_WOULD_BLOCK;
1.22 frystyk 343: }
1.73 frystyk 344: HTChunk_delete(me->welcome);
1.77 frystyk 345: HT_FREE(me);
1.60 frystyk 346: return HT_OK;
1.22 frystyk 347: }
348:
1.68 frystyk 349: PRIVATE int FTPStatus_abort (HTStream * me, HTList * e)
1.22 frystyk 350: {
1.60 frystyk 351: if (me->target)
352: (*me->target->isa->abort)(me->target, e);
1.73 frystyk 353: HTChunk_delete(me->welcome);
1.77 frystyk 354: HT_FREE(me);
1.60 frystyk 355: if (PROT_TRACE)
1.78 eric 356: HTTrace("FTPStatus... ABORTING...\n");
1.60 frystyk 357: return HT_ERROR;
1.22 frystyk 358: }
359:
1.60 frystyk 360: /* FTPStatus Stream
361: ** -----------------
1.22 frystyk 362: */
1.79 frystyk 363: PRIVATE const HTStreamClass FTPStatusClass =
1.60 frystyk 364: {
365: "FTPStatus",
366: FTPStatus_flush,
367: FTPStatus_free,
368: FTPStatus_abort,
369: FTPStatus_put_character,
370: FTPStatus_put_string,
371: FTPStatus_put_block
372: };
373:
1.92 eric 374: PRIVATE HTStream * FTPStatus_new (HTRequest * request, ftp_ctrl * ctrl, HTHost * host)
1.60 frystyk 375: {
1.77 frystyk 376: HTStream * me;
377: if ((me = (HTStream *) HT_CALLOC(1, sizeof(HTStream))) == NULL)
378: HT_OUTOFMEM("FTPStatus_new");
1.60 frystyk 379: me->isa = &FTPStatusClass;
380: me->request = request;
381: me->first_line = YES;
1.73 frystyk 382: me->welcome = HTChunk_new(256);
1.60 frystyk 383: me->ctrl = ctrl;
384: me->state = EOL_BEGIN;
1.92 eric 385: me->host = host;
1.60 frystyk 386: return me;
1.22 frystyk 387: }
388:
1.60 frystyk 389: /* ------------------------------------------------------------------------- */
390: /* FTP Client Functions for managing control and data connections */
391: /* ------------------------------------------------------------------------- */
1.22 frystyk 392:
1.60 frystyk 393: PRIVATE int SendCommand (HTRequest *request, ftp_ctrl *ctrl,
394: char *token, char *pars)
395: {
396: int len = strlen(token) + (pars ? strlen(pars)+1:0) + 2;
1.84 frystyk 397: HTStream * input = HTRequest_inputStream(request);
1.73 frystyk 398: HTChunk_clear(ctrl->cmd);
399: HTChunk_ensure(ctrl->cmd, len);
1.60 frystyk 400: if (pars && *pars)
1.73 frystyk 401: sprintf(HTChunk_data(ctrl->cmd), "%s %s%c%c", token, pars, CR, LF);
1.60 frystyk 402: else
1.73 frystyk 403: sprintf(HTChunk_data(ctrl->cmd), "%s%c%c", token, CR, LF);
1.78 eric 404: if (PROT_TRACE) HTTrace("FTP Tx...... %s", HTChunk_data(ctrl->cmd));
1.84 frystyk 405: return (*input->isa->put_block)(input, HTChunk_data(ctrl->cmd), len);
1.60 frystyk 406: }
407:
408: /* HTFTPParseURL
409: ** -------------
410: ** Scan URL for uid and passwd, and any data type indication. The
411: ** expected format is [user[:password]@]host[:port].
412: ** If no values are found then use defaults.
413: ** Returns YES if OK, else NO
1.22 frystyk 414: */
1.83 frystyk 415: PRIVATE BOOL HTFTPParseURL (HTRequest * request,
416: char *url, ftp_ctrl *ctrl, ftp_data *data)
1.22 frystyk 417: {
1.60 frystyk 418: char *login = HTParse(url, "", PARSE_HOST);
419: char *path = HTParse(url, "", PARSE_PATH+PARSE_PUNCTUATION);
420: char *ptr = strchr(login, '@');
421: if (ptr) { /* Uid and/or passwd specified */
422: char *passwd;
423: *ptr = '\0';
424: if ((passwd = strchr(login, ':'))) { /* Passwd specified */
425: *passwd++ = '\0';
426: HTUnEscape(passwd);
427: StrAllocCopy(ctrl->passwd, passwd);
1.22 frystyk 428: }
1.60 frystyk 429: HTUnEscape(login);
430: StrAllocCopy(ctrl->uid, login);
1.97 frystyk 431: } else if (g_FTPControlMode & FTP_ALWAYS_ASK_UID_PW) {
432: /* Added by Marek Nagy. */
433: ctrl->uid=NULL;
434: ctrl->passwd=NULL;
435: /* End of adding. */
436: } else { /* Use anonymous */
1.83 frystyk 437: HTUserProfile * up = HTRequest_userProfile(request);
1.97 frystyk 438: const char * mailaddress = HTUserProfile_email(up);
1.60 frystyk 439: StrAllocCopy(ctrl->uid, "anonymous");
440: if (mailaddress)
441: StrAllocCopy(ctrl->passwd, mailaddress);
442: else
443: StrAllocCopy(ctrl->passwd, WWW_FTP_CLIENT);
1.22 frystyk 444: }
1.95 frystyk 445: /* begin _GM_ */
446: /* Note: libwww bug ID: GM6 */
447: {
1.97 frystyk 448: /* char tempParams[512];
1.95 frystyk 449: sprintf(tempParams, "Username='%s', Password='%s'", ctrl->uid, ctrl->passwd);
450: HTRequest_addError(request, ERR_INFO, NO, HTERR_OK,
451: tempParams, strlen(tempParams), "HTFTPParseURL");
1.97 frystyk 452: */ }
1.95 frystyk 453: /* end _GM_ */
1.66 frystyk 454: if (PROT_TRACE)
1.78 eric 455: HTTrace("FTPParse.... uid `%s\' pw `%s\'\n",
1.66 frystyk 456: ctrl->uid ? ctrl->uid : "<null>",
457: ctrl->passwd ? ctrl->passwd : "<null>");
1.60 frystyk 458:
459: ptr = strchr(path, ';');
460: if (ptr) {
461: *ptr = '\0';
462: if (strncasecomp(ptr, ";type=", 6)) /* Look for type */
463: data->type = TOUPPER(*(ptr+6));
464: else if (*(ptr-1) == '/')
465: data->type = 'N';
466: } else if (*(path+strlen(path)-1) == '/') {
467: *(path+strlen(path)-1) = '\0';
468: data->type = 'N';
469: }
470: if (data->type && PROT_TRACE)
1.78 eric 471: HTTrace("FTPParse.... Datatype %c\n", data->type);
1.60 frystyk 472: StrAllocCopy(data->file, path);
473: data->offset = data->file;
1.77 frystyk 474: HT_FREE(login);
475: HT_FREE(path);
1.60 frystyk 476: return YES;
1.22 frystyk 477: }
478:
1.60 frystyk 479: /* Use LIST or NLST
480: ** ----------------
481: ** This function sets the type field for what type of list we can use
482: ** Returns YES if OK, else NO
483: */
1.63 frystyk 484: PRIVATE BOOL FTPListType (ftp_data * data, FTPServerType type)
1.60 frystyk 485: {
486: if (!data) return NO;
487: switch (type) {
488: case FTP_GENERIC: data->type='N'; break;
489: case FTP_MACHTEN: data->type='L'; break;
490: case FTP_UNIX: data->type='L'; break;
491: case FTP_VMS: data->type='L'; break;
492: case FTP_CMS: data->type='N'; break;
493: case FTP_DCTS: data->type='N'; break;
494: case FTP_TCPC: data->type='N'; break;
495: case FTP_PETER_LEWIS: data->type='L'; break;
496: case FTP_NCSA: data->type='N'; break;
497: case FTP_WINNT: data->type='L'; break;
498: default: data->type='N'; break;
499: }
500: return YES;
501: }
502:
503: /* Open a Data socket for listening on
504: ** -----------------------------------
505: ** Set up a port to listen for data
506: ** Returns YES if OK, else NO
1.22 frystyk 507: */
1.60 frystyk 508: PRIVATE BOOL ListenSocket (HTNet *cnet, HTNet *dnet, ftp_data *data)
1.22 frystyk 509: {
1.79 frystyk 510: #ifdef FTP_POLL_PORTS
1.60 frystyk 511: unsigned short old_DataPort = DataPort;
512: for (DataPort=old_DataPort+1;; DataPort++) {
513: if (DataPort > LAST_TCP_PORT)
514: DataPort = FIRST_TCP_PORT;
515: if (DataPort == old_DataPort) {
1.78 eric 516: if(PROT_TRACE) HTTrace("FTP......... No data port found\n");
1.60 frystyk 517: return NO;
518: }
1.71 frystyk 519: if (HTDoListen(dnet, DataPort, 1) == HT_OK)
1.60 frystyk 520: break;
1.85 frystyk 521: #if 0
1.91 frystyk 522: if (HTNet_socket(dnet) != INVSOC) {
523: NETCLOSE(HTNet_socket(dnet));
524: HTNet_socket(dnet) = INVSOC;
1.60 frystyk 525: }
1.85 frystyk 526: #else
527: HTDoClose(dnet);
528: #endif
1.22 frystyk 529: }
1.60 frystyk 530: #else
1.91 frystyk 531: if (HTDoListen(dnet, 0, HTNet_socket(cnet), 1) != HT_OK) return NO;
1.79 frystyk 532: #endif /* FTP_POLL_PORTS */
1.22 frystyk 533:
1.60 frystyk 534: /* Now we must find out who we are to tell the other guy */
535: {
536: SockA local_addr;
537: int addr_size = sizeof(local_addr);
538: memset((void *) &local_addr, '\0', sizeof(local_addr));
1.91 frystyk 539: if (getsockname(HTNet_socket(dnet), (struct sockaddr *) &local_addr,
1.60 frystyk 540: &addr_size) < 0) {
1.93 frystyk 541: HTRequest_addSystemError(HTNet_request(dnet), ERR_FATAL, socerrno,
1.68 frystyk 542: NO, "getsockname");
1.60 frystyk 543: return NO;
1.22 frystyk 544: }
1.78 eric 545: if (PROT_TRACE) HTTrace("FTP......... This host is `%s\'\n",
1.60 frystyk 546: HTInetString(&local_addr));
547: {
548: u_long addr = local_addr.sin_addr.s_addr;
549: u_short port = local_addr.sin_port;
550: sprintf(data->host, "%d,%d,%d,%d,%d,%d",
551: (int)*((unsigned char *)(&addr)+0),
552: (int)*((unsigned char *)(&addr)+1),
553: (int)*((unsigned char *)(&addr)+2),
554: (int)*((unsigned char *)(&addr)+3),
555: (int)*((unsigned char *)(&port)+0),
556: (int)*((unsigned char *)(&port)+1));
1.22 frystyk 557: }
558: }
1.60 frystyk 559: return YES;
1.22 frystyk 560: }
561:
1.60 frystyk 562: /* HTFTPLogin
563: ** -----------
564: ** This function makes a login to a ftp-server. It takes the user name
565: ** and passwd specified in ctrl->user and if that fails or an additional
566: ** account is needed, the user is prompted.
567: ** Returns HT_OK, HT_ERROR, or HT_WOULD_BLOCK
1.22 frystyk 568: */
1.60 frystyk 569: PRIVATE int HTFTPLogin (HTRequest *request, HTNet *cnet, ftp_ctrl *ctrl)
1.22 frystyk 570: {
1.60 frystyk 571: int status;
572: typedef enum _state {
573: SUB_ERROR = -2,
574: SUB_SUCCESS = -1,
575: NEED_SELECT = 0,
576: NEED_GREETING,
577: NEED_REIN,
578: NEED_UID,
579: NEED_PASSWD,
580: NEED_ACCOUNT,
581: PROMPT_USER
582: } state;
583:
584: /* Jump into a second level state machine */
585: while (1) {
586: switch ((state) ctrl->substate) {
587: case NEED_SELECT:
1.95 frystyk 588: if (PROT_TRACE) HTTrace("FTP Login.. now in state NEED_SELECT\n");
1.60 frystyk 589: ctrl->substate = ctrl->reset ? NEED_REIN : NEED_GREETING;
1.95 frystyk 590: #if 0
591: ctrl->substate = ctrl->reset ? NEED_UID : NEED_GREETING;
592: #endif
1.60 frystyk 593: break;
594:
595: case NEED_GREETING:
1.95 frystyk 596: if (PROT_TRACE) HTTrace("FTP Login.. now in state NEED_GREETING\n");
1.93 frystyk 597: status = HTHost_read(HTNet_host(cnet), cnet);
1.60 frystyk 598: if (status == HT_WOULD_BLOCK)
599: return HT_WOULD_BLOCK;
600: else if (status == HT_LOADED) {
1.66 frystyk 601: if (ctrl->repcode/100 == 2) {
602: ctrl->substate = (ctrl->uid && *ctrl->uid) ?
603: NEED_UID : PROMPT_USER;
1.95 frystyk 604: } else {
1.60 frystyk 605: ctrl->substate = SUB_ERROR;
1.95 frystyk 606: }
607: } else {
1.60 frystyk 608: ctrl->substate = SUB_ERROR;
1.95 frystyk 609: }
1.60 frystyk 610: break;
611:
612: case NEED_REIN:
1.95 frystyk 613: if (PROT_TRACE) HTTrace("FTP Login.. now in state NEED_REIN\n");
1.60 frystyk 614: if (!ctrl->sent) {
615: status = SendCommand(request, ctrl, "REIN", NULL);
616: if (status == HT_WOULD_BLOCK)
617: return HT_WOULD_BLOCK;
618: else if (status == HT_ERROR)
619: ctrl->substate = SUB_ERROR;
620: ctrl->sent = YES;
621: } else {
1.93 frystyk 622: status = HTHost_read(HTNet_host(cnet), cnet);
1.60 frystyk 623: if (status == HT_WOULD_BLOCK)
624: return HT_WOULD_BLOCK;
625: else if (status == HT_LOADED) {
1.95 frystyk 626: /* begin _GM_ */
627: /* Note: libwww bug ID: GM8 */
628: /* if (ctrl->repcode/100 == 2) { */
629: /* If the FTP server doesn't support the REIN command, then
630: the return code will be 502 */
631: if ((ctrl->repcode/100 == 2) || (ctrl->repcode == 502)) {
632: /* end _GM_ */
1.66 frystyk 633: ctrl->substate = (ctrl->uid && *ctrl->uid) ?
634: NEED_UID : PROMPT_USER;
1.95 frystyk 635: } else {
1.60 frystyk 636: ctrl->substate = SUB_SUCCESS; /* hope the best */
1.95 frystyk 637: }
638: } else {
1.60 frystyk 639: ctrl->substate = SUB_ERROR;
1.95 frystyk 640: }
1.60 frystyk 641: ctrl->sent = NO;
1.22 frystyk 642: }
1.60 frystyk 643: break;
644:
645: case NEED_UID:
1.95 frystyk 646: if (PROT_TRACE) HTTrace("FTP Login.. now in state NEED_UID\n");
1.60 frystyk 647: if (!ctrl->sent) {
648: status = SendCommand(request, ctrl, "USER", ctrl->uid);
649: if (status == HT_WOULD_BLOCK)
650: return HT_WOULD_BLOCK;
651: else if (status == HT_ERROR)
652: ctrl->substate = SUB_ERROR;
653: ctrl->sent = YES;
1.22 frystyk 654: } else {
1.93 frystyk 655: status = HTHost_read(HTNet_host(cnet), cnet);
1.60 frystyk 656: if (status == HT_WOULD_BLOCK)
657: return HT_WOULD_BLOCK;
658: else if (status == HT_LOADED) {
659: int code = ctrl->repcode/100;
660: if (code == 2) /* Logged in w/o passwd! */
661: ctrl->substate = SUB_SUCCESS;
1.66 frystyk 662: else if (code == 3) { /* Password demanded */
663: ctrl->substate = (ctrl->passwd && *ctrl->passwd) ?
664: NEED_PASSWD : PROMPT_USER;
1.95 frystyk 665: /* begin _GM_ */
666: /* Note: libwww bug ID: GM3 */
667: /* } else if (ctrl->repcode == 530) */
668: /* ctrl->substate = PROMPT_USER;*/ /* User unknown */
669: } else if (ctrl->repcode == 530) {
670: if (ctrl->alreadyLoggedIn == YES) {
671: ctrl->substate = SUB_SUCCESS;
672: if (PROT_TRACE) HTTrace("FTP Login.. Already logged in\n");
673: } else {
674: ctrl->substate = PROMPT_USER;
675: if (PROT_TRACE) HTTrace("FTP Login.. User Unknown\n");
676: }
677: }
678: /* end _GM_ */
1.60 frystyk 679: else
680: ctrl->substate = SUB_ERROR;
681: } else
682: ctrl->substate = SUB_ERROR;
683: ctrl->sent = NO;
1.22 frystyk 684: }
1.60 frystyk 685: break;
1.1 timbl 686:
1.60 frystyk 687: case NEED_PASSWD:
1.95 frystyk 688: if (PROT_TRACE) HTTrace("FTP Login.. now in state NEED_PASSWD\n");
1.60 frystyk 689: if (!ctrl->sent) {
690: status = SendCommand(request, ctrl, "PASS", ctrl->passwd);
691: if (status == HT_WOULD_BLOCK)
692: return HT_WOULD_BLOCK;
693: else if (status == HT_ERROR)
694: ctrl->substate = SUB_ERROR;
695: ctrl->sent = YES;
696: } else {
1.93 frystyk 697: status = HTHost_read(HTNet_host(cnet), cnet);
1.60 frystyk 698: if (status == HT_WOULD_BLOCK)
699: return HT_WOULD_BLOCK;
700: else if (status == HT_LOADED) {
701: int code = ctrl->repcode/100;
702: if (code == 2) /* Logged in with passwd */
703: ctrl->substate = SUB_SUCCESS;
1.70 frystyk 704: else if (code == 3) { /* Account required */
705: HTAlertCallback *cbf = HTAlert_find(HT_A_PROMPT);
706: HTAlertPar * reply = HTAlert_newReply();
707: if (cbf && (*cbf)(request, HT_A_PROMPT,
708: HT_MSG_ACCOUNT, NULL, NULL, reply)) {
709: ctrl->account = HTAlert_replyMessage(reply);
1.60 frystyk 710: ctrl->substate = NEED_ACCOUNT;
1.70 frystyk 711: } else
1.60 frystyk 712: ctrl->substate = SUB_ERROR;
1.70 frystyk 713: HTAlert_deleteReply(reply);
1.60 frystyk 714: } else if (ctrl->repcode == 530)
715: ctrl->substate = PROMPT_USER;
716: else
717: ctrl->substate = SUB_ERROR;
718: } else
719: ctrl->substate = SUB_ERROR;
720: ctrl->sent = NO;
721: }
722: break;
1.1 timbl 723:
1.60 frystyk 724: case NEED_ACCOUNT:
1.95 frystyk 725: if (PROT_TRACE) HTTrace("FTP Login.. now in state NEED_ACCOUNT\n");
1.60 frystyk 726: if (!ctrl->sent) {
727: status = SendCommand(request, ctrl, "ACCT", ctrl->account);
728: if (status == HT_WOULD_BLOCK)
729: return HT_WOULD_BLOCK;
730: else if (status == HT_ERROR)
731: ctrl->substate = SUB_ERROR;
732: ctrl->sent = YES;
1.23 frystyk 733: } else {
1.93 frystyk 734: status = HTHost_read(HTNet_host(cnet), cnet);
1.60 frystyk 735: if (status == HT_WOULD_BLOCK)
736: return HT_WOULD_BLOCK;
737: else if (status == HT_LOADED) {
738: int code = ctrl->repcode/100;
739: if (code == 2) /* Logged in with account */
740: ctrl->substate = SUB_SUCCESS;
741: else
742: ctrl->substate = SUB_ERROR; /* hopeless */
743: } else
744: ctrl->substate = SUB_ERROR;
745: ctrl->sent = NO;
1.1 timbl 746: }
1.60 frystyk 747: break;
1.1 timbl 748:
1.60 frystyk 749: case PROMPT_USER:
1.95 frystyk 750: if (PROT_TRACE) HTTrace("FTP Login.. now in state PROMPT_USER\n");
1.60 frystyk 751: {
1.70 frystyk 752: HTAlertCallback *cbf = HTAlert_find(HT_A_USER_PW);
753: HTAlertPar * reply = HTAlert_newReply();
1.77 frystyk 754: HT_FREE(ctrl->uid);
755: HT_FREE(ctrl->passwd);
1.87 frystyk 756: if (cbf && (*cbf)(request, HT_A_USER_PW, HT_MSG_FTP_UID,
757: NULL, NULL, reply)){
1.70 frystyk 758: ctrl->uid = HTAlert_replyMessage(reply);
759: ctrl->passwd = HTAlert_replySecret(reply);
760: }
761: HTAlert_deleteReply(reply);
1.66 frystyk 762: if (ctrl->uid && *ctrl->uid && ctrl->passwd && *ctrl->passwd)
1.60 frystyk 763: ctrl->substate = NEED_UID;
764: else
765: ctrl->substate = SUB_ERROR;
766: }
767: break;
1.1 timbl 768:
1.60 frystyk 769: case SUB_ERROR:
1.95 frystyk 770: if (PROT_TRACE) HTTrace("FTP Login.. now in state SUB_ERROR\n");
771: HTRequest_addError(request, ERR_FATAL, NO,
772: HTERR_FTP_LOGIN_FAILURE, NULL, 0, "HTFTPLogin");
773: if (PROT_TRACE) HTTrace("FTP......... Login failed\n");
1.60 frystyk 774: ctrl->substate = 0;
775: return HT_ERROR;
776: break;
1.23 frystyk 777:
1.60 frystyk 778: case SUB_SUCCESS:
1.95 frystyk 779: if (PROT_TRACE) HTTrace("FTP Login.. now in state SUB_SUCCESS\n");
780: if (PROT_TRACE) HTTrace("FTP......... Logged in as `%s\'\n", ctrl->uid);
1.60 frystyk 781: ctrl->substate = 0;
782: return HT_OK;
783: break;
1.23 frystyk 784: }
1.22 frystyk 785: }
786: }
787:
1.60 frystyk 788: /* HTFTPDataConnection
789: ** -------------------
790: ** Prepares a data connection to the server and initializes the
791: ** transfer mode.
792: ** Returns HT_OK, HT_ERROR, or HT_WOULD_BLOCK
1.1 timbl 793: */
1.60 frystyk 794: PRIVATE int HTFTPDataConnection (HTRequest * request, HTNet *cnet,
795: ftp_ctrl *ctrl, ftp_data *data)
1.1 timbl 796: {
1.60 frystyk 797: int status;
798: HTNet *dnet = ctrl->dnet;
799: typedef enum _state {
800: SUB_ERROR = -2,
801: SUB_SUCCESS = -1,
802: NEED_TYPE = 0,
803: NEED_SELECT,
804: NEED_PASV,
805: NEED_PORT
806: } state;
807:
808: /* Jump into a second level state machine */
809: while (1) {
810: switch ((state) ctrl->substate) {
811: case NEED_TYPE:
1.95 frystyk 812: if (PROT_TRACE) HTTrace("FTP Data.... now in state NEED_TYPE\n");
1.60 frystyk 813: if(!data->type|| data->pasv || data->type=='N' || data->type=='L'){
814: ctrl->substate = NEED_SELECT;
815: break;
816: }
817: if (!ctrl->sent) {
818: char type[2];
819: *type = data->type;
820: *(type+1) = '\0';
821: status = SendCommand(request, ctrl, "TYPE", type);
822: if (status == HT_WOULD_BLOCK)
823: return HT_WOULD_BLOCK;
824: else if (status == HT_ERROR)
825: ctrl->substate = SUB_ERROR;
826: ctrl->sent = YES;
827: } else {
1.93 frystyk 828: status = HTHost_read(HTNet_host(cnet), cnet);
1.60 frystyk 829: if (status == HT_WOULD_BLOCK)
830: return HT_WOULD_BLOCK;
831: else if (status == HT_LOADED) {
832: if (ctrl->repcode/100 == 2)
833: ctrl->substate = NEED_SELECT;
834: else
835: ctrl->substate = SUB_ERROR;
836: } else
837: ctrl->substate = SUB_ERROR;
838: ctrl->sent = NO;
839: }
840: break;
841:
842: case NEED_SELECT:
1.95 frystyk 843: if (PROT_TRACE) HTTrace("FTP Data.... now in state NEED_SELECT\n");
1.60 frystyk 844: if (FTPMode & FTP_DATA_PASV && !data->pasv)
845: ctrl->substate = NEED_PASV;
846: else if (ListenSocket(cnet, dnet, data))
847: ctrl->substate = NEED_PORT;
848: else
849: ctrl->substate = SUB_ERROR;
850: break;
851:
852: case NEED_PASV:
1.95 frystyk 853: if (PROT_TRACE) HTTrace("FTP Data.... now in state NEED_PASV\n");
1.60 frystyk 854: if (!ctrl->sent) {
855: status = SendCommand(request, ctrl, "PASV", NULL);
856: if (status == HT_WOULD_BLOCK)
857: return HT_WOULD_BLOCK;
858: else if (status == HT_ERROR)
859: ctrl->substate = SUB_ERROR;
860: ctrl->sent = YES;
861: } else {
1.93 frystyk 862: status = HTHost_read(HTNet_host(cnet), cnet);
1.60 frystyk 863: if (status == HT_WOULD_BLOCK)
864: return HT_WOULD_BLOCK;
865: else if (status == HT_LOADED) {
866: if (ctrl->repcode == 227) {
867: /*
868: ** If succes, we have to scan for the returned number.
869: ** As the format for the response isn't standard,
870: ** the best thing to do is to scan for the first digit
871: ** after the status code, see RFC1123
872: */
873: char *host = ctrl->reply;
874: int h0, h1, h2, h3, p0=0, p1=0;
1.94 frystyk 875: while (*host && !isdigit((int) *host++));
1.60 frystyk 876: if (!*host || sscanf(--host, "%d,%d,%d,%d,%d,%d",
877: &h0,&h1,&h2,&h3,&p0,&p1) < 6) {
878: if (PROT_TRACE)
1.95 frystyk 879: HTTrace("FTP Data.... PASV No addr\n");
1.60 frystyk 880: ctrl->substate = SUB_ERROR;
881: break;
882: } else {
883: int port = (p0<<8)+p1;
884: sprintf(data->host, "ftp://%d.%d.%d.%d:%d/",
885: h0, h1, h2, h3, port);
886: data->pasv = YES;
887: ctrl->substate = SUB_SUCCESS;
888: }
889: } else {
890: ctrl->substate = ListenSocket(cnet, dnet, data) ?
891: NEED_PORT : SUB_ERROR;
892: }
893: } else
894: ctrl->substate = SUB_ERROR;
895: ctrl->sent = NO;
896: }
897: break;
1.22 frystyk 898:
1.60 frystyk 899: case NEED_PORT:
1.95 frystyk 900: if (PROT_TRACE) HTTrace("FTP Data.... now in state NEED_PORT\n");
1.60 frystyk 901: if (!ctrl->sent) {
902: status = SendCommand(request, ctrl, "PORT", data->host);
903: if (status == HT_WOULD_BLOCK)
904: return HT_WOULD_BLOCK;
905: else if (status == HT_ERROR)
906: ctrl->substate = SUB_ERROR;
907: ctrl->sent = YES;
908: } else {
1.93 frystyk 909: status = HTHost_read(HTNet_host(cnet), cnet);
1.60 frystyk 910: if (status == HT_WOULD_BLOCK)
911: return HT_WOULD_BLOCK;
912: else if (status == HT_LOADED) {
913: data->pasv = NO;
914: ctrl->substate = (ctrl->repcode/100 == 2) ?
915: SUB_SUCCESS : SUB_ERROR;
916: } else
917: ctrl->substate = SUB_ERROR;
918: ctrl->sent = NO;
919: }
920: break;
1.1 timbl 921:
1.60 frystyk 922: case SUB_ERROR:
1.95 frystyk 923: if (PROT_TRACE) HTTrace("FTP Data.... now in state SUB_ERROR\n");
1.60 frystyk 924: if (PROT_TRACE)
1.95 frystyk 925: HTTrace("FTP Data.... Can't setup data connection\n");
1.60 frystyk 926: ctrl->substate = 0;
927: return HT_ERROR;
928: break;
1.1 timbl 929:
1.60 frystyk 930: case SUB_SUCCESS:
1.95 frystyk 931: if (PROT_TRACE) HTTrace("FTP Data.... now in state SUB_SUCCESS\n");
1.60 frystyk 932: if (PROT_TRACE)
1.95 frystyk 933: HTTrace("FTP Data.... Data connection negotiated\n");
1.60 frystyk 934: ctrl->substate = 0;
935: return HT_OK;
936: break;
1.23 frystyk 937: }
1.58 frystyk 938: }
1.23 frystyk 939: }
1.1 timbl 940:
941:
1.60 frystyk 942: /* HTFTPServerInfo
943: ** ---------------
944: ** This function finds out what server we are talking to.
945: ** Maybe we can upgrade from NLST to LIST.
946: ** Returns HT_OK, HT_ERROR, or HT_WOULD_BLOCK
947: ** Thanks to James.W.Matthews@Dartmouth.EDU (James W. Matthews) for making
948: ** his code available.
1.1 timbl 949: */
1.60 frystyk 950: PRIVATE int HTFTPServerInfo (HTRequest *request, HTNet *cnet,
951: ftp_ctrl *ctrl, ftp_data *data)
1.23 frystyk 952: {
1.60 frystyk 953: int status;
954: typedef enum _state {
955: SUB_ERROR = -2,
956: SUB_SUCCESS = -1,
957: NEED_SYST = 0,
958: CHECK_SYST,
959: NEED_PWD,
960: CHECK_PWD
961: } state;
962:
963: /* Jump into a second level state machine */
964: while (1) {
965: switch ((state) ctrl->substate) {
966: case NEED_SYST:
1.95 frystyk 967: if (PROT_TRACE) HTTrace("FTP Server.. now in state NEED_SYST\n");
1.60 frystyk 968: if (!ctrl->sent) {
1.63 frystyk 969: if (ctrl->server != FTP_UNSURE) {
1.60 frystyk 970: FTPListType(data, ctrl->server);
971: return HT_OK;
972: }
973: status = SendCommand(request, ctrl, "SYST", NULL);
974: if (status == HT_WOULD_BLOCK)
975: return HT_WOULD_BLOCK;
976: else if (status == HT_ERROR)
977: ctrl->substate = SUB_ERROR;
978: ctrl->sent = YES;
979: } else {
1.93 frystyk 980: status = HTHost_read(HTNet_host(cnet), cnet);
1.60 frystyk 981: if (status == HT_WOULD_BLOCK)
982: return HT_WOULD_BLOCK;
983: else if (status == HT_LOADED) {
984: ctrl->substate=ctrl->repcode==215 ? CHECK_SYST : NEED_PWD;
985: } else
986: ctrl->substate = SUB_ERROR;
987: ctrl->sent = NO;
1.23 frystyk 988: }
989: break;
990:
1.60 frystyk 991: case CHECK_SYST:
1.95 frystyk 992: if (PROT_TRACE) HTTrace("FTP Server.. now in state CHECK_SYST\n");
1.23 frystyk 993: {
1.60 frystyk 994: char *reply = ctrl->reply;
995: if (!*reply) {
1.43 frystyk 996: if (PROT_TRACE)
1.95 frystyk 997: HTTrace("FTP Server.. No server info?\n");
1.60 frystyk 998: ctrl->substate = NEED_PWD;
1.23 frystyk 999: break;
1000: }
1.60 frystyk 1001: if (strncmp(reply, "UNIX Type: L8MAC-OSMachTen", 28) == 0) {
1002: ctrl->server = FTP_MACHTEN;
1003: } else if (strstr(reply, "UNIX") != NULL) {
1004: ctrl->server = FTP_UNIX;
1005: } else if (strncmp(reply, "VMS", 3) == 0) {
1006: ctrl->server = FTP_VMS;
1007: } else if ((strncmp(reply, "VM/CMS", 6) == 0) ||
1008: (strncmp(reply, "VM", 2) == 0)) {
1009: ctrl->server = FTP_CMS;
1010: } else if (strncmp(reply, "DCTS", 4) == 0) {
1011: ctrl->server = FTP_DCTS;
1012: } else if (strstr(reply, "MAC-OS TCP/ConnectII") != NULL) {
1.23 frystyk 1013: /* Check old versions of TCP/C using / in pathnames */
1.63 frystyk 1014: ctrl->server = FTP_TCPC + FTP_UNSURE;
1.60 frystyk 1015: } else if (strncmp(reply, "MACOS Peter's Server", 20) == 0) {
1016: ctrl->server = FTP_PETER_LEWIS;
1017: } else if (strncmp(reply, "Windows_NT", 10) == 0) {
1018: ctrl->server = FTP_WINNT;
1.23 frystyk 1019: }
1020:
1021: /* If we are unsure, try PWD to get more information */
1.60 frystyk 1022: if (ctrl->server & FTP_UNSURE)
1023: ctrl->substate = NEED_PWD;
1.23 frystyk 1024: else
1.60 frystyk 1025: ctrl->substate = SUB_SUCCESS;
1.1 timbl 1026: }
1.23 frystyk 1027: break;
1028:
1029: case NEED_PWD:
1.95 frystyk 1030: if (PROT_TRACE) HTTrace("FTP Server.. now in state NEED_PWD\n");
1.60 frystyk 1031: if (!ctrl->sent) {
1032: status = SendCommand(request, ctrl, "PWD", NULL);
1033: if (status == HT_WOULD_BLOCK)
1034: return HT_WOULD_BLOCK;
1035: else if (status == HT_ERROR)
1036: ctrl->substate = SUB_ERROR;
1037: ctrl->sent = YES;
1.23 frystyk 1038: } else {
1.93 frystyk 1039: status = HTHost_read(HTNet_host(cnet), cnet);
1.60 frystyk 1040: if (status == HT_WOULD_BLOCK)
1041: return HT_WOULD_BLOCK;
1042: else if (status == HT_LOADED) {
1043: ctrl->substate = (ctrl->repcode/100 == 2) ?
1044: CHECK_PWD : SUB_ERROR;
1045: } else
1046: ctrl->substate = SUB_ERROR;
1047: ctrl->sent = NO;
1.23 frystyk 1048: }
1049: break;
1050:
1.60 frystyk 1051: case CHECK_PWD:
1.95 frystyk 1052: if (PROT_TRACE) HTTrace("FTP Server.. now in state CHECK_PWD\n");
1.60 frystyk 1053: {
1054: char *start = strchr(ctrl->reply, '"');
1055: char *end;
1056: if (!start || (end = strchr(++start, '"')) == NULL) {
1.43 frystyk 1057: if (PROT_TRACE)
1.95 frystyk 1058: HTTrace("FTP Server.. No current directory?\n");
1.60 frystyk 1059: ctrl->server = FTP_GENERIC;
1.23 frystyk 1060: } else {
1.60 frystyk 1061: *end = '\0';
1.63 frystyk 1062: if (ctrl->server & FTP_TCPC) {
1.60 frystyk 1063: ctrl->server = *start == '/' ? FTP_NCSA : FTP_TCPC;
1064: } else if (*start == '/') {
1065: /* path names starting with / imply Unix, right? */
1066: ctrl->server = FTP_UNIX;
1067: } else if (*(end-1) == ']') {
1068: /* path names ending with ] imply VMS, right? */
1069: ctrl->server = FTP_VMS;
1070: } else
1071: ctrl->server = FTP_GENERIC;
1.23 frystyk 1072: }
1.60 frystyk 1073: ctrl->substate = SUB_SUCCESS;
1.1 timbl 1074: }
1.23 frystyk 1075: break;
1.1 timbl 1076:
1.60 frystyk 1077: case SUB_ERROR:
1.95 frystyk 1078: if (PROT_TRACE) HTTrace("FTP Server.. now in state SUB_ERROR\n");
1.60 frystyk 1079: if (PROT_TRACE)
1.95 frystyk 1080: HTTrace("FTP Server.. Can't get server information\n");
1.60 frystyk 1081: ctrl->substate = 0;
1.63 frystyk 1082: ctrl->server = FTP_GENERIC;
1.60 frystyk 1083: return HT_ERROR;
1.23 frystyk 1084: break;
1.22 frystyk 1085:
1.60 frystyk 1086: case SUB_SUCCESS:
1.95 frystyk 1087: if (PROT_TRACE) HTTrace("FTP Server.. now in state SUB_SUCCESS\n");
1088: {
1.81 frystyk 1089: HTHost * host = HTNet_host(cnet);
1090: if (PROT_TRACE)
1091: HTTrace("FTP Server.. Guessed type %d\n", ctrl->server);
1092: HTHost_setVersion(host, ctrl->server);
1093: FTPListType(data, ctrl->server);
1094: ctrl->substate = 0;
1095: return HT_OK;
1096: break;
1.95 frystyk 1097: }
1.22 frystyk 1098: }
1.23 frystyk 1099: }
1100: }
1101:
1.60 frystyk 1102: /* HTFTPGetData
1103: ** ------------
1104: ** This function asks for the file or a directory. First we try in one go,
1.23 frystyk 1105: ** but if that doesn't work, then we use CWD for each segment and then
1106: ** try to retrieve it. If that also fails, then we try if it is a
1.60 frystyk 1107: ** directory.
1108: ** Returns HT_OK, HT_LOADED, HT_ERROR, or HT_WOULD_BLOCK
1.23 frystyk 1109: */
1.71 frystyk 1110: PRIVATE int HTFTPGetData (HTRequest *request, HTNet *cnet, SOCKET sockfd,
1.60 frystyk 1111: ftp_ctrl *ctrl, ftp_data *data)
1.23 frystyk 1112: {
1113: int status;
1.60 frystyk 1114: char *segment = NULL;
1115: HTNet *dnet = ctrl->dnet;
1.93 frystyk 1116: BOOL data_is_active = (sockfd == HTNet_socket(dnet));
1.60 frystyk 1117: typedef enum _state {
1118: SUB_ERROR = -2,
1119: SUB_SUCCESS = -1,
1120: NEED_SELECT = 0,
1121: NEED_CONNECT,
1122: NEED_ACCEPT,
1123: NEED_ACTION,
1124: NEED_CWD,
1125: NEED_SEGMENT,
1126: NEED_STREAM,
1.63 frystyk 1127: NEED_BODY
1.60 frystyk 1128: } state;
1129:
1130: /* Jump into a second level state machine */
1131: while (1) {
1132: switch ((state) ctrl->substate) {
1133: case NEED_SELECT:
1.95 frystyk 1134: if (PROT_TRACE) HTTrace("FTP Get Data now in state NEED_SELECT\n");
1.60 frystyk 1135: ctrl->substate = data->pasv ? NEED_CONNECT : NEED_ACTION;
1136: break;
1137:
1138: case NEED_CONNECT:
1.95 frystyk 1139: if (PROT_TRACE) HTTrace("FTP Get Data now in state NEED_CONNECT\n");
1.93 frystyk 1140: status = HTHost_connect(HTNet_host(dnet), dnet, data->host, FTP_DATA);
1.60 frystyk 1141: if (status == HT_WOULD_BLOCK)
1142: return HT_WOULD_BLOCK;
1143: else if (status == HT_OK) {
1144: if (PROT_TRACE)
1.95 frystyk 1145: HTTrace("FTP Get Data.... Active data socket %d\n",
1146: HTNet_socket(dnet));
1.93 frystyk 1147: #if 0
1.92 eric 1148: /* HTNet_setPersistent(dnet, YES, HT_TP_INTERLEAVE); */
1149: HTNet_setPersistent(dnet, YES, HT_TP_SINGLE);
1.93 frystyk 1150: #endif
1.60 frystyk 1151: ctrl->substate = NEED_ACTION;
1.81 frystyk 1152: } else { /* Swap to PORT on the fly */
1.91 frystyk 1153: NETCLOSE(HTNet_socket(dnet));
1154: HTNet_setSocket(dnet, INVSOC);
1.60 frystyk 1155: if (PROT_TRACE)
1.95 frystyk 1156: HTTrace("FTP Get Data Swap to PORT on the fly\n");
1.89 frystyk 1157: ctrl->substate = NEED_SELECT;
1.77 frystyk 1158: HT_FREE(segment);
1.60 frystyk 1159: return HT_OK;
1160: }
1.23 frystyk 1161: break;
1162:
1.60 frystyk 1163: case NEED_ACCEPT:
1.95 frystyk 1164: if (PROT_TRACE) HTTrace("FTP Get Data now in state NEED_ACCEPT\n");
1.60 frystyk 1165: {
1.86 frystyk 1166: status = HTDoAccept(ctrl->dnet, &ctrl->dnet);
1167: dnet = ctrl->dnet;
1.60 frystyk 1168: if (status == HT_WOULD_BLOCK)
1169: return HT_WOULD_BLOCK;
1170: else if (status == HT_OK) {
1171: if (PROT_TRACE)
1.95 frystyk 1172: HTTrace("FTP Get Data.... Passive data socket %d\n",
1.91 frystyk 1173: HTNet_socket(dnet));
1.60 frystyk 1174: ctrl->substate = NEED_STREAM;
1175: } else
1176: ctrl->substate = SUB_ERROR;
1.23 frystyk 1177: }
1.60 frystyk 1178: break;
1.33 frystyk 1179:
1.60 frystyk 1180: case NEED_ACTION:
1.95 frystyk 1181: if (PROT_TRACE) HTTrace("FTP Get Data now in state NEED_ACTION\n");
1.60 frystyk 1182: if (!ctrl->sent) {
1183: char *cmd = (data->type=='L') ? "LIST" :
1184: (data->type=='N') ? "NLST" : "RETR";
1185: StrAllocCopy(segment, data->offset);
1186: HTUnEscape(segment);
1187: HTCleanTelnetString(segment);
1188: status = SendCommand(request, ctrl, cmd, segment);
1.77 frystyk 1189: HT_FREE(segment);
1.60 frystyk 1190: if (status == HT_WOULD_BLOCK)
1191: return HT_WOULD_BLOCK;
1192: else if (status == HT_ERROR)
1193: ctrl->substate = SUB_ERROR;
1194: ctrl->sent = YES;
1195: } else {
1.93 frystyk 1196: status = HTHost_read(HTNet_host(cnet), cnet);
1.60 frystyk 1197: if (status == HT_WOULD_BLOCK)
1198: return HT_WOULD_BLOCK;
1199: else if (status == HT_LOADED) {
1200: int code = ctrl->repcode;
1201: if (code==125 || code==150 || code==225)
1.93 frystyk 1202: ctrl->substate = data->pasv ? NEED_STREAM : NEED_ACCEPT;
1.60 frystyk 1203: else if (code/100==5 && !ctrl->cwd)
1204: ctrl->substate = NEED_SEGMENT;
1.95 frystyk 1205: /* begin _GM_ */
1206: /* Note: libwww bug ID: GM9 */
1207: /* else */
1208: /* ctrl->substate = SUB_ERROR; */
1209: else {
1210: if (ctrl->repcode == 550) {
1211: if (PROT_TRACE) HTTrace("FTP Get Data no such file or directory\n");
1212: data->stream_error = YES;
1213: }
1214: ctrl->substate = SUB_ERROR;
1215: }
1216: /* end _GM_ */
1.60 frystyk 1217: } else
1218: ctrl->substate = SUB_ERROR;
1219: ctrl->sent = NO;
1.23 frystyk 1220: }
1221: break;
1.60 frystyk 1222:
1223: case NEED_SEGMENT:
1.95 frystyk 1224: if (PROT_TRACE) HTTrace("FTP Get Data now in state NEED_SEGMENT\n");
1.23 frystyk 1225: {
1.60 frystyk 1226: char *ptr;
1227: if (data->offset == data->file) {
1.63 frystyk 1228: if (ctrl->server == FTP_VMS) { /* Change to root */
1.77 frystyk 1229: if ((segment = (char *) HT_MALLOC(strlen(ctrl->uid)+3)) == NULL)
1230: HT_OUTOFMEM("segment ");
1.63 frystyk 1231: sprintf(segment, "[%s]", ctrl->uid);
1232: } else
1233: StrAllocCopy(segment, "/");
1.60 frystyk 1234: data->offset++;
1235: ctrl->substate = NEED_CWD;
1236: } else {
1237: if ((ptr = strchr(data->offset, '/'))) {
1238: *ptr='\0';
1239: StrAllocCopy(segment, data->offset);
1240: *ptr='/';
1241: data->offset = ++ptr;
1242: HTUnEscape(segment);
1243: HTCleanTelnetString(segment);
1244: ctrl->substate = NEED_CWD;
1.33 frystyk 1245: } else
1.60 frystyk 1246: ctrl->substate = NEED_ACTION;
1.23 frystyk 1247: }
1248: }
1249: break;
1250:
1.60 frystyk 1251: case NEED_CWD:
1.95 frystyk 1252: if (PROT_TRACE) HTTrace("FTP Get Data now in state NEED_CWD\n");
1.60 frystyk 1253: if (!ctrl->sent) {
1254: status = SendCommand(request, ctrl, "CWD", segment);
1.77 frystyk 1255: HT_FREE(segment);
1.60 frystyk 1256: if (status == HT_WOULD_BLOCK)
1257: return HT_WOULD_BLOCK;
1258: else if (status == HT_ERROR)
1259: ctrl->substate = SUB_ERROR;
1260: ctrl->cwd = YES;
1261: ctrl->sent = YES;
1262: } else {
1.93 frystyk 1263: status = HTHost_read(HTNet_host(cnet), cnet);
1.60 frystyk 1264: if (status == HT_WOULD_BLOCK)
1265: return HT_WOULD_BLOCK;
1266: else if (status == HT_LOADED) {
1267: if (ctrl->repcode/100 == 2)
1268: ctrl->substate = NEED_SEGMENT;
1269: else
1270: ctrl->substate = SUB_ERROR;
1271: } else
1272: ctrl->substate = SUB_ERROR;
1273: ctrl->sent = NO;
1.33 frystyk 1274: }
1.60 frystyk 1275: break;
1.33 frystyk 1276:
1.81 frystyk 1277: case NEED_STREAM:
1.95 frystyk 1278: if (PROT_TRACE) HTTrace("FTP Get Data now in state NEED_STREAM\n");
1.81 frystyk 1279: /*
1280: ** Create the stream pipe FROM the channel to the application.
1281: ** The target for the input stream pipe is set up using the
1282: ** stream stack.
1283: */
1.93 frystyk 1284: {
1285: HTStream * target = FTP_DIR(data) ?
1286: HTFTPDir_new(request, ctrl->server, data->type) :
1287: HTStreamStack(HTAnchor_format(HTRequest_anchor(request)),
1288: HTRequest_outputFormat(request),
1289: HTRequest_outputStream(request),
1290: request, YES);
1291: HTNet_setReadStream(dnet, target);
1.81 frystyk 1292: }
1.86 frystyk 1293: HTRequest_setOutputConnected(request, YES);
1.93 frystyk 1294: data_is_active = YES;
1.81 frystyk 1295: ctrl->substate = NEED_BODY;
1.91 frystyk 1296: break;
1.23 frystyk 1297:
1.60 frystyk 1298: case NEED_BODY:
1.95 frystyk 1299: if (PROT_TRACE) HTTrace("FTP Get Data now in state NEED_BODY\n");
1.93 frystyk 1300: if (data_is_active) {
1301: status = HTHost_read(HTNet_host(dnet), dnet);
1302: if (status == HT_WOULD_BLOCK)
1303: return HT_WOULD_BLOCK;
1304: else if (status == HT_LOADED || status == HT_CLOSED) {
1305: data->complete |= 1;
1306: if (data->complete >= 3)
1307: ctrl->substate = SUB_SUCCESS;
1308: else
1309: data_is_active = NO;
1310: } else {
1311: ctrl->substate = SUB_ERROR;
1312: data->stream_error = YES;
1313: }
1314: } else {
1315: status = HTHost_read(HTNet_host(cnet), cnet);
1316: if (status == HT_WOULD_BLOCK)
1317: return HT_WOULD_BLOCK;
1318: else if (status == HT_LOADED || status == HT_CLOSED) {
1319: if (ctrl->repcode/100 == 2) {
1320: data->complete |= 2;
1321: if (data->complete >= 3)
1322: ctrl->substate = SUB_SUCCESS;
1323: else
1324: data_is_active = YES;
1325: } else
1326: ctrl->substate = SUB_ERROR;
1327: } else
1328: ctrl->substate = SUB_ERROR;
1329: }
1330: break;
1.22 frystyk 1331:
1.60 frystyk 1332: case SUB_ERROR:
1.95 frystyk 1333: if (PROT_TRACE) HTTrace("FTP Get Data now in state SUB_ERROR\n");
1334: HTRequest_addError(request, ERR_FATAL, NO, HTERR_NOT_FOUND,
1335: NULL, 0, "HTFTPGetData");
1.60 frystyk 1336: ctrl->substate = 0;
1.77 frystyk 1337: HT_FREE(segment);
1.60 frystyk 1338: return HT_ERROR;
1.23 frystyk 1339: break;
1340:
1.60 frystyk 1341: case SUB_SUCCESS:
1.95 frystyk 1342: if (PROT_TRACE) HTTrace("FTP Get Data now in state SUB_SUCCESS\n");
1.60 frystyk 1343: ctrl->substate = 0;
1.77 frystyk 1344: HT_FREE(segment);
1.60 frystyk 1345: return HT_LOADED;
1.23 frystyk 1346: break;
1.1 timbl 1347: }
1348: }
1.23 frystyk 1349: }
1.1 timbl 1350:
1.23 frystyk 1351: /* ------------------------------------------------------------------------- */
1352:
1353: /* Retrieve File from Server as an atomic action.
1354: ** -----------------------------------------------
1.58 frystyk 1355: ** Given a hypertext address, this routine loads a document.
1.23 frystyk 1356: **
1357: ** On entry,
1.58 frystyk 1358: ** request This is the request structure
1359: ** returns HT_ERROR Error has occured in call back
1360: ** HT_OK Call back was OK
1361: */
1.91 frystyk 1362: PRIVATE int FTPEvent (SOCKET soc, void * pVoid, HTEventType type);
1363:
1364: PUBLIC int HTLoadFTP (SOCKET soc, HTRequest * request)
1.58 frystyk 1365: {
1.84 frystyk 1366: HTNet * cnet = HTRequest_net(request);
1367: ftp_ctrl * ctrl = NULL;
1368: ftp_data * data = NULL;
1369: HTParentAnchor * anchor = HTRequest_anchor(request);
1370: char * url = HTAnchor_physical(anchor);
1.23 frystyk 1371:
1.97 frystyk 1372:
1.58 frystyk 1373: /*
1.60 frystyk 1374: ** Initiate a new FTP ctrl and data structure and bind to request structure
1.58 frystyk 1375: ** This is actually state FTP_BEGIN, but it can't be in the state
1376: ** machine as we need the structure first.
1377: */
1.91 frystyk 1378: if (PROT_TRACE) HTTrace("FTP......... Looking for `%s\'\n",url);
1379: if ((ctrl = (ftp_ctrl *) HT_CALLOC(1, sizeof(ftp_ctrl))) == NULL ||
1380: (data = (ftp_data *) HT_CALLOC(1, sizeof(ftp_data))) == NULL)
1381: HT_OUTOFMEM("HTLoadFTP");
1382: ctrl->cmd = HTChunk_new(128);
1383: ctrl->state = FTP_BEGIN;
1384: ctrl->server = FTP_UNSURE;
1385: ctrl->dnet = HTNet_dup(cnet);
1.93 frystyk 1386: ctrl->cnet = cnet;
1.91 frystyk 1387: HTNet_setContext(cnet, ctrl);
1388: HTNet_setEventCallback(cnet, FTPEvent);
1.92 eric 1389: HTNet_setEventParam(cnet, ctrl);
1.98 ! frystyk 1390: HTNet_setRawBytesCount(ctrl->dnet, YES);
1.97 frystyk 1391:
1.92 eric 1392: /* for now, the dnet comes back to the same place
1393: ** - vestigial from when the callback was from the request object
1394: */
1395: HTNet_setContext(ctrl->dnet, data);
1396: HTNet_setEventCallback(ctrl->dnet, FTPEvent);
1397: HTNet_setEventParam(ctrl->dnet, ctrl);
1.91 frystyk 1398: return FTPEvent(soc, ctrl, HTEvent_BEGIN);
1399: }
1400:
1401: PRIVATE int FTPEvent (SOCKET soc, void * pVoid, HTEventType type)
1402: {
1.93 frystyk 1403: ftp_ctrl * ctrl = (ftp_ctrl *) pVoid;
1404: ftp_data * data = (ftp_data *) HTNet_context(ctrl->dnet);
1.91 frystyk 1405: int status = HT_ERROR;
1.93 frystyk 1406: HTNet * cnet = ctrl->cnet;
1.91 frystyk 1407: HTRequest * request = HTNet_request(cnet);
1408: HTParentAnchor * anchor = HTRequest_anchor(request);
1409: char * url = HTAnchor_physical(anchor);
1410:
1.97 frystyk 1411: HTHost *host = HTNet_host(cnet);
1412:
1413:
1.91 frystyk 1414: if (type == HTEvent_CLOSE) { /* Interrupted */
1.98 ! frystyk 1415: if (soc == HTNet_socket(cnet))
! 1416: FTPCleanup(request, HT_INTERRUPTED);
1.60 frystyk 1417: else
1.98 ! frystyk 1418: FTPCleanup(request, HT_LOADED);
! 1419: return HT_OK;
! 1420: } else if (type == HTEvent_TIMEOUT) {
! 1421: HTRequest_addError(request, ERR_FATAL, NO, HTERR_TIME_OUT,
! 1422: NULL, 0, "HTLoadHTTP");
! 1423: FTPCleanup(request, HT_TIMEOUT);
1.60 frystyk 1424: return HT_OK;
1.98 ! frystyk 1425:
1.60 frystyk 1426: } else {
1.93 frystyk 1427: ctrl = (ftp_ctrl *) HTNet_context(cnet); /* Get existing copy */
1428: data = (ftp_data *) HTNet_context(ctrl->dnet);
1.60 frystyk 1429: }
1.58 frystyk 1430:
1431: /* Now jump into the machine. We know the state from the previous run */
1432: while (1) {
1433: switch (ctrl->state) {
1.60 frystyk 1434: case FTP_BEGIN:
1.95 frystyk 1435: if (PROT_TRACE) HTTrace("FTP Event... now in state FTP_BEGIN\n");
1436: HTFTPParseURL(request, url, ctrl, data);
1437:
1.97 frystyk 1438:
1.95 frystyk 1439: /* The following is added by Neil Griffin, GAIN Software */
1440:
1441: /*
1442: ** If the user hasn't specified a permanent transfer type, then
1443: ** use the transfer type specified at the end of the URL.
1444: */
1445: if (g_FTPTransferMode == FTP_DEFAULT_TRANSFER_MODE) {
1446: switch (data->type) {
1447: case 'a' : data->type = 'A'; break;
1448: case 'A' : data->type = 'A'; break;
1449: case 'i' : data->type = 'I'; break;
1450: case 'I' : data->type = 'I'; break;
1451: case 'd' : FTPListType(data, ctrl->server); break;
1452: case 'D' : FTPListType(data, ctrl->server); break;
1453: default : data->type = 'I'; break;
1454: }
1455:
1456: /* Otherwise, use the permanent transfer type specified by the user. */
1457: } else {
1458: switch (g_FTPTransferMode) {
1459: case FTP_ASCII_TRANSFER_MODE : data->type = 'A'; break;
1460: case FTP_BINARY_TRANSFER_MODE : data->type = 'I'; break;
1461: case FTP_DIR_TRANSFER_MODE : FTPListType(data, ctrl->server); break;
1462: default : data->type = 'I'; break;
1463: }
1464: }
1465:
1466: if (PROT_TRACE)
1467: HTTrace("FTP Event... Transfer mode set to '%c'\n", data->type);
1468:
1469: /*
1470: ** See if we can get any hints to what we might expect content wise.
1471: */
1472: if (!FTP_DIR(data)) HTBind_getAnchorBindings(anchor);
1.98 ! frystyk 1473:
! 1474: /* Ready for next state */
! 1475: ctrl->state = FTP_NEED_CCON;
! 1476: break;
1.60 frystyk 1477:
1.95 frystyk 1478: case FTP_NEED_CCON:
1479: if (PROT_TRACE) HTTrace("FTP Event... now in state FTP_NEED_CONN\n");
1.97 frystyk 1480: status = HTHost_connect(host, cnet, url, FTP_PORT);
1481: host = HTNet_host(cnet);
1.60 frystyk 1482: if (status == HT_OK) {
1.81 frystyk 1483:
1484: /*
1485: ** Check the protocol class to see if we have connected to a
1486: ** the right class of server, in this case HTTP.
1487: */
1488: {
1489: char * s_class = HTHost_class(host);
1490: if (s_class && strcasecomp(s_class, "ftp")) {
1491: HTRequest_addError(request, ERR_FATAL, NO, HTERR_CLASS,
1492: NULL, 0, "HTLoadNews");
1493: ctrl->state = FTP_ERROR;
1494: break;
1495: }
1496: HTHost_setClass(host, "ftp");
1497: }
1498:
1499: /* Check persistent connection */
1500: if (HTNet_persistent(cnet)) {
1501: ctrl->server = HTHost_version(host);
1502: if (PROT_TRACE)
1503: HTTrace("FTP Server.. Cache says type %d server\n",
1504: ctrl->server);
1505: ctrl->reset = 1;
1506: } else
1.88 frystyk 1507: HTNet_setPersistent(cnet, YES, HT_TP_SINGLE);
1.23 frystyk 1508:
1.81 frystyk 1509: /*
1510: ** Create the stream pipe FROM the channel to the application.
1511: ** The target for the input stream pipe is set up using the
1512: ** stream stack.
1513: */
1.93 frystyk 1514: {
1515: HTStream * readstream = FTPStatus_new(request, ctrl, host);
1516: HTNet_setReadStream(cnet, readstream);
1517: }
1.23 frystyk 1518:
1.60 frystyk 1519: /*
1.81 frystyk 1520: ** Create the stream pipe TO the channel from the application
1521: ** and hook it up to the request object
1522: */
1523: {
1524: HTOutputStream * output = HTNet_getOutput(cnet, NULL, 0);
1525: HTRequest_setInputStream(request, (HTStream *) output);
1526: }
1527:
1528: /*
1.60 frystyk 1529: ** Set up concurrent read/write if this request isn't the
1530: ** source for a PUT or POST. As source we don't start reading
1531: ** before all destinations are ready. If destination then
1532: ** register the input stream and get ready for read
1533: */
1534: if (HTRequest_isPostWeb(request)) {
1.93 frystyk 1535: HTEvent * event = HTNet_event(cnet);
1536: HTEvent_register(HTNet_socket(cnet), HTEvent_READ, event);
1.60 frystyk 1537: HTRequest_linkDestination(request);
1538: }
1539:
1540: ctrl->state = FTP_NEED_LOGIN;
1.88 frystyk 1541: } else if (status == HT_WOULD_BLOCK || status == HT_PENDING)
1.60 frystyk 1542: return HT_OK;
1543: else
1544: ctrl->state = FTP_ERROR; /* Error or interrupt */
1545: break;
1546:
1547: case FTP_NEED_LOGIN:
1.95 frystyk 1548: if (PROT_TRACE) HTTrace("FTP Event... now in state FTP_NEED_LOGIN\n");
1.60 frystyk 1549: status = HTFTPLogin(request, cnet, ctrl);
1550: if (status == HT_WOULD_BLOCK) return HT_OK;
1551: ctrl->state = (status == HT_OK) ? FTP_NEED_DCON : FTP_ERROR;
1552: break;
1553:
1554: case FTP_NEED_DCON:
1.95 frystyk 1555: if (PROT_TRACE) HTTrace("FTP Event... now in state FTP_NEED_DCON\n");
1.60 frystyk 1556: status = HTFTPDataConnection(request, cnet, ctrl, data);
1557: if (status == HT_WOULD_BLOCK) return HT_OK;
1558: if (status == HT_OK)
1559: ctrl->state = (data->type=='N') ?
1560: FTP_NEED_SERVER : FTP_NEED_DATA;
1561: else
1562: ctrl->state = FTP_ERROR;
1563: break;
1564:
1565: case FTP_NEED_DATA:
1.95 frystyk 1566: if (PROT_TRACE) HTTrace("FTP Event... now in state FTP_NEED_DATA\n");
1.63 frystyk 1567: status = HTFTPGetData(request, cnet, soc, ctrl, data);
1.60 frystyk 1568: if (status == HT_WOULD_BLOCK) return HT_OK;
1569: if (status == HT_LOADED)
1570: ctrl->state = FTP_SUCCESS;
1571: else if (status == HT_OK)
1572: ctrl->state = FTP_NEED_DCON;
1.76 frystyk 1573: else if (!FTP_DIR(data) && !data->stream_error) {
1.60 frystyk 1574: FTPListType(data, ctrl->server);
1575: ctrl->state = FTP_NEED_SERVER; /* Try a dir instead? */
1576: } else
1577: ctrl->state = FTP_ERROR;
1578: break;
1.23 frystyk 1579:
1.60 frystyk 1580: case FTP_NEED_SERVER:
1.95 frystyk 1581: if (PROT_TRACE) HTTrace("FTP Event... now in state FTP_NEED_SERVER\n");
1.60 frystyk 1582: status = HTFTPServerInfo(request, cnet, ctrl, data);
1.95 frystyk 1583: if (status == HT_WOULD_BLOCK) return HT_OK;
1.60 frystyk 1584: ctrl->state = FTP_NEED_DATA;
1585: break;
1586:
1587: case FTP_SUCCESS:
1.95 frystyk 1588: if (PROT_TRACE) HTTrace("FTP Event... now in state FTP_SUCCESS\n");
1589: FTPCleanup(request, HT_LOADED);
1.60 frystyk 1590: return HT_OK;
1591: break;
1592:
1593: case FTP_ERROR:
1.95 frystyk 1594: if (PROT_TRACE) HTTrace("FTP Event... now in state FTP_ERROR\n");
1595: FTPCleanup(request, HT_ERROR);
1.60 frystyk 1596: return HT_OK;
1597: break;
1.23 frystyk 1598: }
1.60 frystyk 1599: } /* End of while(1) */
1.23 frystyk 1600: }
1.22 frystyk 1601:
1.95 frystyk 1602: PUBLIC void HTFTP_setTransferMode(FTPTransferMode mode)
1603: {
1604: g_FTPTransferMode = mode;
1605: }
1606:
1607: PUBLIC FTPTransferMode HTFTP_transferMode (void)
1608: {
1609: return g_FTPTransferMode;
1.97 frystyk 1610: }
1611:
1612: PUBLIC void HTFTP_setControlMode (FTPControlMode mode)
1613: {
1614: g_FTPControlMode = mode;
1615: }
1616:
1617: PUBLIC FTPControlMode HTFTP_controlMode (void)
1618: {
1619: return g_FTPControlMode;
1.95 frystyk 1620: }
Webmaster
![[BACK]](/cvsweb/icons/back.gif){kind=icon}
Return to HTFTP.c CVS log ![[TXT]](/cvsweb/icons/text.gif){kind=icon}
![[DIR]](/cvsweb/icons/dir.gif){kind=icon}
Up to [Public] / libwww / Library / src