![[BACK]](/cvsweb/icons/back.gif){kind=icon}
Return to ftp.c CVS log ![[TXT]](/cvsweb/icons/text.gif){kind=icon}
![[DIR]](/cvsweb/icons/dir.gif){kind=icon}
Up to [CSRG BSD Unix] / 43BSDReno / contrib / isode-beta / ftam-ftp|
Return to ftp.c CVS log | Up to [CSRG BSD Unix] / 43BSDReno / contrib / isode-beta / ftam-ftp |
1.1 root 1: /* ftp.c - FTP client */
2:
3: #ifndef lint
4: static char *rcsid = "$Header: /f/osi/ftam-ftp/RCS/ftp.c,v 7.0 89/11/23 21:55:04 mrose Rel $"; /* from UCB 4.11 7/26/83 */
5: #endif
6:
7: /*
8: * $Header: /f/osi/ftam-ftp/RCS/ftp.c,v 7.0 89/11/23 21:55:04 mrose Rel $
9: *
10: *
11: * $Log: ftp.c,v $
12: * Revision 7.0 89/11/23 21:55:04 mrose
13: * Release 6.0
14: *
15: */
16:
17: /*
18: * NOTICE
19: *
20: * The MITRE Corporation (hereafter MITRE) makes this software available
21: * on an "as is" basis. No guarantees, either explicit or implied, are
22: * given as to performance or suitability.
23: *
24: */
25:
26: /*
27: * Shamelessly taken from UCB
28: */
29:
30: #include "config.h"
31: #include <sys/param.h>
32: #include <sys/ioctl.h>
33: #include "internet.h"
34: #include <sys/time.h>
35:
36: #include <arpa/ftp.h>
37:
38: #include <stdio.h>
39: #include <errno.h>
40: #include <varargs.h>
41:
42: #include "ftp_var.h"
43: #include "general.h"
44: #include "logger.h"
45: void advise ();
46:
47: #ifndef NOTOK
48: #define NOTOK (-1)
49: #define OK 0
50: #define DONE 1
51: #endif /* NOTOK */
52:
53: int verbose = 0;
54:
55: struct sockaddr_in hisctladdr;
56: struct sockaddr_in data_addr;
57: int data = -1;
58: int connected = 0;
59: struct sockaddr_in myctladdr;
60:
61: FILE *cin, *cout;
62: int dataconn();
63:
64:
65: ftp_init()
66: { /* default ftp communication values */
67:
68: (void)strcpy(typename, "ascii"), type = TYPE_A;
69: (void)strcpy(formname, "non-print"), form = FORM_N;
70: (void)strcpy(modename, "stream"), mode = MODE_S;
71: (void)strcpy(structname, "file"), stru = STRU_F;
72: (void)strcpy(bytename, "8"), bytesize = 8;
73: ftp_directory = 0;
74: ftp_error = ftp_error_buffer;
75: verbose = isatty (fileno (stderr));
76: }
77:
78: hookup(host, port)
79: char *host;
80: int port;
81: {
82: register struct hostent *hp;
83: int s, len;
84:
85: bzero((char *)&hisctladdr, sizeof (hisctladdr));
86: hp = gethostbyname(host);
87: if (hp == NULL) {
88: #ifdef h_addr
89: static char *addrs = NULL;
90: #endif
91: static struct hostent def;
92: static struct in_addr defaddr;
93: static char namebuf[128];
94: u_long inet_addr();
95:
96: defaddr.s_addr = inet_addr(host);
97: if (defaddr.s_addr == -1) {
98: (void)sprintf(ftp_error, "%s: Unknown host.", host);
99: return (NOTOK);
100: }
101: (void)strcpy(namebuf, host);
102: def.h_name = namebuf;
103: hostname = namebuf;
104: #ifdef h_addr
105: def.h_addr_list = &addrs;
106: #endif
107: def.h_addr = (char *)&defaddr;
108: def.h_length = sizeof (struct in_addr);
109: def.h_addrtype = AF_INET;
110: def.h_aliases = 0;
111: hp = &def;
112: }
113: hostname = hp->h_name;
114: hisctladdr.sin_family = hp->h_addrtype;
115: s = socket(hp->h_addrtype, SOCK_STREAM, 0);
116: if (s < 0) {
117: (void)sprintf(ftp_error,"ftp: socket %s",
118: (errno <= sys_nerr)? sys_errlist[errno]:"");
119: return (NOTOK);
120: }
121: if (bind(s, (struct sockaddr *)&hisctladdr, sizeof (hisctladdr)) < 0) {
122: (void)sprintf(ftp_error,"ftp: bind %s",
123: (errno <= sys_nerr)? sys_errlist[errno]:"");
124: goto bad;
125: }
126: inaddr_copy (hp, &hisctladdr);
127: hisctladdr.sin_port = htons ((u_short) port);
128: if (connect(s, (struct sockaddr *)&hisctladdr, sizeof (hisctladdr)) < 0) {
129: (void)sprintf(ftp_error,"ftp: connect %s",
130: (errno <= sys_nerr)? sys_errlist[errno]:"");
131: goto bad;
132: }
133: len = sizeof (myctladdr);
134: if (getsockname(s, (struct sockaddr *)&myctladdr, &len) < 0) {
135: (void)sprintf(ftp_error,"ftp: getsockname %s",
136: (errno <= sys_nerr)? sys_errlist[errno]:"");
137: goto bad;
138: }
139: cin = fdopen(s, "r");
140: cout = fdopen(s, "w");
141: if (cin == NULL || cout == NULL) {
142: (void)sprintf(ftp_error, "ftp: fdopen failed.");
143: if (cin)
144: (void)fclose(cin);
145: if (cout)
146: (void)fclose(cout);
147: goto bad;
148: }
149: (void) getreply(0); /* read startup message from server */
150: connected = 1;
151: return (OK);
152: bad:
153: (void)close(s);
154: return (NOTOK);
155: }
156:
157: login(user,pass,acct)
158: char *user, *pass, *acct;
159: {
160: int n;
161:
162: if (!user){
163: (void)sprintf(ftp_error, "Username required");
164: return(NOTOK);
165: }
166: n = command("USER %s", user);
167: if (n == CONTINUE){
168: if (!pass){
169: (void)sprintf(ftp_error, "Password required");
170: return(NOTOK);
171: }
172: n = command("PASS %s", pass);
173: }
174: if (n == CONTINUE) {
175: if (!acct){
176: (void)sprintf(ftp_error, "Account required");
177: return(NOTOK);
178: }
179: n = command("ACCT %s", acct);
180: }
181: if (n != COMPLETE) {
182: (void)sprintf(ftp_error, "Login failed.");
183: return (NOTOK);
184: }
185: return (OK);
186: }
187:
188: #ifndef lint
189: command(va_alist)
190: va_dcl
191: {
192: int val;
193: va_list ap;
194:
195: va_start (ap);
196:
197: val = _command (ap);
198:
199: va_end (ap);
200:
201: return val;
202: }
203:
204: _command(ap)
205: va_list ap;
206: {
207: char buffer[BUFSIZ];
208:
209: if (cout == NULL) {
210: (void)sprintf(ftp_error,"No control connection for command %s",
211: (errno <= sys_nerr)? sys_errlist[errno]:"");
212: return (NOTOK);
213: }
214:
215: _asprintf (buffer, NULLCP, ap);
216: fprintf (cout, "%s\r\n", buffer);
217: (void) fflush(cout);
218: if (verbose)
219: advise (LLOG_DEBUG, NULLCP, "<--- %s", buffer);
220: return (getreply(!strcmp(buffer, "QUIT")));
221: }
222: #else
223: /* VARARGS1 */
224:
225: command (fmt)
226: char *fmt;
227: {
228: return command (fmt);
229: }
230: #endif
231:
232: #include <ctype.h>
233:
234: getreply(expecteof)
235: int expecteof;
236: {
237: register int c, n;
238: register int code, dig;
239: int originalcode = 0, continuation = 0;
240: char *mesg;
241:
242: mesg = ftp_error_buffer;
243: for (;;) {
244: dig = n = code = 0;
245: while ((c = getc(cin)) != '\n') {
246: dig++;
247: if (c == EOF) {
248: if (expecteof)
249: return (0);
250: lostpeer();
251: advise (LLOG_EXCEPTIONS,NULLCP,"getreply: %s",
252: ftp_error_buffer);
253: return(1);
254: /* exit(1); */
255: }
256: if (c != '\r') *mesg++ = c;
257: else *mesg = '\0';
258: if (dig < 4 && isdigit(c))
259: code = code * 10 + (c - '0');
260: if (dig == 4 && c == '-')
261: continuation++;
262: if (n == 0)
263: n = c;
264: }
265: if (continuation && code != originalcode) {
266: if (originalcode == 0)
267: originalcode = code;
268: continue;
269: }
270: if (verbose)
271: advise (LLOG_DEBUG,NULLCP,"---> %s",
272: ftp_error_buffer);
273: return (n - '0');
274: }
275: }
276:
277: /*
278: * sendrequest and recvrequest routines have been modified to send the
279: * appropriate remote command then open and return a file descriptor (socket).
280: * The FTAM code treats this as though it were a local file (which
281: * is about what FTP does)
282: */
283: int
284: sendrequest(cmd, /* local, */ remote)
285: char *cmd, /* *local, */ *remote;
286: {
287: int dout;
288: int expectingreply = 0;
289:
290: if (initconn())
291: goto bad;
292: if (remote) {
293: if (command("%s %s", cmd, remote) != PRELIM)
294: goto bad;
295: } else
296: if (command("%s", cmd) != PRELIM)
297: goto bad;
298: expectingreply++; /* got preliminary reply, expecting final reply */
299: dout = dataconn("w");
300: if (dout == NOTOK)
301: goto bad;
302: return(dout);
303:
304: bad:
305: if (data >= 0)
306: (void) close(data), data = -1;
307: if (expectingreply) {
308: (void) getreply(0);
309: expectingreply = 0;
310: }
311: return(NOTOK);
312: }
313:
314: int
315: recvrequest(cmd, /* local,*/ remote)
316: char *cmd, /* *local,*/ *remote;
317: {
318: int din;
319: int expectingreply = 0;
320:
321: if (initconn())
322: goto bad;
323: if (remote) {
324: if (command("%s %s", cmd, remote) != PRELIM)
325: goto bad;
326: } else
327: if (command("%s", cmd) != PRELIM)
328: goto bad;
329: expectingreply++; /* got preliminary reply, expecting final reply */
330: din = dataconn("r");
331: if (din == NOTOK)
332: goto bad;
333: return(din);
334: bad:
335: if (data >= 0)
336: (void) close(data), data = -1;
337: if (expectingreply) {
338: (void) getreply(0);
339: expectingreply = 0;
340: }
341: return(NOTOK);
342: }
343:
344: /*
345: * Need to start a listen on the data channel
346: * before we send the command, otherwise the
347: * server's connect may fail.
348: */
349: int sendport = -1;
350:
351: initconn()
352: {
353: register char *p, *a;
354: int result, len;
355: #ifdef BSD43
356: int on = 1;
357: #endif
358:
359: noport:
360: data_addr = myctladdr;
361: if (sendport)
362: data_addr.sin_port = 0; /* let system pick one */
363: if (data != -1)
364: (void) close (data);
365: data = socket(AF_INET, SOCK_STREAM, 0);
366: if (data < 0) {
367: (void)sprintf(ftp_error,"ftp: socket %s",
368: (errno <= sys_nerr)? sys_errlist[errno]:"");
369: return (NOTOK);
370: }
371: if (!sendport)
372: #ifndef BSD43
373: if (setsockopt(data, SOL_SOCKET, SO_REUSEADDR, (char *) 0, 0) < 0) {
374: #else
375: if (setsockopt(data, SOL_SOCKET, SO_REUSEADDR, (char *)&on, sizeof on) < 0) {
376: #endif
377: (void)sprintf(ftp_error,"ftp: setsockopt (reuse address) %s",
378: (errno <= sys_nerr)? sys_errlist[errno]:"");
379: goto bad;
380: }
381: if (bind(data, (struct sockaddr *)&data_addr, sizeof (data_addr)) < 0) {
382: (void)sprintf(ftp_error,"ftp: bind %s",
383: (errno <= sys_nerr)? sys_errlist[errno]:"");
384: goto bad;
385: }
386: if (options & SO_DEBUG &&
387: #ifndef BSD43
388: setsockopt(data, SOL_SOCKET, SO_DEBUG, (char *) 0, 0) < 0)
389: #else
390: setsockopt(data, SOL_SOCKET, SO_DEBUG, (char *) &on, on) < 0)
391: #endif
392: (void)sprintf(ftp_error,"ftp: setsockopt (ignoreg) %s",
393: (errno <= sys_nerr)? sys_errlist[errno]:"");
394: len = sizeof (data_addr);
395: if (getsockname(data, (struct sockaddr *)&data_addr, &len) < 0) {
396: (void)sprintf(ftp_error,"ftp: getsockname %s",
397: (errno <= sys_nerr)? sys_errlist[errno]:"");
398: goto bad;
399: }
400: if (listen(data, 1) < 0) {
401: (void)sprintf(ftp_error,"ftp: listen %s",
402: (errno <= sys_nerr)? sys_errlist[errno]:"");
403: goto bad;
404: }
405: if (sendport) {
406: a = (char *)&data_addr.sin_addr;
407: p = (char *)&data_addr.sin_port;
408: #define UC(b) (((int)b)&0xff)
409: result =
410: command("PORT %d,%d,%d,%d,%d,%d",
411: UC(a[0]), UC(a[1]), UC(a[2]), UC(a[3]),
412: UC(p[0]), UC(p[1]));
413: if (result == ERROR && sendport == -1) {
414: sendport = 0;
415: goto noport;
416: }
417: return ((result == COMPLETE)?OK:NOTOK);
418: }
419: return (OK);
420: bad:
421: (void) close(data), data = -1;
422: return (NOTOK);
423: }
424:
425: /*ARGSUSED */
426: int
427: dataconn(modeX)
428: char *modeX;
429: {
430: struct sockaddr_in from;
431: int s, fromlen = sizeof (from);
432:
433: s = accept(data, (struct sockaddr *) &from, &fromlen);
434: if (s < 0) {
435: (void)sprintf(ftp_error,"ftp: accept %s",
436: (errno <= sys_nerr)? sys_errlist[errno]:"");
437: (void) close(data), data = -1;
438: return (NOTOK);
439: }
440: (void) close(data);
441: data = s;
442: return (data);
443: }
444:
445: lostpeer()
446: {
447:
448: if (connected) {
449: if (cout != NULL) {
450: (void)shutdown(fileno(cout), 1+1);
451: (void)fclose(cout);
452: cout = NULL;
453: }
454: if (data >= 0) {
455: (void) shutdown(data, 1+1);
456: (void) close(data);
457: data = -1;
458: }
459: connected = 0;
460: }
461: }
This archive runs on limited infrastructure. Preserving old code on modern bandwidth. Automated agents are requested to crawl responsibly.