]> mj.ucw.cz Git - ursary.git/blobdiff - nocturn.c
Removed switching of ports, revived switching of outputs
[ursary.git] / nocturn.c
index e4d0af6fefc1289db4222d1507c9f841075828df..7dd788855af55e76b2c3141756786a5d0f348570 100644 (file)
--- a/nocturn.c
+++ b/nocturn.c
 
 #include <ucw/lib.h>
 #include <ucw/bitops.h>
-#include <ucw/clists.h>
-#include <ucw/gary.h>
 #include <ucw/mainloop.h>
 #include <ucw/stkstring.h>
-#include <ucw/string.h>
 
 #include <stdio.h>
 #include <string.h>
-#include <stdlib.h>
-#include <sys/poll.h>
-
-#include <libusb.h>
 
 #include "ursaryd.h"
+#include "usb.h"
 
-static libusb_context *usb_ctx;
-static libusb_device_handle *usb_dev;
-static bool usb_iface_claimed;
+static libusb_device_handle *noct_dev;
+static bool noct_iface_claimed;
 
 static void noct_error(int usb_err, char *text);
 
-static struct main_file **usb_fds;
-
-static int usb_fd_ready(struct main_file *f UNUSED)
-{
-  DBG("USB: Handling events (ready on fd %d)", f->fd);
-  struct timeval tv = { 0, 0 };
-  int comp = 0;
-  int err = libusb_handle_events_timeout_completed(usb_ctx, &tv, &comp);
-  if (err < 0)
-    msg(L_ERROR, "libusb_handle_events: error %d", err);
-  return HOOK_IDLE;
-}
-
-static void usb_added_fd(int fd, short events, void *user_data UNUSED)
-{
-  if (fd >= (int) GARY_SIZE(usb_fds))
-    GARY_RESIZE(usb_fds, fd + 1);
-
-  struct main_file *f = usb_fds[fd];
-  if (!f)
-    {
-      f = xmalloc_zero(sizeof(*f));
-      usb_fds[fd] = f;
-    }
-  else if (file_is_active(f))
-    {
-      DBG("USB: Releasing fd %d", fd);
-      file_del(f);
-    }
-
-  DBG("USB: Adding fd %d with event mask %u", fd, events);
-  f->fd = fd;
-  f->read_handler = (events & POLLIN) ? usb_fd_ready : NULL;
-  f->write_handler = (events & POLLOUT) ? usb_fd_ready : NULL;
-  file_add(f);
-}
-
-static void usb_removed_fd(int fd, void *user_data UNUSED)
-{
-  DBG("USB: Releasing fd %d", fd);
-  ASSERT(fd < (int) GARY_SIZE(usb_fds));
-  struct main_file *f = usb_fds[fd];
-  ASSERT(f);
-  ASSERT(file_is_active(f));
-  file_del(f);
-}
-
 static const char noct_magic[4][9] = {
   { 3, 0xb0, 0x00, 0x00 },
   { 8, 0x28, 0x00, 0x2b, 0x4a, 0x2c, 0x00, 0x2e, 0x35 },
@@ -95,7 +41,7 @@ static void noct_read_done(struct libusb_transfer *xfer)
 {
   byte *pkt = xfer->buffer;
   int len = xfer->actual_length;
-  DBG("USB: Read done: status %d, length %d", xfer->status, len);
+  DBG("Noct: Read done: status %d, length %d", xfer->status, len);
   noct_read_pending = 0;
 
   if (xfer->status != LIBUSB_TRANSFER_COMPLETED)
@@ -104,7 +50,7 @@ static void noct_read_done(struct libusb_transfer *xfer)
 #ifdef LOCAL_DEBUG
   char buf[256];
   mem_to_hex(buf, pkt, len, ' ');
-  DBG("USB: Read <%s>", buf);
+  DBG("Noct: Read <%s>", buf);
 #endif
 
   int i = 0;
@@ -216,7 +162,7 @@ static void noct_read_init(void)
   DBG("Noct: Read init");
 
   noct_read_xfer = libusb_alloc_transfer(0);
-  libusb_fill_interrupt_transfer(noct_read_xfer, usb_dev, 0x81, xmalloc(8), 8, noct_read_done, NULL, 0);
+  libusb_fill_interrupt_transfer(noct_read_xfer, noct_dev, 0x81, xmalloc(8), 8, noct_read_done, NULL, 0);
 
   int err;
   if ((err = libusb_submit_transfer(noct_read_xfer)) < 0)
@@ -240,7 +186,7 @@ static void noct_sched_write(void);
 static void noct_write_done(struct libusb_transfer *xfer)
 {
   int len = xfer->actual_length;
-  DBG("USB: Write done: status %d, length %d", xfer->status, len);
+  DBG("Noct: Write done: status %d, length %d", xfer->status, len);
 
   if (xfer->status != LIBUSB_TRANSFER_COMPLETED)
     return noct_error(0, stk_printf("USB write failed with status %d", xfer->status));
@@ -253,7 +199,7 @@ static void noct_write_done(struct libusb_transfer *xfer)
 
 static void noct_do_write(uint cmd, uint arg)
 {
-  DBG("USB: Submitting write %02x %02x", cmd, arg);
+  DBG("Noct: Submitting write %02x %02x", cmd, arg);
   ASSERT(!noct_write_pending);
   noct_write_pending = 1;
 
@@ -270,7 +216,7 @@ static void noct_do_write(uint cmd, uint arg)
 
 static void noct_sched_write(void)
 {
-  if (!usb_dev || noct_write_pending)
+  if (!noct_dev || noct_write_pending)
     return;
 
   if (noct_dirty_button)
@@ -341,7 +287,7 @@ static void noct_write_init(void)
   DBG("Noct: Write init");
 
   noct_write_xfer = libusb_alloc_transfer(0);
-  libusb_fill_interrupt_transfer(noct_write_xfer, usb_dev, 0x02, xmalloc(8), 0, noct_write_done, NULL, 1000);
+  libusb_fill_interrupt_transfer(noct_write_xfer, noct_dev, 0x02, xmalloc(8), 0, noct_write_done, NULL, 1000);
 
   bzero(noct_button_pressed, sizeof(noct_button_pressed));
   bzero(noct_rotary_touched, sizeof(noct_rotary_touched));
@@ -391,24 +337,24 @@ static void noct_connect(struct main_timer *t)
 
   DBG("Initializing Nocturn");
 
-  if ((err = libusb_open(found_dev, &usb_dev)) < 0)
+  if ((err = libusb_open(found_dev, &noct_dev)) < 0)
     return noct_error(err, "libusb_open failed");
 
   // In newer kernels, Nocturn is claimed by snd-usb-audio. Tell it to surrender the device.
-  libusb_detach_kernel_driver(usb_dev, 0);
+  libusb_detach_kernel_driver(noct_dev, 0);
 
   // There exist configurations 1 (high brightness) and 2 (power-save)
-  if ((err = libusb_set_configuration(usb_dev, 2)) < 0)
+  if ((err = libusb_set_configuration(noct_dev, 2)) < 0)
     return noct_error(err, "libusb_set_configuration failed");
 
-  if ((err = libusb_claim_interface(usb_dev, 0)) < 0)
+  if ((err = libusb_claim_interface(noct_dev, 0)) < 0)
     return noct_error(err, "libusb_claim_interface failed");
-  usb_iface_claimed = 1;
+  noct_iface_claimed = 1;
 
   for (int i=0; i<4; i++)
     {
       int done;
-      if ((err = libusb_interrupt_transfer(usb_dev, 0x02, (byte *) noct_magic[i] + 1, noct_magic[i][0], &done, 5000)) < 0)
+      if ((err = libusb_interrupt_transfer(noct_dev, 0x02, (byte *) noct_magic[i] + 1, noct_magic[i][0], &done, 5000)) < 0)
        return noct_error(err, "Cannot send init packets");
       if (done != noct_magic[i][0])
        return noct_error(err, stk_printf("Partial send of init packet (%d < %d)", done, noct_magic[i][0]));
@@ -424,7 +370,7 @@ static int noct_error_handler(struct main_hook *h)
   DBG("Noct: Entered error handling hook");
   hook_del(h);
 
-  if (usb_dev)
+  if (noct_dev)
     {
       if (noct_read_xfer)
        {
@@ -452,16 +398,16 @@ static int noct_error_handler(struct main_hook *h)
          libusb_free_transfer(noct_write_xfer);
          noct_write_xfer = NULL;
        }
-      if (usb_iface_claimed)
+      if (noct_iface_claimed)
        {
          DBG("Noct: Unclaiming interface");
-         libusb_release_interface(usb_dev, 0);
-         usb_iface_claimed = 0;
+         libusb_release_interface(noct_dev, 0);
+         noct_iface_claimed = 0;
        }
       DBG("Noct: Resetting device");
-      libusb_reset_device(usb_dev);
-      libusb_close(usb_dev);
-      usb_dev = NULL;
+      libusb_reset_device(noct_dev);
+      libusb_close(noct_dev);
+      noct_dev = NULL;
     }
 
   DBG("Noct: Scheduling rescan after error");
@@ -483,32 +429,11 @@ static void noct_error(int usb_err, char *text)
 
 bool noct_is_ready(void)
 {
-  return !!usb_dev;
+  return !!noct_dev;
 }
 
 void noct_init(void)
 {
-  int err;
-
-  // Initialize libusb
-  if ((err = libusb_init(&usb_ctx)) < 0)
-    die("libusb_init failed: error %d", err);
-  libusb_set_debug(usb_ctx, 3);
-
-  // Connect libusb to UCW mainloop
-
-  if (!libusb_pollfds_handle_timeouts(usb_ctx))
-    die("Unsupported version of libusb, please fix me");
-
-  GARY_INIT_ZERO(usb_fds, 0);
-  libusb_set_pollfd_notifiers(usb_ctx, usb_added_fd, usb_removed_fd, NULL);
-
-  const struct libusb_pollfd **fds = libusb_get_pollfds(usb_ctx);
-  ASSERT(fds);
-  for (int i=0; fds[i]; i++)
-    usb_added_fd(fds[i]->fd, fds[i]->events, NULL);
-  free(fds);
-
   // Prepare error handling hook
   noct_error_hook.handler = noct_error_handler;