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