/* File Transfer Protocol (FTP) Client ** for a WorldWideWeb browser ** =================================== ** ** A cache of control connections is kept (NOT ANYMORE -- IT WAS BROKEN) ** ** Note: Port allocation ** ** It is essential that the port is allocated by the system, rather ** than chosen in rotation by us (POLL_PORTS), or the following ** problem occurs. ** ** It seems that an attempt by the server to connect to a port which has ** been used recently by a listen on the same socket, or by another ** socket this or another process causes a hangup of (almost exactly) ** one minute. Therefore, we have to use a rotating port number. ** The problem remains that if the application is run twice in quick ** succession, it will hang for what remains of a minute. ** ** Authors ** TBL Tim Berners-lee ** DD Denis DeLaRoca 310 825-4580 ** History: ** 2 May 91 Written TBL, as a part of the WorldWideWeb project. ** 15 Jan 92 Bug fix: close() was used for NETCLOSE for control soc ** 10 Feb 92 Retry if cached connection times out or breaks ** 8 Dec 92 Bug fix 921208 TBL after DD ** 17 Dec 92 Anon FTP password now just WWWuser@ suggested by DD ** fails on princeton.edu! ** */ #include "HTFTP.h" /* Implemented here */ #define LINE_LENGTH 1024 #include "HTParse.h" #include "HTUtils.h" #include "tcp.h" #include "HTTCP.h" #include "HTAnchor.h" #include "HTFile.h" #include "HTChunk.h" #include "HTSort.h" #include "HText.h" #ifndef IPPORT_FTP #define IPPORT_FTP 21 #endif #ifdef __STDC__ #include #endif /* #define TRACE 1 */ #ifndef NIL #define NIL 0 #endif /* Hypertext object building machinery */ #include "HTML.h" #define PUTC(c) (*targetClass.put_character)(target, c) #define PUTS(s) (*targetClass.put_string)(target, s) #define START(e) (*targetClass.start_element)(target, e, 0, 0) #define END(e) (*targetClass.end_element)(target, e) #define END_TARGET (*targetClass.end_document)(target) #define FREE_TARGET (*targetClass.free)(target) struct _HTStructured { CONST HTStructuredClass * isa; /* ... */ }; struct _HTStream { CONST HTStreamClass* isa; /* ... */ }; /* Module-Wide Variables ** --------------------- */ PRIVATE char response_text[LINE_LENGTH+1];/* Last response from NewsHost */ PRIVATE int control = -1; /* Current connection */ PRIVATE int data_soc = -1; /* Socket for data transfer =invalid */ PRIVATE int master_socket = -1; /* Listening socket = invalid */ PRIVATE char port_command[255]; /* Command for setting the port */ #define DATA_BUFFER_SIZE 2048 PRIVATE char data_buffer[DATA_BUFFER_SIZE]; /* Input data buffer */ PRIVATE char * data_read_pointer; PRIVATE char * data_write_pointer; #ifndef NotBSN PRIVATE char VMS_server[10]; #endif /* BSN, VMS FTP servers */ /* Procedure: Read a character from the data connection ** ---------------------------------------------------- */ PRIVATE int interrupted_in_next_data_char = 0; PRIVATE char next_data_char NOARGS { int status; interrupted_in_next_data_char = 0; if (data_read_pointer >= data_write_pointer) { status = NETREAD(data_soc, data_buffer, DATA_BUFFER_SIZE); if (status == HT_INTERRUPTED) interrupted_in_next_data_char = 1; if (status <= 0) return (char)-1; data_write_pointer = data_buffer + status; data_read_pointer = data_buffer; } return *data_read_pointer++; } /* Execute Command and get Response ** -------------------------------- ** ** See the state machine illustrated in RFC959, p57. This implements ** one command/reply sequence. It also interprets lines which are to ** be continued, which are marked with a "-" immediately after the ** status code. ** ** Continuation then goes on until a line with a matching reply code ** an a space after it. ** ** On entry, ** con points to the connection which is established. ** cmd points to a command, or is NIL to just get the response. ** ** The command is terminated with the CRLF pair. ** ** On exit, ** returns: The first digit of the reply type, ** or negative for communication failure. */ #ifdef __STDC__ PRIVATE int response (char * cmd) #else PRIVATE int response (cmd) char * cmd; #endif { int result; /* Three-digit decimal code */ int continuation_response = -1; int status; if (!control || control == -1) { if(TRACE) fprintf(stderr, "FTP: No control connection set up!!\n"); return -99; } if (cmd) { if (TRACE) fprintf(stderr, " Tx: %s", cmd); status = NETWRITE(control, cmd, (int)strlen(cmd)); if (status<0) { if (TRACE) fprintf(stderr, "FTP: Error %d sending command: closing socket %d\n", status, control); NETCLOSE(control); control = -1; return status; } } do { char *p = response_text; for(;;) { int foo; /* This is set to 0 at the start of HTGetCharacter. */ extern int interrupted_in_htgetcharacter; foo = (*p++ = HTGetCharacter ()); if (interrupted_in_htgetcharacter) { if (TRACE) fprintf (stderr, "FTP: Interrupted in HTGetCharacter, apparently.\n"); NETCLOSE (control); control = -1; return HT_INTERRUPTED; } if (foo == LF || p == &response_text[LINE_LENGTH]) { char continuation; int rv; *p++=0; /* Terminate the string */ if (TRACE) fprintf(stderr, " Rx: %s", response_text); /* Clear out result ahead of time to see if we couldn't read a real value. */ result = -1; rv = sscanf(response_text, "%d%c", &result, &continuation); /* Try just continuing if we couldn't pull out a value for result and the response_text starts with whitespace. */ if (rv < 2 && result == -1 && (*response_text == ' ' || *response_text == '\t')) { /* Dunno what to do here -- the code isn't really set up to deal with continuation lines starting with whitespace. Testcase is reports.adm.cs.cmu.edu. */ } else if (continuation_response == -1) { if (continuation == '-') /* start continuation */ continuation_response = result; } else { /* continuing */ if (continuation_response == result && continuation == ' ') continuation_response = -1; /* ended */ } break; } /* if end of line */ if (*(p-1) == EOF) { if (TRACE) fprintf(stderr, "Error on rx: closing socket %d\n", control); strcpy (response_text, "000 *** TCP read error on response\n"); NETCLOSE(control); control = -1; return -1; /* End of file on response */ } } /* Loop over characters */ } while (continuation_response != -1); if (result == 421) { if(TRACE) fprintf(stderr, "FTP: They close so we close socket %d\n", control); NETCLOSE(control); return -1; } return result/100; } /* Get a valid connection to the host ** ---------------------------------- ** ** On entry, ** arg points to the name of the host in a hypertext address ** On exit, ** returns <0 if error ** socket number if success ** ** This routine takes care of managing timed-out connections, and ** limiting the number of connections in use at any one time. ** ** It ensures that all connections are logged in if they exist. ** It ensures they have the port number transferred. */ PRIVATE int get_connection ARGS1 (char *,arg) { int status, con; char *username = 0; char *password = 0; if (!arg) return -1; /* Bad if no name sepcified */ if (!*arg) return -1; /* Bad if name had zero length */ if (TRACE) fprintf(stderr, "FTP: Looking for %s\n", arg); { char *p1 = HTParse(arg, "", PARSE_HOST); char *p2 = strrchr(p1, '@'); /* user? */ char * pw; if (p2) { username = p1; *p2=0; /* terminate */ p1 = p2+1; /* point to host */ pw = strchr(username, ':'); if (pw) { *pw++ = 0; password = pw; } } if (!username) free(p1); } con = -1; status = HTDoConnect (arg, "FTP", IPPORT_FTP, &con); if (status < 0) { if (TRACE) { if (status == HT_INTERRUPTED) fprintf (stderr, "FTP: Interrupted on connect\n"); else fprintf(stderr, "FTP: Unable to connect to remote host for `%s'.\n", arg); } if (status == HT_INTERRUPTED) HTProgress ("Connection interrupted."); if (con != -1) { NETCLOSE(con); con = -1; } if (username) free(username); return status; /* Bad return */ } if (TRACE) fprintf(stderr, "FTP connected, assigning control socket %d\n", con); control = con; /* Current control connection */ /* Initialise buffering for contron connection */ HTInitInput (con); /* Now we log in; Look up username, prompt for pw. */ { int status = response (NIL); /* Get greeting */ if (status == HT_INTERRUPTED) { if (TRACE) fprintf (stderr, "FTP: Interrupted at beginning of login.\n"); HTProgress ("Connection interrupted."); NETCLOSE(control); control = -1; return HT_INTERRUPTED; } if (status == 2) { /* Send username */ char * command; #ifndef Not_BSN if (strstr (response_text, "UCX")) strcpy (VMS_server, "UCX"); if (strstr (response_text, "MultiNet")) strcpy (VMS_server, "MultiNet"); #endif /* VMS server, BSN */ if (username) { command = (char*)malloc(10+strlen(username)+2+1); sprintf(command, "USER %s%c%c", username, CR, LF); } else { command = (char*)malloc(25); sprintf(command, "USER anonymous%c%c", CR, LF); } status = response (command); free(command); if (status == HT_INTERRUPTED) { if (TRACE) fprintf (stderr, "FTP: Interrupted while sending username.\n"); HTProgress ("Connection interrupted."); NETCLOSE(control); control = -1; return HT_INTERRUPTED; } } if (status == 3) { /* Send password */ char * command; if (password) { command = (char*)malloc(10+strlen(password)+2+1); sprintf(command, "PASS %s%c%c", password, CR, LF); } else { char * user = getenv("USER"); extern char *machine_with_domain; char *host = machine_with_domain; if (!user) user = "WWWuser"; /* If not fully qualified, suppress it as ftp.uu.net prefers a blank to a bad name */ if (!strchr(host, '.')) host = ""; command = (char*)malloc(20+strlen(host)+2+1); sprintf(command, "PASS %s@%s%c%c", user ? user : "WWWuser", host, CR, LF); /*@@*/ } status = response (command); free(command); if (status == HT_INTERRUPTED) { if (TRACE) fprintf (stderr, "FTP: Interrupted while sending password.\n"); HTProgress ("Connection interrupted."); NETCLOSE(control); control = -1; return HT_INTERRUPTED; } } if (username) free(username); if (status == 3) { char temp[80]; sprintf (temp, "ACCT noaccount%c%c", CR, LF); status = response (temp); if (status == HT_INTERRUPTED) { if (TRACE) fprintf (stderr, "FTP: Interrupted while sending ACCT.\n"); HTProgress ("Connection interrupted."); NETCLOSE(control); control = -1; return HT_INTERRUPTED; } } if (status != 2) { if (TRACE) fprintf(stderr, "FTP: Login fail: %s", response_text); NETCLOSE(control); control = -1; return -1; /* Bad return */ } if (TRACE) fprintf(stderr, "FTP: Logged in.\n"); } return con; /* Good return */ } /* Scope of con */ /* Close Master (listening) socket ** ------------------------------- ** ** */ #ifdef __STDC__ PRIVATE void close_master_socket(void) #else PRIVATE void close_master_socket() #endif { if (TRACE) fprintf(stderr, "FTP: Closing master socket %d\n", master_socket); NETCLOSE(master_socket); master_socket = -1; return; } /* Open a master socket for listening on ** ------------------------------------- ** ** When data is transferred, we open a port, and wait for the server to ** connect with the data. ** ** On entry, ** master_socket Must be negative if not set up already. ** On exit, ** Returns socket number if good ** less than zero if error. ** master_socket is socket number if good, else negative. ** port_number is valid if good. */ #ifdef __STDC__ PRIVATE int get_listen_socket(void) #else PRIVATE int get_listen_socket() #endif { struct sockaddr_in soc_address; /* Binary network address */ struct sockaddr_in *sin = &soc_address; int new_socket; /* Will be master_socket */ /* Create internet socket */ new_socket = socket (AF_INET, SOCK_STREAM, IPPROTO_TCP); if (new_socket < 0) return -1; if (TRACE) fprintf(stderr, "FTP: Opened master socket number %d\n", new_socket); /* Search for a free port. */ sin->sin_family = AF_INET; /* Family = internet, host order */ sin->sin_addr.s_addr = INADDR_ANY; /* Any peer address */ { int status; int address_length = sizeof(soc_address); status = getsockname(control, (struct sockaddr *)&soc_address, &address_length); if (status<0) return -1; CTRACE(tfp, "FTP: This host is %s\n", HTInetString(sin)); soc_address.sin_port = 0; /* Unspecified: please allocate */ status=bind(new_socket, (struct sockaddr*)&soc_address, /* Cast to generic sockaddr */ sizeof(soc_address)); if (status<0) return -1; address_length = sizeof(soc_address); status = getsockname(new_socket, (struct sockaddr*)&soc_address, &address_length); if (status<0) return -1; } CTRACE(tfp, "FTP: bound to port %d on %s\n", (int)ntohs(sin->sin_port), HTInetString(sin)); if (master_socket >= 0) close_master_socket (); master_socket = new_socket; /* Now we must find out who we are to tell the other guy */ (void)HTHostName(); /* Make address valid - doesn't work*/ sprintf(port_command, "PORT %d,%d,%d,%d,%d,%d%c%c", (int)*((unsigned char *)(&sin->sin_addr)+0), (int)*((unsigned char *)(&sin->sin_addr)+1), (int)*((unsigned char *)(&sin->sin_addr)+2), (int)*((unsigned char *)(&sin->sin_addr)+3), (int)*((unsigned char *)(&sin->sin_port)+0), (int)*((unsigned char *)(&sin->sin_port)+1), CR, LF); /* Inform TCP that we will accept connections */ if (listen (master_socket, 1) < 0) { close_master_socket (); return -1; } CTRACE(tfp, "FTP: Master socket(), bind() and listen() all OK\n"); return master_socket; /* Good */ } /* get_listen_socket */ /* Read a directory into an hypertext object from the data socket ** -------------------------------------------------------------- ** ** On entry, ** anchor Parent anchor to link the this node to ** address Address of the directory ** On exit, ** returns HT_LOADED if OK ** <0 if error. ** ** Author: Charles Henrich (henrich@crh.cl.msu.edu) October 2, 1993 ** ** Completely re-wrote this chunk of code to present FTP directory information ** in a much more useful manner. Also included the use of icons. -Crh */ PRIVATE int read_directory ARGS4 ( HTParentAnchor *, parent, CONST char *, address, HTFormat, format_out, HTStream *, sink ) { HText *HT = HText_new (); HTFormat format; HTAtom *pencoding; char *filename = HTParse(address, "", PARSE_PATH + PARSE_PUNCTUATION); char buffer[BUFSIZ]; char itemtype; char itemname[BUFSIZ]; char itemsize[BUFSIZ]; char *full_ftp_name, *ptr; int count, ret, cmpr, c, rv; extern char *HTgeticonname(HTFormat, char *); HText_beginAppend (HT); HText_appendText (HT, "

