Home
last modified time | relevance | path

Searched refs:queues (Results 1 – 25 of 345) sorted by relevance

12345678910>>...14

/netbsd-src/external/ibm-public/postfix/dist/src/postsuper/
H A Dpostsuper.c828 const char **queues) in operate_stream() argument
833 operator(queues, STR(buf)); in operate_stream()
903 static void super(const char **queues, int action) in super() argument
933 while ((queue_name = *queues++) != 0) { in super()
1272 const char **queues; in main() local
1480 queues = (const char **) argv + optind; in main()
1482 queues = (const char **) default_queues; in main()
1490 super(queues, action & ACTIONS_FOR_REPAIR); in main()
1499 super(queues, action & ACTIONS_FOR_REPAIR); in main()
1530 super(queues, ACTION_DELETE_ALL); in main()
[all …]
/netbsd-src/sys/dev/pci/ixgbe/
H A Dixv.c654 evcnt_detach(&sc->queues[i].irqs); in ixv_detach()
655 evcnt_detach(&sc->queues[i].handleq); in ixv_detach()
656 evcnt_detach(&sc->queues[i].req); in ixv_detach()
724 for (i = 0, que = sc->queues; i < sc->num_queues; i++, que++) in ixv_init_locked()
784 for (i = 0, que = sc->queues; i < sc->num_queues; i++, que++) in ixv_init_locked()
833 struct ix_queue *que = &sc->queues[vector]; in ixv_enable_queue()
854 struct ix_queue *que = &sc->queues[vector]; in ixv_disable_queue()
870 ixv_rearm_queues(struct ixgbe_softc *sc, u64 queues)
872 u32 mask = (IXGBE_EIMS_RTX_QUEUE & queues);
1285 struct ix_queue *que = sc->queues; in ixv_handle_timer()
[all …]
H A Dixgbe.c1890 snprintf(sc->queues[i].evnamebuf, in ixgbe_add_hw_stats()
1891 sizeof(sc->queues[i].evnamebuf), "%s q%d", xname, i); in ixgbe_add_hw_stats()
1892 snprintf(sc->queues[i].namebuf, in ixgbe_add_hw_stats()
1893 sizeof(sc->queues[i].namebuf), "q%d", i); in ixgbe_add_hw_stats()
1903 sc->queues[i].namebuf, SYSCTL_DESCR("Queue Name"), in ixgbe_add_hw_stats()
1911 (void *)&sc->queues[i], 0, CTL_CREATE, CTL_EOL) != 0) in ixgbe_add_hw_stats()
1956 evcnt_attach_dynamic(&sc->queues[i].irqs, EVCNT_TYPE_INTR, in ixgbe_add_hw_stats()
1957 NULL, sc->queues[i].evnamebuf, "IRQs on queue"); in ixgbe_add_hw_stats()
1958 evcnt_attach_dynamic(&sc->queues[i].handleq, in ixgbe_add_hw_stats()
1959 EVCNT_TYPE_MISC, NULL, sc->queues[i].evnamebuf, in ixgbe_add_hw_stats()
[all …]
H A Dif_fdir.c142 que = &sc->queues[txr->me]; in ixgbe_atr()
/netbsd-src/sys/fs/udf/
H A Dudf_strat_rmw.c136 struct bufq_state *queues[UDF_SHED_MAX]; member
260 bufq_put(priv->queues[newqueue], eccline->buf); in udf_push_eccline()
279 buf = bufq_peek(priv->queues[queued_on]); in udf_peek_eccline()
313 buf = bufq_get(priv->queues[queued_on]); in udf_pop_eccline()
356 ret = bufq_cancel(priv->queues[eccline->queued_on], eccline->buf); in udf_unqueue_eccline()
1299 if (bufq_peek(priv->queues[UDF_SHED_READING])) in udf_discstrat_thread()
1301 if (bufq_peek(priv->queues[UDF_SHED_WRITING])) in udf_discstrat_thread()
1303 if (bufq_peek(priv->queues[UDF_SHED_SEQWRITING])) in udf_discstrat_thread()
1323 work = (bufq_peek(priv->queues[UDF_SHED_WAITING]) != NULL); in udf_discstrat_thread()
1324 work |= (bufq_peek(priv->queues[UDF_SHED_READING]) != NULL); in udf_discstrat_thread()
[all …]
H A Dudf_strat_sequential.c96 struct bufq_state *queues[UDF_SHED_MAX]; member
284 bufq_put(priv->queues[queue], nestbuf); in udf_queuebuf_seq()
486 buf = bufq_get(priv->queues[priv->cur_queue]); in udf_doshedule()
529 if (bufq_peek(priv->queues[UDF_SHED_READING])) in udf_doshedule()
531 if (bufq_peek(priv->queues[UDF_SHED_WRITING])) /* only for unmount */ in udf_doshedule()
533 if (bufq_peek(priv->queues[UDF_SHED_SEQWRITING])) in udf_doshedule()
579 empty = (bufq_peek(priv->queues[UDF_SHED_READING]) == NULL); in udf_discstrat_thread()
580 empty &= (bufq_peek(priv->queues[UDF_SHED_WRITING]) == NULL); in udf_discstrat_thread()
581 empty &= (bufq_peek(priv->queues[UDF_SHED_SEQWRITING]) == NULL); in udf_discstrat_thread()
657 bufq_alloc(&priv->queues[UDF_SHED_READING], "disksort", in udf_discstrat_init_seq()
[all …]
/netbsd-src/external/ibm-public/postfix/dist/mantools/
H A Dpostlink1216 s/\b"*maildrop"* *queues*\b/<a href="QSHAPE_README.html#maildrop_queue">$&<\/a>/g;
1221 s/\b"*incoming"* *queues*\b/<a href="QSHAPE_README.html#incoming_queue">$&<\/a>/g;
1222 s/<b> *incoming *<\/b> *queues*\b/<a href="QSHAPE_README.html#incoming_queue">$&<\/a>/g;
1224 s/\b"*active"* *queues*\b/<a href="QSHAPE_README.html#active_queue">$&<\/a>/ig;
1225 s/\b"*deferred"* *queues*\b/<a href="QSHAPE_README.html#deferred_queue">$&<\/a>/g;
1226 s/\b"*hold"* *queues*\b/<a href="QSHAPE_README.html#hold_queue">$&<\/a>/g;
/netbsd-src/sys/external/gpl2/dts/dist/arch/arm64/boot/dts/freescale/
H A Dimx8-ss-conn.dtsi86 fsl,num-tx-queues=<3>;
87 fsl,num-rx-queues=<3>;
106 fsl,num-tx-queues=<3>;
107 fsl,num-rx-queues=<3>;
/netbsd-src/dist/pf/share/pf/
H A Dfaq-example316 # define the parameters for the child queues.
19 # www_ext - container queue for WWW server queues. limit to
40 # define the parameters for the child queues.
64 # define the parameters for the child queues.
H A Dfaq-example218 # define the parameters for the child queues.
37 # define the parameters for the child queues.
H A Dqueue46 # Departments under the engineering faculty are defined as child queues.
/netbsd-src/sys/dist/pf/net/
H A Dpf_ruleset.c150 TAILQ_INIT(&ruleset->rules[i].queues[0]); in pf_init_ruleset()
151 TAILQ_INIT(&ruleset->rules[i].queues[1]); in pf_init_ruleset()
152 ruleset->rules[i].active.ptr = &ruleset->rules[i].queues[0]; in pf_init_ruleset()
153 ruleset->rules[i].inactive.ptr = &ruleset->rules[i].queues[1]; in pf_init_ruleset()
/netbsd-src/sys/external/bsd/drm2/dist/drm/amd/amdkfd/
H A Dkfd_process_queue_manager.c41 list_for_each_entry(pqn, &pqm->queues, process_queue_list) { in get_queue_by_qid()
142 INIT_LIST_HEAD(&pqm->queues); in pqm_init()
157 list_for_each_entry_safe(pqn, next, &pqm->queues, process_queue_list) { in pqm_uninit()
326 list_add(&pqn->process_queue_list, &pqm->queues); in pqm_create_queue()
518 list_for_each_entry(pqn, &pqm->queues, process_queue_list) { in pqm_debugfs_mqds()
H A Dkfd_device_queue_manager.c823 list_add(&n->list, &dqm->queues); in register_process()
855 list_for_each_entry_safe(cur, next, &dqm->queues, list) { in unregister_process()
906 INIT_LIST_HEAD(&dqm->queues); in initialize_nocpsch()
1071 INIT_LIST_HEAD(&dqm->queues); in initialize_cpsch()
1332 retval = pm_send_runlist(&dqm->packets, &dqm->queues); in map_queues_cpsch()
1584 list_for_each_entry_safe(cur, next_dpn, &dqm->queues, list) { in process_termination_nocpsch()
1679 list_for_each_entry_safe(cur, next_dpn, &dqm->queues, list) { in process_termination_cpsch()
H A Dkfd_packet_manager.c125 struct list_head *queues, in pm_create_runlist_ib() argument
152 list_for_each_entry(cur, queues, list) { in pm_create_runlist_ib()
/netbsd-src/sys/dev/pci/igc/
H A Dif_igc.c400 /* Allocate TX/RX queues */ in igc_attach()
402 aprint_error_dev(sc->sc_dev, "unable to allocate queues\n"); in igc_attach()
646 sc->queues = in igc_allocate_queues()
657 /* Set up the TX queues. */ in igc_allocate_queues()
665 txr->txr_igcq = &sc->queues[iq]; in igc_allocate_queues()
682 /* Set up the RX queues. */ in igc_allocate_queues()
690 rxr->rxr_igcq = &sc->queues[iq]; in igc_allocate_queues()
714 struct igc_queue *q = &sc->queues[iq]; in igc_allocate_queues()
733 kmem_free(sc->queues, sc->sc_nqueues * sizeof(struct igc_queue)); in igc_allocate_queues()
734 sc->queues in igc_allocate_queues()
[all...]
/netbsd-src/sys/dev/marvell/
H A Dif_mvxpe.c1435 uint32_t ic, queues, datum = 0; in mvxpe_rxtxth_intr() local
1470 queues = MVXPE_PRXTXTI_GET_RBICTAPQ(ic); in mvxpe_rxtxth_intr()
1471 if (queues) { in mvxpe_rxtxth_intr()
1473 mvxpe_rx(sc, queues); in mvxpe_rxtxth_intr()
1475 queues = MVXPE_PRXTXTI_GET_TBTCQ(ic); in mvxpe_rxtxth_intr()
1476 if (queues) { in mvxpe_rxtxth_intr()
1478 mvxpe_tx_complete(sc, queues); in mvxpe_rxtxth_intr()
1480 queues = MVXPE_PRXTXTI_GET_RDTAQ(ic); in mvxpe_rxtxth_intr()
1481 if (queues) { in mvxpe_rxtxth_intr()
1483 mvxpe_rx_refill(sc, queues); in mvxpe_rxtxth_intr()
[all …]
H A Dif_mvxpevar.h88 #define MVXPE_IS_QUEUE_BUSY(queues, q) \ argument
89 ((((queues) >> (q)) & 0x1))
/netbsd-src/sys/external/gpl2/dts/dist/arch/arm/boot/dts/
H A Dartpec6.dtsi319 mtl_rx_setup: rx-queues-config {
320 snps,rx-queues-to-use = <1>;
324 mtl_tx_setup: tx-queues-config {
325 snps,tx-queues-to-use = <2>;
H A Dimx7d.dtsi160 fsl,num-tx-queues = <3>;
161 fsl,num-rx-queues = <3>;
H A Dkeystone-k2hk-netcp.dtsi24 managed-queues = <0 0x2000>;
36 managed-queues = <0x2000 0x2000>;
/netbsd-src/dist/pf/sbin/pfctl/
H A Dparse.y171 } *queues = NULL; variable
203 struct node_qassign queues; member
2009 if ($9.queues.qname != NULL) {
2010 if (strlcpy(r.qname, $9.queues.qname,
2016 free($9.queues.qname);
2018 if ($9.queues.pqname != NULL) {
2019 if (strlcpy(r.pqname, $9.queues.pqname,
2025 free($9.queues.pqname);
2126 if (filter_opts.queues.qname) {
2130 filter_opts.queues = $1;
[all …]
/netbsd-src/sys/arch/amd64/conf/
H A DNOCOMPAT5 no options SYSVMSG # System V-like message queues
/netbsd-src/sys/arch/cesfic/conf/
H A DGENERIC50 #options SYSVMSG # System V-style message queues
82 #options ALTQ # Manipulate network interfaces' output queues
/netbsd-src/external/gpl2/lvm2/dist/doc/
H A Dpvmove_outline.txt38 it hasn't it queues the initial copy and defers the current io until

12345678910>>...14