/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() 359 db_printf("sb_state: 0x%x (", sb->sb_state); in db_print_sockbuf() 360 db_print_sbstate(sb->sb_state); in db_print_sockbuf()
|
H A D | sys_socket.c | 253 *(int *)data = (so->so_rcv.sb_state & SBS_RCVATMARK) != 0; in soo_ioctl() 316 if ((sb->sb_state & SBS_CANTRCVMORE) == 0 || sbavail(sb)) in soo_stat() 323 if ((sb->sb_state & SBS_CANTSENDMORE) == 0) in soo_stat() 378 so->so_rcv.sb_state; in soo_fill_kinfo() 380 so->so_snd.sb_state; in soo_fill_kinfo() 393 so->so_rcv.sb_state; in soo_fill_kinfo() 395 so->so_snd.sb_state; in soo_fill_kinfo()
|
H A D | uipc_socket.c | 1532 if (so->so_snd.sb_state & SBS_CANTSENDMORE) { 2139 if (so->so_rcv.sb_state & SBS_CANTRCVMORE) { 2355 so->so_rcv.sb_state &= ~SBS_RCVATMARK; 2457 so->so_rcv.sb_state |= SBS_RCVATMARK; 2479 so->so_rcv.sb_state & SBS_CANTRCVMORE) 2652 if (sb->sb_state & SBS_CANTRCVMORE) { 2845 if (so->so_rcv.sb_state & SBS_CANTRCVMORE || 3684 (so->so_rcv.sb_state & SBS_RCVATMARK)) 3693 if (so->so_rcv.sb_state & SBS_CANTRCVMORE) 3791 if (so->so_rcv.sb_state & SBS_CANTRCVMORE) { [all …]
|
H A D | uipc_usrreq.c | 977 } else if (so->so_snd.sb_state & SBS_CANTSENDMORE) { in uipc_send() 1085 if (__predict_false(sb->sb_state & SBS_CANTRCVMORE)) in uipc_dgram_sbspace() 1192 if (so->so_snd.sb_state & SBS_CANTSENDMORE) { in uipc_sosend_dgram() 1459 if (so->so_rcv.sb_state & SBS_CANTRCVMORE || in uipc_soreceive_dgram() 2129 if (__predict_true((so2->so_rcv.sb_state & in unp_disconnect() 3266 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 | 2215 if ((sb->sb_state & SBS_CANTRCVMORE) != 0 && sb->sb_tlscc != 0) in ktls_check_rx() 2224 if ((sb->sb_state & SBS_CANTRCVMORE) != 0) in ktls_check_rx() 2721 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 | 1941 if (so->so_rcv.sb_state & SBS_CANTRCVMORE) { in tcp_do_segment() 3037 if (so->so_rcv.sb_state & SBS_CANTRCVMORE) { in tcp_do_segment() 3138 so->so_rcv.sb_state |= SBS_RCVATMARK; in tcp_do_segment() 3216 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 | 329 (soreadabledata(so) || ((so)->so_rcv.sb_state & SBS_CANTRCVMORE)) 336 ((so)->so_snd.sb_state & SBS_CANTSENDMORE) || \
|
H A D | sockbuf.h | 89 short sb_state; /* socket state on sockbuf */ member
|
/freebsd/sys/cam/ctl/ |
H A D | ctl_ha.c | 225 (so->so_rcv.sb_state & SBS_CANTRCVMORE)) { in ctl_ha_rx_thread() 507 softc->ha_so->so_rcv.sb_state & SBS_CANTRCVMORE)) in ctl_ha_conn_thread() 540 softc->ha_so->so_rcv.sb_state & SBS_CANTRCVMORE)) in ctl_ha_conn_thread()
|
/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 | 353 (so->so_rcv.sb_state & SBS_CANTRCVMORE)) { in nbssn_recv()
|
/freebsd/sys/dev/cxgbe/tom/ |
H A D | t4_cpl_io.c | 1473 if (so->so_rcv.sb_state & SBS_CANTRCVMORE) in do_close_con_rpl() 1710 if (__predict_false(sb->sb_state & SBS_CANTRCVMORE)) { in do_rx_data() 2199 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 | 1114 if ((so->so_rcv.sb_state & SBS_CANTRCVMORE) != 0) { in nvmf_tcp_receive() 1205 if ((so->so_rcv.sb_state & SBS_CANTRCVMORE) == 0) { in nvmf_tcp_receive()
|
/freebsd/sys/netgraph/ |
H A D | ng_ksocket.c | 1158 if (so->so_rcv.sb_state & SBS_CANTRCVMORE && in ng_ksocket_incoming2()
|