ftpd.c revision 1.52 1 1.52 mrg /* $NetBSD: ftpd.c,v 1.52 1998/07/06 06:47:58 mrg Exp $ */
2 1.13 cgd
3 1.1 cgd /*
4 1.8 deraadt * Copyright (c) 1985, 1988, 1990, 1992, 1993, 1994
5 1.8 deraadt * The Regents of the University of California. All rights reserved.
6 1.1 cgd *
7 1.1 cgd * Redistribution and use in source and binary forms, with or without
8 1.1 cgd * modification, are permitted provided that the following conditions
9 1.1 cgd * are met:
10 1.1 cgd * 1. Redistributions of source code must retain the above copyright
11 1.1 cgd * notice, this list of conditions and the following disclaimer.
12 1.1 cgd * 2. Redistributions in binary form must reproduce the above copyright
13 1.1 cgd * notice, this list of conditions and the following disclaimer in the
14 1.1 cgd * documentation and/or other materials provided with the distribution.
15 1.1 cgd * 3. All advertising materials mentioning features or use of this software
16 1.1 cgd * must display the following acknowledgement:
17 1.1 cgd * This product includes software developed by the University of
18 1.1 cgd * California, Berkeley and its contributors.
19 1.1 cgd * 4. Neither the name of the University nor the names of its contributors
20 1.1 cgd * may be used to endorse or promote products derived from this software
21 1.1 cgd * without specific prior written permission.
22 1.1 cgd *
23 1.1 cgd * THIS SOFTWARE IS PROVIDED BY THE REGENTS AND CONTRIBUTORS ``AS IS'' AND
24 1.1 cgd * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
25 1.1 cgd * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
26 1.1 cgd * ARE DISCLAIMED. IN NO EVENT SHALL THE REGENTS OR CONTRIBUTORS BE LIABLE
27 1.1 cgd * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
28 1.1 cgd * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS
29 1.1 cgd * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
30 1.1 cgd * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
31 1.1 cgd * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY
32 1.1 cgd * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
33 1.1 cgd * SUCH DAMAGE.
34 1.1 cgd */
35 1.1 cgd
36 1.25 christos #include <sys/cdefs.h>
37 1.1 cgd #ifndef lint
38 1.25 christos __COPYRIGHT(
39 1.8 deraadt "@(#) Copyright (c) 1985, 1988, 1990, 1992, 1993, 1994\n\
40 1.25 christos The Regents of the University of California. All rights reserved.\n");
41 1.1 cgd #endif /* not lint */
42 1.1 cgd
43 1.1 cgd #ifndef lint
44 1.13 cgd #if 0
45 1.17 cjs static char sccsid[] = "@(#)ftpd.c 8.5 (Berkeley) 4/28/95";
46 1.13 cgd #else
47 1.52 mrg __RCSID("$NetBSD: ftpd.c,v 1.52 1998/07/06 06:47:58 mrg Exp $");
48 1.13 cgd #endif
49 1.1 cgd #endif /* not lint */
50 1.1 cgd
51 1.1 cgd /*
52 1.1 cgd * FTP server.
53 1.1 cgd */
54 1.1 cgd #include <sys/param.h>
55 1.1 cgd #include <sys/stat.h>
56 1.1 cgd #include <sys/ioctl.h>
57 1.1 cgd #include <sys/socket.h>
58 1.1 cgd #include <sys/wait.h>
59 1.1 cgd
60 1.1 cgd #include <netinet/in.h>
61 1.1 cgd #include <netinet/in_systm.h>
62 1.1 cgd #include <netinet/ip.h>
63 1.1 cgd
64 1.1 cgd #define FTP_NAMES
65 1.1 cgd #include <arpa/ftp.h>
66 1.1 cgd #include <arpa/inet.h>
67 1.1 cgd #include <arpa/telnet.h>
68 1.1 cgd
69 1.8 deraadt #include <ctype.h>
70 1.1 cgd #include <dirent.h>
71 1.8 deraadt #include <err.h>
72 1.8 deraadt #include <errno.h>
73 1.1 cgd #include <fcntl.h>
74 1.21 cjs #include <fnmatch.h>
75 1.8 deraadt #include <glob.h>
76 1.8 deraadt #include <limits.h>
77 1.8 deraadt #include <netdb.h>
78 1.1 cgd #include <pwd.h>
79 1.1 cgd #include <setjmp.h>
80 1.8 deraadt #include <signal.h>
81 1.1 cgd #include <stdio.h>
82 1.1 cgd #include <stdlib.h>
83 1.1 cgd #include <string.h>
84 1.8 deraadt #include <syslog.h>
85 1.8 deraadt #include <time.h>
86 1.8 deraadt #include <unistd.h>
87 1.25 christos #ifdef SKEY
88 1.25 christos #include <skey.h>
89 1.25 christos #endif
90 1.38 mycroft #ifdef KERBEROS5
91 1.38 mycroft #include <krb5.h>
92 1.38 mycroft #endif
93 1.8 deraadt
94 1.24 lukem #include "extern.h"
95 1.1 cgd #include "pathnames.h"
96 1.1 cgd
97 1.8 deraadt #if __STDC__
98 1.8 deraadt #include <stdarg.h>
99 1.8 deraadt #else
100 1.8 deraadt #include <varargs.h>
101 1.8 deraadt #endif
102 1.8 deraadt
103 1.40 mrg static char version[] = "Version 7.02";
104 1.8 deraadt
105 1.8 deraadt extern off_t restart_point;
106 1.1 cgd extern char cbuf[];
107 1.25 christos extern int yyparse __P((void));
108 1.1 cgd
109 1.1 cgd struct sockaddr_in ctrl_addr;
110 1.1 cgd struct sockaddr_in data_source;
111 1.1 cgd struct sockaddr_in data_dest;
112 1.1 cgd struct sockaddr_in his_addr;
113 1.1 cgd struct sockaddr_in pasv_addr;
114 1.1 cgd
115 1.1 cgd int data;
116 1.1 cgd jmp_buf errcatch, urgcatch;
117 1.1 cgd int logged_in;
118 1.1 cgd struct passwd *pw;
119 1.1 cgd int debug;
120 1.51 msaitoh int sflag;
121 1.1 cgd int logging;
122 1.1 cgd int guest;
123 1.5 cgd int dochroot;
124 1.1 cgd int type;
125 1.1 cgd int form;
126 1.1 cgd int stru; /* avoid C keyword */
127 1.1 cgd int mode;
128 1.1 cgd int usedefault = 1; /* for data transfers */
129 1.1 cgd int pdata = -1; /* for passive mode */
130 1.8 deraadt sig_atomic_t transflag;
131 1.1 cgd off_t file_size;
132 1.1 cgd off_t byte_count;
133 1.1 cgd char tmpline[7];
134 1.52 mrg char hostname[MAXHOSTNAMELEN+1];
135 1.52 mrg char remotehost[MAXHOSTNAMELEN+1];
136 1.13 cgd static char ttyline[20];
137 1.13 cgd char *tty = ttyline; /* for klogin */
138 1.22 cjs static char *anondir = NULL;
139 1.34 lukem static char confdir[MAXPATHLEN];
140 1.24 lukem
141 1.24 lukem extern struct ftpclass curclass;
142 1.1 cgd
143 1.38 mycroft #if defined(KERBEROS) || defined(KERBEROS5)
144 1.13 cgd int notickets = 1;
145 1.13 cgd char *krbtkfile_env = NULL;
146 1.4 cgd #endif
147 1.38 mycroft #ifdef KERBEROS5
148 1.38 mycroft extern krb5_context kcontext;
149 1.38 mycroft #endif
150 1.4 cgd
151 1.1 cgd /*
152 1.1 cgd * Timeout intervals for retrying connections
153 1.1 cgd * to hosts that don't accept PORT cmds. This
154 1.1 cgd * is a kludge, but given the problems with TCP...
155 1.1 cgd */
156 1.1 cgd #define SWAITMAX 90 /* wait at most 90 seconds */
157 1.1 cgd #define SWAITINT 5 /* interval between retries */
158 1.1 cgd
159 1.1 cgd int swaitmax = SWAITMAX;
160 1.1 cgd int swaitint = SWAITINT;
161 1.1 cgd
162 1.6 cgd #ifdef HASSETPROCTITLE
163 1.1 cgd char proctitle[BUFSIZ]; /* initial part of title */
164 1.6 cgd #endif /* HASSETPROCTITLE */
165 1.1 cgd
166 1.8 deraadt #define LOGCMD(cmd, file) \
167 1.8 deraadt if (logging > 1) \
168 1.8 deraadt syslog(LOG_INFO,"%s %s%s", cmd, \
169 1.8 deraadt *(file) == '/' ? "" : curdir(), file);
170 1.8 deraadt #define LOGCMD2(cmd, file1, file2) \
171 1.8 deraadt if (logging > 1) \
172 1.8 deraadt syslog(LOG_INFO,"%s %s%s %s%s", cmd, \
173 1.8 deraadt *(file1) == '/' ? "" : curdir(), file1, \
174 1.8 deraadt *(file2) == '/' ? "" : curdir(), file2);
175 1.8 deraadt #define LOGBYTES(cmd, file, cnt) \
176 1.8 deraadt if (logging > 1) { \
177 1.8 deraadt if (cnt == (off_t)-1) \
178 1.8 deraadt syslog(LOG_INFO,"%s %s%s", cmd, \
179 1.8 deraadt *(file) == '/' ? "" : curdir(), file); \
180 1.8 deraadt else \
181 1.8 deraadt syslog(LOG_INFO, "%s %s%s = %qd bytes", \
182 1.27 cjs cmd, (*(file) == '/') ? "" : curdir(), file, \
183 1.27 cjs (long long)cnt); \
184 1.8 deraadt }
185 1.8 deraadt
186 1.8 deraadt static void ack __P((char *));
187 1.8 deraadt static void myoob __P((int));
188 1.8 deraadt static int checkuser __P((char *, char *));
189 1.19 cjs static int checkaccess __P((char *));
190 1.8 deraadt static FILE *dataconn __P((char *, off_t, char *));
191 1.8 deraadt static void dolog __P((struct sockaddr_in *));
192 1.8 deraadt static char *curdir __P((void));
193 1.8 deraadt static void end_login __P((void));
194 1.8 deraadt static FILE *getdatasock __P((char *));
195 1.8 deraadt static char *gunique __P((char *));
196 1.8 deraadt static void lostconn __P((int));
197 1.8 deraadt static int receive_data __P((FILE *, FILE *));
198 1.33 lukem static void replydirname __P((const char *, const char *));
199 1.49 lukem static int send_data __P((FILE *, FILE *, off_t));
200 1.8 deraadt static struct passwd *
201 1.8 deraadt sgetpwnam __P((char *));
202 1.8 deraadt static char *sgetsave __P((char *));
203 1.8 deraadt
204 1.42 lukem int main __P((int, char *[]));
205 1.26 mellon
206 1.38 mycroft #if defined(KERBEROS) || defined(KERBEROS5)
207 1.38 mycroft int klogin __P((struct passwd *, char *, char *, char *));
208 1.38 mycroft void kdestroy __P((void));
209 1.26 mellon #endif
210 1.25 christos
211 1.8 deraadt static char *
212 1.8 deraadt curdir()
213 1.8 deraadt {
214 1.8 deraadt static char path[MAXPATHLEN+1+1]; /* path + '/' + '\0' */
215 1.8 deraadt
216 1.8 deraadt if (getcwd(path, sizeof(path)-2) == NULL)
217 1.8 deraadt return ("");
218 1.8 deraadt if (path[1] != '\0') /* special case for root dir. */
219 1.8 deraadt strcat(path, "/");
220 1.8 deraadt /* For guest account, skip / since it's chrooted */
221 1.8 deraadt return (guest ? path+1 : path);
222 1.8 deraadt }
223 1.8 deraadt
224 1.8 deraadt int
225 1.42 lukem main(argc, argv)
226 1.1 cgd int argc;
227 1.1 cgd char *argv[];
228 1.1 cgd {
229 1.8 deraadt int addrlen, ch, on = 1, tos;
230 1.8 deraadt char *cp, line[LINE_MAX];
231 1.8 deraadt FILE *fd;
232 1.38 mycroft #ifdef KERBEROS5
233 1.38 mycroft krb5_error_code kerror;
234 1.38 mycroft #endif
235 1.1 cgd
236 1.1 cgd debug = 0;
237 1.35 lukem logging = 0;
238 1.51 msaitoh sflag = 0;
239 1.34 lukem (void)strcpy(confdir, _DEFAULT_CONFDIR);
240 1.1 cgd
241 1.51 msaitoh while ((ch = getopt(argc, argv, "a:c:C:dlst:T:u:v")) != -1) {
242 1.8 deraadt switch (ch) {
243 1.22 cjs case 'a':
244 1.22 cjs anondir = optarg;
245 1.22 cjs break;
246 1.22 cjs
247 1.34 lukem case 'c':
248 1.34 lukem (void)strncpy(confdir, optarg, sizeof(confdir));
249 1.34 lukem confdir[sizeof(confdir)-1] = '\0';
250 1.34 lukem break;
251 1.35 lukem
252 1.35 lukem case 'C':
253 1.35 lukem exit(checkaccess(optarg));
254 1.35 lukem /* NOTREACHED */
255 1.34 lukem
256 1.1 cgd case 'd':
257 1.22 cjs case 'v': /* deprecated */
258 1.1 cgd debug = 1;
259 1.1 cgd break;
260 1.1 cgd
261 1.1 cgd case 'l':
262 1.8 deraadt logging++; /* > 1 == extra logging */
263 1.1 cgd break;
264 1.1 cgd
265 1.51 msaitoh case 's':
266 1.51 msaitoh sflag = 1;
267 1.51 msaitoh break;
268 1.51 msaitoh
269 1.1 cgd case 't':
270 1.1 cgd case 'T':
271 1.1 cgd case 'u':
272 1.32 lukem warnx("-%c has been deprecated in favour of ftpd.conf",
273 1.24 lukem ch);
274 1.8 deraadt break;
275 1.1 cgd
276 1.1 cgd default:
277 1.35 lukem if (optopt == 'a' || optopt == 'C')
278 1.35 lukem exit(1);
279 1.8 deraadt warnx("unknown flag -%c ignored", optopt);
280 1.1 cgd break;
281 1.1 cgd }
282 1.1 cgd }
283 1.35 lukem
284 1.35 lukem /*
285 1.35 lukem * LOG_NDELAY sets up the logging connection immediately,
286 1.35 lukem * necessary for anonymous ftp's that chroot and can't do it later.
287 1.35 lukem */
288 1.35 lukem openlog("ftpd", LOG_PID | LOG_NDELAY, LOG_FTP);
289 1.35 lukem addrlen = sizeof(his_addr);
290 1.35 lukem if (getpeername(0, (struct sockaddr *)&his_addr, &addrlen) < 0) {
291 1.35 lukem syslog(LOG_ERR, "getpeername (%s): %m",argv[0]);
292 1.35 lukem exit(1);
293 1.35 lukem }
294 1.35 lukem addrlen = sizeof(ctrl_addr);
295 1.35 lukem if (getsockname(0, (struct sockaddr *)&ctrl_addr, &addrlen) < 0) {
296 1.35 lukem syslog(LOG_ERR, "getsockname (%s): %m",argv[0]);
297 1.35 lukem exit(1);
298 1.35 lukem }
299 1.35 lukem #ifdef IP_TOS
300 1.35 lukem tos = IPTOS_LOWDELAY;
301 1.35 lukem if (setsockopt(0, IPPROTO_IP, IP_TOS, (char *)&tos, sizeof(int)) < 0)
302 1.35 lukem syslog(LOG_WARNING, "setsockopt (IP_TOS): %m");
303 1.35 lukem #endif
304 1.35 lukem data_source.sin_port = htons(ntohs(ctrl_addr.sin_port) - 1);
305 1.35 lukem
306 1.35 lukem /* set this here so klogin can use it... */
307 1.35 lukem (void)snprintf(ttyline, sizeof(ttyline), "ftp%d", getpid());
308 1.35 lukem
309 1.1 cgd (void) freopen(_PATH_DEVNULL, "w", stderr);
310 1.1 cgd (void) signal(SIGPIPE, lostconn);
311 1.1 cgd (void) signal(SIGCHLD, SIG_IGN);
312 1.10 cgd if ((long)signal(SIGURG, myoob) < 0)
313 1.1 cgd syslog(LOG_ERR, "signal: %m");
314 1.1 cgd
315 1.1 cgd /* Try to handle urgent data inline */
316 1.1 cgd #ifdef SO_OOBINLINE
317 1.1 cgd if (setsockopt(0, SOL_SOCKET, SO_OOBINLINE, (char *)&on, sizeof(on)) < 0)
318 1.1 cgd syslog(LOG_ERR, "setsockopt: %m");
319 1.1 cgd #endif
320 1.1 cgd
321 1.1 cgd #ifdef F_SETOWN
322 1.1 cgd if (fcntl(fileno(stdin), F_SETOWN, getpid()) == -1)
323 1.1 cgd syslog(LOG_ERR, "fcntl F_SETOWN: %m");
324 1.1 cgd #endif
325 1.1 cgd dolog(&his_addr);
326 1.1 cgd /*
327 1.1 cgd * Set up default state
328 1.1 cgd */
329 1.1 cgd data = -1;
330 1.1 cgd type = TYPE_A;
331 1.1 cgd form = FORM_N;
332 1.1 cgd stru = STRU_F;
333 1.1 cgd mode = MODE_S;
334 1.1 cgd tmpline[0] = '\0';
335 1.8 deraadt
336 1.38 mycroft #ifdef KERBEROS5
337 1.38 mycroft kerror = krb5_init_context(&kcontext);
338 1.38 mycroft if (kerror) {
339 1.38 mycroft syslog(LOG_NOTICE, "%s when initializing Kerberos context",
340 1.38 mycroft error_message(kerror));
341 1.38 mycroft exit(0);
342 1.38 mycroft }
343 1.45 christos #endif /* KERBEROS5 */
344 1.38 mycroft
345 1.8 deraadt /* If logins are disabled, print out the message. */
346 1.8 deraadt if ((fd = fopen(_PATH_NOLOGIN,"r")) != NULL) {
347 1.8 deraadt while (fgets(line, sizeof(line), fd) != NULL) {
348 1.8 deraadt if ((cp = strchr(line, '\n')) != NULL)
349 1.8 deraadt *cp = '\0';
350 1.8 deraadt lreply(530, "%s", line);
351 1.8 deraadt }
352 1.8 deraadt (void) fflush(stdout);
353 1.8 deraadt (void) fclose(fd);
354 1.8 deraadt reply(530, "System not available.");
355 1.8 deraadt exit(0);
356 1.8 deraadt }
357 1.34 lukem if ((fd = fopen(conffilename(_PATH_FTPWELCOME), "r")) != NULL) {
358 1.8 deraadt while (fgets(line, sizeof(line), fd) != NULL) {
359 1.8 deraadt if ((cp = strchr(line, '\n')) != NULL)
360 1.8 deraadt *cp = '\0';
361 1.8 deraadt lreply(220, "%s", line);
362 1.8 deraadt }
363 1.8 deraadt (void) fflush(stdout);
364 1.8 deraadt (void) fclose(fd);
365 1.8 deraadt /* reply(220,) must follow */
366 1.8 deraadt }
367 1.52 mrg (void)gethostname(hostname, sizeof(hostname));
368 1.52 mrg hostname[sizeof(hostname) - 1] = '\0';
369 1.1 cgd reply(220, "%s FTP server (%s) ready.", hostname, version);
370 1.1 cgd (void) setjmp(errcatch);
371 1.43 lukem curclass.timeout = 300; /* 5 minutes, as per login(1) */
372 1.1 cgd for (;;)
373 1.1 cgd (void) yyparse();
374 1.1 cgd /* NOTREACHED */
375 1.1 cgd }
376 1.1 cgd
377 1.8 deraadt static void
378 1.8 deraadt lostconn(signo)
379 1.8 deraadt int signo;
380 1.1 cgd {
381 1.8 deraadt
382 1.1 cgd if (debug)
383 1.1 cgd syslog(LOG_DEBUG, "lost connection");
384 1.35 lukem dologout(1);
385 1.1 cgd }
386 1.1 cgd
387 1.1 cgd /*
388 1.1 cgd * Helper function for sgetpwnam().
389 1.1 cgd */
390 1.8 deraadt static char *
391 1.1 cgd sgetsave(s)
392 1.1 cgd char *s;
393 1.1 cgd {
394 1.1 cgd char *new = malloc((unsigned) strlen(s) + 1);
395 1.1 cgd
396 1.1 cgd if (new == NULL) {
397 1.1 cgd perror_reply(421, "Local resource failure: malloc");
398 1.1 cgd dologout(1);
399 1.1 cgd /* NOTREACHED */
400 1.1 cgd }
401 1.1 cgd (void) strcpy(new, s);
402 1.1 cgd return (new);
403 1.1 cgd }
404 1.1 cgd
405 1.1 cgd /*
406 1.1 cgd * Save the result of a getpwnam. Used for USER command, since
407 1.1 cgd * the data returned must not be clobbered by any other command
408 1.1 cgd * (e.g., globbing).
409 1.1 cgd */
410 1.8 deraadt static struct passwd *
411 1.1 cgd sgetpwnam(name)
412 1.1 cgd char *name;
413 1.1 cgd {
414 1.1 cgd static struct passwd save;
415 1.8 deraadt struct passwd *p;
416 1.1 cgd
417 1.1 cgd if ((p = getpwnam(name)) == NULL)
418 1.1 cgd return (p);
419 1.1 cgd if (save.pw_name) {
420 1.1 cgd free(save.pw_name);
421 1.1 cgd free(save.pw_passwd);
422 1.1 cgd free(save.pw_gecos);
423 1.1 cgd free(save.pw_dir);
424 1.1 cgd free(save.pw_shell);
425 1.1 cgd }
426 1.1 cgd save = *p;
427 1.1 cgd save.pw_name = sgetsave(p->pw_name);
428 1.1 cgd save.pw_passwd = sgetsave(p->pw_passwd);
429 1.1 cgd save.pw_gecos = sgetsave(p->pw_gecos);
430 1.1 cgd save.pw_dir = sgetsave(p->pw_dir);
431 1.1 cgd save.pw_shell = sgetsave(p->pw_shell);
432 1.1 cgd return (&save);
433 1.1 cgd }
434 1.1 cgd
435 1.8 deraadt static int login_attempts; /* number of failed login attempts */
436 1.8 deraadt static int askpasswd; /* had user command, ask for passwd */
437 1.8 deraadt static char curname[10]; /* current USER name */
438 1.1 cgd
439 1.1 cgd /*
440 1.1 cgd * USER command.
441 1.1 cgd * Sets global passwd pointer pw if named account exists and is acceptable;
442 1.1 cgd * sets askpasswd if a PASS command is expected. If logged in previously,
443 1.1 cgd * need to reset state. If name is "ftp" or "anonymous", the name is not in
444 1.1 cgd * _PATH_FTPUSERS, and ftp account exists, set guest and pw, then just return.
445 1.1 cgd * If account doesn't exist, ask for passwd anyway. Otherwise, check user
446 1.1 cgd * requesting login privileges. Disallow anyone who does not have a standard
447 1.1 cgd * shell as returned by getusershell(). Disallow anyone mentioned in the file
448 1.1 cgd * _PATH_FTPUSERS to allow people such as root and uucp to be avoided.
449 1.1 cgd */
450 1.8 deraadt void
451 1.1 cgd user(name)
452 1.1 cgd char *name;
453 1.1 cgd {
454 1.1 cgd if (logged_in) {
455 1.1 cgd if (guest) {
456 1.1 cgd reply(530, "Can't change user from guest login.");
457 1.1 cgd return;
458 1.5 cgd } else if (dochroot) {
459 1.5 cgd reply(530, "Can't change user from chroot user.");
460 1.5 cgd return;
461 1.1 cgd }
462 1.1 cgd end_login();
463 1.1 cgd }
464 1.1 cgd
465 1.38 mycroft #if defined(KERBEROS) || defined(KERBEROS5)
466 1.38 mycroft kdestroy();
467 1.38 mycroft #endif
468 1.38 mycroft
469 1.1 cgd guest = 0;
470 1.1 cgd if (strcmp(name, "ftp") == 0 || strcmp(name, "anonymous") == 0) {
471 1.19 cjs if (checkaccess("ftp") || checkaccess("anonymous"))
472 1.1 cgd reply(530, "User %s access denied.", name);
473 1.1 cgd else if ((pw = sgetpwnam("ftp")) != NULL) {
474 1.1 cgd guest = 1;
475 1.1 cgd askpasswd = 1;
476 1.8 deraadt reply(331,
477 1.8 deraadt "Guest login ok, type your name as password.");
478 1.1 cgd } else
479 1.1 cgd reply(530, "User %s unknown.", name);
480 1.8 deraadt if (!askpasswd && logging)
481 1.8 deraadt syslog(LOG_NOTICE,
482 1.8 deraadt "ANONYMOUS FTP LOGIN REFUSED FROM %s", remotehost);
483 1.1 cgd return;
484 1.1 cgd }
485 1.34 lukem
486 1.19 cjs pw = sgetpwnam(name);
487 1.8 deraadt if (logging)
488 1.8 deraadt strncpy(curname, name, sizeof(curname)-1);
489 1.36 mycroft
490 1.7 deraadt #ifdef SKEY
491 1.36 mycroft if (skey_haskey(name) == 0) {
492 1.36 mycroft char *myskey;
493 1.7 deraadt
494 1.8 deraadt myskey = skey_keyinfo(name);
495 1.36 mycroft reply(331, "Password [%s] required for %s.",
496 1.8 deraadt myskey ? myskey : "error getting challenge", name);
497 1.7 deraadt } else
498 1.7 deraadt #endif
499 1.7 deraadt reply(331, "Password required for %s.", name);
500 1.7 deraadt
501 1.1 cgd askpasswd = 1;
502 1.1 cgd /*
503 1.1 cgd * Delay before reading passwd after first failed
504 1.1 cgd * attempt to slow down passwd-guessing programs.
505 1.1 cgd */
506 1.1 cgd if (login_attempts)
507 1.1 cgd sleep((unsigned) login_attempts);
508 1.1 cgd }
509 1.1 cgd
510 1.1 cgd /*
511 1.5 cgd * Check if a user is in the file "fname"
512 1.1 cgd */
513 1.8 deraadt static int
514 1.5 cgd checkuser(fname, name)
515 1.5 cgd char *fname;
516 1.1 cgd char *name;
517 1.1 cgd {
518 1.8 deraadt FILE *fd;
519 1.8 deraadt int found = 0;
520 1.8 deraadt char *p, line[BUFSIZ];
521 1.1 cgd
522 1.5 cgd if ((fd = fopen(fname, "r")) != NULL) {
523 1.1 cgd while (fgets(line, sizeof(line), fd) != NULL)
524 1.8 deraadt if ((p = strchr(line, '\n')) != NULL) {
525 1.1 cgd *p = '\0';
526 1.1 cgd if (line[0] == '#')
527 1.1 cgd continue;
528 1.9 jtc if (strcmp(line, name) == 0) {
529 1.8 deraadt found = 1;
530 1.8 deraadt break;
531 1.8 deraadt }
532 1.1 cgd }
533 1.1 cgd (void) fclose(fd);
534 1.1 cgd }
535 1.8 deraadt return (found);
536 1.1 cgd }
537 1.1 cgd
538 1.1 cgd /*
539 1.19 cjs * Determine whether a user has access, based on information in
540 1.21 cjs * _PATH_FTPUSERS. Each line is a shell-style glob followed by
541 1.21 cjs * `allow' or `deny' (with deny being the default if anything but
542 1.21 cjs * `allow', or nothing at all, is specified).
543 1.19 cjs *
544 1.21 cjs * Each glob is matched against the username in turn, and the first
545 1.21 cjs * match found is used. If no match is found, access is allowed.
546 1.21 cjs *
547 1.21 cjs * Any line starting with `#' is considered a comment and ignored.
548 1.19 cjs *
549 1.19 cjs * This is probably not the best way to do this, but it preserves
550 1.19 cjs * the old semantics where if a user was listed in the file he was
551 1.19 cjs * denied, otherwise he was allowed.
552 1.19 cjs *
553 1.19 cjs * There is one change in the semantics, however; ftpd will now `fail
554 1.19 cjs * safe' and deny all access if there's no /etc/ftpusers file.
555 1.19 cjs *
556 1.19 cjs * Return 1 if the user is denied, or 0 if he is allowed.
557 1.19 cjs */
558 1.19 cjs static int
559 1.19 cjs checkaccess(name)
560 1.19 cjs char *name;
561 1.19 cjs {
562 1.19 cjs #define ALLOWED 0
563 1.19 cjs #define NOT_ALLOWED 1
564 1.19 cjs FILE *fd;
565 1.21 cjs int retval = ALLOWED;
566 1.21 cjs char *glob, *perm, line[BUFSIZ];
567 1.19 cjs
568 1.34 lukem if ((fd = fopen(conffilename(_PATH_FTPUSERS), "r")) == NULL)
569 1.19 cjs return NOT_ALLOWED;
570 1.19 cjs
571 1.19 cjs while (fgets(line, sizeof(line), fd) != NULL) {
572 1.21 cjs glob = strtok(line, " \t\n");
573 1.21 cjs if (glob[0] == '#')
574 1.19 cjs continue;
575 1.19 cjs perm = strtok(NULL, " \t\n");
576 1.21 cjs if (fnmatch(glob, name, 0) == 0) {
577 1.19 cjs if (perm != NULL && strcmp(perm, "allow") == 0)
578 1.21 cjs retval = ALLOWED;
579 1.19 cjs else
580 1.21 cjs retval = NOT_ALLOWED;
581 1.21 cjs break;
582 1.19 cjs }
583 1.19 cjs }
584 1.19 cjs (void) fclose(fd);
585 1.21 cjs return (retval);
586 1.19 cjs }
587 1.19 cjs #undef ALLOWED
588 1.19 cjs #undef NOT_ALLOWED
589 1.19 cjs
590 1.19 cjs /*
591 1.1 cgd * Terminate login as previous user, if any, resetting state;
592 1.1 cgd * used when USER command is given or login fails.
593 1.1 cgd */
594 1.8 deraadt static void
595 1.1 cgd end_login()
596 1.1 cgd {
597 1.1 cgd
598 1.1 cgd (void) seteuid((uid_t)0);
599 1.1 cgd if (logged_in)
600 1.1 cgd logwtmp(ttyline, "", "");
601 1.1 cgd pw = NULL;
602 1.1 cgd logged_in = 0;
603 1.1 cgd guest = 0;
604 1.5 cgd dochroot = 0;
605 1.1 cgd }
606 1.1 cgd
607 1.8 deraadt void
608 1.1 cgd pass(passwd)
609 1.1 cgd char *passwd;
610 1.1 cgd {
611 1.4 cgd int rval;
612 1.8 deraadt FILE *fd;
613 1.44 lukem char *cp, *shell, *home;
614 1.1 cgd
615 1.1 cgd if (logged_in || askpasswd == 0) {
616 1.1 cgd reply(503, "Login with USER first.");
617 1.1 cgd return;
618 1.1 cgd }
619 1.1 cgd askpasswd = 0;
620 1.1 cgd if (!guest) { /* "ftp" is only account allowed no password */
621 1.8 deraadt if (pw == NULL) {
622 1.8 deraadt rval = 1; /* failure below */
623 1.8 deraadt goto skip;
624 1.8 deraadt }
625 1.37 mycroft #ifdef KERBEROS
626 1.38 mycroft if (klogin(pw, "", hostname, passwd) == 0) {
627 1.38 mycroft rval = 0;
628 1.38 mycroft goto skip;
629 1.38 mycroft }
630 1.38 mycroft #endif
631 1.38 mycroft #ifdef KERBEROS5
632 1.37 mycroft if (klogin(pw, "", hostname, passwd) == 0) {
633 1.37 mycroft rval = 0;
634 1.37 mycroft goto skip;
635 1.37 mycroft }
636 1.37 mycroft #endif
637 1.36 mycroft #ifdef SKEY
638 1.36 mycroft if (skey_haskey(pw->pw_name) == 0 &&
639 1.36 mycroft skey_passcheck(pw->pw_name, passwd) != -1) {
640 1.36 mycroft rval = 0;
641 1.8 deraadt goto skip;
642 1.36 mycroft }
643 1.4 cgd #endif
644 1.51 msaitoh if (!sflag && *pw->pw_passwd != '\0' &&
645 1.37 mycroft !strcmp(crypt(passwd, pw->pw_passwd), pw->pw_passwd)) {
646 1.8 deraadt rval = 0;
647 1.8 deraadt goto skip;
648 1.8 deraadt }
649 1.37 mycroft rval = 1;
650 1.4 cgd
651 1.8 deraadt skip:
652 1.46 cjs if (pw != NULL && pw->pw_expire && time(NULL) >= pw->pw_expire)
653 1.45 christos rval = 2;
654 1.4 cgd /*
655 1.45 christos * If rval > 0, the user failed the authentication check
656 1.4 cgd * above. If rval == 0, either Kerberos or local authentication
657 1.4 cgd * succeeded.
658 1.4 cgd */
659 1.4 cgd if (rval) {
660 1.45 christos reply(530, rval == 2 ? "Password expired." :
661 1.45 christos "Login incorrect.");
662 1.23 lukem if (logging) {
663 1.8 deraadt syslog(LOG_NOTICE,
664 1.23 lukem "FTP LOGIN FAILED FROM %s", remotehost);
665 1.23 lukem syslog(LOG_AUTHPRIV | LOG_NOTICE,
666 1.8 deraadt "FTP LOGIN FAILED FROM %s, %s",
667 1.8 deraadt remotehost, curname);
668 1.23 lukem }
669 1.1 cgd pw = NULL;
670 1.1 cgd if (login_attempts++ >= 5) {
671 1.1 cgd syslog(LOG_NOTICE,
672 1.1 cgd "repeated login failures from %s",
673 1.1 cgd remotehost);
674 1.1 cgd exit(0);
675 1.1 cgd }
676 1.1 cgd return;
677 1.1 cgd }
678 1.1 cgd }
679 1.19 cjs
680 1.19 cjs /* password was ok; see if anything else prevents login */
681 1.19 cjs if (checkaccess(pw->pw_name)) {
682 1.19 cjs reply(530, "User %s may not use FTP.", pw->pw_name);
683 1.19 cjs if (logging)
684 1.19 cjs syslog(LOG_NOTICE, "FTP LOGIN REFUSED FROM %s, %s",
685 1.19 cjs remotehost, pw->pw_name);
686 1.19 cjs pw = (struct passwd *) NULL;
687 1.19 cjs return;
688 1.19 cjs }
689 1.19 cjs /* check for valid shell, if not guest user */
690 1.19 cjs if ((shell = pw->pw_shell) == NULL || *shell == 0)
691 1.19 cjs shell = _PATH_BSHELL;
692 1.19 cjs while ((cp = getusershell()) != NULL)
693 1.19 cjs if (strcmp(cp, shell) == 0)
694 1.19 cjs break;
695 1.19 cjs endusershell();
696 1.19 cjs if (cp == NULL && guest == 0) {
697 1.19 cjs reply(530, "User %s may not use FTP.", pw->pw_name);
698 1.19 cjs if (logging)
699 1.19 cjs syslog(LOG_NOTICE,
700 1.19 cjs "FTP LOGIN REFUSED FROM %s, %s",
701 1.19 cjs remotehost, pw->pw_name);
702 1.19 cjs pw = (struct passwd *) NULL;
703 1.19 cjs return;
704 1.19 cjs }
705 1.19 cjs
706 1.1 cgd login_attempts = 0; /* this time successful */
707 1.8 deraadt if (setegid((gid_t)pw->pw_gid) < 0) {
708 1.8 deraadt reply(550, "Can't set gid.");
709 1.8 deraadt return;
710 1.8 deraadt }
711 1.1 cgd (void) initgroups(pw->pw_name, pw->pw_gid);
712 1.1 cgd
713 1.1 cgd /* open wtmp before chroot */
714 1.1 cgd logwtmp(ttyline, pw->pw_name, remotehost);
715 1.1 cgd logged_in = 1;
716 1.1 cgd
717 1.34 lukem dochroot = checkuser(conffilename(_PATH_FTPCHROOT), pw->pw_name);
718 1.24 lukem
719 1.24 lukem /* parse ftpd.conf, setting up various parameters */
720 1.24 lukem if (guest)
721 1.24 lukem parse_conf(CLASS_GUEST);
722 1.24 lukem else if (dochroot)
723 1.24 lukem parse_conf(CLASS_CHROOT);
724 1.24 lukem else
725 1.24 lukem parse_conf(CLASS_REAL);
726 1.24 lukem
727 1.44 lukem home = "/";
728 1.1 cgd if (guest) {
729 1.1 cgd /*
730 1.1 cgd * We MUST do a chdir() after the chroot. Otherwise
731 1.1 cgd * the old current directory will be accessible as "."
732 1.1 cgd * outside the new root!
733 1.1 cgd */
734 1.24 lukem if (chroot(anondir ? anondir : pw->pw_dir) < 0 ||
735 1.24 lukem chdir("/") < 0) {
736 1.1 cgd reply(550, "Can't set guest privileges.");
737 1.5 cgd goto bad;
738 1.5 cgd }
739 1.5 cgd } else if (dochroot) {
740 1.5 cgd if (chroot(pw->pw_dir) < 0 || chdir("/") < 0) {
741 1.5 cgd reply(550, "Can't change root.");
742 1.1 cgd goto bad;
743 1.1 cgd }
744 1.1 cgd } else if (chdir(pw->pw_dir) < 0) {
745 1.1 cgd if (chdir("/") < 0) {
746 1.1 cgd reply(530, "User %s: can't change directory to %s.",
747 1.1 cgd pw->pw_name, pw->pw_dir);
748 1.1 cgd goto bad;
749 1.1 cgd } else
750 1.1 cgd lreply(230, "No directory! Logging in with home=/");
751 1.44 lukem } else
752 1.44 lukem home = pw->pw_dir;
753 1.1 cgd if (seteuid((uid_t)pw->pw_uid) < 0) {
754 1.1 cgd reply(550, "Can't set uid.");
755 1.1 cgd goto bad;
756 1.1 cgd }
757 1.44 lukem setenv("HOME", home, 1);
758 1.44 lukem
759 1.44 lukem
760 1.8 deraadt /*
761 1.8 deraadt * Display a login message, if it exists.
762 1.8 deraadt * N.B. reply(230,) must follow the message.
763 1.8 deraadt */
764 1.34 lukem if ((fd = fopen(conffilename(_PATH_FTPLOGINMESG), "r")) != NULL) {
765 1.8 deraadt char *cp, line[LINE_MAX];
766 1.8 deraadt
767 1.8 deraadt while (fgets(line, sizeof(line), fd) != NULL) {
768 1.8 deraadt if ((cp = strchr(line, '\n')) != NULL)
769 1.8 deraadt *cp = '\0';
770 1.8 deraadt lreply(230, "%s", line);
771 1.8 deraadt }
772 1.8 deraadt (void) fflush(stdout);
773 1.8 deraadt (void) fclose(fd);
774 1.8 deraadt }
775 1.24 lukem show_chdir_messages(230);
776 1.1 cgd if (guest) {
777 1.1 cgd reply(230, "Guest login ok, access restrictions apply.");
778 1.6 cgd #ifdef HASSETPROCTITLE
779 1.8 deraadt snprintf(proctitle, sizeof(proctitle),
780 1.8 deraadt "%s: anonymous/%.*s", remotehost,
781 1.25 christos (int) (sizeof(proctitle) - sizeof(remotehost) -
782 1.25 christos sizeof(": anonymous/")), passwd);
783 1.1 cgd setproctitle(proctitle);
784 1.6 cgd #endif /* HASSETPROCTITLE */
785 1.1 cgd if (logging)
786 1.1 cgd syslog(LOG_INFO, "ANONYMOUS FTP LOGIN FROM %s, %s",
787 1.1 cgd remotehost, passwd);
788 1.1 cgd } else {
789 1.1 cgd reply(230, "User %s logged in.", pw->pw_name);
790 1.6 cgd #ifdef HASSETPROCTITLE
791 1.8 deraadt snprintf(proctitle, sizeof(proctitle),
792 1.8 deraadt "%s: %s", remotehost, pw->pw_name);
793 1.1 cgd setproctitle(proctitle);
794 1.6 cgd #endif /* HASSETPROCTITLE */
795 1.1 cgd if (logging)
796 1.8 deraadt syslog(LOG_INFO, "FTP LOGIN FROM %s as %s",
797 1.1 cgd remotehost, pw->pw_name);
798 1.1 cgd }
799 1.24 lukem (void) umask(curclass.umask);
800 1.1 cgd return;
801 1.1 cgd bad:
802 1.1 cgd /* Forget all about it... */
803 1.1 cgd end_login();
804 1.1 cgd }
805 1.1 cgd
806 1.8 deraadt void
807 1.1 cgd retrieve(cmd, name)
808 1.1 cgd char *cmd, *name;
809 1.1 cgd {
810 1.28 christos FILE *fin = NULL, *dout;
811 1.1 cgd struct stat st;
812 1.28 christos int (*closefunc) __P((FILE *)) = NULL;
813 1.49 lukem int log, sendrv, closerv, stderrfd, isconversion;
814 1.1 cgd
815 1.49 lukem sendrv = closerv = stderrfd = -1;
816 1.49 lukem isconversion = 0;
817 1.24 lukem log = (cmd == 0);
818 1.49 lukem if (cmd == NULL) {
819 1.1 cgd fin = fopen(name, "r"), closefunc = fclose;
820 1.24 lukem if (fin == NULL)
821 1.24 lukem cmd = do_conversion(name);
822 1.49 lukem if (cmd != NULL) {
823 1.49 lukem isconversion++;
824 1.49 lukem syslog(LOG_INFO, "get command: '%s'", cmd);
825 1.49 lukem }
826 1.24 lukem }
827 1.49 lukem if (cmd != NULL) {
828 1.1 cgd char line[BUFSIZ];
829 1.49 lukem char temp[MAXPATHLEN];
830 1.1 cgd
831 1.49 lukem (void)snprintf(temp, sizeof(temp), "%s", TMPFILE);
832 1.49 lukem stderrfd = mkstemp(temp);
833 1.49 lukem if (stderrfd != -1)
834 1.49 lukem (void)unlink(temp);
835 1.30 lukem (void)snprintf(line, sizeof(line), cmd, name), name = line;
836 1.49 lukem fin = ftpd_popen(line, "r", stderrfd), closefunc = ftpd_pclose;
837 1.1 cgd st.st_size = -1;
838 1.1 cgd st.st_blksize = BUFSIZ;
839 1.1 cgd }
840 1.1 cgd if (fin == NULL) {
841 1.8 deraadt if (errno != 0) {
842 1.1 cgd perror_reply(550, name);
843 1.24 lukem if (log) {
844 1.8 deraadt LOGCMD("get", name);
845 1.8 deraadt }
846 1.8 deraadt }
847 1.49 lukem if (stderrfd != -1)
848 1.49 lukem (void)close(stderrfd);
849 1.1 cgd return;
850 1.1 cgd }
851 1.8 deraadt byte_count = -1;
852 1.49 lukem if (cmd == NULL
853 1.49 lukem && (fstat(fileno(fin), &st) < 0 || !S_ISREG(st.st_mode))) {
854 1.1 cgd reply(550, "%s: not a plain file.", name);
855 1.1 cgd goto done;
856 1.1 cgd }
857 1.1 cgd if (restart_point) {
858 1.1 cgd if (type == TYPE_A) {
859 1.49 lukem off_t i;
860 1.8 deraadt int c;
861 1.1 cgd
862 1.49 lukem for (i = 0; i < restart_point; i++) {
863 1.1 cgd if ((c=getc(fin)) == EOF) {
864 1.1 cgd perror_reply(550, name);
865 1.1 cgd goto done;
866 1.1 cgd }
867 1.1 cgd if (c == '\n')
868 1.1 cgd i++;
869 1.8 deraadt }
870 1.31 kleink } else if (lseek(fileno(fin), restart_point, SEEK_SET) < 0) {
871 1.1 cgd perror_reply(550, name);
872 1.1 cgd goto done;
873 1.1 cgd }
874 1.1 cgd }
875 1.1 cgd dout = dataconn(name, st.st_size, "w");
876 1.1 cgd if (dout == NULL)
877 1.1 cgd goto done;
878 1.49 lukem sendrv = send_data(fin, dout, st.st_blksize);
879 1.1 cgd (void) fclose(dout);
880 1.1 cgd data = -1;
881 1.1 cgd pdata = -1;
882 1.1 cgd done:
883 1.24 lukem if (log)
884 1.8 deraadt LOGBYTES("get", name, byte_count);
885 1.49 lukem closerv = (*closefunc)(fin);
886 1.49 lukem if (sendrv == 0) {
887 1.49 lukem FILE *err;
888 1.49 lukem struct stat sb;
889 1.49 lukem
890 1.49 lukem if (cmd != NULL && closerv != 0) {
891 1.49 lukem lreply(226,
892 1.49 lukem "Command returned an exit status of %d",
893 1.49 lukem closerv);
894 1.49 lukem if (isconversion)
895 1.49 lukem syslog(LOG_INFO,
896 1.49 lukem "get command: '%s' returned %d",
897 1.49 lukem cmd, closerv);
898 1.49 lukem }
899 1.49 lukem if (cmd != NULL && stderrfd != -1 &&
900 1.49 lukem (fstat(stderrfd, &sb) == 0) && sb.st_size > 0 &&
901 1.49 lukem ((err = fdopen(stderrfd, "r")) != NULL)) {
902 1.49 lukem char *cp, line[LINE_MAX];
903 1.49 lukem
904 1.49 lukem lreply(226, "Command error messages:");
905 1.49 lukem rewind(err);
906 1.49 lukem while (fgets(line, sizeof(line), err) != NULL) {
907 1.49 lukem if ((cp = strchr(line, '\n')) != NULL)
908 1.49 lukem *cp = '\0';
909 1.49 lukem lreply(226, " %s", line);
910 1.49 lukem }
911 1.49 lukem (void) fflush(stdout);
912 1.49 lukem (void) fclose(err);
913 1.49 lukem lreply(226, "End of command error messages.");
914 1.49 lukem /* a reply(226,) must follow */
915 1.49 lukem }
916 1.49 lukem reply(226, "Transfer complete.");
917 1.49 lukem }
918 1.49 lukem if (stderrfd != -1)
919 1.49 lukem (void)close(stderrfd);
920 1.1 cgd }
921 1.1 cgd
922 1.8 deraadt void
923 1.1 cgd store(name, mode, unique)
924 1.1 cgd char *name, *mode;
925 1.1 cgd int unique;
926 1.1 cgd {
927 1.1 cgd FILE *fout, *din;
928 1.1 cgd struct stat st;
929 1.8 deraadt int (*closefunc) __P((FILE *));
930 1.1 cgd
931 1.1 cgd if (unique && stat(name, &st) == 0 &&
932 1.8 deraadt (name = gunique(name)) == NULL) {
933 1.8 deraadt LOGCMD(*mode == 'w' ? "put" : "append", name);
934 1.1 cgd return;
935 1.8 deraadt }
936 1.1 cgd
937 1.1 cgd if (restart_point)
938 1.8 deraadt mode = "r+";
939 1.1 cgd fout = fopen(name, mode);
940 1.1 cgd closefunc = fclose;
941 1.1 cgd if (fout == NULL) {
942 1.1 cgd perror_reply(553, name);
943 1.8 deraadt LOGCMD(*mode == 'w' ? "put" : "append", name);
944 1.1 cgd return;
945 1.1 cgd }
946 1.8 deraadt byte_count = -1;
947 1.1 cgd if (restart_point) {
948 1.1 cgd if (type == TYPE_A) {
949 1.49 lukem off_t i;
950 1.8 deraadt int c;
951 1.1 cgd
952 1.49 lukem for (i = 0; i < restart_point; i++) {
953 1.1 cgd if ((c=getc(fout)) == EOF) {
954 1.1 cgd perror_reply(550, name);
955 1.1 cgd goto done;
956 1.1 cgd }
957 1.1 cgd if (c == '\n')
958 1.1 cgd i++;
959 1.8 deraadt }
960 1.1 cgd /*
961 1.1 cgd * We must do this seek to "current" position
962 1.1 cgd * because we are changing from reading to
963 1.1 cgd * writing.
964 1.1 cgd */
965 1.20 lukem if (fseek(fout, 0L, SEEK_CUR) < 0) {
966 1.1 cgd perror_reply(550, name);
967 1.1 cgd goto done;
968 1.1 cgd }
969 1.31 kleink } else if (lseek(fileno(fout), restart_point, SEEK_SET) < 0) {
970 1.1 cgd perror_reply(550, name);
971 1.1 cgd goto done;
972 1.1 cgd }
973 1.1 cgd }
974 1.1 cgd din = dataconn(name, (off_t)-1, "r");
975 1.1 cgd if (din == NULL)
976 1.1 cgd goto done;
977 1.1 cgd if (receive_data(din, fout) == 0) {
978 1.1 cgd if (unique)
979 1.1 cgd reply(226, "Transfer complete (unique file name:%s).",
980 1.1 cgd name);
981 1.1 cgd else
982 1.1 cgd reply(226, "Transfer complete.");
983 1.1 cgd }
984 1.1 cgd (void) fclose(din);
985 1.1 cgd data = -1;
986 1.1 cgd pdata = -1;
987 1.1 cgd done:
988 1.8 deraadt LOGBYTES(*mode == 'w' ? "put" : "append", name, byte_count);
989 1.1 cgd (*closefunc)(fout);
990 1.1 cgd }
991 1.1 cgd
992 1.8 deraadt static FILE *
993 1.1 cgd getdatasock(mode)
994 1.1 cgd char *mode;
995 1.1 cgd {
996 1.8 deraadt int on = 1, s, t, tries;
997 1.1 cgd
998 1.1 cgd if (data >= 0)
999 1.1 cgd return (fdopen(data, mode));
1000 1.1 cgd (void) seteuid((uid_t)0);
1001 1.1 cgd s = socket(AF_INET, SOCK_STREAM, 0);
1002 1.1 cgd if (s < 0)
1003 1.1 cgd goto bad;
1004 1.1 cgd if (setsockopt(s, SOL_SOCKET, SO_REUSEADDR,
1005 1.8 deraadt (char *) &on, sizeof(on)) < 0)
1006 1.1 cgd goto bad;
1007 1.1 cgd /* anchor socket to avoid multi-homing problems */
1008 1.15 mycroft data_source.sin_len = sizeof(struct sockaddr_in);
1009 1.1 cgd data_source.sin_family = AF_INET;
1010 1.1 cgd data_source.sin_addr = ctrl_addr.sin_addr;
1011 1.1 cgd for (tries = 1; ; tries++) {
1012 1.1 cgd if (bind(s, (struct sockaddr *)&data_source,
1013 1.8 deraadt sizeof(data_source)) >= 0)
1014 1.1 cgd break;
1015 1.1 cgd if (errno != EADDRINUSE || tries > 10)
1016 1.1 cgd goto bad;
1017 1.1 cgd sleep(tries);
1018 1.1 cgd }
1019 1.1 cgd (void) seteuid((uid_t)pw->pw_uid);
1020 1.1 cgd #ifdef IP_TOS
1021 1.1 cgd on = IPTOS_THROUGHPUT;
1022 1.1 cgd if (setsockopt(s, IPPROTO_IP, IP_TOS, (char *)&on, sizeof(int)) < 0)
1023 1.1 cgd syslog(LOG_WARNING, "setsockopt (IP_TOS): %m");
1024 1.1 cgd #endif
1025 1.1 cgd return (fdopen(s, mode));
1026 1.1 cgd bad:
1027 1.8 deraadt /* Return the real value of errno (close may change it) */
1028 1.8 deraadt t = errno;
1029 1.1 cgd (void) seteuid((uid_t)pw->pw_uid);
1030 1.1 cgd (void) close(s);
1031 1.8 deraadt errno = t;
1032 1.1 cgd return (NULL);
1033 1.1 cgd }
1034 1.1 cgd
1035 1.8 deraadt static FILE *
1036 1.1 cgd dataconn(name, size, mode)
1037 1.1 cgd char *name;
1038 1.1 cgd off_t size;
1039 1.1 cgd char *mode;
1040 1.1 cgd {
1041 1.1 cgd char sizebuf[32];
1042 1.1 cgd FILE *file;
1043 1.1 cgd int retry = 0, tos;
1044 1.1 cgd
1045 1.1 cgd file_size = size;
1046 1.1 cgd byte_count = 0;
1047 1.1 cgd if (size != (off_t) -1)
1048 1.30 lukem (void)snprintf(sizebuf, sizeof(sizebuf), " (%qd bytes)",
1049 1.29 mrg (long long)size);
1050 1.1 cgd else
1051 1.29 mrg sizebuf[0] = '\0';
1052 1.1 cgd if (pdata >= 0) {
1053 1.1 cgd struct sockaddr_in from;
1054 1.1 cgd int s, fromlen = sizeof(from);
1055 1.1 cgd
1056 1.42 lukem (void) alarm(curclass.timeout);
1057 1.1 cgd s = accept(pdata, (struct sockaddr *)&from, &fromlen);
1058 1.42 lukem (void) alarm(0);
1059 1.1 cgd if (s < 0) {
1060 1.1 cgd reply(425, "Can't open data connection.");
1061 1.1 cgd (void) close(pdata);
1062 1.1 cgd pdata = -1;
1063 1.8 deraadt return (NULL);
1064 1.1 cgd }
1065 1.1 cgd (void) close(pdata);
1066 1.1 cgd pdata = s;
1067 1.1 cgd #ifdef IP_TOS
1068 1.12 mycroft tos = IPTOS_THROUGHPUT;
1069 1.1 cgd (void) setsockopt(s, IPPROTO_IP, IP_TOS, (char *)&tos,
1070 1.1 cgd sizeof(int));
1071 1.1 cgd #endif
1072 1.8 deraadt reply(150, "Opening %s mode data connection for '%s'%s.",
1073 1.1 cgd type == TYPE_A ? "ASCII" : "BINARY", name, sizebuf);
1074 1.8 deraadt return (fdopen(pdata, mode));
1075 1.1 cgd }
1076 1.1 cgd if (data >= 0) {
1077 1.8 deraadt reply(125, "Using existing data connection for '%s'%s.",
1078 1.1 cgd name, sizebuf);
1079 1.1 cgd usedefault = 1;
1080 1.1 cgd return (fdopen(data, mode));
1081 1.1 cgd }
1082 1.1 cgd if (usedefault)
1083 1.1 cgd data_dest = his_addr;
1084 1.1 cgd usedefault = 1;
1085 1.1 cgd file = getdatasock(mode);
1086 1.1 cgd if (file == NULL) {
1087 1.1 cgd reply(425, "Can't create data socket (%s,%d): %s.",
1088 1.1 cgd inet_ntoa(data_source.sin_addr),
1089 1.1 cgd ntohs(data_source.sin_port), strerror(errno));
1090 1.1 cgd return (NULL);
1091 1.1 cgd }
1092 1.1 cgd data = fileno(file);
1093 1.1 cgd while (connect(data, (struct sockaddr *)&data_dest,
1094 1.8 deraadt sizeof(data_dest)) < 0) {
1095 1.1 cgd if (errno == EADDRINUSE && retry < swaitmax) {
1096 1.1 cgd sleep((unsigned) swaitint);
1097 1.1 cgd retry += swaitint;
1098 1.1 cgd continue;
1099 1.1 cgd }
1100 1.1 cgd perror_reply(425, "Can't build data connection");
1101 1.1 cgd (void) fclose(file);
1102 1.1 cgd data = -1;
1103 1.1 cgd return (NULL);
1104 1.1 cgd }
1105 1.8 deraadt reply(150, "Opening %s mode data connection for '%s'%s.",
1106 1.1 cgd type == TYPE_A ? "ASCII" : "BINARY", name, sizebuf);
1107 1.1 cgd return (file);
1108 1.1 cgd }
1109 1.1 cgd
1110 1.1 cgd /*
1111 1.8 deraadt * Tranfer the contents of "instr" to "outstr" peer using the appropriate
1112 1.8 deraadt * encapsulation of the data subject * to Mode, Structure, and Type.
1113 1.1 cgd *
1114 1.1 cgd * NB: Form isn't handled.
1115 1.1 cgd */
1116 1.49 lukem static int
1117 1.1 cgd send_data(instr, outstr, blksize)
1118 1.1 cgd FILE *instr, *outstr;
1119 1.1 cgd off_t blksize;
1120 1.1 cgd {
1121 1.24 lukem int c, cnt, filefd, netfd;
1122 1.24 lukem char *buf;
1123 1.1 cgd
1124 1.1 cgd transflag++;
1125 1.1 cgd if (setjmp(urgcatch)) {
1126 1.1 cgd transflag = 0;
1127 1.49 lukem return (-1);
1128 1.1 cgd }
1129 1.24 lukem
1130 1.1 cgd switch (type) {
1131 1.1 cgd
1132 1.1 cgd case TYPE_A:
1133 1.1 cgd while ((c = getc(instr)) != EOF) {
1134 1.1 cgd byte_count++;
1135 1.1 cgd if (c == '\n') {
1136 1.1 cgd if (ferror(outstr))
1137 1.1 cgd goto data_err;
1138 1.1 cgd (void) putc('\r', outstr);
1139 1.1 cgd }
1140 1.1 cgd (void) putc(c, outstr);
1141 1.1 cgd }
1142 1.1 cgd fflush(outstr);
1143 1.1 cgd transflag = 0;
1144 1.1 cgd if (ferror(instr))
1145 1.1 cgd goto file_err;
1146 1.1 cgd if (ferror(outstr))
1147 1.1 cgd goto data_err;
1148 1.49 lukem return (0);
1149 1.1 cgd
1150 1.1 cgd case TYPE_I:
1151 1.1 cgd case TYPE_L:
1152 1.1 cgd if ((buf = malloc((u_int)blksize)) == NULL) {
1153 1.1 cgd transflag = 0;
1154 1.1 cgd perror_reply(451, "Local resource failure: malloc");
1155 1.49 lukem return (-1);
1156 1.1 cgd }
1157 1.1 cgd netfd = fileno(outstr);
1158 1.1 cgd filefd = fileno(instr);
1159 1.1 cgd while ((cnt = read(filefd, buf, (u_int)blksize)) > 0 &&
1160 1.1 cgd write(netfd, buf, cnt) == cnt)
1161 1.1 cgd byte_count += cnt;
1162 1.1 cgd transflag = 0;
1163 1.1 cgd (void)free(buf);
1164 1.1 cgd if (cnt != 0) {
1165 1.1 cgd if (cnt < 0)
1166 1.1 cgd goto file_err;
1167 1.1 cgd goto data_err;
1168 1.1 cgd }
1169 1.49 lukem return (0);
1170 1.1 cgd default:
1171 1.1 cgd transflag = 0;
1172 1.1 cgd reply(550, "Unimplemented TYPE %d in send_data", type);
1173 1.49 lukem return (-1);
1174 1.1 cgd }
1175 1.1 cgd
1176 1.1 cgd data_err:
1177 1.1 cgd transflag = 0;
1178 1.1 cgd perror_reply(426, "Data connection");
1179 1.49 lukem return (-1);
1180 1.1 cgd
1181 1.1 cgd file_err:
1182 1.1 cgd transflag = 0;
1183 1.1 cgd perror_reply(551, "Error on input file");
1184 1.49 lukem return (-1);
1185 1.1 cgd }
1186 1.1 cgd
1187 1.1 cgd /*
1188 1.8 deraadt * Transfer data from peer to "outstr" using the appropriate encapulation of
1189 1.8 deraadt * the data subject to Mode, Structure, and Type.
1190 1.1 cgd *
1191 1.1 cgd * N.B.: Form isn't handled.
1192 1.1 cgd */
1193 1.8 deraadt static int
1194 1.1 cgd receive_data(instr, outstr)
1195 1.1 cgd FILE *instr, *outstr;
1196 1.1 cgd {
1197 1.24 lukem int c, cnt, bare_lfs;
1198 1.24 lukem char buf[BUFSIZ];
1199 1.25 christos #ifdef __GNUC__
1200 1.25 christos (void) &bare_lfs;
1201 1.25 christos #endif
1202 1.1 cgd
1203 1.24 lukem bare_lfs = 0;
1204 1.1 cgd transflag++;
1205 1.1 cgd if (setjmp(urgcatch)) {
1206 1.1 cgd transflag = 0;
1207 1.1 cgd return (-1);
1208 1.1 cgd }
1209 1.24 lukem
1210 1.1 cgd switch (type) {
1211 1.1 cgd
1212 1.1 cgd case TYPE_I:
1213 1.1 cgd case TYPE_L:
1214 1.8 deraadt while ((cnt = read(fileno(instr), buf, sizeof(buf))) > 0) {
1215 1.1 cgd if (write(fileno(outstr), buf, cnt) != cnt)
1216 1.1 cgd goto file_err;
1217 1.1 cgd byte_count += cnt;
1218 1.1 cgd }
1219 1.1 cgd if (cnt < 0)
1220 1.1 cgd goto data_err;
1221 1.1 cgd transflag = 0;
1222 1.1 cgd return (0);
1223 1.1 cgd
1224 1.1 cgd case TYPE_E:
1225 1.1 cgd reply(553, "TYPE E not implemented.");
1226 1.1 cgd transflag = 0;
1227 1.1 cgd return (-1);
1228 1.1 cgd
1229 1.1 cgd case TYPE_A:
1230 1.1 cgd while ((c = getc(instr)) != EOF) {
1231 1.1 cgd byte_count++;
1232 1.1 cgd if (c == '\n')
1233 1.1 cgd bare_lfs++;
1234 1.1 cgd while (c == '\r') {
1235 1.1 cgd if (ferror(outstr))
1236 1.1 cgd goto data_err;
1237 1.1 cgd if ((c = getc(instr)) != '\n') {
1238 1.1 cgd (void) putc ('\r', outstr);
1239 1.1 cgd if (c == '\0' || c == EOF)
1240 1.1 cgd goto contin2;
1241 1.1 cgd }
1242 1.1 cgd }
1243 1.1 cgd (void) putc(c, outstr);
1244 1.1 cgd contin2: ;
1245 1.1 cgd }
1246 1.1 cgd fflush(outstr);
1247 1.1 cgd if (ferror(instr))
1248 1.1 cgd goto data_err;
1249 1.1 cgd if (ferror(outstr))
1250 1.1 cgd goto file_err;
1251 1.1 cgd transflag = 0;
1252 1.1 cgd if (bare_lfs) {
1253 1.8 deraadt lreply(226,
1254 1.8 deraadt "WARNING! %d bare linefeeds received in ASCII mode",
1255 1.8 deraadt bare_lfs);
1256 1.8 deraadt (void)printf(" File may not have transferred correctly.\r\n");
1257 1.1 cgd }
1258 1.1 cgd return (0);
1259 1.1 cgd default:
1260 1.1 cgd reply(550, "Unimplemented TYPE %d in receive_data", type);
1261 1.1 cgd transflag = 0;
1262 1.1 cgd return (-1);
1263 1.1 cgd }
1264 1.1 cgd
1265 1.1 cgd data_err:
1266 1.1 cgd transflag = 0;
1267 1.1 cgd perror_reply(426, "Data Connection");
1268 1.1 cgd return (-1);
1269 1.1 cgd
1270 1.1 cgd file_err:
1271 1.1 cgd transflag = 0;
1272 1.1 cgd perror_reply(452, "Error writing file");
1273 1.1 cgd return (-1);
1274 1.1 cgd }
1275 1.1 cgd
1276 1.8 deraadt void
1277 1.1 cgd statfilecmd(filename)
1278 1.1 cgd char *filename;
1279 1.1 cgd {
1280 1.1 cgd FILE *fin;
1281 1.1 cgd int c;
1282 1.8 deraadt char line[LINE_MAX];
1283 1.1 cgd
1284 1.8 deraadt (void)snprintf(line, sizeof(line), "/bin/ls -lgA %s", filename);
1285 1.49 lukem fin = ftpd_popen(line, "r", STDOUT_FILENO);
1286 1.1 cgd lreply(211, "status of %s:", filename);
1287 1.1 cgd while ((c = getc(fin)) != EOF) {
1288 1.1 cgd if (c == '\n') {
1289 1.1 cgd if (ferror(stdout)){
1290 1.1 cgd perror_reply(421, "control connection");
1291 1.1 cgd (void) ftpd_pclose(fin);
1292 1.1 cgd dologout(1);
1293 1.1 cgd /* NOTREACHED */
1294 1.1 cgd }
1295 1.1 cgd if (ferror(fin)) {
1296 1.1 cgd perror_reply(551, filename);
1297 1.1 cgd (void) ftpd_pclose(fin);
1298 1.1 cgd return;
1299 1.1 cgd }
1300 1.1 cgd (void) putc('\r', stdout);
1301 1.1 cgd }
1302 1.1 cgd (void) putc(c, stdout);
1303 1.1 cgd }
1304 1.1 cgd (void) ftpd_pclose(fin);
1305 1.1 cgd reply(211, "End of Status");
1306 1.1 cgd }
1307 1.1 cgd
1308 1.8 deraadt void
1309 1.1 cgd statcmd()
1310 1.1 cgd {
1311 1.1 cgd struct sockaddr_in *sin;
1312 1.1 cgd u_char *a, *p;
1313 1.1 cgd
1314 1.24 lukem lreply(211, "%s FTP server status:", hostname);
1315 1.24 lukem lreply(211, "%s", version);
1316 1.24 lukem if (isdigit(remotehost[0]))
1317 1.24 lukem lreply(211, "Connected to %s", remotehost);
1318 1.24 lukem else
1319 1.24 lukem lreply(211, "Connected to %s (%s)", remotehost,
1320 1.24 lukem inet_ntoa(his_addr.sin_addr));
1321 1.1 cgd if (logged_in) {
1322 1.1 cgd if (guest)
1323 1.24 lukem lreply(211, "Logged in anonymously");
1324 1.1 cgd else
1325 1.24 lukem lreply(211, "Logged in as %s", pw->pw_name);
1326 1.1 cgd } else if (askpasswd)
1327 1.24 lukem lreply(211, "Waiting for password");
1328 1.1 cgd else
1329 1.24 lukem lreply(211, "Waiting for user name");
1330 1.24 lukem printf("211- TYPE: %s", typenames[type]);
1331 1.1 cgd if (type == TYPE_A || type == TYPE_E)
1332 1.1 cgd printf(", FORM: %s", formnames[form]);
1333 1.1 cgd if (type == TYPE_L)
1334 1.1 cgd #if NBBY == 8
1335 1.1 cgd printf(" %d", NBBY);
1336 1.1 cgd #else
1337 1.1 cgd printf(" %d", bytesize); /* need definition! */
1338 1.1 cgd #endif
1339 1.1 cgd printf("; STRUcture: %s; transfer MODE: %s\r\n",
1340 1.1 cgd strunames[stru], modenames[mode]);
1341 1.1 cgd if (data != -1)
1342 1.24 lukem lreply(211, "Data connection open");
1343 1.1 cgd else if (pdata != -1) {
1344 1.24 lukem printf("211- in Passive mode");
1345 1.1 cgd sin = &pasv_addr;
1346 1.1 cgd goto printaddr;
1347 1.1 cgd } else if (usedefault == 0) {
1348 1.24 lukem printf("211- PORT");
1349 1.1 cgd sin = &data_dest;
1350 1.1 cgd printaddr:
1351 1.1 cgd a = (u_char *) &sin->sin_addr;
1352 1.1 cgd p = (u_char *) &sin->sin_port;
1353 1.1 cgd #define UC(b) (((int) b) & 0xff)
1354 1.1 cgd printf(" (%d,%d,%d,%d,%d,%d)\r\n", UC(a[0]),
1355 1.1 cgd UC(a[1]), UC(a[2]), UC(a[3]), UC(p[0]), UC(p[1]));
1356 1.1 cgd #undef UC
1357 1.1 cgd } else
1358 1.24 lukem lreply(211, "No data connection");
1359 1.24 lukem
1360 1.24 lukem if (logged_in) {
1361 1.24 lukem struct ftpconv *cp;
1362 1.24 lukem
1363 1.24 lukem lreply(211, "");
1364 1.24 lukem lreply(211, "Class: %s", curclass.classname);
1365 1.41 lukem lreply(211, "Check PORT commands: %sabled",
1366 1.41 lukem curclass.checkportcmd ? "en" : "dis");
1367 1.24 lukem if (curclass.display)
1368 1.24 lukem lreply(211, "Display file: %s", curclass.display);
1369 1.24 lukem if (curclass.notify)
1370 1.24 lukem lreply(211, "Notify fileglob: %s", curclass.notify);
1371 1.24 lukem lreply(211, "Idle timeout: %d, maximum timeout: %d",
1372 1.24 lukem curclass.timeout, curclass.maxtimeout);
1373 1.41 lukem lreply(211, "DELE, MKD, RMD, UMASK, CHMOD commands: %sabled",
1374 1.24 lukem curclass.modify ? "en" : "dis");
1375 1.24 lukem lreply(211, "Umask: %.04o", curclass.umask);
1376 1.24 lukem for (cp = curclass.conversions; cp != NULL; cp=cp->next) {
1377 1.24 lukem if (cp->suffix == NULL || cp->types == NULL ||
1378 1.24 lukem cp->command == NULL)
1379 1.24 lukem continue;
1380 1.24 lukem lreply(211,
1381 1.24 lukem "Conversion: %s [%s] disable: %s, command: %s",
1382 1.24 lukem cp->suffix, cp->types, cp->disable, cp->command);
1383 1.24 lukem }
1384 1.24 lukem }
1385 1.24 lukem
1386 1.1 cgd reply(211, "End of status");
1387 1.1 cgd }
1388 1.1 cgd
1389 1.8 deraadt void
1390 1.1 cgd fatal(s)
1391 1.1 cgd char *s;
1392 1.1 cgd {
1393 1.8 deraadt
1394 1.1 cgd reply(451, "Error in server: %s\n", s);
1395 1.1 cgd reply(221, "Closing connection due to server error.");
1396 1.1 cgd dologout(0);
1397 1.1 cgd /* NOTREACHED */
1398 1.1 cgd }
1399 1.1 cgd
1400 1.8 deraadt void
1401 1.45 christos #ifdef __STDC__
1402 1.8 deraadt reply(int n, const char *fmt, ...)
1403 1.8 deraadt #else
1404 1.8 deraadt reply(n, fmt, va_alist)
1405 1.1 cgd int n;
1406 1.1 cgd char *fmt;
1407 1.8 deraadt va_dcl
1408 1.8 deraadt #endif
1409 1.1 cgd {
1410 1.8 deraadt va_list ap;
1411 1.45 christos #ifdef __STDC__
1412 1.8 deraadt va_start(ap, fmt);
1413 1.8 deraadt #else
1414 1.8 deraadt va_start(ap);
1415 1.8 deraadt #endif
1416 1.8 deraadt (void)printf("%d ", n);
1417 1.8 deraadt (void)vprintf(fmt, ap);
1418 1.8 deraadt (void)printf("\r\n");
1419 1.1 cgd (void)fflush(stdout);
1420 1.1 cgd if (debug) {
1421 1.1 cgd syslog(LOG_DEBUG, "<--- %d ", n);
1422 1.8 deraadt vsyslog(LOG_DEBUG, fmt, ap);
1423 1.8 deraadt }
1424 1.1 cgd }
1425 1.1 cgd
1426 1.8 deraadt void
1427 1.45 christos #ifdef __STDC__
1428 1.8 deraadt lreply(int n, const char *fmt, ...)
1429 1.8 deraadt #else
1430 1.8 deraadt lreply(n, fmt, va_alist)
1431 1.1 cgd int n;
1432 1.1 cgd char *fmt;
1433 1.8 deraadt va_dcl
1434 1.8 deraadt #endif
1435 1.1 cgd {
1436 1.8 deraadt va_list ap;
1437 1.45 christos #ifdef __STDC__
1438 1.8 deraadt va_start(ap, fmt);
1439 1.8 deraadt #else
1440 1.8 deraadt va_start(ap);
1441 1.8 deraadt #endif
1442 1.8 deraadt (void)printf("%d- ", n);
1443 1.8 deraadt (void)vprintf(fmt, ap);
1444 1.8 deraadt (void)printf("\r\n");
1445 1.1 cgd (void)fflush(stdout);
1446 1.1 cgd if (debug) {
1447 1.1 cgd syslog(LOG_DEBUG, "<--- %d- ", n);
1448 1.8 deraadt vsyslog(LOG_DEBUG, fmt, ap);
1449 1.1 cgd }
1450 1.1 cgd }
1451 1.1 cgd
1452 1.8 deraadt static void
1453 1.1 cgd ack(s)
1454 1.1 cgd char *s;
1455 1.1 cgd {
1456 1.8 deraadt
1457 1.1 cgd reply(250, "%s command successful.", s);
1458 1.1 cgd }
1459 1.1 cgd
1460 1.8 deraadt void
1461 1.1 cgd nack(s)
1462 1.1 cgd char *s;
1463 1.1 cgd {
1464 1.8 deraadt
1465 1.1 cgd reply(502, "%s command not implemented.", s);
1466 1.1 cgd }
1467 1.1 cgd
1468 1.1 cgd /* ARGSUSED */
1469 1.8 deraadt void
1470 1.1 cgd yyerror(s)
1471 1.1 cgd char *s;
1472 1.1 cgd {
1473 1.1 cgd char *cp;
1474 1.1 cgd
1475 1.20 lukem if ((cp = strchr(cbuf,'\n')) != NULL)
1476 1.1 cgd *cp = '\0';
1477 1.1 cgd reply(500, "'%s': command not understood.", cbuf);
1478 1.1 cgd }
1479 1.1 cgd
1480 1.8 deraadt void
1481 1.1 cgd delete(name)
1482 1.1 cgd char *name;
1483 1.1 cgd {
1484 1.1 cgd
1485 1.8 deraadt LOGCMD("delete", name);
1486 1.39 mycroft if (remove(name) < 0)
1487 1.1 cgd perror_reply(550, name);
1488 1.39 mycroft else
1489 1.39 mycroft ack("DELE");
1490 1.1 cgd }
1491 1.1 cgd
1492 1.8 deraadt void
1493 1.1 cgd cwd(path)
1494 1.1 cgd char *path;
1495 1.1 cgd {
1496 1.8 deraadt
1497 1.1 cgd if (chdir(path) < 0)
1498 1.1 cgd perror_reply(550, path);
1499 1.24 lukem else {
1500 1.24 lukem show_chdir_messages(250);
1501 1.1 cgd ack("CWD");
1502 1.24 lukem }
1503 1.1 cgd }
1504 1.1 cgd
1505 1.33 lukem static void
1506 1.33 lukem replydirname(name, message)
1507 1.33 lukem const char *name, *message;
1508 1.33 lukem {
1509 1.33 lukem char npath[MAXPATHLEN + 1];
1510 1.33 lukem int i;
1511 1.33 lukem
1512 1.33 lukem for (i = 0; *name != '\0' && i < sizeof(npath) - 1; i++, name++) {
1513 1.33 lukem npath[i] = *name;
1514 1.33 lukem if (*name == '"')
1515 1.33 lukem npath[++i] = '"';
1516 1.33 lukem }
1517 1.33 lukem npath[i] = '\0';
1518 1.33 lukem reply(257, "\"%s\" %s", npath, message);
1519 1.33 lukem }
1520 1.33 lukem
1521 1.8 deraadt void
1522 1.1 cgd makedir(name)
1523 1.1 cgd char *name;
1524 1.1 cgd {
1525 1.8 deraadt
1526 1.8 deraadt LOGCMD("mkdir", name);
1527 1.1 cgd if (mkdir(name, 0777) < 0)
1528 1.1 cgd perror_reply(550, name);
1529 1.1 cgd else
1530 1.33 lukem replydirname(name, "directory created.");
1531 1.1 cgd }
1532 1.1 cgd
1533 1.8 deraadt void
1534 1.1 cgd removedir(name)
1535 1.1 cgd char *name;
1536 1.1 cgd {
1537 1.8 deraadt
1538 1.8 deraadt LOGCMD("rmdir", name);
1539 1.1 cgd if (rmdir(name) < 0)
1540 1.1 cgd perror_reply(550, name);
1541 1.1 cgd else
1542 1.1 cgd ack("RMD");
1543 1.1 cgd }
1544 1.1 cgd
1545 1.8 deraadt void
1546 1.1 cgd pwd()
1547 1.1 cgd {
1548 1.1 cgd char path[MAXPATHLEN + 1];
1549 1.1 cgd
1550 1.33 lukem if (getcwd(path, sizeof(path) - 1) == NULL)
1551 1.48 mouse reply(550, "Can't get the current directory: %s.",
1552 1.48 mouse strerror(errno));
1553 1.1 cgd else
1554 1.33 lukem replydirname(path, "is the current directory.");
1555 1.1 cgd }
1556 1.1 cgd
1557 1.1 cgd char *
1558 1.1 cgd renamefrom(name)
1559 1.1 cgd char *name;
1560 1.1 cgd {
1561 1.1 cgd struct stat st;
1562 1.1 cgd
1563 1.1 cgd if (stat(name, &st) < 0) {
1564 1.1 cgd perror_reply(550, name);
1565 1.1 cgd return ((char *)0);
1566 1.1 cgd }
1567 1.1 cgd reply(350, "File exists, ready for destination name");
1568 1.1 cgd return (name);
1569 1.1 cgd }
1570 1.1 cgd
1571 1.8 deraadt void
1572 1.1 cgd renamecmd(from, to)
1573 1.1 cgd char *from, *to;
1574 1.1 cgd {
1575 1.8 deraadt
1576 1.8 deraadt LOGCMD2("rename", from, to);
1577 1.1 cgd if (rename(from, to) < 0)
1578 1.1 cgd perror_reply(550, "rename");
1579 1.1 cgd else
1580 1.1 cgd ack("RNTO");
1581 1.1 cgd }
1582 1.1 cgd
1583 1.8 deraadt static void
1584 1.1 cgd dolog(sin)
1585 1.1 cgd struct sockaddr_in *sin;
1586 1.1 cgd {
1587 1.1 cgd struct hostent *hp = gethostbyaddr((char *)&sin->sin_addr,
1588 1.8 deraadt sizeof(struct in_addr), AF_INET);
1589 1.1 cgd
1590 1.1 cgd if (hp)
1591 1.52 mrg (void)strncpy(remotehost, hp->h_name, sizeof(remotehost));
1592 1.1 cgd else
1593 1.52 mrg (void)strncpy(remotehost, inet_ntoa(sin->sin_addr),
1594 1.8 deraadt sizeof(remotehost));
1595 1.52 mrg remotehost[sizeof(remotehost) - 1] = '\0';
1596 1.6 cgd #ifdef HASSETPROCTITLE
1597 1.8 deraadt snprintf(proctitle, sizeof(proctitle), "%s: connected", remotehost);
1598 1.1 cgd setproctitle(proctitle);
1599 1.6 cgd #endif /* HASSETPROCTITLE */
1600 1.1 cgd
1601 1.8 deraadt if (logging)
1602 1.8 deraadt syslog(LOG_INFO, "connection from %s", remotehost);
1603 1.1 cgd }
1604 1.1 cgd
1605 1.1 cgd /*
1606 1.1 cgd * Record logout in wtmp file
1607 1.1 cgd * and exit with supplied status.
1608 1.1 cgd */
1609 1.8 deraadt void
1610 1.1 cgd dologout(status)
1611 1.1 cgd int status;
1612 1.1 cgd {
1613 1.16 mrg /*
1614 1.16 mrg * Prevent reception of SIGURG from resulting in a resumption
1615 1.16 mrg * back to the main program loop.
1616 1.16 mrg */
1617 1.16 mrg transflag = 0;
1618 1.8 deraadt
1619 1.1 cgd if (logged_in) {
1620 1.1 cgd (void) seteuid((uid_t)0);
1621 1.1 cgd logwtmp(ttyline, "", "");
1622 1.36 mycroft #ifdef KERBEROS
1623 1.4 cgd if (!notickets && krbtkfile_env)
1624 1.4 cgd unlink(krbtkfile_env);
1625 1.4 cgd #endif
1626 1.1 cgd }
1627 1.1 cgd /* beware of flushing buffers after a SIGPIPE */
1628 1.1 cgd _exit(status);
1629 1.1 cgd }
1630 1.1 cgd
1631 1.8 deraadt static void
1632 1.8 deraadt myoob(signo)
1633 1.8 deraadt int signo;
1634 1.1 cgd {
1635 1.1 cgd char *cp;
1636 1.1 cgd
1637 1.1 cgd /* only process if transfer occurring */
1638 1.1 cgd if (!transflag)
1639 1.1 cgd return;
1640 1.1 cgd cp = tmpline;
1641 1.1 cgd if (getline(cp, 7, stdin) == NULL) {
1642 1.1 cgd reply(221, "You could at least say goodbye.");
1643 1.1 cgd dologout(0);
1644 1.1 cgd }
1645 1.1 cgd upper(cp);
1646 1.1 cgd if (strcmp(cp, "ABOR\r\n") == 0) {
1647 1.1 cgd tmpline[0] = '\0';
1648 1.1 cgd reply(426, "Transfer aborted. Data connection closed.");
1649 1.1 cgd reply(226, "Abort successful");
1650 1.1 cgd longjmp(urgcatch, 1);
1651 1.1 cgd }
1652 1.1 cgd if (strcmp(cp, "STAT\r\n") == 0) {
1653 1.1 cgd if (file_size != (off_t) -1)
1654 1.8 deraadt reply(213, "Status: %qd of %qd bytes transferred",
1655 1.1 cgd byte_count, file_size);
1656 1.1 cgd else
1657 1.8 deraadt reply(213, "Status: %qd bytes transferred", byte_count);
1658 1.1 cgd }
1659 1.1 cgd }
1660 1.1 cgd
1661 1.1 cgd /*
1662 1.1 cgd * Note: a response of 425 is not mentioned as a possible response to
1663 1.8 deraadt * the PASV command in RFC959. However, it has been blessed as
1664 1.8 deraadt * a legitimate response by Jon Postel in a telephone conversation
1665 1.1 cgd * with Rick Adams on 25 Jan 89.
1666 1.1 cgd */
1667 1.8 deraadt void
1668 1.1 cgd passive()
1669 1.1 cgd {
1670 1.1 cgd int len;
1671 1.8 deraadt char *p, *a;
1672 1.1 cgd
1673 1.1 cgd pdata = socket(AF_INET, SOCK_STREAM, 0);
1674 1.23 lukem if (pdata < 0 || !logged_in) {
1675 1.1 cgd perror_reply(425, "Can't open passive connection");
1676 1.1 cgd return;
1677 1.1 cgd }
1678 1.1 cgd pasv_addr = ctrl_addr;
1679 1.1 cgd pasv_addr.sin_port = 0;
1680 1.1 cgd (void) seteuid((uid_t)0);
1681 1.1 cgd if (bind(pdata, (struct sockaddr *)&pasv_addr, sizeof(pasv_addr)) < 0) {
1682 1.1 cgd (void) seteuid((uid_t)pw->pw_uid);
1683 1.1 cgd goto pasv_error;
1684 1.1 cgd }
1685 1.1 cgd (void) seteuid((uid_t)pw->pw_uid);
1686 1.1 cgd len = sizeof(pasv_addr);
1687 1.1 cgd if (getsockname(pdata, (struct sockaddr *) &pasv_addr, &len) < 0)
1688 1.1 cgd goto pasv_error;
1689 1.1 cgd if (listen(pdata, 1) < 0)
1690 1.1 cgd goto pasv_error;
1691 1.1 cgd a = (char *) &pasv_addr.sin_addr;
1692 1.1 cgd p = (char *) &pasv_addr.sin_port;
1693 1.1 cgd
1694 1.1 cgd #define UC(b) (((int) b) & 0xff)
1695 1.1 cgd
1696 1.1 cgd reply(227, "Entering Passive Mode (%d,%d,%d,%d,%d,%d)", UC(a[0]),
1697 1.1 cgd UC(a[1]), UC(a[2]), UC(a[3]), UC(p[0]), UC(p[1]));
1698 1.1 cgd return;
1699 1.1 cgd
1700 1.1 cgd pasv_error:
1701 1.1 cgd (void) close(pdata);
1702 1.1 cgd pdata = -1;
1703 1.1 cgd perror_reply(425, "Can't open passive connection");
1704 1.1 cgd return;
1705 1.1 cgd }
1706 1.1 cgd
1707 1.1 cgd /*
1708 1.1 cgd * Generate unique name for file with basename "local".
1709 1.1 cgd * The file named "local" is already known to exist.
1710 1.1 cgd * Generates failure reply on error.
1711 1.29 mrg *
1712 1.29 mrg * XXX this function should under go changes similar to
1713 1.29 mrg * the mktemp(3)/mkstemp(3) changes.
1714 1.1 cgd */
1715 1.8 deraadt static char *
1716 1.1 cgd gunique(local)
1717 1.1 cgd char *local;
1718 1.1 cgd {
1719 1.1 cgd static char new[MAXPATHLEN];
1720 1.1 cgd struct stat st;
1721 1.29 mrg int count, len;
1722 1.8 deraadt char *cp;
1723 1.1 cgd
1724 1.8 deraadt cp = strrchr(local, '/');
1725 1.1 cgd if (cp)
1726 1.1 cgd *cp = '\0';
1727 1.1 cgd if (stat(cp ? local : ".", &st) < 0) {
1728 1.1 cgd perror_reply(553, cp ? local : ".");
1729 1.8 deraadt return ((char *) 0);
1730 1.1 cgd }
1731 1.1 cgd if (cp)
1732 1.1 cgd *cp = '/';
1733 1.1 cgd (void) strcpy(new, local);
1734 1.29 mrg len = strlen(new);
1735 1.29 mrg cp = new + len;
1736 1.1 cgd *cp++ = '.';
1737 1.1 cgd for (count = 1; count < 100; count++) {
1738 1.29 mrg (void)snprintf(cp, sizeof(new) - len - 2, "%d", count);
1739 1.1 cgd if (stat(new, &st) < 0)
1740 1.8 deraadt return (new);
1741 1.1 cgd }
1742 1.1 cgd reply(452, "Unique file name cannot be created.");
1743 1.8 deraadt return (NULL);
1744 1.1 cgd }
1745 1.1 cgd
1746 1.1 cgd /*
1747 1.1 cgd * Format and send reply containing system error number.
1748 1.1 cgd */
1749 1.8 deraadt void
1750 1.1 cgd perror_reply(code, string)
1751 1.1 cgd int code;
1752 1.1 cgd char *string;
1753 1.1 cgd {
1754 1.8 deraadt
1755 1.1 cgd reply(code, "%s: %s.", string, strerror(errno));
1756 1.1 cgd }
1757 1.1 cgd
1758 1.1 cgd static char *onefile[] = {
1759 1.1 cgd "",
1760 1.1 cgd 0
1761 1.1 cgd };
1762 1.1 cgd
1763 1.8 deraadt void
1764 1.8 deraadt send_file_list(whichf)
1765 1.8 deraadt char *whichf;
1766 1.1 cgd {
1767 1.1 cgd struct stat st;
1768 1.1 cgd DIR *dirp = NULL;
1769 1.1 cgd struct dirent *dir;
1770 1.1 cgd FILE *dout = NULL;
1771 1.8 deraadt char **dirlist, *dirname;
1772 1.1 cgd int simple = 0;
1773 1.8 deraadt int freeglob = 0;
1774 1.8 deraadt glob_t gl;
1775 1.25 christos #ifdef __GNUC__
1776 1.25 christos (void) &dout;
1777 1.25 christos (void) &dirlist;
1778 1.25 christos (void) &simple;
1779 1.25 christos (void) &freeglob;
1780 1.25 christos #endif
1781 1.1 cgd
1782 1.8 deraadt if (strpbrk(whichf, "~{[*?") != NULL) {
1783 1.50 kleink int flags = GLOB_BRACE|GLOB_NOCHECK|GLOB_TILDE;
1784 1.1 cgd
1785 1.8 deraadt memset(&gl, 0, sizeof(gl));
1786 1.8 deraadt freeglob = 1;
1787 1.8 deraadt if (glob(whichf, flags, 0, &gl)) {
1788 1.8 deraadt reply(550, "not found");
1789 1.8 deraadt goto out;
1790 1.8 deraadt } else if (gl.gl_pathc == 0) {
1791 1.1 cgd errno = ENOENT;
1792 1.8 deraadt perror_reply(550, whichf);
1793 1.8 deraadt goto out;
1794 1.1 cgd }
1795 1.8 deraadt dirlist = gl.gl_pathv;
1796 1.1 cgd } else {
1797 1.8 deraadt onefile[0] = whichf;
1798 1.1 cgd dirlist = onefile;
1799 1.1 cgd simple = 1;
1800 1.1 cgd }
1801 1.1 cgd
1802 1.1 cgd if (setjmp(urgcatch)) {
1803 1.1 cgd transflag = 0;
1804 1.8 deraadt goto out;
1805 1.1 cgd }
1806 1.20 lukem while ((dirname = *dirlist++) != NULL) {
1807 1.33 lukem int trailingslash = 0;
1808 1.33 lukem
1809 1.1 cgd if (stat(dirname, &st) < 0) {
1810 1.1 cgd /*
1811 1.1 cgd * If user typed "ls -l", etc, and the client
1812 1.1 cgd * used NLST, do what the user meant.
1813 1.1 cgd */
1814 1.1 cgd if (dirname[0] == '-' && *dirlist == NULL &&
1815 1.1 cgd transflag == 0) {
1816 1.1 cgd retrieve("/bin/ls %s", dirname);
1817 1.8 deraadt goto out;
1818 1.1 cgd }
1819 1.8 deraadt perror_reply(550, whichf);
1820 1.1 cgd if (dout != NULL) {
1821 1.1 cgd (void) fclose(dout);
1822 1.1 cgd transflag = 0;
1823 1.1 cgd data = -1;
1824 1.1 cgd pdata = -1;
1825 1.1 cgd }
1826 1.8 deraadt goto out;
1827 1.1 cgd }
1828 1.1 cgd
1829 1.8 deraadt if (S_ISREG(st.st_mode)) {
1830 1.1 cgd if (dout == NULL) {
1831 1.1 cgd dout = dataconn("file list", (off_t)-1, "w");
1832 1.1 cgd if (dout == NULL)
1833 1.8 deraadt goto out;
1834 1.1 cgd transflag++;
1835 1.1 cgd }
1836 1.1 cgd fprintf(dout, "%s%s\n", dirname,
1837 1.1 cgd type == TYPE_A ? "\r" : "");
1838 1.1 cgd byte_count += strlen(dirname) + 1;
1839 1.1 cgd continue;
1840 1.8 deraadt } else if (!S_ISDIR(st.st_mode))
1841 1.1 cgd continue;
1842 1.1 cgd
1843 1.33 lukem if (dirname[strlen(dirname) - 1] == '/')
1844 1.33 lukem trailingslash++;
1845 1.33 lukem
1846 1.1 cgd if ((dirp = opendir(dirname)) == NULL)
1847 1.1 cgd continue;
1848 1.1 cgd
1849 1.1 cgd while ((dir = readdir(dirp)) != NULL) {
1850 1.1 cgd char nbuf[MAXPATHLEN];
1851 1.1 cgd
1852 1.1 cgd if (dir->d_name[0] == '.' && dir->d_namlen == 1)
1853 1.1 cgd continue;
1854 1.1 cgd if (dir->d_name[0] == '.' && dir->d_name[1] == '.' &&
1855 1.1 cgd dir->d_namlen == 2)
1856 1.1 cgd continue;
1857 1.1 cgd
1858 1.33 lukem (void)snprintf(nbuf, sizeof(nbuf), "%s%s%s", dirname,
1859 1.33 lukem trailingslash ? "" : "/", dir->d_name);
1860 1.1 cgd
1861 1.1 cgd /*
1862 1.30 lukem * We have to do a stat to ensure it's
1863 1.1 cgd * not a directory or special file.
1864 1.1 cgd */
1865 1.1 cgd if (simple || (stat(nbuf, &st) == 0 &&
1866 1.8 deraadt S_ISREG(st.st_mode))) {
1867 1.1 cgd if (dout == NULL) {
1868 1.1 cgd dout = dataconn("file list", (off_t)-1,
1869 1.1 cgd "w");
1870 1.1 cgd if (dout == NULL)
1871 1.8 deraadt goto out;
1872 1.1 cgd transflag++;
1873 1.1 cgd }
1874 1.1 cgd if (nbuf[0] == '.' && nbuf[1] == '/')
1875 1.1 cgd fprintf(dout, "%s%s\n", &nbuf[2],
1876 1.1 cgd type == TYPE_A ? "\r" : "");
1877 1.1 cgd else
1878 1.1 cgd fprintf(dout, "%s%s\n", nbuf,
1879 1.1 cgd type == TYPE_A ? "\r" : "");
1880 1.1 cgd byte_count += strlen(nbuf) + 1;
1881 1.1 cgd }
1882 1.1 cgd }
1883 1.1 cgd (void) closedir(dirp);
1884 1.1 cgd }
1885 1.1 cgd
1886 1.1 cgd if (dout == NULL)
1887 1.1 cgd reply(550, "No files found.");
1888 1.1 cgd else if (ferror(dout) != 0)
1889 1.1 cgd perror_reply(550, "Data connection");
1890 1.1 cgd else
1891 1.1 cgd reply(226, "Transfer complete.");
1892 1.1 cgd
1893 1.1 cgd transflag = 0;
1894 1.1 cgd if (dout != NULL)
1895 1.1 cgd (void) fclose(dout);
1896 1.1 cgd data = -1;
1897 1.1 cgd pdata = -1;
1898 1.8 deraadt out:
1899 1.8 deraadt if (freeglob) {
1900 1.8 deraadt freeglob = 0;
1901 1.8 deraadt globfree(&gl);
1902 1.8 deraadt }
1903 1.34 lukem }
1904 1.34 lukem
1905 1.34 lukem char *
1906 1.34 lukem conffilename(s)
1907 1.34 lukem const char *s;
1908 1.34 lukem {
1909 1.34 lukem static char filename[MAXPATHLEN];
1910 1.34 lukem
1911 1.34 lukem (void)snprintf(filename, sizeof(filename), "%s/%s", confdir ,s);
1912 1.34 lukem return filename;
1913 1.1 cgd }
1914