1 /* raw_cb.c 4.1 82/02/01 */ 2 3 #include "../h/param.h" 4 #include "../h/systm.h" 5 #include "../h/mbuf.h" 6 #include "../h/socket.h" 7 #include "../h/socketvar.h" 8 #include "../h/mtpr.h" 9 #include "../net/in.h" 10 #include "../net/in_systm.h" 11 #include "../net/if.h" 12 #include "../net/raw_cb.h" 13 #include "/usr/include/errno.h" 14 15 /* 16 * Routines to manage the raw protocol control blocks. 17 * 18 * TODO: 19 * hash lookups by protocol family/protocol + address family 20 * take care of unique address problems per AF 21 */ 22 23 /* 24 * Allocate a control block and a nominal amount 25 * of buffer space for the socket. 26 */ 27 raw_attach(so, addr) 28 register struct socket *so; 29 struct sockaddr *addr; 30 { 31 struct mbuf *m; 32 register struct rawcb *rp; 33 struct ifnet *ifp = ifnet; 34 35 COUNT(RAW_ATTACH); 36 if (so->so_options & SO_DEBUG) 37 printf("raw_attach: addr=%d\n", addr->sa_family); 38 /* 39 * Should we verify address not already in use? 40 * Some say yes, others no. 41 */ 42 if (addr) switch (addr->sa_family) { 43 44 case AF_INET: { 45 register struct sockaddr_in *sin = (struct sockaddr_in *)addr; 46 47 if (ifnet && sin->sin_addr.s_addr == 0) 48 sin->sin_addr = ifnet->if_addr; 49 ifp = if_ifwithaddr(sin->sin_addr); 50 break; 51 } 52 53 default: 54 return (EAFNOSUPPORT); 55 } 56 if (ifp == 0) 57 return (EADDRNOTAVAIL); 58 m = m_getclr(M_DONTWAIT); 59 if (m == 0) 60 return (ENOBUFS); 61 if (sbreserve(&so->so_snd, RAWSNDQ) == 0) 62 goto bad; 63 if (sbreserve(&so->so_rcv, RAWRCVQ) == 0) 64 goto bad2; 65 rp = mtod(m, struct rawcb *); 66 rp->rcb_socket = so; 67 insque(rp, &rawcb); 68 so->so_pcb = (caddr_t)rp; 69 rp->rcb_pcb = 0; 70 71 if (addr) 72 bcopy(addr, &so->so_addr, sizeof(*addr)); 73 return (0); 74 bad2: 75 sbrelease(&so->so_snd); 76 bad: 77 (void) m_free(m); 78 return (ENOBUFS); 79 } 80 81 /* 82 * Detach the raw connection block and discard 83 * socket resources. 84 */ 85 raw_detach(rp) 86 register struct rawcb *rp; 87 { 88 struct socket *so = rp->rcb_socket; 89 90 COUNT(RAW_DETACH); 91 if (rp->rcb_socket->so_options & SO_DEBUG) 92 printf("raw_detach: rp=%X\n", rp); 93 so->so_pcb = 0; 94 sofree(so); 95 remque(rp); 96 (void) m_freem(dtom(rp)); 97 } 98 99 /* 100 * Disconnect and possibly release resources. 101 */ 102 raw_disconnect(rp) 103 struct rawcb *rp; 104 { 105 COUNT(RAW_DISCONNECT); 106 if (rp->rcb_socket->so_options & SO_DEBUG) 107 printf("raw_disconnect: rp=%X\n", rp); 108 rp->rcb_flags &= ~RAW_ADDR; 109 if (rp->rcb_socket->so_state & SS_USERGONE) 110 raw_detach(rp); 111 } 112 113 /* 114 * Associate a peer's address with a 115 * raw connection block. 116 */ 117 raw_connaddr(rp, addr) 118 struct rawcb *rp; 119 struct sockaddr *addr; 120 { 121 COUNT(RAW_CONNADDR); 122 if (rp->rcb_socket->so_options & SO_DEBUG); 123 printf("raw_connaddr: rp=%x, addr=<%x,%x>\n", 124 rp, addr->sa_family, ((struct sockaddr_in *)addr)->sin_addr); 125 bcopy(addr, &rp->rcb_addr, sizeof(struct sockaddr)); 126 rp->rcb_flags |= RAW_ADDR; 127 } 128