lib/libutil/imsg.c

113

return msgbuf_queuelen(imsgbuf->w);

lib/libutil/imsg.h

125

uint32_t msgbuf_queuelen(struct msgbuf *);

usr.sbin/bgpd/bgpd_imsg.c

50

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

3528

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

usr.sbin/bgpd/rtr_proto.c

1299

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

usr.sbin/bgpd/rtr_proto.c

1306

msgbuf_queuelen(rs->w) == 0)

usr.sbin/bgpd/rtr_proto.c

1413

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

usr.sbin/bgpd/session.c

283

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

usr.sbin/bgpd/session.c

406

msgbuf_queuelen(p->wbuf) > SESS_MSG_HIGH_MARK) {

usr.sbin/bgpd/session.c

411

msgbuf_queuelen(p->wbuf) < SESS_MSG_LOW_MARK) {

usr.sbin/bgpd/session.c

418

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

usr.sbin/bgpd/session.c

437

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

usr.sbin/bgpd/session.c

657

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

usr.sbin/bgpd/session_bgp.c

1834

msgbuf_queuelen(peer->wbuf) > 0)

usr.sbin/ldpd/ldpd.c

591

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

819

if (msgbuf_queuelen(msgq) > 0)

usr.sbin/rpki-client/http.c

2150

if (msgbuf_queuelen(msgq) > 0)

usr.sbin/rpki-client/main.c

1372

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

usr.sbin/rpki-client/parser.c

1132

if (msgbuf_queuelen(myq) == 0) {

usr.sbin/rpki-client/parser.c

1154

if (msgbuf_queuelen(myq) > 0) {

usr.sbin/rpki-client/rrdp.c

589

if (msgbuf_queuelen(msgq) > 0)

usr.sbin/rpki-client/rsync.c

326

if (msgbuf_queuelen(msgq) > 0)