![[BACK]](/cvsweb/icons/back.gif){kind=icon}
Return to in_pcb.c CVS log ![[TXT]](/cvsweb/icons/text.gif){kind=icon}
![[DIR]](/cvsweb/icons/dir.gif){kind=icon}
Up to [Power 6/32 Unix Tahoe 4.2BSD] / cci / sys / netinet|
Return to in_pcb.c CVS log | Up to [Power 6/32 Unix Tahoe 4.2BSD] / cci / sys / netinet |
1.1 root 1: /* in_pcb.c 6.1 83/07/29 */
2:
3: #include "../h/param.h"
4: #include "../h/systm.h"
5: #include "../h/dir.h"
6: #include "../h/user.h"
7: #include "../h/mbuf.h"
8: #include "../h/socket.h"
9: #include "../h/socketvar.h"
10: #include "../netinet/in.h"
11: #include "../netinet/in_systm.h"
12: #include "../net/if.h"
13: #include "../net/route.h"
14: #include "../netinet/in_pcb.h"
15: #include "../h/protosw.h"
16:
17: struct in_addr zeroin_addr;
18:
19: in_pcballoc(so, head)
20: struct socket *so;
21: struct inpcb *head;
22: {
23: struct mbuf *m;
24: register struct inpcb *inp;
25:
26: m = m_getclr(M_DONTWAIT, MT_PCB);
27: MBUFNULL(45, m); /* for debugging */
28: if (m == NULL)
29: return (ENOBUFS);
30: inp = mtod(m, struct inpcb *);
31: inp->inp_head = head;
32: inp->inp_socket = so;
33: insque(inp, head);
34: so->so_pcb = (caddr_t)inp;
35: return (0);
36: }
37:
38: in_pcbbind(inp, nam)
39: register struct inpcb *inp;
40: struct mbuf *nam;
41: {
42: register struct socket *so = inp->inp_socket;
43: register struct inpcb *head = inp->inp_head;
44: register struct sockaddr_in *sin;
45: u_short lport = 0;
46:
47: if (ifnet == 0)
48: return (EADDRNOTAVAIL);
49: if (inp->inp_lport || inp->inp_laddr.s_addr != INADDR_ANY)
50: return (EINVAL);
51: if (nam == 0)
52: goto noname;
53: sin = mtod(nam, struct sockaddr_in *);
54: if (nam->m_len != sizeof (*sin))
55: return (EINVAL);
56: if (sin->sin_addr.s_addr != INADDR_ANY) {
57: int tport = sin->sin_port;
58:
59: sin->sin_port = 0; /* yech... */
60: if (if_ifwithaddr((struct sockaddr *)sin) == 0)
61: return (EADDRNOTAVAIL);
62: sin->sin_port = tport;
63: }
64: lport = sin->sin_port;
65: if (lport) {
66: u_short aport = ntohs(lport);
67: int wild = 0;
68:
69: /* GROSS */
70: if (aport < IPPORT_RESERVED && u.u_uid != 0)
71: return (EACCES);
72: /* even GROSSER, but this is the Internet */
73: if ((so->so_options & SO_REUSEADDR) == 0 &&
74: ((so->so_proto->pr_flags & PR_CONNREQUIRED) == 0 ||
75: (so->so_options & SO_ACCEPTCONN) == 0))
76: wild = INPLOOKUP_WILDCARD;
77: if (in_pcblookup(head,
78: zeroin_addr, 0, sin->sin_addr, lport, wild))
79: return (EADDRINUSE);
80: }
81: inp->inp_laddr = sin->sin_addr;
82: noname:
83: if (lport == 0)
84: do {
85: if (head->inp_lport++ < IPPORT_RESERVED)
86: head->inp_lport = IPPORT_RESERVED;
87: lport = htons(head->inp_lport);
88: } while (in_pcblookup(head,
89: zeroin_addr, 0, inp->inp_laddr, lport, 0));
90: inp->inp_lport = lport;
91: return (0);
92: }
93:
94: /*
95: * Connect from a socket to a specified address.
96: * Both address and port must be specified in argument sin.
97: * If don't have a local address for this socket yet,
98: * then pick one.
99: */
100: in_pcbconnect(inp, nam)
101: struct inpcb *inp;
102: struct mbuf *nam;
103: {
104: struct ifnet *ifp;
105: struct sockaddr_in *ifaddr;
106: register struct sockaddr_in *sin = mtod(nam, struct sockaddr_in *);
107:
108: if (nam->m_len != sizeof (*sin))
109: return (EINVAL);
110: if (sin->sin_family != AF_INET)
111: return (EAFNOSUPPORT);
112: if (sin->sin_addr.s_addr == INADDR_ANY || sin->sin_port == 0)
113: return (EADDRNOTAVAIL);
114: if (inp->inp_laddr.s_addr == INADDR_ANY) {
115: ifp = if_ifonnetof(in_netof(sin->sin_addr));
116: if (ifp == 0) {
117: /*
118: * We should select the interface based on
119: * the route to be used, but for udp this would
120: * result in two calls to rtalloc for each packet
121: * sent; hardly worthwhile...
122: */
123: ifp = if_ifwithaf(AF_INET);
124: if (ifp == 0)
125: return (EADDRNOTAVAIL);
126: }
127: ifaddr = (struct sockaddr_in *)&ifp->if_addr;
128: }
129: if (in_pcblookup(inp->inp_head,
130: sin->sin_addr,
131: sin->sin_port,
132: inp->inp_laddr.s_addr ? inp->inp_laddr : ifaddr->sin_addr,
133: inp->inp_lport,
134: 0))
135: return (EADDRINUSE);
136: if (inp->inp_laddr.s_addr == INADDR_ANY) {
137: if (inp->inp_lport == 0)
138: in_pcbbind(inp, (struct mbuf *)0);
139: inp->inp_laddr = ifaddr->sin_addr;
140: }
141: inp->inp_faddr = sin->sin_addr;
142: inp->inp_fport = sin->sin_port;
143: return (0);
144: }
145:
146: in_pcbdisconnect(inp)
147: struct inpcb *inp;
148: {
149:
150: inp->inp_faddr.s_addr = INADDR_ANY;
151: inp->inp_fport = 0;
152: if (inp->inp_socket->so_state & SS_NOFDREF)
153: in_pcbdetach(inp);
154: }
155:
156: in_pcbdetach(inp)
157: struct inpcb *inp;
158: {
159: struct socket *so = inp->inp_socket;
160:
161: so->so_pcb = 0;
162: sofree(so);
163: if (inp->inp_route.ro_rt)
164: rtfree(inp->inp_route.ro_rt);
165: remque(inp);
166: (void) m_free(dtom(inp));
167: }
168:
169: in_setsockaddr(inp, nam)
170: register struct inpcb *inp;
171: struct mbuf *nam;
172: {
173: register struct sockaddr_in *sin = mtod(nam, struct sockaddr_in *);
174:
175: nam->m_len = sizeof (*sin);
176: sin = mtod(nam, struct sockaddr_in *);
177: bzero((caddr_t)sin, sizeof (*sin));
178: sin->sin_family = AF_INET;
179: sin->sin_port = inp->inp_lport;
180: sin->sin_addr = inp->inp_laddr;
181: }
182:
183: in_setpeeraddr(inp, nam)
184: register struct inpcb *inp;
185: struct mbuf *nam;
186: {
187: register struct sockaddr_in *sin = mtod(nam, struct sockaddr_in *);
188:
189: nam->m_len = sizeof (*sin);
190: sin = mtod(nam, struct sockaddr_in *);
191: bzero((caddr_t)sin, sizeof (*sin));
192: sin->sin_family = AF_INET;
193: sin->sin_port = inp->inp_fport;
194: sin->sin_addr = inp->inp_faddr;
195: }
196:
197: /*
198: * Pass an error to all internet connections
199: * associated with address sin. Call the
200: * protocol specific routine to clean up the
201: * mess afterwards.
202: */
203: in_pcbnotify(head, dst, errno, abort)
204: struct inpcb *head;
205: register struct in_addr *dst;
206: int errno, (*abort)();
207: {
208: register struct inpcb *inp, *oinp;
209: int s = splimp();
210:
211: for (inp = head->inp_next; inp != head;) {
212: if (inp->inp_faddr.s_addr != dst->s_addr) {
213: next:
214: inp = inp->inp_next;
215: continue;
216: }
217: if (inp->inp_socket == 0)
218: goto next;
219: inp->inp_socket->so_error = errno;
220: oinp = inp;
221: inp = inp->inp_next;
222: (*abort)(oinp);
223: }
224: splx(s);
225: }
226:
227: struct inpcb *
228: in_pcblookup(head, faddr, fport, laddr, lport, flags)
229: struct inpcb *head;
230: struct in_addr faddr, laddr;
231: u_short fport, lport;
232: int flags;
233: {
234: register struct inpcb *inp, *match = 0;
235: int matchwild = 3, wildcard;
236:
237: for (inp = head->inp_next; inp != head; inp = inp->inp_next) {
238: if (inp->inp_lport != lport)
239: continue;
240: wildcard = 0;
241: if (inp->inp_laddr.s_addr != INADDR_ANY) {
242: if (laddr.s_addr == INADDR_ANY)
243: wildcard++;
244: else if (inp->inp_laddr.s_addr != laddr.s_addr)
245: continue;
246: } else {
247: if (laddr.s_addr != INADDR_ANY)
248: wildcard++;
249: }
250: if (inp->inp_faddr.s_addr != INADDR_ANY) {
251: if (faddr.s_addr == INADDR_ANY)
252: wildcard++;
253: else if (inp->inp_faddr.s_addr != faddr.s_addr ||
254: inp->inp_fport != fport)
255: continue;
256: } else {
257: if (faddr.s_addr != INADDR_ANY)
258: wildcard++;
259: }
260: if (wildcard && (flags & INPLOOKUP_WILDCARD) == 0)
261: continue;
262: if (wildcard < matchwild) {
263: match = inp;
264: matchwild = wildcard;
265: if (matchwild == 0)
266: break;
267: }
268: }
269: return (match);
270: }
This archive runs on limited infrastructure. Preserving old code on modern bandwidth. Automated agents are requested to crawl responsibly.