lib/librt/mq.c

73

struct __mq *mq;

lib/librt/mq.c

76

mq = malloc(sizeof(struct __mq));

lib/librt/mq.c

77

if (mq == NULL)

lib/librt/mq.c

80

mq->oshandle = __sys_kmq_open(name, oflag, mode, attr);

lib/librt/mq.c

81

if (mq->oshandle != -1) {

lib/librt/mq.c

82

mq->node = NULL;

lib/librt/mq.c

83

return (mq);

lib/librt/mq.c

86

free(mq);

lib/libthr/thread/thr_create.c

128

TAILQ_INIT(&new_thread->mq[i]);

lib/libthr/thread/thr_init.c

425

TAILQ_INIT(&thread->mq[i]);

lib/libthr/thread/thr_mutex.c

1061

q = &curthread->mq[qidx];

lib/libthr/thread/thr_mutex.c

1062

qp = &curthread->mq[qidx + 1];

lib/libthr/thread/thr_mutex.c

324

m2 = TAILQ_LAST(&curthread->mq[mutex_qidx(m)], mutex_queue);

lib/libthr/thread/thr_mutex.c

452

queue_fork(curthread, &curthread->mq[TMQ_NORM],

lib/libthr/thread/thr_mutex.c

453

&curthread->mq[TMQ_NORM_PRIV], 0);

lib/libthr/thread/thr_mutex.c

454

queue_fork(curthread, &curthread->mq[TMQ_NORM_PP],

lib/libthr/thread/thr_mutex.c

455

&curthread->mq[TMQ_NORM_PP_PRIV], UMUTEX_CONTESTED);

lib/libthr/thread/thr_mutex.c

456

queue_fork(curthread, &curthread->mq[TMQ_ROBUST_PP],

lib/libthr/thread/thr_mutex.c

457

&curthread->mq[TMQ_ROBUST_PP_PRIV], UMUTEX_CONTESTED);

lib/libthr/thread/thr_mutex.c

533

TAILQ_INSERT_TAIL(&curthread->mq[qidx], m, m_qe);

lib/libthr/thread/thr_mutex.c

535

TAILQ_INSERT_TAIL(&curthread->mq[qidx + 1], m, m_pqe);

lib/libthr/thread/thr_mutex.c

581

TAILQ_REMOVE(&curthread->mq[qidx], m, m_qe);

lib/libthr/thread/thr_mutex.c

583

TAILQ_REMOVE(&curthread->mq[qidx + 1], m, m_pqe);

lib/libthr/thread/thr_private.h

506

struct mutex_queue mq[TMQ_NITEMS];

sys/compat/linuxkpi/common/src/linux_80211.c

2183

struct mbufq mq;

sys/compat/linuxkpi/common/src/linux_80211.c

2206

mbufq_init(&mq, IFQ_MAXLEN);

sys/compat/linuxkpi/common/src/linux_80211.c

2207

mbufq_concat(&mq, &lsta->txq);

sys/compat/linuxkpi/common/src/linux_80211.c

2210

m = mbufq_dequeue(&mq);

sys/compat/linuxkpi/common/src/linux_80211.c

2213

m = mbufq_dequeue(&mq);

sys/compat/linuxkpi/common/src/linux_80211.c

5660

struct mbufq mq;

sys/compat/linuxkpi/common/src/linux_80211.c

5673

mbufq_init(&mq, IFQ_MAXLEN);

sys/compat/linuxkpi/common/src/linux_80211.c

5695

mbufq_concat(&mq, &lsta->txq);

sys/compat/linuxkpi/common/src/linux_80211.c

5702

m = mbufq_dequeue(&mq);

sys/compat/linuxkpi/common/src/linux_80211.c

5705

m = mbufq_dequeue(&mq);

sys/compat/linuxkpi/common/src/linux_80211.c

7164

struct mbufq mq;

sys/compat/linuxkpi/common/src/linux_80211.c

7175

mbufq_init(&mq, IFQ_MAXLEN);

sys/compat/linuxkpi/common/src/linux_80211.c

7178

mbufq_concat(&mq, &lhw->rxq);

sys/compat/linuxkpi/common/src/linux_80211.c

7181

m = mbufq_dequeue(&mq);

sys/compat/linuxkpi/common/src/linux_80211.c

7184

m = mbufq_dequeue(&mq);

sys/dev/cxgbe/cxgbei/icl_cxgbei.c

1337

struct mbufq mq;

sys/dev/cxgbe/cxgbei/icl_cxgbei.c

1377

mbufq_init(&mq, INT_MAX);

sys/dev/cxgbe/cxgbei/icl_cxgbei.c

1388

(struct bio *)csio->data_ptr, &mq);

sys/dev/cxgbe/cxgbei/icl_cxgbei.c

1390

mbufq_drain(&mq);

sys/dev/cxgbe/cxgbei/icl_cxgbei.c

1405

(vm_offset_t)csio->data_ptr, csio->dxfer_len, &mq);

sys/dev/cxgbe/cxgbei/icl_cxgbei.c

1407

mbufq_drain(&mq);

sys/dev/cxgbe/cxgbei/icl_cxgbei.c

1427

mbufq_drain(&mq);

sys/dev/cxgbe/cxgbei/icl_cxgbei.c

1432

mbufq_concat(&toep->ulp_pduq, &mq);

sys/dev/cxgbe/cxgbei/icl_cxgbei.c

1500

struct mbufq mq;

sys/dev/cxgbe/cxgbei/icl_cxgbei.c

1577

mbufq_init(&mq, INT_MAX);

sys/dev/cxgbe/cxgbei/icl_cxgbei.c

1579

xferlen, &mq);

sys/dev/cxgbe/cxgbei/icl_cxgbei.c

1581

mbufq_drain(&mq);

sys/dev/cxgbe/cxgbei/icl_cxgbei.c

1594

mbufq_drain(&mq);

sys/dev/cxgbe/cxgbei/icl_cxgbei.c

1604

mbufq_drain(&mq);

sys/dev/cxgbe/cxgbei/icl_cxgbei.c

1609

mbufq_concat(&toep->ulp_pduq, &mq);

sys/dev/cxgbe/cxgbei/icl_cxgbei.c

439

struct mbufq mq;

sys/dev/cxgbe/cxgbei/icl_cxgbei.c

442

mbufq_init(&mq, INT_MAX);

sys/dev/cxgbe/cxgbei/icl_cxgbei.c

464

mbufq_enqueue(&mq, m);

sys/dev/cxgbe/cxgbei/icl_cxgbei.c

470

mbufq_drain(&mq);

sys/dev/cxgbe/cxgbei/icl_cxgbei.c

481

mbufq_drain(&mq);

sys/dev/cxgbe/cxgbei/icl_cxgbei.c

483

mbufq_concat(&toep->ulp_pduq, &mq);

sys/dev/cxgbe/nvmf/nvmf_che.c

558

struct mbufq mq;

sys/dev/cxgbe/nvmf/nvmf_che.c

561

mbufq_init(&mq, INT_MAX);

sys/dev/cxgbe/nvmf/nvmf_che.c

563

error = che_write_mem_inline(sc, toep, addr, len, data, &mq);

sys/dev/cxgbe/nvmf/nvmf_che.c

566

&mq);

sys/dev/cxgbe/nvmf/nvmf_che.c

576

mbufq_concat(&toep->ulp_pduq, &mq);

sys/dev/cxgbe/nvmf/nvmf_che.c

581

mbufq_drain(&mq);

sys/dev/oce/oce_hw.c

483

rc = oce_start_mq(sc->mq);

sys/dev/oce/oce_if.c

2649

struct oce_mq *mq = (struct oce_mq *)arg;

sys/dev/oce/oce_if.c

2650

POCE_SOFTC sc = mq->parent;

sys/dev/oce/oce_if.c

