/freebsd/sys/kern/ |
H A D | uipc_debug.c | 198 db_print_sbstate(short sb_state) in db_print_sbstate() argument 203 if (sb_state & SBS_CANTSENDMORE) { in db_print_sbstate() 207 if (sb_state & SBS_CANTRCVMORE) { in db_print_sbstate() 211 if (sb_state & SBS_RCVATMARK) { in db_print_sbstate() 355 db_printf("sb_state: 0x%x (", sb->sb_state); in db_print_sockbuf() 356 db_print_sbstate(sb->sb_state); in db_print_sockbuf()
|
H A D | sys_socket.c | 254 *(int *)data = (so->so_rcv.sb_state & SBS_RCVATMARK) != 0; in soo_ioctl() 317 if ((sb->sb_state & SBS_CANTRCVMORE) == 0 || sbavail(sb)) in soo_stat() 324 if ((sb->sb_state & SBS_CANTSENDMORE) == 0) in soo_stat() 393 so->so_rcv.sb_state; in soo_fill_kinfo() 395 so->so_snd.sb_state; in soo_fill_kinfo() 408 so->so_rcv.sb_state; in soo_fill_kinfo() 410 so->so_snd.sb_state; in soo_fill_kinfo()
|
H A D | uipc_socket.c | 559 if ((sb_src->sb_state & SBS_CANTRCVMORE) != 0) in so_splice_xfer_data() 584 if ((sb_dst->sb_state & SBS_CANTSENDMORE) != 0) in so_splice_xfer_data() 2166 if (so->so_snd.sb_state & SBS_CANTSENDMORE) { 2372 if (so->so_snd.sb_state & SBS_CANTSENDMORE) { 2774 if (so->so_rcv.sb_state & SBS_CANTRCVMORE) { 2990 so->so_rcv.sb_state &= ~SBS_RCVATMARK; 3092 so->so_rcv.sb_state |= SBS_RCVATMARK; 3114 so->so_rcv.sb_state & SBS_CANTRCVMORE) 3127 so->so_rcv.sb_state & SBS_CANTRCVMORE))) 3188 (flags & MSG_EOR) == 0 && (so->so_rcv.sb_state & SBS_CANTRCVMORE) == 0) { [all …]
|
H A D | uipc_usrreq.c | 1000 } else if (so->so_snd.sb_state & SBS_CANTSENDMORE) { in uipc_send() 1108 if (__predict_false(sb->sb_state & SBS_CANTRCVMORE)) in uipc_dgram_sbspace() 1215 if (so->so_snd.sb_state & SBS_CANTSENDMORE) { in uipc_sosend_dgram() 1482 if (so->so_rcv.sb_state & SBS_CANTRCVMORE || in uipc_soreceive_dgram() 2152 if (__predict_true((so2->so_rcv.sb_state & in unp_disconnect() 3290 sb->sb_state |= SBS_CANTRCVMORE; in unp_dispose()
|
H A D | uipc_sockbuf.c | 384 so->so_snd.sb_state |= SBS_CANTSENDMORE; in socantsendmore_locked() 404 so->so_rcv.sb_state |= SBS_CANTRCVMORE; in socantrcvmore_locked()
|
H A D | uipc_ktls.c | 2234 if ((sb->sb_state & SBS_CANTRCVMORE) != 0 && sb->sb_tlscc != 0) in ktls_check_rx() 2243 if ((sb->sb_state & SBS_CANTRCVMORE) != 0) in ktls_check_rx() 2740 if ((sb->sb_state & SBS_CANTRCVMORE) != 0 && sb->sb_tlscc > 0) in ktls_decrypt()
|
H A D | kern_sendfile.c | 783 if (so->so_snd.sb_state & SBS_CANTSENDMORE) { in vn_sendfile()
|
/freebsd/sys/netinet/ |
H A D | accf_http.c | 153 if ((so->so_rcv.sb_state & SBS_CANTRCVMORE) == 0 && in sohashttpget() 203 if ((so->so_rcv.sb_state & SBS_CANTRCVMORE) != 0 || sbfull(&so->so_rcv)) in soparsehttpvers() 284 if ((so->so_rcv.sb_state & SBS_CANTRCVMORE) != 0 || sbfull(&so->so_rcv)) in soishttpconnected()
|
H A D | accf_tls.c | 77 if ((sb->sb_state & SBS_CANTRCVMORE) || sbfull(sb)) in so_hastls()
|
H A D | tcp_reass.c | 961 if (so->so_rcv.sb_state & SBS_CANTRCVMORE) { in tcp_reass() 1067 if (so->so_rcv.sb_state & SBS_CANTRCVMORE) { in tcp_reass()
|
H A D | tcp_timer.c | 358 (inp->inp_socket->so_rcv.sb_state & SBS_CANTRCVMORE)) { in tcp_timer_2msl()
|
H A D | tcp_input.c | 1938 if (so->so_rcv.sb_state & SBS_CANTRCVMORE) { in tcp_do_segment() 3083 if (so->so_rcv.sb_state & SBS_CANTRCVMORE) { in tcp_do_segment() 3184 so->so_rcv.sb_state |= SBS_RCVATMARK; in tcp_do_segment() 3262 if (so->so_rcv.sb_state & SBS_CANTRCVMORE) in tcp_do_segment()
|
/freebsd/sys/dev/cxgbe/cxgbei/ |
H A D | cxgbei.c | 420 while (sbused(sb) != 0 && (sb->sb_state & SBS_CANTRCVMORE) == 0) { in parse_pdus() 531 if (__predict_false(icc == NULL || sb->sb_state & SBS_CANTRCVMORE)) { in do_rx_iscsi_ddp() 534 __func__, tid, pdu_len, icc, sb->sb_state); in do_rx_iscsi_ddp() 784 if (__predict_false(sb->sb_state & SBS_CANTRCVMORE)) { in do_rx_iscsi_cmp() 787 __func__, tid, pdu_len, icc, sb->sb_state); in do_rx_iscsi_cmp()
|
/freebsd/sys/dev/hyperv/hvsock/ |
H A D | hv_sock.c | 667 if ((sb->sb_state & SBS_CANTRCVMORE) && in hvs_trans_soreceive() 722 if (sb->sb_state & SBS_CANTRCVMORE) in hvs_trans_soreceive() 765 if (so->so_snd.sb_state & SBS_CANTSENDMORE) { in hvs_trans_soreceive() 817 if ((sb->sb_state & SBS_CANTSENDMORE) || in hvs_trans_sosend()
|
/freebsd/sys/sys/ |
H A D | socketvar.h | 363 (soreadabledata(so) || ((so)->so_rcv.sb_state & SBS_CANTRCVMORE)) 378 ((so)->so_snd.sb_state & SBS_CANTSENDMORE) || \
|
H A D | sockbuf.h | 90 short sb_state; /* socket state on sockbuf */ member
|
/freebsd/sys/ofed/drivers/infiniband/ulp/sdp/ |
H A D | sdp_main.c | 1092 if (so->so_snd.sb_state & SBS_CANTSENDMORE) { in sdp_sosend() 1292 if (sb->sb_state & SBS_CANTRCVMORE) { in sdp_sorecv() 1480 (so->so_rcv.sb_state & SBS_RCVATMARK) == 0) || in sdp_rcvoob()
|
/freebsd/sys/netsmb/ |
H A D | smb_trantcp.c | 347 (so->so_rcv.sb_state & SBS_CANTRCVMORE)) { in nbssn_recv()
|
/freebsd/sys/dev/cxgbe/tom/ |
H A D | t4_cpl_io.c | 1475 if (so->so_rcv.sb_state & SBS_CANTRCVMORE) in do_close_con_rpl() 1712 if (__predict_false(sb->sb_state & SBS_CANTRCVMORE)) { in do_rx_data() 2196 if (so->so_snd.sb_state & SBS_CANTSENDMORE) { in t4_aiotx_process_job()
|
H A D | t4_ddp.c | 2396 if (sb->sb_state & SBS_CANTRCVMORE && sbavail(sb) == 0) { in aio_ddp_requeue() 2470 if (sb->sb_state & SBS_CANTRCVMORE && sbavail(sb) == 0) { in aio_ddp_requeue() 2907 if (so->so_error != 0 || (sb->sb_state & SBS_CANTRCVMORE) != 0) { in ddp_rcvbuf_requeue()
|
H A D | t4_tls.c | 878 if (__predict_false(sb->sb_state & SBS_CANTRCVMORE)) { in do_rx_tls_cmp()
|
/freebsd/sys/dev/cxgbe/iw_cxgbe/ |
H A D | cm.c | 1126 so->so_error, so->so_rcv.sb_state, ep, states[state]); in process_socket_event() 1167 if ((so->so_rcv.sb_state & SBS_CANTRCVMORE) && state <= CLOSING) { in process_socket_event() 1199 __func__, so, so->so_state, so->so_error, so->so_rcv.sb_state, in process_socket_event()
|
/freebsd/sys/dev/nvmf/ |
H A D | nvmf_tcp.c | 1110 if ((so->so_rcv.sb_state & SBS_CANTRCVMORE) != 0) { in nvmf_tcp_receive() 1201 if ((so->so_rcv.sb_state & SBS_CANTRCVMORE) == 0) { in nvmf_tcp_receive()
|
/freebsd/sys/netgraph/ |
H A D | ng_ksocket.c | 1242 if (so->so_rcv.sb_state & SBS_CANTRCVMORE && in ng_ksocket_incoming2()
|
/freebsd/lib/libprocstat/ |
H A D | libprocstat.c | 1525 sock->so_rcv_sb_state = s.so_rcv.sb_state; in procstat_get_socket_info_kvm() 1526 sock->so_snd_sb_state = s.so_snd.sb_state; in procstat_get_socket_info_kvm()
|