Home
last modified time | relevance | path

Searched refs:ssb (Results 1 – 8 of 8) sorted by relevance

/dragonfly/sys/kern/
H A Duipc_socket2.c113 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 Duipc_msg.c655 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 Duipc_socket.c1972 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 Duipc_usrreq.c2121 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 Dsocketvar.h279 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 Dsocketvar2.h59 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 Daccf_http.c99 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 Dfifo_vnops.c473 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()