2651

struct oce_cq *cq = mq->cq;

sys/dev/oce/oce_if.h

848

struct oce_mq *mq; /* Mailbox queue */

sys/dev/oce/oce_if.h

976

int oce_start_mq(struct oce_mq *mq);

sys/dev/oce/oce_mbox.c

334

struct oce_mq *mq = sc->mq;

sys/dev/oce/oce_mbox.c

338

mbx = RING_GET_PRODUCER_ITEM_VA(mq->ring, struct oce_mbx);

sys/dev/oce/oce_mbox.c

350

bus_dmamap_sync(mq->ring->dma.tag, mq->ring->dma.map,

sys/dev/oce/oce_mbox.c

352

RING_PUT(mq->ring, 1);

sys/dev/oce/oce_mbox.c

353

reg_value = (1 << 16) | mq->mq_id;

sys/dev/oce/oce_queue.c

147

sc->mq = oce_mq_create(sc, sc->eq[0], 64);

sys/dev/oce/oce_queue.c

148

if (!sc->mq)

sys/dev/oce/oce_queue.c

188

if (sc->mq)

sys/dev/oce/oce_queue.c

189

oce_mq_free(sc->mq);

sys/dev/oce/oce_queue.c

634

struct oce_mq *mq = NULL;

sys/dev/oce/oce_queue.c

647

mq = malloc(sizeof(struct oce_mq), M_DEVBUF, M_NOWAIT | M_ZERO);

sys/dev/oce/oce_queue.c

648

if (!mq) {

sys/dev/oce/oce_queue.c

653

mq->parent = sc;

sys/dev/oce/oce_queue.c

655

mq->ring = oce_create_ring_buffer(sc, q_len, sizeof(struct oce_mbx));

sys/dev/oce/oce_queue.c

656

if (!mq->ring)

sys/dev/oce/oce_queue.c

670

num_pages = oce_page_list(mq->ring, &fwcmd->params.req.pages[0]);

sys/dev/oce/oce_queue.c

68

static void oce_mq_free(struct oce_mq *mq);

sys/dev/oce/oce_queue.c

708

mq->mq_id = LE_16(fwcmd->params.rsp.mq_id);

sys/dev/oce/oce_queue.c

709

mq->cq = cq;

sys/dev/oce/oce_queue.c

712

mq->cq->eq = eq;

sys/dev/oce/oce_queue.c

713

mq->cfg.q_len = (uint8_t) q_len;

sys/dev/oce/oce_queue.c

714

mq->cfg.eqd = 0;

sys/dev/oce/oce_queue.c

715

mq->qstate = QCREATED;

sys/dev/oce/oce_queue.c

717

mq->cq->cb_arg = mq;

sys/dev/oce/oce_queue.c

718

mq->cq->cq_handler = oce_mq_handler;

sys/dev/oce/oce_queue.c

720

return mq;

sys/dev/oce/oce_queue.c

724

oce_mq_free(mq);

sys/dev/oce/oce_queue.c

725

mq = NULL;

sys/dev/oce/oce_queue.c

726

return mq;

sys/dev/oce/oce_queue.c

734

oce_mq_free(struct oce_mq *mq)

sys/dev/oce/oce_queue.c

736

POCE_SOFTC sc = (POCE_SOFTC) mq->parent;

sys/dev/oce/oce_queue.c

740

if (!mq)

sys/dev/oce/oce_queue.c

743

if (mq->ring != NULL) {

sys/dev/oce/oce_queue.c

744

oce_destroy_ring_buffer(sc, mq->ring);

sys/dev/oce/oce_queue.c

745

mq->ring = NULL;

sys/dev/oce/oce_queue.c

746

if (mq->qstate == QCREATED) {

sys/dev/oce/oce_queue.c

749

fwcmd->params.req.id = mq->mq_id;

sys/dev/oce/oce_queue.c

754

mq->qstate = QDELETED;

sys/dev/oce/oce_queue.c

757

if (mq->cq != NULL) {

sys/dev/oce/oce_queue.c

758

oce_cq_del(sc, mq->cq);

sys/dev/oce/oce_queue.c

759

mq->cq = NULL;

sys/dev/oce/oce_queue.c

762

free(mq, M_DEVBUF);

sys/dev/oce/oce_queue.c

763

mq = NULL;

sys/dev/oce/oce_queue.c

941

oce_start_mq(struct oce_mq *mq)

sys/dev/oce/oce_queue.c

943

oce_arm_cq(mq->parent, mq->cq->cq_id, 0, TRUE);

sys/dev/ocs_fc/ocs_ddump.c

462

ocs_ddump_sli4_queue(textbuf, "mq", hw, hw->mq, hw->mq_count,

sys/dev/ocs_fc/ocs_ddump.c

557

hw_mq_t *mq;

sys/dev/ocs_fc/ocs_ddump.c

573

mq = (hw_mq_t *) q;

sys/dev/ocs_fc/ocs_ddump.c

574

ocs_ddump_section(textbuf, "mq", mq->instance);

sys/dev/ocs_fc/ocs_ddump.c

575

ocs_ddump_value(textbuf, "queue-id", "%d", mq->queue->id);

sys/dev/ocs_fc/ocs_ddump.c

576

OCS_STAT(ocs_ddump_value(textbuf, "use_count", "%d", mq->use_count));

sys/dev/ocs_fc/ocs_ddump.c

577

ocs_ddump_endsection(textbuf, "mq", mq->instance);

sys/dev/ocs_fc/ocs_hw.c

1269

sli_queue_free(&hw->sli, &hw->mq[i], destroy_queues, free_memory);

sys/dev/ocs_fc/ocs_hw.c

1434

sli_queue_reset(&hw->sli, &hw->mq[i]);

sys/dev/ocs_fc/ocs_hw.c

2265

if (sli_queue_write(&hw->sli, hw->mq, ctx->buf) < 0) {

sys/dev/ocs_fc/ocs_hw.c

2323

if (hw->mq->length && !sli_queue_is_empty(&hw->sli, hw->mq)) {

sys/dev/ocs_fc/ocs_hw.c

8462

ocs_hw_mq_process(hw, status, hw->mq);

sys/dev/ocs_fc/ocs_hw.c

9098

ocs_hw_mq_process(ocs_hw_t *hw, int32_t status, sli4_queue_t *mq)

sys/dev/ocs_fc/ocs_hw.c

9102

if (!sli_queue_read(&hw->sli, mq, mqe)) {

sys/dev/ocs_fc/ocs_hw.c

9103

ocs_hw_command_process(hw, status, mqe, mq->size);

sys/dev/ocs_fc/ocs_hw.h

1241

extern void hw_del_mq(hw_mq_t *mq);

sys/dev/ocs_fc/ocs_hw.h

937

sli4_queue_t mq[OCS_HW_MAX_NUM_MQ];

sys/dev/ocs_fc/ocs_hw_queues.c

256

mq = hw_new_mq(cq, len);

sys/dev/ocs_fc/ocs_hw_queues.c

257

if (mq == NULL) {

sys/dev/ocs_fc/ocs_hw_queues.c

505

hw_mq_t *mq = ocs_malloc(hw->os, sizeof(*mq), OCS_M_ZERO | OCS_M_NOWAIT);

sys/dev/ocs_fc/ocs_hw_queues.c

507

if (mq != NULL) {

sys/dev/ocs_fc/ocs_hw_queues.c

508

mq->cq = cq;

sys/dev/ocs_fc/ocs_hw_queues.c

509

mq->type = SLI_QTYPE_MQ;

sys/dev/ocs_fc/ocs_hw_queues.c

510

mq->instance = cq->eq->hw->mq_count++;

sys/dev/ocs_fc/ocs_hw_queues.c

511

mq->entry_count = entry_count;

sys/dev/ocs_fc/ocs_hw_queues.c

512

mq->entry_size = OCS_HW_MQ_DEPTH;

sys/dev/ocs_fc/ocs_hw_queues.c

513

mq->queue = &hw->mq[mq->instance];

sys/dev/ocs_fc/ocs_hw_queues.c

516

mq->queue,

sys/dev/ocs_fc/ocs_hw_queues.c

517

mq->entry_size,

sys/dev/ocs_fc/ocs_hw_queues.c

520

ocs_free(hw->os, mq, sizeof(*mq));

sys/dev/ocs_fc/ocs_hw_queues.c

521

mq = NULL;

sys/dev/ocs_fc/ocs_hw_queues.c

523

hw->hw_mq[mq->instance] = mq;

sys/dev/ocs_fc/ocs_hw_queues.c

524

ocs_list_add_tail(&cq->q_list, mq);

sys/dev/ocs_fc/ocs_hw_queues.c

525

ocs_log_debug(hw->os, "create mq[%2d] id %3d len %4d\n", mq->instance, mq->queue->id,

sys/dev/ocs_fc/ocs_hw_queues.c

526

mq->entry_count);

sys/dev/ocs_fc/ocs_hw_queues.c

529

return mq;

sys/dev/ocs_fc/ocs_hw_queues.c

72

hw_mq_t *mq = NULL;

sys/dev/ocs_fc/ocs_hw_queues.c

826

hw_del_mq(hw_mq_t *mq)

sys/dev/ocs_fc/ocs_hw_queues.c

828

if (mq != NULL) {

sys/dev/ocs_fc/ocs_hw_queues.c

829

ocs_list_remove(&mq->cq->q_list, mq);

sys/dev/ocs_fc/ocs_hw_queues.c

830

mq->cq->eq->hw->hw_mq[mq->instance] = NULL;

sys/dev/ocs_fc/ocs_hw_queues.c

831

ocs_free(mq->cq->eq->hw->os, mq, sizeof(*mq));

sys/dev/ocs_fc/ocs_hw_queues.c

895

hw_mq_t *mq;

sys/dev/ocs_fc/ocs_hw_queues.c

906

mq = (hw_mq_t *) q;

sys/dev/ocs_fc/ocs_hw_queues.c

907

ocs_printf(" mq[%d] id %2d\n", mq->instance, mq->queue->id);

sys/dev/ocs_fc/sli4.c

2286

sli4_req_common_create_mq_ext_t *mq = NULL;

sys/dev/ocs_fc/sli4.c

2301

mq = (sli4_req_common_create_mq_ext_t *)((uint8_t *)buf + sli_config_off);

sys/dev/ocs_fc/sli4.c

2303

mq->hdr.opcode = SLI4_OPC_COMMON_CREATE_MQ_EXT;

sys/dev/ocs_fc/sli4.c

2304

mq->hdr.subsystem = SLI4_SUBSYSTEM_COMMON;

sys/dev/ocs_fc/sli4.c

2305

mq->hdr.request_length = sizeof(sli4_req_common_create_mq_ext_t) -

sys/dev/ocs_fc/sli4.c

2308

mq->num_pages = qmem->size / SLI_PAGE_SIZE;

sys/dev/ocs_fc/sli4.c

2309

switch (mq->num_pages) {

sys/dev/ocs_fc/sli4.c

2311

mq->ring_size = SLI4_MQE_SIZE_16;

sys/dev/ocs_fc/sli4.c

2314

mq->ring_size = SLI4_MQE_SIZE_32;

sys/dev/ocs_fc/sli4.c

2317

mq->ring_size = SLI4_MQE_SIZE_64;

sys/dev/ocs_fc/sli4.c

2320

mq->ring_size = SLI4_MQE_SIZE_128;

sys/dev/ocs_fc/sli4.c

2323

ocs_log_test(sli4->os, "num_pages %d not valid\n", mq->num_pages);

sys/dev/ocs_fc/sli4.c

2328

mq->async_event_bitmap = SLI4_ASYNC_EVT_FC_FCOE;

sys/dev/ocs_fc/sli4.c

2331

mq->cq_id_v1 = cq_id;

sys/dev/ocs_fc/sli4.c

2332

mq->hdr.version = 1;

sys/dev/ocs_fc/sli4.c

2335

mq->cq_id_v0 = cq_id;

sys/dev/ocs_fc/sli4.c

2337

mq->val = TRUE;

sys/dev/ocs_fc/sli4.c

2340

p < mq->num_pages;

sys/dev/ocs_fc/sli4.c

2342

mq->page_physical_address[p].low = ocs_addr32_lo(addr);

sys/dev/ocs_fc/sli4.c

2343

mq->page_physical_address[p].high = ocs_addr32_hi(addr);

sys/dev/ocs_fc/sli4.c

2364

sli4_req_common_destroy_mq_t *mq = NULL;

sys/dev/ocs_fc/sli4.c

2374

mq = (sli4_req_common_destroy_mq_t *)((uint8_t *)buf + sli_config_off);

sys/dev/ocs_fc/sli4.c

2376

mq->hdr.opcode = SLI4_OPC_COMMON_DESTROY_MQ;

sys/dev/ocs_fc/sli4.c

2377

mq->hdr.subsystem = SLI4_SUBSYSTEM_COMMON;

sys/dev/ocs_fc/sli4.c

2378

mq->hdr.request_length = sizeof(sli4_req_common_destroy_mq_t) -

sys/dev/ocs_fc/sli4.c

2381

mq->mq_id = mq_id;

sys/dev/qcom_ess_edma/qcom_ess_edma.c

295

struct mbufq mq;

sys/dev/qcom_ess_edma/qcom_ess_edma.c

297

mbufq_init(&mq, EDMA_RX_RING_SIZE);

sys/dev/qcom_ess_edma/qcom_ess_edma.c

309

(void) qcom_ess_edma_rx_ring_complete(sc, rxs->queue_id, &mq);

sys/dev/qcom_ess_edma/qcom_ess_edma.c

325

(void) qcom_ess_edma_gmac_receive_frames(sc, rxs->queue_id, &mq);

sys/dev/qcom_ess_edma/qcom_ess_edma_gmac.c

439

int rx_queue, struct mbufq *mq)

sys/dev/qcom_ess_edma/qcom_ess_edma_gmac.c

449

while ((m = mbufq_dequeue(mq)) != NULL) {

sys/dev/qcom_ess_edma/qcom_ess_edma_gmac.h

44

struct mbufq *mq);

sys/dev/qcom_ess_edma/qcom_ess_edma_rx.c

329

struct mbufq *mq)

sys/dev/qcom_ess_edma/qcom_ess_edma_rx.c

496

if (mbufq_enqueue(mq, m) != 0) {

sys/dev/qcom_ess_edma/qcom_ess_edma_rx.h

49

int queue, struct mbufq *mq);

sys/dev/rge/if_rge.c

2074

rge_rxeof(struct rge_queues *q, struct mbufq *mq)

sys/dev/rge/if_rge.c

2261

mbufq_enqueue(mq, m);

sys/dev/virtio/network/if_vtnet.c

3663

struct virtio_net_ctrl_mq mq __aligned(2);

sys/dev/virtio/network/if_vtnet.c

3674

s.mq.virtqueue_pairs = vtnet_gtoh16(sc, npairs);

sys/dev/virtio/network/if_vtnet.c

3679

error |= sglist_append(&sg, &s.mq, sizeof(struct virtio_net_ctrl_mq));

sys/kern/uipc_mqueue.c

1015

pn->mn_data = mq;

sys/kern/uipc_mqueue.c

1018

mqueue_free(mq);

sys/kern/uipc_mqueue.c

1345

struct mqueue *mq;

sys/kern/uipc_mqueue.c

1351

mq = VTOMQ(vp);

sys/kern/uipc_mqueue.c

1354

mq->mq_totalbytes,

sys/kern/uipc_mqueue.c

1355

mq->mq_maxmsg,

sys/kern/uipc_mqueue.c

1356

mq->mq_curmsgs,

sys/kern/uipc_mqueue.c

1357

mq->mq_msgsize);

sys/kern/uipc_mqueue.c

1594

struct mqueue *mq;

sys/kern/uipc_mqueue.c

1598

mq = uma_zalloc(mqueue_zone, M_WAITOK | M_ZERO);

sys/kern/uipc_mqueue.c

1599

TAILQ_INIT(&mq->mq_msgq);

sys/kern/uipc_mqueue.c

1601

mq->mq_maxmsg = attr->mq_maxmsg;

sys/kern/uipc_mqueue.c

1602

mq->mq_msgsize = attr->mq_msgsize;

sys/kern/uipc_mqueue.c

1604

mq->mq_maxmsg = default_maxmsg;

sys/kern/uipc_mqueue.c

1605

mq->mq_msgsize = default_msgsize;

sys/kern/uipc_mqueue.c

1607

mtx_init(&mq->mq_mutex, "mqueue lock", NULL, MTX_DEF);

sys/kern/uipc_mqueue.c

1608

knlist_init_mtx(&mq->mq_rsel.si_note, &mq->mq_mutex);

sys/kern/uipc_mqueue.c

1609

knlist_init_mtx(&mq->mq_wsel.si_note, &mq->mq_mutex);

sys/kern/uipc_mqueue.c

1611

return (mq);

sys/kern/uipc_mqueue.c

1618

mqueue_free(struct mqueue *mq)

sys/kern/uipc_mqueue.c

1622

while ((msg = TAILQ_FIRST(&mq->mq_msgq)) != NULL) {

sys/kern/uipc_mqueue.c

1623

TAILQ_REMOVE(&mq->mq_msgq, msg, msg_link);

sys/kern/uipc_mqueue.c

1627

mtx_destroy(&mq->mq_mutex);

sys/kern/uipc_mqueue.c

1628

seldrain(&mq->mq_rsel);

sys/kern/uipc_mqueue.c

1629

seldrain(&mq->mq_wsel);

sys/kern/uipc_mqueue.c

1630

knlist_destroy(&mq->mq_rsel.si_note);

sys/kern/uipc_mqueue.c

1631

knlist_destroy(&mq->mq_wsel.si_note);

sys/kern/uipc_mqueue.c

1632

uma_zfree(mqueue_zone, mq);

sys/kern/uipc_mqueue.c

1690

mqueue_send(struct mqueue *mq, const char *msg_ptr,

sys/kern/uipc_mqueue.c

1701

if (msg_len > mq->mq_msgsize)

sys/kern/uipc_mqueue.c

1709

error = _mqueue_send(mq, msg, -1);

sys/kern/uipc_mqueue.c

1717

error = _mqueue_send(mq, msg, 0);

sys/kern/uipc_mqueue.c

1724

error = _mqueue_send(mq, msg, -1);

sys/kern/uipc_mqueue.c

1743

error = _mqueue_send(mq, msg, tvtohz(&tv));

sys/kern/uipc_mqueue.c

1758

_mqueue_send(struct mqueue *mq, struct mqueue_msg *msg, int timo)

sys/kern/uipc_mqueue.c

1763

mtx_lock(&mq->mq_mutex);

sys/kern/uipc_mqueue.c

1764

while (mq->mq_curmsgs >= mq->mq_maxmsg && error == 0) {

sys/kern/uipc_mqueue.c

1766

mtx_unlock(&mq->mq_mutex);

sys/kern/uipc_mqueue.c

1769

mq->mq_senders++;

sys/kern/uipc_mqueue.c

1770

error = msleep(&mq->mq_senders, &mq->mq_mutex,

sys/kern/uipc_mqueue.c

1772

mq->mq_senders--;

sys/kern/uipc_mqueue.c

1776

if (mq->mq_curmsgs >= mq->mq_maxmsg) {

sys/kern/uipc_mqueue.c

1777

mtx_unlock(&mq->mq_mutex);

sys/kern/uipc_mqueue.c

1781

if (TAILQ_EMPTY(&mq->mq_msgq)) {

sys/kern/uipc_mqueue.c

1782

TAILQ_INSERT_HEAD(&mq->mq_msgq, msg, msg_link);

sys/kern/uipc_mqueue.c

1784

if (msg->msg_prio <= TAILQ_LAST(&mq->mq_msgq, msgq)->msg_prio) {

sys/kern/uipc_mqueue.c

1785

TAILQ_INSERT_TAIL(&mq->mq_msgq, msg, msg_link);

sys/kern/uipc_mqueue.c

1787

TAILQ_FOREACH(msg2, &mq->mq_msgq, msg_link) {

sys/kern/uipc_mqueue.c

1794

mq->mq_curmsgs++;

sys/kern/uipc_mqueue.c

1795

mq->mq_totalbytes += msg->msg_size;

sys/kern/uipc_mqueue.c

1796

if (mq->mq_receivers)

sys/kern/uipc_mqueue.c

1797

wakeup_one(&mq->mq_receivers);

sys/kern/uipc_mqueue.c

1798

else if (mq->mq_notifier != NULL)

sys/kern/uipc_mqueue.c

1799

mqueue_send_notification(mq);

sys/kern/uipc_mqueue.c

1800

if (mq->mq_flags & MQ_RSEL) {

sys/kern/uipc_mqueue.c

1801

mq->mq_flags &= ~MQ_RSEL;

sys/kern/uipc_mqueue.c

1802

selwakeup(&mq->mq_rsel);

sys/kern/uipc_mqueue.c

1804

KNOTE_LOCKED(&mq->mq_rsel.si_note, 0);

sys/kern/uipc_mqueue.c

1805

mtx_unlock(&mq->mq_mutex);

sys/kern/uipc_mqueue.c

1814

mqueue_send_notification(struct mqueue *mq)

sys/kern/uipc_mqueue.c

1821

mtx_assert(&mq->mq_mutex, MA_OWNED);

sys/kern/uipc_mqueue.c

1822

nt = mq->mq_notifier;

sys/kern/uipc_mqueue.c

1827

mq->mq_notifier = NULL;

sys/kern/uipc_mqueue.c

1836

mq->mq_notifier = NULL;

sys/kern/uipc_mqueue.c

1845

mqueue_receive(struct mqueue *mq, char *msg_ptr,

sys/kern/uipc_mqueue.c

1854

if (msg_len < mq->mq_msgsize)

sys/kern/uipc_mqueue.c

1859

error = _mqueue_recv(mq, &msg, -1);

sys/kern/uipc_mqueue.c

1867

error = _mqueue_recv(mq, &msg, 0);

sys/kern/uipc_mqueue.c

1874

error = _mqueue_recv(mq, &msg, -1);

sys/kern/uipc_mqueue.c

1894

error = _mqueue_recv(mq, &msg, tvtohz(&tv));

sys/kern/uipc_mqueue.c

1915

_mqueue_recv(struct mqueue *mq, struct mqueue_msg **msg, int timo)

sys/kern/uipc_mqueue.c

1919

mtx_lock(&mq->mq_mutex);

sys/kern/uipc_mqueue.c

1920

while ((*msg = TAILQ_FIRST(&mq->mq_msgq)) == NULL && error == 0) {

sys/kern/uipc_mqueue.c

1922

mtx_unlock(&mq->mq_mutex);

sys/kern/uipc_mqueue.c

1925

mq->mq_receivers++;

sys/kern/uipc_mqueue.c

1926

error = msleep(&mq->mq_receivers, &mq->mq_mutex,

sys/kern/uipc_mqueue.c

1928

mq->mq_receivers--;

sys/kern/uipc_mqueue.c

1934

TAILQ_REMOVE(&mq->mq_msgq, *msg, msg_link);

sys/kern/uipc_mqueue.c

1935

mq->mq_curmsgs--;

sys/kern/uipc_mqueue.c

1936

mq->mq_totalbytes -= (*msg)->msg_size;

sys/kern/uipc_mqueue.c

1937

if (mq->mq_senders)

sys/kern/uipc_mqueue.c

1938

wakeup_one(&mq->mq_senders);

sys/kern/uipc_mqueue.c

1939

if (mq->mq_flags & MQ_WSEL) {

sys/kern/uipc_mqueue.c

1940

mq->mq_flags &= ~MQ_WSEL;

sys/kern/uipc_mqueue.c

1941

selwakeup(&mq->mq_wsel);

sys/kern/uipc_mqueue.c

1943

KNOTE_LOCKED(&mq->mq_wsel.si_note, 0);

sys/kern/uipc_mqueue.c

1945

if (mq->mq_notifier != NULL && mq->mq_receivers == 0 &&

sys/kern/uipc_mqueue.c

1946

!TAILQ_EMPTY(&mq->mq_msgq)) {

sys/kern/uipc_mqueue.c

1947

mqueue_send_notification(mq);

sys/kern/uipc_mqueue.c

1949

mtx_unlock(&mq->mq_mutex);

sys/kern/uipc_mqueue.c

1991

notifier_remove(struct proc *p, struct mqueue *mq, int fd)

sys/kern/uipc_mqueue.c

1995

mtx_assert(&mq->mq_mutex, MA_OWNED);

sys/kern/uipc_mqueue.c

1999

if (mq->mq_notifier == nt)

sys/kern/uipc_mqueue.c

2000

mq->mq_notifier = NULL;

sys/kern/uipc_mqueue.c

2015

struct mqueue *mq;

sys/kern/uipc_mqueue.c

2023

mq = NULL;

sys/kern/uipc_mqueue.c

2066

mq = mqueue_alloc(attr);

sys/kern/uipc_mqueue.c

2067

if (mq == NULL) {

sys/kern/uipc_mqueue.c

2075

mqueue_free(mq);

sys/kern/uipc_mqueue.c

2081

pn->mn_data = mq;

sys/kern/uipc_mqueue.c

2232

struct mqueue *mq;

sys/kern/uipc_mqueue.c

2240

error = getmq(td, mqd, &fp, NULL, &mq);

sys/kern/uipc_mqueue.c

2243

oattr->mq_maxmsg = mq->mq_maxmsg;

sys/kern/uipc_mqueue.c

2244

oattr->mq_msgsize = mq->mq_msgsize;

sys/kern/uipc_mqueue.c

2245

oattr->mq_curmsgs = mq->mq_curmsgs;

sys/kern/uipc_mqueue.c

2283

struct mqueue *mq;

sys/kern/uipc_mqueue.c

2288

error = getmq_read(td, mqd, &fp, NULL, &mq);

sys/kern/uipc_mqueue.c

2292

error = mqueue_receive(mq, msg_ptr, msg_len, msg_prio, waitok,

sys/kern/uipc_mqueue.c

2320

struct mqueue *mq;

sys/kern/uipc_mqueue.c

2325

error = getmq_write(td, mqd, &fp, NULL, &mq);

sys/kern/uipc_mqueue.c

2329

error = mqueue_send(mq, msg_ptr, msg_len, msg_prio, waitok,

sys/kern/uipc_mqueue.c

2358

struct mqueue *mq;

sys/kern/uipc_mqueue.c

2376

error = getmq(td, mqd, &fp, NULL, &mq);

sys/kern/uipc_mqueue.c

2399

mtx_lock(&mq->mq_mutex);

sys/kern/uipc_mqueue.c

2402

if (mq->mq_notifier != NULL) {

sys/kern/uipc_mqueue.c

2410

mtx_unlock(&mq->mq_mutex);

sys/kern/uipc_mqueue.c

2433

mq->mq_notifier = nt;

sys/kern/uipc_mqueue.c

2440

if (mq->mq_receivers == 0 &&

sys/kern/uipc_mqueue.c

2441

!TAILQ_EMPTY(&mq->mq_msgq))

sys/kern/uipc_mqueue.c

2442

mqueue_send_notification(mq);

sys/kern/uipc_mqueue.c

2445

notifier_remove(p, mq, mqd);

sys/kern/uipc_mqueue.c

2447

mtx_unlock(&mq->mq_mutex);

sys/kern/uipc_mqueue.c

2478

struct mqueue *mq;

sys/kern/uipc_mqueue.c

2486

mq = FPTOMQ(fp);

sys/kern/uipc_mqueue.c

2487

mtx_lock(&mq->mq_mutex);

sys/kern/uipc_mqueue.c

2489

mtx_unlock(&mq->mq_mutex);

sys/kern/uipc_mqueue.c

2500

struct mqueue *mq = FPTOMQ(fp);

sys/kern/uipc_mqueue.c

2503

mtx_lock(&mq->mq_mutex);

sys/kern/uipc_mqueue.c

2505

if (mq->mq_curmsgs) {

sys/kern/uipc_mqueue.c

2508

mq->mq_flags |= MQ_RSEL;

sys/kern/uipc_mqueue.c

2509

selrecord(td, &mq->mq_rsel);

sys/kern/uipc_mqueue.c

2513

if (mq->mq_curmsgs < mq->mq_maxmsg)

sys/kern/uipc_mqueue.c

2516

mq->mq_flags |= MQ_WSEL;

sys/kern/uipc_mqueue.c

2517

selrecord(td, &mq->mq_wsel);

sys/kern/uipc_mqueue.c

2520

mtx_unlock(&mq->mq_mutex);

sys/kern/uipc_mqueue.c

2541

struct mqueue *mq;

sys/kern/uipc_mqueue.c

2549

mq = FPTOMQ(fp);

sys/kern/uipc_mqueue.c

2550

mtx_lock(&mq->mq_mutex);

sys/kern/uipc_mqueue.c

2551

notifier_remove(td->td_proc, mq, fd);

sys/kern/uipc_mqueue.c

2554

if (mq->mq_flags & MQ_RSEL) {

sys/kern/uipc_mqueue.c

2555

mq->mq_flags &= ~MQ_RSEL;

sys/kern/uipc_mqueue.c

2556

selwakeup(&mq->mq_rsel);

sys/kern/uipc_mqueue.c

2558

if (mq->mq_flags & MQ_WSEL) {

sys/kern/uipc_mqueue.c

2559

mq->mq_flags &= ~MQ_WSEL;

sys/kern/uipc_mqueue.c

2560

selwakeup(&mq->mq_wsel);

sys/kern/uipc_mqueue.c

2562

mtx_unlock(&mq->mq_mutex);

sys/kern/uipc_mqueue.c

258

static void mqueue_free(struct mqueue *mq);

sys/kern/uipc_mqueue.c

259

static int mqueue_send(struct mqueue *mq, const char *msg_ptr,

sys/kern/uipc_mqueue.c

262

static int mqueue_receive(struct mqueue *mq, char *msg_ptr,

sys/kern/uipc_mqueue.c

2631

struct mqueue *mq = FPTOMQ(fp);

sys/kern/uipc_mqueue.c

2636

knlist_add(&mq->mq_rsel.si_note, kn, 0);

sys/kern/uipc_mqueue.c

2639

knlist_add(&mq->mq_wsel.si_note, kn, 0);

sys/kern/uipc_mqueue.c

2648

struct mqueue *mq = FPTOMQ(kn->kn_fp);

sys/kern/uipc_mqueue.c

265

static int _mqueue_send(struct mqueue *mq, struct mqueue_msg *msg,

sys/kern/uipc_mqueue.c

2651

knlist_remove(&mq->mq_rsel.si_note, kn, 0);

sys/kern/uipc_mqueue.c

2653

knlist_remove(&mq->mq_wsel.si_note, kn, 0);

sys/kern/uipc_mqueue.c

2661

struct mqueue *mq = FPTOMQ(kn->kn_fp);

sys/kern/uipc_mqueue.c

2663

mtx_assert(&mq->mq_mutex, MA_OWNED);

sys/kern/uipc_mqueue.c

2664

return (mq->mq_curmsgs != 0);

sys/kern/uipc_mqueue.c

267

static int _mqueue_recv(struct mqueue *mq, struct mqueue_msg **msg,

sys/kern/uipc_mqueue.c

2670

struct mqueue *mq = FPTOMQ(kn->kn_fp);

sys/kern/uipc_mqueue.c

2672

mtx_assert(&mq->mq_mutex, MA_OWNED);

sys/kern/uipc_mqueue.c

2673

return (mq->mq_curmsgs < mq->mq_maxmsg);

sys/kern/uipc_mqueue.c

269

static void mqueue_send_notification(struct mqueue *mq);

sys/kern/uipc_mqueue.c

992

struct mqueue *mq;

sys/kern/uipc_mqueue.c

998

mq = mqueue_alloc(NULL);

sys/kern/uipc_mqueue.c

999

if (mq == NULL)

sys/netinet/igmp.c

2396

struct mbufq *mq;

sys/netinet/igmp.c

2470

mq = &inm->inm_scq;

sys/netinet/igmp.c

2471

mbufq_drain(mq);

sys/netinet/igmp.c

2472

retval = igmp_v3_enqueue_group_record(mq, inm, 1,

sys/netinet/igmp.c

2699

igmp_v3_enqueue_group_record(struct mbufq *mq, struct in_multi *inm,

sys/netinet/igmp.c

2788

return (igmp_v3_enqueue_filter_change(mq, inm));

sys/netinet/igmp.c

2817

m0 = mbufq_last(mq);

sys/netinet/igmp.c

2828

if (mbufq_full(mq)) {

sys/netinet/igmp.c

2941

mbufq_enqueue(mq, m);

sys/netinet/igmp.c

2957

if (mbufq_full(mq)) {

sys/netinet/igmp.c

3020

mbufq_enqueue(mq, m);

sys/netinet/igmp.c

3060

igmp_v3_enqueue_filter_change(struct mbufq *mq, struct in_multi *inm)

sys/netinet/igmp.c

3108

m0 = mbufq_last(mq);

sys/netinet/igmp.c

3257

mbufq_enqueue(mq, m);

sys/netinet/igmp.c

556

igmp_dispatch_queue(struct mbufq *mq, int limit, const int loop)

sys/netinet/igmp.c

562

while ((m = mbufq_dequeue(mq)) != NULL) {

sys/netinet/igmp.c

563

CTR3(KTR_IGMPV3, "%s: dispatch %p from %p", __func__, mq, m);

sys/netinet6/mld6.c

1923

struct mbufq *mq;

sys/netinet6/mld6.c

2013

mq = &inm->in6m_scq;

sys/netinet6/mld6.c

2014

mbufq_drain(mq);

sys/netinet6/mld6.c

2015

retval = mld_v2_enqueue_group_record(mq, inm, 1,

sys/netinet6/mld6.c

2253

mld_v2_enqueue_group_record(struct mbufq *mq, struct in6_multi *inm,

sys/netinet6/mld6.c

2367

return (mld_v2_enqueue_filter_change(mq, inm));

sys/netinet6/mld6.c

2398

m0 = mbufq_last(mq);

sys/netinet6/mld6.c

2410

if (mbufq_full(mq)) {

sys/netinet6/mld6.c

2523

mbufq_enqueue(mq, m);

sys/netinet6/mld6.c

2539

if (mbufq_full(mq)) {

sys/netinet6/mld6.c

2598

mbufq_enqueue(mq, m);

sys/netinet6/mld6.c

2638

mld_v2_enqueue_filter_change(struct mbufq *mq, struct in6_multi *inm)

sys/netinet6/mld6.c

2686

m0 = mbufq_last(mq);

sys/netinet6/mld6.c

2832

mbufq_enqueue(mq, m);

sys/netinet6/mld6.c

421

mld_dispatch_queue(struct mbufq *mq, int limit)

sys/netinet6/mld6.c

425

while ((m = mbufq_dequeue(mq)) != NULL) {

sys/netinet6/mld6.c

426

CTR3(KTR_MLD, "%s: dispatch %p from %p", __func__, mq, m);

sys/netpfil/ipfw/dn_aqm_codel.c

195

next: m = q->mq.head;

sys/netpfil/ipfw/dn_aqm_codel.c

198

q->mq.head = m->m_nextpkt;

sys/netpfil/ipfw/dn_aqm_codel.c

269

mq_append(&q->mq, m);

sys/netpfil/ipfw/dn_aqm_pie.c

331

next: m = q->mq.head;

sys/netpfil/ipfw/dn_aqm_pie.c

334

q->mq.head = m->m_nextpkt;

sys/netpfil/ipfw/dn_aqm_pie.c

555

mq_append(&q->mq, m);

sys/netpfil/ipfw/dn_sched.h

174

m = q->mq.head;

sys/netpfil/ipfw/dn_sched.h

182

q->mq.head = m->m_nextpkt;

sys/netpfil/ipfw/dn_sched.h

183

q->mq.count--;

sys/netpfil/ipfw/dn_sched_fifo.c

97

dn_free_pkts(q->mq.head);

sys/netpfil/ipfw/dn_sched_fq_codel.c

157

struct mbuf *m = q->mq.head;

sys/netpfil/ipfw/dn_sched_fq_codel.c

161

q->mq.head = m->m_nextpkt;

sys/netpfil/ipfw/dn_sched_fq_codel.c

198

mq_append(&q->mq, m);

sys/netpfil/ipfw/dn_sched_fq_codel.h

141

next: m = q->mq.head;

sys/netpfil/ipfw/dn_sched_fq_codel.h

144

q->mq.head = m->m_nextpkt;

sys/netpfil/ipfw/dn_sched_fq_codel.h

60

struct mq mq; /* list of packets */

sys/netpfil/ipfw/dn_sched_fq_pie.c

106

struct mq mq; /* list of packets */

sys/netpfil/ipfw/dn_sched_fq_pie.c

341

next: m = q->mq.head;

sys/netpfil/ipfw/dn_sched_fq_pie.c

344

q->mq.head = m->m_nextpkt;

sys/netpfil/ipfw/dn_sched_fq_pie.c

750

mq_append(&q->mq, m);

sys/netpfil/ipfw/dn_sched_fq_pie.c

767

struct mbuf *m = q->mq.head;

sys/netpfil/ipfw/dn_sched_fq_pie.c

771

q->mq.head = m->m_nextpkt;

sys/netpfil/ipfw/dn_sched_prio.c

132

if (q->mq.head == NULL) {

sys/netpfil/ipfw/dn_sched_prio.c

170

if (q->mq.head == NULL)

sys/netpfil/ipfw/dn_sched_prio.c

185

oldq->mq.tail->m_nextpkt = q->mq.head;

sys/netpfil/ipfw/dn_sched_prio.c

186

oldq->mq.tail = q->mq.tail;

sys/netpfil/ipfw/dn_sched_prio.c

191

q->mq.tail = q->mq.head = NULL;

sys/netpfil/ipfw/dn_sched_qfq.c

529

if (cl->_q.mq.head == NULL) {

sys/netpfil/ipfw/dn_sched_qfq.c

535

len = cl->_q.mq.head->m_pkthdr.len;

sys/netpfil/ipfw/dn_sched_qfq.c

665

if (m != _q->mq.head) {

sys/netpfil/ipfw/dn_sched_qfq.c

669

if (m != _q->mq.head)

sys/netpfil/ipfw/dn_sched_rr.c

156

if (m != q->mq.head) {

sys/netpfil/ipfw/dn_sched_rr.c

159

if (m != q->mq.head)

sys/netpfil/ipfw/dn_sched_rr.c

185

struct mbuf *m = rrq->q.mq.head;

sys/netpfil/ipfw/dn_sched_rr.c

273

if (_q->mq.head != NULL) {

sys/netpfil/ipfw/dn_sched_wf2q.c

143

if (m != q->mq.head) {

sys/netpfil/ipfw/dn_sched_wf2q.c

146

if (m != q->mq.head) /* queue was already busy */

sys/netpfil/ipfw/dn_sched_wf2q.c

251

if (q->mq.head == 0) { /* not backlogged any more. */

sys/netpfil/ipfw/dn_sched_wf2q.c

255

uint64_t len = q->mq.head->m_pkthdr.len;

sys/netpfil/ipfw/dn_sched_wf2q.c

314

if (_q->mq.head != NULL) {

sys/netpfil/ipfw/dn_sched_wf2q.c

315

wf2qp_enqueue(_q->_si, _q, _q->mq.head);

sys/netpfil/ipfw/ip_dn_io.c

257

mq_append(struct mq *q, struct mbuf *m)

sys/netpfil/ipfw/ip_dn_io.c

543

mq_append(&q->mq, m);

sys/netpfil/ipfw/ip_dn_io.c

565

transmit_event(struct mq *q, struct delay_line *dline, uint64_t now)

sys/netpfil/ipfw/ip_dn_io.c

571

while ((m = dline->mq.head) != NULL) {

sys/netpfil/ipfw/ip_dn_io.c

575

dline->mq.head = m->m_nextpkt;

sys/netpfil/ipfw/ip_dn_io.c

576

dline->mq.count--;

sys/netpfil/ipfw/ip_dn_io.c

618

serve_sched(struct mq *q, struct dn_sch_inst *si, uint64_t now)

sys/netpfil/ipfw/ip_dn_io.c

620

struct mq def_q;

sys/netpfil/ipfw/ip_dn_io.c

623

int delay_line_idle = (si->dline.mq.head == NULL);

sys/netpfil/ipfw/ip_dn_io.c

652

mq_append(&si->dline.mq, m);

sys/netpfil/ipfw/ip_dn_io.c

685

struct mq q = { NULL, NULL }; /* queue to accumulate results */

sys/netpfil/ipfw/ip_dn_io.c

693

memset(&q, 0, sizeof(struct mq));

sys/netpfil/ipfw/ip_dn_private.h

188

struct mq mq;

sys/netpfil/ipfw/ip_dn_private.h

252

struct mq mq; /* packets queue */

sys/netpfil/ipfw/ip_dn_private.h

452

mq_append(struct mq *q, struct mbuf *m)

sys/netpfil/ipfw/ip_dummynet.c

2366

if ((si->kflags & DN_ACTIVE) || si->dline.mq.head != NULL)

sys/netpfil/ipfw/ip_dummynet.c

410

if (q->mq.head)

sys/netpfil/ipfw/ip_dummynet.c

411

dn_free_pkts(q->mq.head);

sys/netpfil/ipfw/ip_dummynet.c

580

dn_free_pkts(dl->mq.head); /* drain delay line */

sys/netpfil/ipfw/nat64/nat64_translate.c

1231

struct mbufq mq;

sys/netpfil/ipfw/nat64/nat64_translate.c

1324

mbufq_init(&mq, 255);

sys/netpfil/ipfw/nat64/nat64_translate.c

1325

nat64_fragment6(&cfg->stats, &ip6, &mq, m, nh->nh_mtu, ip_id, ip_off);

sys/netpfil/ipfw/nat64/nat64_translate.c

1326

while ((m = mbufq_dequeue(&mq)) != NULL) {

sys/netpfil/ipfw/nat64/nat64_translate.c

1332

mbufq_drain(&mq);

sys/netpfil/ipfw/nat64/nat64_translate.c

537

struct mbufq *mq, struct mbuf *m, uint32_t mtu, uint16_t ip_id,

sys/netpfil/ipfw/nat64/nat64_translate.c

556

if (mbufq_enqueue(mq, m) != 0) {

sys/netpfil/ipfw/nat64/nat64_translate.c

604

if (mbufq_enqueue(mq, m) != 0)

sys/netpfil/ipfw/nat64/nat64_translate.c

608

NAT64STAT_ADD(stats, ofrags, mbufq_len(mq));

sys/netpfil/ipfw/nat64/nat64_translate.c

615

mbufq_drain(mq);

sys/netpfil/ipfw/test/dn_test.h

168

mq_append(struct mq *q, struct mbuf *m)

sys/netpfil/ipfw/test/main.c

141

struct mq *mq = (struct mq *)si;

sys/netpfil/ipfw/test/main.c

145

if (mq->head == NULL)

sys/netpfil/ipfw/test/main.c

146

mq->head = m;

sys/netpfil/ipfw/test/main.c

148

mq->tail->m_nextpkt = m;

sys/netpfil/ipfw/test/main.c

149

mq->tail = m;

sys/netpfil/ipfw/test/main.c

156

struct mq *mq = (struct mq *)si;

sys/netpfil/ipfw/test/main.c

159

if ((m = mq->head)) {

sys/netpfil/ipfw/test/main.c

160

m = mq->head;

sys/netpfil/ipfw/test/main.c

161

mq->head = m->m_nextpkt;

sys/netpfil/ipfw/test/test_dn_sched.c

39

if (q->mq.head)

sys/netpfil/ipfw/test/test_dn_sched.c

40

dn_free_pkts(q->mq.head);

sys/netpfil/ipfw/test/test_dn_sched.c

60

mq_append(&q->mq, m);

sys/sys/mbuf.h

1583

mbufq_init(struct mbufq *mq, int maxlen)

sys/sys/mbuf.h

1586

STAILQ_INIT(&mq->mq_head);

sys/sys/mbuf.h

1587

mq->mq_maxlen = maxlen;

sys/sys/mbuf.h

1588

mq->mq_len = 0;

sys/sys/mbuf.h

1592

mbufq_flush(struct mbufq *mq)

sys/sys/mbuf.h

1596

m = STAILQ_FIRST(&mq->mq_head);

sys/sys/mbuf.h

1597

STAILQ_INIT(&mq->mq_head);

sys/sys/mbuf.h

1598

mq->mq_len = 0;

sys/sys/mbuf.h

1603

mbufq_drain(struct mbufq *mq)

sys/sys/mbuf.h

1607

n = mbufq_flush(mq);

sys/sys/mbuf.h

1615

mbufq_first(const struct mbufq *mq)

sys/sys/mbuf.h

1618

return (STAILQ_FIRST(&mq->mq_head));

sys/sys/mbuf.h

1622

mbufq_last(const struct mbufq *mq)

sys/sys/mbuf.h

1625

return (STAILQ_LAST(&mq->mq_head, mbuf, m_stailqpkt));

sys/sys/mbuf.h

1629

mbufq_empty(const struct mbufq *mq)

sys/sys/mbuf.h

1631

return (mq->mq_len == 0);

sys/sys/mbuf.h

1635

mbufq_full(const struct mbufq *mq)

sys/sys/mbuf.h

1638

return (mq->mq_maxlen > 0 && mq->mq_len >= mq->mq_maxlen);

sys/sys/mbuf.h

1642

mbufq_len(const struct mbufq *mq)

sys/sys/mbuf.h

1645

return (mq->mq_len);

sys/sys/mbuf.h

1649

mbufq_enqueue(struct mbufq *mq, struct mbuf *m)

sys/sys/mbuf.h

1652

if (mbufq_full(mq))

sys/sys/mbuf.h

1654

STAILQ_INSERT_TAIL(&mq->mq_head, m, m_stailqpkt);

sys/sys/mbuf.h

1655

mq->mq_len++;

sys/sys/mbuf.h

1660

mbufq_dequeue(struct mbufq *mq)

sys/sys/mbuf.h

1664

m = STAILQ_FIRST(&mq->mq_head);

sys/sys/mbuf.h

1666

STAILQ_REMOVE_HEAD(&mq->mq_head, m_stailqpkt);

sys/sys/mbuf.h

1668

mq->mq_len--;

sys/sys/mbuf.h

1674

mbufq_prepend(struct mbufq *mq, struct mbuf *m)

sys/sys/mbuf.h

1677

STAILQ_INSERT_HEAD(&mq->mq_head, m, m_stailqpkt);

sys/sys/mbuf.h

1678

mq->mq_len++;

tests/sys/capsicum/mqueue.cc

32

int mq = mq_open_("/cap_mq", O_RDWR|O_CREAT, 0644, NULL);

tests/sys/capsicum/mqueue.cc

36

if (mq < 0 && errno == ENOSYS) {

tests/sys/capsicum/mqueue.cc

39

EXPECT_OK(mq);

tests/sys/capsicum/mqueue.cc

47

int cap_read_mq = dup(mq);

tests/sys/capsicum/mqueue.cc

50

int cap_write_mq = dup(mq);

tests/sys/capsicum/mqueue.cc

53

int cap_poll_mq = dup(mq);

tests/sys/capsicum/mqueue.cc

56

EXPECT_OK(mq_close_(mq));

tests/sys/mqueue/mqtest1.c

16

mqd_t mq;

tests/sys/mqueue/mqtest1.c

21

mq = mq_open(MQNAME, O_CREAT | O_RDWR | O_EXCL, 0666, &attr);

tests/sys/mqueue/mqtest1.c

22

if (mq == (mqd_t)-1)

tests/sys/mqueue/mqtest1.c

27

status = mq_getattr(mq, &attr2);

tests/sys/mqueue/mqtest1.c

37

status = mq_notify(mq, &sigev);

tests/sys/mqueue/mqtest1.c

40

status = mq_notify(mq, &sigev);

tests/sys/mqueue/mqtest1.c

45

status = mq_notify(mq, NULL);

tests/sys/mqueue/mqtest1.c

48

status = mq_close(mq);

tests/sys/mqueue/mqtest2.c

27

mqd_t mq;

tests/sys/mqueue/mqtest2.c

35

mq = mq_open(MQNAME, O_CREAT | O_RDWR | O_EXCL, 0666, &attr);

tests/sys/mqueue/mqtest2.c

36

if (mq == (mqd_t)-1)

tests/sys/mqueue/mqtest2.c

38

status = mq_getattr(mq, &attr);

tests/sys/mqueue/mqtest2.c

47

mq_close(mq);

tests/sys/mqueue/mqtest2.c

51

mq = mq_open(MQNAME, O_RDWR);

tests/sys/mqueue/mqtest2.c

52

if (mq == (mqd_t)-1)

tests/sys/mqueue/mqtest2.c

57

status = mq_receive(mq, buf, attr.mq_msgsize, &prio);

tests/sys/mqueue/mqtest2.c

69

mq_close(mq);

tests/sys/mqueue/mqtest2.c

83

status = mq_send(mq, buf, attr.mq_msgsize, PRIO);

tests/sys/mqueue/mqtest2.c

91

status = mq_close(mq);

tests/sys/mqueue/mqtest3.c

108

status = mq_close(mq);

tests/sys/mqueue/mqtest3.c

30

mqd_t mq;

tests/sys/mqueue/mqtest3.c

37

mq = mq_open(MQNAME, O_CREAT | O_RDWR | O_EXCL, 0666, &attr);

tests/sys/mqueue/mqtest3.c

38

if (mq == (mqd_t)-1)

tests/sys/mqueue/mqtest3.c

40

status = mq_getattr(mq, &attr);

tests/sys/mqueue/mqtest3.c

50

mq_close(mq);

tests/sys/mqueue/mqtest3.c

54

mq = mq_open(MQNAME, O_RDWR);

tests/sys/mqueue/mqtest3.c

55

if (mq == (mqd_t)-1)

tests/sys/mqueue/mqtest3.c

60

FD_SET(mq_getfd_np(mq), &set);

tests/sys/mqueue/mqtest3.c

62

status = select(mq_getfd_np(mq) + 1, &set, NULL,

tests/sys/mqueue/mqtest3.c

66

status = mq_receive(mq, buf, attr.mq_msgsize, &prio);

tests/sys/mqueue/mqtest3.c

77

mq_close(mq);

tests/sys/mqueue/mqtest3.c

93

FD_SET(mq_getfd_np(mq), &set);

tests/sys/mqueue/mqtest3.c

94

status = select(mq_getfd_np(mq) + 1, NULL, &set,

tests/sys/mqueue/mqtest3.c

98

status = mq_send(mq, buf, attr.mq_msgsize, PRIO);

tests/sys/mqueue/mqtest4.c

100

status = mq_send(mq, buf, attr.mq_msgsize, PRIO);

tests/sys/mqueue/mqtest4.c

110

status = mq_close(mq);

tests/sys/mqueue/mqtest4.c

30

mqd_t mq;

tests/sys/mqueue/mqtest4.c

38

mq = mq_open(MQNAME, O_CREAT | O_RDWR | O_EXCL, 0666, &attr);

tests/sys/mqueue/mqtest4.c

39

if (mq == (mqd_t) -1)

tests/sys/mqueue/mqtest4.c

41

status = mq_getattr(mq, &attr);

tests/sys/mqueue/mqtest4.c

50

mq_close(mq);

tests/sys/mqueue/mqtest4.c

52

mq = mq_open(MQNAME, O_RDWR);

tests/sys/mqueue/mqtest4.c

53

if (mq == (mqd_t)-1)

tests/sys/mqueue/mqtest4.c

55

EV_SET(&kev, mq_getfd_np(mq), EVFILT_READ, EV_ADD, 0, 0, 0);

tests/sys/mqueue/mqtest4.c

65

status = mq_receive(mq, buf, attr.mq_msgsize, &prio);

tests/sys/mqueue/mqtest4.c

77

mq_close(mq);

tests/sys/mqueue/mqtest4.c

87

EV_SET(&kev, mq_getfd_np(mq), EVFILT_WRITE, EV_ADD, 0, 0, 0);

tests/sys/mqueue/mqtest5.c

108

status = mq_send(mq, buf, attr.mq_msgsize, PRIO);

tests/sys/mqueue/mqtest5.c

118

status = mq_close(mq);

tests/sys/mqueue/mqtest5.c

33

mqd_t mq;

tests/sys/mqueue/mqtest5.c

48

mq = mq_open(MQNAME, O_CREAT | O_RDWR | O_EXCL, 0666, &attr);

tests/sys/mqueue/mqtest5.c

49

if (mq == (mqd_t)-1)

tests/sys/mqueue/mqtest5.c

51

status = mq_getattr(mq, &attr);

tests/sys/mqueue/mqtest5.c

66

mq_close(mq);

tests/sys/mqueue/mqtest5.c

67

mq = mq_open(MQNAME, O_RDWR | O_NONBLOCK);

tests/sys/mqueue/mqtest5.c

68

if (mq == (mqd_t)-1)

tests/sys/mqueue/mqtest5.c

73

status = mq_notify(mq, &sigev);

tests/sys/mqueue/mqtest5.c

81

status = mq_receive(mq, buf, attr.mq_msgsize, &prio);

tests/sys/mqueue/mqtest5.c

93

mq_close(mq);