Lines Matching defs:sb
309 struct sockbuf *sb;
315 sb = &so->so_rcv;
317 if ((sb->sb_state & SBS_CANTRCVMORE) == 0 || sbavail(sb))
319 ub->st_size = sbavail(sb) - sb->sb_ctl;
322 sb = &so->so_snd;
324 if ((sb->sb_state & SBS_CANTSENDMORE) == 0)
593 soaio_ready(struct socket *so, struct sockbuf *sb)
595 return (sb == &so->so_rcv ? soreadable(so) : sowriteable(so));
603 struct sockbuf *sb = sobuf(so, which);
631 if (sb == &so->so_rcv) {
643 if (!TAILQ_EMPTY(&sb->sb_aiojobq))
674 if (soaio_ready(so, sb)) {
688 TAILQ_INSERT_HEAD(&sb->sb_aiojobq, job, list);
708 struct sockbuf *sb = sobuf(so, which);
712 while (!TAILQ_EMPTY(&sb->sb_aiojobq) && soaio_ready(so, sb)) {
713 job = TAILQ_FIRST(&sb->sb_aiojobq);
714 TAILQ_REMOVE(&sb->sb_aiojobq, job, list);
726 if (!TAILQ_EMPTY(&sb->sb_aiojobq))
727 sb->sb_flags |= SB_AIO;
728 sb->sb_flags &= ~SB_AIO_RUNNING;
756 struct sockbuf *sb = sobuf(so, which);
760 sb->sb_flags &= ~SB_AIO;
761 if (sb->sb_flags & SB_AIO_RUNNING)
763 sb->sb_flags |= SB_AIO_RUNNING;
765 soaio_enqueue(&sb->sb_aiotask);
772 struct sockbuf *sb;
780 sb = &so->so_rcv;
784 sb = &so->so_snd;
790 TAILQ_REMOVE(&sb->sb_aiojobq, job, list);
791 if (TAILQ_EMPTY(&sb->sb_aiojobq))
792 sb->sb_flags &= ~SB_AIO;
806 struct sockbuf *sb;
819 sb = &so->so_rcv;
824 sb = &so->so_snd;
838 TAILQ_INSERT_TAIL(&sb->sb_aiojobq, job, list);
839 if (!(sb->sb_flags & SB_AIO_RUNNING)) {
840 if (soaio_ready(so, sb))
843 sb->sb_flags |= SB_AIO;