lib/libutil/imsg.c

113

return msgbuf_queuelen(imsgbuf->w);

lib/libutil/imsg.h

125

uint32_t msgbuf_queuelen(struct msgbuf *);

usr.sbin/bgpd/control.c

586

peer.stats.msg_queue_len = msgbuf_queuelen(p->wbuf);

usr.sbin/bgpd/rde.c

256

if (msgbuf_queuelen(mctx->mrt.wbuf) > 0) {

usr.sbin/bgpd/rde.c

3491

return (msgbuf_queuelen(mrt->wbuf) > SESS_MSG_LOW_MARK);

usr.sbin/bgpd/rtr_proto.c

1277

if (pfd->revents & POLLOUT && msgbuf_queuelen(rs->w) > 0) {

usr.sbin/bgpd/rtr_proto.c

1284

msgbuf_queuelen(rs->w) == 0)

usr.sbin/bgpd/rtr_proto.c

1391

if (msgbuf_queuelen(rs->w) > 0)

usr.sbin/bgpd/session.c

284

if (msgbuf_queuelen(m->wbuf) > 0)

usr.sbin/bgpd/session.c

409

msgbuf_queuelen(p->wbuf) > SESS_MSG_HIGH_MARK) {

usr.sbin/bgpd/session.c

414

msgbuf_queuelen(p->wbuf) < SESS_MSG_LOW_MARK) {

usr.sbin/bgpd/session.c

421

if (msgbuf_queuelen(p->wbuf) > 0 ||

usr.sbin/bgpd/session.c

440

if (msgbuf_queuelen(m->wbuf) > 0) {

usr.sbin/bgpd/session.c

662

if (pfd->revents & POLLOUT && msgbuf_queuelen(p->wbuf) > 0) {

usr.sbin/bgpd/session_bgp.c

1822

msgbuf_queuelen(peer->wbuf) > 0)

usr.sbin/ldpd/ldpd.c

593

if (msgbuf_queuelen(eb->wbuf) > 0)

usr.sbin/ldpd/packet.c

605

if (nbr == NULL && msgbuf_queuelen(tcp->wbuf.wbuf) == 0) {

usr.sbin/rpki-client/filemode.c

814

if (msgbuf_queuelen(msgq) > 0)

usr.sbin/rpki-client/http.c

2111

if (msgbuf_queuelen(msgq) > 0)

usr.sbin/rpki-client/main.c

1358

if (msgbuf_queuelen(queues[i]) > 0)

usr.sbin/rpki-client/parser.c

1101

if (msgbuf_queuelen(myq) == 0) {

usr.sbin/rpki-client/parser.c

1121

if (msgbuf_queuelen(myq) > 0) {

usr.sbin/rpki-client/rrdp.c

589

if (msgbuf_queuelen(msgq) > 0)

usr.sbin/rpki-client/rsync.c

316

if (msgbuf_queuelen(msgq) > 0)