Lines Matching refs:sb
74 static void sbcompress_ktls_rx(struct sockbuf *sb, struct mbuf *m,
77 static struct mbuf *sbcut_internal(struct sockbuf *sb, int len);
107 sbready_compress(struct sockbuf *sb, struct mbuf *m0, struct mbuf *end) in sbready_compress() argument
112 SOCKBUF_LOCK_ASSERT(sb); in sbready_compress()
114 if ((sb->sb_flags & SB_NOCOALESCE) != 0) in sbready_compress()
157 sb->sb_mbcnt -= ext_size; in sbready_compress()
168 KASSERT(sb->sb_lastrecord != n, in sbready_compress()
175 if (sb->sb_mbtail == n) in sbready_compress()
176 sb->sb_mbtail = m; in sbready_compress()
178 sb->sb_mbcnt -= MSIZE; in sbready_compress()
180 sb->sb_mbcnt -= n->m_ext.ext_size; in sbready_compress()
185 SBLASTRECORDCHK(sb); in sbready_compress()
186 SBLASTMBUFCHK(sb); in sbready_compress()
195 sbready(struct sockbuf *sb, struct mbuf *m0, int count) in sbready() argument
200 SOCKBUF_LOCK_ASSERT(sb); in sbready()
201 KASSERT(sb->sb_fnrdy != NULL, ("%s: sb %p NULL fnrdy", __func__, sb)); in sbready()
205 blocker = (sb->sb_fnrdy == m) ? M_BLOCKED : 0; in sbready()
223 sb->sb_acc += m->m_len; in sbready()
238 sbready_compress(sb, m0, m); in sbready()
247 sb->sb_acc += m->m_len; in sbready()
250 sb->sb_fnrdy = m; in sbready()
251 sbready_compress(sb, m0, m); in sbready()
260 sballoc(struct sockbuf *sb, struct mbuf *m) in sballoc() argument
263 SOCKBUF_LOCK_ASSERT(sb); in sballoc()
265 sb->sb_ccc += m->m_len; in sballoc()
267 if (sb->sb_fnrdy == NULL) { in sballoc()
269 sb->sb_fnrdy = m; in sballoc()
271 sb->sb_acc += m->m_len; in sballoc()
276 sb->sb_ctl += m->m_len; in sballoc()
278 sb->sb_mbcnt += MSIZE; in sballoc()
281 sb->sb_mbcnt += m->m_ext.ext_size; in sballoc()
288 sbfree(struct sockbuf *sb, struct mbuf *m) in sbfree() argument
292 SOCKBUF_LOCK_ASSERT(sb); in sbfree()
295 sb->sb_ccc -= m->m_len; in sbfree()
298 sb->sb_acc -= m->m_len; in sbfree()
300 if (m == sb->sb_fnrdy) { in sbfree()
309 sb->sb_acc += n->m_len; in sbfree()
312 sb->sb_fnrdy = n; in sbfree()
316 sb->sb_ctl -= m->m_len; in sbfree()
318 sb->sb_mbcnt -= MSIZE; in sbfree()
320 sb->sb_mbcnt -= m->m_ext.ext_size; in sbfree()
322 if (sb->sb_sndptr == m) { in sbfree()
323 sb->sb_sndptr = NULL; in sbfree()
324 sb->sb_sndptroff = 0; in sbfree()
326 if (sb->sb_sndptroff != 0) in sbfree()
327 sb->sb_sndptroff -= m->m_len; in sbfree()
337 sballoc_ktls_rx(struct sockbuf *sb, struct mbuf *m) in sballoc_ktls_rx() argument
340 SOCKBUF_LOCK_ASSERT(sb); in sballoc_ktls_rx()
342 sb->sb_ccc += m->m_len; in sballoc_ktls_rx()
343 sb->sb_tlscc += m->m_len; in sballoc_ktls_rx()
345 sb->sb_mbcnt += MSIZE; in sballoc_ktls_rx()
348 sb->sb_mbcnt += m->m_ext.ext_size; in sballoc_ktls_rx()
352 sbfree_ktls_rx(struct sockbuf *sb, struct mbuf *m) in sbfree_ktls_rx() argument
356 SOCKBUF_LOCK_ASSERT(sb); in sbfree_ktls_rx()
359 sb->sb_ccc -= m->m_len; in sbfree_ktls_rx()
360 sb->sb_tlscc -= m->m_len; in sbfree_ktls_rx()
362 sb->sb_mbcnt -= MSIZE; in sbfree_ktls_rx()
365 sb->sb_mbcnt -= m->m_ext.ext_size; in sbfree_ktls_rx()
452 struct sockbuf *sb; in sbwait() local
456 sb = sobuf(so, which); in sbwait()
457 sb->sb_flags |= SB_WAIT; in sbwait()
458 return (msleep_sbt(&sb->sb_acc, soeventmtx(so, which), in sbwait()
459 PSOCK | PCATCH, "sbwait", sb->sb_timeo, 0, 0)); in sbwait()
477 struct sockbuf *sb; in sowakeup() local
482 sb = sobuf(so, which); in sowakeup()
483 selwakeuppri(sb->sb_sel, PSOCK); in sowakeup()
484 if (!SEL_WAITING(sb->sb_sel)) in sowakeup()
485 sb->sb_flags &= ~SB_SEL; in sowakeup()
486 if (sb->sb_flags & SB_WAIT) { in sowakeup()
487 sb->sb_flags &= ~SB_WAIT; in sowakeup()
488 wakeup(&sb->sb_acc); in sowakeup()
490 KNOTE_LOCKED(&sb->sb_sel->si_note, 0); in sowakeup()
491 if (sb->sb_upcall != NULL) { in sowakeup()
492 ret = sb->sb_upcall(so, sb->sb_upcallarg, M_NOWAIT); in sowakeup()
494 KASSERT(sb == &so->so_rcv, in sowakeup()
500 if (sb->sb_flags & SB_AIO) in sowakeup()
540 sb_notify(const struct sockbuf *sb) in sb_notify() argument
542 return ((sb->sb_flags & (SB_WAIT | SB_SEL | SB_ASYNC | in sb_notify()
653 struct sockbuf *sb = sobuf(so, which); in sbreserve_locked_limit() local
671 if (!chgsbsize(so->so_cred->cr_uidinfo, &sb->sb_hiwat, cc, in sbreserve_locked_limit()
674 sb->sb_mbmax = min(cc * sb_efficiency, buf_max); in sbreserve_locked_limit()
675 if (sb->sb_lowat > sb->sb_hiwat) in sbreserve_locked_limit()
676 sb->sb_lowat = sb->sb_hiwat; in sbreserve_locked_limit()
690 struct sockbuf *sb = sobuf(so, which); in sbunreserve_locked() local
694 (void)chgsbsize(so->so_cred->cr_uidinfo, &sb->sb_hiwat, 0, in sbunreserve_locked()
696 sb->sb_mbmax = 0; in sbunreserve_locked()
702 struct sockbuf *sb; in sbsetopt() local
720 sb = NULL; in sbsetopt()
741 sb = &so->so_snd; in sbsetopt()
746 sb = &so->so_rcv; in sbsetopt()
750 flags = &sb->sb_flags; in sbsetopt()
751 hiwat = &sb->sb_hiwat; in sbsetopt()
752 lowat = &sb->sb_lowat; in sbsetopt()
797 struct sockbuf *sb = sobuf(so, which); in sbrelease_locked() local
801 sbflush_locked(sb); in sbrelease_locked()
818 struct sockbuf *sb = sobuf(so, which); in sbdestroy() local
820 if (sb->sb_tls_info != NULL) in sbdestroy()
821 ktls_free(sb->sb_tls_info); in sbdestroy()
822 sb->sb_tls_info = NULL; in sbdestroy()
851 sblastrecordchk(struct sockbuf *sb, const char *file, int line) in sblastrecordchk() argument
853 struct mbuf *m = sb->sb_mb; in sblastrecordchk()
855 SOCKBUF_LOCK_ASSERT(sb); in sblastrecordchk()
860 if (m != sb->sb_lastrecord) { in sblastrecordchk()
862 __func__, sb->sb_mb, sb->sb_lastrecord, m); in sblastrecordchk()
864 for (m = sb->sb_mb; m != NULL; m = m->m_nextpkt) in sblastrecordchk()
871 sblastmbufchk(struct sockbuf *sb, const char *file, int line) in sblastmbufchk() argument
873 struct mbuf *m = sb->sb_mb; in sblastmbufchk()
876 SOCKBUF_LOCK_ASSERT(sb); in sblastmbufchk()
884 if (m != sb->sb_mbtail) { in sblastmbufchk()
886 __func__, sb->sb_mb, sb->sb_mbtail, m); in sblastmbufchk()
888 for (m = sb->sb_mb; m != NULL; m = m->m_nextpkt) { in sblastmbufchk()
898 m = sb->sb_mtls; in sblastmbufchk()
902 if (m != sb->sb_mtlstail) { in sblastmbufchk()
904 __func__, sb->sb_mtls, sb->sb_mtlstail, m); in sblastmbufchk()
907 for (m = sb->sb_mtls; m != NULL; m = m->m_next) { in sblastmbufchk()
917 #define SBLINKRECORD(sb, m0) do { \ argument
918 SOCKBUF_LOCK_ASSERT(sb); \
919 if ((sb)->sb_lastrecord != NULL) \
920 (sb)->sb_lastrecord->m_nextpkt = (m0); \
922 (sb)->sb_mb = (m0); \
923 (sb)->sb_lastrecord = (m0); \
932 sbappend_locked(struct sockbuf *sb, struct mbuf *m, int flags) in sbappend_locked() argument
936 SOCKBUF_LOCK_ASSERT(sb); in sbappend_locked()
942 SBLASTRECORDCHK(sb); in sbappend_locked()
943 n = sb->sb_mb; in sbappend_locked()
949 sbappendrecord_locked(sb, m); /* XXXXXX!!!! */ in sbappend_locked()
959 if ((n = sb->sb_lastrecord) != NULL) { in sbappend_locked()
962 sbappendrecord_locked(sb, m); /* XXXXXX!!!! */ in sbappend_locked()
971 sb->sb_lastrecord = m; in sbappend_locked()
974 sbcompress(sb, m, n); in sbappend_locked()
975 SBLASTRECORDCHK(sb); in sbappend_locked()
984 sbappend(struct sockbuf *sb, struct mbuf *m, int flags) in sbappend() argument
987 SOCKBUF_LOCK(sb); in sbappend()
988 sbappend_locked(sb, m, flags); in sbappend()
989 SOCKBUF_UNLOCK(sb); in sbappend()
999 sbappend_ktls_rx(struct sockbuf *sb, struct mbuf *m) in sbappend_ktls_rx() argument
1008 SBLASTMBUFCHK(sb); in sbappend_ktls_rx()
1033 sbcompress_ktls_rx(sb, m, sb->sb_mtlstail); in sbappend_ktls_rx()
1034 ktls_check_rx(sb); in sbappend_ktls_rx()
1037 if (ifp != NULL && sb->sb_tls_info->rx_ifp != NULL && in sbappend_ktls_rx()
1038 sb->sb_tls_info->rx_ifp != ifp) in sbappend_ktls_rx()
1039 ktls_input_ifp_mismatch(sb, ifp); in sbappend_ktls_rx()
1049 sbappendstream_locked(struct sockbuf *sb, struct mbuf *m, int flags) in sbappendstream_locked() argument
1051 SOCKBUF_LOCK_ASSERT(sb); in sbappendstream_locked()
1063 if (sb->sb_flags & SB_TLS_RX) { in sbappendstream_locked()
1064 sbappend_ktls_rx(sb, m); in sbappendstream_locked()
1069 KASSERT(sb->sb_mb == sb->sb_lastrecord,("sbappendstream 1")); in sbappendstream_locked()
1071 SBLASTMBUFCHK(sb); in sbappendstream_locked()
1074 if (sb->sb_tls_info != NULL) in sbappendstream_locked()
1075 ktls_seq(sb, m); in sbappendstream_locked()
1081 sbcompress(sb, m, sb->sb_mbtail); in sbappendstream_locked()
1083 sb->sb_lastrecord = sb->sb_mb; in sbappendstream_locked()
1084 SBLASTRECORDCHK(sb); in sbappendstream_locked()
1093 sbappendstream(struct sockbuf *sb, struct mbuf *m, int flags) in sbappendstream() argument
1096 SOCKBUF_LOCK(sb); in sbappendstream()
1097 sbappendstream_locked(sb, m, flags); in sbappendstream()
1098 SOCKBUF_UNLOCK(sb); in sbappendstream()
1103 sbcheck(struct sockbuf *sb, const char *file, int line) in sbcheck() argument
1111 SOCKBUF_LOCK_ASSERT(sb); in sbcheck()
1116 for (m = sb->sb_mb; m; m = n) { in sbcheck()
1120 printf("sb %p empty mbuf %p\n", sb, m); in sbcheck()
1124 if (m != sb->sb_fnrdy) { in sbcheck()
1126 sb, sb->sb_fnrdy, m); in sbcheck()
1134 sb, sb->sb_fnrdy, m); in sbcheck()
1153 ccc += sb->sb_tlsdcc; in sbcheck()
1156 for (m = sb->sb_mtls; m; m = m->m_next) { in sbcheck()
1158 printf("sb %p TLS mbuf %p with nextpkt\n", sb, m); in sbcheck()
1162 printf("sb %p TLS mbuf %p ready\n", sb, m); in sbcheck()
1172 if (sb->sb_tlscc != tlscc) { in sbcheck()
1173 printf("tlscc %ld/%u dcc %u\n", tlscc, sb->sb_tlscc, in sbcheck()
1174 sb->sb_tlsdcc); in sbcheck()
1178 if (acc != sb->sb_acc || ccc != sb->sb_ccc || mbcnt != sb->sb_mbcnt) { in sbcheck()
1180 acc, sb->sb_acc, ccc, sb->sb_ccc, mbcnt, sb->sb_mbcnt); in sbcheck()
1182 printf("tlscc %ld/%u dcc %u\n", tlscc, sb->sb_tlscc, in sbcheck()
1183 sb->sb_tlsdcc); in sbcheck()
1197 sbappendrecord_locked(struct sockbuf *sb, struct mbuf *m0) in sbappendrecord_locked() argument
1201 SOCKBUF_LOCK_ASSERT(sb); in sbappendrecord_locked()
1213 sballoc(sb, m0); in sbappendrecord_locked()
1214 SBLASTRECORDCHK(sb); in sbappendrecord_locked()
1215 SBLINKRECORD(sb, m0); in sbappendrecord_locked()
1216 sb->sb_mbtail = m0; in sbappendrecord_locked()
1224 sbcompress(sb, m, m0); in sbappendrecord_locked()
1231 sbappendrecord(struct sockbuf *sb, struct mbuf *m0) in sbappendrecord() argument
1234 SOCKBUF_LOCK(sb); in sbappendrecord()
1235 sbappendrecord_locked(sb, m0); in sbappendrecord()
1236 SOCKBUF_UNLOCK(sb); in sbappendrecord()
1241 sbappendaddr_locked_internal(struct sockbuf *sb, const struct sockaddr *asa, in sbappendaddr_locked_internal() argument
1281 sballoc(sb, n); in sbappendaddr_locked_internal()
1282 sballoc(sb, n); in sbappendaddr_locked_internal()
1284 SBLINKRECORD(sb, m); in sbappendaddr_locked_internal()
1286 sb->sb_mbtail = nlast; in sbappendaddr_locked_internal()
1287 SBLASTMBUFCHK(sb); in sbappendaddr_locked_internal()
1289 SBLASTRECORDCHK(sb); in sbappendaddr_locked_internal()
1300 sbappendaddr_locked(struct sockbuf *sb, const struct sockaddr *asa, in sbappendaddr_locked() argument
1306 SOCKBUF_LOCK_ASSERT(sb); in sbappendaddr_locked()
1314 if (space > sbspace(sb)) in sbappendaddr_locked()
1316 return (sbappendaddr_locked_internal(sb, asa, m0, control, ctrl_last)); in sbappendaddr_locked()
1326 sbappendaddr_nospacecheck_locked(struct sockbuf *sb, const struct sockaddr *asa, in sbappendaddr_nospacecheck_locked() argument
1331 SOCKBUF_LOCK_ASSERT(sb); in sbappendaddr_nospacecheck_locked()
1334 return (sbappendaddr_locked_internal(sb, asa, m0, control, ctrl_last)); in sbappendaddr_nospacecheck_locked()
1344 sbappendaddr(struct sockbuf *sb, const struct sockaddr *asa, in sbappendaddr() argument
1349 SOCKBUF_LOCK(sb); in sbappendaddr()
1350 retval = sbappendaddr_locked(sb, asa, m0, control); in sbappendaddr()
1351 SOCKBUF_UNLOCK(sb); in sbappendaddr()
1356 sbappendcontrol_locked(struct sockbuf *sb, struct mbuf *m0, in sbappendcontrol_locked() argument
1368 SBLASTRECORDCHK(sb); in sbappendcontrol_locked()
1371 sballoc(sb, m); in sbappendcontrol_locked()
1372 sballoc(sb, m); in sbappendcontrol_locked()
1374 SBLINKRECORD(sb, control); in sbappendcontrol_locked()
1376 sb->sb_mbtail = mlast; in sbappendcontrol_locked()
1377 SBLASTMBUFCHK(sb); in sbappendcontrol_locked()
1379 SBLASTRECORDCHK(sb); in sbappendcontrol_locked()
1383 sbappendcontrol(struct sockbuf *sb, struct mbuf *m0, struct mbuf *control, in sbappendcontrol() argument
1387 SOCKBUF_LOCK(sb); in sbappendcontrol()
1388 sbappendcontrol_locked(sb, m0, control, flags); in sbappendcontrol()
1389 SOCKBUF_UNLOCK(sb); in sbappendcontrol()
1413 sbcompress(struct sockbuf *sb, struct mbuf *m, struct mbuf *n) in sbcompress() argument
1418 SOCKBUF_LOCK_ASSERT(sb); in sbcompress()
1426 if (sb->sb_lastrecord == m) in sbcompress()
1427 sb->sb_lastrecord = m->m_next; in sbcompress()
1433 ((sb->sb_flags & SB_NOCOALESCE) == 0) && in sbcompress()
1443 sb->sb_ccc += m->m_len; in sbcompress()
1444 if (sb->sb_fnrdy == NULL) in sbcompress()
1445 sb->sb_acc += m->m_len; in sbcompress()
1448 sb->sb_ctl += m->m_len; in sbcompress()
1459 sb->sb_mb = m; in sbcompress()
1460 sb->sb_mbtail = m; in sbcompress()
1461 sballoc(sb, m); in sbcompress()
1471 SBLASTMBUFCHK(sb); in sbcompress()
1481 sbcompress_ktls_rx(struct sockbuf *sb, struct mbuf *m, struct mbuf *n) in sbcompress_ktls_rx() argument
1484 SOCKBUF_LOCK_ASSERT(sb); in sbcompress_ktls_rx()
1507 ((sb->sb_flags & SB_NOCOALESCE) == 0) && in sbcompress_ktls_rx()
1514 sb->sb_ccc += m->m_len; in sbcompress_ktls_rx()
1515 sb->sb_tlscc += m->m_len; in sbcompress_ktls_rx()
1522 sb->sb_mtls = m; in sbcompress_ktls_rx()
1523 sb->sb_mtlstail = m; in sbcompress_ktls_rx()
1524 sballoc_ktls_rx(sb, m); in sbcompress_ktls_rx()
1529 SBLASTMBUFCHK(sb); in sbcompress_ktls_rx()
1537 sbflush_locked(struct sockbuf *sb) in sbflush_locked() argument
1540 SOCKBUF_LOCK_ASSERT(sb); in sbflush_locked()
1542 while (sb->sb_mbcnt || sb->sb_tlsdcc) { in sbflush_locked()
1547 if (sb->sb_ccc == 0 && (sb->sb_mb == NULL || sb->sb_mb->m_len)) in sbflush_locked()
1549 m_freem(sbcut_internal(sb, (int)sb->sb_ccc)); in sbflush_locked()
1551 KASSERT(sb->sb_ccc == 0 && sb->sb_mb == 0 && sb->sb_mbcnt == 0, in sbflush_locked()
1553 sb->sb_ccc, (void *)sb->sb_mb, sb->sb_mbcnt)); in sbflush_locked()
1557 sbflush(struct sockbuf *sb) in sbflush() argument
1560 SOCKBUF_LOCK(sb); in sbflush()
1561 sbflush_locked(sb); in sbflush()
1562 SOCKBUF_UNLOCK(sb); in sbflush()
1569 sbcut_internal(struct sockbuf *sb, int len) in sbcut_internal() argument
1576 KASSERT(len <= sb->sb_ccc, ("%s: len: %d is > ccc: %u", in sbcut_internal()
1577 __func__, len, sb->sb_ccc)); in sbcut_internal()
1579 next = (m = sb->sb_mb) ? m->m_nextpkt : 0; in sbcut_internal()
1587 if (sb->sb_tlsdcc != 0) { in sbcut_internal()
1588 MPASS(len >= sb->sb_tlsdcc); in sbcut_internal()
1589 len -= sb->sb_tlsdcc; in sbcut_internal()
1590 sb->sb_ccc -= sb->sb_tlsdcc; in sbcut_internal()
1591 sb->sb_tlsdcc = 0; in sbcut_internal()
1595 next = sb->sb_mtls; in sbcut_internal()
1608 sb->sb_ccc -= len; in sbcut_internal()
1609 sb->sb_acc -= len; in sbcut_internal()
1610 if (sb->sb_sndptroff != 0) in sbcut_internal()
1611 sb->sb_sndptroff -= len; in sbcut_internal()
1613 sb->sb_ctl -= len; in sbcut_internal()
1619 sbfree_ktls_rx(sb, m); in sbcut_internal()
1622 sbfree(sb, m); in sbcut_internal()
1647 sbfree(sb, m); in sbcut_internal()
1655 sb->sb_mb = NULL; in sbcut_internal()
1656 sb->sb_mtls = m; in sbcut_internal()
1658 sb->sb_mtlstail = NULL; in sbcut_internal()
1662 sb->sb_mb = m; in sbcut_internal()
1665 sb->sb_mb = next; in sbcut_internal()
1670 m = sb->sb_mb; in sbcut_internal()
1672 sb->sb_mbtail = NULL; in sbcut_internal()
1673 sb->sb_lastrecord = NULL; in sbcut_internal()
1675 sb->sb_lastrecord = m; in sbcut_internal()
1685 sbdrop_locked(struct sockbuf *sb, int len) in sbdrop_locked() argument
1688 SOCKBUF_LOCK_ASSERT(sb); in sbdrop_locked()
1689 m_freem(sbcut_internal(sb, len)); in sbdrop_locked()
1697 sbcut_locked(struct sockbuf *sb, int len) in sbcut_locked() argument
1700 SOCKBUF_LOCK_ASSERT(sb); in sbcut_locked()
1701 return (sbcut_internal(sb, len)); in sbcut_locked()
1705 sbdrop(struct sockbuf *sb, int len) in sbdrop() argument
1709 SOCKBUF_LOCK(sb); in sbdrop()
1710 mfree = sbcut_internal(sb, len); in sbdrop()
1711 SOCKBUF_UNLOCK(sb); in sbdrop()
1717 sbsndptr_noadv(struct sockbuf *sb, uint32_t off, uint32_t *moff) in sbsndptr_noadv() argument
1721 KASSERT(sb->sb_mb != NULL, ("%s: sb_mb is NULL", __func__)); in sbsndptr_noadv()
1722 if (sb->sb_sndptr == NULL || sb->sb_sndptroff > off) { in sbsndptr_noadv()
1724 if (sb->sb_sndptr == NULL) { in sbsndptr_noadv()
1725 sb->sb_sndptr = sb->sb_mb; in sbsndptr_noadv()
1726 sb->sb_sndptroff = 0; in sbsndptr_noadv()
1728 return (sb->sb_mb); in sbsndptr_noadv()
1730 m = sb->sb_sndptr; in sbsndptr_noadv()
1731 off -= sb->sb_sndptroff; in sbsndptr_noadv()
1738 sbsndptr_adv(struct sockbuf *sb, struct mbuf *mb, uint32_t len) in sbsndptr_adv() argument
1746 if (mb != sb->sb_sndptr) { in sbsndptr_adv()
1755 sb->sb_sndptroff += m->m_len; in sbsndptr_adv()
1756 sb->sb_sndptr = m->m_next; in sbsndptr_adv()
1770 sbsndmbuf(struct sockbuf *sb, u_int off, u_int *moff) in sbsndmbuf() argument
1774 KASSERT(sb->sb_mb != NULL, ("%s: sb_mb is NULL", __func__)); in sbsndmbuf()
1780 if (sb->sb_sndptr == NULL || sb->sb_sndptroff > off) { in sbsndmbuf()
1781 m = sb->sb_mb; in sbsndmbuf()
1783 m = sb->sb_sndptr; in sbsndmbuf()
1784 off -= sb->sb_sndptroff; in sbsndmbuf()
1801 sbdroprecord_locked(struct sockbuf *sb) in sbdroprecord_locked() argument
1805 SOCKBUF_LOCK_ASSERT(sb); in sbdroprecord_locked()
1807 m = sb->sb_mb; in sbdroprecord_locked()
1809 sb->sb_mb = m->m_nextpkt; in sbdroprecord_locked()
1811 sbfree(sb, m); in sbdroprecord_locked()
1815 SB_EMPTY_FIXUP(sb); in sbdroprecord_locked()
1823 sbdroprecord(struct sockbuf *sb) in sbdroprecord() argument
1826 SOCKBUF_LOCK(sb); in sbdroprecord()
1827 sbdroprecord_locked(sb); in sbdroprecord()
1828 SOCKBUF_UNLOCK(sb); in sbdroprecord()
1882 sbtoxsockbuf(struct sockbuf *sb, struct xsockbuf *xsb) in sbtoxsockbuf() argument
1885 xsb->sb_cc = sb->sb_ccc; in sbtoxsockbuf()
1886 xsb->sb_hiwat = sb->sb_hiwat; in sbtoxsockbuf()
1887 xsb->sb_mbcnt = sb->sb_mbcnt; in sbtoxsockbuf()
1888 xsb->sb_mbmax = sb->sb_mbmax; in sbtoxsockbuf()
1889 xsb->sb_lowat = sb->sb_lowat; in sbtoxsockbuf()
1890 xsb->sb_flags = sb->sb_flags; in sbtoxsockbuf()
1891 xsb->sb_timeo = sb->sb_timeo; in sbtoxsockbuf()