1*784d8958Smaxv /* $NetBSD: ip_ftp_pxy.c,v 1.7 2018/06/03 10:37:23 maxv Exp $ */
2ecd7789bSchristos
3ecd7789bSchristos /*
4f52ace7aSdarrenr * Copyright (C) 2012 by Darren Reed.
5ecd7789bSchristos *
6ecd7789bSchristos * See the IPFILTER.LICENCE file for details on licencing.
7ecd7789bSchristos *
8ecd7789bSchristos * Simple FTP transparent proxy for in-kernel use. For use with the NAT
9ecd7789bSchristos * code.
10ecd7789bSchristos *
11f52ace7aSdarrenr * Id: ip_ftp_pxy.c,v 1.1.1.2 2012/07/22 13:45:18 darrenr Exp
12ecd7789bSchristos */
13ecd7789bSchristos
14f330e785Schristos #include <sys/cdefs.h>
15*784d8958Smaxv __KERNEL_RCSID(1, "$NetBSD: ip_ftp_pxy.c,v 1.7 2018/06/03 10:37:23 maxv Exp $");
16f330e785Schristos
17ecd7789bSchristos #define IPF_FTP_PROXY
18ecd7789bSchristos
19ecd7789bSchristos #define IPF_MINPORTLEN 18
20ecd7789bSchristos #define IPF_MINEPRTLEN 20
21ecd7789bSchristos #define IPF_MAXPORTLEN 30
22ecd7789bSchristos #define IPF_MIN227LEN 39
23ecd7789bSchristos #define IPF_MAX227LEN 51
24ecd7789bSchristos #define IPF_MIN229LEN 47
25ecd7789bSchristos #define IPF_MAX229LEN 51
26ecd7789bSchristos
27ecd7789bSchristos #define FTPXY_GO 0
28ecd7789bSchristos #define FTPXY_INIT 1
29ecd7789bSchristos #define FTPXY_USER_1 2
30ecd7789bSchristos #define FTPXY_USOK_1 3
31ecd7789bSchristos #define FTPXY_PASS_1 4
32ecd7789bSchristos #define FTPXY_PAOK_1 5
33ecd7789bSchristos #define FTPXY_AUTH_1 6
34ecd7789bSchristos #define FTPXY_AUOK_1 7
35ecd7789bSchristos #define FTPXY_ADAT_1 8
36ecd7789bSchristos #define FTPXY_ADOK_1 9
37ecd7789bSchristos #define FTPXY_ACCT_1 10
38ecd7789bSchristos #define FTPXY_ACOK_1 11
39ecd7789bSchristos #define FTPXY_USER_2 12
40ecd7789bSchristos #define FTPXY_USOK_2 13
41ecd7789bSchristos #define FTPXY_PASS_2 14
42ecd7789bSchristos #define FTPXY_PAOK_2 15
43ecd7789bSchristos
44ecd7789bSchristos #define FTPXY_JUNK_OK 0
45ecd7789bSchristos #define FTPXY_JUNK_BAD 1 /* Ignore all commands for this connection */
46ecd7789bSchristos #define FTPXY_JUNK_EOL 2 /* consume the rest of this line only */
47ecd7789bSchristos #define FTPXY_JUNK_CONT 3 /* Saerching for next numeric */
48ecd7789bSchristos
49ecd7789bSchristos /*
50ecd7789bSchristos * Values for FTP commands. Numerics cover 0-999
51ecd7789bSchristos */
52ecd7789bSchristos #define FTPXY_C_PASV 1000
53ecd7789bSchristos #define FTPXY_C_PORT 1001
54ecd7789bSchristos #define FTPXY_C_EPSV 1002
55ecd7789bSchristos #define FTPXY_C_EPRT 1003
56ecd7789bSchristos
57ecd7789bSchristos
58ecd7789bSchristos typedef struct ipf_ftp_softc_s {
59ecd7789bSchristos int ipf_p_ftp_pasvonly;
60ecd7789bSchristos /* Do not require logins before transfers */
61ecd7789bSchristos int ipf_p_ftp_insecure;
62ecd7789bSchristos int ipf_p_ftp_pasvrdr;
63ecd7789bSchristos /* PASV must be last command prior to 227 */
64ecd7789bSchristos int ipf_p_ftp_forcepasv;
65ecd7789bSchristos int ipf_p_ftp_debug;
66ecd7789bSchristos int ipf_p_ftp_single_xfer;
67ecd7789bSchristos void *ipf_p_ftp_tune;
68ecd7789bSchristos } ipf_ftp_softc_t;
69ecd7789bSchristos
70ecd7789bSchristos
71f330e785Schristos void ipf_p_ftp_main_load(void);
72f330e785Schristos void ipf_p_ftp_main_unload(void);
73f330e785Schristos void *ipf_p_ftp_soft_create(ipf_main_softc_t *);
74f330e785Schristos void ipf_p_ftp_soft_destroy(ipf_main_softc_t *, void *);
75ecd7789bSchristos
76f330e785Schristos int ipf_p_ftp_client(ipf_ftp_softc_t *, fr_info_t *, ip_t *, nat_t *,
77f330e785Schristos ftpinfo_t *, int);
78f330e785Schristos int ipf_p_ftp_complete(char *, size_t);
79f330e785Schristos int ipf_p_ftp_in(void *, fr_info_t *, ap_session_t *, nat_t *);
80f330e785Schristos int ipf_p_ftp_new(void *, fr_info_t *, ap_session_t *, nat_t *);
81f330e785Schristos void ipf_p_ftp_del(ipf_main_softc_t *, ap_session_t *);
82f330e785Schristos int ipf_p_ftp_out(void *, fr_info_t *, ap_session_t *, nat_t *);
83f330e785Schristos int ipf_p_ftp_pasv(ipf_ftp_softc_t *, fr_info_t *, ip_t *, nat_t *,
84f330e785Schristos ftpinfo_t *, int);
85f330e785Schristos int ipf_p_ftp_epsv(ipf_ftp_softc_t *, fr_info_t *, ip_t *, nat_t *,
86f330e785Schristos ftpinfo_t *, int);
87f330e785Schristos int ipf_p_ftp_port(ipf_ftp_softc_t *, fr_info_t *, ip_t *, nat_t *,
88f330e785Schristos ftpinfo_t *, int);
89f330e785Schristos int ipf_p_ftp_process(ipf_ftp_softc_t *, fr_info_t *, nat_t *,
90f330e785Schristos ftpinfo_t *, int);
91f330e785Schristos int ipf_p_ftp_server(ipf_ftp_softc_t *, fr_info_t *, ip_t *, nat_t *,
92f330e785Schristos ftpinfo_t *, int);
93f330e785Schristos int ipf_p_ftp_valid(ipf_ftp_softc_t *, ftpinfo_t *, int, char *, size_t);
94f330e785Schristos int ipf_p_ftp_server_valid(ipf_ftp_softc_t *, ftpside_t *, char *,
95f330e785Schristos size_t);
96f330e785Schristos int ipf_p_ftp_client_valid(ipf_ftp_softc_t *, ftpside_t *, char *,
97f330e785Schristos size_t);
98f330e785Schristos u_short ipf_p_ftp_atoi(char **);
99f330e785Schristos int ipf_p_ftp_pasvreply(ipf_ftp_softc_t *, fr_info_t *, ip_t *, nat_t *,
100f52ace7aSdarrenr ftpinfo_t *, u_int, char *, char *);
101f330e785Schristos int ipf_p_ftp_eprt(ipf_ftp_softc_t *, fr_info_t *, ip_t *, nat_t *,
102f330e785Schristos ftpinfo_t *, int);
103f330e785Schristos int ipf_p_ftp_eprt4(ipf_ftp_softc_t *, fr_info_t *, ip_t *, nat_t *,
104f330e785Schristos ftpinfo_t *, int);
105f52ace7aSdarrenr int ipf_p_ftp_eprt6(ipf_ftp_softc_t *, fr_info_t *, ip_t *, nat_t *,
106f52ace7aSdarrenr ftpinfo_t *, int);
107f330e785Schristos int ipf_p_ftp_addport(ipf_ftp_softc_t *, fr_info_t *, ip_t *, nat_t *,
108f330e785Schristos ftpinfo_t *, int, int, int);
109f330e785Schristos void ipf_p_ftp_setpending(ipf_main_softc_t *, ftpinfo_t *);
110ecd7789bSchristos
111ecd7789bSchristos /*
112f52ace7aSdarrenr * Debug levels
113ecd7789bSchristos */
114f52ace7aSdarrenr #define DEBUG_SECURITY 0x01
115f52ace7aSdarrenr #define DEBUG_ERROR 0x02
116f52ace7aSdarrenr #define DEBUG_INFO 0x04
117f52ace7aSdarrenr #define DEBUG_PARSE_ERR 0x08
118f52ace7aSdarrenr #define DEBUG_PARSE_INFO 0x10
119f52ace7aSdarrenr #define DEBUG_PARSE 0x20
120ecd7789bSchristos
121ecd7789bSchristos static int ipf_p_ftp_proxy_init = 0;
122ecd7789bSchristos static frentry_t ftppxyfr;
123*784d8958Smaxv static const ipftuneable_t ipf_ftp_tuneables[] = {
124ecd7789bSchristos { { (void *)offsetof(ipf_ftp_softc_t, ipf_p_ftp_debug) },
125f52ace7aSdarrenr "ftp_debug", 0, 0x7f,
126ecd7789bSchristos stsizeof(ipf_ftp_softc_t, ipf_p_ftp_debug),
127ecd7789bSchristos 0, NULL, NULL },
128ecd7789bSchristos { { (void *)offsetof(ipf_ftp_softc_t, ipf_p_ftp_pasvonly) },
129ecd7789bSchristos "ftp_pasvonly", 0, 1,
130ecd7789bSchristos stsizeof(ipf_ftp_softc_t, ipf_p_ftp_pasvonly),
131ecd7789bSchristos 0, NULL, NULL },
132ecd7789bSchristos { { (void *)offsetof(ipf_ftp_softc_t, ipf_p_ftp_insecure) },
133ecd7789bSchristos "ftp_insecure", 0, 1,
134ecd7789bSchristos stsizeof(ipf_ftp_softc_t, ipf_p_ftp_insecure),
135ecd7789bSchristos 0, NULL, NULL },
136ecd7789bSchristos { { (void *)offsetof(ipf_ftp_softc_t, ipf_p_ftp_pasvrdr) },
137ecd7789bSchristos "ftp_pasvrdr", 0, 1,
138ecd7789bSchristos stsizeof(ipf_ftp_softc_t, ipf_p_ftp_pasvrdr),
139ecd7789bSchristos 0, NULL, NULL },
140ecd7789bSchristos { { (void *)offsetof(ipf_ftp_softc_t, ipf_p_ftp_forcepasv) },
141ecd7789bSchristos "ftp_forcepasv", 0, 1,
142ecd7789bSchristos stsizeof(ipf_ftp_softc_t, ipf_p_ftp_forcepasv),
143ecd7789bSchristos 0, NULL, NULL },
144ecd7789bSchristos { { (void *)offsetof(ipf_ftp_softc_t, ipf_p_ftp_single_xfer) },
145ecd7789bSchristos "ftp_single_xfer", 0, 1,
146ecd7789bSchristos stsizeof(ipf_ftp_softc_t, ipf_p_ftp_single_xfer),
147ecd7789bSchristos 0, NULL, NULL },
148ecd7789bSchristos { { NULL }, NULL, 0, 0, 0, 0, NULL, NULL }
149ecd7789bSchristos };
150ecd7789bSchristos
151ecd7789bSchristos
152ecd7789bSchristos void
ipf_p_ftp_main_load(void)153f330e785Schristos ipf_p_ftp_main_load(void)
154ecd7789bSchristos {
155ecd7789bSchristos bzero((char *)&ftppxyfr, sizeof(ftppxyfr));
156ecd7789bSchristos ftppxyfr.fr_ref = 1;
157ecd7789bSchristos ftppxyfr.fr_flags = FR_INQUE|FR_PASS|FR_QUICK|FR_KEEPSTATE;
158ecd7789bSchristos
159ecd7789bSchristos MUTEX_INIT(&ftppxyfr.fr_lock, "FTP Proxy Mutex");
160ecd7789bSchristos ipf_p_ftp_proxy_init = 1;
161ecd7789bSchristos }
162ecd7789bSchristos
163ecd7789bSchristos
164ecd7789bSchristos void
ipf_p_ftp_main_unload(void)165f330e785Schristos ipf_p_ftp_main_unload(void)
166ecd7789bSchristos {
167ecd7789bSchristos
168ecd7789bSchristos if (ipf_p_ftp_proxy_init == 1) {
169ecd7789bSchristos MUTEX_DESTROY(&ftppxyfr.fr_lock);
170ecd7789bSchristos ipf_p_ftp_proxy_init = 0;
171ecd7789bSchristos }
172ecd7789bSchristos }
173ecd7789bSchristos
174ecd7789bSchristos
175ecd7789bSchristos /*
176ecd7789bSchristos * Initialize local structures.
177ecd7789bSchristos */
178ecd7789bSchristos void *
ipf_p_ftp_soft_create(ipf_main_softc_t * softc)179f330e785Schristos ipf_p_ftp_soft_create(ipf_main_softc_t *softc)
180ecd7789bSchristos {
181ecd7789bSchristos ipf_ftp_softc_t *softf;
182ecd7789bSchristos
183ecd7789bSchristos KMALLOC(softf, ipf_ftp_softc_t *);
184ecd7789bSchristos if (softf == NULL)
185ecd7789bSchristos return NULL;
186ecd7789bSchristos
187ecd7789bSchristos bzero((char *)softf, sizeof(*softf));
188ecd7789bSchristos #if defined(_KERNEL)
189ecd7789bSchristos softf->ipf_p_ftp_debug = 0;
190ecd7789bSchristos #else
191f52ace7aSdarrenr softf->ipf_p_ftp_debug = DEBUG_PARSE_ERR;
192ecd7789bSchristos #endif
193ecd7789bSchristos softf->ipf_p_ftp_forcepasv = 1;
194ecd7789bSchristos
195ecd7789bSchristos softf->ipf_p_ftp_tune = ipf_tune_array_copy(softf,
196ecd7789bSchristos sizeof(ipf_ftp_tuneables),
197ecd7789bSchristos ipf_ftp_tuneables);
198ecd7789bSchristos if (softf->ipf_p_ftp_tune == NULL) {
199ecd7789bSchristos ipf_p_ftp_soft_destroy(softc, softf);
200ecd7789bSchristos return NULL;
201ecd7789bSchristos }
202ecd7789bSchristos if (ipf_tune_array_link(softc, softf->ipf_p_ftp_tune) == -1) {
203ecd7789bSchristos ipf_p_ftp_soft_destroy(softc, softf);
204ecd7789bSchristos return NULL;
205ecd7789bSchristos }
206ecd7789bSchristos
207ecd7789bSchristos return softf;
208ecd7789bSchristos }
209ecd7789bSchristos
210ecd7789bSchristos
211ecd7789bSchristos void
ipf_p_ftp_soft_destroy(ipf_main_softc_t * softc,void * arg)212f330e785Schristos ipf_p_ftp_soft_destroy(ipf_main_softc_t *softc, void *arg)
213ecd7789bSchristos {
214ecd7789bSchristos ipf_ftp_softc_t *softf = arg;
215ecd7789bSchristos
216ecd7789bSchristos if (softf->ipf_p_ftp_tune != NULL) {
217ecd7789bSchristos ipf_tune_array_unlink(softc, softf->ipf_p_ftp_tune);
218ecd7789bSchristos KFREES(softf->ipf_p_ftp_tune, sizeof(ipf_ftp_tuneables));
219ecd7789bSchristos softf->ipf_p_ftp_tune = NULL;
220ecd7789bSchristos }
221ecd7789bSchristos
222ecd7789bSchristos KFREE(softf);
223ecd7789bSchristos }
224ecd7789bSchristos
225ecd7789bSchristos
226ecd7789bSchristos int
ipf_p_ftp_new(void * arg,fr_info_t * fin,ap_session_t * aps,nat_t * nat)227f330e785Schristos ipf_p_ftp_new(void *arg, fr_info_t *fin, ap_session_t *aps, nat_t *nat)
228ecd7789bSchristos {
229ecd7789bSchristos ftpinfo_t *ftp;
230ecd7789bSchristos ftpside_t *f;
231ecd7789bSchristos
232ecd7789bSchristos KMALLOC(ftp, ftpinfo_t *);
233ecd7789bSchristos if (ftp == NULL)
234ecd7789bSchristos return -1;
235ecd7789bSchristos
236ecd7789bSchristos nat = nat; /* LINT */
237ecd7789bSchristos
238ecd7789bSchristos aps->aps_data = ftp;
239ecd7789bSchristos aps->aps_psiz = sizeof(ftpinfo_t);
240f52ace7aSdarrenr aps->aps_sport = htons(fin->fin_sport);
241f52ace7aSdarrenr aps->aps_dport = htons(fin->fin_dport);
242ecd7789bSchristos
243ecd7789bSchristos bzero((char *)ftp, sizeof(*ftp));
244ecd7789bSchristos f = &ftp->ftp_side[0];
245ecd7789bSchristos f->ftps_rptr = f->ftps_buf;
246ecd7789bSchristos f->ftps_wptr = f->ftps_buf;
247ecd7789bSchristos f = &ftp->ftp_side[1];
248ecd7789bSchristos f->ftps_rptr = f->ftps_buf;
249ecd7789bSchristos f->ftps_wptr = f->ftps_buf;
250ecd7789bSchristos ftp->ftp_passok = FTPXY_INIT;
251ecd7789bSchristos ftp->ftp_incok = 0;
252ecd7789bSchristos return 0;
253ecd7789bSchristos }
254ecd7789bSchristos
255ecd7789bSchristos
256ecd7789bSchristos void
ipf_p_ftp_setpending(ipf_main_softc_t * softc,ftpinfo_t * ftp)257ecd7789bSchristos ipf_p_ftp_setpending(ipf_main_softc_t *softc, ftpinfo_t *ftp)
258ecd7789bSchristos {
259ecd7789bSchristos if (ftp->ftp_pendnat != NULL)
260ecd7789bSchristos ipf_nat_setpending(softc, ftp->ftp_pendnat);
261ecd7789bSchristos
262ecd7789bSchristos if (ftp->ftp_pendstate != NULL) {
263ecd7789bSchristos READ_ENTER(&softc->ipf_state);
264ecd7789bSchristos ipf_state_setpending(softc, ftp->ftp_pendstate);
265ecd7789bSchristos RWLOCK_EXIT(&softc->ipf_state);
266ecd7789bSchristos }
267ecd7789bSchristos }
268ecd7789bSchristos
269ecd7789bSchristos
270ecd7789bSchristos void
ipf_p_ftp_del(ipf_main_softc_t * softc,ap_session_t * aps)271f330e785Schristos ipf_p_ftp_del(ipf_main_softc_t *softc, ap_session_t *aps)
272ecd7789bSchristos {
273ecd7789bSchristos ftpinfo_t *ftp;
274ecd7789bSchristos
275ecd7789bSchristos ftp = aps->aps_data;
276ecd7789bSchristos if (ftp != NULL)
277ecd7789bSchristos ipf_p_ftp_setpending(softc, ftp);
278ecd7789bSchristos }
279ecd7789bSchristos
280ecd7789bSchristos
281ecd7789bSchristos int
ipf_p_ftp_port(ipf_ftp_softc_t * softf,fr_info_t * fin,ip_t * ip,nat_t * nat,ftpinfo_t * ftp,int dlen)282f330e785Schristos ipf_p_ftp_port(ipf_ftp_softc_t *softf, fr_info_t *fin, ip_t *ip, nat_t *nat,
283f330e785Schristos ftpinfo_t *ftp, int dlen)
284ecd7789bSchristos {
285ecd7789bSchristos char newbuf[IPF_FTPBUFSZ], *s;
286ecd7789bSchristos u_int a1, a2, a3, a4;
287ecd7789bSchristos u_short a5, a6, sp;
288ecd7789bSchristos size_t nlen, olen;
289ecd7789bSchristos tcphdr_t *tcp;
290ecd7789bSchristos int inc, off;
291ecd7789bSchristos ftpside_t *f;
292ecd7789bSchristos mb_t *m;
293ecd7789bSchristos
294ecd7789bSchristos m = fin->fin_m;
295ecd7789bSchristos f = &ftp->ftp_side[0];
296ecd7789bSchristos tcp = (tcphdr_t *)fin->fin_dp;
297ecd7789bSchristos off = (char *)tcp - (char *)ip + (TCP_OFF(tcp) << 2) + fin->fin_ipoff;
298ecd7789bSchristos
299ecd7789bSchristos /*
300ecd7789bSchristos * Check for client sending out PORT message.
301ecd7789bSchristos */
302ecd7789bSchristos if (dlen < IPF_MINPORTLEN) {
303f52ace7aSdarrenr DT3(ftp_PORT_error_dlen, nat_t *, nat, ftpside_t *, f,
304f52ace7aSdarrenr u_int, dlen);
305f52ace7aSdarrenr if (softf->ipf_p_ftp_debug & DEBUG_PARSE)
306ecd7789bSchristos printf("ipf_p_ftp_port:dlen(%d) < IPF_MINPORTLEN\n",
307ecd7789bSchristos dlen);
308ecd7789bSchristos return 0;
309ecd7789bSchristos }
310ecd7789bSchristos /*
311ecd7789bSchristos * Skip the PORT command + space
312ecd7789bSchristos */
313ecd7789bSchristos s = f->ftps_rptr + 5;
314ecd7789bSchristos /*
315ecd7789bSchristos * Pick out the address components, two at a time.
316ecd7789bSchristos */
317ecd7789bSchristos a1 = ipf_p_ftp_atoi(&s);
318ecd7789bSchristos if (s == NULL) {
319f52ace7aSdarrenr DT2(ftp_PORT_error_atoi_1, nat_t *, nat, ftpside_t *, f);
320f52ace7aSdarrenr if (softf->ipf_p_ftp_debug & DEBUG_PARSE_ERR)
321ecd7789bSchristos printf("ipf_p_ftp_port:ipf_p_ftp_atoi(%d) failed\n", 1);
322ecd7789bSchristos return 0;
323ecd7789bSchristos }
324ecd7789bSchristos a2 = ipf_p_ftp_atoi(&s);
325ecd7789bSchristos if (s == NULL) {
326f52ace7aSdarrenr DT2(ftp_PORT_error_atoi_2, nat_t *, nat, ftpside_t *, f);
327f52ace7aSdarrenr if (softf->ipf_p_ftp_debug & DEBUG_PARSE_ERR)
328ecd7789bSchristos printf("ipf_p_ftp_port:ipf_p_ftp_atoi(%d) failed\n", 2);
329ecd7789bSchristos return 0;
330ecd7789bSchristos }
331ecd7789bSchristos
332ecd7789bSchristos /*
333ecd7789bSchristos * Check that IP address in the PORT/PASV reply is the same as the
334ecd7789bSchristos * sender of the command - prevents using PORT for port scanning.
335ecd7789bSchristos */
336ecd7789bSchristos a1 <<= 16;
337ecd7789bSchristos a1 |= a2;
338ecd7789bSchristos if (((nat->nat_dir == NAT_OUTBOUND) &&
339ecd7789bSchristos (a1 != ntohl(nat->nat_osrcaddr))) ||
340ecd7789bSchristos ((nat->nat_dir == NAT_INBOUND) &&
341f52ace7aSdarrenr (a1 != ntohl(nat->nat_nsrcaddr)))) {
342f52ace7aSdarrenr DT3(ftp_PORT_error_address, nat_t *, nat, ftpside_t *, f,
343f52ace7aSdarrenr u_int, a1);
344f52ace7aSdarrenr if (softf->ipf_p_ftp_debug & DEBUG_ERROR)
345ecd7789bSchristos printf("ipf_p_ftp_port:%s != nat->nat_inip\n", "a1");
346ecd7789bSchristos return APR_ERR(1);
347ecd7789bSchristos }
348ecd7789bSchristos
349ecd7789bSchristos a5 = ipf_p_ftp_atoi(&s);
350ecd7789bSchristos if (s == NULL) {
351f52ace7aSdarrenr DT2(ftp_PORT_error_atoi_3, nat_t *, nat, ftpside_t *, f);
352f52ace7aSdarrenr if (softf->ipf_p_ftp_debug & DEBUG_PARSE_ERR)
353ecd7789bSchristos printf("ipf_p_ftp_port:ipf_p_ftp_atoi(%d) failed\n", 3);
354ecd7789bSchristos return 0;
355ecd7789bSchristos }
356ecd7789bSchristos if (*s == ')')
357ecd7789bSchristos s++;
358ecd7789bSchristos
359ecd7789bSchristos /*
360ecd7789bSchristos * check for CR-LF at the end.
361ecd7789bSchristos */
362ecd7789bSchristos if (*s == '\n')
363ecd7789bSchristos s--;
364f52ace7aSdarrenr if ((*s != '\r') || (*(s + 1) != '\n')) {
365f52ace7aSdarrenr DT2(ftp_PORT_error_no_crlf, nat_t *, nat, ftpside_t *, f);
366f52ace7aSdarrenr if (softf->ipf_p_ftp_debug & DEBUG_PARSE_ERR)
367ecd7789bSchristos printf("ipf_p_ftp_port:missing %s\n", "cr-lf");
368ecd7789bSchristos return 0;
369ecd7789bSchristos }
370f52ace7aSdarrenr s += 2;
371f52ace7aSdarrenr a6 = a5 & 0xff;
372ecd7789bSchristos
373f52ace7aSdarrenr /*
374f52ace7aSdarrenr * Calculate the source port. Verification of > 1024 is in
375f52ace7aSdarrenr * ipf_p_ftp_addport.
376f52ace7aSdarrenr */
377ecd7789bSchristos a5 >>= 8;
378ecd7789bSchristos a5 &= 0xff;
379ecd7789bSchristos sp = a5 << 8 | a6;
380f52ace7aSdarrenr
381ecd7789bSchristos /*
382ecd7789bSchristos * Calculate new address parts for PORT command
383ecd7789bSchristos */
384ecd7789bSchristos if (nat->nat_dir == NAT_INBOUND)
385f52ace7aSdarrenr a1 = ntohl(nat->nat_ndstaddr);
386ecd7789bSchristos else
387ecd7789bSchristos a1 = ntohl(ip->ip_src.s_addr);
388f52ace7aSdarrenr a1 = ntohl(ip->ip_src.s_addr);
389ecd7789bSchristos a2 = (a1 >> 16) & 0xff;
390ecd7789bSchristos a3 = (a1 >> 8) & 0xff;
391ecd7789bSchristos a4 = a1 & 0xff;
392ecd7789bSchristos a1 >>= 24;
393ecd7789bSchristos olen = s - f->ftps_rptr;
394ae8e75c8Schristos snprintf(newbuf, sizeof(newbuf), "%s %u,%u,%u,%u,%u,%u\r\n",
395ecd7789bSchristos "PORT", a1, a2, a3, a4, a5, a6);
396ecd7789bSchristos
397ecd7789bSchristos nlen = strlen(newbuf);
398ecd7789bSchristos inc = nlen - olen;
399ecd7789bSchristos if ((inc + fin->fin_plen) > 65535) {
400f52ace7aSdarrenr DT3(ftp_PORT_error_inc, nat_t *, nat, ftpside_t *, f,
401f52ace7aSdarrenr int, inc);
402f52ace7aSdarrenr if (softf->ipf_p_ftp_debug & DEBUG_ERROR)
403ecd7789bSchristos printf("ipf_p_ftp_port:inc(%d) + ip->ip_len > 65535\n",
404ecd7789bSchristos inc);
405ecd7789bSchristos return 0;
406ecd7789bSchristos }
407ecd7789bSchristos
408ecd7789bSchristos #if !defined(_KERNEL)
409f52ace7aSdarrenr M_ADJ(m, inc);
410ecd7789bSchristos #else
411ecd7789bSchristos /*
412ecd7789bSchristos * m_adj takes care of pkthdr.len, if required and treats inc<0 to
413ecd7789bSchristos * mean remove -len bytes from the end of the packet.
414ecd7789bSchristos * The mbuf chain will be extended if necessary by m_copyback().
415ecd7789bSchristos */
416ecd7789bSchristos if (inc < 0)
417ecd7789bSchristos M_ADJ(m, inc);
418ecd7789bSchristos #endif /* !defined(_KERNEL) */
419ecd7789bSchristos COPYBACK(m, off, nlen, newbuf);
420f52ace7aSdarrenr fin->fin_flx |= FI_DOCKSUM;
421ecd7789bSchristos
422ecd7789bSchristos if (inc != 0) {
423ecd7789bSchristos fin->fin_plen += inc;
424ecd7789bSchristos ip->ip_len = htons(fin->fin_plen);
425ecd7789bSchristos fin->fin_dlen += inc;
426ecd7789bSchristos }
427ecd7789bSchristos
428ecd7789bSchristos f->ftps_cmd = FTPXY_C_PORT;
429f52ace7aSdarrenr return ipf_p_ftp_addport(softf, fin, ip, nat, ftp, dlen, sp, inc);
430ecd7789bSchristos }
431ecd7789bSchristos
432ecd7789bSchristos
433ecd7789bSchristos int
ipf_p_ftp_addport(ipf_ftp_softc_t * softf,fr_info_t * fin,ip_t * ip,nat_t * nat,ftpinfo_t * ftp,int dlen,int nport,int inc)434f330e785Schristos ipf_p_ftp_addport(ipf_ftp_softc_t *softf, fr_info_t *fin, ip_t *ip, nat_t *nat,
435f330e785Schristos ftpinfo_t *ftp, int dlen, int nport, int inc)
436ecd7789bSchristos {
437ecd7789bSchristos tcphdr_t tcph, *tcp2 = &tcph;
438ecd7789bSchristos ipf_main_softc_t *softc;
439ecd7789bSchristos ipf_nat_softc_t *softn;
440f52ace7aSdarrenr int direction;
441ecd7789bSchristos fr_info_t fi;
442f52ace7aSdarrenr ipnat_t *ipn;
443ecd7789bSchristos nat_t *nat2;
444ecd7789bSchristos u_short sp;
445ecd7789bSchristos int flags;
446ecd7789bSchristos
447ecd7789bSchristos softc = fin->fin_main_soft;
448ecd7789bSchristos softn = softc->ipf_nat_soft;
449ecd7789bSchristos
450ecd7789bSchristos if ((ftp->ftp_pendnat != NULL) || (ftp->ftp_pendstate != NULL)) {
451ecd7789bSchristos if (softf->ipf_p_ftp_single_xfer != 0) {
452f52ace7aSdarrenr DT2(ftp_PORT_error_add_active, nat_t *, nat,
453f52ace7aSdarrenr ftpinfo_t *, ftp);
454f52ace7aSdarrenr if (softf->ipf_p_ftp_debug & DEBUG_ERROR)
455ecd7789bSchristos printf("ipf_p_ftp_addport:xfer active %p/%p\n",
456ecd7789bSchristos ftp->ftp_pendnat, ftp->ftp_pendstate);
457ecd7789bSchristos return 0;
458ecd7789bSchristos }
459ecd7789bSchristos ipf_p_ftp_setpending(softc, ftp);
460ecd7789bSchristos }
461ecd7789bSchristos
462ecd7789bSchristos /*
463ecd7789bSchristos * Add skeleton NAT entry for connection which will come back the
464ecd7789bSchristos * other way.
465ecd7789bSchristos */
466ecd7789bSchristos sp = nport;
467ecd7789bSchristos /*
468ecd7789bSchristos * Don't allow the PORT command to specify a port < 1024 due to
469f52ace7aSdarrenr * security risks.
470ecd7789bSchristos */
471ecd7789bSchristos if (sp < 1024) {
472f52ace7aSdarrenr DT3(ftp_PORT_error_port, nat_t *, nat, ftpinfo_t *, ftp,
473f52ace7aSdarrenr u_int, sp);
474f52ace7aSdarrenr if (softf->ipf_p_ftp_debug & DEBUG_SECURITY)
475ecd7789bSchristos printf("ipf_p_ftp_addport:sp(%d) < 1024\n", sp);
476ecd7789bSchristos return 0;
477ecd7789bSchristos }
478ecd7789bSchristos /*
479ecd7789bSchristos * The server may not make the connection back from port 20, but
480ecd7789bSchristos * it is the most likely so use it here to check for a conflicting
481ecd7789bSchristos * mapping.
482ecd7789bSchristos */
483ecd7789bSchristos bcopy((char *)fin, (char *)&fi, sizeof(fi));
484ecd7789bSchristos fi.fin_flx |= FI_IGNORE;
485ecd7789bSchristos fi.fin_data[0] = sp;
486ecd7789bSchristos fi.fin_data[1] = fin->fin_data[1] - 1;
487f52ace7aSdarrenr fi.fin_src6 = nat->nat_ndst6;
488f52ace7aSdarrenr fi.fin_dst6 = nat->nat_nsrc6;
489f52ace7aSdarrenr
490f52ace7aSdarrenr if (nat->nat_v[0] == 6) {
491f52ace7aSdarrenr #ifndef USE_INET6
492f52ace7aSdarrenr return APR_INC(inc);
493f52ace7aSdarrenr #endif
494f52ace7aSdarrenr }
495f52ace7aSdarrenr
496ecd7789bSchristos /*
497ecd7789bSchristos * Add skeleton NAT entry for connection which will come back the
498ecd7789bSchristos * other way.
499ecd7789bSchristos */
500f52ace7aSdarrenr #ifdef USE_INET6
5013373d596Smrg if (nat->nat_v[0] == 6) {
502f52ace7aSdarrenr if (nat->nat_dir == NAT_OUTBOUND) {
503f52ace7aSdarrenr nat2 = ipf_nat6_outlookup(&fi, IPN_TCP|NAT_SEARCH,
504f52ace7aSdarrenr nat->nat_pr[1],
505f52ace7aSdarrenr &nat->nat_osrc6.in6,
506f52ace7aSdarrenr &nat->nat_odst6.in6);
507f52ace7aSdarrenr } else {
508f52ace7aSdarrenr nat2 = ipf_nat6_inlookup(&fi, IPN_TCP|NAT_SEARCH,
509f52ace7aSdarrenr nat->nat_pr[0],
510f52ace7aSdarrenr &nat->nat_odst6.in6,
511f52ace7aSdarrenr &nat->nat_osrc6.in6);
512f52ace7aSdarrenr }
5133373d596Smrg } else
514f52ace7aSdarrenr #endif
5153373d596Smrg {
516f52ace7aSdarrenr if (nat->nat_dir == NAT_OUTBOUND) {
517f52ace7aSdarrenr nat2 = ipf_nat_outlookup(&fi, IPN_TCP|NAT_SEARCH,
518f52ace7aSdarrenr nat->nat_pr[1],
519f52ace7aSdarrenr nat->nat_osrcip,
520ecd7789bSchristos nat->nat_odstip);
521f52ace7aSdarrenr } else {
522f52ace7aSdarrenr nat2 = ipf_nat_inlookup(&fi, IPN_TCP|NAT_SEARCH,
523f52ace7aSdarrenr nat->nat_pr[0],
524f52ace7aSdarrenr nat->nat_odstip,
525f52ace7aSdarrenr nat->nat_osrcip);
526f52ace7aSdarrenr }
527f52ace7aSdarrenr }
528f52ace7aSdarrenr if (nat2 != NULL)
529f52ace7aSdarrenr return APR_INC(inc);
530ecd7789bSchristos
531f52ace7aSdarrenr ipn = ipf_proxy_rule_rev(nat);
532f52ace7aSdarrenr if (ipn == NULL)
533f52ace7aSdarrenr return APR_ERR(1);
534f52ace7aSdarrenr ipn->in_use = 0;
535f52ace7aSdarrenr
536f52ace7aSdarrenr fi.fin_fr = &ftppxyfr;
537f52ace7aSdarrenr fi.fin_dp = (char *)tcp2;
538ecd7789bSchristos fi.fin_dlen = sizeof(*tcp2);
539ecd7789bSchristos fi.fin_plen = fi.fin_hlen + sizeof(*tcp2);
540ecd7789bSchristos fi.fin_flx &= FI_LOWTTL|FI_FRAG|FI_TCPUDP|FI_OPTIONS|FI_IGNORE;
541f52ace7aSdarrenr fi.fin_data[1] = sp;
542f52ace7aSdarrenr fi.fin_data[0] = 0;
543ecd7789bSchristos
544f52ace7aSdarrenr bzero((char *)tcp2, sizeof(*tcp2));
545f52ace7aSdarrenr tcp2->th_sport = 0;
546f52ace7aSdarrenr tcp2->th_dport = htons(sp);
547f52ace7aSdarrenr
548f52ace7aSdarrenr tcp2->th_win = htons(8192);
549f52ace7aSdarrenr TCP_OFF_A(tcp2, 5);
550f52ace7aSdarrenr tcp2->th_flags = TH_SYN;
551f52ace7aSdarrenr
552f52ace7aSdarrenr if (nat->nat_dir == NAT_INBOUND) {
553f52ace7aSdarrenr fi.fin_out = 1;
554f52ace7aSdarrenr direction = NAT_OUTBOUND;
555f52ace7aSdarrenr } else {
556f52ace7aSdarrenr fi.fin_out = 0;
557f52ace7aSdarrenr direction = NAT_INBOUND;
558f52ace7aSdarrenr }
559f52ace7aSdarrenr flags = SI_W_SPORT|NAT_SLAVE|IPN_TCP;
560f52ace7aSdarrenr
561ecd7789bSchristos MUTEX_ENTER(&softn->ipf_nat_new);
562f52ace7aSdarrenr if (nat->nat_v[0] == 6) {
563f52ace7aSdarrenr #ifdef USE_INET6
564f52ace7aSdarrenr nat2 = ipf_nat6_add(&fi, ipn, &ftp->ftp_pendnat, flags,
565f52ace7aSdarrenr direction);
566f52ace7aSdarrenr #endif
567f52ace7aSdarrenr } else {
568f52ace7aSdarrenr nat2 = ipf_nat_add(&fi, ipn, &ftp->ftp_pendnat, flags,
569f52ace7aSdarrenr direction);
570f52ace7aSdarrenr }
571ecd7789bSchristos MUTEX_EXIT(&softn->ipf_nat_new);
572ecd7789bSchristos
573f52ace7aSdarrenr if (nat2 == NULL) {
574f52ace7aSdarrenr KFREES(ipn, ipn->in_size);
575f52ace7aSdarrenr return APR_ERR(1);
576f52ace7aSdarrenr }
577f52ace7aSdarrenr
578ecd7789bSchristos (void) ipf_nat_proto(&fi, nat2, IPN_TCP);
579ecd7789bSchristos MUTEX_ENTER(&nat2->nat_lock);
580ecd7789bSchristos ipf_nat_update(&fi, nat2);
581ecd7789bSchristos MUTEX_EXIT(&nat2->nat_lock);
582ecd7789bSchristos fi.fin_ifp = NULL;
583f52ace7aSdarrenr if (nat2->nat_dir == NAT_INBOUND)
584f52ace7aSdarrenr fi.fin_dst6 = nat->nat_osrc6;
585f52ace7aSdarrenr if (ipf_state_add(softc, &fi, (ipstate_t **)&ftp->ftp_pendstate,
586f52ace7aSdarrenr SI_W_SPORT) != 0)
587ecd7789bSchristos ipf_nat_setpending(softc, nat2);
588f52ace7aSdarrenr
589ecd7789bSchristos return APR_INC(inc);
590ecd7789bSchristos }
591ecd7789bSchristos
592ecd7789bSchristos
593ecd7789bSchristos int
ipf_p_ftp_client(ipf_ftp_softc_t * softf,fr_info_t * fin,ip_t * ip,nat_t * nat,ftpinfo_t * ftp,int dlen)594f330e785Schristos ipf_p_ftp_client(ipf_ftp_softc_t *softf, fr_info_t *fin, ip_t *ip, nat_t *nat,
595f330e785Schristos ftpinfo_t *ftp, int dlen)
596ecd7789bSchristos {
597ecd7789bSchristos char *rptr, *wptr, cmd[6], c;
598ecd7789bSchristos ftpside_t *f;
599ecd7789bSchristos int inc, i;
600ecd7789bSchristos
601ecd7789bSchristos inc = 0;
602ecd7789bSchristos f = &ftp->ftp_side[0];
603ecd7789bSchristos rptr = f->ftps_rptr;
604ecd7789bSchristos wptr = f->ftps_wptr;
605ecd7789bSchristos
606ecd7789bSchristos for (i = 0; (i < 5) && (i < dlen); i++) {
607ecd7789bSchristos c = rptr[i];
608ecd7789bSchristos if (ISALPHA(c)) {
609ecd7789bSchristos cmd[i] = TOUPPER(c);
610ecd7789bSchristos } else {
611ecd7789bSchristos cmd[i] = c;
612ecd7789bSchristos }
613ecd7789bSchristos }
614ecd7789bSchristos cmd[i] = '\0';
615ecd7789bSchristos
616ecd7789bSchristos ftp->ftp_incok = 0;
617f52ace7aSdarrenr DT2(ftp_client_command, char [], cmd, int, ftp->ftp_passok);
618ecd7789bSchristos if (!strncmp(cmd, "USER ", 5) || !strncmp(cmd, "XAUT ", 5)) {
619ecd7789bSchristos if (ftp->ftp_passok == FTPXY_ADOK_1 ||
620ecd7789bSchristos ftp->ftp_passok == FTPXY_AUOK_1) {
621ecd7789bSchristos ftp->ftp_passok = FTPXY_USER_2;
622ecd7789bSchristos ftp->ftp_incok = 1;
623ecd7789bSchristos } else {
624ecd7789bSchristos ftp->ftp_passok = FTPXY_USER_1;
625ecd7789bSchristos ftp->ftp_incok = 1;
626ecd7789bSchristos }
627ecd7789bSchristos } else if (!strncmp(cmd, "AUTH ", 5)) {
628ecd7789bSchristos ftp->ftp_passok = FTPXY_AUTH_1;
629ecd7789bSchristos ftp->ftp_incok = 1;
630ecd7789bSchristos } else if (!strncmp(cmd, "PASS ", 5)) {
631ecd7789bSchristos if (ftp->ftp_passok == FTPXY_USOK_1) {
632ecd7789bSchristos ftp->ftp_passok = FTPXY_PASS_1;
633ecd7789bSchristos ftp->ftp_incok = 1;
634ecd7789bSchristos } else if (ftp->ftp_passok == FTPXY_USOK_2) {
635ecd7789bSchristos ftp->ftp_passok = FTPXY_PASS_2;
636ecd7789bSchristos ftp->ftp_incok = 1;
637ecd7789bSchristos }
638ecd7789bSchristos } else if ((ftp->ftp_passok == FTPXY_AUOK_1) &&
639ecd7789bSchristos !strncmp(cmd, "ADAT ", 5)) {
640ecd7789bSchristos ftp->ftp_passok = FTPXY_ADAT_1;
641ecd7789bSchristos ftp->ftp_incok = 1;
642ecd7789bSchristos } else if ((ftp->ftp_passok == FTPXY_PAOK_1 ||
643ecd7789bSchristos ftp->ftp_passok == FTPXY_PAOK_2) &&
644ecd7789bSchristos !strncmp(cmd, "ACCT ", 5)) {
645ecd7789bSchristos ftp->ftp_passok = FTPXY_ACCT_1;
646ecd7789bSchristos ftp->ftp_incok = 1;
647ecd7789bSchristos } else if ((ftp->ftp_passok == FTPXY_GO) &&
648ecd7789bSchristos !softf->ipf_p_ftp_pasvonly &&
649ecd7789bSchristos !strncmp(cmd, "PORT ", 5)) {
650ecd7789bSchristos inc = ipf_p_ftp_port(softf, fin, ip, nat, ftp, dlen);
651ecd7789bSchristos } else if ((ftp->ftp_passok == FTPXY_GO) &&
652ecd7789bSchristos !softf->ipf_p_ftp_pasvonly &&
653ecd7789bSchristos !strncmp(cmd, "EPRT ", 5)) {
654ecd7789bSchristos inc = ipf_p_ftp_eprt(softf, fin, ip, nat, ftp, dlen);
655ecd7789bSchristos } else if (softf->ipf_p_ftp_insecure &&
656ecd7789bSchristos !softf->ipf_p_ftp_pasvonly &&
657ecd7789bSchristos !strncmp(cmd, "PORT ", 5)) {
658ecd7789bSchristos inc = ipf_p_ftp_port(softf, fin, ip, nat, ftp, dlen);
659ecd7789bSchristos }
660f52ace7aSdarrenr if (softf->ipf_p_ftp_debug & DEBUG_PARSE)
661ecd7789bSchristos printf("ipf_p_ftp_client: cmd[%s] passok %d incok %d inc %d\n",
662ecd7789bSchristos cmd, ftp->ftp_passok, ftp->ftp_incok, inc);
663ecd7789bSchristos
664f52ace7aSdarrenr DT2(ftp_client_passok, char *, cmd, int, ftp->ftp_passok);
665ecd7789bSchristos while ((*rptr++ != '\n') && (rptr < wptr))
666ecd7789bSchristos ;
667ecd7789bSchristos f->ftps_rptr = rptr;
668ecd7789bSchristos return inc;
669ecd7789bSchristos }
670ecd7789bSchristos
671ecd7789bSchristos
672ecd7789bSchristos int
ipf_p_ftp_pasv(ipf_ftp_softc_t * softf,fr_info_t * fin,ip_t * ip,nat_t * nat,ftpinfo_t * ftp,int dlen)673f330e785Schristos ipf_p_ftp_pasv(ipf_ftp_softc_t *softf, fr_info_t *fin, ip_t *ip, nat_t *nat,
674f330e785Schristos ftpinfo_t *ftp, int dlen)
675ecd7789bSchristos {
676ecd7789bSchristos u_int a1, a2, a3, a4, data_ip;
677ecd7789bSchristos char newbuf[IPF_FTPBUFSZ];
678ecd7789bSchristos const char *brackets[2];
679ecd7789bSchristos u_short a5, a6;
680ecd7789bSchristos ftpside_t *f;
681ecd7789bSchristos char *s;
682ecd7789bSchristos
683ecd7789bSchristos if ((softf->ipf_p_ftp_forcepasv != 0) &&
684ecd7789bSchristos (ftp->ftp_side[0].ftps_cmd != FTPXY_C_PASV)) {
685f52ace7aSdarrenr DT2(ftp_PASV_error_state, nat_t *, nat, ftpinfo_t *, ftp);
686f52ace7aSdarrenr if (softf->ipf_p_ftp_debug & DEBUG_ERROR)
687ecd7789bSchristos printf("ipf_p_ftp_pasv:ftps_cmd(%d) != FTPXY_C_PASV\n",
688ecd7789bSchristos ftp->ftp_side[0].ftps_cmd);
689ecd7789bSchristos return 0;
690ecd7789bSchristos }
691ecd7789bSchristos
692ecd7789bSchristos f = &ftp->ftp_side[1];
693ecd7789bSchristos
694ecd7789bSchristos #define PASV_REPLEN 24
695ecd7789bSchristos /*
696ecd7789bSchristos * Check for PASV reply message.
697ecd7789bSchristos */
698ecd7789bSchristos if (dlen < IPF_MIN227LEN) {
699f52ace7aSdarrenr DT3(ftp_PASV_error_short, nat_t *, nat, ftpinfo_t *, ftp,
700f52ace7aSdarrenr int, dlen);
701f52ace7aSdarrenr if (softf->ipf_p_ftp_debug & DEBUG_ERROR)
702ecd7789bSchristos printf("ipf_p_ftp_pasv:dlen(%d) < IPF_MIN227LEN\n",
703ecd7789bSchristos dlen);
704ecd7789bSchristos return 0;
705ecd7789bSchristos } else if (strncmp(f->ftps_rptr,
706ecd7789bSchristos "227 Entering Passive Mod", PASV_REPLEN)) {
707f52ace7aSdarrenr DT2(ftp_PASV_error_string, nat_t *, nat, ftpinfo_t *, ftp);
708f52ace7aSdarrenr if (softf->ipf_p_ftp_debug & DEBUG_PARSE_ERR)
709ecd7789bSchristos printf("ipf_p_ftp_pasv:%d reply wrong\n", 227);
710ecd7789bSchristos return 0;
711ecd7789bSchristos }
712ecd7789bSchristos
713ecd7789bSchristos brackets[0] = "";
714ecd7789bSchristos brackets[1] = "";
715ecd7789bSchristos /*
716ecd7789bSchristos * Skip the PASV reply + space
717ecd7789bSchristos */
718ecd7789bSchristos s = f->ftps_rptr + PASV_REPLEN;
719ecd7789bSchristos while (*s && !ISDIGIT(*s)) {
720ecd7789bSchristos if (*s == '(') {
721ecd7789bSchristos brackets[0] = "(";
722ecd7789bSchristos brackets[1] = ")";
723ecd7789bSchristos }
724ecd7789bSchristos s++;
725ecd7789bSchristos }
726ecd7789bSchristos
727ecd7789bSchristos /*
728ecd7789bSchristos * Pick out the address components, two at a time.
729ecd7789bSchristos */
730ecd7789bSchristos a1 = ipf_p_ftp_atoi(&s);
731ecd7789bSchristos if (s == NULL) {
732f52ace7aSdarrenr DT2(ftp_PASV_error_atoi_1, nat_t *, nat, ftpside_t *, f);
733f52ace7aSdarrenr if (softf->ipf_p_ftp_debug & DEBUG_PARSE_ERR)
734ecd7789bSchristos printf("ipf_p_ftp_pasv:ipf_p_ftp_atoi(%d) failed\n", 1);
735ecd7789bSchristos return 0;
736ecd7789bSchristos }
737ecd7789bSchristos a2 = ipf_p_ftp_atoi(&s);
738ecd7789bSchristos if (s == NULL) {
739f52ace7aSdarrenr DT2(ftp_PASV_error_atoi_2, nat_t *, nat, ftpside_t *, f);
740f52ace7aSdarrenr if (softf->ipf_p_ftp_debug & DEBUG_PARSE_ERR)
741ecd7789bSchristos printf("ipf_p_ftp_pasv:ipf_p_ftp_atoi(%d) failed\n", 2);
742ecd7789bSchristos return 0;
743ecd7789bSchristos }
744ecd7789bSchristos
745ecd7789bSchristos /*
746ecd7789bSchristos * check that IP address in the PASV reply is the same as the
747ecd7789bSchristos * sender of the command - prevents using PASV for port scanning.
748ecd7789bSchristos */
749ecd7789bSchristos a1 <<= 16;
750ecd7789bSchristos a1 |= a2;
751ecd7789bSchristos
752ecd7789bSchristos if (((nat->nat_dir == NAT_INBOUND) &&
753f52ace7aSdarrenr (a1 != ntohl(nat->nat_ndstaddr))) ||
754ecd7789bSchristos ((nat->nat_dir == NAT_OUTBOUND) &&
755ecd7789bSchristos (a1 != ntohl(nat->nat_odstaddr)))) {
756f52ace7aSdarrenr DT3(ftp_PASV_error_address, nat_t *, nat, ftpside_t *, f,
757f52ace7aSdarrenr u_int, a1);
758f52ace7aSdarrenr if (softf->ipf_p_ftp_debug & DEBUG_ERROR)
759ecd7789bSchristos printf("ipf_p_ftp_pasv:%s != nat->nat_oip\n", "a1");
760ecd7789bSchristos return 0;
761ecd7789bSchristos }
762ecd7789bSchristos
763ecd7789bSchristos a5 = ipf_p_ftp_atoi(&s);
764ecd7789bSchristos if (s == NULL) {
765f52ace7aSdarrenr DT2(ftp_PASV_error_atoi_3, nat_t *, nat, ftpside_t *, f);
766f52ace7aSdarrenr if (softf->ipf_p_ftp_debug & DEBUG_PARSE_ERR)
767ecd7789bSchristos printf("ipf_p_ftp_pasv:ipf_p_ftp_atoi(%d) failed\n", 3);
768ecd7789bSchristos return 0;
769ecd7789bSchristos }
770ecd7789bSchristos
771ecd7789bSchristos if (*s == ')')
772ecd7789bSchristos s++;
773ecd7789bSchristos if (*s == '.')
774ecd7789bSchristos s++;
775ecd7789bSchristos if (*s == '\n')
776ecd7789bSchristos s--;
777ecd7789bSchristos /*
778ecd7789bSchristos * check for CR-LF at the end.
779ecd7789bSchristos */
780f52ace7aSdarrenr if ((*s != '\r') || (*(s + 1) != '\n')) {
781f52ace7aSdarrenr DT(pasv_missing_crlf);
782f52ace7aSdarrenr if (softf->ipf_p_ftp_debug & DEBUG_PARSE_ERR)
783ecd7789bSchristos printf("ipf_p_ftp_pasv:missing %s", "cr-lf\n");
784ecd7789bSchristos return 0;
785ecd7789bSchristos }
786f52ace7aSdarrenr s += 2;
787ecd7789bSchristos
788ecd7789bSchristos a6 = a5 & 0xff;
789ecd7789bSchristos a5 >>= 8;
790ecd7789bSchristos /*
791ecd7789bSchristos * Calculate new address parts for 227 reply
792ecd7789bSchristos */
793ecd7789bSchristos if (nat->nat_dir == NAT_INBOUND) {
794f52ace7aSdarrenr data_ip = nat->nat_odstaddr;
795ecd7789bSchristos a1 = ntohl(data_ip);
796ecd7789bSchristos } else
797ecd7789bSchristos data_ip = htonl(a1);
798ecd7789bSchristos
799ecd7789bSchristos a2 = (a1 >> 16) & 0xff;
800ecd7789bSchristos a3 = (a1 >> 8) & 0xff;
801ecd7789bSchristos a4 = a1 & 0xff;
802ecd7789bSchristos a1 >>= 24;
803ecd7789bSchristos
804ae8e75c8Schristos snprintf(newbuf, sizeof(newbuf), "%s %s%u,%u,%u,%u,%u,%u%s\r\n",
805ecd7789bSchristos "227 Entering Passive Mode", brackets[0], a1, a2, a3, a4,
806ecd7789bSchristos a5, a6, brackets[1]);
807ecd7789bSchristos return ipf_p_ftp_pasvreply(softf, fin, ip, nat, ftp, (a5 << 8 | a6),
808f52ace7aSdarrenr newbuf, s);
809ecd7789bSchristos }
810ecd7789bSchristos
811ecd7789bSchristos int
ipf_p_ftp_pasvreply(ipf_ftp_softc_t * softf,fr_info_t * fin,ip_t * ip,nat_t * nat,ftpinfo_t * ftp,u_int port,char * newmsg,char * s)812f330e785Schristos ipf_p_ftp_pasvreply(ipf_ftp_softc_t *softf, fr_info_t *fin, ip_t *ip,
813f52ace7aSdarrenr nat_t *nat, ftpinfo_t *ftp, u_int port, char *newmsg, char *s)
814ecd7789bSchristos {
815f52ace7aSdarrenr int inc, off, nflags;
816ecd7789bSchristos tcphdr_t *tcp, tcph, *tcp2;
817ecd7789bSchristos ipf_main_softc_t *softc;
818ecd7789bSchristos ipf_nat_softc_t *softn;
819ecd7789bSchristos size_t nlen, olen;
820f52ace7aSdarrenr #ifdef USE_INET6
821f52ace7aSdarrenr ip6_t *ip6;
822f52ace7aSdarrenr #endif
823f52ace7aSdarrenr ipnat_t *ipn;
824ecd7789bSchristos fr_info_t fi;
825ecd7789bSchristos ftpside_t *f;
826785bbd87Spgoyette nat_t *nat2 = NULL;
827ecd7789bSchristos mb_t *m;
828ecd7789bSchristos
829ecd7789bSchristos softc = fin->fin_main_soft;
830ecd7789bSchristos softn = softc->ipf_nat_soft;
831ecd7789bSchristos
832ecd7789bSchristos if ((ftp->ftp_pendnat != NULL) || (ftp->ftp_pendstate != NULL))
833ecd7789bSchristos ipf_p_ftp_setpending(softc, ftp);
834ecd7789bSchristos
835ecd7789bSchristos m = fin->fin_m;
836ecd7789bSchristos tcp = (tcphdr_t *)fin->fin_dp;
837ecd7789bSchristos off = (char *)tcp - (char *)ip + (TCP_OFF(tcp) << 2) + fin->fin_ipoff;
838ecd7789bSchristos
839ecd7789bSchristos tcp2 = &tcph;
840ecd7789bSchristos inc = 0;
841ecd7789bSchristos
842ecd7789bSchristos f = &ftp->ftp_side[1];
843ecd7789bSchristos olen = s - f->ftps_rptr;
844ecd7789bSchristos nlen = strlen(newmsg);
845ecd7789bSchristos inc = nlen - olen;
846ecd7789bSchristos if ((inc + fin->fin_plen) > 65535) {
847f52ace7aSdarrenr DT3(ftp_PASV_error_inc, nat_t *, nat, ftpside_t *, f,
848f52ace7aSdarrenr int, inc);
849f52ace7aSdarrenr if (softf->ipf_p_ftp_debug & DEBUG_ERROR)
850ecd7789bSchristos printf("ipf_p_ftp_pasv:inc(%d) + ip->ip_len > 65535\n",
851ecd7789bSchristos inc);
852ecd7789bSchristos return 0;
853ecd7789bSchristos }
854ecd7789bSchristos
855f52ace7aSdarrenr ipn = ipf_proxy_rule_fwd(nat);
856f52ace7aSdarrenr if (ipn == NULL)
857f52ace7aSdarrenr return APR_ERR(1);
858f52ace7aSdarrenr ipn->in_use = 0;
859f52ace7aSdarrenr
860f52ace7aSdarrenr /*
861f52ace7aSdarrenr * Add skeleton NAT entry for connection which will come back the
862f52ace7aSdarrenr * other way.
863f52ace7aSdarrenr */
864f52ace7aSdarrenr bzero((char *)tcp2, sizeof(*tcp2));
865f52ace7aSdarrenr bcopy((char *)fin, (char *)&fi, sizeof(fi));
866f52ace7aSdarrenr fi.fin_flx |= FI_IGNORE;
867f52ace7aSdarrenr fi.fin_data[0] = 0;
868f52ace7aSdarrenr fi.fin_data[1] = port;
869f52ace7aSdarrenr nflags = IPN_TCP|SI_W_SPORT;
870f52ace7aSdarrenr
871f52ace7aSdarrenr fi.fin_fr = &ftppxyfr;
872f52ace7aSdarrenr fi.fin_dp = (char *)tcp2;
873f52ace7aSdarrenr fi.fin_out = 1 - fin->fin_out;
874f52ace7aSdarrenr fi.fin_dlen = sizeof(*tcp2);
875f52ace7aSdarrenr fi.fin_src6 = nat->nat_osrc6;
876f52ace7aSdarrenr fi.fin_dst6 = nat->nat_odst6;
877f52ace7aSdarrenr fi.fin_plen = fi.fin_hlen + sizeof(*tcp);
878f52ace7aSdarrenr fi.fin_flx &= FI_LOWTTL|FI_FRAG|FI_TCPUDP|FI_OPTIONS|FI_IGNORE;
879f52ace7aSdarrenr
880f52ace7aSdarrenr TCP_OFF_A(tcp2, 5);
881f52ace7aSdarrenr tcp2->th_flags = TH_SYN;
882f52ace7aSdarrenr tcp2->th_win = htons(8192);
883f52ace7aSdarrenr tcp2->th_dport = htons(port);
884f52ace7aSdarrenr
885f52ace7aSdarrenr MUTEX_ENTER(&softn->ipf_nat_new);
886f52ace7aSdarrenr if (nat->nat_v[0] == 6) {
887f52ace7aSdarrenr #ifdef USE_INET6
888f52ace7aSdarrenr nat2 = ipf_nat6_add(&fi, ipn, &ftp->ftp_pendnat,
889f52ace7aSdarrenr nflags, nat->nat_dir);
890f52ace7aSdarrenr #endif
891f52ace7aSdarrenr } else {
892f52ace7aSdarrenr nat2 = ipf_nat_add(&fi, ipn, &ftp->ftp_pendnat,
893f52ace7aSdarrenr nflags, nat->nat_dir);
894f52ace7aSdarrenr }
895f52ace7aSdarrenr MUTEX_EXIT(&softn->ipf_nat_new);
896f52ace7aSdarrenr
897f52ace7aSdarrenr if (nat2 == NULL) {
898f52ace7aSdarrenr KFREES(ipn, ipn->in_size);
899f52ace7aSdarrenr return APR_ERR(1);
900f52ace7aSdarrenr }
901f52ace7aSdarrenr
902f52ace7aSdarrenr (void) ipf_nat_proto(&fi, nat2, IPN_TCP);
903f52ace7aSdarrenr MUTEX_ENTER(&nat2->nat_lock);
904f52ace7aSdarrenr ipf_nat_update(&fi, nat2);
905f52ace7aSdarrenr MUTEX_EXIT(&nat2->nat_lock);
906f52ace7aSdarrenr fi.fin_ifp = NULL;
907f52ace7aSdarrenr if (nat->nat_dir == NAT_INBOUND) {
908f52ace7aSdarrenr if (nat->nat_v[0] == 6) {
909f52ace7aSdarrenr #ifdef USE_INET6
910f52ace7aSdarrenr fi.fin_dst6 = nat->nat_ndst6;
911f52ace7aSdarrenr #endif
912f52ace7aSdarrenr } else {
913f52ace7aSdarrenr fi.fin_daddr = nat->nat_ndstaddr;
914f52ace7aSdarrenr }
915f52ace7aSdarrenr }
916f52ace7aSdarrenr if (ipf_state_add(softc, &fi, (ipstate_t **)&ftp->ftp_pendstate,
917f52ace7aSdarrenr SI_W_SPORT) != 0)
918f52ace7aSdarrenr ipf_nat_setpending(softc, nat2);
919f52ace7aSdarrenr
920ecd7789bSchristos #if !defined(_KERNEL)
921f52ace7aSdarrenr M_ADJ(m, inc);
922ecd7789bSchristos #else
923ecd7789bSchristos /*
924ecd7789bSchristos * m_adj takes care of pkthdr.len, if required and treats inc<0 to
925ecd7789bSchristos * mean remove -len bytes from the end of the packet.
926ecd7789bSchristos * The mbuf chain will be extended if necessary by m_copyback().
927ecd7789bSchristos */
928ecd7789bSchristos if (inc < 0)
929ecd7789bSchristos M_ADJ(m, inc);
930ecd7789bSchristos #endif /* !defined(_KERNEL) */
931ecd7789bSchristos COPYBACK(m, off, nlen, newmsg);
932f52ace7aSdarrenr fin->fin_flx |= FI_DOCKSUM;
933ecd7789bSchristos
934ecd7789bSchristos if (inc != 0) {
935ecd7789bSchristos fin->fin_plen += inc;
936ecd7789bSchristos fin->fin_dlen += inc;
937f52ace7aSdarrenr if (nat->nat_v[0] == 6) {
938f52ace7aSdarrenr #ifdef USE_INET6
939f52ace7aSdarrenr ip6 = (ip6_t *)fin->fin_ip;
940f52ace7aSdarrenr u_short len = ntohs(ip6->ip6_plen) + inc;
941f52ace7aSdarrenr ip6->ip6_plen = htons(len);
942f52ace7aSdarrenr #endif
943f52ace7aSdarrenr } else {
944f52ace7aSdarrenr ip->ip_len = htons(fin->fin_plen);
945ecd7789bSchristos }
946ecd7789bSchristos }
947ecd7789bSchristos
948f52ace7aSdarrenr return APR_INC(inc);
949ecd7789bSchristos }
950ecd7789bSchristos
951ecd7789bSchristos
952ecd7789bSchristos int
ipf_p_ftp_server(ipf_ftp_softc_t * softf,fr_info_t * fin,ip_t * ip,nat_t * nat,ftpinfo_t * ftp,int dlen)953f330e785Schristos ipf_p_ftp_server(ipf_ftp_softc_t *softf, fr_info_t *fin, ip_t *ip, nat_t *nat,
954f330e785Schristos ftpinfo_t *ftp, int dlen)
955ecd7789bSchristos {
956ecd7789bSchristos char *rptr, *wptr;
957ecd7789bSchristos ftpside_t *f;
958ecd7789bSchristos int inc;
959ecd7789bSchristos
960ecd7789bSchristos inc = 0;
961ecd7789bSchristos f = &ftp->ftp_side[1];
962ecd7789bSchristos rptr = f->ftps_rptr;
963ecd7789bSchristos wptr = f->ftps_wptr;
964ecd7789bSchristos
965f52ace7aSdarrenr DT2(ftp_server_response, char *, rptr, int, ftp->ftp_passok);
966ecd7789bSchristos if (*rptr == ' ')
967ecd7789bSchristos goto server_cmd_ok;
968ecd7789bSchristos if (!ISDIGIT(*rptr) || !ISDIGIT(*(rptr + 1)) || !ISDIGIT(*(rptr + 2)))
969ecd7789bSchristos return 0;
970f52ace7aSdarrenr if (softf->ipf_p_ftp_debug & DEBUG_PARSE)
971f52ace7aSdarrenr printf("ipf_p_ftp_server_1: cmd[%4.4s] passok %d\n",
972f52ace7aSdarrenr rptr, ftp->ftp_passok);
973ecd7789bSchristos if (ftp->ftp_passok == FTPXY_GO) {
974ecd7789bSchristos if (!strncmp(rptr, "227 ", 4))
975ecd7789bSchristos inc = ipf_p_ftp_pasv(softf, fin, ip, nat, ftp, dlen);
976ecd7789bSchristos else if (!strncmp(rptr, "229 ", 4))
977ecd7789bSchristos inc = ipf_p_ftp_epsv(softf, fin, ip, nat, ftp, dlen);
978ecd7789bSchristos else if (strncmp(rptr, "200", 3)) {
979ecd7789bSchristos /*
980ecd7789bSchristos * 200 is returned for a successful command.
981ecd7789bSchristos */
982ecd7789bSchristos ;
983ecd7789bSchristos }
984ecd7789bSchristos } else if (softf->ipf_p_ftp_insecure && !strncmp(rptr, "227 ", 4)) {
985ecd7789bSchristos inc = ipf_p_ftp_pasv(softf, fin, ip, nat, ftp, dlen);
986ecd7789bSchristos } else if (softf->ipf_p_ftp_insecure && !strncmp(rptr, "229 ", 4)) {
987ecd7789bSchristos inc = ipf_p_ftp_epsv(softf, fin, ip, nat, ftp, dlen);
988ecd7789bSchristos } else if (*rptr == '5' || *rptr == '4')
989ecd7789bSchristos ftp->ftp_passok = FTPXY_INIT;
990ecd7789bSchristos else if (ftp->ftp_incok) {
991ecd7789bSchristos if (*rptr == '3') {
992ecd7789bSchristos if (ftp->ftp_passok == FTPXY_ACCT_1)
993ecd7789bSchristos ftp->ftp_passok = FTPXY_GO;
994ecd7789bSchristos else
995ecd7789bSchristos ftp->ftp_passok++;
996ecd7789bSchristos } else if (*rptr == '2') {
997ecd7789bSchristos switch (ftp->ftp_passok)
998ecd7789bSchristos {
999ecd7789bSchristos case FTPXY_USER_1 :
1000ecd7789bSchristos case FTPXY_USER_2 :
1001ecd7789bSchristos case FTPXY_PASS_1 :
1002ecd7789bSchristos case FTPXY_PASS_2 :
1003ecd7789bSchristos case FTPXY_ACCT_1 :
1004ecd7789bSchristos ftp->ftp_passok = FTPXY_GO;
1005ecd7789bSchristos break;
1006ecd7789bSchristos default :
1007ecd7789bSchristos ftp->ftp_passok += 3;
1008ecd7789bSchristos break;
1009ecd7789bSchristos }
1010ecd7789bSchristos }
1011ecd7789bSchristos }
1012ecd7789bSchristos ftp->ftp_incok = 0;
1013f52ace7aSdarrenr server_cmd_ok:
1014f52ace7aSdarrenr if (softf->ipf_p_ftp_debug & DEBUG_PARSE)
1015f52ace7aSdarrenr printf("ipf_p_ftp_server_2: cmd[%4.4s] passok %d\n",
1016f52ace7aSdarrenr rptr, ftp->ftp_passok);
1017f52ace7aSdarrenr DT3(ftp_server_passok, char *,rptr, int, ftp->ftp_incok,
1018f52ace7aSdarrenr int, ftp->ftp_passok);
1019ecd7789bSchristos
1020ecd7789bSchristos while ((*rptr++ != '\n') && (rptr < wptr))
1021ecd7789bSchristos ;
1022ecd7789bSchristos f->ftps_rptr = rptr;
1023ecd7789bSchristos return inc;
1024ecd7789bSchristos }
1025ecd7789bSchristos
1026ecd7789bSchristos
1027ecd7789bSchristos /*
1028f52ace7aSdarrenr * 0 FTPXY_JUNK_OK
1029f52ace7aSdarrenr * 1 FTPXY_JUNK_BAD
1030f52ace7aSdarrenr * 2 FTPXY_JUNK_EOL
1031f52ace7aSdarrenr * 3 FTPXY_JUNK_CONT
1032f52ace7aSdarrenr *
1033ecd7789bSchristos * Look to see if the buffer starts with something which we recognise as
1034ecd7789bSchristos * being the correct syntax for the FTP protocol.
1035ecd7789bSchristos */
1036ecd7789bSchristos int
ipf_p_ftp_client_valid(ipf_ftp_softc_t * softf,ftpside_t * ftps,char * buf,size_t len)1037f330e785Schristos ipf_p_ftp_client_valid(ipf_ftp_softc_t *softf, ftpside_t *ftps, char *buf,
1038f330e785Schristos size_t len)
1039ecd7789bSchristos {
1040ecd7789bSchristos register char *s, c, pc;
1041ecd7789bSchristos register size_t i = len;
1042ecd7789bSchristos char cmd[5];
1043ecd7789bSchristos
1044ecd7789bSchristos s = buf;
1045ecd7789bSchristos
1046ecd7789bSchristos if (ftps->ftps_junk == FTPXY_JUNK_BAD)
1047ecd7789bSchristos return FTPXY_JUNK_BAD;
1048ecd7789bSchristos
1049ecd7789bSchristos if (i < 5) {
1050f52ace7aSdarrenr DT1(client_valid, int, i);
1051f52ace7aSdarrenr if (softf->ipf_p_ftp_debug & DEBUG_ERROR)
1052ecd7789bSchristos printf("ipf_p_ftp_client_valid:i(%d) < 5\n", (int)i);
1053ecd7789bSchristos return 2;
1054ecd7789bSchristos }
1055ecd7789bSchristos
1056ecd7789bSchristos i--;
1057ecd7789bSchristos c = *s++;
1058ecd7789bSchristos
1059ecd7789bSchristos if (ISALPHA(c)) {
1060ecd7789bSchristos cmd[0] = TOUPPER(c);
1061ecd7789bSchristos c = *s++;
1062ecd7789bSchristos i--;
1063ecd7789bSchristos if (ISALPHA(c)) {
1064ecd7789bSchristos cmd[1] = TOUPPER(c);
1065ecd7789bSchristos c = *s++;
1066ecd7789bSchristos i--;
1067ecd7789bSchristos if (ISALPHA(c)) {
1068ecd7789bSchristos cmd[2] = TOUPPER(c);
1069ecd7789bSchristos c = *s++;
1070ecd7789bSchristos i--;
1071ecd7789bSchristos if (ISALPHA(c)) {
1072ecd7789bSchristos cmd[3] = TOUPPER(c);
1073ecd7789bSchristos c = *s++;
1074ecd7789bSchristos i--;
1075ecd7789bSchristos if ((c != ' ') && (c != '\r'))
1076ecd7789bSchristos goto bad_client_command;
1077ecd7789bSchristos } else if ((c != ' ') && (c != '\r'))
1078ecd7789bSchristos goto bad_client_command;
1079ecd7789bSchristos } else
1080ecd7789bSchristos goto bad_client_command;
1081ecd7789bSchristos } else
1082ecd7789bSchristos goto bad_client_command;
1083ecd7789bSchristos } else {
1084ecd7789bSchristos bad_client_command:
1085f52ace7aSdarrenr DT4(client_junk, int, len, int, i, int, c, char *, buf);
1086f52ace7aSdarrenr if (softf->ipf_p_ftp_debug & DEBUG_PARSE_ERR)
1087ecd7789bSchristos printf("%s:bad:junk %d len %d/%d c 0x%x buf [%*.*s]\n",
1088ecd7789bSchristos "ipf_p_ftp_client_valid",
1089ecd7789bSchristos ftps->ftps_junk, (int)len, (int)i, c,
1090ecd7789bSchristos (int)len, (int)len, buf);
1091ecd7789bSchristos return FTPXY_JUNK_BAD;
1092ecd7789bSchristos }
1093ecd7789bSchristos
1094ecd7789bSchristos for (; i; i--) {
1095ecd7789bSchristos pc = c;
1096ecd7789bSchristos c = *s++;
1097ecd7789bSchristos if ((pc == '\r') && (c == '\n')) {
1098ecd7789bSchristos cmd[4] = '\0';
1099f52ace7aSdarrenr if (!strcmp(cmd, "PASV")) {
1100ecd7789bSchristos ftps->ftps_cmd = FTPXY_C_PASV;
1101f52ace7aSdarrenr } else if (!strcmp(cmd, "EPSV")) {
1102f52ace7aSdarrenr ftps->ftps_cmd = FTPXY_C_EPSV;
1103f52ace7aSdarrenr } else {
1104ecd7789bSchristos ftps->ftps_cmd = 0;
1105f52ace7aSdarrenr }
1106ecd7789bSchristos return 0;
1107ecd7789bSchristos }
1108ecd7789bSchristos }
1109ecd7789bSchristos #if !defined(_KERNEL)
1110ecd7789bSchristos printf("ipf_p_ftp_client_valid:junk after cmd[%*.*s]\n",
1111ecd7789bSchristos (int)len, (int)len, buf);
1112ecd7789bSchristos #endif
1113ecd7789bSchristos return FTPXY_JUNK_EOL;
1114ecd7789bSchristos }
1115ecd7789bSchristos
1116ecd7789bSchristos
1117ecd7789bSchristos int
ipf_p_ftp_server_valid(ipf_ftp_softc_t * softf,ftpside_t * ftps,char * buf,size_t len)1118f330e785Schristos ipf_p_ftp_server_valid(ipf_ftp_softc_t *softf, ftpside_t *ftps, char *buf,
1119f330e785Schristos size_t len)
1120ecd7789bSchristos {
1121ecd7789bSchristos register char *s, c, pc;
1122ecd7789bSchristos register size_t i = len;
1123ecd7789bSchristos int cmd;
1124ecd7789bSchristos
1125ecd7789bSchristos s = buf;
1126ecd7789bSchristos cmd = 0;
1127ecd7789bSchristos
1128ecd7789bSchristos if (ftps->ftps_junk == FTPXY_JUNK_BAD)
1129ecd7789bSchristos return FTPXY_JUNK_BAD;
1130ecd7789bSchristos
1131ecd7789bSchristos if (i < 5) {
1132f52ace7aSdarrenr DT1(server_valid, int, i);
1133f52ace7aSdarrenr if (softf->ipf_p_ftp_debug & DEBUG_PARSE_ERR)
1134ecd7789bSchristos printf("ipf_p_ftp_servert_valid:i(%d) < 5\n", (int)i);
1135ecd7789bSchristos return 2;
1136ecd7789bSchristos }
1137ecd7789bSchristos
1138ecd7789bSchristos c = *s++;
1139ecd7789bSchristos i--;
1140ecd7789bSchristos if (c == ' ') {
1141ecd7789bSchristos cmd = -1;
1142ecd7789bSchristos goto search_eol;
1143ecd7789bSchristos }
1144ecd7789bSchristos
1145ecd7789bSchristos if (ISDIGIT(c)) {
1146ecd7789bSchristos cmd = (c - '0') * 100;
1147ecd7789bSchristos c = *s++;
1148ecd7789bSchristos i--;
1149ecd7789bSchristos if (ISDIGIT(c)) {
1150ecd7789bSchristos cmd += (c - '0') * 10;
1151ecd7789bSchristos c = *s++;
1152ecd7789bSchristos i--;
1153ecd7789bSchristos if (ISDIGIT(c)) {
1154ecd7789bSchristos cmd += (c - '0');
1155ecd7789bSchristos c = *s++;
1156ecd7789bSchristos i--;
1157ecd7789bSchristos if ((c != '-') && (c != ' '))
1158ecd7789bSchristos goto bad_server_command;
1159ecd7789bSchristos if (c == '-')
1160ecd7789bSchristos return FTPXY_JUNK_CONT;
1161ecd7789bSchristos } else
1162ecd7789bSchristos goto bad_server_command;
1163ecd7789bSchristos } else
1164ecd7789bSchristos goto bad_server_command;
1165ecd7789bSchristos } else {
1166ecd7789bSchristos bad_server_command:
1167f52ace7aSdarrenr DT4(server_junk, int len, buf, int, i, int, c, char *, buf);
1168f52ace7aSdarrenr if (softf->ipf_p_ftp_debug & DEBUG_PARSE_INFO)
1169ecd7789bSchristos printf("%s:bad:junk %d len %d/%d c 0x%x buf [%*.*s]\n",
1170ecd7789bSchristos "ipf_p_ftp_server_valid",
1171ecd7789bSchristos ftps->ftps_junk, (int)len, (int)i,
1172ecd7789bSchristos c, (int)len, (int)len, buf);
1173ecd7789bSchristos if (ftps->ftps_junk == FTPXY_JUNK_CONT)
1174ecd7789bSchristos return FTPXY_JUNK_CONT;
1175ecd7789bSchristos return FTPXY_JUNK_BAD;
1176ecd7789bSchristos }
1177ecd7789bSchristos search_eol:
1178ecd7789bSchristos for (; i; i--) {
1179ecd7789bSchristos pc = c;
1180ecd7789bSchristos c = *s++;
1181ecd7789bSchristos if ((pc == '\r') && (c == '\n')) {
1182ecd7789bSchristos if (cmd == -1) {
1183ecd7789bSchristos if (ftps->ftps_junk == FTPXY_JUNK_CONT)
1184ecd7789bSchristos return FTPXY_JUNK_CONT;
1185ecd7789bSchristos } else {
1186ecd7789bSchristos ftps->ftps_cmd = cmd;
1187ecd7789bSchristos }
1188ecd7789bSchristos return FTPXY_JUNK_OK;
1189ecd7789bSchristos }
1190ecd7789bSchristos }
1191f52ace7aSdarrenr
1192f52ace7aSdarrenr DT2(junk_eol, int, len, char *, buf);
1193f52ace7aSdarrenr if (softf->ipf_p_ftp_debug & DEBUG_PARSE_INFO)
1194ecd7789bSchristos printf("ipf_p_ftp_server_valid:junk after cmd[%*.*s]\n",
1195ecd7789bSchristos (int)len, (int)len, buf);
1196ecd7789bSchristos return FTPXY_JUNK_EOL;
1197ecd7789bSchristos }
1198ecd7789bSchristos
1199ecd7789bSchristos
1200ecd7789bSchristos int
ipf_p_ftp_valid(ipf_ftp_softc_t * softf,ftpinfo_t * ftp,int side,char * buf,size_t len)1201f330e785Schristos ipf_p_ftp_valid(ipf_ftp_softc_t *softf, ftpinfo_t *ftp, int side, char *buf,
1202f330e785Schristos size_t len)
1203ecd7789bSchristos {
1204ecd7789bSchristos ftpside_t *ftps;
1205ecd7789bSchristos int ret;
1206ecd7789bSchristos
1207ecd7789bSchristos ftps = &ftp->ftp_side[side];
1208ecd7789bSchristos
1209ecd7789bSchristos if (side == 0)
1210ecd7789bSchristos ret = ipf_p_ftp_client_valid(softf, ftps, buf, len);
1211ecd7789bSchristos else
1212ecd7789bSchristos ret = ipf_p_ftp_server_valid(softf, ftps, buf, len);
1213ecd7789bSchristos return ret;
1214ecd7789bSchristos }
1215ecd7789bSchristos
1216ecd7789bSchristos
1217ecd7789bSchristos /*
1218ecd7789bSchristos * For map rules, the following applies:
1219ecd7789bSchristos * rv == 0 for outbound processing,
1220ecd7789bSchristos * rv == 1 for inbound processing.
1221ecd7789bSchristos * For rdr rules, the following applies:
1222ecd7789bSchristos * rv == 0 for inbound processing,
1223ecd7789bSchristos * rv == 1 for outbound processing.
1224ecd7789bSchristos */
1225ecd7789bSchristos int
ipf_p_ftp_process(ipf_ftp_softc_t * softf,fr_info_t * fin,nat_t * nat,ftpinfo_t * ftp,int rv)1226f330e785Schristos ipf_p_ftp_process(ipf_ftp_softc_t *softf, fr_info_t *fin, nat_t *nat,
1227f330e785Schristos ftpinfo_t *ftp, int rv)
1228ecd7789bSchristos {
1229ecd7789bSchristos int mlen, len, off, inc, i, sel, sel2, ok, ackoff, seqoff, retry;
1230ecd7789bSchristos char *rptr, *wptr, *s;
1231ecd7789bSchristos u_32_t thseq, thack;
1232ecd7789bSchristos ap_session_t *aps;
1233ecd7789bSchristos ftpside_t *f, *t;
1234ecd7789bSchristos tcphdr_t *tcp;
1235ecd7789bSchristos ip_t *ip;
1236ecd7789bSchristos mb_t *m;
1237ecd7789bSchristos
1238ecd7789bSchristos m = fin->fin_m;
1239ecd7789bSchristos ip = fin->fin_ip;
1240ecd7789bSchristos tcp = (tcphdr_t *)fin->fin_dp;
1241ecd7789bSchristos off = (char *)tcp - (char *)ip + (TCP_OFF(tcp) << 2) + fin->fin_ipoff;
1242ecd7789bSchristos
1243ecd7789bSchristos f = &ftp->ftp_side[rv];
1244ecd7789bSchristos t = &ftp->ftp_side[1 - rv];
1245ecd7789bSchristos thseq = ntohl(tcp->th_seq);
1246ecd7789bSchristos thack = ntohl(tcp->th_ack);
1247ecd7789bSchristos #ifdef __sgi
1248ecd7789bSchristos mlen = fin->fin_plen - off;
1249ecd7789bSchristos #else
1250ecd7789bSchristos mlen = MSGDSIZE(m) - off;
1251ecd7789bSchristos #endif
1252f52ace7aSdarrenr
1253f52ace7aSdarrenr DT3(process_debug, tcphdr_t *, tcp, int, off, int, mlen);
1254f52ace7aSdarrenr if (softf->ipf_p_ftp_debug & DEBUG_INFO)
1255f52ace7aSdarrenr printf("ipf_p_ftp_process: %d:%d,%d, mlen %d flags %x\n",
1256f52ace7aSdarrenr fin->fin_out, fin->fin_sport, fin->fin_dport,
1257f52ace7aSdarrenr mlen, tcp->th_flags);
1258ecd7789bSchristos
1259ecd7789bSchristos if ((mlen == 0) && ((tcp->th_flags & TH_OPENING) == TH_OPENING)) {
1260ecd7789bSchristos f->ftps_seq[0] = thseq + 1;
1261ecd7789bSchristos t->ftps_seq[0] = thack;
1262ecd7789bSchristos return 0;
1263ecd7789bSchristos } else if (mlen < 0) {
1264ecd7789bSchristos return 0;
1265ecd7789bSchristos }
1266ecd7789bSchristos
1267ecd7789bSchristos aps = nat->nat_aps;
1268ecd7789bSchristos
1269ecd7789bSchristos sel = aps->aps_sel[1 - rv];
1270ecd7789bSchristos sel2 = aps->aps_sel[rv];
1271f52ace7aSdarrenr if (rv == 1) {
1272ecd7789bSchristos seqoff = aps->aps_seqoff[sel];
1273ecd7789bSchristos if (aps->aps_seqmin[sel] > seqoff + thseq)
1274ecd7789bSchristos seqoff = aps->aps_seqoff[!sel];
1275ecd7789bSchristos ackoff = aps->aps_ackoff[sel2];
1276ecd7789bSchristos if (aps->aps_ackmin[sel2] > ackoff + thack)
1277ecd7789bSchristos ackoff = aps->aps_ackoff[!sel2];
1278ecd7789bSchristos } else {
1279ecd7789bSchristos seqoff = aps->aps_ackoff[sel];
1280f52ace7aSdarrenr if (softf->ipf_p_ftp_debug & DEBUG_INFO)
1281ecd7789bSchristos printf("seqoff %d thseq %x ackmin %x\n", seqoff, thseq,
1282ecd7789bSchristos aps->aps_ackmin[sel]);
1283ecd7789bSchristos if (aps->aps_ackmin[sel] > seqoff + thseq)
1284ecd7789bSchristos seqoff = aps->aps_ackoff[!sel];
1285ecd7789bSchristos
1286ecd7789bSchristos ackoff = aps->aps_seqoff[sel2];
1287f52ace7aSdarrenr if (softf->ipf_p_ftp_debug & DEBUG_INFO)
1288ecd7789bSchristos printf("ackoff %d thack %x seqmin %x\n", ackoff, thack,
1289ecd7789bSchristos aps->aps_seqmin[sel2]);
1290ecd7789bSchristos if (ackoff > 0) {
1291ecd7789bSchristos if (aps->aps_seqmin[sel2] > ackoff + thack)
1292ecd7789bSchristos ackoff = aps->aps_seqoff[!sel2];
1293ecd7789bSchristos } else {
1294ecd7789bSchristos if (aps->aps_seqmin[sel2] > thack)
1295ecd7789bSchristos ackoff = aps->aps_seqoff[!sel2];
1296ecd7789bSchristos }
1297ecd7789bSchristos }
1298f52ace7aSdarrenr if (softf->ipf_p_ftp_debug & DEBUG_INFO) {
1299ecd7789bSchristos printf("%s: %x seq %x/%d ack %x/%d len %d/%d off %d\n",
1300ecd7789bSchristos rv ? "IN" : "OUT", tcp->th_flags, thseq, seqoff,
1301ecd7789bSchristos thack, ackoff, mlen, fin->fin_plen, off);
1302ecd7789bSchristos printf("sel %d seqmin %x/%x offset %d/%d\n", sel,
1303ecd7789bSchristos aps->aps_seqmin[sel], aps->aps_seqmin[sel2],
1304ecd7789bSchristos aps->aps_seqoff[sel], aps->aps_seqoff[sel2]);
1305ecd7789bSchristos printf("sel %d ackmin %x/%x offset %d/%d\n", sel2,
1306ecd7789bSchristos aps->aps_ackmin[sel], aps->aps_ackmin[sel2],
1307ecd7789bSchristos aps->aps_ackoff[sel], aps->aps_ackoff[sel2]);
1308ecd7789bSchristos }
1309ecd7789bSchristos
1310ecd7789bSchristos /*
1311ecd7789bSchristos * XXX - Ideally, this packet should get dropped because we now know
1312ecd7789bSchristos * that it is out of order (and there is no real danger in doing so
1313ecd7789bSchristos * apart from causing packets to go through here ordered).
1314ecd7789bSchristos */
1315f52ace7aSdarrenr if (softf->ipf_p_ftp_debug & DEBUG_INFO) {
1316ecd7789bSchristos printf("rv %d t:seq[0] %x seq[1] %x %d/%d\n",
1317ecd7789bSchristos rv, t->ftps_seq[0], t->ftps_seq[1], seqoff, ackoff);
1318ecd7789bSchristos }
1319ecd7789bSchristos
1320ecd7789bSchristos ok = 0;
1321ecd7789bSchristos if (t->ftps_seq[0] == 0) {
1322ecd7789bSchristos t->ftps_seq[0] = thack;
1323ecd7789bSchristos ok = 1;
1324ecd7789bSchristos } else {
1325ecd7789bSchristos if (ackoff == 0) {
1326ecd7789bSchristos if (t->ftps_seq[0] == thack)
1327ecd7789bSchristos ok = 1;
1328ecd7789bSchristos else if (t->ftps_seq[1] == thack) {
1329ecd7789bSchristos t->ftps_seq[0] = thack;
1330ecd7789bSchristos ok = 1;
1331ecd7789bSchristos }
1332ecd7789bSchristos } else {
1333f52ace7aSdarrenr if (t->ftps_seq[0] + ackoff == thack) {
1334f52ace7aSdarrenr t->ftps_seq[0] = thack;
1335ecd7789bSchristos ok = 1;
1336f52ace7aSdarrenr } else if (t->ftps_seq[0] == thack + ackoff) {
1337f52ace7aSdarrenr t->ftps_seq[0] = thack + ackoff;
1338ecd7789bSchristos ok = 1;
1339f52ace7aSdarrenr } else if (t->ftps_seq[1] + ackoff == thack) {
1340f52ace7aSdarrenr t->ftps_seq[0] = thack;
1341ecd7789bSchristos ok = 1;
1342ecd7789bSchristos } else if (t->ftps_seq[1] == thack + ackoff) {
1343f52ace7aSdarrenr t->ftps_seq[0] = thack + ackoff;
1344ecd7789bSchristos ok = 1;
1345ecd7789bSchristos }
1346ecd7789bSchristos }
1347ecd7789bSchristos }
1348ecd7789bSchristos
1349f52ace7aSdarrenr if (softf->ipf_p_ftp_debug & DEBUG_INFO) {
1350ecd7789bSchristos if (!ok)
1351ecd7789bSchristos printf("%s ok\n", "not");
1352ecd7789bSchristos }
1353ecd7789bSchristos
1354ecd7789bSchristos if (!mlen) {
1355f52ace7aSdarrenr if (t->ftps_seq[0] + ackoff != thack &&
1356f52ace7aSdarrenr t->ftps_seq[1] + ackoff != thack) {
1357f52ace7aSdarrenr DT3(thack, ftpside_t *t, t, int, ackoff, u_32_t, thack);
1358f52ace7aSdarrenr if (softf->ipf_p_ftp_debug & DEBUG_ERROR) {
1359f52ace7aSdarrenr printf("%s:seq[0](%u) + (%d) != (%u)\n",
1360ecd7789bSchristos "ipf_p_ftp_process", t->ftps_seq[0],
1361ecd7789bSchristos ackoff, thack);
1362f52ace7aSdarrenr printf("%s:seq[0](%u) + (%d) != (%u)\n",
1363f52ace7aSdarrenr "ipf_p_ftp_process", t->ftps_seq[1],
1364f52ace7aSdarrenr ackoff, thack);
1365ecd7789bSchristos }
1366ecd7789bSchristos return APR_ERR(1);
1367ecd7789bSchristos }
1368ecd7789bSchristos
1369f52ace7aSdarrenr if (softf->ipf_p_ftp_debug & DEBUG_PARSE) {
1370ecd7789bSchristos printf("ipf_p_ftp_process:f:seq[0] %x seq[1] %x\n",
1371ecd7789bSchristos f->ftps_seq[0], f->ftps_seq[1]);
1372ecd7789bSchristos }
1373ecd7789bSchristos
1374ecd7789bSchristos if (tcp->th_flags & TH_FIN) {
1375ecd7789bSchristos if (thseq == f->ftps_seq[1]) {
1376ecd7789bSchristos f->ftps_seq[0] = f->ftps_seq[1] - seqoff;
1377ecd7789bSchristos f->ftps_seq[1] = thseq + 1 - seqoff;
1378ecd7789bSchristos } else {
1379f52ace7aSdarrenr DT2(thseq, ftpside_t *t, t, u_32_t, thseq);
1380f52ace7aSdarrenr if (softf->ipf_p_ftp_debug & DEBUG_ERROR) {
1381ecd7789bSchristos printf("FIN: thseq %x seqoff %d ftps_seq %x\n",
1382ecd7789bSchristos thseq, seqoff, f->ftps_seq[0]);
1383ecd7789bSchristos }
1384ecd7789bSchristos return APR_ERR(1);
1385ecd7789bSchristos }
1386ecd7789bSchristos }
1387ecd7789bSchristos f->ftps_len = 0;
1388ecd7789bSchristos return 0;
1389ecd7789bSchristos }
1390ecd7789bSchristos
1391ecd7789bSchristos ok = 0;
1392ecd7789bSchristos if ((thseq == f->ftps_seq[0]) || (thseq == f->ftps_seq[1])) {
1393ecd7789bSchristos ok = 1;
1394ecd7789bSchristos /*
1395ecd7789bSchristos * Retransmitted data packet.
1396ecd7789bSchristos */
1397ecd7789bSchristos } else if ((thseq + mlen == f->ftps_seq[0]) ||
1398ecd7789bSchristos (thseq + mlen == f->ftps_seq[1])) {
1399ecd7789bSchristos ok = 1;
1400ecd7789bSchristos }
1401ecd7789bSchristos
1402ecd7789bSchristos if (ok == 0) {
1403f52ace7aSdarrenr DT3(ok_0, ftpside_t *, f, u_32_t, thseq, int, mlen);
1404ecd7789bSchristos inc = thseq - f->ftps_seq[0];
1405f52ace7aSdarrenr if (softf->ipf_p_ftp_debug & DEBUG_ERROR) {
1406ecd7789bSchristos printf("inc %d sel %d rv %d\n", inc, sel, rv);
1407ecd7789bSchristos printf("th_seq %x ftps_seq %x/%x\n",
1408ecd7789bSchristos thseq, f->ftps_seq[0], f->ftps_seq[1]);
1409ecd7789bSchristos printf("ackmin %x ackoff %d\n", aps->aps_ackmin[sel],
1410ecd7789bSchristos aps->aps_ackoff[sel]);
1411ecd7789bSchristos printf("seqmin %x seqoff %d\n", aps->aps_seqmin[sel],
1412ecd7789bSchristos aps->aps_seqoff[sel]);
1413ecd7789bSchristos }
1414ecd7789bSchristos
1415ecd7789bSchristos return APR_ERR(1);
1416ecd7789bSchristos }
1417ecd7789bSchristos
1418ecd7789bSchristos inc = 0;
1419ecd7789bSchristos rptr = f->ftps_rptr;
1420ecd7789bSchristos wptr = f->ftps_wptr;
1421ecd7789bSchristos f->ftps_seq[0] = thseq;
1422ecd7789bSchristos f->ftps_seq[1] = f->ftps_seq[0] + mlen;
1423ecd7789bSchristos f->ftps_len = mlen;
1424ecd7789bSchristos
1425ecd7789bSchristos while (mlen > 0) {
1426ecd7789bSchristos len = MIN(mlen, sizeof(f->ftps_buf) - (wptr - rptr));
1427ecd7789bSchristos if (len == 0)
1428ecd7789bSchristos break;
1429ecd7789bSchristos COPYDATA(m, off, len, wptr);
1430ecd7789bSchristos mlen -= len;
1431ecd7789bSchristos off += len;
1432ecd7789bSchristos wptr += len;
1433ecd7789bSchristos
1434ecd7789bSchristos whilemore:
1435f52ace7aSdarrenr if (softf->ipf_p_ftp_debug & DEBUG_PARSE)
1436ecd7789bSchristos printf("%s:len %d/%d off %d wptr %lx junk %d [%*.*s]\n",
1437ecd7789bSchristos "ipf_p_ftp_process",
1438ecd7789bSchristos len, mlen, off, (u_long)wptr, f->ftps_junk,
1439ecd7789bSchristos len, len, rptr);
1440ecd7789bSchristos
1441ecd7789bSchristos f->ftps_wptr = wptr;
1442ecd7789bSchristos if (f->ftps_junk != FTPXY_JUNK_OK) {
1443ecd7789bSchristos i = f->ftps_junk;
1444ecd7789bSchristos f->ftps_junk = ipf_p_ftp_valid(softf, ftp, rv, rptr,
1445ecd7789bSchristos wptr - rptr);
1446f52ace7aSdarrenr DT2(junk_transit, int, i, int, f->ftps_junk);
1447ecd7789bSchristos
1448f52ace7aSdarrenr if (softf->ipf_p_ftp_debug & DEBUG_PARSE)
1449ecd7789bSchristos printf("%s:junk %d -> %d\n",
1450ecd7789bSchristos "ipf_p_ftp_process", i, f->ftps_junk);
1451ecd7789bSchristos
1452ecd7789bSchristos if (f->ftps_junk == FTPXY_JUNK_BAD) {
1453f52ace7aSdarrenr DT(buffer_full);
1454ecd7789bSchristos if (wptr - rptr == sizeof(f->ftps_buf)) {
1455f52ace7aSdarrenr if (softf->ipf_p_ftp_debug &
1456f52ace7aSdarrenr DEBUG_PARSE_INFO)
1457ecd7789bSchristos printf("%s:full buffer\n",
1458ecd7789bSchristos "ipf_p_ftp_process");
1459ecd7789bSchristos f->ftps_rptr = f->ftps_buf;
1460ecd7789bSchristos f->ftps_wptr = f->ftps_buf;
1461ecd7789bSchristos rptr = f->ftps_rptr;
1462ecd7789bSchristos wptr = f->ftps_wptr;
1463ecd7789bSchristos continue;
1464ecd7789bSchristos }
1465ecd7789bSchristos }
1466ecd7789bSchristos }
1467ecd7789bSchristos
1468ecd7789bSchristos while ((f->ftps_junk == FTPXY_JUNK_OK) && (wptr > rptr)) {
1469ecd7789bSchristos len = wptr - rptr;
1470ecd7789bSchristos f->ftps_junk = ipf_p_ftp_valid(softf, ftp, rv,
1471ecd7789bSchristos rptr, len);
1472ecd7789bSchristos
1473f52ace7aSdarrenr if (softf->ipf_p_ftp_debug & DEBUG_PARSE) {
1474ecd7789bSchristos printf("%s=%d len %d rv %d ptr %lx/%lx ",
1475ecd7789bSchristos "ipf_p_ftp_valid",
1476ecd7789bSchristos f->ftps_junk, len, rv, (u_long)rptr,
1477ecd7789bSchristos (u_long)wptr);
1478ecd7789bSchristos printf("buf [%*.*s]\n", len, len, rptr);
1479ecd7789bSchristos }
1480ecd7789bSchristos
1481ecd7789bSchristos if (f->ftps_junk == FTPXY_JUNK_OK) {
1482ecd7789bSchristos f->ftps_cmds++;
1483ecd7789bSchristos f->ftps_rptr = rptr;
1484ecd7789bSchristos if (rv)
1485f52ace7aSdarrenr inc += ipf_p_ftp_server(softf, fin, ip,
1486f52ace7aSdarrenr nat, ftp, len);
1487ecd7789bSchristos else
1488f52ace7aSdarrenr inc += ipf_p_ftp_client(softf, fin, ip,
1489f52ace7aSdarrenr nat, ftp, len);
1490ecd7789bSchristos rptr = f->ftps_rptr;
1491ecd7789bSchristos wptr = f->ftps_wptr;
1492ecd7789bSchristos }
1493ecd7789bSchristos }
1494ecd7789bSchristos
1495ecd7789bSchristos /*
1496ecd7789bSchristos * Off to a bad start so lets just forget about using the
1497ecd7789bSchristos * ftp proxy for this connection.
1498ecd7789bSchristos */
1499ecd7789bSchristos if ((f->ftps_cmds == 0) && (f->ftps_junk == FTPXY_JUNK_BAD)) {
1500ecd7789bSchristos /* f->ftps_seq[1] += inc; */
1501ecd7789bSchristos
1502f52ace7aSdarrenr DT(ftp_junk_cmd);
1503f52ace7aSdarrenr if (softf->ipf_p_ftp_debug & DEBUG_ERROR)
1504ecd7789bSchristos printf("%s:cmds == 0 junk == 1\n",
1505ecd7789bSchristos "ipf_p_ftp_process");
1506ecd7789bSchristos return APR_ERR(2);
1507ecd7789bSchristos }
1508ecd7789bSchristos
1509ecd7789bSchristos retry = 0;
1510ecd7789bSchristos if ((f->ftps_junk != FTPXY_JUNK_OK) && (rptr < wptr)) {
1511ecd7789bSchristos for (s = rptr; s < wptr; s++) {
1512ecd7789bSchristos if ((*s == '\r') && (s + 1 < wptr) &&
1513ecd7789bSchristos (*(s + 1) == '\n')) {
1514ecd7789bSchristos rptr = s + 2;
1515ecd7789bSchristos retry = 1;
1516ecd7789bSchristos if (f->ftps_junk != FTPXY_JUNK_CONT)
1517ecd7789bSchristos f->ftps_junk = FTPXY_JUNK_OK;
1518ecd7789bSchristos break;
1519ecd7789bSchristos }
1520ecd7789bSchristos }
1521ecd7789bSchristos }
1522ecd7789bSchristos
1523ecd7789bSchristos if (rptr == wptr) {
1524ecd7789bSchristos rptr = wptr = f->ftps_buf;
1525ecd7789bSchristos } else {
1526ecd7789bSchristos /*
1527ecd7789bSchristos * Compact the buffer back to the start. The junk
1528ecd7789bSchristos * flag should already be set and because we're not
1529ecd7789bSchristos * throwing away any data, it is preserved from its
1530ecd7789bSchristos * current state.
1531ecd7789bSchristos */
1532ecd7789bSchristos if (rptr > f->ftps_buf) {
1533ecd7789bSchristos bcopy(rptr, f->ftps_buf, wptr - rptr);
1534ecd7789bSchristos wptr -= rptr - f->ftps_buf;
1535ecd7789bSchristos rptr = f->ftps_buf;
1536ecd7789bSchristos }
1537ecd7789bSchristos }
1538ecd7789bSchristos f->ftps_rptr = rptr;
1539ecd7789bSchristos f->ftps_wptr = wptr;
1540ecd7789bSchristos if (retry)
1541ecd7789bSchristos goto whilemore;
1542ecd7789bSchristos }
1543ecd7789bSchristos
1544ecd7789bSchristos /* f->ftps_seq[1] += inc; */
1545ecd7789bSchristos if (tcp->th_flags & TH_FIN)
1546ecd7789bSchristos f->ftps_seq[1]++;
1547f52ace7aSdarrenr if (softf->ipf_p_ftp_debug & DEBUG_PARSE_INFO) {
1548ecd7789bSchristos #ifdef __sgi
1549ecd7789bSchristos mlen = fin->fin_plen;
1550ecd7789bSchristos #else
1551ecd7789bSchristos mlen = MSGDSIZE(m);
1552ecd7789bSchristos #endif
1553ecd7789bSchristos mlen -= off;
1554ecd7789bSchristos printf("ftps_seq[1] = %x inc %d len %d\n",
1555ecd7789bSchristos f->ftps_seq[1], inc, mlen);
1556ecd7789bSchristos }
1557ecd7789bSchristos
1558ecd7789bSchristos f->ftps_rptr = rptr;
1559ecd7789bSchristos f->ftps_wptr = wptr;
1560ecd7789bSchristos return APR_INC(inc);
1561ecd7789bSchristos }
1562ecd7789bSchristos
1563ecd7789bSchristos
1564ecd7789bSchristos int
ipf_p_ftp_out(void * arg,fr_info_t * fin,ap_session_t * aps,nat_t * nat)1565f330e785Schristos ipf_p_ftp_out(void *arg, fr_info_t *fin, ap_session_t *aps, nat_t *nat)
1566ecd7789bSchristos {
1567ecd7789bSchristos ipf_ftp_softc_t *softf = arg;
1568ecd7789bSchristos ftpinfo_t *ftp;
1569ecd7789bSchristos int rev;
1570ecd7789bSchristos
1571ecd7789bSchristos ftp = aps->aps_data;
1572ecd7789bSchristos if (ftp == NULL)
1573ecd7789bSchristos return 0;
1574ecd7789bSchristos
1575ecd7789bSchristos rev = (nat->nat_dir == NAT_OUTBOUND) ? 0 : 1;
1576ecd7789bSchristos if (ftp->ftp_side[1 - rev].ftps_ifp == NULL)
1577ecd7789bSchristos ftp->ftp_side[1 - rev].ftps_ifp = fin->fin_ifp;
1578ecd7789bSchristos
1579ecd7789bSchristos return ipf_p_ftp_process(softf, fin, nat, ftp, rev);
1580ecd7789bSchristos }
1581ecd7789bSchristos
1582ecd7789bSchristos
1583ecd7789bSchristos int
ipf_p_ftp_in(void * arg,fr_info_t * fin,ap_session_t * aps,nat_t * nat)1584f330e785Schristos ipf_p_ftp_in(void *arg, fr_info_t *fin, ap_session_t *aps, nat_t *nat)
1585ecd7789bSchristos {
1586ecd7789bSchristos ipf_ftp_softc_t *softf = arg;
1587ecd7789bSchristos ftpinfo_t *ftp;
1588ecd7789bSchristos int rev;
1589ecd7789bSchristos
1590ecd7789bSchristos ftp = aps->aps_data;
1591ecd7789bSchristos if (ftp == NULL)
1592ecd7789bSchristos return 0;
1593ecd7789bSchristos
1594ecd7789bSchristos rev = (nat->nat_dir == NAT_OUTBOUND) ? 0 : 1;
1595ecd7789bSchristos if (ftp->ftp_side[rev].ftps_ifp == NULL)
1596ecd7789bSchristos ftp->ftp_side[rev].ftps_ifp = fin->fin_ifp;
1597ecd7789bSchristos
1598ecd7789bSchristos return ipf_p_ftp_process(softf, fin, nat, ftp, 1 - rev);
1599ecd7789bSchristos }
1600ecd7789bSchristos
1601ecd7789bSchristos
1602ecd7789bSchristos /*
1603ecd7789bSchristos * ipf_p_ftp_atoi - implement a version of atoi which processes numbers in
1604ecd7789bSchristos * pairs separated by commas (which are expected to be in the range 0 - 255),
1605ecd7789bSchristos * returning a 16 bit number combining either side of the , as the MSB and
1606ecd7789bSchristos * LSB.
1607ecd7789bSchristos */
1608ecd7789bSchristos u_short
ipf_p_ftp_atoi(char ** ptr)1609f330e785Schristos ipf_p_ftp_atoi(char **ptr)
1610ecd7789bSchristos {
1611ecd7789bSchristos register char *s = *ptr, c;
1612ecd7789bSchristos register u_char i = 0, j = 0;
1613ecd7789bSchristos
1614ecd7789bSchristos while (((c = *s++) != '\0') && ISDIGIT(c)) {
1615ecd7789bSchristos i *= 10;
1616ecd7789bSchristos i += c - '0';
1617ecd7789bSchristos }
1618ecd7789bSchristos if (c != ',') {
1619ecd7789bSchristos *ptr = NULL;
1620ecd7789bSchristos return 0;
1621ecd7789bSchristos }
1622ecd7789bSchristos while (((c = *s++) != '\0') && ISDIGIT(c)) {
1623ecd7789bSchristos j *= 10;
1624ecd7789bSchristos j += c - '0';
1625ecd7789bSchristos }
1626ecd7789bSchristos *ptr = s;
1627ecd7789bSchristos i &= 0xff;
1628ecd7789bSchristos j &= 0xff;
1629ecd7789bSchristos return (i << 8) | j;
1630ecd7789bSchristos }
1631ecd7789bSchristos
1632ecd7789bSchristos
1633ecd7789bSchristos int
ipf_p_ftp_eprt(ipf_ftp_softc_t * softf,fr_info_t * fin,ip_t * ip,nat_t * nat,ftpinfo_t * ftp,int dlen)1634f330e785Schristos ipf_p_ftp_eprt(ipf_ftp_softc_t *softf, fr_info_t *fin, ip_t *ip, nat_t *nat,
1635f330e785Schristos ftpinfo_t *ftp, int dlen)
1636ecd7789bSchristos {
1637ecd7789bSchristos ftpside_t *f;
1638ecd7789bSchristos
1639ecd7789bSchristos /*
1640ecd7789bSchristos * Check for client sending out EPRT message.
1641ecd7789bSchristos */
1642ecd7789bSchristos if (dlen < IPF_MINEPRTLEN) {
1643f52ace7aSdarrenr DT1(epert_dlen, int, dlen);
1644f52ace7aSdarrenr if (softf->ipf_p_ftp_debug & DEBUG_PARSE_ERR)
1645ecd7789bSchristos printf("ipf_p_ftp_eprt:dlen(%d) < IPF_MINEPRTLEN\n",
1646ecd7789bSchristos dlen);
1647ecd7789bSchristos return 0;
1648ecd7789bSchristos }
1649ecd7789bSchristos
1650ecd7789bSchristos /*
1651ecd7789bSchristos * Parse the EPRT command. Format is:
1652ecd7789bSchristos * "EPRT |1|1.2.3.4|2000|" for IPv4 and
1653f52ace7aSdarrenr * "EPRT |2|ef00::1:2|2000|" for IPv6
1654ecd7789bSchristos */
1655ecd7789bSchristos f = &ftp->ftp_side[0];
1656f52ace7aSdarrenr if (f->ftps_rptr[5] != '|')
1657f52ace7aSdarrenr return 0;
1658ecd7789bSchristos if (f->ftps_rptr[5] == f->ftps_rptr[7]) {
1659f52ace7aSdarrenr if (f->ftps_rptr[6] == '1' && nat->nat_v[0] == 4)
1660ecd7789bSchristos return ipf_p_ftp_eprt4(softf, fin, ip, nat, ftp, dlen);
1661785bbd87Spgoyette #ifdef USE_INET6
1662f52ace7aSdarrenr if (f->ftps_rptr[6] == '2' && nat->nat_v[0] == 6)
1663f52ace7aSdarrenr return ipf_p_ftp_eprt6(softf, fin, ip, nat, ftp, dlen);
1664785bbd87Spgoyette #endif
1665ecd7789bSchristos }
1666ecd7789bSchristos return 0;
1667ecd7789bSchristos }
1668ecd7789bSchristos
1669ecd7789bSchristos
1670ecd7789bSchristos int
ipf_p_ftp_eprt4(ipf_ftp_softc_t * softf,fr_info_t * fin,ip_t * ip,nat_t * nat,ftpinfo_t * ftp,int dlen)1671f330e785Schristos ipf_p_ftp_eprt4(ipf_ftp_softc_t *softf, fr_info_t *fin, ip_t *ip, nat_t *nat,
1672f330e785Schristos ftpinfo_t *ftp, int dlen)
1673ecd7789bSchristos {
1674ecd7789bSchristos int a1, a2, a3, a4, port, olen, nlen, inc, off;
1675ecd7789bSchristos char newbuf[IPF_FTPBUFSZ];
1676ecd7789bSchristos char *s, c, delim;
1677ecd7789bSchristos u_32_t addr, i;
1678ecd7789bSchristos tcphdr_t *tcp;
1679ecd7789bSchristos ftpside_t *f;
1680ecd7789bSchristos mb_t *m;
1681ecd7789bSchristos
1682ecd7789bSchristos m = fin->fin_m;
1683ecd7789bSchristos tcp = (tcphdr_t *)fin->fin_dp;
1684ecd7789bSchristos off = (char *)tcp - (char *)ip + (TCP_OFF(tcp) << 2) + fin->fin_ipoff;
1685ecd7789bSchristos f = &ftp->ftp_side[0];
1686ecd7789bSchristos delim = f->ftps_rptr[5];
1687ecd7789bSchristos s = f->ftps_rptr + 8;
1688ecd7789bSchristos
1689ecd7789bSchristos /*
1690ecd7789bSchristos * get the IP address.
1691ecd7789bSchristos */
1692ecd7789bSchristos i = 0;
1693ecd7789bSchristos while (((c = *s++) != '\0') && ISDIGIT(c)) {
1694ecd7789bSchristos i *= 10;
1695ecd7789bSchristos i += c - '0';
1696ecd7789bSchristos }
1697ecd7789bSchristos if (i > 255)
1698ecd7789bSchristos return 0;
1699ecd7789bSchristos if (c != '.')
1700ecd7789bSchristos return 0;
1701ecd7789bSchristos addr = (i << 24);
1702ecd7789bSchristos
1703ecd7789bSchristos i = 0;
1704ecd7789bSchristos while (((c = *s++) != '\0') && ISDIGIT(c)) {
1705ecd7789bSchristos i *= 10;
1706ecd7789bSchristos i += c - '0';
1707ecd7789bSchristos }
1708ecd7789bSchristos if (i > 255)
1709ecd7789bSchristos return 0;
1710ecd7789bSchristos if (c != '.')
1711ecd7789bSchristos return 0;
1712ecd7789bSchristos addr |= (addr << 16);
1713ecd7789bSchristos
1714ecd7789bSchristos i = 0;
1715ecd7789bSchristos while (((c = *s++) != '\0') && ISDIGIT(c)) {
1716ecd7789bSchristos i *= 10;
1717ecd7789bSchristos i += c - '0';
1718ecd7789bSchristos }
1719ecd7789bSchristos if (i > 255)
1720ecd7789bSchristos return 0;
1721ecd7789bSchristos if (c != '.')
1722ecd7789bSchristos return 0;
1723ecd7789bSchristos addr |= (addr << 8);
1724ecd7789bSchristos
1725ecd7789bSchristos i = 0;
1726ecd7789bSchristos while (((c = *s++) != '\0') && ISDIGIT(c)) {
1727ecd7789bSchristos i *= 10;
1728ecd7789bSchristos i += c - '0';
1729ecd7789bSchristos }
1730ecd7789bSchristos if (i > 255)
1731ecd7789bSchristos return 0;
1732ecd7789bSchristos if (c != delim)
1733ecd7789bSchristos return 0;
1734ecd7789bSchristos addr |= addr;
1735ecd7789bSchristos
1736ecd7789bSchristos /*
1737ecd7789bSchristos * Get the port number
1738ecd7789bSchristos */
1739ecd7789bSchristos i = 0;
1740ecd7789bSchristos while (((c = *s++) != '\0') && ISDIGIT(c)) {
1741ecd7789bSchristos i *= 10;
1742ecd7789bSchristos i += c - '0';
1743ecd7789bSchristos }
1744ecd7789bSchristos if (i > 65535)
1745ecd7789bSchristos return 0;
1746ecd7789bSchristos if (c != delim)
1747ecd7789bSchristos return 0;
1748ecd7789bSchristos port = i;
1749ecd7789bSchristos
1750ecd7789bSchristos /*
1751ecd7789bSchristos * Check for CR-LF at the end of the command string.
1752ecd7789bSchristos */
1753ecd7789bSchristos if ((*s != '\r') || (*(s + 1) != '\n')) {
1754f52ace7aSdarrenr DT(eprt4_no_crlf);
1755f52ace7aSdarrenr if (softf->ipf_p_ftp_debug & DEBUG_PARSE_ERR)
1756ecd7789bSchristos printf("ipf_p_ftp_eprt4:missing %s\n", "cr-lf");
1757ecd7789bSchristos return 0;
1758ecd7789bSchristos }
1759f52ace7aSdarrenr s += 2;
1760ecd7789bSchristos
1761ecd7789bSchristos /*
1762ecd7789bSchristos * Calculate new address parts for PORT command
1763ecd7789bSchristos */
1764ecd7789bSchristos if (nat->nat_dir == NAT_INBOUND)
1765ecd7789bSchristos a1 = ntohl(nat->nat_odstaddr);
1766ecd7789bSchristos else
1767ecd7789bSchristos a1 = ntohl(ip->ip_src.s_addr);
1768ecd7789bSchristos a2 = (a1 >> 16) & 0xff;
1769ecd7789bSchristos a3 = (a1 >> 8) & 0xff;
1770ecd7789bSchristos a4 = a1 & 0xff;
1771ecd7789bSchristos a1 >>= 24;
1772ecd7789bSchristos olen = s - f->ftps_rptr;
1773ecd7789bSchristos /*
1774ecd7789bSchristos * While we could force the use of | as a delimiter here, it makes
1775ecd7789bSchristos * sense to preserve whatever character is being used by the systems
1776ecd7789bSchristos * involved in the communication.
1777ecd7789bSchristos */
1778ae8e75c8Schristos snprintf(newbuf, sizeof(newbuf), "%s %c1%c%u.%u.%u.%u%c%u%c\r\n",
1779f52ace7aSdarrenr "EPRT", delim, delim, a1, a2, a3, a4, delim, port, delim);
1780ecd7789bSchristos
1781ecd7789bSchristos nlen = strlen(newbuf);
1782ecd7789bSchristos inc = nlen - olen;
1783ecd7789bSchristos if ((inc + fin->fin_plen) > 65535) {
1784f52ace7aSdarrenr DT2(eprt4_len, int, inc, int, fin->fin_plen);
1785f52ace7aSdarrenr if (softf->ipf_p_ftp_debug & DEBUG_ERROR)
1786ecd7789bSchristos printf("ipf_p_ftp_eprt4:inc(%d) + ip->ip_len > 65535\n",
1787ecd7789bSchristos inc);
1788ecd7789bSchristos return 0;
1789ecd7789bSchristos }
1790ecd7789bSchristos
1791ecd7789bSchristos off = (char *)tcp - (char *)ip + (TCP_OFF(tcp) << 2) + fin->fin_ipoff;
1792ecd7789bSchristos #if !defined(_KERNEL)
1793f52ace7aSdarrenr M_ADJ(m, inc);
1794ecd7789bSchristos #else
1795ecd7789bSchristos if (inc < 0)
1796ecd7789bSchristos M_ADJ(m, inc);
1797ecd7789bSchristos #endif
1798ecd7789bSchristos /* the mbuf chain will be extended if necessary by m_copyback() */
1799ecd7789bSchristos COPYBACK(m, off, nlen, newbuf);
1800f52ace7aSdarrenr fin->fin_flx |= FI_DOCKSUM;
1801ecd7789bSchristos
1802ecd7789bSchristos if (inc != 0) {
1803ecd7789bSchristos fin->fin_plen += inc;
1804ecd7789bSchristos ip->ip_len = htons(fin->fin_plen);
1805ecd7789bSchristos fin->fin_dlen += inc;
1806ecd7789bSchristos }
1807ecd7789bSchristos
1808ecd7789bSchristos f->ftps_cmd = FTPXY_C_EPRT;
1809ecd7789bSchristos return ipf_p_ftp_addport(softf, fin, ip, nat, ftp, dlen, port, inc);
1810ecd7789bSchristos }
1811ecd7789bSchristos
1812ecd7789bSchristos
1813ecd7789bSchristos int
ipf_p_ftp_epsv(ipf_ftp_softc_t * softf,fr_info_t * fin,ip_t * ip,nat_t * nat,ftpinfo_t * ftp,int dlen)1814f330e785Schristos ipf_p_ftp_epsv(ipf_ftp_softc_t *softf, fr_info_t *fin, ip_t *ip, nat_t *nat,
1815f330e785Schristos ftpinfo_t *ftp, int dlen)
1816ecd7789bSchristos {
1817ecd7789bSchristos char newbuf[IPF_FTPBUFSZ];
1818ecd7789bSchristos u_short ap = 0;
1819ecd7789bSchristos ftpside_t *f;
1820ecd7789bSchristos char *s;
1821ecd7789bSchristos
1822ecd7789bSchristos if ((softf->ipf_p_ftp_forcepasv != 0) &&
1823ecd7789bSchristos (ftp->ftp_side[0].ftps_cmd != FTPXY_C_EPSV)) {
1824f52ace7aSdarrenr DT1(epsv_cmd, int, ftp->ftp_side[0].ftps_cmd);
1825f52ace7aSdarrenr if (softf->ipf_p_ftp_debug & DEBUG_PARSE_ERR)
1826ecd7789bSchristos printf("ipf_p_ftp_epsv:ftps_cmd(%d) != FTPXY_C_EPSV\n",
1827ecd7789bSchristos ftp->ftp_side[0].ftps_cmd);
1828ecd7789bSchristos return 0;
1829ecd7789bSchristos }
1830ecd7789bSchristos f = &ftp->ftp_side[1];
1831ecd7789bSchristos
1832ecd7789bSchristos #define EPSV_REPLEN 33
1833ecd7789bSchristos /*
1834ecd7789bSchristos * Check for EPSV reply message.
1835ecd7789bSchristos */
1836f52ace7aSdarrenr if (dlen < IPF_MIN229LEN) {
1837ecd7789bSchristos return (0);
1838f52ace7aSdarrenr } else if (strncmp(f->ftps_rptr,
1839f52ace7aSdarrenr "229 Entering Extended Passive Mode", EPSV_REPLEN)) {
1840ecd7789bSchristos return (0);
1841f52ace7aSdarrenr }
1842ecd7789bSchristos
1843ecd7789bSchristos /*
1844ecd7789bSchristos * Skip the EPSV command + space
1845ecd7789bSchristos */
1846ecd7789bSchristos s = f->ftps_rptr + 33;
1847ecd7789bSchristos while (*s && !ISDIGIT(*s))
1848ecd7789bSchristos s++;
1849ecd7789bSchristos
1850ecd7789bSchristos /*
1851ecd7789bSchristos * As per RFC 2428, there are no addres components in the EPSV
1852ecd7789bSchristos * response. So we'll go straight to getting the port.
1853ecd7789bSchristos */
1854ecd7789bSchristos while (*s && ISDIGIT(*s)) {
1855ecd7789bSchristos ap *= 10;
1856ecd7789bSchristos ap += *s++ - '0';
1857ecd7789bSchristos }
1858ecd7789bSchristos
1859f52ace7aSdarrenr if (!s) {
1860ecd7789bSchristos return 0;
1861f52ace7aSdarrenr }
1862ecd7789bSchristos
1863ecd7789bSchristos if (*s == '|')
1864ecd7789bSchristos s++;
1865ecd7789bSchristos if (*s == ')')
1866ecd7789bSchristos s++;
1867ecd7789bSchristos if (*s == '\n')
1868ecd7789bSchristos s--;
1869ecd7789bSchristos /*
1870ecd7789bSchristos * check for CR-LF at the end.
1871ecd7789bSchristos */
1872f52ace7aSdarrenr if ((*s != '\r') || (*(s + 1) != '\n')) {
1873ecd7789bSchristos return 0;
1874f52ace7aSdarrenr }
1875f52ace7aSdarrenr s += 2;
1876ecd7789bSchristos
1877ae8e75c8Schristos snprintf(newbuf, sizeof(newbuf), "%s (|||%u|)\r\n",
1878ecd7789bSchristos "229 Entering Extended Passive Mode", ap);
1879ecd7789bSchristos
1880ecd7789bSchristos return ipf_p_ftp_pasvreply(softf, fin, ip, nat, ftp, (u_int)ap,
1881f52ace7aSdarrenr newbuf, s);
1882f52ace7aSdarrenr }
1883f52ace7aSdarrenr
1884785bbd87Spgoyette #ifdef USE_INET6
1885f52ace7aSdarrenr int
ipf_p_ftp_eprt6(ipf_ftp_softc_t * softf,fr_info_t * fin,ip_t * ip,nat_t * nat,ftpinfo_t * ftp,int dlen)1886f52ace7aSdarrenr ipf_p_ftp_eprt6(ipf_ftp_softc_t *softf, fr_info_t *fin, ip_t *ip,
1887f52ace7aSdarrenr nat_t *nat, ftpinfo_t *ftp, int dlen)
1888f52ace7aSdarrenr {
1889f52ace7aSdarrenr int port, olen, nlen, inc, off, left, i;
1890f52ace7aSdarrenr char newbuf[IPF_FTPBUFSZ];
1891f52ace7aSdarrenr char *s, c;
1892f52ace7aSdarrenr i6addr_t addr, *a6;
1893f52ace7aSdarrenr tcphdr_t *tcp;
1894f52ace7aSdarrenr ip6_t *ip6;
1895f52ace7aSdarrenr char delim;
1896f52ace7aSdarrenr u_short whole;
1897f52ace7aSdarrenr u_short part;
1898f52ace7aSdarrenr ftpside_t *f;
1899f52ace7aSdarrenr u_short *t;
1900f52ace7aSdarrenr int fwd;
1901f52ace7aSdarrenr mb_t *m;
1902f52ace7aSdarrenr u_32_t a;
1903f52ace7aSdarrenr
1904f52ace7aSdarrenr m = fin->fin_m;
1905f52ace7aSdarrenr ip6 = (ip6_t *)ip;
1906f52ace7aSdarrenr f = &ftp->ftp_side[0];
1907f52ace7aSdarrenr s = f->ftps_rptr + 8;
1908f52ace7aSdarrenr f = &ftp->ftp_side[0];
1909f52ace7aSdarrenr delim = f->ftps_rptr[5];
1910f52ace7aSdarrenr tcp = (tcphdr_t *)fin->fin_dp;
1911f52ace7aSdarrenr off = (char *)tcp - (char *)ip + (TCP_OFF(tcp) << 2) + fin->fin_ipoff;
1912f52ace7aSdarrenr
1913f52ace7aSdarrenr addr.i6[0] = 0;
1914f52ace7aSdarrenr addr.i6[1] = 0;
1915f52ace7aSdarrenr addr.i6[2] = 0;
1916f52ace7aSdarrenr addr.i6[3] = 0;
1917f52ace7aSdarrenr /*
1918f52ace7aSdarrenr * Parse an IPv6 address.
1919f52ace7aSdarrenr * Go forward until either :: or | is found. If :: is found,
1920f52ace7aSdarrenr * reverse direction. Direction change is performed to ease
1921f52ace7aSdarrenr * parsing an unknown number of 0s in the middle.
1922f52ace7aSdarrenr */
1923f52ace7aSdarrenr whole = 0;
1924f52ace7aSdarrenr t = (u_short *)&addr;
1925f52ace7aSdarrenr fwd = 1;
1926f52ace7aSdarrenr for (part = 0; (c = *s) != '\0'; ) {
1927f52ace7aSdarrenr if (c == delim) {
1928f52ace7aSdarrenr *t = htons((u_short)whole);
1929f52ace7aSdarrenr break;
1930f52ace7aSdarrenr }
1931f52ace7aSdarrenr if (c == ':') {
1932f52ace7aSdarrenr *t = part;
1933f52ace7aSdarrenr if (fwd) {
1934f52ace7aSdarrenr *t = htons((u_short)whole);
1935f52ace7aSdarrenr t++;
1936f52ace7aSdarrenr } else {
1937f52ace7aSdarrenr *t = htons((u_short)(whole >> 16));
1938f52ace7aSdarrenr t--;
1939f52ace7aSdarrenr }
1940f52ace7aSdarrenr whole = 0;
1941f52ace7aSdarrenr if (fwd == 1 && s[1] == ':') {
1942f52ace7aSdarrenr while (*s && *s != '|')
1943f52ace7aSdarrenr s++;
1944f52ace7aSdarrenr if ((c = *s) != delim)
1945f52ace7aSdarrenr break;
1946f52ace7aSdarrenr t = (u_short *)&addr.i6[3];
1947f52ace7aSdarrenr t++;
1948f52ace7aSdarrenr fwd = 0;
1949f52ace7aSdarrenr } else if (fwd == 0 && s[-1] == ':') {
1950f52ace7aSdarrenr break;
1951f52ace7aSdarrenr }
1952f52ace7aSdarrenr } else {
1953f52ace7aSdarrenr if (c >= '0' && c <= '9') {
1954f52ace7aSdarrenr c -= '0';
1955f52ace7aSdarrenr } else if (c >= 'a' && c <= 'f') {
1956f52ace7aSdarrenr c -= 'a' + 10;
1957f52ace7aSdarrenr } else if (c >= 'A' && c <= 'F') {
1958f52ace7aSdarrenr c -= 'A' + 10;
1959f52ace7aSdarrenr }
1960f52ace7aSdarrenr if (fwd) {
1961f52ace7aSdarrenr whole <<= 8;
1962f52ace7aSdarrenr whole |= c;
1963f52ace7aSdarrenr } else {
1964f52ace7aSdarrenr whole >>= 8;
1965f52ace7aSdarrenr whole |= ((u_32_t)c) << 24;
1966f52ace7aSdarrenr }
1967f52ace7aSdarrenr }
1968f52ace7aSdarrenr if (fwd)
1969f52ace7aSdarrenr s++;
1970f52ace7aSdarrenr else
1971f52ace7aSdarrenr s--;
1972f52ace7aSdarrenr }
1973f52ace7aSdarrenr if (c != ':' && c != delim)
1974f52ace7aSdarrenr return 0;
1975f52ace7aSdarrenr
1976f52ace7aSdarrenr while (*s != '|')
1977f52ace7aSdarrenr s++;
1978f52ace7aSdarrenr s++;
1979f52ace7aSdarrenr
1980f52ace7aSdarrenr /*
1981f52ace7aSdarrenr * Get the port number
1982f52ace7aSdarrenr */
1983f52ace7aSdarrenr i = 0;
1984f52ace7aSdarrenr while (((c = *s++) != '\0') && ISDIGIT(c)) {
1985f52ace7aSdarrenr i *= 10;
1986f52ace7aSdarrenr i += c - '0';
1987f52ace7aSdarrenr }
1988f52ace7aSdarrenr if (i > 65535)
1989f52ace7aSdarrenr return 0;
1990f52ace7aSdarrenr if (c != delim)
1991f52ace7aSdarrenr return 0;
1992f52ace7aSdarrenr port = (u_short)(i & 0xffff);
1993f52ace7aSdarrenr
1994f52ace7aSdarrenr /*
1995f52ace7aSdarrenr * Check for CR-LF at the end of the command string.
1996f52ace7aSdarrenr */
1997f52ace7aSdarrenr if ((*s != '\r') || (*(s + 1) != '\n')) {
1998f52ace7aSdarrenr DT(eprt6_no_crlf);
1999f52ace7aSdarrenr if (softf->ipf_p_ftp_debug & DEBUG_PARSE_ERR)
2000f52ace7aSdarrenr printf("ipf_p_ftp_eprt6:missing %s\n", "cr-lf");
2001f52ace7aSdarrenr return 0;
2002f52ace7aSdarrenr }
2003f52ace7aSdarrenr s += 2;
2004f52ace7aSdarrenr
2005f52ace7aSdarrenr /*
2006f52ace7aSdarrenr * Calculate new address parts for PORT command
2007f52ace7aSdarrenr */
2008f52ace7aSdarrenr a6 = (i6addr_t *)&ip6->ip6_src;
2009f52ace7aSdarrenr olen = s - f->ftps_rptr;
2010f52ace7aSdarrenr /* DO NOT change this to snprintf! */
2011f52ace7aSdarrenr /*
2012f52ace7aSdarrenr * While we could force the use of | as a delimiter here, it makes
2013f52ace7aSdarrenr * sense to preserve whatever character is being used by the systems
2014f52ace7aSdarrenr * involved in the communication.
2015f52ace7aSdarrenr */
2016f52ace7aSdarrenr s = newbuf;
2017f52ace7aSdarrenr left = sizeof(newbuf);
2018ae8e75c8Schristos snprintf(newbuf, left, "EPRT %c2%c", delim, delim);
2019f52ace7aSdarrenr left -= strlen(s) + 1;
2020f52ace7aSdarrenr s += strlen(s);
2021f52ace7aSdarrenr a = ntohl(a6->i6[0]);
2022ae8e75c8Schristos snprintf(s, left, "%x:%x:", a >> 16, a & 0xffff);
2023f52ace7aSdarrenr left -= strlen(s);
2024f52ace7aSdarrenr s += strlen(s);
2025f52ace7aSdarrenr a = ntohl(a6->i6[1]);
2026ae8e75c8Schristos snprintf(s, left, "%x:%x:", a >> 16, a & 0xffff);
2027f52ace7aSdarrenr left -= strlen(s);
2028f52ace7aSdarrenr s += strlen(s);
2029f52ace7aSdarrenr a = ntohl(a6->i6[2]);
2030ae8e75c8Schristos snprintf(s, left, "%x:%x:", a >> 16, a & 0xffff);
2031f52ace7aSdarrenr left -= strlen(s);
2032f52ace7aSdarrenr s += strlen(s);
2033f52ace7aSdarrenr a = ntohl(a6->i6[3]);
2034ae8e75c8Schristos snprintf(s, left, "%x:%x", a >> 16, a & 0xffff);
2035f52ace7aSdarrenr left -= strlen(s);
2036f52ace7aSdarrenr s += strlen(s);
2037ae8e75c8Schristos snprintf(s, left, "|%d|\r\n", port);
2038f52ace7aSdarrenr nlen = strlen(newbuf);
2039f52ace7aSdarrenr inc = nlen - olen;
2040f52ace7aSdarrenr if ((inc + fin->fin_plen) > 65535) {
2041f52ace7aSdarrenr DT2(eprt6_len, int, inc, int, fin->fin_plen);
2042f52ace7aSdarrenr if (softf->ipf_p_ftp_debug & DEBUG_ERROR)
2043f52ace7aSdarrenr printf("ipf_p_ftp_eprt6:inc(%d) + ip->ip_len > 65535\n",
2044f52ace7aSdarrenr inc);
2045f52ace7aSdarrenr return 0;
2046f52ace7aSdarrenr }
2047f52ace7aSdarrenr
2048f52ace7aSdarrenr off = (char *)tcp - (char *)ip + (TCP_OFF(tcp) << 2) + fin->fin_ipoff;
2049f52ace7aSdarrenr #if !defined(_KERNEL)
2050f52ace7aSdarrenr M_ADJ(m, inc);
2051f52ace7aSdarrenr #else
2052f52ace7aSdarrenr if (inc < 0)
2053f52ace7aSdarrenr M_ADJ(m, inc);
2054f52ace7aSdarrenr #endif
2055f52ace7aSdarrenr /* the mbuf chain will be extended if necessary by m_copyback() */
2056f52ace7aSdarrenr COPYBACK(m, off, nlen, newbuf);
2057f52ace7aSdarrenr fin->fin_flx |= FI_DOCKSUM;
2058f52ace7aSdarrenr
2059f52ace7aSdarrenr if (inc != 0) {
2060f52ace7aSdarrenr fin->fin_plen += inc;
2061f52ace7aSdarrenr ip6->ip6_plen = htons(fin->fin_plen - fin->fin_hlen);
2062f52ace7aSdarrenr fin->fin_dlen += inc;
2063f52ace7aSdarrenr }
2064f52ace7aSdarrenr
2065f52ace7aSdarrenr f->ftps_cmd = FTPXY_C_EPRT;
2066f52ace7aSdarrenr return ipf_p_ftp_addport(softf, fin, ip, nat, ftp, dlen, port, inc);
2067ecd7789bSchristos }
2068785bbd87Spgoyette #endif /* USE_INET6 */
2069