diff options
Diffstat (limited to 'sys/dev/dpaa/qman_portals.c')
| -rw-r--r-- | sys/dev/dpaa/qman_portals.c | 191 |
1 files changed, 191 insertions, 0 deletions
diff --git a/sys/dev/dpaa/qman_portals.c b/sys/dev/dpaa/qman_portals.c new file mode 100644 index 0000000..8f39307 --- /dev/null +++ b/sys/dev/dpaa/qman_portals.c @@ -0,0 +1,191 @@ +/*- + * Copyright (c) 2012 Semihalf. + * All rights reserved. + * + * Redistribution and use in source and binary forms, with or without + * modification, are permitted provided that the following conditions + * are met: + * 1. Redistributions of source code must retain the above copyright + * notice, this list of conditions and the following disclaimer. + * 2. Redistributions in binary form must reproduce the above copyright + * notice, this list of conditions and the following disclaimer in the + * documentation and/or other materials provided with the distribution. + * + * THIS SOFTWARE IS PROVIDED BY THE AUTHOR AND CONTRIBUTORS ``AS IS'' AND + * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE + * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE + * ARE DISCLAIMED. IN NO EVENT SHALL THE AUTHOR OR CONTRIBUTORS BE LIABLE + * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL + * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS + * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) + * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT + * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY + * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF + * SUCH DAMAGE. + */ + +#include "opt_platform.h" +#include <sys/cdefs.h> +__FBSDID("$FreeBSD$"); + +#include <sys/param.h> +#include <sys/systm.h> +#include <sys/kernel.h> +#include <sys/bus.h> +#include <sys/lock.h> +#include <sys/module.h> +#include <sys/mutex.h> +#include <sys/proc.h> +#include <sys/pcpu.h> +#include <sys/sched.h> + +#include <machine/bus.h> +#include <machine/tlb.h> + +#include <dev/ofw/ofw_bus.h> +#include <dev/ofw/ofw_bus_subr.h> + +#include <powerpc/mpc85xx/mpc85xx.h> + +#include "qman.h" +#include "portals.h" + +extern e_RxStoreResponse qman_received_frame_callback(t_Handle, t_Handle, + t_Handle, uint32_t, t_DpaaFD *); +extern e_RxStoreResponse qman_rejected_frame_callback(t_Handle, t_Handle, + t_Handle, uint32_t, t_DpaaFD *, t_QmRejectedFrameInfo *); + +t_Handle qman_portal_setup(struct qman_softc *); + +struct dpaa_portals_softc *qp_sc; + +int +qman_portals_attach(device_t dev) +{ + struct dpaa_portals_softc *sc; + + sc = qp_sc = device_get_softc(dev); + + /* Map bman portal to physical address space */ + if (law_enable(OCP85XX_TGTIF_QMAN, sc->sc_dp_pa, sc->sc_dp_size)) { + qman_portals_detach(dev); + return (ENXIO); + } + /* Set portal properties for XX_VirtToPhys() */ + XX_PortalSetInfo(dev); + + return (bus_generic_attach(dev)); +} + +int +qman_portals_detach(device_t dev) +{ + struct dpaa_portals_softc *sc; + int i; + + qp_sc = NULL; + sc = device_get_softc(dev); + + for (i = 0; i < ARRAY_SIZE(sc->sc_dp); i++) { + if (sc->sc_dp[i].dp_ph != NULL) { + thread_lock(curthread); + sched_bind(curthread, i); + thread_unlock(curthread); + + QM_PORTAL_Free(sc->sc_dp[i].dp_ph); + + thread_lock(curthread); + sched_unbind(curthread); + thread_unlock(curthread); + } + + if (sc->sc_dp[i].dp_ires != NULL) { + XX_DeallocIntr((int)sc->sc_dp[i].dp_ires); + bus_release_resource(dev, SYS_RES_IRQ, + sc->sc_dp[i].dp_irid, sc->sc_dp[i].dp_ires); + } + } + for (i = 0; i < ARRAY_SIZE(sc->sc_rres); i++) { + if (sc->sc_rres[i] != NULL) + bus_release_resource(dev, SYS_RES_MEMORY, + sc->sc_rrid[i], + sc->sc_rres[i]); + } + + return (0); +} + +t_Handle +qman_portal_setup(struct qman_softc *qsc) +{ + struct dpaa_portals_softc *sc; + t_QmPortalParam qpp; + unsigned int cpu, p; + t_Handle portal; + + /* Return NULL if we're not ready or while detach */ + if (qp_sc == NULL) + return (NULL); + + sc = qp_sc; + + sched_pin(); + portal = NULL; + cpu = PCPU_GET(cpuid); + + /* Check if portal is ready */ + while (atomic_cmpset_acq_32((uint32_t *)&sc->sc_dp[cpu].dp_ph, + 0, -1) == 0) { + p = atomic_load_acq_32((uint32_t *)&sc->sc_dp[cpu].dp_ph); + + /* Return if portal is already initialized */ + if (p != 0 && p != -1) { + sched_unpin(); + return ((t_Handle)p); + } + + /* Not inititialized and "owned" by another thread */ + thread_lock(curthread); + mi_switch(SW_VOL, NULL); + thread_unlock(curthread); + } + + /* Map portal registers */ + dpaa_portal_map_registers(sc); + + /* Configure and initialize portal */ + qpp.ceBaseAddress = rman_get_bushandle(sc->sc_rres[0]); + qpp.ciBaseAddress = rman_get_bushandle(sc->sc_rres[1]); + qpp.h_Qm = qsc->sc_qh; + qpp.swPortalId = cpu; + qpp.irq = (int)sc->sc_dp[cpu].dp_ires; + qpp.fdLiodnOffset = 0; + qpp.f_DfltFrame = qman_received_frame_callback; + qpp.f_RejectedFrame = qman_rejected_frame_callback; + qpp.h_App = qsc; + + portal = QM_PORTAL_Config(&qpp); + if (portal == NULL) + goto err; + + if (QM_PORTAL_Init(portal) != E_OK) + goto err; + + if (QM_PORTAL_AddPoolChannel(portal, QMAN_COMMON_POOL_CHANNEL) != E_OK) + goto err; + + atomic_store_rel_32((uint32_t *)&sc->sc_dp[cpu].dp_ph, + (uint32_t)portal); + sched_unpin(); + + return (portal); + +err: + if (portal != NULL) + QM_PORTAL_Free(portal); + + atomic_store_rel_32((uint32_t *)&sc->sc_dp[cpu].dp_ph, 0); + sched_unpin(); + + return (NULL); +} |
