Source-Changes-HG archive
[Date Prev][Date Next][Thread Prev][Thread Next][Date Index][Thread Index][Old Index]
[src/perseant-stdc-iso10646]: src/sys/dev/usb 2992172
details: https://anonhg.NetBSD.org/src/rev/ed1d931fd7cf
branches: perseant-stdc-iso10646
changeset: 850629:ed1d931fd7cf
user: riastradh <riastradh%NetBSD.org@localhost>
date: Sat Jul 15 05:46:10 2017 +0000
description:
2992172
diffstat:
sys/dev/usb/ualea.c | 309 ++++++++++++++++++++++++++++++++++++++++++++++++++++
1 files changed, 309 insertions(+), 0 deletions(-)
diffs (truncated from 313 to 300 lines):
diff -r d004c5c78877 -r ed1d931fd7cf sys/dev/usb/ualea.c
--- /dev/null Thu Jan 01 00:00:00 1970 +0000
+++ b/sys/dev/usb/ualea.c Sat Jul 15 05:46:10 2017 +0000
@@ -0,0 +1,309 @@
+/* $NetBSD: ualea.c,v 1.7.2.2 2017/07/15 05:46:10 riastradh Exp $ */
+
+/*-
+ * Copyright (c) 2017 The NetBSD Foundation, Inc.
+ * All rights reserved.
+ *
+ * This code is derived from software contributed to The NetBSD Foundation
+ * by Taylor R. Campbell.
+ *
+ * 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 NETBSD FOUNDATION, INC. 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 FOUNDATION 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 <sys/cdefs.h>
+__KERNEL_RCSID(0, "$NetBSD: ualea.c,v 1.7.2.2 2017/07/15 05:46:10 riastradh Exp $");
+
+#include <sys/types.h>
+#include <sys/atomic.h>
+#include <sys/device_if.h>
+#include <sys/kmem.h>
+#include <sys/module.h>
+#include <sys/rndpool.h>
+#include <sys/rndsource.h>
+
+#include <dev/usb/usb.h>
+#include <dev/usb/usbdevs.h>
+#include <dev/usb/usbdi.h>
+#include <dev/usb/usbdi_util.h>
+
+struct ualea_softc {
+ device_t sc_dev;
+ kmutex_t sc_lock;
+ krndsource_t sc_rnd;
+ uint16_t sc_maxpktsize;
+ struct usbd_pipe *sc_pipe;
+ /*
+ * Lock covers:
+ * - sc_needed
+ * - sc_attached
+ * - sc_inflight
+ * - usbd_transfer(sc_xfer)
+ */
+ struct usbd_xfer *sc_xfer;
+ size_t sc_needed;
+ bool sc_attached:1;
+ bool sc_inflight:1;
+};
+
+static int ualea_match(device_t, cfdata_t, void *);
+static void ualea_attach(device_t, device_t, void *);
+static int ualea_detach(device_t, int);
+static void ualea_get(size_t, void *);
+static void ualea_xfer_done(struct usbd_xfer *, void *, usbd_status);
+
+CFATTACH_DECL_NEW(ualea, sizeof(struct ualea_softc),
+ ualea_match, ualea_attach, ualea_detach, NULL);
+
+static const struct usb_devno ualea_devs[] = {
+ { USB_VENDOR_ARANEUS, USB_PRODUCT_ARANEUS_ALEA },
+};
+
+static int
+ualea_match(device_t parent, cfdata_t match, void *aux)
+{
+ struct usbif_attach_arg *uiaa = aux;
+
+ if (usb_lookup(ualea_devs, uiaa->uiaa_vendor, uiaa->uiaa_product))
+ return UMATCH_VENDOR_PRODUCT;
+
+ return UMATCH_NONE;
+}
+
+static void
+ualea_attach(device_t parent, device_t self, void *aux)
+{
+ struct usbif_attach_arg *uiaa = aux;
+ struct ualea_softc *sc = device_private(self);
+ const usb_endpoint_descriptor_t *ed;
+ char *devinfop;
+ usbd_status status;
+
+ /* Print the device info. */
+ aprint_naive("\n");
+ aprint_normal("\n");
+ devinfop = usbd_devinfo_alloc(uiaa->uiaa_device, 0);
+ aprint_normal_dev(self, "%s\n", devinfop);
+ usbd_devinfo_free(devinfop);
+
+ /* Initialize the softc. */
+ sc->sc_dev = self;
+ mutex_init(&sc->sc_lock, MUTEX_DEFAULT, IPL_SOFTUSB);
+ rndsource_setcb(&sc->sc_rnd, ualea_get, sc);
+ rnd_attach_source(&sc->sc_rnd, device_xname(self), RND_TYPE_RNG,
+ RND_FLAG_COLLECT_VALUE|RND_FLAG_HASCB);
+
+ /* Get endpoint descriptor 0. Make sure it's bulk-in. */
+ ed = usbd_interface2endpoint_descriptor(uiaa->uiaa_iface, 0);
+ if (ed == NULL) {
+ aprint_error_dev(sc->sc_dev, "failed to read endpoint 0\n");
+ return;
+ }
+ if (UE_GET_DIR(ed->bEndpointAddress) != UE_DIR_IN ||
+ UE_GET_XFERTYPE(ed->bmAttributes) != UE_BULK) {
+ aprint_error_dev(sc->sc_dev, "invalid endpoint\n");
+ return;
+ }
+
+ /* Remember the maximum packet size. */
+ sc->sc_maxpktsize = UGETW(ed->wMaxPacketSize);
+
+ /* Open an exclusive MP-safe pipe for endpoint 0. */
+ status = usbd_open_pipe(uiaa->uiaa_iface, ed->bEndpointAddress,
+ USBD_EXCLUSIVE_USE|USBD_MPSAFE, &sc->sc_pipe);
+ if (status) {
+ aprint_error_dev(sc->sc_dev, "failed to open pipe: %d\n",
+ status);
+ return;
+ }
+
+ /* Create an xfer of maximum packet size, short OK, on the pipe. */
+ status = usbd_create_xfer(sc->sc_pipe, sc->sc_maxpktsize,
+ USBD_SHORT_XFER_OK, 0, &sc->sc_xfer);
+ if (status) {
+ aprint_error_dev(sc->sc_dev, "failed to create xfer: %d\n",
+ status);
+ return;
+ }
+
+ /* Setup the xfer to call ualea_xfer_done with sc. */
+ usbd_setup_xfer(sc->sc_xfer, sc, usbd_get_buffer(sc->sc_xfer),
+ sc->sc_maxpktsize, USBD_SHORT_XFER_OK, USBD_NO_TIMEOUT,
+ ualea_xfer_done);
+
+ /* Success! We are ready to run. */
+ mutex_enter(&sc->sc_lock);
+ sc->sc_attached = true;
+ mutex_exit(&sc->sc_lock);
+
+ /* Get some initial entropy now. */
+ ualea_get(RND_POOLBITS/NBBY, sc);
+}
+
+static int
+ualea_detach(device_t self, int flags)
+{
+ struct ualea_softc *sc = device_private(self);
+
+ /* Prevent new use of xfer. */
+ mutex_enter(&sc->sc_lock);
+ sc->sc_attached = false;
+ mutex_exit(&sc->sc_lock);
+
+ /* Cancel pending xfer. */
+ if (sc->sc_pipe)
+ (void)usbd_abort_pipe(sc->sc_pipe);
+ KASSERT(!sc->sc_inflight);
+
+ /* All users have drained. Tear it all down. */
+ if (sc->sc_xfer)
+ usbd_destroy_xfer(sc->sc_xfer);
+ if (sc->sc_pipe)
+ (void)usbd_close_pipe(sc->sc_pipe);
+ rnd_detach_source(&sc->sc_rnd);
+ mutex_destroy(&sc->sc_lock);
+
+ return 0;
+}
+
+static void
+ualea_xfer(struct ualea_softc *sc)
+{
+ usbd_status status;
+
+ KASSERT(mutex_owned(&sc->sc_lock));
+ KASSERT(sc->sc_attached);
+ KASSERT(!sc->sc_inflight);
+
+ /* Do nothing if we need nothing. */
+ if (sc->sc_needed == 0)
+ return;
+
+ /* Issue xfer or complain if we can't. */
+ /*
+ * XXX Does USBD_NORMAL_COMPLETION (= 0) make sense here? The
+ * xfer can't complete synchronously because of the lock.
+ */
+ status = usbd_transfer(sc->sc_xfer);
+ if (status && status != USBD_IN_PROGRESS) {
+ aprint_error_dev(sc->sc_dev, "failed to issue xfer: %d\n",
+ status);
+ /* We failed -- let someone else have a go. */
+ return;
+ }
+
+ /* Mark xfer in-flight. */
+ sc->sc_inflight = true;
+}
+
+static void
+ualea_get(size_t nbytes, void *cookie)
+{
+ struct ualea_softc *sc = cookie;
+
+ mutex_enter(&sc->sc_lock);
+
+ /* Do nothing if not yet attached. */
+ if (!sc->sc_attached)
+ goto out;
+
+ /* Update how many bytes we need. */
+ sc->sc_needed = MAX(sc->sc_needed, nbytes);
+
+ /* Do nothing if xfer is already in flight. */
+ if (sc->sc_inflight)
+ goto out;
+
+ /* Issue xfer. */
+ ualea_xfer(sc);
+
+out: mutex_exit(&sc->sc_lock);
+}
+
+static void
+ualea_xfer_done(struct usbd_xfer *xfer, void *cookie, usbd_status status)
+{
+ struct ualea_softc *sc = cookie;
+ void *pkt;
+ uint32_t pktsize;
+
+ /* Check the transfer status. */
+ if (status) {
+ aprint_error_dev(sc->sc_dev, "xfer failed: %d\n", status);
+ goto out;
+ }
+
+ /* Get and sanity-check the transferred size. */
+ usbd_get_xfer_status(xfer, NULL, &pkt, &pktsize, NULL);
+ if (pktsize > sc->sc_maxpktsize) {
+ aprint_error_dev(sc->sc_dev,
+ "bogus packet size: %"PRIu32" > %"PRIu16" (max), ignoring"
+ "\n",
+ pktsize, sc->sc_maxpktsize);
+ goto out;
+ }
+
+ /* Add the data to the pool. */
+ rnd_add_data(&sc->sc_rnd, pkt, pktsize, NBBY*pktsize);
+
+out:
+ mutex_enter(&sc->sc_lock);
+
+ /* Debit what we contributed from what we need. */
+ sc->sc_needed -= MIN(sc->sc_needed, pktsize);
+
+ /* Mark xfer done. */
+ sc->sc_inflight = false;
+
+ /* Reissue xfer if we still need more. */
+ ualea_xfer(sc);
+
+ mutex_exit(&sc->sc_lock);
+}
+
+MODULE(MODULE_CLASS_DRIVER, ualea, NULL);
+
+#ifdef _MODULE
+#include "ioconf.c"
+#endif
+
+static int
+ualea_modcmd(modcmd_t cmd, void *aux)
+{
+ int error = 0;
+
+ switch (cmd) {
+ case MODULE_CMD_INIT:
+#ifdef _MODULE
+ error = config_init_component(cfdriver_ioconf_ualea,
Home |
Main Index |
Thread Index |
Old Index