sys/kern/uipc_socket.c

396 	SOCKBUF_LOCK_INIT(&so->so_snd, "so_snd");
398 	sx_init(&so->so_snd.sb_sx, "so_snd_sx");
400 	TAILQ_INIT(&so->so_snd.sb_aiojobq);
402 	TASK_INIT(&so->so_snd.sb_aiotask, 0, soaio_snd, so);
450 	if (so->so_snd.sb_hiwat)
452 		    &so->so_snd.sb_hiwat, 0, RLIM_INFINITY);
463 	sx_destroy(&so->so_snd.sb_sx);
465 	SOCKBUF_LOCK_DESTROY(&so->so_snd);
524 	knlist_init_mtx(&so->so_snd.sb_sel.si_note, SOCKBUF_MTX(&so->so_snd));
613 	knlist_init_mtx(&so->so_snd.sb_sel.si_note, SOCKBUF_MTX(&so->so_snd));
615 	if (soreserve(so, head->so_snd.sb_hiwat, head->so_rcv.sb_hiwat)) {
628 	so->so_snd.sb_lowat = head->so_snd.sb_lowat;
630 	so->so_snd.sb_timeo = head->so_snd.sb_timeo;
632 	so->so_snd.sb_flags |= head->so_snd.sb_flags & SB_AUTOSIZE;
836 	sbdestroy(&so->so_snd, so);
838 	seldrain(&so->so_snd.sb_sel);
841 	knlist_destroy(&so->so_snd.sb_sel.si_note);
1087 	SOCKBUF_LOCK(&so->so_snd);
1088 	if (so->so_snd.sb_state & SBS_CANTSENDMORE) {
1089 		SOCKBUF_UNLOCK(&so->so_snd);
1096 		SOCKBUF_UNLOCK(&so->so_snd);
1109 				SOCKBUF_UNLOCK(&so->so_snd);
1118 			SOCKBUF_UNLOCK(&so->so_snd);
1127 	space = sbspace(&so->so_snd);
1131 	SOCKBUF_UNLOCK(&so->so_snd);
1253 	error = sblock(&so->so_snd, SBLOCKWAIT(flags));
1259 		SOCKBUF_LOCK(&so->so_snd);
1260 		if (so->so_snd.sb_state & SBS_CANTSENDMORE) {
1261 			SOCKBUF_UNLOCK(&so->so_snd);
1268 			SOCKBUF_UNLOCK(&so->so_snd);
1282 					SOCKBUF_UNLOCK(&so->so_snd);
1287 				SOCKBUF_UNLOCK(&so->so_snd);
1295 		space = sbspace(&so->so_snd);
1298 		if ((atomic && resid > so->so_snd.sb_hiwat) ||
1299 		    clen > so->so_snd.sb_hiwat) {
1300 			SOCKBUF_UNLOCK(&so->so_snd);
1305 		    (atomic || space < so->so_snd.sb_lowat || space < clen)) {
1307 				SOCKBUF_UNLOCK(&so->so_snd);
1311 			error = sbwait(&so->so_snd);
1312 			SOCKBUF_UNLOCK(&so->so_snd);
1317 		SOCKBUF_UNLOCK(&so->so_snd);
1389 	sbunlock(&so->so_snd);
2627 				    &so->so_snd : &so->so_rcv, (u_long)optval,
2632 				(sopt->sopt_name == SO_SNDBUF ? &so->so_snd :
2641 				SOCKBUF_LOCK(&so->so_snd);
2642 				so->so_snd.sb_lowat =
2643 				    (optval > so->so_snd.sb_hiwat) ?
2644 				    so->so_snd.sb_hiwat : optval;
2645 				SOCKBUF_UNLOCK(&so->so_snd);
2684 				so->so_snd.sb_timeo = val;
2831 			optval = so->so_snd.sb_hiwat;
2839 			optval = so->so_snd.sb_lowat;
2849 			    so->so_snd.sb_timeo : so->so_rcv.sb_timeo);
3068 	SOCKBUF_LOCK(&so->so_snd);
3085 			if (so->so_snd.sb_state & SBS_CANTSENDMORE)
3097 			selrecord(td, &so->so_snd.sb_sel);
3098 			so->so_snd.sb_flags |= SB_SEL;
3103 	SOCKBUF_UNLOCK(&so->so_snd);
3123 		sb = &so->so_snd;
3264 	sb->st_blksize = so->so_snd.sb_hiwat;
3352 	SOCKBUF_LOCK(&so->so_snd);
3353 	knlist_remove(&so->so_snd.sb_sel.si_note, kn, 1);
3354 	if (knlist_empty(&so->so_snd.sb_sel.si_note))
3355 		so->so_snd.sb_flags &= ~SB_KNOTE;
3356 	SOCKBUF_UNLOCK(&so->so_snd);
3366 	SOCKBUF_LOCK_ASSERT(&so->so_snd);
3367 	kn->kn_data = sbspace(&so->so_snd);
3371 	if (so->so_snd.sb_state & SBS_CANTSENDMORE) {
3383 		return (kn->kn_data >= so->so_snd.sb_lowat);
3508 	SOCKBUF_LOCK(&so->so_snd);
3534 	SOCKBUF_LOCK(&so->so_snd);
3535 	sbdrop_locked(&so->so_snd, sbused(&so->so_snd));
3568 		sb = &so->so_snd;
3593 		sb = &so->so_snd;
3634 	sbtoxsockbuf(&so->so_snd, &xso->so_snd);
3666 	return (&so->so_snd);