Searched refs:ssb (Results 1 – 8 of 8) sorted by relevance
/dragonfly/sys/kern/ |
H A D | uipc_socket2.c | 113 flags = ssb->ssb_flags; in ssb_wait() 158 flags = ssb->ssb_flags; in _ssb_lock() 191 xsb->sb_cc = ssb->ssb_cc; in ssbtoxsockbuf() 575 flags = ssb->ssb_flags; in sowakeup() 582 if ((ssb == &so->so_snd && space >= ssb->ssb_lowat) || in sowakeup() 583 (ssb == &so->so_rcv && ssb->ssb_cc >= ssb->ssb_lowat) || in sowakeup() 741 ssb->ssb_lowat = ssb->ssb_hiwat / 4; in ssb_reserve() 745 if (ssb->ssb_lowat > ssb->ssb_hiwat) in ssb_reserve() 746 ssb->ssb_lowat = ssb->ssb_hiwat; in ssb_reserve() 756 sbflush(&ssb->sb); in ssb_release() [all …]
|
H A D | uipc_msg.c | 655 struct signalsockbuf *ssb; in netmsg_so_notify() local 657 ssb = (msg->notify.nm_etype & NM_REVENT) ? &so->so_rcv : &so->so_snd; in netmsg_so_notify() 667 atomic_set_int(&ssb->ssb_flags, SSB_MEVENT); in netmsg_so_notify() 669 if (TAILQ_EMPTY(&ssb->ssb_mlist)) in netmsg_so_notify() 670 atomic_clear_int(&ssb->ssb_flags, SSB_MEVENT); in netmsg_so_notify() 675 TAILQ_INSERT_TAIL(&ssb->ssb_mlist, &msg->notify, nm_list); in netmsg_so_notify() 683 atomic_set_int(&ssb->ssb_flags, SSB_MEVENT); in netmsg_so_notify() 738 struct signalsockbuf *ssb; in netmsg_so_notify_abort() local 746 ssb = (nmsg->nm_etype & NM_REVENT) ? in netmsg_so_notify_abort() 749 TAILQ_REMOVE(&ssb->ssb_mlist, nmsg, nm_list); in netmsg_so_notify_abort()
|
H A D | uipc_socket.c | 1972 lwkt_gettoken(&ssb->ssb_token); in sorflush() 1974 asb = *ssb; in sorflush() 1979 bzero(&ssb->sb, sizeof(ssb->sb)); in sorflush() 1980 ssb->ssb_timeo = 0; in sorflush() 1981 ssb->ssb_lowat = 0; in sorflush() 1982 ssb->ssb_hiwat = 0; in sorflush() 1983 ssb->ssb_mbmax = 0; in sorflush() 2553 struct signalsockbuf *ssb; in sokqfilter() local 2561 ssb = &so->so_rcv; in sokqfilter() 2565 ssb = &so->so_snd; in sokqfilter() [all …]
|
H A D | uipc_usrreq.c | 2121 struct signalsockbuf *ssb = &unp->unp_socket->so_rcv; in unp_gc_process() local 2124 lwkt_gettoken(&ssb->ssb_token); in unp_gc_process() 2131 unp_scan(ssb->ssb_mb, unp_accessable, NULL); in unp_gc_process() 2132 lwkt_reltoken(&ssb->ssb_token); in unp_gc_process()
|
/dragonfly/sys/sys/ |
H A D | socketvar.h | 279 bleft = ssb->ssb_hiwat - ssb->ssb_cc; in ssb_space() 280 mleft = ssb->ssb_mbmax - ssb->ssb_mbcnt; in ssb_space() 293 bleft = ssb->ssb_hiwat - ssb->ssb_cc; in ssb_space_prealloc() 294 bleft_prealloc = ssb->ssb_hiwat - ssb->ssb_cc_prealloc; in ssb_space_prealloc() 298 mleft = ssb->ssb_mbmax - ssb->ssb_mbcnt; in ssb_space_prealloc() 299 mleft_prealloc = ssb->ssb_mbmax - ssb->ssb_mbcnt_prealloc; in ssb_space_prealloc() 314 sbprealloc(&ssb->sb, m); in ssb_preallocstream() 320 sbappend(&(ssb)->sb, m) 323 sbappendstream(&(ssb)->sb, m) 329 ((ssb_space(ssb) <= 0) ? 0 : sbappendaddr(&(ssb)->sb, src, m, control)) [all …]
|
H A D | socketvar2.h | 59 ssb_lock(struct signalsockbuf *ssb, int wf) in ssb_lock() argument 64 flags = ssb->ssb_flags; in ssb_lock() 68 return _ssb_lock(ssb); in ssb_lock() 71 if (atomic_cmpset_int(&ssb->ssb_flags, flags, flags|SSB_LOCK)) { in ssb_lock() 72 lwkt_gettoken(&ssb->ssb_token); in ssb_lock() 85 ssb_unlock(struct signalsockbuf *ssb) in ssb_unlock() argument 89 KKASSERT(ssb->ssb_flags & SSB_LOCK); in ssb_unlock() 90 lwkt_reltoken(&ssb->ssb_token); in ssb_unlock() 92 flags = ssb->ssb_flags; in ssb_unlock() 94 if (atomic_cmpset_int(&ssb->ssb_flags, flags, in ssb_unlock() [all …]
|
/dragonfly/sys/net/accf_http/ |
H A D | accf_http.c | 99 sbfull(struct signalsockbuf *ssb) in sbfull() argument 103 ssb->ssb_cc, ssb->ssb_hiwat, ssb->ssb_cc >= ssb->ssb_hiwat, in sbfull() 104 ssb->ssb_mbcnt, ssb->ssb_mbmax, ssb->ssb_mbcnt >= ssb->ssb_mbmax); in sbfull() 105 return(ssb->ssb_cc >= ssb->ssb_hiwat || in sbfull() 106 ssb->ssb_mbcnt >= ssb->ssb_mbmax); in sbfull()
|
/dragonfly/sys/vfs/fifofs/ |
H A D | fifo_vnops.c | 473 struct signalsockbuf *ssb; in fifo_kqfilter() local 481 ssb = &so->so_rcv; in fifo_kqfilter() 486 ssb = &so->so_snd; in fifo_kqfilter() 494 ssb_insert_knote(ssb, ap->a_kn); in fifo_kqfilter()
|