From: Hans Verkuil <hans.verk...@cisco.com>

Alpha quality only at the moment.

Signed-off-by: Hans Verkuil <hans.verkuil at cisco.com>
---
 MAINTAINERS                           |   7 +
 drivers/media/usb/Kconfig             |   5 +
 drivers/media/usb/Makefile            |   1 +
 drivers/media/usb/pulse8/Kconfig      |  10 +
 drivers/media/usb/pulse8/Makefile     |   1 +
 drivers/media/usb/pulse8/pulse8-cec.c | 412 ++++++++++++++++++++++++++++++++++
 include/uapi/linux/serio.h            |   1 +
 7 files changed, 437 insertions(+)
 create mode 100644 drivers/media/usb/pulse8/Kconfig
 create mode 100644 drivers/media/usb/pulse8/Makefile
 create mode 100644 drivers/media/usb/pulse8/pulse8-cec.c

diff --git a/MAINTAINERS b/MAINTAINERS
index 0e43b30..734d177 100644
--- a/MAINTAINERS
+++ b/MAINTAINERS
@@ -8962,6 +8962,13 @@ F:       include/linux/tracehook.h
 F:     include/uapi/linux/ptrace.h
 F:     kernel/ptrace.c

+PULSE8-CEC DRIVER
+M:     Hans Verkuil <hverkuil at xs4all.nl>
+L:     linux-media at vger.kernel.org
+T:     git git://linuxtv.org/media_tree.git
+S:     Maintained
+F:     drivers/media/usb/pulse8
+
 PVRUSB2 VIDEO4LINUX DRIVER
 M:     Mike Isely <isely at pobox.com>
 L:     pvrusb2 at isely.net    (subscribers-only)
diff --git a/drivers/media/usb/Kconfig b/drivers/media/usb/Kconfig
index 7496f33..9301961 100644
--- a/drivers/media/usb/Kconfig
+++ b/drivers/media/usb/Kconfig
@@ -60,5 +60,10 @@ source "drivers/media/usb/hackrf/Kconfig"
 source "drivers/media/usb/msi2500/Kconfig"
 endif

+if MEDIA_CEC
+       comment "HDMI CEC USB devices"
+source "drivers/media/usb/pulse8/Kconfig"
+endif
+
 endif #MEDIA_USB_SUPPORT
 endif #USB
diff --git a/drivers/media/usb/Makefile b/drivers/media/usb/Makefile
index 8874ba7..468e541 100644
--- a/drivers/media/usb/Makefile
+++ b/drivers/media/usb/Makefile
@@ -12,6 +12,7 @@ obj-$(CONFIG_USB_PWC)           += pwc/
 obj-$(CONFIG_USB_AIRSPY)        += airspy/
 obj-$(CONFIG_USB_HACKRF)        += hackrf/
 obj-$(CONFIG_USB_MSI2500)       += msi2500/
+obj-$(CONFIG_USB_PULSE8_CEC)    += pulse8/
 obj-$(CONFIG_VIDEO_CPIA2) += cpia2/
 obj-$(CONFIG_VIDEO_AU0828) += au0828/
 obj-$(CONFIG_VIDEO_HDPVR)      += hdpvr/
