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