Home
last modified time | relevance | path

Searched refs:sb_state (Results 1 – 25 of 32) sorted by relevance

12

/freebsd/sys/kern/
H A Duipc_debug.c198 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 Dsys_socket.c253 *(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 Duipc_socket.c1532 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 Duipc_usrreq.c977 } 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 Duipc_sockbuf.c384 so->so_snd.sb_state |= SBS_CANTSENDMORE; in socantsendmore_locked()
404 so->so_rcv.sb_state |= SBS_CANTRCVMORE; in socantrcvmore_locked()
H A Duipc_ktls.c2215 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 Dkern_sendfile.c783 if (so->so_snd.sb_state & SBS_CANTSENDMORE) { in vn_sendfile()
/freebsd/sys/netinet/
H A Daccf_http.c153 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 Daccf_tls.c77 if ((sb->sb_state & SBS_CANTRCVMORE) || sbfull(sb)) in so_hastls()
H A Dtcp_reass.c961 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 Dtcp_timer.c358 (inp->inp_socket->so_rcv.sb_state & SBS_CANTRCVMORE)) { in tcp_timer_2msl()
H A Dtcp_input.c1941 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 Dcxgbei.c420 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 Dhv_sock.c667 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 Dsocketvar.h329 (soreadabledata(so) || ((so)->so_rcv.sb_state & SBS_CANTRCVMORE))
336 ((so)->so_snd.sb_state & SBS_CANTSENDMORE) || \
H A Dsockbuf.h89 short sb_state; /* socket state on sockbuf */ member
/freebsd/sys/cam/ctl/
H A Dctl_ha.c225 (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 Dsdp_main.c1092 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 Dsmb_trantcp.c353 (so->so_rcv.sb_state & SBS_CANTRCVMORE)) { in nbssn_recv()
/freebsd/sys/dev/cxgbe/tom/
H A Dt4_cpl_io.c1473 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 Dt4_ddp.c2396 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 Dt4_tls.c878 if (__predict_false(sb->sb_state & SBS_CANTRCVMORE)) { in do_rx_tls_cmp()
/freebsd/sys/dev/cxgbe/iw_cxgbe/
H A Dcm.c1126 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 Dnvmf_tcp.c1114 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 Dng_ksocket.c1158 if (so->so_rcv.sb_state & SBS_CANTRCVMORE && in ng_ksocket_incoming2()

12