diff --git a/drivers/media/usb/pulse8/Kconfig b/drivers/media/usb/pulse8/Kconfig
new file mode 100644
index 0000000..c6aa2d1
--- /dev/null
+++ b/drivers/media/usb/pulse8/Kconfig
@@ -0,0 +1,10 @@
+config USB_PULSE8_CEC
+       tristate "Pulse Eight HDMI CEC"
+       depends on USB_ACM && MEDIA_CEC
+       select SERIO
+       select SERIO_SERPORT
+       ---help---
+         This is a cec driver for the Pulse Eight HDMI CEC device.
+
+         To compile this driver as a module, choose M here: the
+         module will be called pulse8-cec.
diff --git a/drivers/media/usb/pulse8/Makefile 
b/drivers/media/usb/pulse8/Makefile
new file mode 100644
index 0000000..dd52d42
--- /dev/null
+++ b/drivers/media/usb/pulse8/Makefile
@@ -0,0 +1 @@
+obj-$(CONFIG_USB_PULSE8_CEC)              += pulse8-cec.o
diff --git a/drivers/media/usb/pulse8/pulse8-cec.c 
b/drivers/media/usb/pulse8/pulse8-cec.c
new file mode 100644
index 0000000..d02e5df
--- /dev/null
+++ b/drivers/media/usb/pulse8/pulse8-cec.c
@@ -0,0 +1,412 @@
+/*
+ * Pulse Eight HDMI CEC driver
+ *
+ * Copyright 2016 Hans Verkuil <hverkuil at xs4all.nl
+ *
+ * This program is free software; you can redistribute it and/or modify it
+ * under the terms of the GNU General Public License as published by the
+ * Free Software Foundation; either version of 2 of the License, or (at your
+ * option) any later version. See the file COPYING in the main directory of
+ * this archive for more details.
+ */
+
+#include <linux/completion.h>
+#include <linux/init.h>
+#include <linux/interrupt.h>
+#include <linux/kernel.h>
+#include <linux/module.h>
+#include <linux/workqueue.h>
+#include <linux/serio.h>
+#include <linux/slab.h>
+#include <linux/time.h>
+
+#include <media/cec.h>
+
+MODULE_AUTHOR("Hans Verkuil <hverkuil at xs4all.nl>");
+MODULE_DESCRIPTION("Pulse Eight HDMI CEC driver");
+MODULE_LICENSE("GPL");
+
+enum pulse8_msgcodes
+{
+       MSGCODE_NOTHING = 0,
+       MSGCODE_PING,
+       MSGCODE_TIMEOUT_ERROR,
+       MSGCODE_HIGH_ERROR,
+       MSGCODE_LOW_ERROR,
+       MSGCODE_FRAME_START,
+       MSGCODE_FRAME_DATA,
+       MSGCODE_RECEIVE_FAILED,
+       MSGCODE_COMMAND_ACCEPTED,       /* 0x08 */
+       MSGCODE_COMMAND_REJECTED,
+       MSGCODE_SET_ACK_MASK,
+       MSGCODE_TRANSMIT,
+       MSGCODE_TRANSMIT_EOM,
+       MSGCODE_TRANSMIT_IDLETIME,
+       MSGCODE_TRANSMIT_ACK_POLARITY,
+       MSGCODE_TRANSMIT_LINE_TIMEOUT,
+       MSGCODE_TRANSMIT_SUCCEEDED,     /* 0x10 */
+       MSGCODE_TRANSMIT_FAILED_LINE,
+       MSGCODE_TRANSMIT_FAILED_ACK,
+       MSGCODE_TRANSMIT_FAILED_TIMEOUT_DATA,
+       MSGCODE_TRANSMIT_FAILED_TIMEOUT_LINE,
+       MSGCODE_FIRMWARE_VERSION,
+       MSGCODE_START_BOOTLOADER,
+       MSGCODE_GET_BUILDDATE,
+       MSGCODE_SET_CONTROLLED,         /* 0x18 */
+       MSGCODE_GET_AUTO_ENABLED,
+       MSGCODE_SET_AUTO_ENABLED,
+       MSGCODE_GET_DEFAULT_LOGICAL_ADDRESS,
+       MSGCODE_SET_DEFAULT_LOGICAL_ADDRESS,
+       MSGCODE_GET_LOGICAL_ADDRESS_MASK,
+       MSGCODE_SET_LOGICAL_ADDRESS_MASK,
+       MSGCODE_GET_PHYSICAL_ADDRESS,
+       MSGCODE_SET_PHYSICAL_ADDRESS,   /* 0x20 */
+       MSGCODE_GET_DEVICE_TYPE,
+       MSGCODE_SET_DEVICE_TYPE,
+       MSGCODE_GET_HDMI_VERSION,
+       MSGCODE_SET_HDMI_VERSION,
+       MSGCODE_GET_OSD_NAME,
+       MSGCODE_SET_OSD_NAME,
+       MSGCODE_WRITE_EEPROM,
+       MSGCODE_GET_ADAPTER_TYPE,       /* 0x28 */
+       MSGCODE_SET_ACTIVE_SOURCE,
+
+       MSGCODE_FRAME_EOM = 0x80,
+       MSGCODE_FRAME_ACK = 0x40,
+};
+
+#define DATA_SIZE 256
+
+struct pulse8 {
+       struct device *dev;
+       struct serio *serio;
+       struct cec_adapter *adap;
+       struct completion cmd_done;
+       struct work_struct work;
+       struct cec_msg rx_msg;
+       u8 data[DATA_SIZE];
+       unsigned int len;
+       u8 buf[DATA_SIZE];
+       unsigned int idx;
+       bool escape;
+       bool started;
+};
+
+void pulse8_irq_work_handler(struct work_struct *work)
+{
+       struct pulse8 *pulse8 =
+               container_of(work, struct pulse8, work);
+
+       switch (pulse8->data[0]) {
+       case MSGCODE_FRAME_START:
+               break;
+       case MSGCODE_FRAME_DATA:
+               break;
+       case MSGCODE_TRANSMIT_SUCCEEDED:
+               cec_transmit_done(pulse8->adap, CEC_TX_STATUS_OK, 0, 0, 0, 0);
+               break;
+       case MSGCODE_TRANSMIT_FAILED_LINE:
+               cec_transmit_done(pulse8->adap, CEC_TX_STATUS_ARB_LOST, 1, 0, 
0, 0);
+               break;
+       case MSGCODE_TRANSMIT_FAILED_ACK:
+               cec_transmit_done(pulse8->adap, CEC_TX_STATUS_NACK, 0, 1, 0, 0);
+               break;
+       case MSGCODE_TRANSMIT_FAILED_TIMEOUT_DATA:
+       case MSGCODE_TRANSMIT_FAILED_TIMEOUT_LINE:
+               cec_transmit_done(pulse8->adap, CEC_TX_STATUS_ERROR, 0, 0, 0, 
1);
+               break;
+       }
+}
+
+static irqreturn_t pulse8_interrupt(struct serio *serio, unsigned char data,
+                                  unsigned int flags)
+{
+       struct pulse8 *pulse8 = serio_get_drvdata(serio);
+
+       if (!pulse8->started && data != 0xff)
+               return IRQ_HANDLED;
+       if (data == 0xfd) {
+               pulse8->escape = true;
+               return IRQ_HANDLED;
+       }
+       if (pulse8->escape) {
+               data += 0xfd;
+               pulse8->escape = false;
+       } else if (data == 0xfe) {
+               if (pulse8->idx) {
+                       dev_info(pulse8->dev, "received: %*ph\n", pulse8->idx, 
pulse8->buf);
+                       memcpy(pulse8->data, pulse8->buf, pulse8->idx);
+                       pulse8->len = pulse8->idx;
+                       complete(&pulse8->cmd_done);
+               }
+               pulse8->idx = 0;
+               pulse8->started = false;
+               switch (pulse8->data[0]) {
+               case MSGCODE_FRAME_START:
+               case MSGCODE_FRAME_DATA:
+               case MSGCODE_TRANSMIT_SUCCEEDED:
+               case MSGCODE_TRANSMIT_FAILED_LINE:
+               case MSGCODE_TRANSMIT_FAILED_ACK:
+               case MSGCODE_TRANSMIT_FAILED_TIMEOUT_DATA:
+               case MSGCODE_TRANSMIT_FAILED_TIMEOUT_LINE:
+                       schedule_work(&pulse8->work);
+                       break;
+               case MSGCODE_COMMAND_ACCEPTED:
+               case MSGCODE_COMMAND_REJECTED:
+               default:
+                       break;
+               }
+               return IRQ_HANDLED;
+       } else if (data == 0xff) {
+               pulse8->idx = 0;
+               pulse8->started = true;
+               return IRQ_HANDLED;
+       }
+
+       if (pulse8->idx >= DATA_SIZE) {
+               dev_dbg(pulse8->dev,
+                       "throwing away %d bytes of garbage\n", pulse8->idx);
+               pulse8->idx = 0;
+       }
+       pulse8->buf[pulse8->idx++] = data;
+       return IRQ_HANDLED;
+}
+
+static void pulse8_disconnect(struct serio *serio)
+{
+       struct pulse8 *pulse8 = serio_get_drvdata(serio);
+
+       cec_unregister_adapter(pulse8->adap);
+       dev_info(&serio->dev, "disconnected\n");
+       serio_close(serio);
+       serio_set_drvdata(serio, NULL);
+       kfree(pulse8);
+}
+
+static int pulse8_send(struct serio *serio, const u8 *command, u8 cmd_len)
+{
+       int err = 0;
+
+       err = serio_write(serio, 0xff);
+       if (err)
+               return err;
+       for (; !err && cmd_len; command++, cmd_len--) {
+               if (*command >= 0xfd) {
+                       err = serio_write(serio, 0xfd);
+                       if (!err)
+                               err = serio_write(serio, *command - 0xfd);
+               } else {
+                       err = serio_write(serio, *command);
+               }
+       }
+       if (!err)
+               err = serio_write(serio, 0xfe);
+
+       return err;
+}
+
+static int pulse8_send_and_wait(struct pulse8 *pulse8,
+                                const u8 *cmd, u8 cmd_len, u8 response, u8 
size)
+{
+       int err;
+
+       init_completion(&pulse8->cmd_done);
+
+       err = pulse8_send(pulse8->serio, cmd, cmd_len);
+       if (err)
+               return err;
+
+       if (!wait_for_completion_timeout(&pulse8->cmd_done, HZ))
+               return -ETIMEDOUT;
+       if (response && ((pulse8->data[0] & 0x3f) != response || pulse8->len < 
size + 1))
+               return -EIO;
+       return 0;
+}
+
+static int pulse8_setup(struct pulse8 *pulse8, struct serio *serio)
+{
+       u8 *data = pulse8->data + 1;
+       unsigned int vers = 0;
+       u8 cmd[2];
+       int err;
+
+       cmd[0] = MSGCODE_PING;
+       err = pulse8_send_and_wait(pulse8, cmd, 1,
+                                  MSGCODE_COMMAND_ACCEPTED, 0);
+       cmd[0] = MSGCODE_FIRMWARE_VERSION;
+       if (!err)
+               err = pulse8_send_and_wait(pulse8, cmd, 1, cmd[0], 2);
+       if (!err) {
+               vers = (data[0] << 8) | data[1];
+
+               dev_info(pulse8->dev, "Firmware version %04x\n", vers);
+               if (vers < 2)
+                       return 0;
+       }
+       if (vers >= 2) {
+               cmd[0] = MSGCODE_SET_CONTROLLED;
+               cmd[1] = 1;
+               if (!err)
+                       err = pulse8_send_and_wait(pulse8, cmd, 2,
+                                                  MSGCODE_COMMAND_ACCEPTED, 1);
+       }
+
+       cmd[0] = MSGCODE_GET_BUILDDATE;
+       if (!err)
+               err = pulse8_send_and_wait(pulse8, cmd, 1, cmd[0], 4);
+       if (!err) {
+               time_t date = (data[0] << 24) | (data[1] << 16) |
+                       (data[2] << 8) | data[3];
+               struct tm tm;
+
+               time_to_tm(date, 0, &tm);
+
+               dev_info(pulse8->dev, "Firmware build date %04ld.%02d.%02d 
%02d:%02d:%02d\n",
+                        tm.tm_year + 1900, tm.tm_mon + 1, tm.tm_mday,
+                        tm.tm_hour, tm.tm_min, tm.tm_sec);
+       }
+       return err;
+}
+
+static int pulse8_cec_adap_enable(struct cec_adapter *adap, bool enable)
+{
+       return 0;
+}
+
+static int pulse8_cec_adap_log_addr(struct cec_adapter *adap, u8 log_addr)
+{
+       struct pulse8 *pulse8 = adap->priv;
+       u16 mask = 0;
+       u8 cmd[3];
+       int err;
+
+       if (log_addr != CEC_LOG_ADDR_INVALID)
+               mask = 1 << log_addr;
+       cmd[0] = MSGCODE_SET_ACK_MASK;
+       cmd[1] = mask >> 8;
+       cmd[2] = mask & 0xff;
+       err = pulse8_send_and_wait(pulse8, cmd, 3,
+                                  MSGCODE_COMMAND_ACCEPTED, 0);
+       if (mask == 0)
+               return 0;
+       return err;
+}
+
+static int pulse8_cec_adap_transmit(struct cec_adapter *adap, u8 attempts,
+                                  u32 signal_free_time, struct cec_msg *msg)
+{
+       struct pulse8 *pulse8 = adap->priv;
+       u8 cmd[2];
+       unsigned int i;
+       int err;
+
+       cmd[0] = MSGCODE_TRANSMIT_ACK_POLARITY;
+       cmd[1] = cec_msg_is_broadcast(msg);
+       err = pulse8_send_and_wait(pulse8, cmd, 2,
+                                  MSGCODE_COMMAND_ACCEPTED, 1);
+       cmd[0] = msg->len == 0 ? MSGCODE_TRANSMIT_EOM : MSGCODE_TRANSMIT;
+       cmd[1] = msg->msg[0];
+       if (!err)
+               err = pulse8_send_and_wait(pulse8, cmd, 2,
+                                          MSGCODE_COMMAND_ACCEPTED, 1);
+       if (!err && msg->len) {
+               cmd[0] = msg->len == 1 ? MSGCODE_TRANSMIT_EOM : 
MSGCODE_TRANSMIT;
+               cmd[1] = msg->msg[1];
+               err = pulse8_send_and_wait(pulse8, cmd, 2,
+                                          MSGCODE_COMMAND_ACCEPTED, 1);
+               for (i = 0; !err && i + 2 < msg->len; i++) {
+                       cmd[0] = (i + 2 == msg->len - 1) ?
+                               MSGCODE_TRANSMIT_EOM : MSGCODE_TRANSMIT;
+                       cmd[1] = msg->msg[i + 2];
+                       err = pulse8_send_and_wait(pulse8, cmd, 2,
+                                                  MSGCODE_COMMAND_ACCEPTED, 1);
+               }
+       }
+
+       return err;
+}
+
+static int pulse8_received(struct cec_adapter *adap, struct cec_msg *msg)
+{
+       return -ENOMSG;
+}
+
+const struct cec_adap_ops pulse8_cec_adap_ops = {
+       .adap_enable = pulse8_cec_adap_enable,
+       .adap_log_addr = pulse8_cec_adap_log_addr,
+       .adap_transmit = pulse8_cec_adap_transmit,
+       .received = pulse8_received,
+};
+
+static int pulse8_connect(struct serio *serio, struct serio_driver *drv)
+{
+       u32 caps = CEC_CAP_TRANSMIT | CEC_CAP_LOG_ADDRS | CEC_CAP_PHYS_ADDR |
+               CEC_CAP_PASSTHROUGH | CEC_CAP_RC | CEC_CAP_MONITOR_ALL;
+       struct pulse8 *pulse8;
+       int err = -ENOMEM;
+
+       pulse8 = kzalloc(sizeof(struct pulse8), GFP_KERNEL);
+
+       if (!pulse8)
+               return -ENOMEM;
+
+       pulse8->serio = serio;
+       pulse8->adap = cec_allocate_adapter(&pulse8_cec_adap_ops, pulse8,
+               "HDMI CEC", caps, 1, &serio->dev);
+       err = PTR_ERR_OR_ZERO(pulse8->adap);
+       if (err < 0)
+               goto free_device;
+
+       pulse8->dev = &serio->dev;
+       serio_set_drvdata(serio, pulse8);
+       INIT_WORK(&pulse8->work, pulse8_irq_work_handler);
+
+       err = serio_open(serio, drv);
+       if (err)
+               goto delete_adap;
+
+       err = pulse8_setup(pulse8, serio);
+       if (err)
+               goto close_serio;
+
+       err = cec_register_adapter(pulse8->adap);
+       if (err < 0)
+               goto close_serio;
+
+       pulse8->dev = &pulse8->adap->devnode.dev;
+       return 0;
+
+close_serio:
+       serio_close(serio);
+delete_adap:
+       cec_delete_adapter(pulse8->adap);
+       serio_set_drvdata(serio, NULL);
+free_device:
+       kfree(pulse8);
+       return err;
+}
+
+static struct serio_device_id pulse8_serio_ids[] = {
+       {
+               .type   = SERIO_RS232,
+               .proto  = SERIO_PULSE8_CEC,
+               .id     = SERIO_ANY,
+               .extra  = SERIO_ANY,
+       },
+       { 0 }
+};
+
+MODULE_DEVICE_TABLE(serio, pulse8_serio_ids);
+
+static struct serio_driver pulse8_drv = {
+       .driver         = {
+               .name   = "pulse8-cec",
+       },
+       .description    = "Pulse Eight HDMI CEC driver",
+       .id_table       = pulse8_serio_ids,
+       .interrupt      = pulse8_interrupt,
+       .connect        = pulse8_connect,
+       .disconnect     = pulse8_disconnect,
+};
+
+module_serio_driver(pulse8_drv);
diff --git a/include/uapi/linux/serio.h b/include/uapi/linux/serio.h
index c2ea169..f2447a8 100644
--- a/include/uapi/linux/serio.h
+++ b/include/uapi/linux/serio.h
@@ -78,5 +78,6 @@
 #define SERIO_TSC40    0x3d
 #define SERIO_WACOM_IV 0x3e
 #define SERIO_EGALAX   0x3f
+#define SERIO_PULSE8_CEC       0x40

 #endif /* _UAPI_SERIO_H */
-- 
2.8.1

Reply via email to