/original-bsd/sys/kern/ |
H A D | uipc_socket.c | 52 bzero((caddr_t)so, sizeof(*so)); 64 *aso = so; 77 (*so->so_proto->pr_usrreq)(so, PRU_BIND, 91 (*so->so_proto->pr_usrreq)(so, PRU_LISTEN, 107 sofree(so) in sofree() argument 111 if (so->so_pcb || (so->so_state & SS_NOFDREF) == 0) 114 if (!soqremque(so, 0) && !soqremque(so, 1)) 162 (*so->so_proto->pr_usrreq)(so, PRU_DETACH, 185 (*so->so_proto->pr_usrreq)(so, PRU_ABORT, 423 error = (*so->so_proto->pr_usrreq)(so, [all …]
|
H A D | sys_socket.c | 64 so->so_state |= SS_NBIO; 66 so->so_state &= ~SS_NBIO; 71 so->so_state |= SS_ASYNC; 75 so->so_state &= ~SS_ASYNC; 86 so->so_pgid = *(int *)data; 106 return ((*so->so_proto->pr_usrreq)(so, PRU_CONTROL, 122 if (soreadable(so)) { 131 if (sowriteable(so)) { 140 if (so->so_oobmark || (so->so_state & SS_RCVATMARK)) { 153 soo_stat(so, ub) in soo_stat() argument [all …]
|
H A D | uipc_socket2.c | 85 sorwakeup(so); 98 sowwakeup(so); 99 sorwakeup(so); 110 sowwakeup(so); 111 sorwakeup(so); 138 bzero((caddr_t)so, sizeof(*so)); 148 if ((*so->so_proto->pr_usrreq)(so, PRU_ATTACH, 159 return (so); 181 *prev = so; 348 if (so->so_snd.sb_lowat > so->so_snd.sb_hiwat) [all …]
|
H A D | uipc_usrreq.c | 40 struct socket *so; in uipc_usrreq() 111 socantsendmore(so); 292 unp_attach(so) in unp_attach() argument 293 struct socket *so; in unp_attach() 299 if (so->so_snd.sb_hiwat == 0 || so->so_rcv.sb_hiwat == 0) { 406 struct socket *so; in unp_connect() 477 soisconnected(so); 482 soisconnected(so); 543 struct socket *so; local 559 if (so->so_head) { [all …]
|
/original-bsd/sys/sys/ |
H A D | socketvar.h | 106 #define sosendallatonce(so) \ argument 110 #define soreadable(so) \ argument 111 ((so)->so_rcv.sb_cc >= (so)->so_rcv.sb_lowat || \ 113 (so)->so_qlen || (so)->so_error) 116 #define sowriteable(so) \ argument 117 (sbspace(&(so)->so_snd) >= (so)->so_snd.sb_lowat && \ 121 (so)->so_error) 157 #define sorwakeup(so) { sowakeup((so), &(so)->so_rcv); \ argument 158 if ((so)->so_upcall) \ 159 (*((so)->so_upcall))((so), (so)->so_upcallarg, M_DONTWAIT); \ [all …]
|
/original-bsd/sys/netinet/ |
H A D | tcp_usrreq.c | 49 struct socket *so; in tcp_usrreq() 70 inp = sotoinpcb(so); 115 if ((so->so_options & SO_LINGER) && so->so_linger == 0) 117 tp = sototcpcb(so); 179 soisconnecting(so); 223 socantsendmore(so); 325 struct socket *so; 410 tcp_attach(so) in tcp_attach() argument 411 struct socket *so; in tcp_attach() 417 if (so->so_snd.sb_hiwat == 0 || so->so_rcv.sb_hiwat == 0) { [all …]
|
H A D | raw_ip.c | 107 rip_output(m, so, dst) in rip_output() argument 109 struct socket *so; 150 struct socket *so; 231 rip_usrreq(so, req, m, nam, control) in rip_usrreq() argument 232 register struct socket *so; in rip_usrreq() 253 inp = (struct inpcb *)so->so_pcb; 264 soisdisconnected(so); 270 if (so == ip_mrouter) 313 soisconnected(so); 325 socantsendmore(so); [all …]
|
H A D | tcp_input.c | 72 sorwakeup(so); \ 180 sorwakeup(so); 200 struct socket *so; local 343 so = sonewconn(so, 0); 344 if (so == 0) 456 sowwakeup(so); 480 sorwakeup(so); 1021 sbdrop(&so->so_snd, (int)so->so_snd.sb_cc); 1029 sowwakeup(so); 1150 so->so_oobmark = so->so_rcv.sb_cc + [all …]
|
/original-bsd/sys/deprecated/netdecnet/ |
H A D | nsp_usrreq.c | 26 nsp_usrreq(so, req, m, addr) 27 struct socket *so; variable 75 np = sotonspcb(so); 105 soisconnecting(so); 138 socantsendmore(so); 156 sbpappend(&so->so_snd, m); 224 nsp_attach(so, sa) 225 struct socket *so; variable 252 sbrelease(&so->so_snd); 288 soisdisconnecting(so); [all …]
|
/original-bsd/sys/net/ |
H A D | raw_cb.c | 41 raw_attach(so, proto) in raw_attach() argument 42 register struct socket *so; in raw_attach() 45 register struct rawcb *rp = sotorawcb(so); 55 if (error = soreserve(so, raw_sendspace, raw_recvspace)) 57 rp->rcb_socket = so; 72 struct socket *so = rp->rcb_socket; local 74 so->so_pcb = 0; 75 sofree(so); 104 raw_bind(so, nam) in raw_bind() argument 105 register struct socket *so; in raw_bind() [all …]
|
H A D | raw_usrreq.c | 115 raw_usrreq(so, req, m, nam, control) in raw_usrreq() argument 116 struct socket *so; in raw_usrreq() 142 if ((so->so_state & SS_PRIV) == 0) { 146 error = raw_attach(so, (int)nam); 175 soisconnected(so); 183 error = raw_bind(so, nam); 197 soisdisconnected(so); 204 socantsendmore(so); 222 error = (*so->so_proto->pr_output)(m, so); 230 sofree(so); [all …]
|
/original-bsd/sbin/mount_portal/ |
H A D | activate.c | 39 int so; 51 static int get_request(so, pcr, key, klen) in get_request() argument 52 int so; in get_request() 70 n = recvmsg(so, &msg, 0); 83 static void send_reply(so, fd, error) in send_reply() argument 84 int so; in send_reply() 133 if (shutdown(so, 2) < 0) 142 void activate(q, so) in activate() argument 144 int so; 185 send_reply(so, fd, error); [all …]
|
H A D | mount_portal.c | 74 int so; local 117 so = socket(AF_UNIX, SOCK_STREAM, 0); 118 if (so < 0) { 123 if (bind(so, (struct sockaddr *) &un, sizeof(un)) < 0) 127 (void) listen(so, 5); 129 args.pa_socket = so; 177 FD_SET(so, &fdset); 178 rc = select(so+1, &fdset, (void *) 0, (void *) 0, (void *) 0); 187 so2 = accept(so, (struct sockaddr *) &un2, &len2); 215 (void) close(so);
|
H A D | portald.h | 37 char *key, char **v, int so, int *fdp)); 45 char *key, char **v, int so, int *fdp)); 47 char *key, char **v, int so, int *fdp)); 49 char *key, char **v, int so, int *fdp)); 54 extern void activate __P((qelem *q, int so));
|
H A D | pt_tcp.c | 111 int so; local 114 so = rresvport((int *) 0); 116 so = socket(AF_INET, SOCK_STREAM, 0); 117 if (so < 0) { 123 if (connect(so, (struct sockaddr *) &sain, sizeof(sain)) == 0) { 124 *fdp = so; 127 (void) close(so);
|
/original-bsd/usr.bin/netstat/ |
H A D | unix.c | 46 struct socket sock, *so = &sock; local 60 if (kread((u_long)fp->f_data, (char *)so, sizeof (*so))) 63 if (so->so_proto >= unixsw && so->so_proto <= unixsw + 2) 64 if (so->so_pcb) 65 unixdomainpr(so, fp->f_data); 73 unixdomainpr(so, soaddr) in unixdomainpr() argument 74 register struct socket *so; in unixdomainpr() 82 if (kread((u_long)so->so_pcb, (char *)unp, sizeof (*unp))) 100 soaddr, socktype[so->so_type], so->so_rcv.sb_cc, so->so_snd.sb_cc,
|
/original-bsd/sys/netiso/ |
H A D | tp_usrreq.c | 290 sbwait(&so->so_snd); 352 struct socket *so; in tp_usrreq() 365 if (so->so_error) 387 tpcb = sototpcb(so); 486 soisconnecting(so); 529 so->so_rcv.sb_cc, so->so_rcv.sb_hiwat); 534 so->so_rcv.sb_cc, so->so_rcv.sb_hiwat); 538 so->so_rcv.sb_cc, sbspace(&so->so_rcv), 677 tp_ltrace(so, uio) 678 struct socket *so; variable [all …]
|
H A D | tp_pcb.c | 392 soisdisconnecting(so); 394 IFPERF(sototpcb(so)) 619 struct socket *so; variable 639 if (so->so_snd.sb_hiwat == 0 || so->so_rcv.sb_hiwat == 0) 658 tpcb->tp_sock = so; 721 so->so_pcb = 0; 762 tpcb,so); 770 printf("so_snd at 0x%x so_rcv at 0x%x\n", &so->so_snd, &so->so_rcv); 798 tpcb->tp_npcb, so); 800 so, so->so_head, [all …]
|
H A D | tuba_usrreq.c | 55 tuba_usrreq(so, req, m, nam, control) 56 struct socket *so; variable 73 inp = sotoinpcb(so); 104 isop = (struct isopcb *)so->so_pcb; 105 so->so_pcb = 0; 110 inp = sotoinpcb(so); 197 soisconnecting(so); 237 socantsendmore(so); 269 if (tp && (so->so_options & SO_DEBUG)) 278 struct socket *so; [all …]
|
H A D | clnp_raw.c | 105 rclnp_output(m0, so) 107 struct socket *so; /* socket to send from */ variable 158 rclnp_ctloutput(op, so, level, optname, m) in rclnp_ctloutput() argument 160 struct socket *so; /* ptr to socket */ 245 clnp_usrreq(so, req, m, nam, control) in clnp_usrreq() argument 246 register struct socket *so; in clnp_usrreq() 253 rp = sotorawisopcb(so); 263 so->so_pcb = (caddr_t)rp; 317 soisconnected(so); 321 error = raw_usrreq(so, req, m, nam, control); [all …]
|
/original-bsd/sys/netns/ |
H A D | idp_usrreq.c | 84 soisdisconnected(so); 106 so->so_error = errno; 108 soisdisconnected(so); 185 so = nsp->nsp_socket; 237 struct socket *so; 347 struct socket *so; variable 403 soisconnected(so); 424 socantsendmore(so); 466 sofree(so); 509 struct socket *so; variable [all …]
|
/original-bsd/sys/deprecated/bbnnet/ |
H A D | tcp_usrreq.c | 59 struct socket *so; 321 while (so->so_q0 && (so->so_q0 != so)) 323 while (so->so_q && (so->so_q != so)) 346 struct socket *so; variable 422 if ((so->so_options & SO_LINGER) && so->so_linger == 0) 424 tp = sototcpcb(so); 545 socantsendmore(so); 573 if (so->so_oobmark == 0 && (so->so_state & SS_RCVATMARK) == 0) 658 struct socket *so; 745 tcp_attach(so) [all …]
|
H A D | rdp_usrreq.c | 413 struct socket *so; variable 487 if ((so->so_options & SO_LINGER) && so->so_linger == 0) 488 so->so_linger = 120; 595 socantsendmore(so); 659 struct socket *so; 672 inp = sotoinpcb(so); 713 rdp_attach(so) 714 struct socket *so; variable 721 inp = sotoinpcb(so); 736 struct socket *so; local [all …]
|
H A D | in_pcb.c | 26 in_pcballoc(so, head) 27 struct socket *so; variable 38 inp->inp_socket = so; 42 so->so_pcb = (caddr_t)inp; 330 soisdisconnected(so); 331 sofree(so); 460 advise_user(so, error) 461 struct socket *so; variable 464 if (so == 0) 470 sowwakeup(so); [all …]
|
H A D | udp_usrreq.c | 54 soisdisconnected(so); 114 struct socket *so; variable 123 inp = sotoinpcb(so); 152 error = in_pcballoc(so, &udp); 188 soisconnected(so); 202 soisdisconnected(so); 206 socantsendmore(so); 315 struct socket *so; local 317 so = inp->inp_socket; 319 advise_user(so, error); [all …]
|