| Index: third_party/libusb/libusb/os/linux_usbfs.c
|
| diff --git a/third_party/libusb/libusb/os/linux_usbfs.c b/third_party/libusb/libusb/os/linux_usbfs.c
|
| new file mode 100644
|
| index 0000000000000000000000000000000000000000..2b81189dc1f5453fbbb06f916aa0013a2abfcc05
|
| --- /dev/null
|
| +++ b/third_party/libusb/libusb/os/linux_usbfs.c
|
| @@ -0,0 +1,2313 @@
|
| +/*
|
| + * Linux usbfs backend for libusb
|
| + * Copyright (C) 2007-2009 Daniel Drake <dsd@gentoo.org>
|
| + * Copyright (c) 2001 Johannes Erdfelt <johannes@erdfelt.com>
|
| + *
|
| + * This library is free software; you can redistribute it and/or
|
| + * modify it under the terms of the GNU Lesser General Public
|
| + * License as published by the Free Software Foundation; either
|
| + * version 2.1 of the License, or (at your option) any later version.
|
| + *
|
| + * This library is distributed in the hope that it will be useful,
|
| + * but WITHOUT ANY WARRANTY; without even the implied warranty of
|
| + * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
|
| + * Lesser General Public License for more details.
|
| + *
|
| + * You should have received a copy of the GNU Lesser General Public
|
| + * License along with this library; if not, write to the Free Software
|
| + * Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA
|
| + */
|
| +
|
| +#include <config.h>
|
| +#include <ctype.h>
|
| +#include <dirent.h>
|
| +#include <errno.h>
|
| +#include <fcntl.h>
|
| +#include <poll.h>
|
| +#include <stdio.h>
|
| +#include <stdlib.h>
|
| +#include <string.h>
|
| +#include <sys/ioctl.h>
|
| +#include <sys/stat.h>
|
| +#include <sys/types.h>
|
| +#include <sys/utsname.h>
|
| +#include <unistd.h>
|
| +
|
| +#include "libusb.h"
|
| +#include "libusbi.h"
|
| +#include "linux_usbfs.h"
|
| +
|
| +/* sysfs vs usbfs:
|
| + * opening a usbfs node causes the device to be resumed, so we attempt to
|
| + * avoid this during enumeration.
|
| + *
|
| + * sysfs allows us to read the kernel's in-memory copies of device descriptors
|
| + * and so forth, avoiding the need to open the device:
|
| + * - The binary "descriptors" file was added in 2.6.23.
|
| + * - The "busnum" file was added in 2.6.22
|
| + * - The "devnum" file has been present since pre-2.6.18
|
| + * - the "bConfigurationValue" file has been present since pre-2.6.18
|
| + *
|
| + * If we have bConfigurationValue, busnum, and devnum, then we can determine
|
| + * the active configuration without having to open the usbfs node in RDWR mode.
|
| + * We assume this is the case if we see the busnum file (indicates 2.6.22+).
|
| + * The busnum file is important as that is the only way we can relate sysfs
|
| + * devices to usbfs nodes.
|
| + *
|
| + * If we also have descriptors, we can obtain the device descriptor and active
|
| + * configuration without touching usbfs at all.
|
| + *
|
| + * The descriptors file originally only contained the active configuration
|
| + * descriptor alongside the device descriptor, but all configurations are
|
| + * included as of Linux 2.6.26.
|
| + */
|
| +
|
| +/* endianness for multi-byte fields:
|
| + *
|
| + * Descriptors exposed by usbfs have the multi-byte fields in the device
|
| + * descriptor as host endian. Multi-byte fields in the other descriptors are
|
| + * bus-endian. The kernel documentation says otherwise, but it is wrong.
|
| + */
|
| +
|
| +static const char *usbfs_path = NULL;
|
| +
|
| +/* Linux 2.6.32 adds support for a bulk continuation URB flag. this basically
|
| + * allows us to mark URBs as being part of a specific logical transfer when
|
| + * we submit them to the kernel. then, on any error except a cancellation, all
|
| + * URBs within that transfer will be cancelled and no more URBs will be
|
| + * accepted for the transfer, meaning that no more data can creep in.
|
| + *
|
| + * The BULK_CONTINUATION flag must be set on all URBs within a bulk transfer
|
| + * (in either direction) except the first.
|
| + * For IN transfers, we must also set SHORT_NOT_OK on all URBs except the
|
| + * last; it means that the kernel should treat a short reply as an error.
|
| + * For OUT transfers, SHORT_NOT_OK must not be set. it isn't needed (OUT
|
| + * transfers can't be short unless there's already some sort of error), and
|
| + * setting this flag is disallowed (a kernel with USB debugging enabled will
|
| + * reject such URBs).
|
| + */
|
| +static int supports_flag_bulk_continuation = -1;
|
| +
|
| +/* clock ID for monotonic clock, as not all clock sources are available on all
|
| + * systems. appropriate choice made at initialization time. */
|
| +static clockid_t monotonic_clkid = -1;
|
| +
|
| +/* do we have a busnum to relate devices? this also implies that we can read
|
| + * the active configuration through bConfigurationValue */
|
| +static int sysfs_can_relate_devices = 0;
|
| +
|
| +/* do we have a descriptors file? */
|
| +static int sysfs_has_descriptors = 0;
|
| +
|
| +struct linux_device_priv {
|
| + char *sysfs_dir;
|
| + unsigned char *dev_descriptor;
|
| + unsigned char *config_descriptor;
|
| +};
|
| +
|
| +struct linux_device_handle_priv {
|
| + int fd;
|
| +};
|
| +
|
| +enum reap_action {
|
| + NORMAL = 0,
|
| + /* submission failed after the first URB, so await cancellation/completion
|
| + * of all the others */
|
| + SUBMIT_FAILED,
|
| +
|
| + /* cancelled by user or timeout */
|
| + CANCELLED,
|
| +
|
| + /* completed multi-URB transfer in non-final URB */
|
| + COMPLETED_EARLY,
|
| +
|
| + /* one or more urbs encountered a low-level error */
|
| + ERROR,
|
| +};
|
| +
|
| +struct linux_transfer_priv {
|
| + union {
|
| + struct usbfs_urb *urbs;
|
| + struct usbfs_urb **iso_urbs;
|
| + };
|
| +
|
| + enum reap_action reap_action;
|
| + int num_urbs;
|
| + unsigned int num_retired;
|
| + enum libusb_transfer_status reap_status;
|
| +
|
| + /* next iso packet in user-supplied transfer to be populated */
|
| + int iso_packet_offset;
|
| +};
|
| +
|
| +static void _get_usbfs_path(struct libusb_device *dev, char *path)
|
| +{
|
| + snprintf(path, PATH_MAX, "%s/%03d/%03d", usbfs_path, dev->bus_number,
|
| + dev->device_address);
|
| +}
|
| +
|
| +static struct linux_device_priv *_device_priv(struct libusb_device *dev)
|
| +{
|
| + return (struct linux_device_priv *) dev->os_priv;
|
| +}
|
| +
|
| +static struct linux_device_handle_priv *_device_handle_priv(
|
| + struct libusb_device_handle *handle)
|
| +{
|
| + return (struct linux_device_handle_priv *) handle->os_priv;
|
| +}
|
| +
|
| +static int check_usb_vfs(const char *dirname)
|
| +{
|
| + DIR *dir;
|
| + struct dirent *entry;
|
| + int found = 0;
|
| +
|
| + dir = opendir(dirname);
|
| + if (!dir)
|
| + return 0;
|
| +
|
| + while ((entry = readdir(dir)) != NULL) {
|
| + if (entry->d_name[0] == '.')
|
| + continue;
|
| +
|
| + /* We assume if we find any files that it must be the right place */
|
| + found = 1;
|
| + break;
|
| + }
|
| +
|
| + closedir(dir);
|
| + return found;
|
| +}
|
| +
|
| +static const char *find_usbfs_path(void)
|
| +{
|
| + const char *path = "/dev/bus/usb";
|
| + const char *ret = NULL;
|
| +
|
| + if (check_usb_vfs(path)) {
|
| + ret = path;
|
| + } else {
|
| + path = "/proc/bus/usb";
|
| + if (check_usb_vfs(path))
|
| + ret = path;
|
| + }
|
| +
|
| + usbi_dbg("found usbfs at %s", ret);
|
| + return ret;
|
| +}
|
| +
|
| +/* the monotonic clock is not usable on all systems (e.g. embedded ones often
|
| + * seem to lack it). fall back to REALTIME if we have to. */
|
| +static clockid_t find_monotonic_clock(void)
|
| +{
|
| + struct timespec ts;
|
| + int r;
|
| +
|
| +#ifdef CLOCK_MONOTONIC
|
| + /* Linux 2.6.28 adds CLOCK_MONOTONIC_RAW but we don't use it
|
| + * because it's not available through timerfd */
|
| + r = clock_gettime(CLOCK_MONOTONIC, &ts);
|
| + if (r == 0)
|
| + return CLOCK_MONOTONIC;
|
| + usbi_dbg("monotonic clock doesn't work, errno %d", errno);
|
| +#endif
|
| +
|
| + return CLOCK_REALTIME;
|
| +}
|
| +
|
| +/* bulk continuation URB flag available from Linux 2.6.32 */
|
| +static int check_flag_bulk_continuation(void)
|
| +{
|
| + struct utsname uts;
|
| + int atoms, major, minor, sublevel;
|
| +
|
| + if (uname(&uts) < 0)
|
| + return -1;
|
| + atoms = sscanf(uts.release, "%d.%d.%d", &major, &minor, &sublevel);
|
| + if (atoms < 1)
|
| + return -1;
|
| +
|
| + if (major > 2)
|
| + return 1;
|
| + if (major < 2)
|
| + return 0;
|
| +
|
| + if (atoms < 2)
|
| + return 0;
|
| +
|
| + /* major == 2 */
|
| + if (minor < 6)
|
| + return 0;
|
| + if (minor > 6) /* Does not exist, just here for correctness */
|
| + return 1;
|
| +
|
| + /* 2.6.x */
|
| + if (3 == atoms && sublevel >= 32)
|
| + return 1;
|
| +
|
| + return 0;
|
| +}
|
| +
|
| +/* Return 1 if filename exists inside dirname in sysfs.
|
| + SYSFS_DEVICE_PATH is assumed to be the beginning of the path. */
|
| +static int sysfs_has_file(const char *dirname, const char *filename)
|
| +{
|
| + struct stat statbuf;
|
| + char path[PATH_MAX];
|
| + int r;
|
| +
|
| + snprintf(path, PATH_MAX, "%s/%s/%s", SYSFS_DEVICE_PATH, dirname, filename);
|
| + r = stat(path, &statbuf);
|
| + if (r == 0 && S_ISREG(statbuf.st_mode))
|
| + return 1;
|
| +
|
| + return 0;
|
| +}
|
| +
|
| +static int op_init(struct libusb_context *ctx)
|
| +{
|
| + struct stat statbuf;
|
| + int r;
|
| +
|
| + usbfs_path = find_usbfs_path();
|
| + if (!usbfs_path) {
|
| + usbi_err(ctx, "could not find usbfs");
|
| + return LIBUSB_ERROR_OTHER;
|
| + }
|
| +
|
| + if (monotonic_clkid == -1)
|
| + monotonic_clkid = find_monotonic_clock();
|
| +
|
| + if (supports_flag_bulk_continuation == -1) {
|
| + supports_flag_bulk_continuation = check_flag_bulk_continuation();
|
| + if (supports_flag_bulk_continuation == -1) {
|
| + usbi_err(ctx, "error checking for bulk continuation support");
|
| + return LIBUSB_ERROR_OTHER;
|
| + }
|
| + }
|
| +
|
| + if (supports_flag_bulk_continuation)
|
| + usbi_dbg("bulk continuation flag supported");
|
| +
|
| + r = stat(SYSFS_DEVICE_PATH, &statbuf);
|
| + if (r == 0 && S_ISDIR(statbuf.st_mode)) {
|
| + DIR *devices = opendir(SYSFS_DEVICE_PATH);
|
| + struct dirent *entry;
|
| +
|
| + usbi_dbg("found usb devices in sysfs");
|
| +
|
| + if (!devices) {
|
| + usbi_err(ctx, "opendir devices failed errno=%d", errno);
|
| + return LIBUSB_ERROR_IO;
|
| + }
|
| +
|
| + /* Make sure sysfs supports all the required files. If it
|
| + * does not, then usbfs will be used instead. Determine
|
| + * this by looping through the directories in
|
| + * SYSFS_DEVICE_PATH. With the assumption that there will
|
| + * always be subdirectories of the name usbN (usb1, usb2,
|
| + * etc) representing the root hubs, check the usbN
|
| + * subdirectories to see if they have all the needed files.
|
| + * This algorithm uses the usbN subdirectories (root hubs)
|
| + * because a device disconnection will cause a race
|
| + * condition regarding which files are available, sometimes
|
| + * causing an incorrect result. The root hubs are used
|
| + * because it is assumed that they will always be present.
|
| + * See the "sysfs vs usbfs" comment at the top of this file
|
| + * for more details. */
|
| + while ((entry = readdir(devices))) {
|
| + int has_busnum=0, has_devnum=0, has_descriptors=0;
|
| + int has_configuration_value=0;
|
| +
|
| + /* Only check the usbN directories. */
|
| + if (strncmp(entry->d_name, "usb", 3) != 0)
|
| + continue;
|
| +
|
| + /* Check for the files libusb needs from sysfs. */
|
| + has_busnum = sysfs_has_file(entry->d_name, "busnum");
|
| + has_devnum = sysfs_has_file(entry->d_name, "devnum");
|
| + has_descriptors = sysfs_has_file(entry->d_name, "descriptors");
|
| + has_configuration_value = sysfs_has_file(entry->d_name, "bConfigurationValue");
|
| +
|
| + if (has_busnum && has_devnum && has_configuration_value)
|
| + sysfs_can_relate_devices = 1;
|
| + if (has_descriptors)
|
| + sysfs_has_descriptors = 1;
|
| +
|
| + /* Only need to check until we've found ONE device which
|
| + has all the attributes. */
|
| + if (sysfs_has_descriptors && sysfs_can_relate_devices)
|
| + break;
|
| + }
|
| + closedir(devices);
|
| +
|
| + /* Only use sysfs descriptors if the rest of
|
| + sysfs will work for libusb. */
|
| + if (!sysfs_can_relate_devices)
|
| + sysfs_has_descriptors = 0;
|
| + } else {
|
| + usbi_dbg("sysfs usb info not available");
|
| + sysfs_has_descriptors = 0;
|
| + sysfs_can_relate_devices = 0;
|
| + }
|
| +
|
| + return 0;
|
| +}
|
| +
|
| +static int usbfs_get_device_descriptor(struct libusb_device *dev,
|
| + unsigned char *buffer)
|
| +{
|
| + struct linux_device_priv *priv = _device_priv(dev);
|
| +
|
| + /* return cached copy */
|
| + memcpy(buffer, priv->dev_descriptor, DEVICE_DESC_LENGTH);
|
| + return 0;
|
| +}
|
| +
|
| +static int _open_sysfs_attr(struct libusb_device *dev, const char *attr)
|
| +{
|
| + struct linux_device_priv *priv = _device_priv(dev);
|
| + char filename[PATH_MAX];
|
| + int fd;
|
| +
|
| + snprintf(filename, PATH_MAX, "%s/%s/%s",
|
| + SYSFS_DEVICE_PATH, priv->sysfs_dir, attr);
|
| + fd = open(filename, O_RDONLY);
|
| + if (fd < 0) {
|
| + usbi_err(DEVICE_CTX(dev),
|
| + "open %s failed ret=%d errno=%d", filename, fd, errno);
|
| + return LIBUSB_ERROR_IO;
|
| + }
|
| +
|
| + return fd;
|
| +}
|
| +
|
| +/* Note only suitable for attributes which always read >= 0, < 0 is error */
|
| +static int __read_sysfs_attr(struct libusb_context *ctx,
|
| + const char *devname, const char *attr)
|
| +{
|
| + char filename[PATH_MAX];
|
| + FILE *f;
|
| + int r, value;
|
| +
|
| + snprintf(filename, PATH_MAX, "%s/%s/%s", SYSFS_DEVICE_PATH,
|
| + devname, attr);
|
| + f = fopen(filename, "r");
|
| + if (f == NULL) {
|
| + if (errno == ENOENT) {
|
| + /* File doesn't exist. Assume the device has been
|
| + disconnected (see trac ticket #70). */
|
| + return LIBUSB_ERROR_NO_DEVICE;
|
| + }
|
| + usbi_err(ctx, "open %s failed errno=%d", filename, errno);
|
| + return LIBUSB_ERROR_IO;
|
| + }
|
| +
|
| + r = fscanf(f, "%d", &value);
|
| + fclose(f);
|
| + if (r != 1) {
|
| + usbi_err(ctx, "fscanf %s returned %d, errno=%d", attr, r, errno);
|
| + return LIBUSB_ERROR_NO_DEVICE; /* For unplug race (trac #70) */
|
| + }
|
| + if (value < 0) {
|
| + usbi_err(ctx, "%s contains a negative value", filename);
|
| + return LIBUSB_ERROR_IO;
|
| + }
|
| +
|
| + return value;
|
| +}
|
| +
|
| +static int sysfs_get_device_descriptor(struct libusb_device *dev,
|
| + unsigned char *buffer)
|
| +{
|
| + int fd;
|
| + ssize_t r;
|
| +
|
| + /* sysfs provides access to an in-memory copy of the device descriptor,
|
| + * so we use that rather than keeping our own copy */
|
| +
|
| + fd = _open_sysfs_attr(dev, "descriptors");
|
| + if (fd < 0)
|
| + return fd;
|
| +
|
| + r = read(fd, buffer, DEVICE_DESC_LENGTH);;
|
| + close(fd);
|
| + if (r < 0) {
|
| + usbi_err(DEVICE_CTX(dev), "read failed, ret=%d errno=%d", fd, errno);
|
| + return LIBUSB_ERROR_IO;
|
| + } else if (r < DEVICE_DESC_LENGTH) {
|
| + usbi_err(DEVICE_CTX(dev), "short read %d/%d", r, DEVICE_DESC_LENGTH);
|
| + return LIBUSB_ERROR_IO;
|
| + }
|
| +
|
| + return 0;
|
| +}
|
| +
|
| +static int op_get_device_descriptor(struct libusb_device *dev,
|
| + unsigned char *buffer, int *host_endian)
|
| +{
|
| + if (sysfs_has_descriptors) {
|
| + return sysfs_get_device_descriptor(dev, buffer);
|
| + } else {
|
| + *host_endian = 1;
|
| + return usbfs_get_device_descriptor(dev, buffer);
|
| + }
|
| +}
|
| +
|
| +static int usbfs_get_active_config_descriptor(struct libusb_device *dev,
|
| + unsigned char *buffer, size_t len)
|
| +{
|
| + struct linux_device_priv *priv = _device_priv(dev);
|
| + if (!priv->config_descriptor)
|
| + return LIBUSB_ERROR_NOT_FOUND; /* device is unconfigured */
|
| +
|
| + /* retrieve cached copy */
|
| + memcpy(buffer, priv->config_descriptor, len);
|
| + return 0;
|
| +}
|
| +
|
| +/* read the bConfigurationValue for a device */
|
| +static int sysfs_get_active_config(struct libusb_device *dev, int *config)
|
| +{
|
| + char *endptr;
|
| + char tmp[4] = {0, 0, 0, 0};
|
| + long num;
|
| + int fd;
|
| + ssize_t r;
|
| +
|
| + fd = _open_sysfs_attr(dev, "bConfigurationValue");
|
| + if (fd < 0)
|
| + return fd;
|
| +
|
| + r = read(fd, tmp, sizeof(tmp));
|
| + close(fd);
|
| + if (r < 0) {
|
| + usbi_err(DEVICE_CTX(dev),
|
| + "read bConfigurationValue failed ret=%d errno=%d", r, errno);
|
| + return LIBUSB_ERROR_IO;
|
| + } else if (r == 0) {
|
| + usbi_err(DEVICE_CTX(dev), "device unconfigured");
|
| + *config = -1;
|
| + return 0;
|
| + }
|
| +
|
| + if (tmp[sizeof(tmp) - 1] != 0) {
|
| + usbi_err(DEVICE_CTX(dev), "not null-terminated?");
|
| + return LIBUSB_ERROR_IO;
|
| + } else if (tmp[0] == 0) {
|
| + usbi_err(DEVICE_CTX(dev), "no configuration value?");
|
| + return LIBUSB_ERROR_IO;
|
| + }
|
| +
|
| + num = strtol(tmp, &endptr, 10);
|
| + if (endptr == tmp) {
|
| + usbi_err(DEVICE_CTX(dev), "error converting '%s' to integer", tmp);
|
| + return LIBUSB_ERROR_IO;
|
| + }
|
| +
|
| + *config = (int) num;
|
| + return 0;
|
| +}
|
| +
|
| +/* takes a usbfs/descriptors fd seeked to the start of a configuration, and
|
| + * seeks to the next one. */
|
| +static int seek_to_next_config(struct libusb_context *ctx, int fd,
|
| + int host_endian)
|
| +{
|
| + struct libusb_config_descriptor config;
|
| + unsigned char tmp[6];
|
| + off_t off;
|
| + ssize_t r;
|
| +
|
| + /* read first 6 bytes of descriptor */
|
| + r = read(fd, tmp, sizeof(tmp));
|
| + if (r < 0) {
|
| + usbi_err(ctx, "read failed ret=%d errno=%d", r, errno);
|
| + return LIBUSB_ERROR_IO;
|
| + } else if (r < sizeof(tmp)) {
|
| + usbi_err(ctx, "short descriptor read %d/%d", r, sizeof(tmp));
|
| + return LIBUSB_ERROR_IO;
|
| + }
|
| +
|
| + /* seek forward to end of config */
|
| + usbi_parse_descriptor(tmp, "bbwbb", &config, host_endian);
|
| + off = lseek(fd, config.wTotalLength - sizeof(tmp), SEEK_CUR);
|
| + if (off < 0) {
|
| + usbi_err(ctx, "seek failed ret=%d errno=%d", off, errno);
|
| + return LIBUSB_ERROR_IO;
|
| + }
|
| +
|
| + return 0;
|
| +}
|
| +
|
| +static int sysfs_get_active_config_descriptor(struct libusb_device *dev,
|
| + unsigned char *buffer, size_t len)
|
| +{
|
| + int fd;
|
| + ssize_t r;
|
| + off_t off;
|
| + int to_copy;
|
| + int config;
|
| + unsigned char tmp[6];
|
| +
|
| + r = sysfs_get_active_config(dev, &config);
|
| + if (r < 0)
|
| + return r;
|
| + if (config == -1)
|
| + return LIBUSB_ERROR_NOT_FOUND;
|
| +
|
| + usbi_dbg("active configuration %d", config);
|
| +
|
| + /* sysfs provides access to an in-memory copy of the device descriptor,
|
| + * so we use that rather than keeping our own copy */
|
| +
|
| + fd = _open_sysfs_attr(dev, "descriptors");
|
| + if (fd < 0)
|
| + return fd;
|
| +
|
| + /* device might have been unconfigured since we read bConfigurationValue,
|
| + * so first check that there is any config descriptor data at all... */
|
| + off = lseek(fd, 0, SEEK_END);
|
| + if (off < 1) {
|
| + usbi_err(DEVICE_CTX(dev), "end seek failed, ret=%d errno=%d",
|
| + off, errno);
|
| + close(fd);
|
| + return LIBUSB_ERROR_IO;
|
| + } else if (off == DEVICE_DESC_LENGTH) {
|
| + close(fd);
|
| + return LIBUSB_ERROR_NOT_FOUND;
|
| + }
|
| +
|
| + off = lseek(fd, DEVICE_DESC_LENGTH, SEEK_SET);
|
| + if (off < 0) {
|
| + usbi_err(DEVICE_CTX(dev), "seek failed, ret=%d errno=%d", off, errno);
|
| + close(fd);
|
| + return LIBUSB_ERROR_IO;
|
| + }
|
| +
|
| + /* unbounded loop: we expect the descriptor to be present under all
|
| + * circumstances */
|
| + while (1) {
|
| + r = read(fd, tmp, sizeof(tmp));
|
| + if (r < 0) {
|
| + usbi_err(DEVICE_CTX(dev), "read failed, ret=%d errno=%d",
|
| + fd, errno);
|
| + return LIBUSB_ERROR_IO;
|
| + } else if (r < sizeof(tmp)) {
|
| + usbi_err(DEVICE_CTX(dev), "short read %d/%d", r, sizeof(tmp));
|
| + return LIBUSB_ERROR_IO;
|
| + }
|
| +
|
| + /* check bConfigurationValue */
|
| + if (tmp[5] == config)
|
| + break;
|
| +
|
| + /* try the next descriptor */
|
| + off = lseek(fd, 0 - sizeof(tmp), SEEK_CUR);
|
| + if (off < 0)
|
| + return LIBUSB_ERROR_IO;
|
| +
|
| + r = seek_to_next_config(DEVICE_CTX(dev), fd, 0);
|
| + if (r < 0)
|
| + return r;
|
| + }
|
| +
|
| + to_copy = (len < sizeof(tmp)) ? len : sizeof(tmp);
|
| + memcpy(buffer, tmp, to_copy);
|
| + if (len > sizeof(tmp)) {
|
| + r = read(fd, buffer + sizeof(tmp), len - sizeof(tmp));
|
| + if (r < 0) {
|
| + usbi_err(DEVICE_CTX(dev), "read failed, ret=%d errno=%d",
|
| + fd, errno);
|
| + r = LIBUSB_ERROR_IO;
|
| + } else if (r == 0) {
|
| + usbi_dbg("device is unconfigured");
|
| + r = LIBUSB_ERROR_NOT_FOUND;
|
| + } else if (r < len - sizeof(tmp)) {
|
| + usbi_err(DEVICE_CTX(dev), "short read %d/%d", r, len);
|
| + r = LIBUSB_ERROR_IO;
|
| + }
|
| + } else {
|
| + r = 0;
|
| + }
|
| +
|
| + close(fd);
|
| + return r;
|
| +}
|
| +
|
| +static int op_get_active_config_descriptor(struct libusb_device *dev,
|
| + unsigned char *buffer, size_t len, int *host_endian)
|
| +{
|
| + if (sysfs_has_descriptors) {
|
| + return sysfs_get_active_config_descriptor(dev, buffer, len);
|
| + } else {
|
| + return usbfs_get_active_config_descriptor(dev, buffer, len);
|
| + }
|
| +}
|
| +
|
| +/* takes a usbfs fd, attempts to find the requested config and copy a certain
|
| + * amount of it into an output buffer. */
|
| +static int get_config_descriptor(struct libusb_context *ctx, int fd,
|
| + uint8_t config_index, unsigned char *buffer, size_t len)
|
| +{
|
| + off_t off;
|
| + ssize_t r;
|
| +
|
| + off = lseek(fd, DEVICE_DESC_LENGTH, SEEK_SET);
|
| + if (off < 0) {
|
| + usbi_err(ctx, "seek failed ret=%d errno=%d", off, errno);
|
| + return LIBUSB_ERROR_IO;
|
| + }
|
| +
|
| + /* might need to skip some configuration descriptors to reach the
|
| + * requested configuration */
|
| + while (config_index > 0) {
|
| + r = seek_to_next_config(ctx, fd, 1);
|
| + if (r < 0)
|
| + return r;
|
| + config_index--;
|
| + }
|
| +
|
| + /* read the rest of the descriptor */
|
| + r = read(fd, buffer, len);
|
| + if (r < 0) {
|
| + usbi_err(ctx, "read failed ret=%d errno=%d", r, errno);
|
| + return LIBUSB_ERROR_IO;
|
| + } else if (r < len) {
|
| + usbi_err(ctx, "short output read %d/%d", r, len);
|
| + return LIBUSB_ERROR_IO;
|
| + }
|
| +
|
| + return 0;
|
| +}
|
| +
|
| +static int op_get_config_descriptor(struct libusb_device *dev,
|
| + uint8_t config_index, unsigned char *buffer, size_t len, int *host_endian)
|
| +{
|
| + char filename[PATH_MAX];
|
| + int fd;
|
| + int r;
|
| +
|
| + /* always read from usbfs: sysfs only has the active descriptor
|
| + * this will involve waking the device up, but oh well! */
|
| +
|
| + /* FIXME: the above is no longer true, new kernels have all descriptors
|
| + * in the descriptors file. but its kinda hard to detect if the kernel
|
| + * is sufficiently new. */
|
| +
|
| + _get_usbfs_path(dev, filename);
|
| + fd = open(filename, O_RDONLY);
|
| + if (fd < 0) {
|
| + usbi_err(DEVICE_CTX(dev),
|
| + "open '%s' failed, ret=%d errno=%d", filename, fd, errno);
|
| + return LIBUSB_ERROR_IO;
|
| + }
|
| +
|
| + r = get_config_descriptor(DEVICE_CTX(dev), fd, config_index, buffer, len);
|
| + close(fd);
|
| + return r;
|
| +}
|
| +
|
| +/* cache the active config descriptor in memory. a value of -1 means that
|
| + * we aren't sure which one is active, so just assume the first one.
|
| + * only for usbfs. */
|
| +static int cache_active_config(struct libusb_device *dev, int fd,
|
| + int active_config)
|
| +{
|
| + struct linux_device_priv *priv = _device_priv(dev);
|
| + struct libusb_config_descriptor config;
|
| + unsigned char tmp[8];
|
| + unsigned char *buf;
|
| + int idx;
|
| + int r;
|
| +
|
| + if (active_config == -1) {
|
| + idx = 0;
|
| + } else {
|
| + r = usbi_get_config_index_by_value(dev, active_config, &idx);
|
| + if (r < 0)
|
| + return r;
|
| + if (idx == -1)
|
| + return LIBUSB_ERROR_NOT_FOUND;
|
| + }
|
| +
|
| + r = get_config_descriptor(DEVICE_CTX(dev), fd, idx, tmp, sizeof(tmp));
|
| + if (r < 0) {
|
| + usbi_err(DEVICE_CTX(dev), "first read error %d", r);
|
| + return r;
|
| + }
|
| +
|
| + usbi_parse_descriptor(tmp, "bbw", &config, 0);
|
| + buf = malloc(config.wTotalLength);
|
| + if (!buf)
|
| + return LIBUSB_ERROR_NO_MEM;
|
| +
|
| + r = get_config_descriptor(DEVICE_CTX(dev), fd, idx, buf,
|
| + config.wTotalLength);
|
| + if (r < 0) {
|
| + free(buf);
|
| + return r;
|
| + }
|
| +
|
| + if (priv->config_descriptor)
|
| + free(priv->config_descriptor);
|
| + priv->config_descriptor = buf;
|
| + return 0;
|
| +}
|
| +
|
| +/* send a control message to retrieve active configuration */
|
| +static int usbfs_get_active_config(struct libusb_device *dev, int fd)
|
| +{
|
| + unsigned char active_config = 0;
|
| + int r;
|
| +
|
| + struct usbfs_ctrltransfer ctrl = {
|
| + .bmRequestType = LIBUSB_ENDPOINT_IN,
|
| + .bRequest = LIBUSB_REQUEST_GET_CONFIGURATION,
|
| + .wValue = 0,
|
| + .wIndex = 0,
|
| + .wLength = 1,
|
| + .timeout = 1000,
|
| + .data = &active_config
|
| + };
|
| +
|
| + r = ioctl(fd, IOCTL_USBFS_CONTROL, &ctrl);
|
| + if (r < 0) {
|
| + if (errno == ENODEV)
|
| + return LIBUSB_ERROR_NO_DEVICE;
|
| +
|
| + /* we hit this error path frequently with buggy devices :( */
|
| + usbi_warn(DEVICE_CTX(dev),
|
| + "get_configuration failed ret=%d errno=%d", r, errno);
|
| + return LIBUSB_ERROR_IO;
|
| + }
|
| +
|
| + return active_config;
|
| +}
|
| +
|
| +static int initialize_device(struct libusb_device *dev, uint8_t busnum,
|
| + uint8_t devaddr, const char *sysfs_dir)
|
| +{
|
| + struct linux_device_priv *priv = _device_priv(dev);
|
| + unsigned char *dev_buf;
|
| + char path[PATH_MAX];
|
| + int fd, speed;
|
| + int active_config = 0;
|
| + int device_configured = 1;
|
| + ssize_t r;
|
| +
|
| + dev->bus_number = busnum;
|
| + dev->device_address = devaddr;
|
| +
|
| + if (sysfs_dir) {
|
| + priv->sysfs_dir = malloc(strlen(sysfs_dir) + 1);
|
| + if (!priv->sysfs_dir)
|
| + return LIBUSB_ERROR_NO_MEM;
|
| + strcpy(priv->sysfs_dir, sysfs_dir);
|
| +
|
| + /* Note speed can contain 1.5, in this case __read_sysfs_attr
|
| + will stop parsing at the '.' and return 1 */
|
| + speed = __read_sysfs_attr(DEVICE_CTX(dev), sysfs_dir, "speed");
|
| + if (speed >= 0) {
|
| + switch (speed) {
|
| + case 1: dev->speed = LIBUSB_SPEED_LOW; break;
|
| + case 12: dev->speed = LIBUSB_SPEED_FULL; break;
|
| + case 480: dev->speed = LIBUSB_SPEED_HIGH; break;
|
| + case 5000: dev->speed = LIBUSB_SPEED_SUPER; break;
|
| + default:
|
| + usbi_warn(DEVICE_CTX(dev), "Unknown device speed: %d Mbps", speed);
|
| + }
|
| + }
|
| + }
|
| +
|
| + if (sysfs_has_descriptors)
|
| + return 0;
|
| +
|
| + /* cache device descriptor in memory so that we can retrieve it later
|
| + * without waking the device up (op_get_device_descriptor) */
|
| +
|
| + priv->dev_descriptor = NULL;
|
| + priv->config_descriptor = NULL;
|
| +
|
| + if (sysfs_can_relate_devices) {
|
| + int tmp = sysfs_get_active_config(dev, &active_config);
|
| + if (tmp < 0)
|
| + return tmp;
|
| + if (active_config == -1)
|
| + device_configured = 0;
|
| + }
|
| +
|
| + _get_usbfs_path(dev, path);
|
| + fd = open(path, O_RDWR);
|
| + if (fd < 0 && errno == EACCES) {
|
| + fd = open(path, O_RDONLY);
|
| + /* if we only have read-only access to the device, we cannot
|
| + * send a control message to determine the active config. just
|
| + * assume the first one is active. */
|
| + active_config = -1;
|
| + }
|
| +
|
| + if (fd < 0) {
|
| + usbi_err(DEVICE_CTX(dev), "open failed, ret=%d errno=%d", fd, errno);
|
| + return LIBUSB_ERROR_IO;
|
| + }
|
| +
|
| + if (!sysfs_can_relate_devices) {
|
| + if (active_config == -1) {
|
| + /* if we only have read-only access to the device, we cannot
|
| + * send a control message to determine the active config. just
|
| + * assume the first one is active. */
|
| + usbi_warn(DEVICE_CTX(dev), "access to %s is read-only; cannot "
|
| + "determine active configuration descriptor", path);
|
| + } else {
|
| + active_config = usbfs_get_active_config(dev, fd);
|
| + if (active_config == LIBUSB_ERROR_IO) {
|
| + /* buggy devices sometimes fail to report their active config.
|
| + * assume unconfigured and continue the probing */
|
| + usbi_warn(DEVICE_CTX(dev), "couldn't query active "
|
| + "configuration, assumung unconfigured");
|
| + device_configured = 0;
|
| + } else if (active_config < 0) {
|
| + close(fd);
|
| + return active_config;
|
| + } else if (active_config == 0) {
|
| + /* some buggy devices have a configuration 0, but we're
|
| + * reaching into the corner of a corner case here, so let's
|
| + * not support buggy devices in these circumstances.
|
| + * stick to the specs: a configuration value of 0 means
|
| + * unconfigured. */
|
| + usbi_dbg("active cfg 0? assuming unconfigured device");
|
| + device_configured = 0;
|
| + }
|
| + }
|
| + }
|
| +
|
| + dev_buf = malloc(DEVICE_DESC_LENGTH);
|
| + if (!dev_buf) {
|
| + close(fd);
|
| + return LIBUSB_ERROR_NO_MEM;
|
| + }
|
| +
|
| + r = read(fd, dev_buf, DEVICE_DESC_LENGTH);
|
| + if (r < 0) {
|
| + usbi_err(DEVICE_CTX(dev),
|
| + "read descriptor failed ret=%d errno=%d", fd, errno);
|
| + free(dev_buf);
|
| + close(fd);
|
| + return LIBUSB_ERROR_IO;
|
| + } else if (r < DEVICE_DESC_LENGTH) {
|
| + usbi_err(DEVICE_CTX(dev), "short descriptor read (%d)", r);
|
| + free(dev_buf);
|
| + close(fd);
|
| + return LIBUSB_ERROR_IO;
|
| + }
|
| +
|
| + /* bit of a hack: set num_configurations now because cache_active_config()
|
| + * calls usbi_get_config_index_by_value() which uses it */
|
| + dev->num_configurations = dev_buf[DEVICE_DESC_LENGTH - 1];
|
| +
|
| + if (device_configured) {
|
| + r = cache_active_config(dev, fd, active_config);
|
| + if (r < 0) {
|
| + close(fd);
|
| + free(dev_buf);
|
| + return r;
|
| + }
|
| + }
|
| +
|
| + close(fd);
|
| + priv->dev_descriptor = dev_buf;
|
| + return 0;
|
| +}
|
| +
|
| +static int enumerate_device(struct libusb_context *ctx,
|
| + struct discovered_devs **_discdevs, uint8_t busnum, uint8_t devaddr,
|
| + const char *sysfs_dir)
|
| +{
|
| + struct discovered_devs *discdevs;
|
| + unsigned long session_id;
|
| + int need_unref = 0;
|
| + struct libusb_device *dev;
|
| + int r = 0;
|
| +
|
| + /* FIXME: session ID is not guaranteed unique as addresses can wrap and
|
| + * will be reused. instead we should add a simple sysfs attribute with
|
| + * a session ID. */
|
| + session_id = busnum << 8 | devaddr;
|
| + usbi_dbg("busnum %d devaddr %d session_id %ld", busnum, devaddr,
|
| + session_id);
|
| +
|
| + dev = usbi_get_device_by_session_id(ctx, session_id);
|
| + if (dev) {
|
| + usbi_dbg("using existing device for %d/%d (session %ld)",
|
| + busnum, devaddr, session_id);
|
| + } else {
|
| + usbi_dbg("allocating new device for %d/%d (session %ld)",
|
| + busnum, devaddr, session_id);
|
| + dev = usbi_alloc_device(ctx, session_id);
|
| + if (!dev)
|
| + return LIBUSB_ERROR_NO_MEM;
|
| + need_unref = 1;
|
| + r = initialize_device(dev, busnum, devaddr, sysfs_dir);
|
| + if (r < 0)
|
| + goto out;
|
| + r = usbi_sanitize_device(dev);
|
| + if (r < 0)
|
| + goto out;
|
| + }
|
| +
|
| + discdevs = discovered_devs_append(*_discdevs, dev);
|
| + if (!discdevs)
|
| + r = LIBUSB_ERROR_NO_MEM;
|
| + else
|
| + *_discdevs = discdevs;
|
| +
|
| +out:
|
| + if (need_unref)
|
| + libusb_unref_device(dev);
|
| + return r;
|
| +}
|
| +
|
| +/* open a bus directory and adds all discovered devices to discdevs. on
|
| + * failure (non-zero return) the pre-existing discdevs should be destroyed
|
| + * (and devices freed). on success, the new discdevs pointer should be used
|
| + * as it may have been moved. */
|
| +static int usbfs_scan_busdir(struct libusb_context *ctx,
|
| + struct discovered_devs **_discdevs, uint8_t busnum)
|
| +{
|
| + DIR *dir;
|
| + char dirpath[PATH_MAX];
|
| + struct dirent *entry;
|
| + struct discovered_devs *discdevs = *_discdevs;
|
| + int r = LIBUSB_ERROR_IO;
|
| +
|
| + snprintf(dirpath, PATH_MAX, "%s/%03d", usbfs_path, busnum);
|
| + usbi_dbg("%s", dirpath);
|
| + dir = opendir(dirpath);
|
| + if (!dir) {
|
| + usbi_err(ctx, "opendir '%s' failed, errno=%d", dirpath, errno);
|
| + /* FIXME: should handle valid race conditions like hub unplugged
|
| + * during directory iteration - this is not an error */
|
| + return r;
|
| + }
|
| +
|
| + while ((entry = readdir(dir))) {
|
| + int devaddr;
|
| +
|
| + if (entry->d_name[0] == '.')
|
| + continue;
|
| +
|
| + devaddr = atoi(entry->d_name);
|
| + if (devaddr == 0) {
|
| + usbi_dbg("unknown dir entry %s", entry->d_name);
|
| + continue;
|
| + }
|
| +
|
| + if (enumerate_device(ctx, &discdevs, busnum, (uint8_t) devaddr, NULL)) {
|
| + usbi_dbg("failed to enumerate dir entry %s", entry->d_name);
|
| + continue;
|
| + }
|
| +
|
| + r = 0;
|
| + }
|
| +
|
| + if (!r)
|
| + *_discdevs = discdevs;
|
| + closedir(dir);
|
| + return r;
|
| +}
|
| +
|
| +static int usbfs_get_device_list(struct libusb_context *ctx,
|
| + struct discovered_devs **_discdevs)
|
| +{
|
| + struct dirent *entry;
|
| + DIR *buses = opendir(usbfs_path);
|
| + struct discovered_devs *discdevs = *_discdevs;
|
| + int r = 0;
|
| +
|
| + if (!buses) {
|
| + usbi_err(ctx, "opendir buses failed errno=%d", errno);
|
| + return LIBUSB_ERROR_IO;
|
| + }
|
| +
|
| + while ((entry = readdir(buses))) {
|
| + struct discovered_devs *discdevs_new = discdevs;
|
| + int busnum;
|
| +
|
| + if (entry->d_name[0] == '.')
|
| + continue;
|
| +
|
| + busnum = atoi(entry->d_name);
|
| + if (busnum == 0) {
|
| + usbi_dbg("unknown dir entry %s", entry->d_name);
|
| + continue;
|
| + }
|
| +
|
| + r = usbfs_scan_busdir(ctx, &discdevs_new, busnum);
|
| + if (r < 0)
|
| + goto out;
|
| + discdevs = discdevs_new;
|
| + }
|
| +
|
| +out:
|
| + closedir(buses);
|
| + *_discdevs = discdevs;
|
| + return r;
|
| +
|
| +}
|
| +
|
| +static int sysfs_scan_device(struct libusb_context *ctx,
|
| + struct discovered_devs **_discdevs, const char *devname)
|
| +{
|
| + int busnum;
|
| + int devaddr;
|
| +
|
| + usbi_dbg("scan %s", devname);
|
| +
|
| + busnum = __read_sysfs_attr(ctx, devname, "busnum");
|
| + if (busnum < 0)
|
| + return busnum;
|
| +
|
| + devaddr = __read_sysfs_attr(ctx, devname, "devnum");
|
| + if (devaddr < 0)
|
| + return devaddr;
|
| +
|
| + usbi_dbg("bus=%d dev=%d", busnum, devaddr);
|
| + if (busnum > 255 || devaddr > 255)
|
| + return LIBUSB_ERROR_INVALID_PARAM;
|
| +
|
| + return enumerate_device(ctx, _discdevs, busnum & 0xff, devaddr & 0xff,
|
| + devname);
|
| +}
|
| +
|
| +static int sysfs_get_device_list(struct libusb_context *ctx,
|
| + struct discovered_devs **_discdevs)
|
| +{
|
| + struct discovered_devs *discdevs = *_discdevs;
|
| + DIR *devices = opendir(SYSFS_DEVICE_PATH);
|
| + struct dirent *entry;
|
| + int r = LIBUSB_ERROR_IO;
|
| +
|
| + if (!devices) {
|
| + usbi_err(ctx, "opendir devices failed errno=%d", errno);
|
| + return r;
|
| + }
|
| +
|
| + while ((entry = readdir(devices))) {
|
| + struct discovered_devs *discdevs_new = discdevs;
|
| +
|
| + if ((!isdigit(entry->d_name[0]) && strncmp(entry->d_name, "usb", 3))
|
| + || strchr(entry->d_name, ':'))
|
| + continue;
|
| +
|
| + if (sysfs_scan_device(ctx, &discdevs_new, entry->d_name)) {
|
| + usbi_dbg("failed to enumerate dir entry %s", entry->d_name);
|
| + continue;
|
| + }
|
| +
|
| + r = 0;
|
| + discdevs = discdevs_new;
|
| + }
|
| +
|
| + if (!r)
|
| + *_discdevs = discdevs;
|
| + closedir(devices);
|
| + return r;
|
| +}
|
| +
|
| +static int op_get_device_list(struct libusb_context *ctx,
|
| + struct discovered_devs **_discdevs)
|
| +{
|
| + /* we can retrieve device list and descriptors from sysfs or usbfs.
|
| + * sysfs is preferable, because if we use usbfs we end up resuming
|
| + * any autosuspended USB devices. however, sysfs is not available
|
| + * everywhere, so we need a usbfs fallback too.
|
| + *
|
| + * as described in the "sysfs vs usbfs" comment at the top of this
|
| + * file, sometimes we have sysfs but not enough information to
|
| + * relate sysfs devices to usbfs nodes. op_init() determines the
|
| + * adequacy of sysfs and sets sysfs_can_relate_devices.
|
| + */
|
| + if (sysfs_can_relate_devices != 0)
|
| + return sysfs_get_device_list(ctx, _discdevs);
|
| + else
|
| + return usbfs_get_device_list(ctx, _discdevs);
|
| +}
|
| +
|
| +static int op_open(struct libusb_device_handle *handle)
|
| +{
|
| + struct linux_device_handle_priv *hpriv = _device_handle_priv(handle);
|
| + char filename[PATH_MAX];
|
| +
|
| + _get_usbfs_path(handle->dev, filename);
|
| + usbi_dbg("opening %s", filename);
|
| + hpriv->fd = open(filename, O_RDWR);
|
| + if (hpriv->fd < 0) {
|
| + if (errno == EACCES) {
|
| + usbi_err(HANDLE_CTX(handle), "libusb couldn't open USB device %s: "
|
| + "Permission denied.", filename);
|
| + usbi_err(HANDLE_CTX(handle),
|
| + "libusb requires write access to USB device nodes.");
|
| + return LIBUSB_ERROR_ACCESS;
|
| + } else if (errno == ENOENT) {
|
| + usbi_err(HANDLE_CTX(handle), "libusb couldn't open USB device %s: "
|
| + "No such file or directory.", filename);
|
| + return LIBUSB_ERROR_NO_DEVICE;
|
| + } else {
|
| + usbi_err(HANDLE_CTX(handle),
|
| + "open failed, code %d errno %d", hpriv->fd, errno);
|
| + return LIBUSB_ERROR_IO;
|
| + }
|
| + }
|
| +
|
| + return usbi_add_pollfd(HANDLE_CTX(handle), hpriv->fd, POLLOUT);
|
| +}
|
| +
|
| +static void op_close(struct libusb_device_handle *dev_handle)
|
| +{
|
| + int fd = _device_handle_priv(dev_handle)->fd;
|
| + usbi_remove_pollfd(HANDLE_CTX(dev_handle), fd);
|
| + close(fd);
|
| +}
|
| +
|
| +static int op_get_configuration(struct libusb_device_handle *handle,
|
| + int *config)
|
| +{
|
| + int r;
|
| + if (sysfs_can_relate_devices != 1)
|
| + return LIBUSB_ERROR_NOT_SUPPORTED;
|
| +
|
| + r = sysfs_get_active_config(handle->dev, config);
|
| + if (r < 0)
|
| + return r;
|
| +
|
| + if (*config == -1)
|
| + *config = 0;
|
| +
|
| + return 0;
|
| +}
|
| +
|
| +static int op_set_configuration(struct libusb_device_handle *handle, int config)
|
| +{
|
| + struct linux_device_priv *priv = _device_priv(handle->dev);
|
| + int fd = _device_handle_priv(handle)->fd;
|
| + int r = ioctl(fd, IOCTL_USBFS_SETCONFIG, &config);
|
| + if (r) {
|
| + if (errno == EINVAL)
|
| + return LIBUSB_ERROR_NOT_FOUND;
|
| + else if (errno == EBUSY)
|
| + return LIBUSB_ERROR_BUSY;
|
| + else if (errno == ENODEV)
|
| + return LIBUSB_ERROR_NO_DEVICE;
|
| +
|
| + usbi_err(HANDLE_CTX(handle), "failed, error %d errno %d", r, errno);
|
| + return LIBUSB_ERROR_OTHER;
|
| + }
|
| +
|
| + if (!sysfs_has_descriptors) {
|
| + /* update our cached active config descriptor */
|
| + if (config == -1) {
|
| + if (priv->config_descriptor) {
|
| + free(priv->config_descriptor);
|
| + priv->config_descriptor = NULL;
|
| + }
|
| + } else {
|
| + r = cache_active_config(handle->dev, fd, config);
|
| + if (r < 0)
|
| + usbi_warn(HANDLE_CTX(handle),
|
| + "failed to update cached config descriptor, error %d", r);
|
| + }
|
| + }
|
| +
|
| + return 0;
|
| +}
|
| +
|
| +static int op_claim_interface(struct libusb_device_handle *handle, int iface)
|
| +{
|
| + int fd = _device_handle_priv(handle)->fd;
|
| + int r = ioctl(fd, IOCTL_USBFS_CLAIMINTF, &iface);
|
| + if (r) {
|
| + if (errno == ENOENT)
|
| + return LIBUSB_ERROR_NOT_FOUND;
|
| + else if (errno == EBUSY)
|
| + return LIBUSB_ERROR_BUSY;
|
| + else if (errno == ENODEV)
|
| + return LIBUSB_ERROR_NO_DEVICE;
|
| +
|
| + usbi_err(HANDLE_CTX(handle),
|
| + "claim interface failed, error %d errno %d", r, errno);
|
| + return LIBUSB_ERROR_OTHER;
|
| + }
|
| + return 0;
|
| +}
|
| +
|
| +static int op_release_interface(struct libusb_device_handle *handle, int iface)
|
| +{
|
| + int fd = _device_handle_priv(handle)->fd;
|
| + int r = ioctl(fd, IOCTL_USBFS_RELEASEINTF, &iface);
|
| + if (r) {
|
| + if (errno == ENODEV)
|
| + return LIBUSB_ERROR_NO_DEVICE;
|
| +
|
| + usbi_err(HANDLE_CTX(handle),
|
| + "release interface failed, error %d errno %d", r, errno);
|
| + return LIBUSB_ERROR_OTHER;
|
| + }
|
| + return 0;
|
| +}
|
| +
|
| +static int op_set_interface(struct libusb_device_handle *handle, int iface,
|
| + int altsetting)
|
| +{
|
| + int fd = _device_handle_priv(handle)->fd;
|
| + struct usbfs_setinterface setintf;
|
| + int r;
|
| +
|
| + setintf.interface = iface;
|
| + setintf.altsetting = altsetting;
|
| + r = ioctl(fd, IOCTL_USBFS_SETINTF, &setintf);
|
| + if (r) {
|
| + if (errno == EINVAL)
|
| + return LIBUSB_ERROR_NOT_FOUND;
|
| + else if (errno == ENODEV)
|
| + return LIBUSB_ERROR_NO_DEVICE;
|
| +
|
| + usbi_err(HANDLE_CTX(handle),
|
| + "setintf failed error %d errno %d", r, errno);
|
| + return LIBUSB_ERROR_OTHER;
|
| + }
|
| +
|
| + return 0;
|
| +}
|
| +
|
| +static int op_clear_halt(struct libusb_device_handle *handle,
|
| + unsigned char endpoint)
|
| +{
|
| + int fd = _device_handle_priv(handle)->fd;
|
| + unsigned int _endpoint = endpoint;
|
| + int r = ioctl(fd, IOCTL_USBFS_CLEAR_HALT, &_endpoint);
|
| + if (r) {
|
| + if (errno == ENOENT)
|
| + return LIBUSB_ERROR_NOT_FOUND;
|
| + else if (errno == ENODEV)
|
| + return LIBUSB_ERROR_NO_DEVICE;
|
| +
|
| + usbi_err(HANDLE_CTX(handle),
|
| + "clear_halt failed error %d errno %d", r, errno);
|
| + return LIBUSB_ERROR_OTHER;
|
| + }
|
| +
|
| + return 0;
|
| +}
|
| +
|
| +static int op_reset_device(struct libusb_device_handle *handle)
|
| +{
|
| + int fd = _device_handle_priv(handle)->fd;
|
| + int i, r, ret = 0;
|
| +
|
| + /* Doing a device reset will cause the usbfs driver to get unbound
|
| + from any interfaces it is bound to. By voluntarily unbinding
|
| + the usbfs driver ourself, we stop the kernel from rebinding
|
| + the interface after reset (which would end up with the interface
|
| + getting bound to the in kernel driver if any). */
|
| + for (i = 0; i < USB_MAXINTERFACES; i++) {
|
| + if (handle->claimed_interfaces & (1L << i)) {
|
| + op_release_interface(handle, i);
|
| + }
|
| + }
|
| +
|
| + usbi_mutex_lock(&handle->lock);
|
| + r = ioctl(fd, IOCTL_USBFS_RESET, NULL);
|
| + if (r) {
|
| + if (errno == ENODEV) {
|
| + ret = LIBUSB_ERROR_NOT_FOUND;
|
| + goto out;
|
| + }
|
| +
|
| + usbi_err(HANDLE_CTX(handle),
|
| + "reset failed error %d errno %d", r, errno);
|
| + ret = LIBUSB_ERROR_OTHER;
|
| + goto out;
|
| + }
|
| +
|
| + /* And re-claim any interfaces which were claimed before the reset */
|
| + for (i = 0; i < USB_MAXINTERFACES; i++) {
|
| + if (handle->claimed_interfaces & (1L << i)) {
|
| + r = op_claim_interface(handle, i);
|
| + if (r) {
|
| + usbi_warn(HANDLE_CTX(handle),
|
| + "failed to re-claim interface %d after reset", i);
|
| + handle->claimed_interfaces &= ~(1L << i);
|
| + }
|
| + }
|
| + }
|
| +out:
|
| + usbi_mutex_unlock(&handle->lock);
|
| + return ret;
|
| +}
|
| +
|
| +static int op_kernel_driver_active(struct libusb_device_handle *handle,
|
| + int interface)
|
| +{
|
| + int fd = _device_handle_priv(handle)->fd;
|
| + struct usbfs_getdriver getdrv;
|
| + int r;
|
| +
|
| + getdrv.interface = interface;
|
| + r = ioctl(fd, IOCTL_USBFS_GETDRIVER, &getdrv);
|
| + if (r) {
|
| + if (errno == ENODATA)
|
| + return 0;
|
| + else if (errno == ENODEV)
|
| + return LIBUSB_ERROR_NO_DEVICE;
|
| +
|
| + usbi_err(HANDLE_CTX(handle),
|
| + "get driver failed error %d errno %d", r, errno);
|
| + return LIBUSB_ERROR_OTHER;
|
| + }
|
| +
|
| + return 1;
|
| +}
|
| +
|
| +static int op_detach_kernel_driver(struct libusb_device_handle *handle,
|
| + int interface)
|
| +{
|
| + int fd = _device_handle_priv(handle)->fd;
|
| + struct usbfs_ioctl command;
|
| + int r;
|
| +
|
| + command.ifno = interface;
|
| + command.ioctl_code = IOCTL_USBFS_DISCONNECT;
|
| + command.data = NULL;
|
| +
|
| + r = ioctl(fd, IOCTL_USBFS_IOCTL, &command);
|
| + if (r) {
|
| + if (errno == ENODATA)
|
| + return LIBUSB_ERROR_NOT_FOUND;
|
| + else if (errno == EINVAL)
|
| + return LIBUSB_ERROR_INVALID_PARAM;
|
| + else if (errno == ENODEV)
|
| + return LIBUSB_ERROR_NO_DEVICE;
|
| +
|
| + usbi_err(HANDLE_CTX(handle),
|
| + "detach failed error %d errno %d", r, errno);
|
| + return LIBUSB_ERROR_OTHER;
|
| + }
|
| +
|
| + return 0;
|
| +}
|
| +
|
| +static int op_attach_kernel_driver(struct libusb_device_handle *handle,
|
| + int interface)
|
| +{
|
| + int fd = _device_handle_priv(handle)->fd;
|
| + struct usbfs_ioctl command;
|
| + int r;
|
| +
|
| + command.ifno = interface;
|
| + command.ioctl_code = IOCTL_USBFS_CONNECT;
|
| + command.data = NULL;
|
| +
|
| + r = ioctl(fd, IOCTL_USBFS_IOCTL, &command);
|
| + if (r < 0) {
|
| + if (errno == ENODATA)
|
| + return LIBUSB_ERROR_NOT_FOUND;
|
| + else if (errno == EINVAL)
|
| + return LIBUSB_ERROR_INVALID_PARAM;
|
| + else if (errno == ENODEV)
|
| + return LIBUSB_ERROR_NO_DEVICE;
|
| + else if (errno == EBUSY)
|
| + return LIBUSB_ERROR_BUSY;
|
| +
|
| + usbi_err(HANDLE_CTX(handle),
|
| + "attach failed error %d errno %d", r, errno);
|
| + return LIBUSB_ERROR_OTHER;
|
| + } else if (r == 0) {
|
| + return LIBUSB_ERROR_NOT_FOUND;
|
| + }
|
| +
|
| + return 0;
|
| +}
|
| +
|
| +static void op_destroy_device(struct libusb_device *dev)
|
| +{
|
| + struct linux_device_priv *priv = _device_priv(dev);
|
| + if (!sysfs_has_descriptors) {
|
| + if (priv->dev_descriptor)
|
| + free(priv->dev_descriptor);
|
| + if (priv->config_descriptor)
|
| + free(priv->config_descriptor);
|
| + }
|
| + if (priv->sysfs_dir)
|
| + free(priv->sysfs_dir);
|
| +}
|
| +
|
| +/* URBs are discarded in reverse order of submission to avoid races. */
|
| +static int discard_urbs(struct usbi_transfer *itransfer, int first, int last_plus_one)
|
| +{
|
| + struct libusb_transfer *transfer =
|
| + USBI_TRANSFER_TO_LIBUSB_TRANSFER(itransfer);
|
| + struct linux_transfer_priv *tpriv =
|
| + usbi_transfer_get_os_priv(itransfer);
|
| + struct linux_device_handle_priv *dpriv =
|
| + _device_handle_priv(transfer->dev_handle);
|
| + int i, ret = 0;
|
| + struct usbfs_urb *urb;
|
| +
|
| + for (i = last_plus_one - 1; i >= first; i--) {
|
| + if (LIBUSB_TRANSFER_TYPE_ISOCHRONOUS == transfer->type)
|
| + urb = tpriv->iso_urbs[i];
|
| + else
|
| + urb = &tpriv->urbs[i];
|
| +
|
| + if (0 == ioctl(dpriv->fd, IOCTL_USBFS_DISCARDURB, urb))
|
| + continue;
|
| +
|
| + if (EINVAL == errno) {
|
| + usbi_dbg("URB not found --> assuming ready to be reaped");
|
| + ret = LIBUSB_ERROR_NOT_FOUND;
|
| + } else if (ENODEV == errno) {
|
| + usbi_dbg("Device not found for URB --> assuming ready to be reaped");
|
| + ret = LIBUSB_ERROR_NO_DEVICE;
|
| + } else {
|
| + usbi_warn(TRANSFER_CTX(transfer),
|
| + "unrecognised discard errno %d", errno);
|
| + ret = LIBUSB_ERROR_OTHER;
|
| + }
|
| + }
|
| + return ret;
|
| +}
|
| +
|
| +static void free_iso_urbs(struct linux_transfer_priv *tpriv)
|
| +{
|
| + int i;
|
| + for (i = 0; i < tpriv->num_urbs; i++) {
|
| + struct usbfs_urb *urb = tpriv->iso_urbs[i];
|
| + if (!urb)
|
| + break;
|
| + free(urb);
|
| + }
|
| +
|
| + free(tpriv->iso_urbs);
|
| + tpriv->iso_urbs = NULL;
|
| +}
|
| +
|
| +static int submit_bulk_transfer(struct usbi_transfer *itransfer,
|
| + unsigned char urb_type)
|
| +{
|
| + struct libusb_transfer *transfer =
|
| + USBI_TRANSFER_TO_LIBUSB_TRANSFER(itransfer);
|
| + struct linux_transfer_priv *tpriv = usbi_transfer_get_os_priv(itransfer);
|
| + struct linux_device_handle_priv *dpriv =
|
| + _device_handle_priv(transfer->dev_handle);
|
| + struct usbfs_urb *urbs;
|
| + int is_out = (transfer->endpoint & LIBUSB_ENDPOINT_DIR_MASK)
|
| + == LIBUSB_ENDPOINT_OUT;
|
| + int r;
|
| + int i;
|
| + size_t alloc_size;
|
| +
|
| + if (tpriv->urbs)
|
| + return LIBUSB_ERROR_BUSY;
|
| +
|
| + /* usbfs places a 16kb limit on bulk URBs. we divide up larger requests
|
| + * into smaller units to meet such restriction, then fire off all the
|
| + * units at once. it would be simpler if we just fired one unit at a time,
|
| + * but there is a big performance gain through doing it this way. */
|
| + int num_urbs = transfer->length / MAX_BULK_BUFFER_LENGTH;
|
| + int last_urb_partial = 0;
|
| +
|
| + if (transfer->length == 0) {
|
| + num_urbs = 1;
|
| + } else if ((transfer->length % MAX_BULK_BUFFER_LENGTH) > 0) {
|
| + last_urb_partial = 1;
|
| + num_urbs++;
|
| + }
|
| + usbi_dbg("need %d urbs for new transfer with length %d", num_urbs,
|
| + transfer->length);
|
| + alloc_size = num_urbs * sizeof(struct usbfs_urb);
|
| + urbs = malloc(alloc_size);
|
| + if (!urbs)
|
| + return LIBUSB_ERROR_NO_MEM;
|
| + memset(urbs, 0, alloc_size);
|
| + tpriv->urbs = urbs;
|
| + tpriv->num_urbs = num_urbs;
|
| + tpriv->num_retired = 0;
|
| + tpriv->reap_action = NORMAL;
|
| + tpriv->reap_status = LIBUSB_TRANSFER_COMPLETED;
|
| +
|
| + for (i = 0; i < num_urbs; i++) {
|
| + struct usbfs_urb *urb = &urbs[i];
|
| + urb->usercontext = itransfer;
|
| + urb->type = urb_type;
|
| + urb->endpoint = transfer->endpoint;
|
| + urb->buffer = transfer->buffer + (i * MAX_BULK_BUFFER_LENGTH);
|
| + if (supports_flag_bulk_continuation && !is_out)
|
| + urb->flags = USBFS_URB_SHORT_NOT_OK;
|
| + if (i == num_urbs - 1 && last_urb_partial)
|
| + urb->buffer_length = transfer->length % MAX_BULK_BUFFER_LENGTH;
|
| + else if (transfer->length == 0)
|
| + urb->buffer_length = 0;
|
| + else
|
| + urb->buffer_length = MAX_BULK_BUFFER_LENGTH;
|
| +
|
| + if (i > 0 && supports_flag_bulk_continuation)
|
| + urb->flags |= USBFS_URB_BULK_CONTINUATION;
|
| +
|
| + r = ioctl(dpriv->fd, IOCTL_USBFS_SUBMITURB, urb);
|
| + if (r < 0) {
|
| + if (errno == ENODEV) {
|
| + r = LIBUSB_ERROR_NO_DEVICE;
|
| + } else {
|
| + usbi_err(TRANSFER_CTX(transfer),
|
| + "submiturb failed error %d errno=%d", r, errno);
|
| + r = LIBUSB_ERROR_IO;
|
| + }
|
| +
|
| + /* if the first URB submission fails, we can simply free up and
|
| + * return failure immediately. */
|
| + if (i == 0) {
|
| + usbi_dbg("first URB failed, easy peasy");
|
| + free(urbs);
|
| + tpriv->urbs = NULL;
|
| + return r;
|
| + }
|
| +
|
| + /* if it's not the first URB that failed, the situation is a bit
|
| + * tricky. we may need to discard all previous URBs. there are
|
| + * complications:
|
| + * - discarding is asynchronous - discarded urbs will be reaped
|
| + * later. the user must not have freed the transfer when the
|
| + * discarded URBs are reaped, otherwise libusb will be using
|
| + * freed memory.
|
| + * - the earlier URBs may have completed successfully and we do
|
| + * not want to throw away any data.
|
| + * - this URB failing may be no error; EREMOTEIO means that
|
| + * this transfer simply didn't need all the URBs we submitted
|
| + * so, we report that the transfer was submitted successfully and
|
| + * in case of error we discard all previous URBs. later when
|
| + * the final reap completes we can report error to the user,
|
| + * or success if an earlier URB was completed successfully.
|
| + */
|
| + tpriv->reap_action = EREMOTEIO == errno ? COMPLETED_EARLY : SUBMIT_FAILED;
|
| +
|
| + /* The URBs we haven't submitted yet we count as already
|
| + * retired. */
|
| + tpriv->num_retired += num_urbs - i;
|
| +
|
| + /* If we completed short then don't try to discard. */
|
| + if (COMPLETED_EARLY == tpriv->reap_action)
|
| + return 0;
|
| +
|
| + discard_urbs(itransfer, 0, i);
|
| +
|
| + usbi_dbg("reporting successful submission but waiting for %d "
|
| + "discards before reporting error", i);
|
| + return 0;
|
| + }
|
| + }
|
| +
|
| + return 0;
|
| +}
|
| +
|
| +static int submit_iso_transfer(struct usbi_transfer *itransfer)
|
| +{
|
| + struct libusb_transfer *transfer =
|
| + USBI_TRANSFER_TO_LIBUSB_TRANSFER(itransfer);
|
| + struct linux_transfer_priv *tpriv = usbi_transfer_get_os_priv(itransfer);
|
| + struct linux_device_handle_priv *dpriv =
|
| + _device_handle_priv(transfer->dev_handle);
|
| + struct usbfs_urb **urbs;
|
| + size_t alloc_size;
|
| + int num_packets = transfer->num_iso_packets;
|
| + int i;
|
| + int this_urb_len = 0;
|
| + int num_urbs = 1;
|
| + int packet_offset = 0;
|
| + unsigned int packet_len;
|
| + unsigned char *urb_buffer = transfer->buffer;
|
| +
|
| + if (tpriv->iso_urbs)
|
| + return LIBUSB_ERROR_BUSY;
|
| +
|
| + /* usbfs places a 32kb limit on iso URBs. we divide up larger requests
|
| + * into smaller units to meet such restriction, then fire off all the
|
| + * units at once. it would be simpler if we just fired one unit at a time,
|
| + * but there is a big performance gain through doing it this way. */
|
| +
|
| + /* calculate how many URBs we need */
|
| + for (i = 0; i < num_packets; i++) {
|
| + int space_remaining = MAX_ISO_BUFFER_LENGTH - this_urb_len;
|
| + packet_len = transfer->iso_packet_desc[i].length;
|
| +
|
| + if (packet_len > space_remaining) {
|
| + num_urbs++;
|
| + this_urb_len = packet_len;
|
| + } else {
|
| + this_urb_len += packet_len;
|
| + }
|
| + }
|
| + usbi_dbg("need %d 32k URBs for transfer", num_urbs);
|
| +
|
| + alloc_size = num_urbs * sizeof(*urbs);
|
| + urbs = malloc(alloc_size);
|
| + if (!urbs)
|
| + return LIBUSB_ERROR_NO_MEM;
|
| + memset(urbs, 0, alloc_size);
|
| +
|
| + tpriv->iso_urbs = urbs;
|
| + tpriv->num_urbs = num_urbs;
|
| + tpriv->num_retired = 0;
|
| + tpriv->reap_action = NORMAL;
|
| + tpriv->iso_packet_offset = 0;
|
| +
|
| + /* allocate + initialize each URB with the correct number of packets */
|
| + for (i = 0; i < num_urbs; i++) {
|
| + struct usbfs_urb *urb;
|
| + int space_remaining_in_urb = MAX_ISO_BUFFER_LENGTH;
|
| + int urb_packet_offset = 0;
|
| + unsigned char *urb_buffer_orig = urb_buffer;
|
| + int j;
|
| + int k;
|
| +
|
| + /* swallow up all the packets we can fit into this URB */
|
| + while (packet_offset < transfer->num_iso_packets) {
|
| + packet_len = transfer->iso_packet_desc[packet_offset].length;
|
| + if (packet_len <= space_remaining_in_urb) {
|
| + /* throw it in */
|
| + urb_packet_offset++;
|
| + packet_offset++;
|
| + space_remaining_in_urb -= packet_len;
|
| + urb_buffer += packet_len;
|
| + } else {
|
| + /* it can't fit, save it for the next URB */
|
| + break;
|
| + }
|
| + }
|
| +
|
| + alloc_size = sizeof(*urb)
|
| + + (urb_packet_offset * sizeof(struct usbfs_iso_packet_desc));
|
| + urb = malloc(alloc_size);
|
| + if (!urb) {
|
| + free_iso_urbs(tpriv);
|
| + return LIBUSB_ERROR_NO_MEM;
|
| + }
|
| + memset(urb, 0, alloc_size);
|
| + urbs[i] = urb;
|
| +
|
| + /* populate packet lengths */
|
| + for (j = 0, k = packet_offset - urb_packet_offset;
|
| + k < packet_offset; k++, j++) {
|
| + packet_len = transfer->iso_packet_desc[k].length;
|
| + urb->iso_frame_desc[j].length = packet_len;
|
| + }
|
| +
|
| + urb->usercontext = itransfer;
|
| + urb->type = USBFS_URB_TYPE_ISO;
|
| + /* FIXME: interface for non-ASAP data? */
|
| + urb->flags = USBFS_URB_ISO_ASAP;
|
| + urb->endpoint = transfer->endpoint;
|
| + urb->number_of_packets = urb_packet_offset;
|
| + urb->buffer = urb_buffer_orig;
|
| + }
|
| +
|
| + /* submit URBs */
|
| + for (i = 0; i < num_urbs; i++) {
|
| + int r = ioctl(dpriv->fd, IOCTL_USBFS_SUBMITURB, urbs[i]);
|
| + if (r < 0) {
|
| + if (errno == ENODEV) {
|
| + r = LIBUSB_ERROR_NO_DEVICE;
|
| + } else {
|
| + usbi_err(TRANSFER_CTX(transfer),
|
| + "submiturb failed error %d errno=%d", r, errno);
|
| + r = LIBUSB_ERROR_IO;
|
| + }
|
| +
|
| + /* if the first URB submission fails, we can simply free up and
|
| + * return failure immediately. */
|
| + if (i == 0) {
|
| + usbi_dbg("first URB failed, easy peasy");
|
| + free_iso_urbs(tpriv);
|
| + return r;
|
| + }
|
| +
|
| + /* if it's not the first URB that failed, the situation is a bit
|
| + * tricky. we must discard all previous URBs. there are
|
| + * complications:
|
| + * - discarding is asynchronous - discarded urbs will be reaped
|
| + * later. the user must not have freed the transfer when the
|
| + * discarded URBs are reaped, otherwise libusb will be using
|
| + * freed memory.
|
| + * - the earlier URBs may have completed successfully and we do
|
| + * not want to throw away any data.
|
| + * so, in this case we discard all the previous URBs BUT we report
|
| + * that the transfer was submitted successfully. then later when
|
| + * the final discard completes we can report error to the user.
|
| + */
|
| + tpriv->reap_action = SUBMIT_FAILED;
|
| +
|
| + /* The URBs we haven't submitted yet we count as already
|
| + * retired. */
|
| + tpriv->num_retired = num_urbs - i;
|
| + discard_urbs(itransfer, 0, i);
|
| +
|
| + usbi_dbg("reporting successful submission but waiting for %d "
|
| + "discards before reporting error", i);
|
| + return 0;
|
| + }
|
| + }
|
| +
|
| + return 0;
|
| +}
|
| +
|
| +static int submit_control_transfer(struct usbi_transfer *itransfer)
|
| +{
|
| + struct linux_transfer_priv *tpriv = usbi_transfer_get_os_priv(itransfer);
|
| + struct libusb_transfer *transfer =
|
| + USBI_TRANSFER_TO_LIBUSB_TRANSFER(itransfer);
|
| + struct linux_device_handle_priv *dpriv =
|
| + _device_handle_priv(transfer->dev_handle);
|
| + struct usbfs_urb *urb;
|
| + int r;
|
| +
|
| + if (tpriv->urbs)
|
| + return LIBUSB_ERROR_BUSY;
|
| +
|
| + if (transfer->length - LIBUSB_CONTROL_SETUP_SIZE > MAX_CTRL_BUFFER_LENGTH)
|
| + return LIBUSB_ERROR_INVALID_PARAM;
|
| +
|
| + urb = malloc(sizeof(struct usbfs_urb));
|
| + if (!urb)
|
| + return LIBUSB_ERROR_NO_MEM;
|
| + memset(urb, 0, sizeof(struct usbfs_urb));
|
| + tpriv->urbs = urb;
|
| + tpriv->num_urbs = 1;
|
| + tpriv->reap_action = NORMAL;
|
| +
|
| + urb->usercontext = itransfer;
|
| + urb->type = USBFS_URB_TYPE_CONTROL;
|
| + urb->endpoint = transfer->endpoint;
|
| + urb->buffer = transfer->buffer;
|
| + urb->buffer_length = transfer->length;
|
| +
|
| + r = ioctl(dpriv->fd, IOCTL_USBFS_SUBMITURB, urb);
|
| + if (r < 0) {
|
| + free(urb);
|
| + tpriv->urbs = NULL;
|
| + if (errno == ENODEV)
|
| + return LIBUSB_ERROR_NO_DEVICE;
|
| +
|
| + usbi_err(TRANSFER_CTX(transfer),
|
| + "submiturb failed error %d errno=%d", r, errno);
|
| + return LIBUSB_ERROR_IO;
|
| + }
|
| + return 0;
|
| +}
|
| +
|
| +static int op_submit_transfer(struct usbi_transfer *itransfer)
|
| +{
|
| + struct libusb_transfer *transfer =
|
| + USBI_TRANSFER_TO_LIBUSB_TRANSFER(itransfer);
|
| +
|
| + switch (transfer->type) {
|
| + case LIBUSB_TRANSFER_TYPE_CONTROL:
|
| + return submit_control_transfer(itransfer);
|
| + case LIBUSB_TRANSFER_TYPE_BULK:
|
| + return submit_bulk_transfer(itransfer, USBFS_URB_TYPE_BULK);
|
| + case LIBUSB_TRANSFER_TYPE_INTERRUPT:
|
| + return submit_bulk_transfer(itransfer, USBFS_URB_TYPE_INTERRUPT);
|
| + case LIBUSB_TRANSFER_TYPE_ISOCHRONOUS:
|
| + return submit_iso_transfer(itransfer);
|
| + default:
|
| + usbi_err(TRANSFER_CTX(transfer),
|
| + "unknown endpoint type %d", transfer->type);
|
| + return LIBUSB_ERROR_INVALID_PARAM;
|
| + }
|
| +}
|
| +
|
| +static int op_cancel_transfer(struct usbi_transfer *itransfer)
|
| +{
|
| + struct linux_transfer_priv *tpriv = usbi_transfer_get_os_priv(itransfer);
|
| + struct libusb_transfer *transfer =
|
| + USBI_TRANSFER_TO_LIBUSB_TRANSFER(itransfer);
|
| +
|
| + switch (transfer->type) {
|
| + case LIBUSB_TRANSFER_TYPE_BULK:
|
| + if (tpriv->reap_action == ERROR)
|
| + break;
|
| + /* else, fall through */
|
| + case LIBUSB_TRANSFER_TYPE_CONTROL:
|
| + case LIBUSB_TRANSFER_TYPE_INTERRUPT:
|
| + case LIBUSB_TRANSFER_TYPE_ISOCHRONOUS:
|
| + tpriv->reap_action = CANCELLED;
|
| + break;
|
| + default:
|
| + usbi_err(TRANSFER_CTX(transfer),
|
| + "unknown endpoint type %d", transfer->type);
|
| + return LIBUSB_ERROR_INVALID_PARAM;
|
| + }
|
| +
|
| + if (!tpriv->urbs)
|
| + return LIBUSB_ERROR_NOT_FOUND;
|
| +
|
| + return discard_urbs(itransfer, 0, tpriv->num_urbs);
|
| +}
|
| +
|
| +static void op_clear_transfer_priv(struct usbi_transfer *itransfer)
|
| +{
|
| + struct libusb_transfer *transfer =
|
| + USBI_TRANSFER_TO_LIBUSB_TRANSFER(itransfer);
|
| + struct linux_transfer_priv *tpriv = usbi_transfer_get_os_priv(itransfer);
|
| +
|
| + /* urbs can be freed also in submit_transfer so lock mutex first */
|
| + switch (transfer->type) {
|
| + case LIBUSB_TRANSFER_TYPE_CONTROL:
|
| + case LIBUSB_TRANSFER_TYPE_BULK:
|
| + case LIBUSB_TRANSFER_TYPE_INTERRUPT:
|
| + usbi_mutex_lock(&itransfer->lock);
|
| + if (tpriv->urbs)
|
| + free(tpriv->urbs);
|
| + tpriv->urbs = NULL;
|
| + usbi_mutex_unlock(&itransfer->lock);
|
| + break;
|
| + case LIBUSB_TRANSFER_TYPE_ISOCHRONOUS:
|
| + usbi_mutex_lock(&itransfer->lock);
|
| + if (tpriv->iso_urbs)
|
| + free_iso_urbs(tpriv);
|
| + usbi_mutex_unlock(&itransfer->lock);
|
| + break;
|
| + default:
|
| + usbi_err(TRANSFER_CTX(transfer),
|
| + "unknown endpoint type %d", transfer->type);
|
| + }
|
| +}
|
| +
|
| +static int handle_bulk_completion(struct usbi_transfer *itransfer,
|
| + struct usbfs_urb *urb)
|
| +{
|
| + struct linux_transfer_priv *tpriv = usbi_transfer_get_os_priv(itransfer);
|
| + struct libusb_transfer *transfer = USBI_TRANSFER_TO_LIBUSB_TRANSFER(itransfer);
|
| + int urb_idx = urb - tpriv->urbs;
|
| +
|
| + usbi_mutex_lock(&itransfer->lock);
|
| + usbi_dbg("handling completion status %d of bulk urb %d/%d", urb->status,
|
| + urb_idx + 1, tpriv->num_urbs);
|
| +
|
| + tpriv->num_retired++;
|
| +
|
| + if (tpriv->reap_action != NORMAL) {
|
| + /* cancelled, submit_fail, or completed early */
|
| + usbi_dbg("abnormal reap: urb status %d", urb->status);
|
| +
|
| + /* even though we're in the process of cancelling, it's possible that
|
| + * we may receive some data in these URBs that we don't want to lose.
|
| + * examples:
|
| + * 1. while the kernel is cancelling all the packets that make up an
|
| + * URB, a few of them might complete. so we get back a successful
|
| + * cancellation *and* some data.
|
| + * 2. we receive a short URB which marks the early completion condition,
|
| + * so we start cancelling the remaining URBs. however, we're too
|
| + * slow and another URB completes (or at least completes partially).
|
| + * (this can't happen since we always use BULK_CONTINUATION.)
|
| + *
|
| + * When this happens, our objectives are not to lose any "surplus" data,
|
| + * and also to stick it at the end of the previously-received data
|
| + * (closing any holes), so that libusb reports the total amount of
|
| + * transferred data and presents it in a contiguous chunk.
|
| + */
|
| + if (urb->actual_length > 0) {
|
| + unsigned char *target = transfer->buffer + itransfer->transferred;
|
| + usbi_dbg("received %d bytes of surplus data", urb->actual_length);
|
| + if (urb->buffer != target) {
|
| + usbi_dbg("moving surplus data from offset %d to offset %d",
|
| + (unsigned char *) urb->buffer - transfer->buffer,
|
| + target - transfer->buffer);
|
| + memmove(target, urb->buffer, urb->actual_length);
|
| + }
|
| + itransfer->transferred += urb->actual_length;
|
| + }
|
| +
|
| + if (tpriv->num_retired == tpriv->num_urbs) {
|
| + usbi_dbg("abnormal reap: last URB handled, reporting");
|
| + if (tpriv->reap_action != COMPLETED_EARLY &&
|
| + tpriv->reap_status == LIBUSB_TRANSFER_COMPLETED)
|
| + tpriv->reap_status = LIBUSB_TRANSFER_ERROR;
|
| + goto completed;
|
| + }
|
| + goto out_unlock;
|
| + }
|
| +
|
| + itransfer->transferred += urb->actual_length;
|
| +
|
| + /* Many of these errors can occur on *any* urb of a multi-urb
|
| + * transfer. When they do, we tear down the rest of the transfer.
|
| + */
|
| + switch (urb->status) {
|
| + case 0:
|
| + break;
|
| + case -EREMOTEIO: /* short transfer */
|
| + break;
|
| + case -ENOENT: /* cancelled */
|
| + case -ECONNRESET:
|
| + break;
|
| + case -ESHUTDOWN:
|
| + usbi_dbg("device removed");
|
| + tpriv->reap_status = LIBUSB_TRANSFER_NO_DEVICE;
|
| + goto cancel_remaining;
|
| + case -EPIPE:
|
| + usbi_dbg("detected endpoint stall");
|
| + if (tpriv->reap_status == LIBUSB_TRANSFER_COMPLETED)
|
| + tpriv->reap_status = LIBUSB_TRANSFER_STALL;
|
| + goto cancel_remaining;
|
| + case -EOVERFLOW:
|
| + /* overflow can only ever occur in the last urb */
|
| + usbi_dbg("overflow, actual_length=%d", urb->actual_length);
|
| + if (tpriv->reap_status == LIBUSB_TRANSFER_COMPLETED)
|
| + tpriv->reap_status = LIBUSB_TRANSFER_OVERFLOW;
|
| + goto completed;
|
| + case -ETIME:
|
| + case -EPROTO:
|
| + case -EILSEQ:
|
| + usbi_dbg("low level error %d", urb->status);
|
| + tpriv->reap_action = ERROR;
|
| + goto cancel_remaining;
|
| + default:
|
| + usbi_warn(ITRANSFER_CTX(itransfer),
|
| + "unrecognised urb status %d", urb->status);
|
| + tpriv->reap_action = ERROR;
|
| + goto cancel_remaining;
|
| + }
|
| +
|
| + /* if we're the last urb or we got less data than requested then we're
|
| + * done */
|
| + if (urb_idx == tpriv->num_urbs - 1) {
|
| + usbi_dbg("last URB in transfer --> complete!");
|
| + goto completed;
|
| + } else if (urb->actual_length < urb->buffer_length) {
|
| + usbi_dbg("short transfer %d/%d --> complete!",
|
| + urb->actual_length, urb->buffer_length);
|
| + if (tpriv->reap_action == NORMAL)
|
| + tpriv->reap_action = COMPLETED_EARLY;
|
| + } else
|
| + goto out_unlock;
|
| +
|
| +cancel_remaining:
|
| + if (ERROR == tpriv->reap_action && LIBUSB_TRANSFER_COMPLETED == tpriv->reap_status)
|
| + tpriv->reap_status = LIBUSB_TRANSFER_ERROR;
|
| +
|
| + if (tpriv->num_retired == tpriv->num_urbs) /* nothing to cancel */
|
| + goto completed;
|
| +
|
| + /* cancel remaining urbs and wait for their completion before
|
| + * reporting results */
|
| + discard_urbs(itransfer, urb_idx + 1, tpriv->num_urbs);
|
| +
|
| +out_unlock:
|
| + usbi_mutex_unlock(&itransfer->lock);
|
| + return 0;
|
| +
|
| +completed:
|
| + free(tpriv->urbs);
|
| + tpriv->urbs = NULL;
|
| + usbi_mutex_unlock(&itransfer->lock);
|
| + return CANCELLED == tpriv->reap_action ?
|
| + usbi_handle_transfer_cancellation(itransfer) :
|
| + usbi_handle_transfer_completion(itransfer, tpriv->reap_status);
|
| +}
|
| +
|
| +static int handle_iso_completion(struct usbi_transfer *itransfer,
|
| + struct usbfs_urb *urb)
|
| +{
|
| + struct libusb_transfer *transfer =
|
| + USBI_TRANSFER_TO_LIBUSB_TRANSFER(itransfer);
|
| + struct linux_transfer_priv *tpriv = usbi_transfer_get_os_priv(itransfer);
|
| + int num_urbs = tpriv->num_urbs;
|
| + int urb_idx = 0;
|
| + int i;
|
| + enum libusb_transfer_status status = LIBUSB_TRANSFER_COMPLETED;
|
| +
|
| + usbi_mutex_lock(&itransfer->lock);
|
| + for (i = 0; i < num_urbs; i++) {
|
| + if (urb == tpriv->iso_urbs[i]) {
|
| + urb_idx = i + 1;
|
| + break;
|
| + }
|
| + }
|
| + if (urb_idx == 0) {
|
| + usbi_err(TRANSFER_CTX(transfer), "could not locate urb!");
|
| + usbi_mutex_unlock(&itransfer->lock);
|
| + return LIBUSB_ERROR_NOT_FOUND;
|
| + }
|
| +
|
| + usbi_dbg("handling completion status %d of iso urb %d/%d", urb->status,
|
| + urb_idx, num_urbs);
|
| +
|
| + /* copy isochronous results back in */
|
| +
|
| + for (i = 0; i < urb->number_of_packets; i++) {
|
| + struct usbfs_iso_packet_desc *urb_desc = &urb->iso_frame_desc[i];
|
| + struct libusb_iso_packet_descriptor *lib_desc =
|
| + &transfer->iso_packet_desc[tpriv->iso_packet_offset++];
|
| + lib_desc->status = urb_desc->status;
|
| + lib_desc->actual_length = urb_desc->actual_length;
|
| + }
|
| +
|
| + tpriv->num_retired++;
|
| +
|
| + if (tpriv->reap_action != NORMAL) { /* cancelled or submit_fail */
|
| + usbi_dbg("CANCEL: urb status %d", urb->status);
|
| +
|
| + if (status == LIBUSB_TRANSFER_COMPLETED)
|
| + status = LIBUSB_TRANSFER_ERROR;
|
| +
|
| + if (tpriv->num_retired == num_urbs) {
|
| + usbi_dbg("CANCEL: last URB handled, reporting");
|
| + free_iso_urbs(tpriv);
|
| + if (tpriv->reap_action == CANCELLED) {
|
| + usbi_mutex_unlock(&itransfer->lock);
|
| + return usbi_handle_transfer_cancellation(itransfer);
|
| + } else {
|
| + usbi_mutex_unlock(&itransfer->lock);
|
| + return usbi_handle_transfer_completion(itransfer,
|
| + LIBUSB_TRANSFER_ERROR);
|
| + }
|
| + }
|
| + goto out;
|
| + }
|
| +
|
| + switch (urb->status) {
|
| + case 0:
|
| + break;
|
| + case -ENOENT: /* cancelled */
|
| + break;
|
| + case -ESHUTDOWN:
|
| + usbi_dbg("device removed");
|
| + status = LIBUSB_TRANSFER_NO_DEVICE;
|
| + break;
|
| + case -ETIME:
|
| + case -EPROTO:
|
| + case -EILSEQ:
|
| + usbi_dbg("low-level USB error %d", urb->status);
|
| + break;
|
| + default:
|
| + usbi_warn(TRANSFER_CTX(transfer),
|
| + "unrecognised urb status %d", urb->status);
|
| + break;
|
| + }
|
| +
|
| + /* if we're the last urb or we got less data than requested then we're
|
| + * done */
|
| + if (urb_idx == num_urbs) {
|
| + usbi_dbg("last URB in transfer --> complete!");
|
| + free_iso_urbs(tpriv);
|
| + usbi_mutex_unlock(&itransfer->lock);
|
| + return usbi_handle_transfer_completion(itransfer, status);
|
| + }
|
| +
|
| +out:
|
| + usbi_mutex_unlock(&itransfer->lock);
|
| + return 0;
|
| +}
|
| +
|
| +static int handle_control_completion(struct usbi_transfer *itransfer,
|
| + struct usbfs_urb *urb)
|
| +{
|
| + struct linux_transfer_priv *tpriv = usbi_transfer_get_os_priv(itransfer);
|
| + int status;
|
| +
|
| + usbi_mutex_lock(&itransfer->lock);
|
| + usbi_dbg("handling completion status %d", urb->status);
|
| +
|
| + itransfer->transferred += urb->actual_length;
|
| +
|
| + if (tpriv->reap_action == CANCELLED) {
|
| + if (urb->status != 0 && urb->status != -ENOENT)
|
| + usbi_warn(ITRANSFER_CTX(itransfer),
|
| + "cancel: unrecognised urb status %d", urb->status);
|
| + free(tpriv->urbs);
|
| + tpriv->urbs = NULL;
|
| + usbi_mutex_unlock(&itransfer->lock);
|
| + return usbi_handle_transfer_cancellation(itransfer);
|
| + }
|
| +
|
| + switch (urb->status) {
|
| + case 0:
|
| + status = LIBUSB_TRANSFER_COMPLETED;
|
| + break;
|
| + case -ENOENT: /* cancelled */
|
| + status = LIBUSB_TRANSFER_CANCELLED;
|
| + break;
|
| + case -ESHUTDOWN:
|
| + usbi_dbg("device removed");
|
| + status = LIBUSB_TRANSFER_NO_DEVICE;
|
| + break;
|
| + case -EPIPE:
|
| + usbi_dbg("unsupported control request");
|
| + status = LIBUSB_TRANSFER_STALL;
|
| + break;
|
| + case -ETIME:
|
| + case -EPROTO:
|
| + case -EILSEQ:
|
| + usbi_dbg("low-level bus error occurred");
|
| + status = LIBUSB_TRANSFER_ERROR;
|
| + break;
|
| + default:
|
| + usbi_warn(ITRANSFER_CTX(itransfer),
|
| + "unrecognised urb status %d", urb->status);
|
| + status = LIBUSB_TRANSFER_ERROR;
|
| + break;
|
| + }
|
| +
|
| + free(tpriv->urbs);
|
| + tpriv->urbs = NULL;
|
| + usbi_mutex_unlock(&itransfer->lock);
|
| + return usbi_handle_transfer_completion(itransfer, status);
|
| +}
|
| +
|
| +static int reap_for_handle(struct libusb_device_handle *handle)
|
| +{
|
| + struct linux_device_handle_priv *hpriv = _device_handle_priv(handle);
|
| + int r;
|
| + struct usbfs_urb *urb;
|
| + struct usbi_transfer *itransfer;
|
| + struct libusb_transfer *transfer;
|
| +
|
| + r = ioctl(hpriv->fd, IOCTL_USBFS_REAPURBNDELAY, &urb);
|
| + if (r == -1 && errno == EAGAIN)
|
| + return 1;
|
| + if (r < 0) {
|
| + if (errno == ENODEV)
|
| + return LIBUSB_ERROR_NO_DEVICE;
|
| +
|
| + usbi_err(HANDLE_CTX(handle), "reap failed error %d errno=%d",
|
| + r, errno);
|
| + return LIBUSB_ERROR_IO;
|
| + }
|
| +
|
| + itransfer = urb->usercontext;
|
| + transfer = USBI_TRANSFER_TO_LIBUSB_TRANSFER(itransfer);
|
| +
|
| + usbi_dbg("urb type=%d status=%d transferred=%d", urb->type, urb->status,
|
| + urb->actual_length);
|
| +
|
| + switch (transfer->type) {
|
| + case LIBUSB_TRANSFER_TYPE_ISOCHRONOUS:
|
| + return handle_iso_completion(itransfer, urb);
|
| + case LIBUSB_TRANSFER_TYPE_BULK:
|
| + case LIBUSB_TRANSFER_TYPE_INTERRUPT:
|
| + return handle_bulk_completion(itransfer, urb);
|
| + case LIBUSB_TRANSFER_TYPE_CONTROL:
|
| + return handle_control_completion(itransfer, urb);
|
| + default:
|
| + usbi_err(HANDLE_CTX(handle), "unrecognised endpoint type %x",
|
| + transfer->type);
|
| + return LIBUSB_ERROR_OTHER;
|
| + }
|
| +}
|
| +
|
| +static int op_handle_events(struct libusb_context *ctx,
|
| + struct pollfd *fds, POLL_NFDS_TYPE nfds, int num_ready)
|
| +{
|
| + int r;
|
| + int i = 0;
|
| +
|
| + usbi_mutex_lock(&ctx->open_devs_lock);
|
| + for (i = 0; i < nfds && num_ready > 0; i++) {
|
| + struct pollfd *pollfd = &fds[i];
|
| + struct libusb_device_handle *handle;
|
| + struct linux_device_handle_priv *hpriv = NULL;
|
| +
|
| + if (!pollfd->revents)
|
| + continue;
|
| +
|
| + num_ready--;
|
| + list_for_each_entry(handle, &ctx->open_devs, list, struct libusb_device_handle) {
|
| + hpriv = _device_handle_priv(handle);
|
| + if (hpriv->fd == pollfd->fd)
|
| + break;
|
| + }
|
| +
|
| + if (pollfd->revents & POLLERR) {
|
| + usbi_remove_pollfd(HANDLE_CTX(handle), hpriv->fd);
|
| + usbi_handle_disconnect(handle);
|
| + continue;
|
| + }
|
| +
|
| + r = reap_for_handle(handle);
|
| + if (r == 1 || r == LIBUSB_ERROR_NO_DEVICE)
|
| + continue;
|
| + else if (r < 0)
|
| + goto out;
|
| + }
|
| +
|
| + r = 0;
|
| +out:
|
| + usbi_mutex_unlock(&ctx->open_devs_lock);
|
| + return r;
|
| +}
|
| +
|
| +static int op_clock_gettime(int clk_id, struct timespec *tp)
|
| +{
|
| + switch (clk_id) {
|
| + case USBI_CLOCK_MONOTONIC:
|
| + return clock_gettime(monotonic_clkid, tp);
|
| + case USBI_CLOCK_REALTIME:
|
| + return clock_gettime(CLOCK_REALTIME, tp);
|
| + default:
|
| + return LIBUSB_ERROR_INVALID_PARAM;
|
| + }
|
| +}
|
| +
|
| +#ifdef USBI_TIMERFD_AVAILABLE
|
| +static clockid_t op_get_timerfd_clockid(void)
|
| +{
|
| + return monotonic_clkid;
|
| +
|
| +}
|
| +#endif
|
| +
|
| +const struct usbi_os_backend linux_usbfs_backend = {
|
| + .name = "Linux usbfs",
|
| + .init = op_init,
|
| + .exit = NULL,
|
| + .get_device_list = op_get_device_list,
|
| + .get_device_descriptor = op_get_device_descriptor,
|
| + .get_active_config_descriptor = op_get_active_config_descriptor,
|
| + .get_config_descriptor = op_get_config_descriptor,
|
| +
|
| + .open = op_open,
|
| + .close = op_close,
|
| + .get_configuration = op_get_configuration,
|
| + .set_configuration = op_set_configuration,
|
| + .claim_interface = op_claim_interface,
|
| + .release_interface = op_release_interface,
|
| +
|
| + .set_interface_altsetting = op_set_interface,
|
| + .clear_halt = op_clear_halt,
|
| + .reset_device = op_reset_device,
|
| +
|
| + .kernel_driver_active = op_kernel_driver_active,
|
| + .detach_kernel_driver = op_detach_kernel_driver,
|
| + .attach_kernel_driver = op_attach_kernel_driver,
|
| +
|
| + .destroy_device = op_destroy_device,
|
| +
|
| + .submit_transfer = op_submit_transfer,
|
| + .cancel_transfer = op_cancel_transfer,
|
| + .clear_transfer_priv = op_clear_transfer_priv,
|
| +
|
| + .handle_events = op_handle_events,
|
| +
|
| + .clock_gettime = op_clock_gettime,
|
| +
|
| +#ifdef USBI_TIMERFD_AVAILABLE
|
| + .get_timerfd_clockid = op_get_timerfd_clockid,
|
| +#endif
|
| +
|
| + .device_priv_size = sizeof(struct linux_device_priv),
|
| + .device_handle_priv_size = sizeof(struct linux_device_handle_priv),
|
| + .transfer_priv_size = sizeof(struct linux_transfer_priv),
|
| + .add_iso_packet_size = 0,
|
| +};
|
| +
|
|
|