lib/libz/deflate.c

1056

if (s->pending != 0) {

lib/libz/deflate.c

1082

if (s->pending != 0) {

lib/libz/deflate.c

1108

s->pending);

lib/libz/deflate.c

1115

ulg beg = s->pending; /* start of bytes to update crc */

lib/libz/deflate.c

1117

while (s->pending + left > s->pending_buf_size) {

lib/libz/deflate.c

1118

ulg copy = s->pending_buf_size - s->pending;

lib/libz/deflate.c

1119

zmemcpy(s->pending_buf + s->pending,

lib/libz/deflate.c

1121

s->pending = s->pending_buf_size;

lib/libz/deflate.c

1125

if (s->pending != 0) {

lib/libz/deflate.c

1132

zmemcpy(s->pending_buf + s->pending,

lib/libz/deflate.c

1134

s->pending += left;

lib/libz/deflate.c

1142

ulg beg = s->pending; /* start of bytes to update crc */

lib/libz/deflate.c

1145

if (s->pending == s->pending_buf_size) {

lib/libz/deflate.c

1148

if (s->pending != 0) {

lib/libz/deflate.c

1164

ulg beg = s->pending; /* start of bytes to update crc */

lib/libz/deflate.c

1167

if (s->pending == s->pending_buf_size) {

lib/libz/deflate.c

1170

if (s->pending != 0) {

lib/libz/deflate.c

1185

if (s->pending + 2 > s->pending_buf_size) {

lib/libz/deflate.c

1187

if (s->pending != 0) {

lib/libz/deflate.c

1200

if (s->pending != 0) {

lib/libz/deflate.c

1285

return s->pending != 0 ? Z_OK : Z_STREAM_END;

lib/libz/deflate.c

1356

zmemcpy(ds->pending_out, ss->pending_out, ss->pending);

lib/libz/deflate.c

1712

s->pending_buf[s->pending - 4] = (Bytef)len;

lib/libz/deflate.c

1713

s->pending_buf[s->pending - 3] = (Bytef)(len >> 8);

lib/libz/deflate.c

1714

s->pending_buf[s->pending - 2] = (Bytef)~len;

lib/libz/deflate.c

1715

s->pending_buf[s->pending - 1] = (Bytef)(~len >> 8);

lib/libz/deflate.c

652

s->pending = 0;

lib/libz/deflate.c

718

int ZEXPORT deflatePending(z_streamp strm, unsigned *pending, int *bits) {

lib/libz/deflate.c

722

if (pending != Z_NULL) {

lib/libz/deflate.c

723

*pending = (unsigned)strm->state->pending;

lib/libz/deflate.c

724

if (*pending != strm->state->pending) {

lib/libz/deflate.c

725

*pending = (unsigned)-1;

lib/libz/deflate.c

951

len = s->pending > strm->avail_out ? strm->avail_out :

lib/libz/deflate.c

952

(unsigned)s->pending;

lib/libz/deflate.c

960

s->pending -= len;

lib/libz/deflate.c

961

if (s->pending == 0) {

lib/libz/deflate.c

971

if (s->gzhead->hcrc && s->pending > (beg)) \

lib/libz/deflate.c

973

s->pending - (beg)); \

lib/libz/deflate.c

997

if (s->pending != 0) {

lib/libz/deflate.h

108

ulg pending; /* nb of bytes in the pending buffer */

lib/libz/deflate.h

291

#define put_byte(s, c) {s->pending_buf[s->pending++] = (Bytef)(c);}

lib/libz/trees.c

865

zmemcpy(s->pending_buf + s->pending, (Bytef *)buf, stored_len);

lib/libz/trees.c

866

s->pending += stored_len;

lib/libz/trees.c

941

Assert(s->pending < 2 * (s->lit_bufsize + sx), "pendingBuf overflow");

lib/libz/trees.c

943

Assert(s->pending < s->lit_bufsize + sx, "pendingBuf overflow");

lib/libz/zlib.h

787

unsigned *pending,

sbin/unwind/libunbound/iterator/iter_utils.c

1606

if(outnet->pending == NULL)

sbin/unwind/libunbound/services/outside_network.c

1001

pend->reuse.pending = pend;

sbin/unwind/libunbound/services/outside_network.c

106

struct pending *p1 = (struct pending*)key1;

sbin/unwind/libunbound/services/outside_network.c

107

struct pending *p2 = (struct pending*)key2;

sbin/unwind/libunbound/services/outside_network.c

1131

log_assert(reuse->lru_prev->pending);

sbin/unwind/libunbound/services/outside_network.c

1135

log_assert(!reuse->lru_next || reuse->lru_next->pending);

sbin/unwind/libunbound/services/outside_network.c

1146

log_assert(reuse->lru_next->pending);

sbin/unwind/libunbound/services/outside_network.c

1150

log_assert(!reuse->lru_prev || reuse->lru_prev->pending);

sbin/unwind/libunbound/services/outside_network.c

1164

reuse->pending = NULL;

sbin/unwind/libunbound/services/outside_network.c

1449

struct pending* pend;

sbin/unwind/libunbound/services/outside_network.c

1484

struct pending key;

sbin/unwind/libunbound/services/outside_network.c

1485

struct pending* p;

sbin/unwind/libunbound/services/outside_network.c

1507

verbose(VERB_ALGO, "lookup size is %d entries", (int)outnet->pending->count);

sbin/unwind/libunbound/services/outside_network.c

1508

p = (struct pending*)rbtree_search(outnet->pending, &key);

sbin/unwind/libunbound/services/outside_network.c

1549

(void)rbtree_delete(outnet->pending, p->node.key);

sbin/unwind/libunbound/services/outside_network.c

1590

struct pending* p = (struct pending*)arg;

sbin/unwind/libunbound/services/outside_network.c

1601

struct pending* p = (struct pending*)arg;

sbin/unwind/libunbound/services/outside_network.c

1753

!(outnet->pending = rbtree_create(pending_cmp)) ||

sbin/unwind/libunbound/services/outside_network.c

1829

struct pending* pend = (struct pending*)node;

sbin/unwind/libunbound/services/outside_network.c

1861

if(outnet->pending) {

sbin/unwind/libunbound/services/outside_network.c

1863

traverse_postorder(outnet->pending, pending_node_del, NULL);

sbin/unwind/libunbound/services/outside_network.c

1864

free(outnet->pending);

sbin/unwind/libunbound/services/outside_network.c

1945

struct pending* p = outnet->udp_wait_first, *np;

sbin/unwind/libunbound/services/outside_network.c

1956

pending_delete(struct outside_network* outnet, struct pending* p)

sbin/unwind/libunbound/services/outside_network.c

1963

struct pending* prev = NULL, *x = outnet->udp_wait_first;

sbin/unwind/libunbound/services/outside_network.c

1978

(void)rbtree_delete(outnet->pending, p->node.key);

sbin/unwind/libunbound/services/outside_network.c

2044

select_id(struct outside_network* outnet, struct pending* pend,

sbin/unwind/libunbound/services/outside_network.c

2053

while(!rbtree_insert(outnet->pending, &pend->node)) {

sbin/unwind/libunbound/services/outside_network.c

2112

select_ifport(struct outside_network* outnet, struct pending* pend,

sbin/unwind/libunbound/services/outside_network.c

2215

randomize_and_send_udp(struct pending* pend, sldns_buffer* packet, int timeout)

sbin/unwind/libunbound/services/outside_network.c

2273

struct pending*

sbin/unwind/libunbound/services/outside_network.c

2277

struct pending* pend = (struct pending*)calloc(1, sizeof(*pend));

sbin/unwind/libunbound/services/outside_network.c

2352

reuse_cb_and_decommission(outnet, reuse->pending, NETEVENT_CLOSED);

sbin/unwind/libunbound/services/outside_network.c

2453

log_assert(reuse->pending);

sbin/unwind/libunbound/services/outside_network.c

2454

pend = reuse->pending;

sbin/unwind/libunbound/services/outside_network.c

2466

log_assert(!reuse || (pend == reuse->pending));

sbin/unwind/libunbound/services/outside_network.c

2530

pend->reuse.pending = pend;

sbin/unwind/libunbound/services/outside_network.c

2691

sq->pending = NULL;

sbin/unwind/libunbound/services/outside_network.c

2753

if(sq->pending) {

sbin/unwind/libunbound/services/outside_network.c

2759

struct pending* p = (struct pending*)sq->pending;

sbin/unwind/libunbound/services/outside_network.c

2769

sq->pending;

sbin/unwind/libunbound/services/outside_network.c

2797

sq->pending = NULL;

sbin/unwind/libunbound/services/outside_network.c

2940

sq->pending = pending_udp_query(sq, buff, rtt,

sbin/unwind/libunbound/services/outside_network.c

2942

if(!sq->pending)

sbin/unwind/libunbound/services/outside_network.c

3094

struct waiting_tcp* w = (struct waiting_tcp*)sq->pending;

sbin/unwind/libunbound/services/outside_network.c

3102

sq->pending = NULL; /* removed after this callback */

sbin/unwind/libunbound/services/outside_network.c

3195

sq->pending = pending_tcp_query(sq, buff, sq->outnet->tcp_auth_query_timeout,

sbin/unwind/libunbound/services/outside_network.c

3198

if(!sq->pending) {

sbin/unwind/libunbound/services/outside_network.c

3231

sq->pending = pending_tcp_query(sq, buff, timeout,

sbin/unwind/libunbound/services/outside_network.c

3234

return sq->pending != NULL;

sbin/unwind/libunbound/services/outside_network.c

3283

struct pending* p = (struct pending*)sq->pending;

sbin/unwind/libunbound/services/outside_network.c

3286

sq->pending = NULL; /* removed after callback */

sbin/unwind/libunbound/services/outside_network.c

376

if(!reuse || !reuse->pending || !reuse->pending->c)

sbin/unwind/libunbound/services/outside_network.c

381

reuse->pending->c->fd);

sbin/unwind/libunbound/services/outside_network.c

3884

waiting_udp_get_mem(struct pending* w)

sbin/unwind/libunbound/services/outside_network.c

3896

struct pending* u;

sbin/unwind/libunbound/services/outside_network.c

3923

s += sizeof(*outnet->pending);

sbin/unwind/libunbound/services/outside_network.c

3924

s += (sizeof(struct pending) + comm_timer_get_mem(NULL)) *

sbin/unwind/libunbound/services/outside_network.c

3925

outnet->pending->count;

sbin/unwind/libunbound/services/outside_network.c

3948

s += sizeof(struct pending);

sbin/unwind/libunbound/services/outside_network.c

500

pend_tcp->reuse.pending = pend_tcp;

sbin/unwind/libunbound/services/outside_network.c

546

key_p.reuse.pending = &key_p;

sbin/unwind/libunbound/services/outside_network.c

565

log_assert(&key_p != ((struct reuse_tcp*)result)->pending);

sbin/unwind/libunbound/services/outside_network.c

772

pend->reuse.pending = pend;

sbin/unwind/libunbound/services/outside_network.c

86

static int randomize_and_send_udp(struct pending* pend, sldns_buffer* packet,

sbin/unwind/libunbound/services/outside_network.c

980

pend_tcp = reuse->pending;

sbin/unwind/libunbound/services/outside_network.c

984

w->next_waiting = (void*)reuse->pending;

sbin/unwind/libunbound/services/outside_network.c

986

if(reuse->pending->query) {

sbin/unwind/libunbound/services/outside_network.c

992

comm_point_stop_listening(reuse->pending->c);

sbin/unwind/libunbound/services/outside_network.c

993

reuse->pending->query = w;

sbin/unwind/libunbound/services/outside_network.c

995

reuse->pending->c->fd, reuse->pending,

sbin/unwind/libunbound/services/outside_network.h

130

struct pending* udp_wait_first;

sbin/unwind/libunbound/services/outside_network.h

132

struct pending* udp_wait_last;

sbin/unwind/libunbound/services/outside_network.h

135

rbtree_type* pending;

sbin/unwind/libunbound/services/outside_network.h

279

struct pending_tcp* pending;

sbin/unwind/libunbound/services/outside_network.h

338

struct pending* next_waiting;

sbin/unwind/libunbound/services/outside_network.h

51

struct pending;

sbin/unwind/libunbound/services/outside_network.h

518

void* pending;

sbin/unwind/libunbound/services/outside_network.h

597

struct pending* pending_udp_query(struct serviced_query* sq,

sbin/unwind/libunbound/services/outside_network.h

623

void pending_delete(struct outside_network* outnet, struct pending* p);

sys/arch/amd64/amd64/ipi.c

101

pending = atomic_swap_uint(&ci->ci_ipis, 0);

sys/arch/amd64/amd64/ipi.c

102

for (bit = 0; bit < X86_NIPI && pending; bit++) {

sys/arch/amd64/amd64/ipi.c

103

if (pending & (1 << bit)) {

sys/arch/amd64/amd64/ipi.c

104

pending &= ~(1 << bit);

sys/arch/amd64/amd64/ipi.c

94

u_int32_t pending;

sys/arch/arm64/dev/apldc.c

167

uint32_t stat, pending;

sys/arch/arm64/dev/apldc.c

172

pending = stat;

sys/arch/arm64/dev/apldc.c

173

while (pending) {

sys/arch/arm64/dev/apldc.c

174

irq = ffs(pending) - 1;

sys/arch/arm64/dev/apldc.c

183

pending &= ~(1 << irq);

sys/arch/arm64/dev/aplpinctrl.c

276

uint32_t status, pending;

sys/arch/arm64/dev/aplpinctrl.c

281

pending = status;

sys/arch/arm64/dev/aplpinctrl.c

283

while (pending) {

sys/arch/arm64/dev/aplpinctrl.c

284

bit = ffs(pending) - 1;

sys/arch/arm64/dev/aplpinctrl.c

293

pending &= ~(1 << bit);

sys/arch/arm64/dev/bcm2836_intr.c

397

uint32_t pending;

sys/arch/arm64/dev/bcm2836_intr.c

407

pending = bus_space_read_4(sc->sc_iot, sc->sc_ioh,

sys/arch/arm64/dev/bcm2836_intr.c

409

if (pending == 0) {

sys/arch/arm64/dev/bcm2836_intr.c

412

if (pending & (1 << IRQ_BANK1(irq)))

sys/arch/arm64/dev/bcm2836_intr.c

418

pending = bus_space_read_4(sc->sc_iot, sc->sc_ioh,

sys/arch/arm64/dev/bcm2836_intr.c

420

if (pending == 0) {

sys/arch/arm64/dev/bcm2836_intr.c

423

if (pending & (1 << IRQ_BANK2(irq)))

sys/arch/arm64/dev/bcm2836_intr.c

429

pending = bus_space_read_4(sc->sc_iot, sc->sc_ioh,

sys/arch/arm64/dev/bcm2836_intr.c

431

if (pending == 0) {

sys/arch/arm64/dev/bcm2836_intr.c

434

if (pending & (1 << IRQ_BANK0(irq)))

sys/arch/arm64/dev/bcm2836_intr.c

440

pending = bus_space_read_4(sc->sc_iot, sc->sc_lioh,

sys/arch/arm64/dev/bcm2836_intr.c

442

pending &= ARM_LOCAL_INT_PENDING_MASK;

sys/arch/arm64/dev/bcm2836_intr.c

443

if (pending != 0) do {

sys/arch/arm64/dev/bcm2836_intr.c

444

if (pending & (1 << IRQ_LOCAL(irq)))

sys/arch/armv7/broadcom/bcm2836_intr.c

380

uint32_t pending;

sys/arch/armv7/broadcom/bcm2836_intr.c

390

pending = bus_space_read_4(sc->sc_iot, sc->sc_ioh,

sys/arch/armv7/broadcom/bcm2836_intr.c

392

if (pending == 0) {

sys/arch/armv7/broadcom/bcm2836_intr.c

395

if (pending & (1 << IRQ_BANK1(irq)))

sys/arch/armv7/broadcom/bcm2836_intr.c

401

pending = bus_space_read_4(sc->sc_iot, sc->sc_ioh,

sys/arch/armv7/broadcom/bcm2836_intr.c

403

if (pending == 0) {

sys/arch/armv7/broadcom/bcm2836_intr.c

406

if (pending & (1 << IRQ_BANK2(irq)))

sys/arch/armv7/broadcom/bcm2836_intr.c

412

pending = bus_space_read_4(sc->sc_iot, sc->sc_ioh,

sys/arch/armv7/broadcom/bcm2836_intr.c

414

if (pending == 0) {

sys/arch/armv7/broadcom/bcm2836_intr.c

417

if (pending & (1 << IRQ_BANK0(irq)))

sys/arch/armv7/broadcom/bcm2836_intr.c

424

pending = bus_space_read_4(sc->sc_iot, sc->sc_lioh,

sys/arch/armv7/broadcom/bcm2836_intr.c

426

pending &= ARM_LOCAL_INT_PENDING_MASK;

sys/arch/armv7/broadcom/bcm2836_intr.c

427

if (pending != 0) do {

sys/arch/armv7/broadcom/bcm2836_intr.c

428

if (pending & (1 << IRQ_LOCAL(irq)))

sys/arch/armv7/omap/omgpio.c

722

u_int32_t pending;

sys/arch/armv7/omap/omgpio.c

726

pending = READ4(sc, omgpio.irqstatus0);

sys/arch/armv7/omap/omgpio.c

728

while (pending != 0) {

sys/arch/armv7/omap/omgpio.c

729

bit = ffs(pending) - 1;

sys/arch/armv7/omap/omgpio.c

738

sc->sc_dev.dv_unit * 32 + bit, pending,

sys/arch/armv7/omap/omgpio.c

743

pending &= ~(1 << bit);

sys/arch/armv7/sunxi/sxie.c

436

uint32_t pending;

sys/arch/armv7/sunxi/sxie.c

440

pending = SXIREAD4(sc, SXIE_INTSR);

sys/arch/armv7/sunxi/sxie.c

441

SXIWRITE4(sc, SXIE_INTSR, pending);

sys/arch/armv7/sunxi/sxie.c

446

if (pending & 0x0100) {

sys/arch/armv7/sunxi/sxie.c

451

if (pending & (SXIE_TX_FIFO0 | SXIE_TX_FIFO1)) {

sys/arch/armv7/sunxi/sxie.c

452

sc->txf_inuse &= ~pending;

sys/arch/i386/i386/ipifuncs.c

191

u_int32_t pending;

sys/arch/i386/i386/ipifuncs.c

194

pending = i386_atomic_testset_ul(&ci->ci_ipis, 0);

sys/arch/i386/i386/ipifuncs.c

196

for (bit = 0; bit < I386_NIPI && pending; bit++) {

sys/arch/i386/i386/ipifuncs.c

197

if (pending & (1<<bit)) {

sys/arch/i386/i386/ipifuncs.c

198

pending &= ~(1<<bit);

sys/arch/loongson/loongson/loongson3_intr.c

367

loongson3_intr(uint32_t pending, struct trapframe *frame)

sys/arch/loongson/loongson/loongson3_intr.c

394

return pending;

sys/arch/loongson/loongson/loongson3_intr.c

436

return pending;

sys/arch/loongson/loongson/loongson3_intr.c

440

loongson3_ht_intr(uint32_t pending, struct trapframe *frame)

sys/arch/loongson/loongson/loongson3_intr.c

467

return pending;

sys/arch/loongson/loongson/loongson3_intr.c

516

return pending;

sys/arch/mips64/mips64/interrupt.c

103

u_int32_t pending;

sys/arch/mips64/mips64/interrupt.c

124

pending = trapframe->cause & CR_INT_MASK & trapframe->sr;

sys/arch/mips64/mips64/interrupt.c

126

if (pending & SOFT_INT_MASK_0) {

sys/arch/mips64/mips64/interrupt.c

133

active = cpu_int_tab[i].int_mask & pending;

sys/arch/powerpc64/powerpc64/cpu.c

403

int pending;

sys/arch/powerpc64/powerpc64/cpu.c

405

pending = atomic_swap_uint(&ci->ci_ipi_reason, IPI_NOP);

sys/arch/powerpc64/powerpc64/cpu.c

407

if (pending & IPI_DDB)

sys/arch/powerpc64/powerpc64/cpu.c

410

if (pending & IPI_SETPERF)

sys/arch/riscv64/dev/plic.c

323

uint32_t pending;

sys/arch/riscv64/dev/plic.c

330

pending = bus_space_read_4(sc->sc_iot, sc->sc_ioh,

sys/arch/riscv64/dev/plic.c

333

if (pending >= sc->sc_ndev) {

sys/arch/riscv64/dev/plic.c

334

printf("plic0: pending %x\n", pending);

sys/arch/riscv64/dev/plic.c

338

if (pending) {

sys/arch/riscv64/dev/plic.c

339

handled = plic_irq_dispatch(pending, frame);

sys/arch/riscv64/dev/plic.c

341

PLIC_CLAIM(sc, cpu), pending);

sys/arch/riscv64/dev/plic.c

346

printf("plic handled == 0 on pending %d\n", pending);

sys/arch/riscv64/riscv64/intr.c

758

int pending;

sys/arch/riscv64/riscv64/intr.c

761

pending = atomic_swap_uint(&ci->ci_ipi_reason, IPI_NOP);

sys/arch/riscv64/riscv64/intr.c

763

if (pending & IPI_DDB)

sys/dev/audio.c

112

int pending;

sys/dev/audio.c

1812

if (!e->pending) {

sys/dev/audio.c

1813

e->pending = 1;

sys/dev/audio.c

1974

e->pending = 0;

sys/dev/audio.c

2014

sc->mix_evbuf[i].pending = 0;

sys/dev/fdt/if_mvpp.c

2907

int i, pending;

sys/dev/fdt/if_mvpp.c

2929

pending = mvpp2_read(sc->sc, MVPP2_TXQ_PENDING_REG) &

sys/dev/fdt/if_mvpp.c

2931

} while (pending);

sys/dev/fdt/imxgpio.c

207

uint32_t status, pending, mask;

sys/dev/fdt/imxgpio.c

214

pending = status;

sys/dev/fdt/imxgpio.c

216

while (pending) {

sys/dev/fdt/imxgpio.c

217

pin = ffs(pending) - 1;

sys/dev/fdt/imxgpio.c

226

pending &= ~(1 << pin);

sys/dev/fdt/mvkpcie.c

875

uint32_t pending;

sys/dev/fdt/mvkpcie.c

882

pending = HREAD4(sc, PCIE_CORE_MSI_STATUS);

sys/dev/fdt/mvkpcie.c

883

while (pending) {

sys/dev/fdt/mvkpcie.c

884

i = ffs(pending) - 1;

sys/dev/fdt/mvkpcie.c

886

pending &= ~(1 << i);

sys/dev/fdt/mvkpcie.c

899

pending = HREAD4(sc, PCIE_CORE_ISR1_STATUS);

sys/dev/fdt/mvkpcie.c

901

if (pending & PCIE_CORE_ISR1_MASK_INTX(i)) {

sys/dev/fdt/mvkpcie.c

910

HWRITE4(sc, PCIE_CORE_ISR1_STATUS, pending);

sys/dev/fdt/rkgpio.c

281

uint32_t status, pending;

sys/dev/fdt/rkgpio.c

288

pending = status;

sys/dev/fdt/rkgpio.c

290

while (pending) {

sys/dev/fdt/rkgpio.c

291

pin = ffs(pending) - 1;

sys/dev/fdt/rkgpio.c

300

pending &= ~(1 << pin);

sys/dev/ic/aic79xx.c

8181

int pending;

sys/dev/ic/aic79xx.c

8185

pending = lstate->event_w_idx - lstate->event_r_idx;

sys/dev/ic/aic79xx.c

8187

pending = AHD_TMODE_EVENT_BUFFER_SIZE + 1

sys/dev/ic/aic79xx.c

8200

xpt_release_devq(lstate->path, pending, /*runqueue*/FALSE);

sys/dev/ic/aic79xx.c

8203

if (pending == AHD_TMODE_EVENT_BUFFER_SIZE) {

sys/dev/ic/aic7xxx.c

5995

int pending;

sys/dev/ic/aic7xxx.c

5999

pending = lstate->event_w_idx - lstate->event_r_idx;

sys/dev/ic/aic7xxx.c

6001

pending = AHC_TMODE_EVENT_BUFFER_SIZE + 1

sys/dev/ic/aic7xxx.c

6014

xpt_release_devq(lstate->path, pending, /*runqueue*/FALSE);

sys/dev/ic/aic7xxx.c

6017

if (pending == AHC_TMODE_EVENT_BUFFER_SIZE) {

sys/dev/ic/ar5211.c

1105

int i = 100, pending;

sys/dev/ic/ar5211.c

1115

pending = AR5K_REG_READ(AR5K_AR5211_QCU_STS(queue)) &

sys/dev/ic/ar5211.c

1118

} while (--i && pending);

sys/dev/ic/ar5212.c

1293

int i = 100, pending;

sys/dev/ic/ar5212.c

1303

pending = AR5K_REG_READ(AR5K_AR5212_QCU_STS(queue)) &

sys/dev/ic/ar5212.c

1306

} while (--i && pending);

sys/dev/ic/ath.c

1290

ath_beacon_proc(void *arg, int pending)

sys/dev/ic/ath.c

1297

DPRINTF(ATH_DEBUG_BEACON_PROC, ("%s: pending %u\n", __func__, pending));

sys/dev/ic/ath.c

548

ath_fatal_proc(void *arg, int pending)

sys/dev/ic/ath.c

560

ath_rxorn_proc(void *arg, int pending)

sys/dev/ic/ath.c

572

ath_bmiss_proc(void *arg, int pending)

sys/dev/ic/ath.c

577

DPRINTF(ATH_DEBUG_ANY, ("%s: pending %u\n", __func__, pending));

sys/dev/pci/drm/amd/amdgpu/amdgpu_acpi.c

440

DRM_DEBUG_DRIVER("SBIOS pending requests: %#x\n", req->pending);

sys/dev/pci/drm/amd/amdgpu/amdgpu_acpi.c

442

count = hweight32(req->pending);

sys/dev/pci/drm/amd/amdgpu/amdgpu_acpi.c

494

if (req.pending & ATIF_PANEL_BRIGHTNESS_CHANGE_REQUEST) {

sys/dev/pci/drm/amd/amdgpu/amdgpu_acpi.c

507

if (req.pending & ATIF_DGPU_DISPLAY_EVENT) {

sys/dev/pci/drm/amd/include/amd_acpi.h

45

u32 pending; /* pending sbios requests */

sys/dev/pci/drm/i915/gt/intel_engine_cs.c

1023

memset(execlists->pending, 0, sizeof(execlists->pending));

sys/dev/pci/drm/i915/gt/intel_engine_cs.c

2199

for (port = execlists->pending; (rq = *port); port++) {

sys/dev/pci/drm/i915/gt/intel_engine_cs.c

2205

(int)(port - execlists->pending),

sys/dev/pci/drm/i915/gt/intel_engine_types.h

255

struct i915_request *pending[EXECLIST_MAX_PORTS + 1];

sys/dev/pci/drm/i915/gt/intel_execlists_submission.c

1163

if (READ_ONCE(engine->execlists.pending[0]))

sys/dev/pci/drm/i915/gt/intel_execlists_submission.c

1275

struct i915_request **port = execlists->pending;

sys/dev/pci/drm/i915/gt/intel_execlists_submission.c

1601

execlists->pending,

sys/dev/pci/drm/i915/gt/intel_execlists_submission.c

1602

(port - execlists->pending) * sizeof(*port))) {

sys/dev/pci/drm/i915/gt/intel_execlists_submission.c

1604

while (port-- != execlists->pending)

sys/dev/pci/drm/i915/gt/intel_execlists_submission.c

1605

execlists_schedule_in(*port, port - execlists->pending);

sys/dev/pci/drm/i915/gt/intel_execlists_submission.c

1612

while (port-- != execlists->pending)

sys/dev/pci/drm/i915/gt/intel_execlists_submission.c

1614

*execlists->pending = NULL;

sys/dev/pci/drm/i915/gt/intel_execlists_submission.c

1644

for (port = execlists->pending; *port; port++)

sys/dev/pci/drm/i915/gt/intel_execlists_submission.c

1646

clear_ports(execlists->pending, ARRAY_SIZE(execlists->pending));

sys/dev/pci/drm/i915/gt/intel_execlists_submission.c

1649

for (port = xchg(&execlists->active, execlists->pending); *port; port++)

sys/dev/pci/drm/i915/gt/intel_execlists_submission.c

1657

GEM_BUG_ON(execlists->pending[0]);

sys/dev/pci/drm/i915/gt/intel_execlists_submission.c

1917

if (GEM_WARN_ON(!*execlists->pending)) {

sys/dev/pci/drm/i915/gt/intel_execlists_submission.c

1925

WRITE_ONCE(execlists->active, execlists->pending);

sys/dev/pci/drm/i915/gt/intel_execlists_submission.c

1936

execlists->pending,

sys/dev/pci/drm/i915/gt/intel_execlists_submission.c

1944

WRITE_ONCE(execlists->pending[0], NULL);

sys/dev/pci/drm/i915/gt/intel_execlists_submission.c

2308

for (port = el->pending; (rq = *port); port++) {

sys/dev/pci/drm/i915/gt/intel_execlists_submission.c

2312

ccid, port - el->pending);

sys/dev/pci/drm/i915/gt/intel_execlists_submission.c

2421

return engine->execlists.pending[0];

sys/dev/pci/drm/i915/gt/intel_execlists_submission.c

2478

if (!engine->execlists.pending[0]) {

sys/dev/pci/drm/i915/gt/intel_execlists_submission.c

786

trace_ports(execlists, msg, execlists->pending);

sys/dev/pci/drm/i915/gt/intel_execlists_submission.c

792

if (!execlists->pending[0]) {

sys/dev/pci/drm/i915/gt/intel_execlists_submission.c

798

if (execlists->pending[execlists_num_ports(execlists)]) {

sys/dev/pci/drm/i915/gt/intel_execlists_submission.c

804

for (port = execlists->pending; (rq = *port); port++) {

sys/dev/pci/drm/i915/gt/intel_execlists_submission.c

815

port - execlists->pending);

sys/dev/pci/drm/i915/gt/intel_execlists_submission.c

824

port - execlists->pending);

sys/dev/pci/drm/i915/gt/intel_execlists_submission.c

843

port - execlists->pending);

sys/dev/pci/drm/i915/gt/intel_execlists_submission.c

854

port != execlists->pending) {

sys/dev/pci/drm/i915/gt/intel_execlists_submission.c

858

port - execlists->pending);

sys/dev/pci/drm/i915/gt/intel_execlists_submission.c

874

port - execlists->pending);

sys/dev/pci/drm/i915/gt/intel_execlists_submission.c

883

port - execlists->pending);

sys/dev/pci/drm/i915/gt/intel_execlists_submission.c

892

port - execlists->pending);

sys/dev/pci/drm/i915/gt/intel_execlists_submission.c

930

struct i915_request *rq = execlists->pending[n];

sys/dev/pci/drm/i915/gt/selftest_execlists.c

1378

} while (READ_ONCE(engine->execlists.pending[0]));

sys/dev/pci/drm/i915/gt/selftest_execlists.c

2358

while (!engine->execlists.pending[0])

sys/dev/pci/drm/i915/gt/selftest_execlists.c

3425

while (READ_ONCE(engine->execlists.pending[0]))

sys/dev/pci/drm/i915/gt/selftest_execlists.c

58

if (!READ_ONCE(engine->execlists.pending[0]) && is_active(rq))

sys/dev/pci/drm/i915/gt/selftest_execlists.c

78

if (READ_ONCE(engine->execlists.pending[0]))

sys/dev/pci/drm/i915/gt/selftest_lrc.c

69

if (!READ_ONCE(engine->execlists.pending[0]) && is_active(rq))

sys/dev/pci/drm/i915/gt/sysfs_engines.c

335

if (READ_ONCE(engine->execlists.pending[0]))

sys/dev/pci/drm/i915/gt/uc/intel_guc_ct.c

1061

list_for_each_entry(req, &ct->requests.pending, link) {

sys/dev/pci/drm/i915/gt/uc/intel_guc_ct.c

1093

list_for_each_entry(req, &ct->requests.pending, link)

sys/dev/pci/drm/i915/gt/uc/intel_guc_ct.c

146

INIT_LIST_HEAD(&ct->requests.pending);

sys/dev/pci/drm/i915/gt/uc/intel_guc_ct.c

769

list_add_tail(&request.link, &ct->requests.pending);

sys/dev/pci/drm/i915/gt/uc/intel_guc_ct.h

81

struct list_head pending; /* requests waiting for response */

sys/dev/pci/drm/i915/gvt/execlist.c

115

status.execlist_queue_full = !!(pending);

sys/dev/pci/drm/i915/gvt/execlist.c

186

struct intel_vgpu_execlist_slot *pending = execlist->pending_slot;

sys/dev/pci/drm/i915/gvt/execlist.c

234

if (!pending) {

sys/dev/pci/drm/i915/gvt/execlist.c

91

struct intel_vgpu_execlist_slot *pending = execlist->pending_slot;

sys/dev/pci/drm/i915/i915_sw_fence.c

149

atomic_set_release(&fence->pending, -1); /* 0 -> -1 [done] */

sys/dev/pci/drm/i915/i915_sw_fence.c

196

if (!atomic_dec_and_test(&fence->pending))

sys/dev/pci/drm/i915/i915_sw_fence.c

224

int pending;

sys/dev/pci/drm/i915/i915_sw_fence.c

230

pending = atomic_read(&fence->pending);

sys/dev/pci/drm/i915/i915_sw_fence.c

232

if (pending < 1)

sys/dev/pci/drm/i915/i915_sw_fence.c

234

} while (!atomic_try_cmpxchg(&fence->pending, &pending, pending + 1));

sys/dev/pci/drm/i915/i915_sw_fence.c

257

atomic_set(&fence->pending, 1);

sys/dev/pci/drm/i915/i915_sw_fence.c

344

unsigned int pending;

sys/dev/pci/drm/i915/i915_sw_fence.c

361

pending = I915_SW_FENCE_FLAG_FENCE;

sys/dev/pci/drm/i915/i915_sw_fence.c

373

pending |= I915_SW_FENCE_FLAG_ALLOC;

sys/dev/pci/drm/i915/i915_sw_fence.c

377

wq->flags = pending;

sys/dev/pci/drm/i915/i915_sw_fence.c

386

pending = 1;

sys/dev/pci/drm/i915/i915_sw_fence.c

389

pending = 0;

sys/dev/pci/drm/i915/i915_sw_fence.c

393

return pending;

sys/dev/pci/drm/i915/i915_sw_fence.c

591

int ret = 0, pending;

sys/dev/pci/drm/i915/i915_sw_fence.c

598

pending = i915_sw_fence_await_dma_fence(fence, f, timeout,

sys/dev/pci/drm/i915/i915_sw_fence.c

600

if (pending < 0) {

sys/dev/pci/drm/i915/i915_sw_fence.c

601

ret = pending;

sys/dev/pci/drm/i915/i915_sw_fence.c

605

ret |= pending;

sys/dev/pci/drm/i915/i915_sw_fence.h

103

return atomic_read(&fence->pending) <= 0;

sys/dev/pci/drm/i915/i915_sw_fence.h

108

return atomic_read(&fence->pending) < 0;

sys/dev/pci/drm/i915/i915_sw_fence.h

36

atomic_t pending;

sys/dev/pci/drm/i915/i915_sw_fence_work.h

61

if (atomic_read(&f->chain.pending) <= 1)

sys/dev/pci/drm/i915/i915_vma_resource.c

314

if (atomic_read(&vma_res->chain.pending) <= 1) {

sys/dev/pci/drm/i915/selftests/i915_request.c

408

atomic_read(&wait->pending), count,

sys/dev/pci/drm/i915/selftests/lib_sw_fence.c

42

atomic_set(&fence->pending, 1);

sys/dev/pci/drm/radeon/radeon_acpi.c

338

DRM_DEBUG_DRIVER("SBIOS pending requests: %#x\n", req->pending);

sys/dev/pci/drm/radeon/radeon_acpi.c

340

count = hweight32(req->pending);

sys/dev/pci/drm/radeon/radeon_acpi.c

385

if (req.pending & ATIF_PANEL_BRIGHTNESS_CHANGE_REQUEST) {

sys/dev/pci/drm/radeon/radeon_acpi.c

405

if (req.pending & ATIF_DGPU_DISPLAY_EVENT) {

sys/dev/pci/drm/radeon/radeon_acpi.c

65

u32 pending; /* pending sbios requests */

sys/dev/pci/if_ice.c

28388

struct ice_rq_event_info *e, uint16_t *pending)

sys/dev/pci/if_ice.c

28467

if (pending) {

sys/dev/pci/if_ice.c

28470

*pending = (uint16_t)((ntc > ntu ? cq->rq.count : 0) +

sys/dev/pci/if_ice.c

28492

uint16_t *pending)

sys/dev/pci/if_ice.c

28532

status = ice_clean_rq_elem(hw, cq, &event, pending);

sys/dev/pci/if_ice.c

28550

} while (*pending && (++loop < ICE_CTRLQ_WORK_LIMIT));

sys/dev/pci/if_ice.c

28919

uint16_t pending = 0;

sys/dev/pci/if_ice.c

28971

ice_process_ctrlq(sc, ICE_CTL_Q_ADMIN, &pending);

sys/dev/pci/if_ice.c

28972

if (pending > 0)

sys/dev/pci/if_ice.c

28975

ice_process_ctrlq(sc, ICE_CTL_Q_MAILBOX, &pending);

sys/dev/pci/if_ice.c

28976

if (pending > 0)

sys/dev/pv/hyperv.c

669

u_long *revents, pending;

sys/dev/pv/hyperv.c

696

pending = atomic_swap_ulong(&revents[row], 0);

sys/dev/pv/hyperv.c

697

for (bit = 0; pending > 0; pending >>= 1, bit++) {

sys/dev/pv/hyperv.c

698

if ((pending & 1) == 0)

sys/dev/pv/xen.c

676

ulong pending, selector;

sys/dev/pv/xen.c

688

pending = atomic_swap_ulong(&sc->sc_ipg->evtchn_pending[row],

sys/dev/pv/xen.c

690

for (bit = 0; pending > 0; pending >>= 1, bit++) {

sys/dev/pv/xen.c

691

if ((pending & 1) == 0)

sys/dev/usb/umidi.c

1141

ep->pending++;

sys/dev/usb/umidi.c

1218

unsigned pending;

sys/dev/usb/umidi.c

1225

for (pending = ep->pending; pending > 0; pending--) {

sys/dev/usb/umidi.c

1234

ep->pending--;

sys/dev/usb/umidi.c

341

ep->pending = 0;

sys/dev/usb/umidivar.h

97

unsigned pending;

sys/dev/usb/upd.c

319

if (report->pending)

sys/dev/usb/upd.c

321

report->pending = 1;

sys/dev/usb/upd.c

330

report->pending = 0;

sys/dev/usb/upd.c

389

report->pending = 0;

sys/dev/usb/upd.c

96

int pending; /* Waiting for an answer */

sys/dev/wscons/wstpad.c

1003

tp->tap.button = tp->tap.pending;

sys/dev/wscons/wstpad.c

1004

tp->tap.pending = 0;

sys/dev/wscons/wstpad.c

218

u_int pending;

sys/dev/wscons/wstpad.c

769

return ((tp->tap.button || tp->tap.pending) && tp->tap.masked == 0);

sys/dev/wscons/wstpad.c

824

tp->tap.pending = (tp->tap.valid

sys/dev/wscons/wstpad.c

826

if (tp->tap.pending) {

sys/dev/wscons/wstpad.c

858

if (tp->tap.pending)

sys/dev/wscons/wstpad.c

887

tp->tap.pending = 0;

sys/dev/wscons/wstpad.c

914

if (tp->tap.pending) {

sys/dev/wscons/wstpad.c

915

tp->tap.button = tp->tap.pending;

sys/dev/wscons/wstpad.c

916

tp->tap.pending = 0;

sys/kern/vfs_lockf.c

836

struct lockf *block, *lf, *pending;

sys/kern/vfs_lockf.c

844

TAILQ_FOREACH(pending, &lock->lf_state->ls_pending, lf_entry) {

sys/kern/vfs_lockf.c

845

if (pending->lf_blk == NULL)

sys/kern/vfs_lockf.c

848

if (pending->lf_pid == block->lf_pid &&

sys/kern/vfs_lockf.c

849

pending->lf_blk->lf_pid == lock->lf_pid)

sys/lib/libz/deflate.c

1056

if (s->pending != 0) {

sys/lib/libz/deflate.c

1082

if (s->pending != 0) {

sys/lib/libz/deflate.c

1108

s->pending);

sys/lib/libz/deflate.c

1115

ulg beg = s->pending; /* start of bytes to update crc */

sys/lib/libz/deflate.c

1117

while (s->pending + left > s->pending_buf_size) {

sys/lib/libz/deflate.c

1118

ulg copy = s->pending_buf_size - s->pending;

sys/lib/libz/deflate.c

1119

zmemcpy(s->pending_buf + s->pending,

sys/lib/libz/deflate.c

1121

s->pending = s->pending_buf_size;

sys/lib/libz/deflate.c

1125

if (s->pending != 0) {

sys/lib/libz/deflate.c

1132

zmemcpy(s->pending_buf + s->pending,

sys/lib/libz/deflate.c

1134

s->pending += left;

sys/lib/libz/deflate.c

1142

ulg beg = s->pending; /* start of bytes to update crc */

sys/lib/libz/deflate.c

1145

if (s->pending == s->pending_buf_size) {

sys/lib/libz/deflate.c

1148

if (s->pending != 0) {

sys/lib/libz/deflate.c

1164

ulg beg = s->pending; /* start of bytes to update crc */

sys/lib/libz/deflate.c

1167

if (s->pending == s->pending_buf_size) {

sys/lib/libz/deflate.c

1170

if (s->pending != 0) {

sys/lib/libz/deflate.c

1185

if (s->pending + 2 > s->pending_buf_size) {

sys/lib/libz/deflate.c

1187

if (s->pending != 0) {

sys/lib/libz/deflate.c

1200

if (s->pending != 0) {

sys/lib/libz/deflate.c

1285

return s->pending != 0 ? Z_OK : Z_STREAM_END;

sys/lib/libz/deflate.c

1356

zmemcpy(ds->pending_out, ss->pending_out, ss->pending);

sys/lib/libz/deflate.c

1714

s->pending_buf[s->pending - 4] = (Bytef)len;

sys/lib/libz/deflate.c

1715

s->pending_buf[s->pending - 3] = (Bytef)(len >> 8);

sys/lib/libz/deflate.c

1716

s->pending_buf[s->pending - 2] = (Bytef)~len;

sys/lib/libz/deflate.c

1717

s->pending_buf[s->pending - 1] = (Bytef)(~len >> 8);

sys/lib/libz/deflate.c

652

s->pending = 0;

sys/lib/libz/deflate.c

718

int ZEXPORT deflatePending(z_streamp strm, unsigned *pending, int *bits) {

sys/lib/libz/deflate.c

722

if (pending != Z_NULL) {

sys/lib/libz/deflate.c

723

*pending = (unsigned)strm->state->pending;

sys/lib/libz/deflate.c

724

if (*pending != strm->state->pending) {

sys/lib/libz/deflate.c

725

*pending = (unsigned)-1;

sys/lib/libz/deflate.c

951

len = s->pending > strm->avail_out ? strm->avail_out :

sys/lib/libz/deflate.c

952

(unsigned)s->pending;

sys/lib/libz/deflate.c

960

s->pending -= len;

sys/lib/libz/deflate.c

961

if (s->pending == 0) {

sys/lib/libz/deflate.c

971

if (s->gzhead->hcrc && s->pending > (beg)) \

sys/lib/libz/deflate.c

973

s->pending - (beg)); \

sys/lib/libz/deflate.c

997

if (s->pending != 0) {

sys/lib/libz/deflate.h

108

ulg pending; /* nb of bytes in the pending buffer */

sys/lib/libz/deflate.h

291

#define put_byte(s, c) {s->pending_buf[s->pending++] = (Bytef)(c);}

sys/lib/libz/trees.c

865

zmemcpy(s->pending_buf + s->pending, (Bytef *)buf, stored_len);

sys/lib/libz/trees.c

866

s->pending += stored_len;

sys/lib/libz/trees.c

941

Assert(s->pending < 2 * (s->lit_bufsize + sx), "pendingBuf overflow");

sys/lib/libz/trees.c

943

Assert(s->pending < s->lit_bufsize + sx, "pendingBuf overflow");

sys/lib/libz/zlib.h

787

unsigned *pending,

sys/net/bridgestp.c

1598

bstp_notify_rtage(struct bstp_port *bp, int pending)

sys/net/trunklacp.c

1649

int pending = 0;

sys/net/trunklacp.c

1707

pending = 1;

sys/net/trunklacp.c

1712

if (pending == 0) {

sys/scsi/scsi_base.c

556

link->pending--;

sys/scsi/scsi_base.c

557

if (ISSET(link->state, SDEV_S_DYING) && link->pending == 0)

sys/scsi/scsi_base.c

558

wakeup_one(&link->pending);

sys/scsi/scsi_base.c

586

link->pending < link->openings &&

sys/scsi/scsi_base.c

588

link->pending++;

sys/scsi/scsi_base.c

714

link->pending--;

sys/scsi/scsi_base.c

720

while (link->pending > 0)

sys/scsi/scsi_base.c

721

msleep_nsec(&link->pending, &iopl->mtx, PRIBIO, "pendxs",

sys/scsi/scsi_base.c

737

if (link->pending < link->openings) {

sys/scsi/scsi_base.c

738

link->pending++;

sys/scsi/scsi_base.c

750

link->pending--;

sys/scsi/scsi_base.c

751

if (ISSET(link->state, SDEV_S_DYING) && link->pending == 0)

sys/scsi/scsi_base.c

752

wakeup_one(&link->pending);

sys/scsi/scsiconf.c

510

link->pending = 0;

sys/scsi/scsiconf.h

321

u_short pending;

sys/sys/videoio.h

6185

u_int32_t pending;

usr.bin/dig/dig.h

79

pending, /*%< Pending a successful answer */

usr.bin/dig/dighost.c

2290

lookup->pending = 0;

usr.bin/dig/dighost.c

2415

lookup->pending = 0;

usr.bin/dig/dighost.c

2825

if (!query->lookup->pending) {

usr.bin/dig/dighost.c

3246

if ((!l->pending && !l->ns_search_only) || cancel_now) {

usr.bin/dig/dighost.c

3627

if (l->pending)

usr.bin/dig/dighost.c

3651

query->lookup->pending = 0;

usr.bin/dig/dighost.c

3742

lookup->pending = 1;

usr.bin/dig/dighost.c

649

looknew->pending = 1;

usr.bin/dig/host.c

792

lookup->pending = 0;

usr.bin/mandoc/mdoc_macro.c

549

int j, lastarg, maxargs, nl, pending;

usr.bin/mandoc/mdoc_macro.c

749

pending = 0;

usr.bin/mandoc/mdoc_macro.c

755

pending = find_pending(mdoc, ntok, line, ppos, target);

usr.bin/mandoc/mdoc_macro.c

757

if ( ! pending)

usr.bin/openssl/s_client.c

1511

pending = SSL_pending(con);

usr.bin/openssl/s_client.c

1529

if (p != pending) {

usr.bin/openssl/s_client.c

1533

p, pending);

usr.bin/openssl/s_client.c

867

int s, k, p = 0, pending = 0;

usr.bin/tmux/cmd-capture-pane.c

78

struct evbuffer *pending;

usr.bin/tmux/cmd-capture-pane.c

83

pending = input_pending(wp->ictx);

usr.bin/tmux/cmd-capture-pane.c

84

if (pending == NULL)

usr.bin/tmux/cmd-capture-pane.c

87

line = EVBUFFER_DATA(pending);

usr.bin/tmux/cmd-capture-pane.c

88

linelen = EVBUFFER_LENGTH(pending);

usr.sbin/cron/atrun.c

100

pending = 0;

usr.sbin/cron/atrun.c

138

pending = 1;

usr.sbin/cron/atrun.c

152

return (pending);

usr.sbin/cron/atrun.c

63

int dfd, pending;

usr.sbin/eigrpd/rtp.c

162

int total = 0, pending = 0;

usr.sbin/eigrpd/rtp.c

173

pending++;

usr.sbin/eigrpd/rtp.c

183

if (pending < total) {

usr.sbin/eigrpd/rtp.c

188

if (pending > 0) {

usr.sbin/iscsid/iscsid.h

296

u_int8_t pending;

usr.sbin/smtpd/bounce.c

108

TAILQ_INIT(&pending);

usr.sbin/smtpd/bounce.c

172

TAILQ_REMOVE(&pending, msg, entry);

usr.sbin/smtpd/bounce.c

192

TAILQ_INSERT_TAIL(&pending, msg, entry);

usr.sbin/smtpd/bounce.c

206

if (fd == -1 || TAILQ_EMPTY(&pending)) {

usr.sbin/smtpd/bounce.c

215

msg = TAILQ_FIRST(&pending);

usr.sbin/smtpd/bounce.c

265

if ((msg = TAILQ_FIRST(&pending)) == NULL) {

usr.sbin/smtpd/bounce.c

369

TAILQ_FOREACH(msg, &pending, entry) {

usr.sbin/smtpd/bounce.c

379

TAILQ_REMOVE(&pending, msg, entry);

usr.sbin/smtpd/bounce.c

96

static TAILQ_HEAD(, bounce_message) pending;

usr.sbin/unbound/iterator/iter_utils.c

1606

if(outnet->pending == NULL)

usr.sbin/unbound/services/outside_network.c

1001

pend->reuse.pending = pend;

usr.sbin/unbound/services/outside_network.c

106

struct pending *p1 = (struct pending*)key1;

usr.sbin/unbound/services/outside_network.c

107

struct pending *p2 = (struct pending*)key2;

usr.sbin/unbound/services/outside_network.c

1131

log_assert(reuse->lru_prev->pending);

usr.sbin/unbound/services/outside_network.c

1135

log_assert(!reuse->lru_next || reuse->lru_next->pending);

usr.sbin/unbound/services/outside_network.c

1146

log_assert(reuse->lru_next->pending);

usr.sbin/unbound/services/outside_network.c

1150

log_assert(!reuse->lru_prev || reuse->lru_prev->pending);

usr.sbin/unbound/services/outside_network.c

1164

reuse->pending = NULL;

usr.sbin/unbound/services/outside_network.c

1449

struct pending* pend;

usr.sbin/unbound/services/outside_network.c

1484

struct pending key;

usr.sbin/unbound/services/outside_network.c

1485

struct pending* p;

usr.sbin/unbound/services/outside_network.c

1507

verbose(VERB_ALGO, "lookup size is %d entries", (int)outnet->pending->count);

usr.sbin/unbound/services/outside_network.c

1508

p = (struct pending*)rbtree_search(outnet->pending, &key);

usr.sbin/unbound/services/outside_network.c

1549

(void)rbtree_delete(outnet->pending, p->node.key);

usr.sbin/unbound/services/outside_network.c

1590

struct pending* p = (struct pending*)arg;

usr.sbin/unbound/services/outside_network.c

1601

struct pending* p = (struct pending*)arg;

usr.sbin/unbound/services/outside_network.c

1753

!(outnet->pending = rbtree_create(pending_cmp)) ||

usr.sbin/unbound/services/outside_network.c

1829

struct pending* pend = (struct pending*)node;

usr.sbin/unbound/services/outside_network.c

1861

if(outnet->pending) {

usr.sbin/unbound/services/outside_network.c

1863

traverse_postorder(outnet->pending, pending_node_del, NULL);

usr.sbin/unbound/services/outside_network.c

1864

free(outnet->pending);

usr.sbin/unbound/services/outside_network.c

1945

struct pending* p = outnet->udp_wait_first, *np;

usr.sbin/unbound/services/outside_network.c

1956

pending_delete(struct outside_network* outnet, struct pending* p)

usr.sbin/unbound/services/outside_network.c

1963

struct pending* prev = NULL, *x = outnet->udp_wait_first;

usr.sbin/unbound/services/outside_network.c

1978

(void)rbtree_delete(outnet->pending, p->node.key);

usr.sbin/unbound/services/outside_network.c

2044

select_id(struct outside_network* outnet, struct pending* pend,

usr.sbin/unbound/services/outside_network.c

2053

while(!rbtree_insert(outnet->pending, &pend->node)) {

usr.sbin/unbound/services/outside_network.c

2112

select_ifport(struct outside_network* outnet, struct pending* pend,

usr.sbin/unbound/services/outside_network.c

2215

randomize_and_send_udp(struct pending* pend, sldns_buffer* packet, int timeout)

usr.sbin/unbound/services/outside_network.c

2273

struct pending*

usr.sbin/unbound/services/outside_network.c

2277

struct pending* pend = (struct pending*)calloc(1, sizeof(*pend));

usr.sbin/unbound/services/outside_network.c

2352

reuse_cb_and_decommission(outnet, reuse->pending, NETEVENT_CLOSED);

usr.sbin/unbound/services/outside_network.c

2453

log_assert(reuse->pending);

usr.sbin/unbound/services/outside_network.c

2454

pend = reuse->pending;

usr.sbin/unbound/services/outside_network.c

2466

log_assert(!reuse || (pend == reuse->pending));

usr.sbin/unbound/services/outside_network.c

2530

pend->reuse.pending = pend;

usr.sbin/unbound/services/outside_network.c

2691

sq->pending = NULL;

usr.sbin/unbound/services/outside_network.c

2753

if(sq->pending) {

usr.sbin/unbound/services/outside_network.c

2759

struct pending* p = (struct pending*)sq->pending;

usr.sbin/unbound/services/outside_network.c

2769

sq->pending;

usr.sbin/unbound/services/outside_network.c

2797

sq->pending = NULL;

usr.sbin/unbound/services/outside_network.c

2940

sq->pending = pending_udp_query(sq, buff, rtt,

usr.sbin/unbound/services/outside_network.c

2942

if(!sq->pending)

usr.sbin/unbound/services/outside_network.c

3094

struct waiting_tcp* w = (struct waiting_tcp*)sq->pending;

usr.sbin/unbound/services/outside_network.c

3102

sq->pending = NULL; /* removed after this callback */

usr.sbin/unbound/services/outside_network.c

3195

sq->pending = pending_tcp_query(sq, buff, sq->outnet->tcp_auth_query_timeout,

usr.sbin/unbound/services/outside_network.c

3198

if(!sq->pending) {

usr.sbin/unbound/services/outside_network.c

3231

sq->pending = pending_tcp_query(sq, buff, timeout,

usr.sbin/unbound/services/outside_network.c

3234

return sq->pending != NULL;

usr.sbin/unbound/services/outside_network.c

3283

struct pending* p = (struct pending*)sq->pending;

usr.sbin/unbound/services/outside_network.c

3286

sq->pending = NULL; /* removed after callback */

usr.sbin/unbound/services/outside_network.c

376

if(!reuse || !reuse->pending || !reuse->pending->c)

usr.sbin/unbound/services/outside_network.c

381

reuse->pending->c->fd);

usr.sbin/unbound/services/outside_network.c

3884

waiting_udp_get_mem(struct pending* w)

usr.sbin/unbound/services/outside_network.c

3896

struct pending* u;

usr.sbin/unbound/services/outside_network.c

3923

s += sizeof(*outnet->pending);

usr.sbin/unbound/services/outside_network.c

3924

s += (sizeof(struct pending) + comm_timer_get_mem(NULL)) *

usr.sbin/unbound/services/outside_network.c

3925

outnet->pending->count;

usr.sbin/unbound/services/outside_network.c

3948

s += sizeof(struct pending);

usr.sbin/unbound/services/outside_network.c

500

pend_tcp->reuse.pending = pend_tcp;

usr.sbin/unbound/services/outside_network.c

546

key_p.reuse.pending = &key_p;

usr.sbin/unbound/services/outside_network.c

565

log_assert(&key_p != ((struct reuse_tcp*)result)->pending);

usr.sbin/unbound/services/outside_network.c

772

pend->reuse.pending = pend;

usr.sbin/unbound/services/outside_network.c

86

static int randomize_and_send_udp(struct pending* pend, sldns_buffer* packet,

usr.sbin/unbound/services/outside_network.c

980

pend_tcp = reuse->pending;

usr.sbin/unbound/services/outside_network.c

984

w->next_waiting = (void*)reuse->pending;

usr.sbin/unbound/services/outside_network.c

986

if(reuse->pending->query) {

usr.sbin/unbound/services/outside_network.c

992

comm_point_stop_listening(reuse->pending->c);

usr.sbin/unbound/services/outside_network.c

993

reuse->pending->query = w;

usr.sbin/unbound/services/outside_network.c

995

reuse->pending->c->fd, reuse->pending,

usr.sbin/unbound/services/outside_network.h

130

struct pending* udp_wait_first;

usr.sbin/unbound/services/outside_network.h

132

struct pending* udp_wait_last;

usr.sbin/unbound/services/outside_network.h

135

rbtree_type* pending;

usr.sbin/unbound/services/outside_network.h

279

struct pending_tcp* pending;

usr.sbin/unbound/services/outside_network.h

338

struct pending* next_waiting;

usr.sbin/unbound/services/outside_network.h

51

struct pending;

usr.sbin/unbound/services/outside_network.h

518

void* pending;

usr.sbin/unbound/services/outside_network.h

597

struct pending* pending_udp_query(struct serviced_query* sq,

usr.sbin/unbound/services/outside_network.h

623

void pending_delete(struct outside_network* outnet, struct pending* p);

usr.sbin/unbound/testcode/fake_event.c

1169

struct pending*

usr.sbin/unbound/testcode/fake_event.c

1216

return (struct pending*)pend;

usr.sbin/unbound/testcode/fake_event.c

1489

pending_list_delete(fc->runtime, fc->pending);

usr.sbin/unbound/testcode/fake_event.c

1826

fc->pending = pend;

usr.sbin/unbound/testcode/fake_event.c

1919

fc->pending = pend;

usr.sbin/unbound/testcode/fake_event.c

896

struct fake_pending* pending = NULL;

usr.sbin/unbound/testcode/fake_event.c

906

if(pending_matches_current(runtime, &entry, &pending)) {

usr.sbin/unbound/testcode/fake_event.c

912

pending);

usr.sbin/unbound/testcode/fake_event.c

918

&entry, &pending)) {

usr.sbin/unbound/testcode/fake_event.c

920

answer_callback_from_entry(runtime, entry, pending);

usr.sbin/unbound/testcode/fake_event.c

95

struct fake_pending* pending;

usr.sbin/unbound/testcode/unittcpreuse.c

62

w->next_waiting = (void*)reuse->pending;

usr.sbin/unbound/testcode/unittcpreuse.c

86

pend.reuse.pending = &pend;