FTP Directory "); HText_appendText (HT, filename); HText_appendText (HT, "

\n"); HText_appendText (HT, "
\n"); data_read_pointer = data_write_pointer = data_buffer; /* If this isnt the root level, spit out a parent directory entry */ if(strcmp(filename,"/") != 0) { HText_appendText(HT,"
"); HText_appendText(HT," Parent Directory"); } /* Loop until we hit EOF */ while(1) { /* Read in a line of data */ for(count = 0; count < BUFSIZ; count++) { c = next_data_char (); if (interrupted_in_next_data_char) { if (TRACE) fprintf (stderr, "FTP: Picked up interrupted_in_next_data_char\n"); return HT_INTERRUPTED; } if (c == '\r') { c = next_data_char (); if (interrupted_in_next_data_char) { if (TRACE) fprintf (stderr, "FTP: Picked up interrupted_in_next_data_char\n"); return HT_INTERRUPTED; } if (c != '\n') break; } if (c == '\n' || c == (char)EOF) break; buffer[count] = c; } if(c == (char)EOF) break; buffer[count] = 0; /* Parse the input buffer, extract the item type, and the item size */ #if 0 ret=sscanf(buffer,"%c%*9s%*d %*s %*s %s", &itemtype, itemsize); if (ret != 2) continue; #endif /* Retain whole string -- we don't use it at the moment, but we will. */ full_ftp_name = strdup (buffer); /* Read but disregard itemsize -- this effectively guarantees we will know what we should display and what we shouldn't -- don't ask. */ #ifdef Not_BSN ret=sscanf(buffer,"%c%*9s%*d %*s %*s %s", &itemtype, itemsize); #else if (VMS_server[0] == 0) { ret=sscanf(buffer,"%c%*9s%*d %*s %*s %s", &itemtype, itemsize); if (ret != 2) { free (full_ftp_name); continue; } } else { if ((strchr (buffer, ' ') != 0) || ((ptr=strchr (buffer, '.')) == 0)) { free (full_ftp_name); continue; } /* * MultiNet servers return file_name.file_type while UCX servers return * a file_version too. */ strncpy (itemname, buffer, sizeof(itemname)); ptr = strchr (itemname, ';'); if (ptr != 0) *ptr = '\0'; if ((strstr (itemname, ".DIR") != 0) || (strstr (itemname, ".dir") != 0)) { itemtype = 'd'; ptr = strchr (itemname, '.'); *ptr = '\0'; } else itemtype = '-'; } #endif /* VMS server, BSN */ /* Due to the various time stamp formats, its "safer" to retrieve the */ /* filename by taking it from the right side of the string, we do that here. */ #ifdef Not_BSN ptr = strrchr(buffer,' '); #else if (VMS_server[0] == 0) ptr = strrchr(buffer,' '); else ptr = itemname; #endif /* VMS server, BSN */ if(ptr == NULL) continue; #ifdef Not_BSN strcpy(itemname,ptr+1); #else if (VMS_server[0] == 0) strcpy(itemname,ptr+1); #endif /* VMS server, BSN */ HText_appendText (HT, "
"); /* Spit out the anchor refrence, and continue on... */ HText_appendText (HT, " "); /* There are 3 "types", directory, link and file. If its a directory we */ /* just spit out the name with a directory icon. If its a link, we go */ /* retrieve the proper name (i.e. the input looks like bob -> ../../../bob */ /* so we want to hop past the -> and just grab bob. The link case falls */ /* through to the filetype case. The filetype shows name and filesize, and */ /* then attempts to select the correct icon based on file extension. */ switch(itemtype) { case 'd': { sprintf(buffer,"%s",itemname); HText_appendText(HT, " "); break; } case 'l': { ptr = strrchr(buffer,' '); if(ptr != NULL) { *ptr = '\0'; ptr = strrchr(buffer,' '); } if(ptr != NULL) { *ptr = '\0'; ptr = strrchr(buffer,' '); } if(ptr != NULL) strcpy(itemname,ptr+1); } case '-': { /* If this is a link type, and the bytes are small, its probably a directory so lets not show the byte count */ #if 0 if(itemtype == 'l' && atoi(itemsize) < 128) { sprintf(buffer,"%s",itemname); } else { sprintf(buffer,"%s (%s bytes)",itemname,itemsize); } #endif #if 0 if(itemtype == 'l') { #endif sprintf(buffer,"%s",itemname); #if 0 } else { /* code doesn't work for this, and neither does pre. */ sprintf(buffer,"%s",full_ftp_name); } #endif format = HTFileFormat(itemname, &pencoding, WWW_SOURCE, &cmpr); if (1) { HText_appendText(HT, " "); } else { HText_appendText(HT, " "); } break; } default: { HText_appendText(HT, " "); break; } } HText_appendText (HT, buffer); HText_appendText (HT, "\n"); free (full_ftp_name); } HText_appendText (HT, "
\n"); HText_endAppend (HT); rv = response (NIL); if (rv == HT_INTERRUPTED) return rv; return rv == 2 ? HT_LOADED : -1; } /* Retrieve File from Server ** ------------------------- ** ** On entry, ** name WWW address of a file: document, including hostname ** On exit, ** returns Socket number for file if good. ** <0 if bad. */ PUBLIC int HTFTPLoad ARGS4 ( char *, name, HTParentAnchor *, anchor, HTFormat, format_out, HTStream *, sink ) { BOOL isDirectory = NO; int status; int retry; /* How many times tried? */ HTFormat format; int compressed = 0; #ifndef Not_BSN VMS_server[0] = '\0'; #endif /* VMS server, BSN */ for (retry = 0; retry < 2; retry++) { if (TRACE) fprintf (stderr, "FTP: TRYING in HTFTPLoad, attempt %d\n", retry); status = get_connection(name); if (status < 0) { NETCLOSE (control); control = -1; /* HT_INTERRUPTED will fall through. */ return status; } status = get_listen_socket(); if (status < 0) { NETCLOSE (control); control = -1; close_master_socket (); /* HT_INTERRUPTED would fall through, if we could interrupt somehow in the middle of it, which we currently can't. */ return status; } /* Inform the server of the port number we will listen on */ { status = response (port_command); if (status == HT_INTERRUPTED) { if (TRACE) fprintf (stderr, "FTP: Interrupted in response (port_command)\n"); HTProgress ("Connection interrupted."); NETCLOSE (control); control = -1; close_master_socket (); return HT_INTERRUPTED; } if (status !=2) { /* Could have timed out */ if (status < 0) { NETCLOSE (control); control = -1; close_master_socket (); continue; /* try again - net error*/ } NETCLOSE (control); control = -1; close_master_socket (); return HT_NOT_LOADED; /* bad reply */ } if (TRACE) fprintf(stderr, "FTP: Port defined.\n"); } status = 0; break; /* No more retries */ } /* for retries */ if (status < 0) { close_master_socket (); NETCLOSE (control); control = -1; return status; /* Failed with this code */ } /* Ask for the file: */ { char *filename = HTParse(name, "", PARSE_PATH + PARSE_PUNCTUATION); char command[LINE_LENGTH+1]; HTAtom *encoding; if (!(*filename)) StrAllocCopy(filename, "/"); format = HTFileFormat (filename, &encoding, WWW_PLAINTEXT, &compressed); #ifndef Not_BSN if (VMS_server[0] != 0) { if (strcmp (filename, "/") == 0) { free (filename); StrAllocCopy(filename, "[]"); } else { /* * Now we are in trouble. Convert the UNIX name to a VMS name. I guess * we can safely assume that we always start in the server's topdirectory. * Therefore a construct like /dir1/dir2.../dirn/name.type has to be * converted to [.dir1.dir2..dirn]name.type */ char *file_temp = (char *)malloc (strlen(filename) + 4); int i1 = 0, i2 = 1, i3 = 2; file_temp[0] = '['; file_temp[1] = '.'; if (filename[0] == '/') i1 = 1; for (; i1 < strlen (filename); i1++,i3++) { if (filename[i1] != '/') { file_temp[i3] = filename[i1]; continue; } file_temp[i3] = ']'; if (i2 > 1) file_temp[i2] = '.'; i2 = i3; } if (i2 == 1) file_temp[1] = ']'; file_temp[i3] = '\0'; free (filename); StrAllocCopy(filename, file_temp); free (file_temp); } } #endif /* VMS server, BSN */ sprintf(command, "TYPE %s%c%c", "I", CR, LF); status = response (command); if (status != 2) { if (status == HT_INTERRUPTED) HTProgress ("Connection interrupted."); close_master_socket (); NETCLOSE (control); control = -1; free (filename); return (status == HT_INTERRUPTED) ? HT_INTERRUPTED : -1; } sprintf(command, "RETR %s%c%c", filename, CR, LF); status = response (command); if (status == HT_INTERRUPTED) { if (TRACE) fprintf (stderr, "FTP: Interrupted while sending RETR\n"); HTProgress ("Connection interrupted."); NETCLOSE (control); control = -1; close_master_socket (); free (filename); return HT_INTERRUPTED; } if (status != 1) { /* Failed : try to CWD to it */ #ifndef Not_BSN if (VMS_server[0] != 0) { if (filename[strlen(filename)-1] != ']') { char *cp = strchr (filename, ']'); *cp = '.'; strcat (filename, "]"); } } #endif /* VMS server, BSN */ sprintf(command, "CWD %s%c%c", filename, CR, LF); status = response (command); if (status == HT_INTERRUPTED) { if (TRACE) fprintf (stderr, "FTP: Interrupted while sending CWD\n"); HTProgress ("Connection interrupted."); NETCLOSE (control); control = -1; close_master_socket (); free (filename); return HT_INTERRUPTED; } if (status == 2) { /* Successed : let's NAME LIST it */ isDirectory = YES; #ifdef Not_BSN sprintf(command, "LIST%c%c", CR, LF); #else /* * Make an NLST for VMS servers. It's much faster and avoids bugs in * early UCX servers. */ if (!VMS_server[0]) sprintf(command, "LIST%c%c", CR, LF); else sprintf(command, "NLST%c%c", CR, LF); #endif /* VMS server, BSN */ status = response (command); if (status == HT_INTERRUPTED) { if (TRACE) fprintf (stderr, "FTP: Interrupted while sending LIST\n"); HTProgress ("Connection interrupted."); NETCLOSE (control); control = -1; close_master_socket (); free (filename); return HT_INTERRUPTED; } } } free(filename); if (status != 1) { NETCLOSE (control); control = -1; close_master_socket (); return HT_NOT_LOADED; /* Action not started */ } } /* Wait for the connection */ { struct sockaddr_in soc_address; int soc_addrlen = sizeof(soc_address); status = accept(master_socket, (struct sockaddr *)&soc_address, &soc_addrlen); if (status < 0) { NETCLOSE (control); control = -1; close_master_socket (); /* We can't interrupt out of an accept. */ return HT_NOT_LOADED; } CTRACE(tfp, "FTP: Accepted new socket %d\n", status); data_soc = status; } if (isDirectory) { int s = read_directory (anchor, name, format_out, sink); NETCLOSE (control); control = -1; close_master_socket (); NETCLOSE (data_soc); data_soc = -1; if (TRACE) fprintf (stderr, "FTP: Returning %d after doing read_directory\n", s); /* HT_INTERRUPTED should fall right through. */ return s; } else { /* We reproduce ParseSocket below because of socket/child process problem. */ HTStream * stream; HTStreamClass targetClass; int rv; stream = HTStreamStack(format, format_out, compressed, sink, anchor); if (!stream) { char buffer[1024]; /* @@@@@@@@ */ sprintf(buffer, "Sorry, can't convert from %s to %s.", HTAtom_name(format), HTAtom_name(format_out)); HTProgress (buffer); if (TRACE) fprintf(stderr, "FTP: %s\n", buffer); return HT_NOT_LOADED; } targetClass = *(stream->isa); /* Copy pointers to procedures */ rv = HTCopy(data_soc, stream, 0); if (rv == -1) { rv = HT_INTERRUPTED; } else { (*targetClass.end_document)(stream); /* Do NOT call *targetClass.free yet -- sockets aren't closed. */ rv = HT_LOADED; } if (TRACE) fprintf (stderr, "FTP: Got back %d from our local equivalent of ParseSocket\n", rv); /* Reset buffering to control connection -- probably no longer necessary, since we don't use a connection more than once. */ HTInitInput(control); if (TRACE) fprintf (stderr, "FTP: Closing data socket %d\n", data_soc); NETCLOSE (data_soc); data_soc = -1; /* Unfortunately, picking up the final reply sometimes causes serious problems. It *probably* isn't safe not to do this, as there is the possibility that FTP servers could die if they try to send it and we're not listening. Testcase for problems (10/30/93): uxc.cso.uiuc.edu, AnswerGarden COPYRIGHT in X11R5 contrib clients. Of course, we may already be triggering hostile actions by allowing client-side interrupts as follows... */ if (rv != HT_INTERRUPTED) { if (TRACE) fprintf (stderr, "FTP: Picking up final reply...\n"); status = response (NIL); /* Pick up final reply */ if (status == HT_INTERRUPTED) { if (TRACE) fprintf (stderr, "FTP: Interrupted picking up final reply.\n"); HTProgress ("Connection interrupted."); NETCLOSE (control); control = -1; close_master_socket (); (*targetClass.handle_interrupt)(stream); return HT_INTERRUPTED; } if (status != 2) { NETCLOSE (control); control = -1; close_master_socket (); return HT_NOT_LOADED; } } if (TRACE) fprintf (stderr, "FTP: Closing control socket %d\n", control); NETCLOSE(control); control = -1; close_master_socket (); if (rv != HT_INTERRUPTED) { /* WAIT until all sockets have been closed. */ if (TRACE) fprintf (stderr, "FTP: Calling free method, finally.\n"); (*targetClass.free)(stream); } return rv == HT_INTERRUPTED ? HT_INTERRUPTED : HT_LOADED; } } /* open_file_read */