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);
78 static void sbflush_internal(struct sockbuf *sb);
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; in sbsetopt() local
708 sb = NULL; in sbsetopt()
729 sb = &so->so_snd; in sbsetopt()
734 sb = &so->so_rcv; in sbsetopt()
738 flags = &sb->sb_flags; in sbsetopt()
739 hiwat = &sb->sb_hiwat; in sbsetopt()
740 lowat = &sb->sb_lowat; in sbsetopt()
785 struct sockbuf *sb = sobuf(so, which); in sbrelease_internal() local
787 sbflush_internal(sb); in sbrelease_internal()
788 (void)chgsbsize(so->so_cred->cr_uidinfo, &sb->sb_hiwat, 0, in sbrelease_internal()
790 sb->sb_mbmax = 0; in sbrelease_internal()
815 struct sockbuf *sb = sobuf(so, which); in sbdestroy() local
817 if (sb->sb_tls_info != NULL) in sbdestroy()
818 ktls_free(sb->sb_tls_info); in sbdestroy()
819 sb->sb_tls_info = NULL; in sbdestroy()
848 sblastrecordchk(struct sockbuf *sb, const char *file, int line) in sblastrecordchk() argument
850 struct mbuf *m = sb->sb_mb; in sblastrecordchk()
852 SOCKBUF_LOCK_ASSERT(sb); in sblastrecordchk()
857 if (m != sb->sb_lastrecord) { in sblastrecordchk()
859 __func__, sb->sb_mb, sb->sb_lastrecord, m); in sblastrecordchk()
861 for (m = sb->sb_mb; m != NULL; m = m->m_nextpkt) in sblastrecordchk()
868 sblastmbufchk(struct sockbuf *sb, const char *file, int line) in sblastmbufchk() argument
870 struct mbuf *m = sb->sb_mb; in sblastmbufchk()
873 SOCKBUF_LOCK_ASSERT(sb); in sblastmbufchk()
881 if (m != sb->sb_mbtail) { in sblastmbufchk()
883 __func__, sb->sb_mb, sb->sb_mbtail, m); in sblastmbufchk()
885 for (m = sb->sb_mb; m != NULL; m = m->m_nextpkt) { in sblastmbufchk()
895 m = sb->sb_mtls; in sblastmbufchk()
899 if (m != sb->sb_mtlstail) { in sblastmbufchk()
901 __func__, sb->sb_mtls, sb->sb_mtlstail, m); in sblastmbufchk()
904 for (m = sb->sb_mtls; m != NULL; m = m->m_next) { in sblastmbufchk()
914 #define SBLINKRECORD(sb, m0) do { \ argument
915 SOCKBUF_LOCK_ASSERT(sb); \
916 if ((sb)->sb_lastrecord != NULL) \
917 (sb)->sb_lastrecord->m_nextpkt = (m0); \
919 (sb)->sb_mb = (m0); \
920 (sb)->sb_lastrecord = (m0); \
929 sbappend_locked(struct sockbuf *sb, struct mbuf *m, int flags) in sbappend_locked() argument
933 SOCKBUF_LOCK_ASSERT(sb); in sbappend_locked()
939 SBLASTRECORDCHK(sb); in sbappend_locked()
940 n = sb->sb_mb; in sbappend_locked()
946 sbappendrecord_locked(sb, m); /* XXXXXX!!!! */ in sbappend_locked()
956 if ((n = sb->sb_lastrecord) != NULL) { in sbappend_locked()
959 sbappendrecord_locked(sb, m); /* XXXXXX!!!! */ in sbappend_locked()
968 sb->sb_lastrecord = m; in sbappend_locked()
971 sbcompress(sb, m, n); in sbappend_locked()
972 SBLASTRECORDCHK(sb); in sbappend_locked()
981 sbappend(struct sockbuf *sb, struct mbuf *m, int flags) in sbappend() argument
984 SOCKBUF_LOCK(sb); in sbappend()
985 sbappend_locked(sb, m, flags); in sbappend()
986 SOCKBUF_UNLOCK(sb); in sbappend()
996 sbappend_ktls_rx(struct sockbuf *sb, struct mbuf *m) in sbappend_ktls_rx() argument
1005 SBLASTMBUFCHK(sb); in sbappend_ktls_rx()
1030 sbcompress_ktls_rx(sb, m, sb->sb_mtlstail); in sbappend_ktls_rx()
1031 ktls_check_rx(sb); in sbappend_ktls_rx()
1034 if (ifp != NULL && sb->sb_tls_info->rx_ifp != NULL && in sbappend_ktls_rx()
1035 sb->sb_tls_info->rx_ifp != ifp) in sbappend_ktls_rx()
1036 ktls_input_ifp_mismatch(sb, ifp); in sbappend_ktls_rx()
1046 sbappendstream_locked(struct sockbuf *sb, struct mbuf *m, int flags) in sbappendstream_locked() argument
1048 SOCKBUF_LOCK_ASSERT(sb); in sbappendstream_locked()
1060 if (sb->sb_flags & SB_TLS_RX) { in sbappendstream_locked()
1061 sbappend_ktls_rx(sb, m); in sbappendstream_locked()
1066 KASSERT(sb->sb_mb == sb->sb_lastrecord,("sbappendstream 1")); in sbappendstream_locked()
1068 SBLASTMBUFCHK(sb); in sbappendstream_locked()
1071 if (sb->sb_tls_info != NULL) in sbappendstream_locked()
1072 ktls_seq(sb, m); in sbappendstream_locked()
1078 sbcompress(sb, m, sb->sb_mbtail); in sbappendstream_locked()
1080 sb->sb_lastrecord = sb->sb_mb; in sbappendstream_locked()
1081 SBLASTRECORDCHK(sb); in sbappendstream_locked()
1090 sbappendstream(struct sockbuf *sb, struct mbuf *m, int flags) in sbappendstream() argument
1093 SOCKBUF_LOCK(sb); in sbappendstream()
1094 sbappendstream_locked(sb, m, flags); in sbappendstream()
1095 SOCKBUF_UNLOCK(sb); in sbappendstream()
1100 sbcheck(struct sockbuf *sb, const char *file, int line) in sbcheck() argument
1108 SOCKBUF_LOCK_ASSERT(sb); in sbcheck()
1113 for (m = sb->sb_mb; m; m = n) { in sbcheck()
1117 printf("sb %p empty mbuf %p\n", sb, m); in sbcheck()
1121 if (m != sb->sb_fnrdy) { in sbcheck()
1123 sb, sb->sb_fnrdy, m); in sbcheck()
1131 sb, sb->sb_fnrdy, m); in sbcheck()
1150 ccc += sb->sb_tlsdcc; in sbcheck()
1153 for (m = sb->sb_mtls; m; m = m->m_next) { in sbcheck()
1155 printf("sb %p TLS mbuf %p with nextpkt\n", sb, m); in sbcheck()
1159 printf("sb %p TLS mbuf %p ready\n", sb, m); in sbcheck()
1169 if (sb->sb_tlscc != tlscc) { in sbcheck()
1170 printf("tlscc %ld/%u dcc %u\n", tlscc, sb->sb_tlscc, in sbcheck()
1171 sb->sb_tlsdcc); in sbcheck()
1175 if (acc != sb->sb_acc || ccc != sb->sb_ccc || mbcnt != sb->sb_mbcnt) { in sbcheck()
1177 acc, sb->sb_acc, ccc, sb->sb_ccc, mbcnt, sb->sb_mbcnt); in sbcheck()
1179 printf("tlscc %ld/%u dcc %u\n", tlscc, sb->sb_tlscc, in sbcheck()
1180 sb->sb_tlsdcc); in sbcheck()
1194 sbappendrecord_locked(struct sockbuf *sb, struct mbuf *m0) in sbappendrecord_locked() argument
1198 SOCKBUF_LOCK_ASSERT(sb); in sbappendrecord_locked()
1210 sballoc(sb, m0); in sbappendrecord_locked()
1211 SBLASTRECORDCHK(sb); in sbappendrecord_locked()
1212 SBLINKRECORD(sb, m0); in sbappendrecord_locked()
1213 sb->sb_mbtail = m0; in sbappendrecord_locked()
1221 sbcompress(sb, m, m0); in sbappendrecord_locked()
1228 sbappendrecord(struct sockbuf *sb, struct mbuf *m0) in sbappendrecord() argument
1231 SOCKBUF_LOCK(sb); in sbappendrecord()
1232 sbappendrecord_locked(sb, m0); in sbappendrecord()
1233 SOCKBUF_UNLOCK(sb); in sbappendrecord()
1238 sbappendaddr_locked_internal(struct sockbuf *sb, const struct sockaddr *asa, in sbappendaddr_locked_internal() argument
1278 sballoc(sb, n); in sbappendaddr_locked_internal()
1279 sballoc(sb, n); in sbappendaddr_locked_internal()
1281 SBLINKRECORD(sb, m); in sbappendaddr_locked_internal()
1283 sb->sb_mbtail = nlast; in sbappendaddr_locked_internal()
1284 SBLASTMBUFCHK(sb); in sbappendaddr_locked_internal()
1286 SBLASTRECORDCHK(sb); in sbappendaddr_locked_internal()
1297 sbappendaddr_locked(struct sockbuf *sb, const struct sockaddr *asa, in sbappendaddr_locked() argument
1303 SOCKBUF_LOCK_ASSERT(sb); in sbappendaddr_locked()
1311 if (space > sbspace(sb)) in sbappendaddr_locked()
1313 return (sbappendaddr_locked_internal(sb, asa, m0, control, ctrl_last)); in sbappendaddr_locked()
1323 sbappendaddr_nospacecheck_locked(struct sockbuf *sb, const struct sockaddr *asa, in sbappendaddr_nospacecheck_locked() argument
1328 SOCKBUF_LOCK_ASSERT(sb); in sbappendaddr_nospacecheck_locked()
1331 return (sbappendaddr_locked_internal(sb, asa, m0, control, ctrl_last)); in sbappendaddr_nospacecheck_locked()
1341 sbappendaddr(struct sockbuf *sb, const struct sockaddr *asa, in sbappendaddr() argument
1346 SOCKBUF_LOCK(sb); in sbappendaddr()
1347 retval = sbappendaddr_locked(sb, asa, m0, control); in sbappendaddr()
1348 SOCKBUF_UNLOCK(sb); in sbappendaddr()
1353 sbappendcontrol_locked(struct sockbuf *sb, struct mbuf *m0, in sbappendcontrol_locked() argument
1365 SBLASTRECORDCHK(sb); in sbappendcontrol_locked()
1368 sballoc(sb, m); in sbappendcontrol_locked()
1369 sballoc(sb, m); in sbappendcontrol_locked()
1371 SBLINKRECORD(sb, control); in sbappendcontrol_locked()
1373 sb->sb_mbtail = mlast; in sbappendcontrol_locked()
1374 SBLASTMBUFCHK(sb); in sbappendcontrol_locked()
1376 SBLASTRECORDCHK(sb); in sbappendcontrol_locked()
1380 sbappendcontrol(struct sockbuf *sb, struct mbuf *m0, struct mbuf *control, in sbappendcontrol() argument
1384 SOCKBUF_LOCK(sb); in sbappendcontrol()
1385 sbappendcontrol_locked(sb, m0, control, flags); in sbappendcontrol()
1386 SOCKBUF_UNLOCK(sb); in sbappendcontrol()
1410 sbcompress(struct sockbuf *sb, struct mbuf *m, struct mbuf *n) in sbcompress() argument
1415 SOCKBUF_LOCK_ASSERT(sb); in sbcompress()
1423 if (sb->sb_lastrecord == m) in sbcompress()
1424 sb->sb_lastrecord = m->m_next; in sbcompress()
1430 ((sb->sb_flags & SB_NOCOALESCE) == 0) && in sbcompress()
1440 sb->sb_ccc += m->m_len; in sbcompress()
1441 if (sb->sb_fnrdy == NULL) in sbcompress()
1442 sb->sb_acc += m->m_len; in sbcompress()
1445 sb->sb_ctl += m->m_len; in sbcompress()
1456 sb->sb_mb = m; in sbcompress()
1457 sb->sb_mbtail = m; in sbcompress()
1458 sballoc(sb, m); in sbcompress()
1468 SBLASTMBUFCHK(sb); in sbcompress()
1478 sbcompress_ktls_rx(struct sockbuf *sb, struct mbuf *m, struct mbuf *n) in sbcompress_ktls_rx() argument
1481 SOCKBUF_LOCK_ASSERT(sb); in sbcompress_ktls_rx()
1504 ((sb->sb_flags & SB_NOCOALESCE) == 0) && in sbcompress_ktls_rx()
1511 sb->sb_ccc += m->m_len; in sbcompress_ktls_rx()
1512 sb->sb_tlscc += m->m_len; in sbcompress_ktls_rx()
1519 sb->sb_mtls = m; in sbcompress_ktls_rx()
1520 sb->sb_mtlstail = m; in sbcompress_ktls_rx()
1521 sballoc_ktls_rx(sb, m); in sbcompress_ktls_rx()
1526 SBLASTMBUFCHK(sb); in sbcompress_ktls_rx()
1534 sbflush_internal(struct sockbuf *sb) in sbflush_internal() argument
1537 while (sb->sb_mbcnt || sb->sb_tlsdcc) { in sbflush_internal()
1542 if (sb->sb_ccc == 0 && (sb->sb_mb == NULL || sb->sb_mb->m_len)) in sbflush_internal()
1544 m_freem(sbcut_internal(sb, (int)sb->sb_ccc)); in sbflush_internal()
1546 KASSERT(sb->sb_ccc == 0 && sb->sb_mb == 0 && sb->sb_mbcnt == 0, in sbflush_internal()
1548 sb->sb_ccc, (void *)sb->sb_mb, sb->sb_mbcnt)); in sbflush_internal()
1552 sbflush_locked(struct sockbuf *sb) in sbflush_locked() argument
1555 SOCKBUF_LOCK_ASSERT(sb); in sbflush_locked()
1556 sbflush_internal(sb); in sbflush_locked()
1560 sbflush(struct sockbuf *sb) in sbflush() argument
1563 SOCKBUF_LOCK(sb); in sbflush()
1564 sbflush_locked(sb); in sbflush()
1565 SOCKBUF_UNLOCK(sb); in sbflush()
1572 sbcut_internal(struct sockbuf *sb, int len) in sbcut_internal() argument
1579 KASSERT(len <= sb->sb_ccc, ("%s: len: %d is > ccc: %u", in sbcut_internal()
1580 __func__, len, sb->sb_ccc)); in sbcut_internal()
1582 next = (m = sb->sb_mb) ? m->m_nextpkt : 0; in sbcut_internal()
1590 if (sb->sb_tlsdcc != 0) { in sbcut_internal()
1591 MPASS(len >= sb->sb_tlsdcc); in sbcut_internal()
1592 len -= sb->sb_tlsdcc; in sbcut_internal()
1593 sb->sb_ccc -= sb->sb_tlsdcc; in sbcut_internal()
1594 sb->sb_tlsdcc = 0; in sbcut_internal()
1598 next = sb->sb_mtls; in sbcut_internal()
1611 sb->sb_ccc -= len; in sbcut_internal()
1612 sb->sb_acc -= len; in sbcut_internal()
1613 if (sb->sb_sndptroff != 0) in sbcut_internal()
1614 sb->sb_sndptroff -= len; in sbcut_internal()
1616 sb->sb_ctl -= len; in sbcut_internal()
1622 sbfree_ktls_rx(sb, m); in sbcut_internal()
1625 sbfree(sb, m); in sbcut_internal()
1650 sbfree(sb, m); in sbcut_internal()
1658 sb->sb_mb = NULL; in sbcut_internal()
1659 sb->sb_mtls = m; in sbcut_internal()
1661 sb->sb_mtlstail = NULL; in sbcut_internal()
1665 sb->sb_mb = m; in sbcut_internal()
1668 sb->sb_mb = next; in sbcut_internal()
1673 m = sb->sb_mb; in sbcut_internal()
1675 sb->sb_mbtail = NULL; in sbcut_internal()
1676 sb->sb_lastrecord = NULL; in sbcut_internal()
1678 sb->sb_lastrecord = m; in sbcut_internal()
1688 sbdrop_locked(struct sockbuf *sb, int len) in sbdrop_locked() argument
1691 SOCKBUF_LOCK_ASSERT(sb); in sbdrop_locked()
1692 m_freem(sbcut_internal(sb, len)); in sbdrop_locked()
1700 sbcut_locked(struct sockbuf *sb, int len) in sbcut_locked() argument
1703 SOCKBUF_LOCK_ASSERT(sb); in sbcut_locked()
1704 return (sbcut_internal(sb, len)); in sbcut_locked()
1708 sbdrop(struct sockbuf *sb, int len) in sbdrop() argument
1712 SOCKBUF_LOCK(sb); in sbdrop()
1713 mfree = sbcut_internal(sb, len); in sbdrop()
1714 SOCKBUF_UNLOCK(sb); in sbdrop()
1720 sbsndptr_noadv(struct sockbuf *sb, uint32_t off, uint32_t *moff) in sbsndptr_noadv() argument
1724 KASSERT(sb->sb_mb != NULL, ("%s: sb_mb is NULL", __func__)); in sbsndptr_noadv()
1725 if (sb->sb_sndptr == NULL || sb->sb_sndptroff > off) { in sbsndptr_noadv()
1727 if (sb->sb_sndptr == NULL) { in sbsndptr_noadv()
1728 sb->sb_sndptr = sb->sb_mb; in sbsndptr_noadv()
1729 sb->sb_sndptroff = 0; in sbsndptr_noadv()
1731 return (sb->sb_mb); in sbsndptr_noadv()
1733 m = sb->sb_sndptr; in sbsndptr_noadv()
1734 off -= sb->sb_sndptroff; in sbsndptr_noadv()
1741 sbsndptr_adv(struct sockbuf *sb, struct mbuf *mb, uint32_t len) in sbsndptr_adv() argument
1749 if (mb != sb->sb_sndptr) { in sbsndptr_adv()
1758 sb->sb_sndptroff += m->m_len; in sbsndptr_adv()
1759 sb->sb_sndptr = m->m_next; in sbsndptr_adv()
1773 sbsndmbuf(struct sockbuf *sb, u_int off, u_int *moff) in sbsndmbuf() argument
1777 KASSERT(sb->sb_mb != NULL, ("%s: sb_mb is NULL", __func__)); in sbsndmbuf()
1783 if (sb->sb_sndptr == NULL || sb->sb_sndptroff > off) { in sbsndmbuf()
1784 m = sb->sb_mb; in sbsndmbuf()
1786 m = sb->sb_sndptr; in sbsndmbuf()
1787 off -= sb->sb_sndptroff; in sbsndmbuf()
1804 sbdroprecord_locked(struct sockbuf *sb) in sbdroprecord_locked() argument
1808 SOCKBUF_LOCK_ASSERT(sb); in sbdroprecord_locked()
1810 m = sb->sb_mb; in sbdroprecord_locked()
1812 sb->sb_mb = m->m_nextpkt; in sbdroprecord_locked()
1814 sbfree(sb, m); in sbdroprecord_locked()
1818 SB_EMPTY_FIXUP(sb); in sbdroprecord_locked()
1826 sbdroprecord(struct sockbuf *sb) in sbdroprecord() argument
1829 SOCKBUF_LOCK(sb); in sbdroprecord()
1830 sbdroprecord_locked(sb); in sbdroprecord()
1831 SOCKBUF_UNLOCK(sb); in sbdroprecord()
1885 sbtoxsockbuf(struct sockbuf *sb, struct xsockbuf *xsb) in sbtoxsockbuf() argument
1888 xsb->sb_cc = sb->sb_ccc; in sbtoxsockbuf()
1889 xsb->sb_hiwat = sb->sb_hiwat; in sbtoxsockbuf()
1890 xsb->sb_mbcnt = sb->sb_mbcnt; in sbtoxsockbuf()
1891 xsb->sb_mbmax = sb->sb_mbmax; in sbtoxsockbuf()
1892 xsb->sb_lowat = sb->sb_lowat; in sbtoxsockbuf()
1893 xsb->sb_flags = sb->sb_flags; in sbtoxsockbuf()
1894 xsb->sb_timeo = sb->sb_timeo; in sbtoxsockbuf()