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