lib/libutil/imsg-buffer.c

1000

struct ibufqueue *bufq;

lib/libutil/imsg-buffer.c

1002

if ((bufq = calloc(1, sizeof(*bufq))) == NULL)

lib/libutil/imsg-buffer.c

1004

ibufq_init(bufq);

lib/libutil/imsg-buffer.c

1005

return bufq;

lib/libutil/imsg-buffer.c

1009

ibufq_free(struct ibufqueue *bufq)

lib/libutil/imsg-buffer.c

1011

if (bufq == NULL)

lib/libutil/imsg-buffer.c

1013

ibufq_flush(bufq);

lib/libutil/imsg-buffer.c

1014

free(bufq);

lib/libutil/imsg-buffer.c

1018

ibufq_pop(struct ibufqueue *bufq)

lib/libutil/imsg-buffer.c

1022

if ((buf = TAILQ_FIRST(&bufq->bufs)) == NULL)

lib/libutil/imsg-buffer.c

1024

TAILQ_REMOVE(&bufq->bufs, buf, entry);

lib/libutil/imsg-buffer.c

1025

bufq->queued--;

lib/libutil/imsg-buffer.c

1030

ibufq_push(struct ibufqueue *bufq, struct ibuf *buf)

lib/libutil/imsg-buffer.c

1035

TAILQ_INSERT_TAIL(&bufq->bufs, buf, entry);

lib/libutil/imsg-buffer.c

1036

bufq->queued++;

lib/libutil/imsg-buffer.c

1040

ibufq_queuelen(struct ibufqueue *bufq)

lib/libutil/imsg-buffer.c

1042

return (bufq->queued);

lib/libutil/imsg-buffer.c

1054

ibufq_flush(struct ibufqueue *bufq)

lib/libutil/imsg-buffer.c

1058

while ((buf = TAILQ_FIRST(&bufq->bufs)) != NULL) {

lib/libutil/imsg-buffer.c

1059

TAILQ_REMOVE(&bufq->bufs, buf, entry);

lib/libutil/imsg-buffer.c

1062

bufq->queued = 0;

lib/libutil/imsg-buffer.c

991

ibufq_init(struct ibufqueue *bufq)

lib/libutil/imsg-buffer.c

993

TAILQ_INIT(&bufq->bufs);

lib/libutil/imsg-buffer.c

994

bufq->queued = 0;

lib/libutil/imsg.c

150

imsg_ibufq_pop(struct ibufqueue *bufq, struct imsg *imsg)

lib/libutil/imsg.c

155

if ((buf = ibufq_pop(bufq)) == NULL)

lib/libutil/imsg.c

173

imsg_ibufq_push(struct ibufqueue *bufq, struct imsg *imsg)

lib/libutil/imsg.c

176

ibufq_push(bufq, imsg->buf);

lib/libutil/imsg.h

134

struct ibuf *ibufq_pop(struct ibufqueue *bufq);

sys/arch/octeon/dev/amdcf.c

142

struct bufq sc_bufq;

sys/arch/octeon/dev/octcf.c

112

struct bufq sc_bufq;

sys/arch/sparc64/dev/fd.c

271

struct bufq sc_bufq; /* pending I/O requests */

sys/dev/ata/wdvar.h

66

struct bufq sc_bufq;

sys/dev/isa/fd.c

120

struct bufq sc_bufq; /* pending I/O */

sys/kern/kern_bufq.c

115

bufq_destroy(struct bufq *bq)

sys/kern/kern_bufq.c

126

SLIST_REMOVE(&bufqs, bq, bufq, bufq_entries);

sys/kern/kern_bufq.c

132

bufq_queue(struct bufq *bq, struct buf *bp)

sys/kern/kern_bufq.c

147

bufq_dequeue(struct bufq *bq)

sys/kern/kern_bufq.c

159

bufq_peek(struct bufq *bq)

sys/kern/kern_bufq.c

171

bufq_drain(struct bufq *bq)

sys/kern/kern_bufq.c

186

bufq_wait(struct bufq *bq)

sys/kern/kern_bufq.c

202

bufq_done(struct bufq *bq, struct buf *bp)

sys/kern/kern_bufq.c

218

struct bufq *bq;

sys/kern/kern_bufq.c

241

struct bufq *bq;

sys/kern/kern_bufq.c

28

SLIST_HEAD(, bufq) bufqs = SLIST_HEAD_INITIALIZER(bufqs);

sys/kern/kern_bufq.c

71

bufq_init(struct bufq *bq, int type)

sys/scsi/cd.c

108

struct bufq sc_bufq;

sys/scsi/sdvar.h

57

struct bufq sc_bufq;

sys/scsi/st.c

199

struct bufq sc_bufq;

sys/sys/buf.h

137

struct bufq *b_bq; /* What bufq this buf is on */

sys/sys/buf.h

74

SLIST_ENTRY(bufq) bufq_entries;

sys/sys/buf.h

86

int bufq_init(struct bufq *, int);

sys/sys/buf.h

87

void bufq_destroy(struct bufq *);

sys/sys/buf.h

89

void bufq_queue(struct bufq *, struct buf *);

sys/sys/buf.h

90

struct buf *bufq_dequeue(struct bufq *);

sys/sys/buf.h

91

int bufq_peek(struct bufq *);

sys/sys/buf.h

92

void bufq_drain(struct bufq *);

sys/sys/buf.h

94

void bufq_wait(struct bufq *);

sys/sys/buf.h

95

void bufq_done(struct bufq *, struct buf *);

sys/ufs/mfs/mfsnode.h

41

struct bufq mfs_bufq; /* bufq for MFS I/O */

sys/uvm/uvm_swap.c

151

struct bufq swd_bufq;

usr.sbin/rpki-client/io.c

112

io_close_queue(struct ibufqueue *bufq, struct ibuf *b)

usr.sbin/rpki-client/io.c

120

ibufq_push(bufq, b);