buf_queue
struct bufq_state *buf_queue;
bufq_alloc(&sc->buf_queue, "disksort", BUFQ_SORT_RAWBLOCK);
bufq_put(sc->buf_queue, bp);
if ((bp = bufq_get(sc->buf_queue)) == NULL) {
bufq_alloc(&ss->buf_queue, "fcfs", 0);
bufq_drain(ss->buf_queue);
bufq_free(ss->buf_queue);
bufq_put(ss->buf_queue, bp);
if ((bp = bufq_peek(ss->buf_queue)) == NULL)
if (bufq_get(ss->buf_queue) != bp)
bufq_get(ss->buf_queue);
if (bufq_get(ss->buf_queue) != bp)
bufq_get(ss->buf_queue);
struct bufq_state *buf_queue; /* the queue of pending IO operations */
bufq_put(st->buf_queue, bp);
|| (bp = bufq_get(st->buf_queue)) != NULL) {
bufq_alloc(&st->buf_queue, "fcfs", 0);
bufq_drain(st->buf_queue);
bufq_free(st->buf_queue);
struct bufq_state *buf_queue; /* the queue of pending IO */
extern bool message_queue_remove(struct filed *, struct buf_queue *);
extern void fprintlog(struct filed *, struct buf_msg *, struct buf_queue *);
struct buf_queue *qentry)
static struct buf_queue *
struct buf_queue *
size_t buf_queue_obj_size(struct buf_queue*);
struct buf_queue *buf; \
struct buf_queue *qentry;
static struct buf_queue *
static struct buf_queue *qentry_static;
struct buf_queue *qentry_tmp;
struct buf_queue *qentry = NULL;
buf_queue_obj_size(struct buf_queue *qentry)
message_queue_remove(struct filed *f, struct buf_queue *qentry)
STAILQ_REMOVE(&f->f_qhead, qentry, buf_queue, entries);
struct buf_queue *
struct buf_queue *qentry;
struct buf_queue *qentry;
STAILQ_REMOVE(&f->f_qhead, qentry, buf_queue, entries);
STAILQ_ENTRY(buf_queue) entries;
STAILQ_HEAD(buf_queue_head, buf_queue);
tls_send(struct filed *f, char *line, size_t len, struct buf_queue *qentry)
struct buf_queue *qentry;
bool tls_send(struct filed *, char *, size_t, struct buf_queue*);