3 * sock.c (C) 1995-1998 Darren Reed
5 * See the IPFILTER.LICENCE file for details on licencing.
9 static const char sccsid[] = "@(#)sock.c 1.2 1/11/96 (C)1995 Darren Reed";
10 static const char rcsid[] = "@(#)$Id$";
12 #include <sys/param.h>
13 #include <sys/types.h>
16 #if defined(__NetBSD__) && defined(__vax__)
18 * XXX need to declare boolean_t for _KERNEL <sys/files.h>
19 * which ends up including <sys/device.h> for vax. See PR#32907
20 * for further details.
22 typedef int boolean_t;
25 # include <sys/dirent.h>
27 # include <machine/lock.h>
35 # include <sys/file.h>
44 #include <sys/socket.h>
46 #include <sys/socketvar.h>
50 #include <sys/systm.h>
51 #include <sys/session.h>
53 #include <sys/sysctl.h>
54 #include <sys/filedesc.h>
57 #include <netinet/in.h>
58 #include <netinet/in_systm.h>
59 #include <netinet/ip.h>
60 #include <netinet/tcp.h>
62 # include <net/route.h>
63 #include <netinet/ip_var.h>
65 #include <netinet/in_pcb.h>
66 #include <netinet/tcp_timer.h>
68 #include <netinet/tcp_var.h>
83 # define KMEM _PATH_KMEM
88 # define KERNEL _PATH_UNIX
92 # define KMEM "/dev/kmem"
95 # define KERNEL "/vmunix"
99 static struct kinfo_proc *getproc(void);
103 kmemcpy(char *buf, void *pos, int n)
106 off_t offset = (u_long)pos;
109 kfd = open(KMEM, O_RDONLY);
111 if (lseek(kfd, offset, SEEK_SET) == -1)
116 if (read(kfd, buf, n) == -1)
124 struct nlist names[4] = {
132 kinfo_proc *getproc(void)
134 static struct kinfo_proc kp;
135 pid_t pid = getpid();
141 mib[2] = KERN_PROC_PID;
145 if (sysctl(mib, 4, &kp, &n, NULL, 0) == -1)
155 find_tcp(int tfd, struct tcpiphdr *ti)
161 struct kinfo_proc *p;
164 if (!(p = getproc()))
167 fd = (struct filedesc *)malloc(sizeof(*fd));
170 #if defined( __FreeBSD__)
171 if (KMCPY(fd, p->ki_fd, sizeof(*fd)) == -1)
173 fprintf(stderr, "read(%#lx,%#lx) failed\n",
174 (u_long)p, (u_long)p->ki_fd);
179 if (KMCPY(fd, p->kp_proc.p_fd, sizeof(*fd)) == -1)
181 fprintf(stderr, "read(%#lx,%#lx) failed\n",
182 (u_long)p, (u_long)p->kp_proc.p_fd);
194 o = (struct file **)calloc(fd->fd_lastfile + 1, sizeof(*o));
195 if (KMCPY(o, fd->fd_ofiles, (fd->fd_lastfile + 1) * sizeof(*o)) == -1)
197 fprintf(stderr, "read(%#lx,%#lx,%lu) - u_ofile - failed\n",
198 (u_long)fd->fd_ofiles, (u_long)o, (u_long)sizeof(*o));
201 f = (struct file *)calloc(1, sizeof(*f));
202 if (KMCPY(f, o[tfd], sizeof(*f)) == -1)
204 fprintf(stderr, "read(%#lx,%#lx,%lu) - o[tfd] - failed\n",
205 (u_long)o[tfd], (u_long)f, (u_long)sizeof(*f));
209 s = (struct socket *)calloc(1, sizeof(*s));
210 if (KMCPY(s, f->f_data, sizeof(*s)) == -1)
212 fprintf(stderr, "read(%#lx,%#lx,%lu) - f_data - failed\n",
213 (u_long)f->f_data, (u_long)s, (u_long)sizeof(*s));
217 i = (struct inpcb *)calloc(1, sizeof(*i));
218 if (KMCPY(i, s->so_pcb, sizeof(*i)) == -1)
220 fprintf(stderr, "kvm_read(%#lx,%#lx,%lu) - so_pcb - failed\n",
221 (u_long)s->so_pcb, (u_long)i, (u_long)sizeof(*i));
225 t = (struct tcpcb *)calloc(1, sizeof(*t));
226 if (KMCPY(t, i->inp_ppcb, sizeof(*t)) == -1)
228 fprintf(stderr, "read(%#lx,%#lx,%lu) - inp_ppcb - failed\n",
229 (u_long)i->inp_ppcb, (u_long)t, (u_long)sizeof(*t));
232 return (struct tcpcb *)i->inp_ppcb;
249 do_socket(char *dev, int mtu, struct tcpiphdr *ti, struct in_addr gwip)
251 struct sockaddr_in rsin, lsin;
252 struct tcpcb *t, tcb;
256 printf("Dest. Port: %d\n", ti->ti_dport);
258 fd = socket(AF_INET, SOCK_STREAM, 0);
265 if (fcntl(fd, F_SETFL, FNDELAY) == -1)
271 bzero((char *)&lsin, sizeof(lsin));
272 lsin.sin_family = AF_INET;
273 bcopy((char *)&ti->ti_src, (char *)&lsin.sin_addr,
274 sizeof(struct in_addr));
275 if (bind(fd, (struct sockaddr *)&lsin, sizeof(lsin)) == -1)
281 (void) getsockname(fd, (struct sockaddr *)&lsin, &len);
282 ti->ti_sport = lsin.sin_port;
283 printf("sport %d\n", ntohs(lsin.sin_port));
285 nfd = initdevice(dev, 1);
289 if (!(t = find_tcp(fd, ti)))
292 bzero((char *)&rsin, sizeof(rsin));
293 rsin.sin_family = AF_INET;
294 bcopy((char *)&ti->ti_dst, (char *)&rsin.sin_addr,
295 sizeof(struct in_addr));
296 rsin.sin_port = ti->ti_dport;
297 if (connect(fd, (struct sockaddr *)&rsin, sizeof(rsin)) == -1 &&
298 errno != EINPROGRESS)
303 KMCPY(&tcb, t, sizeof(tcb));
304 ti->ti_win = tcb.rcv_adv;
305 ti->ti_seq = tcb.snd_nxt - 1;
306 ti->ti_ack = tcb.rcv_nxt;
308 if (send_tcp(nfd, mtu, (ip_t *)ti, gwip) == -1)
310 (void)write(fd, "Hello World\n", 12);