consume
n = send(net, (char *)netoring.consume, n, 0); /* normal write */
n = send(net, (char *)netoring.consume, 1, MSG_OOB);/* URGENT data */
Dump('>', netoring.consume, n);
if (ring->mark == ring->consume) {
(ring_subtract(ring, ring->mark, ring->consume) < count)) {
if (ring->consume < ring->clearto &&
ring->clearto <= ring->consume + count)
else if (ring->consume + count > ring->top &&
ring->bottom + ((ring->consume + count) - ring->top))
ring->consume = ring_increment(ring, ring->consume, count);
ring->consume = ring->supply = ring->bottom;
return ring_subtract(ring, ring->consume, ring->supply);
if ((ring->consume < ring->supply) || ring_empty(ring)) {
return ring_subtract(ring, ring->consume, ring->supply);
if ((ring->mark == 0) || (ring->mark == ring->consume)) {
return ring_subtract(ring, ring->supply, ring->consume);
return ring_subtract(ring, ring->mark, ring->consume);
if ((ring->mark == 0) || (ring->mark == ring->consume)) {
if ((ring->supply < ring->consume) || ring_full(ring)) {
return ring_subtract(ring, ring->top, ring->consume);
return ring_subtract(ring, ring->supply, ring->consume);
if (ring->mark < ring->consume) {
return ring_subtract(ring, ring->top, ring->consume);
return ring_subtract(ring, ring->mark, ring->consume);
memmove(buffer, ring->consume, i);
c = ring->consume;
#define ring_empty(d) (((d)->consume == (d)->supply) && \
#define ring_full(d) (((d)->supply == (d)->consume) && \
ring->supply = ring->consume = ring->bottom = buffer;
unsigned char *consume, /* where data comes out of */
sbp = netiring.consume;
tbp = ttyiring.consume;
n = TerminalWrite((char *)ttyoring.consume, n);
Dump('>', ttyoring.consume, n);
consume(str, bytes);
consume(str, bytes);
static void consume(evStream *str, size_t bytes);
goto consume;
goto consume;
consume:
sc->consume = &ipheth_consume_read_ncm;
sc->consume = &ipheth_consume_read;
sc->consume(xfer, x);
ipheth_consumer_t *consume;
exec_args_adjust_args(struct image_args *args, size_t consume, ssize_t extend)
offset = extend - consume;
memmove(args->begin_argv + extend, args->begin_argv + consume,
args->endp - args->begin_argv + consume);
int exec_args_adjust_args(struct image_args *args, size_t consume,
input.consume(';');
while (input.consume("/dts-v1/;"))
if (input.consume("/plugin/;"))
while (input.consume("/memreserve/"))
input.consume(';');
if (input.consume("/delete-node/"))
if (!input.consume(token))
else if (input.consume('/'))
else if (input.consume('&'))
if (input.consume('{') && is_plugin)
input.consume('}');
input.consume('"');
while (!input.consume('>'))
if (input.consume('&'))
if (!input.consume('{'))
input.consume('}');
while (!input.consume(']'))
input.consume('$');
if (input.consume("/incbin/(\""))
if (!(valid = input.consume('"')))
if (!(valid &= input.consume(')')))
valid = input.consume("/bits/");
} while (input.consume(','));
if (semicolonTerminated && !input.consume(';'))
if (!input.consume('{'))
while (valid && !input.consume('}'))
if (at && input.consume('@'))
if (!input.consume(';'))
if (input.consume("/delete-node/"))
if (input.consume("/delete-property/"))
if (input.consume("/omit-if-no-ref/"))
while (input.consume(':'))
if (input.consume('@'))
if (input.consume('='))
else if (input.consume(';'))
if (consume("/include/"))
if (consume("if "))
consume('/');
if (!consume('"'))
consume('"');
consume('?');
if (!true_case || !consume(':'))
consume('\'');
if (!consume('\''))
consume('(');
if (!consume(')'))
consume('+');
consume('-');
consume('!');
consume('~');
bool consume(const char *str);
return input_stack.top()->consume(str);
(void)consume(fp, stamp.scr_len, buf, reg);
(void)consume(fp, stamp.scr_len, buf, reg);
(void)consume(fp, stamp.scr_len, buf, reg);
static void consume(FILE *, off_t, char *, int);