Em Fri, 29 Apr 2016 15:52:19 +0200
Hans Verkuil <hverkuil@xxxxxxxxx> escreveu:
> From: Hans Verkuil <hansverk@xxxxxxxxx>
>
> The added HDMI CEC framework provides a generic kernel interface for
> HDMI CEC devices.
>
> Besides the cec module itself it also adds a cec-edid module that
> contains helper functions to find and manipulate the CEC physical
> address inside an EDID. Even if the CEC support itself is disabled,
> drivers will still need these functions.
>
> Note that the CEC framework is added to staging/media and that the
> cec.h and cec-funcs.h headers are not exported yet. While the kABI
> is mature, I would prefer to allow the uABI some more time before
> it is mainlined in case it needs more tweaks.
As pointed via IRC, it sounds like checkpatch were never used
on this patch series. Just this one got more than 100 errors/warnings:
total: 6 errors, 107 warnings, 5895 lines checked
NOTE: For some of the reported defects, checkpatch may be able to
mechanically convert to the typical style using --fix or --fix-inplace.
Please fix, except if you have a good reason why not follow the
CodingStyle.
>
> Signed-off-by: Hans Verkuil <hans.verkuil@xxxxxxxxx>
> [k.debski@xxxxxxxxxxx: Merged CEC Updates commit by Hans Verkuil]
> [k.debski@xxxxxxxxxxx: Merged Update author commit by Hans Verkuil]
> [k.debski@xxxxxxxxxxx: change kthread handling when setting logical
> address]
> [k.debski@xxxxxxxxxxx: code cleanup and fixes]
> [k.debski@xxxxxxxxxxx: add missing CEC commands to match spec]
> [k.debski@xxxxxxxxxxx: add RC framework support]
> [k.debski@xxxxxxxxxxx: move and edit documentation]
> [k.debski@xxxxxxxxxxx: add vendor id reporting]
> [k.debski@xxxxxxxxxxx: add possibility to clear assigned logical
> addresses]
> [k.debski@xxxxxxxxxxx: documentation fixes, clenaup and expansion]
> [k.debski@xxxxxxxxxxx: reorder of API structs and add reserved fields]
> [k.debski@xxxxxxxxxxx: fix handling of events and fix 32/64bit timespec
> problem]
> [k.debski@xxxxxxxxxxx: add sequence number handling]
> [k.debski@xxxxxxxxxxx: add passthrough mode]
> [k.debski@xxxxxxxxxxx: fix CEC defines, add missing CEC 2.0 commands]
> minor additions]
> Signed-off-by: Kamil Debski <kamil@xxxxxxxxx>
> ---
> MAINTAINERS | 16 +
> drivers/media/Kconfig | 3 +
> drivers/media/Makefile | 2 +
> drivers/media/cec-edid.c | 139 ++
> drivers/staging/media/Kconfig | 2 +
> drivers/staging/media/Makefile | 1 +
> drivers/staging/media/cec/Kconfig | 8 +
> drivers/staging/media/cec/Makefile | 1 +
> drivers/staging/media/cec/cec.c | 2481 ++++++++++++++++++++++++++++++++++++
> include/linux/cec-funcs.h | 1871 +++++++++++++++++++++++++++
> include/linux/cec.h | 985 ++++++++++++++
> include/media/cec-edid.h | 103 ++
> include/media/cec.h | 236 ++++
> 13 files changed, 5848 insertions(+)
> create mode 100644 drivers/media/cec-edid.c
> create mode 100644 drivers/staging/media/cec/Kconfig
> create mode 100644 drivers/staging/media/cec/Makefile
> create mode 100644 drivers/staging/media/cec/cec.c
> create mode 100644 include/linux/cec-funcs.h
> create mode 100644 include/linux/cec.h
> create mode 100644 include/media/cec-edid.h
> create mode 100644 include/media/cec.h
>
> diff --git a/MAINTAINERS b/MAINTAINERS
> index bfcb7ea..83bd865 100644
> --- a/MAINTAINERS
> +++ b/MAINTAINERS
> @@ -2760,6 +2760,22 @@ F: drivers/net/ieee802154/cc2520.c
> F: include/linux/spi/cc2520.h
> F: Documentation/devicetree/bindings/net/ieee802154/cc2520.txt
>
> +CEC DRIVER
> +M: Hans Verkuil <hans.verkuil@xxxxxxxxx>
> +L: linux-media@xxxxxxxxxxxxxxx
> +T: git git://linuxtv.org/media_tree.git
> +W: http://linuxtv.org
> +S: Supported
> +F: Documentation/cec.txt
> +F: Documentation/DocBook/media/v4l/cec*
Not sure about the above. We're in the process of changing the
documentation engines at the Kernel, and the docs location will
likely change soon enough.
> +F: drivers/staging/media/cec/cec.c
> +F: drivers/media/cec-edid.c
> +F: drivers/media/rc/keymaps/rc-cec.c
> +F: include/media/cec.h
> +F: include/media/cec-edid.h
> +F: include/linux/cec.h
> +F: include/linux/cec-funcs.h
> +
> CELL BROADBAND ENGINE ARCHITECTURE
> M: Arnd Bergmann <arnd@xxxxxxxx>
> L: linuxppc-dev@xxxxxxxxxxxxxxxx
> diff --git a/drivers/media/Kconfig b/drivers/media/Kconfig
> index a8518fb..052dcf7 100644
> --- a/drivers/media/Kconfig
> +++ b/drivers/media/Kconfig
> @@ -80,6 +80,9 @@ config MEDIA_RC_SUPPORT
>
> Say Y when you have a TV or an IR device.
>
> +config MEDIA_CEC_EDID
> + tristate
> +
> #
> # Media controller
> # Selectable only for webcam/grabbers, as other drivers don't use it
> diff --git a/drivers/media/Makefile b/drivers/media/Makefile
> index e608bbc..b56f013 100644
> --- a/drivers/media/Makefile
> +++ b/drivers/media/Makefile
> @@ -2,6 +2,8 @@
> # Makefile for the kernel multimedia device drivers.
> #
>
> +obj-$(CONFIG_MEDIA_CEC_EDID) += cec-edid.o
> +
> media-objs := media-device.o media-devnode.o media-entity.o
>
> #
> diff --git a/drivers/media/cec-edid.c b/drivers/media/cec-edid.c
> new file mode 100644
> index 0000000..50202d8
> --- /dev/null
> +++ b/drivers/media/cec-edid.c
> @@ -0,0 +1,139 @@
> +/*
> + * cec-edid - HDMI Consumer Electronics Control EDID & CEC helper functions
> + *
> + * Copyright 2016 Cisco Systems, Inc. and/or its affiliates. All rights reserved.
> + *
> + * This program is free software; you may redistribute it and/or modify
> + * it under the terms of the GNU General Public License as published by
> + * the Free Software Foundation; version 2 of the License.
> + *
> + * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND,
> + * EXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF
> + * MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND
> + * NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT HOLDERS
> + * BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN AN
> + * ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN
> + * CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE
> + * SOFTWARE.
> + */
> +
> +#include <linux/module.h>
> +#include <linux/kernel.h>
> +#include <linux/types.h>
> +#include <linux/cec.h>
> +#include <media/cec-edid.h>
> +
> +static unsigned cec_get_edid_spa_location(const u8 *edid, unsigned size)
> +{
> + u8 d;
> +
> + if (size < 256)
> + return 0;
> +
> + if (edid[0x7e] != 1 || edid[0x80] != 0x02 || edid[0x81] != 0x03)
> + return 0;
Hmm... looking at E-EDID spec:
http://read.pudn.com/downloads110/ebook/456020/E-EDID%20Standard.pdf
you're expecting that EDID will have just *one* extension? If so, please
state so, adding a FIXME to warn about future needs to change the code
to support bigger EDID data. Also, in such case, the EDID size should
always be 256.
I would also check the checksum, to be sure that the vendor specific
data block is not pointing to some invalid location.
> +
> + /* search Vendor Specific Data Block (tag 3) */
> + d = edid[0x82] & 0x7f;
> + if (d > 4) {
> + int i = 0x84;
> + int end = 0x80 + d;
> +
> + do {
> + u8 tag = edid[i] >> 5;
> + u8 len = edid[i] & 0x1f;
> +
> + if (tag == 3 && len >= 5)
> + return i + 4;
> + i += len + 1;
> + } while (i < end);
> + }
It looked weird that check for size at the beginning, since the size
is not being used in the routine itself. Ok, after looking at the
code 3 or 4 times, I understood that you're implicitly using the
size at the "end" variable, as you're doing a loop between
'd', with ranges from 0 to 0x7f
'end', with ranges from 0x85 to 0xff.
'i', ranging from 0x84 to 0xfe.
return value, ranging from 0x88 to 0x102 (i + 4)
As the code seems to rely on having just one extension, allowing to go
past 0xff seems a mistake.
I guess the loop should be checking if it won't return a value
past of the EDID array.
> + return 0;
> +}
> +
> +u16 cec_get_edid_phys_addr(const u8 *edid, unsigned size, unsigned *offset)
> +{
> + unsigned loc = cec_get_edid_spa_location(edid, size);
> +
> + if (offset)
> + *offset = loc;
> + if (loc == 0)
> + return CEC_PHYS_ADDR_INVALID;
> + return (edid[loc] << 8) | edid[loc + 1];
Yeah, if I'm not mistaken, you may be reading past the EDID
array here, if loc > 0xfe, and size = 256.
> +}
> +EXPORT_SYMBOL_GPL(cec_get_edid_phys_addr);
> +
> +void cec_set_edid_phys_addr(u8 *edid, unsigned size, u16 phys_addr)
> +{
> + unsigned loc = cec_get_edid_spa_location(edid, size);
> + u8 sum = 0;
> + unsigned i;
> +
> + if (loc == 0)
> + return;
> + edid[loc] = phys_addr >> 8;
> + edid[loc + 1] = phys_addr & 0xff;
> + loc &= ~0x7f;
> +
> + /* update the checksum */
> + for (i = loc; i < loc + 127; i++)
> + sum += edid[i];
> + edid[i] = 256 - sum;
Here, you can also go past the EDID array, as you're not checking the
size inside the for loop.
> +}
> +EXPORT_SYMBOL_GPL(cec_set_edid_phys_addr);
> +
> +u16 cec_phys_addr_for_input(u16 phys_addr, u8 input)
> +{
> + /* Check if input is sane */
> + if (WARN_ON(input == 0 || input > 0xf))
> + return CEC_PHYS_ADDR_INVALID;
> +
> + if (phys_addr == 0)
> + return input << 12;
> +
> + if ((phys_addr & 0x0fff) == 0)
> + return phys_addr | (input << 8);
> +
> + if ((phys_addr & 0x00ff) == 0)
> + return phys_addr | (input << 4);
> +
> + if ((phys_addr & 0x000f) == 0)
> + return phys_addr | input;
> +
> + /*
> + * All nibbles are used so no valid physical addresses can be assigned
> + * to the input.
> + */
> + return CEC_PHYS_ADDR_INVALID;
> +}
> +EXPORT_SYMBOL_GPL(cec_phys_addr_for_input);
> +
> +int cec_phys_addr_validate(u16 phys_addr, u16 *parent, u16 *port)
> +{
> + int i;
> +
> + if (parent)
> + *parent = phys_addr;
> + if (port)
> + *port = 0;
> + if (phys_addr == CEC_PHYS_ADDR_INVALID)
> + return 0;
> + for (i = 0; i < 16; i += 4)
> + if (phys_addr & (0xf << i))
> + break;
> + if (i == 16)
> + return 0;
> + if (parent)
> + *parent = phys_addr & (0xfff0 << i);
> + if (port)
> + *port = (phys_addr >> i) & 0xf;
> + for (i += 4; i < 16; i += 4)
> + if ((phys_addr & (0xf << i)) == 0)
> + return -EINVAL;
I guess you should be checking the size of the arrays here too.
> + return 0;
> +}
> +EXPORT_SYMBOL_GPL(cec_phys_addr_validate);
> +
> +MODULE_AUTHOR("Hans Verkuil <hans.verkuil@xxxxxxxxx>");
> +MODULE_DESCRIPTION("CEC EDID helper functions");
> +MODULE_LICENSE("GPL");
> diff --git a/drivers/staging/media/Kconfig b/drivers/staging/media/Kconfig
> index de7e9f5..71554d9 100644
> --- a/drivers/staging/media/Kconfig
> +++ b/drivers/staging/media/Kconfig
> @@ -21,6 +21,8 @@ if STAGING_MEDIA
> # Please keep them in alphabetic order
> source "drivers/staging/media/bcm2048/Kconfig"
>
> +source "drivers/staging/media/cec/Kconfig"
> +
> source "drivers/staging/media/cxd2099/Kconfig"
>
> source "drivers/staging/media/davinci_vpfe/Kconfig"
> diff --git a/drivers/staging/media/Makefile b/drivers/staging/media/Makefile
> index 60a35b3..1d6a828 100644
> --- a/drivers/staging/media/Makefile
> +++ b/drivers/staging/media/Makefile
> @@ -1,4 +1,5 @@
> obj-$(CONFIG_I2C_BCM2048) += bcm2048/
> +obj-$(CONFIG_MEDIA_CEC) += cec/
> obj-$(CONFIG_DVB_CXD2099) += cxd2099/
> obj-$(CONFIG_LIRC_STAGING) += lirc/
> obj-$(CONFIG_VIDEO_DM365_VPFE) += davinci_vpfe/
> diff --git a/drivers/staging/media/cec/Kconfig b/drivers/staging/media/cec/Kconfig
> new file mode 100644
> index 0000000..3297a54
> --- /dev/null
> +++ b/drivers/staging/media/cec/Kconfig
> @@ -0,0 +1,8 @@
> +config MEDIA_CEC
> + tristate "CEC API (EXPERIMENTAL)"
> + select MEDIA_CEC_EDID
> + ---help---
> + Enable the CEC API.
> +
> + To compile this driver as a module, choose M here: the
> + module will be called cec.
> diff --git a/drivers/staging/media/cec/Makefile b/drivers/staging/media/cec/Makefile
> new file mode 100644
> index 0000000..7a7532e
> --- /dev/null
> +++ b/drivers/staging/media/cec/Makefile
> @@ -0,0 +1 @@
> +obj-$(CONFIG_MEDIA_CEC) += cec.o
> diff --git a/drivers/staging/media/cec/cec.c b/drivers/staging/media/cec/cec.c
> new file mode 100644
> index 0000000..3c5f084
> --- /dev/null
> +++ b/drivers/staging/media/cec/cec.c
> @@ -0,0 +1,2481 @@
> +/*
> + * cec - HDMI Consumer Electronics Control framework
> + *
> + * Copyright 2016 Cisco Systems, Inc. and/or its affiliates. All rights reserved.
> + *
> + * This program is free software; you may redistribute it and/or modify
> + * it under the terms of the GNU General Public License as published by
> + * the Free Software Foundation; version 2 of the License.
> + *
> + * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND,
> + * EXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF
> + * MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND
> + * NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT HOLDERS
> + * BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN AN
> + * ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN
> + * CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE
> + * SOFTWARE.
> + */
> +
> +#include <linux/errno.h>
> +#include <linux/init.h>
> +#include <linux/module.h>
> +#include <linux/kernel.h>
> +#include <linux/kmod.h>
> +#include <linux/ktime.h>
> +#include <linux/slab.h>
> +#include <linux/mm.h>
> +#include <linux/string.h>
> +#include <linux/types.h>
> +#include <linux/uaccess.h>
> +#include <linux/version.h>
> +#include <media/cec-edid.h>
> +#include <media/cec.h>
> +
> +#define CEC_NUM_DEVICES 256
> +#define CEC_NAME "cec"
> +
> +static int debug;
> +module_param(debug, int, 0644);
> +MODULE_PARM_DESC(debug, "debug level (0-2)");
> +
> +/*
> + * 400 ms is the time it takes for one 16 byte message to be
> + * transferred and 5 is the maximum number of retries. Add
> + * another 100 ms as a margin. So if the transmit doesn't
> + * finish before that time something is really wrong and we
> + * have to time out.
> + *
> + * This is a sign that something it really wrong and a warning
> + * will be issued.
> + */
> +#define CEC_XFER_TIMEOUT_MS (5 * 400 + 100)
> +
> +#define dprintk(lvl, fmt, arg...) \
> + do { \
> + if (lvl <= debug) \
> + pr_info("cec-%s: " fmt, adap->name, ## arg); \
> + } while (0)
> +
> +#define call_op(adap, op, arg...) \
> + (adap->ops->op ? adap->ops->op(adap, ## arg) : 0)
> +
> +#define call_void_op(adap, op, arg...) \
> + do { \
> + if (adap->ops->op) \
> + adap->ops->op(adap, ## arg); \
> + } while (0)
> +
> +static dev_t cec_dev_t;
> +
> +/* Active devices */
> +static DEFINE_MUTEX(cec_devnode_lock);
> +static DECLARE_BITMAP(cec_devnode_nums, CEC_NUM_DEVICES);
> +
> +static struct dentry *top_cec_dir;
> +
> +/* dev to cec_devnode */
> +#define to_cec_devnode(cd) container_of(cd, struct cec_devnode, dev)
> +
> +/* devnode to cec_adapter */
> +#define to_cec_adapter(node) container_of(node, struct cec_adapter, devnode)
> +
> +static inline struct cec_devnode *cec_devnode_data(struct file *filp)
> +{
> + struct cec_fh *fh = filp->private_data;
> +
> + return &fh->adap->devnode;
> +}
> +
> +static int cec_log_addr2idx(const struct cec_adapter *adap, u8 log_addr)
> +{
> + int i;
> +
> + for (i = 0; i < adap->log_addrs.num_log_addrs; i++)
> + if (adap->log_addrs.log_addr[i] == log_addr)
> + return i;
> + return -1;
> +}
> +
> +static unsigned cec_log_addr2dev(const struct cec_adapter *adap, u8 log_addr)
> +{
> + int i = cec_log_addr2idx(adap, log_addr);
> +
> + return adap->log_addrs.primary_device_type[i < 0 ? 0 : i];
> +}
> +
> +/* Initialize the event queues for the filehandle. */
> +static int cec_queue_event_init(struct cec_fh *fh)
> +{
> + /* This has the size of the event queue for each event type. */
> + static const unsigned queue_sizes[CEC_NUM_EVENTS] = {
> + 2, /* CEC_EVENT_STATE_CHANGE */
> + 1, /* CEC_EVENT_LOST_MSGS */
> + };
Why didn't you use, instead, a c99 designated initializer at the array?
> + unsigned i;
> +
> + for (i = 0; i < CEC_NUM_EVENTS; i++) {
> + fh->evqueue[i].events = kcalloc(queue_sizes[i],
> + sizeof(struct cec_event), GFP_KERNEL);
> + if (fh->evqueue[i].events == NULL) {
> + while (i--) {
> + kfree(fh->evqueue[i].events);
> + fh->evqueue[i].events = NULL;
> + fh->evqueue[i].elems = 0;
> + }
> + return -ENOMEM;
> + }
> + fh->evqueue[i].elems = queue_sizes[i];
> + }
> + return 0;
> +}
> +
> +static void cec_queue_event_free(struct cec_fh *fh)
> +{
> + unsigned i;
> +
> + for (i = 0; i < CEC_NUM_EVENTS; i++)
> + kfree(fh->evqueue[i].events);
> +}
> +
> +/*
> + * Queue a new event for this filehandle. If ts == 0, then set it
> + * to the current time.
> + */
> +static void cec_queue_event_fh(struct cec_fh *fh,
> + const struct cec_event *new_ev, u64 ts)
> +{
> + struct cec_event_queue *evq = &fh->evqueue[new_ev->event - 1];
Shouldn't it be checking if event > 0 before instantiating event-1?
> + struct cec_event *ev;
> +
> + if (ts == 0)
> + ts = ktime_get_ns();
> +
> + mutex_lock(&fh->lock);
> + ev = evq->events + evq->num_events;
> + /* Overwrite the last event if there is no more room for the new event */
> + if (evq->num_events == evq->elems) {
> + ev--;
Wouldn't be better to make it a circular buffer and override the
oldest queued event?
Also, the loss of an event should be signaled to the users, for them
to know that a problem happened.
> + } else {
> + evq->num_events++;
> + fh->events++;
> + }
> + *ev = *new_ev;
> + ev->ts = ts;
> + mutex_unlock(&fh->lock);
> + wake_up_interruptible(&fh->wait);
> +}
> +
> +/* Queue a new event for all open filehandles. */
> +static void cec_queue_event(struct cec_adapter *adap,
> + const struct cec_event *ev)
> +{
> + u64 ts = ktime_get_ns();
> + struct cec_fh *fh;
> +
> + mutex_lock(&adap->devnode.fhs_lock);
> + list_for_each_entry(fh, &adap->devnode.fhs, list)
> + cec_queue_event_fh(fh, ev, ts);
> + mutex_unlock(&adap->devnode.fhs_lock);
> +}
> +
> +/*
> + * Queue a new message for this filehandle. If there is no more room
> + * in the queue, then send the LOST_MSGS event instead.
> + */
> +static void cec_queue_msg_fh(struct cec_fh *fh, const struct cec_msg *msg)
> +{
> + struct cec_event ev_lost_msg = {
> + .event = CEC_EVENT_LOST_MSGS,
> + };
> + struct cec_msg_entry *entry;
> +
> + mutex_lock(&fh->lock);
> + if (fh->queued_msgs == CEC_MAX_MSG_QUEUE_SZ)
> + goto lost_msgs;
> + entry = kmalloc(sizeof(*entry), GFP_KERNEL);
> + if (entry == NULL)
> + goto lost_msgs;
> +
> + entry->msg = *msg;
> + list_add(&entry->list, &fh->msgs);
> + fh->queued_msgs++;
> + mutex_unlock(&fh->lock);
> + wake_up_interruptible(&fh->wait);
> + return;
> +
> +lost_msgs:
> + ev_lost_msg.lost_msgs.lost_msgs = ++fh->lost_msgs;
> + mutex_unlock(&fh->lock);
> + cec_queue_event_fh(fh, &ev_lost_msg, 0);
> +}
> +
> +/*
> + * Queue the message for those filehandles that are in monitor mode.
> + * If valid_la is true (this message is for us or was sent by us),
> + * then pass it on to any monitoring filehandle. If this message
> + * isn't for us or from us, then only give it to filehandles that
> + * are in MONITOR_ALL mode.
> + *
> + * This can only happen if the CEC_CAP_MONITOR_ALL capability is
> + * set and the CEC adapter was placed in 'monitor all' mode.
> + */
> +static void cec_queue_msg_monitor(struct cec_adapter *adap,
> + const struct cec_msg *msg,
> + bool valid_la)
> +{
> + struct cec_fh *fh;
> + u32 monitor_mode = valid_la ? CEC_MODE_MONITOR :
> + CEC_MODE_MONITOR_ALL;
> +
> + mutex_lock(&adap->devnode.fhs_lock);
> + list_for_each_entry(fh, &adap->devnode.fhs, list) {
> + if (fh->mode_follower >= monitor_mode)
> + cec_queue_msg_fh(fh, msg);
> + }
> + mutex_unlock(&adap->devnode.fhs_lock);
> +}
> +
> +/*
> + * Queue the message for follower filehandles.
> + */
> +static void cec_queue_msg_followers(struct cec_adapter *adap,
> + const struct cec_msg *msg)
> +{
> + struct cec_fh *fh;
> +
> + mutex_lock(&adap->devnode.fhs_lock);
> + list_for_each_entry(fh, &adap->devnode.fhs, list) {
> + if (fh->mode_follower == CEC_MODE_FOLLOWER)
> + cec_queue_msg_fh(fh, msg);
> + }
> + mutex_unlock(&adap->devnode.fhs_lock);
> +}
> +
> +/* Notify userspace of an adapter state change. */
> +static void cec_post_state_event(struct cec_adapter *adap)
> +{
> + struct cec_event ev = {
> + .event = CEC_EVENT_STATE_CHANGE,
> + };
> +
> + ev.state_change.phys_addr = adap->phys_addr;
> + ev.state_change.log_addr_mask = adap->log_addrs.log_addr_mask;
> + cec_queue_event(adap, &ev);
> +}
> +
> +/*
> + * A CEC transmit (and a possible wait for reply) completed.
> + * If this was in blocking mode, then complete it, otherwise
> + * queue the message for userspace to dequeue later.
> + *
> + * This function is called with adap->lock held.
> + */
> +static void cec_data_completed(struct cec_data *data)
> +{
> + /*
> + * Delete this transmit from the filehandle's xfer_list since
> + * we're done with it.
> + *
> + * Note that if the filehandle is closed before this transmit
> + * finished, then the release() function will set data->fh to NULL.
> + * Without that we would be referring to a closed filehandle.
> + */
> + if (data->fh)
> + list_del(&data->xfer_list);
> +
> + if (data->blocking) {
> + /*
> + * Someone is blocking so mark the message as completed
> + * and call complete.
> + */
> + data->completed = true;
> + complete(&data->c);
> + } else {
> + /*
> + * No blocking, so just queue the message if needed and
> + * free the memory.
> + */
> + if (data->fh)
> + cec_queue_msg_fh(data->fh, &data->msg);
> + kfree(data);
> + }
> +}
> +
> +/*
> + * A pending CEC transmit needs to be cancelled, either because the CEC
> + * adapter is disabled or the transmit takes an impossibly long time to
> + * finish.
> + *
> + * This function is called with adap->lock held.
> + */
> +static void cec_data_cancel(struct cec_data *data)
> +{
> + /*
> + * It's either the current transmit, or it is a pending
> + * transmit. Take the appropriate action to clear it.
> + */
> + if (data->adap->transmitting == data)
> + data->adap->transmitting = NULL;
> + else
> + list_del_init(&data->list);
> +
> + /* Mark it as an error */
> + data->msg.ts = ktime_get_ns();
> + data->msg.tx_status = CEC_TX_STATUS_ERROR |
> + CEC_TX_STATUS_MAX_RETRIES;
> + data->attempts = 0;
> + data->msg.tx_error_cnt = 1;
> + data->msg.reply = 0;
> + /* Queue transmitted message for monitoring purposes */
> + cec_queue_msg_monitor(data->adap, &data->msg, 1);
> +
> + cec_data_completed(data);
> +}
> +
> +/*
> + * Main CEC state machine
> + *
> + * Wait until the thread should be stopped, or we are not transmitting and
> + * a new transmit message is queued up, in which case we start transmitting
> + * that message. When the adapter finished transmitting the message it will
> + * call cec_transmit_done().
> + *
> + * If the adapter is disabled, then remove all queued messages instead.
> + *
> + * If the current transmit times out, then cancel that transmit.
> + */
> +static int cec_thread_func(void *_adap)
> +{
> + struct cec_adapter *adap = _adap;
> +
> + for (;;) {
> + unsigned signal_free_time;
> + struct cec_data *data;
> + bool timeout = false;
> + u8 attempts;
> +
> + if (adap->transmitting) {
> + int err;
> +
> + /*
> + * We are transmitting a message, so add a timeout
> + * to prevent the state machine to get stuck waiting
> + * for this message to finalize and add a check to
> + * see if the adapter is disabled in which case the
> + * transmit should be canceled.
> + */
> + err = wait_event_interruptible_timeout(adap->kthread_waitq,
> + kthread_should_stop() ||
> + adap->phys_addr == CEC_PHYS_ADDR_INVALID ||
> + (!adap->transmitting &&
> + !list_empty(&adap->transmit_queue)),
> + msecs_to_jiffies(CEC_XFER_TIMEOUT_MS));
> + timeout = err == 0;
> + } else {
> + /* Otherwise we just wait for something to happen. */
> + wait_event_interruptible(adap->kthread_waitq,
> + kthread_should_stop() ||
> + (!adap->transmitting &&
> + !list_empty(&adap->transmit_queue)));
> + }
> +
> + mutex_lock(&adap->lock);
> +
> + if (adap->phys_addr == CEC_PHYS_ADDR_INVALID ||
> + kthread_should_stop()) {
> + /*
> + * If the adapter is disabled, or we're asked to stop,
> + * then cancel any pending transmits.
> + */
> + while (!list_empty(&adap->transmit_queue)) {
> + data = list_first_entry(&adap->transmit_queue,
> + struct cec_data, list);
> + cec_data_cancel(data);
> + }
> + while (!list_empty(&adap->wait_queue)) {
> + data = list_first_entry(&adap->wait_queue,
> + struct cec_data, list);
> + cec_data_cancel(data);
> + }
> + if (adap->transmitting)
> + cec_data_cancel(adap->transmitting);
> + goto unlock;
> + }
> +
> + if (adap->transmitting && timeout) {
> + /*
> + * If we timeout, then log that. This really shouldn't
> + * happen and is an indication of a faulty CEC adapter
> + * driver, or the CEC bus is in some weird state.
> + */
> + dprintk(0, "message %*ph timed out!\n",
> + adap->transmitting->msg.len,
> + adap->transmitting->msg.msg);
> + /* Just give up on this. */
> + cec_data_cancel(adap->transmitting);
> + goto unlock;
> + }
> +
> + /*
> + * If we are still transmitting, or there is nothing new to
> + * transmit, then just continue waiting.
> + */
> + if (adap->transmitting || list_empty(&adap->transmit_queue))
> + goto unlock;
> +
> + /* Get a new message to transmit */
> + data = list_first_entry(&adap->transmit_queue,
> + struct cec_data, list);
> + list_del_init(&data->list);
> + /* Make this the current transmitting message */
> + adap->transmitting = data;
> +
> + /*
> + * Suggested number of attempts as per the CEC 2.0 spec:
> + * 4 attempts is the default, except for 'secondary poll
> + * messages', i.e. poll messages not sent during the adapter
> + * configuration phase when it allocates logical addresses.
> + */
> + if (data->msg.len == 1 && adap->is_configured)
> + attempts = 2;
> + else
> + attempts = 4;
> +
> + /* Set the suggested signal free time */
> + if (data->attempts) {
> + /* should be >= 3 data bit periods for a retry */
> + signal_free_time = CEC_SIGNAL_FREE_TIME_RETRY;
> + } else if (data->new_initiator) {
> + /* should be >= 5 data bit periods for new initiator */
> + signal_free_time = CEC_SIGNAL_FREE_TIME_NEW_INITIATOR;
> + } else {
> + /*
> + * should be >= 7 data bit periods for sending another
> + * frame immediately after another.
> + */
> + signal_free_time = CEC_SIGNAL_FREE_TIME_NEXT_XFER;
> + }
> + if (data->attempts == 0)
> + data->attempts = attempts;
> +
> + /* Tell the adapter to transmit, cancel on error */
> + if (adap->ops->adap_transmit(adap, data->attempts,
> + signal_free_time, &data->msg))
> + cec_data_cancel(data);
> +
> +unlock:
> + mutex_unlock(&adap->lock);
> +
> + if (kthread_should_stop())
> + break;
> + }
> + return 0;
> +}
> +
> +/*
> + * Called by the CEC adapter if a transmit finished.
> + */
> +void cec_transmit_done(struct cec_adapter *adap, u8 status, u8 arb_lost_cnt,
> + u8 nack_cnt, u8 low_drive_cnt, u8 error_cnt)
> +{
> + struct cec_data *data;
> + struct cec_msg *msg;
> +
> + dprintk(2, "cec_transmit_done %02x\n", status);
> + mutex_lock(&adap->lock);
> + data = adap->transmitting;
> + if (WARN_ON(data == NULL)) {
> + /* This is weird and should not happen. Ignore this transmit */
> + dprintk(0, "cec_transmit_done without an ongoing transmit!\n");
> + goto unlock;
> + }
> +
> + msg = &data->msg;
> +
> + /* Drivers must fill in the status! */
> + WARN_ON(status == 0);
> + msg->ts = ktime_get_ns();
> + msg->tx_status |= status;
> + msg->tx_arb_lost_cnt += arb_lost_cnt;
> + msg->tx_nack_cnt += nack_cnt;
> + msg->tx_low_drive_cnt += low_drive_cnt;
> + msg->tx_error_cnt += error_cnt;
> +
> + /* Mark that we're done with this transmit */
> + adap->transmitting = NULL;
> +
> + /*
> + * If there are still retry attempts left and there was an error and
> + * the hardware didn't signal that it retried itself (by setting
> + * CEC_TX_STATUS_MAX_RETRIES), then we will retry ourselves.
> + */
> + if (data->attempts > 1 &&
> + !(status & (CEC_TX_STATUS_MAX_RETRIES | CEC_TX_STATUS_OK))) {
> + /* Retry this message */
> + data->attempts--;
> + /* Add the message in front of the transmit queue */
> + list_add(&data->list, &adap->transmit_queue);
> + goto wake_thread;
> + }
> +
> + data->attempts = 0;
> +
> + /* Always set CEC_TX_STATUS_MAX_RETRIES on error */
> + if (!(status & CEC_TX_STATUS_OK))
> + msg->tx_status |= CEC_TX_STATUS_MAX_RETRIES;
> +
> + /* Queue transmitted message for monitoring purposes */
> + cec_queue_msg_monitor(adap, msg, 1);
> +
> + /*
> + * Clear reply on error of if the adapter is no longer
> + * configured. It makes no sense to wait for a reply in
> + * this case.
> + */
> + if (!(status & CEC_TX_STATUS_OK) || !adap->is_configured)
> + msg->reply = 0;
> +
> + if (msg->timeout) {
> + /*
> + * Queue the message into the wait queue if we want to wait
> + * for a reply.
> + */
> + list_add_tail(&data->list, &adap->wait_queue);
> + schedule_delayed_work(&data->work,
> + msecs_to_jiffies(msg->timeout));
> + } else {
> + /* Otherwise we're done */
> + cec_data_completed(data);
> + }
> +
> +wake_thread:
> + /*
> + * Wake up the main thread to see if another message is ready
> + * for transmitting or to retry the current message.
> + */
> + wake_up_interruptible(&adap->kthread_waitq);
> +unlock:
> + mutex_unlock(&adap->lock);
> +}
> +EXPORT_SYMBOL_GPL(cec_transmit_done);
> +
> +/*
> + * Called when waiting for a reply times out.
> + */
> +static void cec_wait_timeout(struct work_struct *work)
> +{
> + struct cec_data *data = container_of(work, struct cec_data, work.work);
> + struct cec_adapter *adap = data->adap;
> +
> + mutex_lock(&adap->lock);
> + /*
> + * Sanity check in case the timeout and the arrival of the message
> + * happened at the same time.
> + */
> + if (list_empty(&data->list))
> + goto unlock;
> +
> + /* Mark the message as timed out */
> + list_del_init(&data->list);
> + data->msg.ts = ktime_get_ns();
> + data->msg.rx_status = CEC_RX_STATUS_TIMEOUT;
> + cec_data_completed(data);
> +unlock:
> + mutex_unlock(&adap->lock);
> +}
> +
> +/*
> + * Transmit a message. The fh argument may be NULL if the transmit is not
> + * associated with a specific filehandle.
> + *
> + * This function is called with adap->lock held.
> + */
> +static int cec_transmit_msg_fh(struct cec_adapter *adap, struct cec_msg *msg,
> + struct cec_fh *fh, bool block)
> +{
> + struct cec_data *data;
> + u8 last_initiator = 0xff;
> + unsigned timeout;
> + int res = 0;
> +
> + if (msg->reply && msg->timeout == 0) {
> + /* Make sure the timeout isn't 0. */
> + msg->timeout = 1000;
> + }
> +
> + /* Sanity checks */
> + if (msg->len == 0 || msg->len > CEC_MAX_MSG_SIZE) {
> + dprintk(1, "cec_transmit_msg: invalid length %d\n", msg->len);
> + return -EINVAL;
> + }
> + if (msg->timeout && msg->len == 1) {
> + dprintk(1, "cec_transmit_msg: can't reply for poll msg\n");
> + return -EINVAL;
> + }
> + if (msg->len == 1) {
> + if (cec_msg_initiator(msg) != 0xf ||
> + cec_msg_destination(msg) == 0xf) {
> + dprintk(1, "cec_transmit_msg: invalid poll message\n");
> + return -EINVAL;
> + }
> + if (cec_has_log_addr(adap, cec_msg_destination(msg))) {
> + /*
> + * If the destination is a logical address our adapter
> + * has already claimed, then just NACK this.
> + * It depends on the hardware what it will do with a
> + * POLL to itself (some OK this), so it is just as
> + * easy to handle it here so the behavior will be
> + * consistent.
> + */
> + msg->tx_status = CEC_TX_STATUS_NACK |
> + CEC_TX_STATUS_MAX_RETRIES;
> + msg->tx_nack_cnt = 1;
> + return 0;
> + }
> + }
> + if (msg->len > 1 && !cec_msg_is_broadcast(msg) &&
> + cec_has_log_addr(adap, cec_msg_destination(msg))) {
> + dprintk(1, "cec_transmit_msg: destination is the adapter itself\n");
> + return -EINVAL;
> + }
> + if (cec_msg_initiator(msg) != 0xf &&
> + !cec_has_log_addr(adap, cec_msg_initiator(msg))) {
> + dprintk(1, "cec_transmit_msg: initiator has unknown logical address %d\n",
> + cec_msg_initiator(msg));
> + return -EINVAL;
> + }
> + if (!adap->is_configured && !adap->is_configuring)
> + return -ENONET;
> +
> + data = kzalloc(sizeof(*data), GFP_KERNEL);
> + if (data == NULL)
> + return -ENOMEM;
> +
> + if (msg->len > 1 && msg->msg[1] == CEC_MSG_CDC_MESSAGE) {
> + msg->msg[2] = adap->phys_addr >> 8;
> + msg->msg[3] = adap->phys_addr & 0xff;
> + }
> +
> + if (msg->timeout)
> + dprintk(2, "cec_transmit_msg: %*ph (wait for 0x%02x%s)\n",
> + msg->len, msg->msg, msg->reply, !block ? ", nb" : "");
> + else
> + dprintk(2, "cec_transmit_msg: %*ph%s\n",
> + msg->len, msg->msg, !block ? " (nb)" : "");
> +
> + msg->rx_status = msg->tx_status = 0;
> + msg->tx_arb_lost_cnt = msg->tx_nack_cnt = 0;
> + msg->tx_low_drive_cnt = msg->tx_error_cnt = 0;
> + data->msg = *msg;
> + data->fh = fh;
> + data->adap = adap;
> + data->blocking = block;
> +
> + /*
> + * Determine if this message follows a message from the same
> + * initiator. Needed to determine the free signal time later on.
> + */
> + if (msg->len > 1) {
> + if (!(list_empty(&adap->transmit_queue))) {
> + const struct cec_data *last;
> +
> + last = list_last_entry(&adap->transmit_queue,
> + const struct cec_data, list);
> + last_initiator = cec_msg_initiator(&last->msg);
> + } else if (adap->transmitting) {
> + last_initiator =
> + cec_msg_initiator(&adap->transmitting->msg);
> + }
> + }
> + data->new_initiator = last_initiator != cec_msg_initiator(msg);
> + init_completion(&data->c);
> + INIT_DELAYED_WORK(&data->work, cec_wait_timeout);
> +
> + data->msg.sequence = adap->sequence++;
> + if (fh)
> + list_add_tail(&data->xfer_list, &fh->xfer_list);
> + list_add_tail(&data->list, &adap->transmit_queue);
> + if (adap->transmitting == NULL)
> + wake_up_interruptible(&adap->kthread_waitq);
> +
> + /* All done if we don't need to block waiting for completion */
> + if (!block)
> + return 0;
> +
> + /*
> + * If we don't get a completion before this time something is really
> + * wrong and we time out.
> + */
> + timeout = CEC_XFER_TIMEOUT_MS;
> + /* Add the requested timeout if we have to wait for a reply as well */
> + if (msg->timeout)
> + timeout += msg->timeout;
> +
> + /*
> + * Release the lock and wait, retake the lock afterwards.
> + */
> + mutex_unlock(&adap->lock);
> + res = wait_for_completion_killable_timeout(&data->c,
> + msecs_to_jiffies(timeout));
> + mutex_lock(&adap->lock);
> +
> + if (data->completed) {
> + /* The transmit completed (possibly with an error) */
> + *msg = data->msg;
> + kfree(data);
> + return 0;
> + }
> + /*
> + * The wait for completion timed out or was interrupted, so mark this
> + * as non-blocking and disconnect from the filehandle since it is
> + * still 'in flight'. When it finally completes it will just drop the
> + * result silently.
> + */
> + data->blocking = false;
> + if (data->fh)
> + list_del(&data->xfer_list);
> + data->fh = NULL;
> +
> + if (res == 0) { /* timed out */
> + /* Check if the reply or the transmit failed */
> + if (msg->timeout && (msg->tx_status & CEC_TX_STATUS_OK))
> + msg->rx_status = CEC_RX_STATUS_TIMEOUT;
> + else
> + msg->tx_status = CEC_TX_STATUS_MAX_RETRIES;
> + }
> + return res > 0 ? 0 : res;
> +}
> +
> +/* Helper function to be used by drivers and this framework. */
> +int cec_transmit_msg(struct cec_adapter *adap, struct cec_msg *msg,
> + bool block)
> +{
> + int ret;
> +
> + mutex_lock(&adap->lock);
> + ret = cec_transmit_msg_fh(adap, msg, NULL, block);
> + mutex_unlock(&adap->lock);
> + return ret;
> +}
> +EXPORT_SYMBOL_GPL(cec_transmit_msg);
> +
> +/*
> + * I don't like forward references but without this the low-level
> + * cec_received_msg() function would come after a bunch of high-level
> + * CEC protocol handling functions. That was very confusing.
> + */
> +static int cec_receive_notify(struct cec_adapter *adap, struct cec_msg *msg,
> + bool is_reply);
> +
> +/* Called by the CEC adapter if a message is received */
> +void cec_received_msg(struct cec_adapter *adap, struct cec_msg *msg)
> +{
> + struct cec_data *data;
> + u8 msg_init = cec_msg_initiator(msg);
> + u8 msg_dest = cec_msg_destination(msg);
> + bool is_reply = false;
> + bool valid_la = true;
> +
> + mutex_lock(&adap->lock);
> + msg->ts = ktime_get_ns();
> + msg->rx_status = CEC_RX_STATUS_OK;
> + msg->tx_status = 0;
> + msg->sequence = msg->reply = msg->timeout = 0;
> + msg->flags = 0;
> +
> + dprintk(2, "cec_received_msg: %*ph\n", msg->len, msg->msg);
> +
> + /* Check if this message was for us (directed or broadcast). */
> + if (!cec_msg_is_broadcast(msg))
> + valid_la = cec_has_log_addr(adap, msg_dest);
> +
> + /* It's a valid message and not a poll or CDC message */
> + if (valid_la && msg->len > 1 && msg->msg[1] != CEC_MSG_CDC_MESSAGE) {
> + u8 cmd = msg->msg[1];
> + bool abort = cmd == CEC_MSG_FEATURE_ABORT;
> +
> + /* The aborted command is in msg[2] */
> + if (abort)
> + cmd = msg->msg[2];
> +
> + /*
> + * Walk over all transmitted messages that are waiting for a
> + * reply.
> + */
> + list_for_each_entry(data, &adap->wait_queue, list) {
> + struct cec_msg *dst = &data->msg;
> + u8 dst_reply;
> +
> + /* Does the command match? */
> + if ((abort && cmd != dst->msg[1]) ||
> + (!abort && cmd != dst->reply))
> + continue;
> +
> + /* Does the addressing match? */
> + if (msg_init != cec_msg_destination(dst) &&
> + !cec_msg_is_broadcast(dst))
> + continue;
> +
> + /* We got a reply */
> + msg->sequence = dst->sequence;
> + dst_reply = dst->reply;
> + *dst = *msg;
> + dst->reply = dst_reply;
> + if (abort) {
> + dst->reply = 0;
> + dst->rx_status |= CEC_RX_STATUS_FEATURE_ABORT;
> + }
> + /* Remove it from the wait_queue */
> + list_del_init(&data->list);
> +
> + /* Cancel the pending timeout work */
> + if (!cancel_delayed_work(&data->work)) {
> + mutex_unlock(&adap->lock);
> + flush_scheduled_work();
> + mutex_lock(&adap->lock);
> + }
> + /*
> + * Mark this as a reply, provided someone is still
> + * waiting for the answer.
> + */
> + if (data->fh)
> + is_reply = true;
> + cec_data_completed(data);
> + break;
> + }
> + }
> + mutex_unlock(&adap->lock);
> +
> + /* Pass the message on to any monitoring filehandles */
> + cec_queue_msg_monitor(adap, msg, valid_la);
> +
> + /* We're done if it is not for us or a poll message */
> + if (!valid_la || msg->len <= 1)
> + return;
> +
> + /*
> + * Process the message on the protocol level. If is_reply is true,
> + * then cec_receive_notify() won't pass on the reply to the listener(s)
> + * since that was already done by cec_data_completed() above.
> + */
> + cec_receive_notify(adap, msg, is_reply);
> +}
> +EXPORT_SYMBOL_GPL(cec_received_msg);
> +
> +
> +/* High-level core CEC message handling */
> +
> +/* Transmit the Report Features message */
> +static int cec_report_features(struct cec_adapter *adap, unsigned la_idx)
> +{
> + struct cec_msg msg = { };
> + const struct cec_log_addrs *las = &adap->log_addrs;
> + const u8 *features = las->features[la_idx];
> + bool op_is_dev_features = false;
> + unsigned idx;
> +
> + /* This is 2.0 and up only */
> + if (adap->log_addrs.cec_version < CEC_OP_CEC_VERSION_2_0)
> + return 0;
> +
> + /* Report Features */
> + msg.msg[0] = (las->log_addr[la_idx] << 4) | 0x0f;
> + msg.len = 4;
> + msg.msg[1] = CEC_MSG_REPORT_FEATURES;
> + msg.msg[2] = adap->log_addrs.cec_version;
> + msg.msg[3] = las->all_device_types[la_idx];
> +
> + /* Write RC Profiles first, then Device Features */
> + for (idx = 0; idx < sizeof(las->features[0]); idx++) {
shouldn't it be, instead, ARRAY_SIZE()?
> + msg.msg[msg.len++] = features[idx];
> + if ((features[idx] & CEC_OP_FEAT_EXT) == 0) {
> + if (op_is_dev_features)
> + break;
> + op_is_dev_features = true;
> + }
> + }
> + return cec_transmit_msg(adap, &msg, false);
> +}
> +
> +/* Transmit the Report Physical Address message */
> +static int cec_report_phys_addr(struct cec_adapter *adap, unsigned la_idx)
> +{
> + const struct cec_log_addrs *las = &adap->log_addrs;
> + struct cec_msg msg = { };
> +
> + /* Report Physical Address */
> + msg.msg[0] = (las->log_addr[la_idx] << 4) | 0x0f;
> + cec_msg_report_physical_addr(&msg, adap->phys_addr,
> + las->primary_device_type[la_idx]);
> + dprintk(2, "config: la %d pa %x.%x.%x.%x\n",
> + las->log_addr[la_idx],
> + cec_phys_addr_exp(adap->phys_addr));
Am I missing something or are there some parameters missing? you're
printing 5 parameters, but I'm only seeing two arguments after the
format string.
> + return cec_transmit_msg(adap, &msg, false);
> +}
> +
> +/* Transmit the Feature Abort message */
> +static int cec_feature_abort_reason(struct cec_adapter *adap,
> + struct cec_msg *msg, u8 reason)
> +{
> + struct cec_msg tx_msg = { };
> +
> + /*
> + * Don't reply with CEC_MSG_FEATURE_ABORT to a CEC_MSG_FEATURE_ABORT
> + * message!
> + */
> + if (msg->msg[1] == CEC_MSG_FEATURE_ABORT)
> + return 0;
> + cec_msg_set_reply_to(&tx_msg, msg);
> + cec_msg_feature_abort(&tx_msg, msg->msg[1], reason);
> + return cec_transmit_msg(adap, &tx_msg, false);
> +}
> +
> +static int cec_feature_abort(struct cec_adapter *adap, struct cec_msg *msg)
> +{
> + return cec_feature_abort_reason(adap, msg,
> + CEC_OP_ABORT_UNRECOGNIZED_OP);
> +}
> +
> +static int cec_feature_refused(struct cec_adapter *adap, struct cec_msg *msg)
> +{
> + return cec_feature_abort_reason(adap, msg,
> + CEC_OP_ABORT_REFUSED);
> +}
> +
> +/*
> + * Called when a CEC message is received. This function will do any
> + * necessary core processing. The is_reply bool is true if this message
> + * is a reply to an earlier transmit.
> + *
> + * The message is either a broadcast message or a valid directed message.
> + */
> +static int cec_receive_notify(struct cec_adapter *adap, struct cec_msg *msg,
> + bool is_reply)
> +{
> + bool is_broadcast = cec_msg_is_broadcast(msg);
> + u8 dest_laddr = cec_msg_destination(msg);
> + u8 init_laddr = cec_msg_initiator(msg);
> + u8 devtype = cec_log_addr2dev(adap, dest_laddr);
> + int la_idx = cec_log_addr2idx(adap, dest_laddr);
> + bool is_directed = la_idx >= 0;
> + bool from_unregistered = init_laddr == 0xf;
> + struct cec_msg tx_cec_msg = { };
> +
> + dprintk(1, "cec_receive_notify: %*ph\n", msg->len, msg->msg);
> +
> + if (adap->ops->received) {
> + /* Allow drivers to process the message first */
> + if (adap->ops->received(adap, msg) != -ENOMSG)
> + return 0;
> + }
> +
> + /*
> + * REPORT_PHYSICAL_ADDR, CEC_MSG_USER_CONTROL_PRESSED and
> + * CEC_MSG_USER_CONTROL_RELEASED messages always have to be
> + * handled by the CEC core, even if the passthrough mode is on.
> + * The others are just ignored if passthrough mode is on.
> + */
> + switch (msg->msg[1]) {
> + case CEC_MSG_GET_CEC_VERSION:
> + case CEC_MSG_GIVE_DEVICE_VENDOR_ID:
> + case CEC_MSG_ABORT:
> + case CEC_MSG_GIVE_DEVICE_POWER_STATUS:
> + case CEC_MSG_GIVE_PHYSICAL_ADDR:
> + case CEC_MSG_GIVE_OSD_NAME:
> + case CEC_MSG_GIVE_FEATURES:
> + /*
> + * Skip processing these messages if the passthrough mode
> + * is on.
> + */
> + if (adap->passthrough)
> + goto skip_processing;
> + /* Ignore if addressing is wrong */
> + if (is_broadcast || from_unregistered)
> + return 0;
> + break;
> +
> + case CEC_MSG_USER_CONTROL_PRESSED:
> + case CEC_MSG_USER_CONTROL_RELEASED:
> + /* Wrong addressing mode: don't process */
> + if (is_broadcast || from_unregistered)
> + goto skip_processing;
> + break;
> +
> + case CEC_MSG_REPORT_PHYSICAL_ADDR:
> + /*
> + * This message is always processed, regardless of the
> + * passthrough setting.
> + *
> + * Exception: don't process if wrong addressing mode.
> + */
> + if (!is_broadcast)
> + goto skip_processing;
> + break;
> +
> + default:
> + break;
> + }
> +
> + cec_msg_set_reply_to(&tx_cec_msg, msg);
> +
> + switch (msg->msg[1]) {
> + /* The following messages are processed but still passed through */
> + case CEC_MSG_REPORT_PHYSICAL_ADDR:
> + adap->phys_addrs[init_laddr] =
> + (msg->msg[2] << 8) | msg->msg[3];
> + dprintk(1, "Reported physical address %04x for logical address %d\n",
> + adap->phys_addrs[init_laddr], init_laddr);
> + break;
> +
> + case CEC_MSG_USER_CONTROL_PRESSED:
> + if (!(adap->capabilities & CEC_CAP_RC))
> + break;
> +
> +#if IS_ENABLED(CONFIG_RC_CORE)
> + switch (msg->msg[2]) {
> + /*
> + * Play function, this message can have variable length
> + * depending on the specific play function that is used.
> + */
> + case 0x60:
> + if (msg->len == 2)
> + rc_keydown(adap->rc, RC_TYPE_CEC,
> + msg->msg[2], 0);
> + else
> + rc_keydown(adap->rc, RC_TYPE_CEC,
> + msg->msg[2] << 8 | msg->msg[3], 0);
> + break;
> + /*
> + * Other function messages that are not handled.
> + * Currently the RC framework does not allow to supply an
> + * additional parameter to a keypress. These "keys" contain
> + * other information such as channel number, an input number
> + * etc.
> + * For the time being these messages are not processed by the
> + * framework and are simply forwarded to the user space.
> + */
> + case 0x56: case 0x57:
> + case 0x67: case 0x68: case 0x69: case 0x6a:
> + break;
> + default:
> + rc_keydown(adap->rc, RC_TYPE_CEC, msg->msg[2], 0);
> + break;
> + }
> +#endif
> + break;
> +
> + case CEC_MSG_USER_CONTROL_RELEASED:
> + if (!(adap->capabilities & CEC_CAP_RC))
> + break;
> +#if IS_ENABLED(CONFIG_RC_CORE)
> + rc_keyup(adap->rc);
> +#endif
> + break;
> +
> + /*
> + * The remaining messages are only processed if the passthrough mode
> + * is off.
> + */
> + case CEC_MSG_GET_CEC_VERSION:
> + cec_msg_cec_version(&tx_cec_msg, adap->log_addrs.cec_version);
> + return cec_transmit_msg(adap, &tx_cec_msg, false);
> +
> + case CEC_MSG_GIVE_PHYSICAL_ADDR:
> + /* Do nothing for CEC switches using addr 15 */
> + if (devtype == CEC_OP_PRIM_DEVTYPE_SWITCH && dest_laddr == 15)
> + return 0;
> + cec_msg_report_physical_addr(&tx_cec_msg, adap->phys_addr, devtype);
> + return cec_transmit_msg(adap, &tx_cec_msg, false);
> +
> + case CEC_MSG_GIVE_DEVICE_VENDOR_ID:
> + if (adap->log_addrs.vendor_id == CEC_VENDOR_ID_NONE)
> + return cec_feature_abort(adap, msg);
> + cec_msg_device_vendor_id(&tx_cec_msg, adap->log_addrs.vendor_id);
> + return cec_transmit_msg(adap, &tx_cec_msg, false);
> +
> + case CEC_MSG_ABORT:
> + /* Do nothing for CEC switches */
> + if (devtype == CEC_OP_PRIM_DEVTYPE_SWITCH)
> + return 0;
> + return cec_feature_refused(adap, msg);
> +
> + case CEC_MSG_GIVE_OSD_NAME: {
> + if (adap->log_addrs.osd_name[0] == 0)
> + return cec_feature_abort(adap, msg);
> + cec_msg_set_osd_name(&tx_cec_msg, adap->log_addrs.osd_name);
> + return cec_transmit_msg(adap, &tx_cec_msg, false);
> + }
> +
> + case CEC_MSG_GIVE_FEATURES:
> + if (adap->log_addrs.cec_version >= CEC_OP_CEC_VERSION_2_0)
> + return cec_report_features(adap, la_idx);
> + return 0;
> +
> + default:
> + /*
> + * Unprocessed messages are aborted if userspace isn't doing
> + * any processing either.
> + */
> + if (is_directed && !is_reply && !adap->follower_cnt &&
> + !adap->cec_follower && msg->msg[1] != CEC_MSG_FEATURE_ABORT)
> + return cec_feature_abort(adap, msg);
> + break;
> + }
> +
> +skip_processing:
> + /* If this was not a reply, then we're done */
> + if (is_reply)
> + return 0;
> +
> + /*
> + * Send to the exclusive follower if there is one, otherwise send
> + * to all followerd.
> + */
> + if (adap->cec_follower)
> + cec_queue_msg_fh(adap->cec_follower, msg);
> + else
> + cec_queue_msg_followers(adap, msg);
> + return 0;
> +}
> +
> +/*
> + * Attempt to claim a specific logical address.
> + *
> + * This function is called with adap->lock held.
> + */
> +static int cec_config_log_addr(struct cec_adapter *adap,
> + unsigned int idx,
> + unsigned int log_addr)
> +{
> + struct cec_log_addrs *las = &adap->log_addrs;
> + struct cec_msg msg = { };
> + int err;
> +
> + if (cec_has_log_addr(adap, log_addr))
> + return 0;
> +
> + /* Send poll message */
> + msg.len = 1;
> + msg.msg[0] = 0xf0 | log_addr;
> + err = cec_transmit_msg_fh(adap, &msg, NULL, true);
> +
> + /*
> + * While trying to poll the physical address was reset
> + * and the adapter was unconfigured, so bail out.
> + */
> + if (!adap->is_configuring)
> + return -EINTR;
> +
> + if (err)
> + return err;
> +
> + if (msg.tx_status & CEC_TX_STATUS_OK)
> + return 0;
> +
> + /*
> + * Message not acknowledged, so this logical
> + * address is free to use.
> + */
> + err = adap->ops->adap_log_addr(adap, log_addr);
> + if (err)
> + return err;
> +
> + las->log_addr[idx] = log_addr;
> + las->log_addr_mask |= 1 << log_addr;
> + adap->phys_addrs[log_addr] = adap->phys_addr;
> +
> + dprintk(2, "claimed addr %d (%d)\n", log_addr,
> + las->primary_device_type[idx]);
> + return 1;
> +}
> +
> +/*
> + * Unconfigure the adapter: clear all logical addresses and send
> + * the state changed event.
> + *
> + * This function is called with adap->lock held.
> + */
> +static void cec_adap_unconfigure(struct cec_adapter *adap)
> +{
> + WARN_ON(adap->ops->adap_log_addr(adap, CEC_LOG_ADDR_INVALID));
> + adap->log_addrs.log_addr_mask = 0;
> + adap->is_configuring = false;
> + adap->is_configured = false;
> + memset(adap->phys_addrs, 0xff, sizeof(adap->phys_addrs));
> + wake_up_interruptible(&adap->kthread_waitq);
> + cec_post_state_event(adap);
> +}
> +
> +/*
> + * Attempt to claim the required logical addresses.
> + */
> +static int cec_config_thread_func(void *arg)
> +{
> + /* The various LAs for each type of device */
> + static const u8 tv_log_addrs[] = {
> + CEC_LOG_ADDR_TV, CEC_LOG_ADDR_SPECIFIC,
> + CEC_LOG_ADDR_INVALID
> + };
> + static const u8 record_log_addrs[] = {
> + CEC_LOG_ADDR_RECORD_1, CEC_LOG_ADDR_RECORD_2,
> + CEC_LOG_ADDR_RECORD_3,
> + CEC_LOG_ADDR_BACKUP_1, CEC_LOG_ADDR_BACKUP_2,
> + CEC_LOG_ADDR_INVALID
> + };
> + static const u8 tuner_log_addrs[] = {
> + CEC_LOG_ADDR_TUNER_1, CEC_LOG_ADDR_TUNER_2,
> + CEC_LOG_ADDR_TUNER_3, CEC_LOG_ADDR_TUNER_4,
> + CEC_LOG_ADDR_BACKUP_1, CEC_LOG_ADDR_BACKUP_2,
> + CEC_LOG_ADDR_INVALID
> + };
> + static const u8 playback_log_addrs[] = {
> + CEC_LOG_ADDR_PLAYBACK_1, CEC_LOG_ADDR_PLAYBACK_2,
> + CEC_LOG_ADDR_PLAYBACK_3,
> + CEC_LOG_ADDR_BACKUP_1, CEC_LOG_ADDR_BACKUP_2,
> + CEC_LOG_ADDR_INVALID
> + };
> + static const u8 audiosystem_log_addrs[] = {
> + CEC_LOG_ADDR_AUDIOSYSTEM,
> + CEC_LOG_ADDR_INVALID
> + };
> + static const u8 specific_use_log_addrs[] = {
> + CEC_LOG_ADDR_SPECIFIC,
> + CEC_LOG_ADDR_BACKUP_1, CEC_LOG_ADDR_BACKUP_2,
> + CEC_LOG_ADDR_INVALID
> + };
> + static const u8 *type2addrs[6] = {
> + [CEC_LOG_ADDR_TYPE_TV] = tv_log_addrs,
> + [CEC_LOG_ADDR_TYPE_RECORD] = record_log_addrs,
> + [CEC_LOG_ADDR_TYPE_TUNER] = tuner_log_addrs,
> + [CEC_LOG_ADDR_TYPE_PLAYBACK] = playback_log_addrs,
> + [CEC_LOG_ADDR_TYPE_AUDIOSYSTEM] = audiosystem_log_addrs,
> + [CEC_LOG_ADDR_TYPE_SPECIFIC] = specific_use_log_addrs,
> + };
> + static const u16 type2mask[] = {
> + [CEC_LOG_ADDR_TYPE_TV] = CEC_LOG_ADDR_MASK_TV,
> + [CEC_LOG_ADDR_TYPE_RECORD] = CEC_LOG_ADDR_MASK_RECORD,
> + [CEC_LOG_ADDR_TYPE_TUNER] = CEC_LOG_ADDR_MASK_TUNER,
> + [CEC_LOG_ADDR_TYPE_PLAYBACK] = CEC_LOG_ADDR_MASK_PLAYBACK,
> + [CEC_LOG_ADDR_TYPE_AUDIOSYSTEM] = CEC_LOG_ADDR_MASK_AUDIOSYSTEM,
> + [CEC_LOG_ADDR_TYPE_SPECIFIC] = CEC_LOG_ADDR_MASK_SPECIFIC,
> + };
> + struct cec_adapter *adap = arg;
> + struct cec_log_addrs *las = &adap->log_addrs;
> + int err;
> + int i, j;
> +
> + mutex_lock(&adap->lock);
> + dprintk(1, "physical address: %x.%x.%x.%x, claim %d logical addresses\n",
> + cec_phys_addr_exp(adap->phys_addr),
> + las->num_log_addrs);
Again, number of arguments doesn't seem to match.
> + las->log_addr_mask = 0;
> +
> + if (las->log_addr_type[0] == CEC_LOG_ADDR_TYPE_UNREGISTERED)
> + goto configured;
> +
> + for (i = 0; i < las->num_log_addrs; i++) {
> + unsigned int type = las->log_addr_type[i];
> + const u8 *la_list;
> + u8 last_la;
> +
> + /*
> + * The TV functionality can only map to physical address 0.
> + * For any other address, try the Specific functionality
> + * instead as per the spec.
> + */
> + if (adap->phys_addr && type == CEC_LOG_ADDR_TYPE_TV)
> + type = CEC_LOG_ADDR_TYPE_SPECIFIC;
> +
> + la_list = type2addrs[type];
> + last_la = las->log_addr[i];
> + las->log_addr[i] = CEC_LOG_ADDR_INVALID;
> + if (last_la == CEC_LOG_ADDR_INVALID ||
> + last_la == CEC_LOG_ADDR_UNREGISTERED ||
> + !(last_la & type2mask[type]))
> + last_la = la_list[0];
> +
> + err = cec_config_log_addr(adap, i, last_la);
> + if (err > 0) /* Reused last LA */
> + continue;
> +
> + if (err < 0)
> + goto unconfigure;
> +
> + for (j = 0; la_list[j] != CEC_LOG_ADDR_INVALID; j++) {
> + /* Tried this one already, skip it */
> + if (la_list[j] == last_la)
> + continue;
> + /* The backup addresses are CEC 2.0 specific */
> + if ((la_list[j] == CEC_LOG_ADDR_BACKUP_1 ||
> + la_list[j] == CEC_LOG_ADDR_BACKUP_2) &&
> + las->cec_version < CEC_OP_CEC_VERSION_2_0)
> + continue;
> +
> + err = cec_config_log_addr(adap, i, la_list[j]);
> + if (err == 0) /* LA is in use */
> + continue;
> + if (err < 0)
> + goto unconfigure;
> + /* Done, claimed an LA */
> + break;
> + }
> +
> + if (la_list[j] == CEC_LOG_ADDR_INVALID)
> + dprintk(1, "could not claim LA %d\n", i);
> + }
> +
> +configured:
> + if (adap->log_addrs.log_addr_mask == 0) {
> + /* Fall back to unregistered */
> + las->log_addr[0] = CEC_LOG_ADDR_UNREGISTERED;
> + las->log_addr_mask = 1 << las->log_addr[0];
> + }
> + adap->is_configured = true;
> + adap->is_configuring = false;
> + cec_post_state_event(adap);
> + mutex_unlock(&adap->lock);
> +
> + for (i = 0; i < las->num_log_addrs; i++) {
> + if (las->log_addr[i] == CEC_LOG_ADDR_INVALID)
> + continue;
> +
> + /*
> + * Report Features must come first according
> + * to CEC 2.0
> + */
> + if (las->log_addr[i] != CEC_LOG_ADDR_UNREGISTERED)
> + cec_report_features(adap, i);
> + cec_report_phys_addr(adap, i);
> + }
> + mutex_lock(&adap->lock);
> + adap->kthread_config = NULL;
> + mutex_unlock(&adap->lock);
> + complete(&adap->config_completion);
> + return 0;
> +
> +unconfigure:
> + for (i = 0; i < las->num_log_addrs; i++)
> + las->log_addr[i] = CEC_LOG_ADDR_INVALID;
> + cec_adap_unconfigure(adap);
> + adap->kthread_config = NULL;
> + mutex_unlock(&adap->lock);
> + complete(&adap->config_completion);
> + return 0;
> +}
> +
> +/*
> + * Called from either __cec_s_phys_addr or __cec_s_log_addrs to claim the
> + * logical addresses.
> + *
> + * This function is called with adap->lock held.
> + */
> +static void cec_claim_log_addrs(struct cec_adapter *adap, bool block)
> +{
> + if (WARN_ON(adap->is_configuring || adap->is_configured))
> + return;
> +
> + init_completion(&adap->config_completion);
> +
> + /* Ready to kick off the thread */
> + adap->is_configuring = true;
> + adap->kthread_config = kthread_run(cec_config_thread_func, adap,
> + "ceccfg-%s", adap->name);
> + if (IS_ERR(adap->kthread_config)) {
> + adap->kthread_config = NULL;
> + } else if (block) {
> + mutex_unlock(&adap->lock);
> + wait_for_completion(&adap->config_completion);
> + mutex_lock(&adap->lock);
> + }
> +}
> +
> +/* Set a new physical address and send an event notifying userspace of this.
> + *
> + * This function is called with adap->lock held.
> + */
> +static void __cec_s_phys_addr(struct cec_adapter *adap, u16 phys_addr, bool block)
> +{
> + if (phys_addr == adap->phys_addr)
> + return;
> +
> + if (phys_addr == CEC_PHYS_ADDR_INVALID ||
> + adap->phys_addr != CEC_PHYS_ADDR_INVALID) {
> + adap->phys_addr = CEC_PHYS_ADDR_INVALID;
> + cec_post_state_event(adap);
> + cec_adap_unconfigure(adap);
> + /* Disabling monitor all mode should always succeed */
> + if (adap->monitor_all_cnt)
> + WARN_ON(call_op(adap, adap_monitor_all_enable, false));
> + WARN_ON(adap->ops->adap_enable(adap, false));
> + if (phys_addr == CEC_PHYS_ADDR_INVALID)
> + return;
> + }
> +
> + if (adap->ops->adap_enable(adap, true))
> + return;
> +
> + if (adap->monitor_all_cnt &&
> + call_op(adap, adap_monitor_all_enable, true)) {
> + WARN_ON(adap->ops->adap_enable(adap, false));
> + return;
> + }
> + adap->phys_addr = phys_addr;
> + cec_post_state_event(adap);
> + if (adap->log_addrs.num_log_addrs)
> + cec_claim_log_addrs(adap, block);
> +}
> +
> +void cec_s_phys_addr(struct cec_adapter *adap, u16 phys_addr, bool block)
> +{
> + if (IS_ERR_OR_NULL(adap))
> + return;
> +
> + if (WARN_ON(adap->capabilities & CEC_CAP_PHYS_ADDR))
> + return;
> + mutex_lock(&adap->lock);
> + __cec_s_phys_addr(adap, phys_addr, block);
> + mutex_unlock(&adap->lock);
> +}
> +EXPORT_SYMBOL_GPL(cec_s_phys_addr);
> +
> +/*
> + * Called from either the ioctl or a driver to set the logical addresses.
> + *
> + * This function is called with adap->lock held.
> + */
> +static int __cec_s_log_addrs(struct cec_adapter *adap,
> + struct cec_log_addrs *log_addrs, bool block)
> +{
> + u16 type_mask = 0;
> + int i;
> +
> + if (log_addrs == NULL || log_addrs->num_log_addrs == 0) {
> + adap->log_addrs.num_log_addrs = 0;
> + cec_adap_unconfigure(adap);
> + return 0;
> + }
> +
> + /* Ensure the osd name is 0-terminated */
> + log_addrs->osd_name[sizeof(log_addrs->osd_name) - 1] = '\0';
> +
> + /* Sanity checks */
> + if (log_addrs->num_log_addrs > adap->available_log_addrs) {
> + dprintk(1, "num_log_addrs > %d\n", adap->available_log_addrs);
> + return -EINVAL;
> + }
> +
> + /*
> + * Vendor ID is a 24 bit number, so check if the value is
> + * within the correct range.
> + */
> + if (log_addrs->vendor_id != CEC_VENDOR_ID_NONE &&
> + (log_addrs->vendor_id & 0xff000000) != 0)
> + return -EINVAL;
> +
> + if (log_addrs->cec_version != CEC_OP_CEC_VERSION_1_4 &&
> + log_addrs->cec_version != CEC_OP_CEC_VERSION_2_0)
> + return -EINVAL;
> +
> + if (log_addrs->num_log_addrs > 1)
> + for (i = 0; i < log_addrs->num_log_addrs; i++)
> + if (log_addrs->log_addr_type[i] ==
> + CEC_LOG_ADDR_TYPE_UNREGISTERED) {
> + dprintk(1, "num_log_addrs > 1 can't be combined with unregistered LA\n");
> + return -EINVAL;
> + }
> +
> + if (log_addrs->cec_version < CEC_OP_CEC_VERSION_2_0) {
> + memset(log_addrs->all_device_types, 0,
> + sizeof(log_addrs->all_device_types));
> + memset(log_addrs->features, 0, sizeof(log_addrs->features));
> + }
> +
> + for (i = 0; i < log_addrs->num_log_addrs; i++) {
> + u8 *features = log_addrs->features[i];
> + bool op_is_dev_features = false;
> +
> + log_addrs->log_addr[i] = CEC_LOG_ADDR_INVALID;
> + if (type_mask & (1 << log_addrs->log_addr_type[i])) {
> + dprintk(1, "duplicate logical address type\n");
> + return -EINVAL;
> + }
> + type_mask |= 1 << log_addrs->log_addr_type[i];
> + if ((type_mask & (1 << CEC_LOG_ADDR_TYPE_RECORD)) &&
> + (type_mask & (1 << CEC_LOG_ADDR_TYPE_PLAYBACK))) {
> + /* Record already contains the playback functionality */
> + dprintk(1, "invalid record + playback combination\n");
> + return -EINVAL;
> + }
> + if (log_addrs->primary_device_type[i] >
> + CEC_OP_PRIM_DEVTYPE_PROCESSOR) {
> + dprintk(1, "unknown primary device type\n");
> + return -EINVAL;
> + }
> + if (log_addrs->primary_device_type[i] == 2) {
> + dprintk(1, "invalid primary device type\n");
> + return -EINVAL;
> + }
> + if (log_addrs->log_addr_type[i] > CEC_LOG_ADDR_TYPE_UNREGISTERED) {
> + dprintk(1, "unknown logical address type\n");
> + return -EINVAL;
> + }
> + if (log_addrs->cec_version < CEC_OP_CEC_VERSION_2_0)
> + continue;
> +
> + for (i = 0; i < sizeof(log_addrs->features[0]); i++) {
ARRAY_SIZE() - and on other occurrences of it...
> + if ((features[i] & 0x80) == 0) {
> + if (op_is_dev_features)
> + break;
> + op_is_dev_features = true;
> + }
> + }
> + if (!op_is_dev_features || i == sizeof(log_addrs->features[0])) {
> + dprintk(1, "malformed features\n");
> + return -EINVAL;
> + }
> + }
> +
> + if (log_addrs->cec_version >= CEC_OP_CEC_VERSION_2_0) {
> + if (log_addrs->num_log_addrs > 2) {
> + dprintk(1, "CEC 2.0 allows no more than 2 logical addresses\n");
> + return -EINVAL;
> + }
> + if (log_addrs->num_log_addrs == 2) {
> + if (!(type_mask & ((1 << CEC_LOG_ADDR_TYPE_AUDIOSYSTEM) |
> + (1 << CEC_LOG_ADDR_TYPE_TV)))) {
> + dprintk(1, "Two LAs is only allowed for audiosystem and TV\n");
> + return -EINVAL;
> + }
> + if (!(type_mask & ((1 << CEC_LOG_ADDR_TYPE_PLAYBACK) |
> + (1 << CEC_LOG_ADDR_TYPE_RECORD)))) {
> + dprintk(1, "An audiosystem/TV can only be combined with record or playback\n");
> + return -EINVAL;
> + }
> + }
> + }
> +
> + log_addrs->log_addr_mask = adap->log_addrs.log_addr_mask;
> + adap->log_addrs = *log_addrs;
> + if (adap->phys_addr != CEC_PHYS_ADDR_INVALID)
> + cec_claim_log_addrs(adap, block);
> + return 0;
> +}
> +
> +int cec_s_log_addrs(struct cec_adapter *adap,
> + struct cec_log_addrs *log_addrs, bool block)
> +{
> + int err;
> +
> + if (WARN_ON(adap->capabilities & CEC_CAP_LOG_ADDRS))
> + return -EINVAL;
> + mutex_lock(&adap->lock);
> + err = __cec_s_log_addrs(adap, log_addrs, block);
> + mutex_unlock(&adap->lock);
> + return err;
> +}
> +EXPORT_SYMBOL_GPL(cec_s_log_addrs);
> +
> +/*
> + * Log the current state of the CEC adapter.
> + * Very useful for debugging.
> + */
> +static int cec_status(struct seq_file *file, void *priv)
As I briefly commented on IRC, the amount of stuff on this
single patch/file is huge, making hard to review.
I would split it into at least 3 or 4 parts:
- low-level code;
- high-level code;
- userspace interface;
- debugfs stuff.
And put each part on a separate patch. That would easy review
the code, as it is easy to lose the track on the logic
due to its complexity.
> +{
> + struct cec_adapter *adap = dev_get_drvdata(file->private);
> + struct cec_data *data;
> +
> + mutex_lock(&adap->lock);
> + seq_printf(file, "configured: %d\n", adap->is_configured);
> + seq_printf(file, "configuring: %d\n", adap->is_configuring);
> + seq_printf(file, "phys_addr: %x.%x.%x.%x\n",
> + cec_phys_addr_exp(adap->phys_addr));
> + seq_printf(file, "number of LAs: %d\n", adap->log_addrs.num_log_addrs);
> + seq_printf(file, "LA mask: 0x%04x\n", adap->log_addrs.log_addr_mask);
> + if (adap->cec_follower)
> + seq_printf(file, "has CEC follower%s\n",
> + adap->passthrough ? " (in passthrough mode)" : "");
> + if (adap->cec_initiator)
> + seq_puts(file, "has CEC initiator\n");
> + if (adap->monitor_all_cnt)
> + seq_printf(file, "file handles in Monitor All mode: %u\n",
> + adap->monitor_all_cnt);
> + data = adap->transmitting;
> + if (data)
> + seq_printf(file, "transmitting message: %*ph (reply: %02x)\n",
> + data->msg.len, data->msg.msg, data->msg.reply);
> + list_for_each_entry(data, &adap->transmit_queue, list) {
> + seq_printf(file, "queued tx message: %*ph (reply: %02x)\n",
> + data->msg.len, data->msg.msg, data->msg.reply);
> + }
> + list_for_each_entry(data, &adap->wait_queue, list) {
> + seq_printf(file, "message waiting for reply: %*ph (reply: %02x)\n",
> + data->msg.len, data->msg.msg, data->msg.reply);
> + }
> +
> + call_void_op(adap, adap_status, file);
> + mutex_unlock(&adap->lock);
> + return 0;
> +}
> +
> +
> +/* CEC file operations */
> +
> +static unsigned cec_poll(struct file *filp,
> + struct poll_table_struct *poll)
> +{
> + struct cec_devnode *devnode = cec_devnode_data(filp);
> + struct cec_fh *fh = filp->private_data;
> + struct cec_adapter *adap = fh->adap;
> + unsigned res = 0;
> +
> + if (!devnode->registered)
> + return POLLERR | POLLHUP;
> + mutex_lock(&adap->lock);
> + if (adap->is_configured)
> + res |= POLLOUT | POLLWRNORM;
> + if (fh->queued_msgs)
> + res |= POLLIN | POLLRDNORM;
> + if (fh->events)
> + res |= POLLPRI;
> + poll_wait(filp, &fh->wait, poll);
> + mutex_unlock(&adap->lock);
> + return res;
> +}
> +
> +/*
> + * Helper functions to keep track of the 'monitor all' use count.
> + *
> + * These functions are called with adap->lock held.
> + */
> +static int cec_monitor_all_cnt_inc(struct cec_adapter *adap)
> +{
> + int ret = 0;
> +
> + if (adap->monitor_all_cnt == 0)
> + ret = call_op(adap, adap_monitor_all_enable, 1);
> + if (ret == 0)
> + adap->monitor_all_cnt++;
> + return ret;
> +}
> +
> +static void cec_monitor_all_cnt_dec(struct cec_adapter *adap)
> +{
> + adap->monitor_all_cnt--;
> + if (adap->monitor_all_cnt == 0)
> + WARN_ON(call_op(adap, adap_monitor_all_enable, 0));
> +}
> +
> +/* Called by CEC_RECEIVE: wait for a message to arrive */
> +static int cec_receive_msg(struct cec_fh *fh, struct cec_msg *msg, bool block)
> +{
> + int res;
> +
> + do {
> + mutex_lock(&fh->lock);
> + /* Are there received messages queued up? */
> + if (fh->queued_msgs) {
> + /* Yes, return the first one */
> + struct cec_msg_entry *entry =
> + list_first_entry(&fh->msgs,
> + struct cec_msg_entry, list);
> +
> + list_del(&entry->list);
> + *msg = entry->msg;
> + kfree(entry);
> + fh->queued_msgs--;
> + res = 0;
> + } else {
> + /* No, return EAGAIN in non-blocking mode or wait */
> + res = -EAGAIN;
IMHO, it will be better if you revert the if logic:
mutex_lock()
if (!block || !fh->queued_msgs) {
mutex_unlock();
return -EAGAIN;
}
// the code that handles queues message
That eliminates one indentation and reduce the code complexity.
> + }
> + mutex_unlock(&fh->lock);
> + /* Return when in non-blocking mode or if we have a message */
> + if (!block || !res)
> + break;
> +
> + if (msg->timeout) {
> + /* The user specified a timeout */
> + res = wait_event_interruptible_timeout(fh->wait,
> + fh->queued_msgs,
> + msecs_to_jiffies(msg->timeout));
> + if (res == 0)
> + res = -ETIMEDOUT;
> + else if (res > 0)
> + res = 0;
> + } else {
> + /* Wait indefinitely */
> + res = wait_event_interruptible(fh->wait,
> + fh->queued_msgs);
> + }
> + /* Exit on error, otherwise loop to get the new message */
> + } while (!res);
> + return res;
> +}
> +
> +static bool cec_is_busy(const struct cec_adapter *adap,
> + const struct cec_fh *fh)
> +{
> + bool valid_initiator = adap->cec_initiator && adap->cec_initiator == fh;
> + bool valid_follower = adap->cec_follower && adap->cec_follower == fh;
> +
> + /*
> + * Exclusive initiators and followers can always access the CEC adapter
> + */
> + if (valid_initiator || valid_follower)
> + return false;
> + /*
> + * All others can only access the CEC adapter if there is no
> + * exclusive initiator and they are in INITIATOR mode.
> + */
> + return adap->cec_initiator != NULL ||
> + fh->mode_initiator == CEC_MODE_NO_INITIATOR;
> +}
> +
> +static long cec_ioctl(struct file *filp, unsigned cmd, unsigned long arg)
> +{
> + struct cec_devnode *devnode = cec_devnode_data(filp);
> + struct cec_fh *fh = filp->private_data;
> + struct cec_adapter *adap = fh->adap;
> + bool block = !(filp->f_flags & O_NONBLOCK);
> + void __user *parg = (void __user *)arg;
> + int err = 0;
> +
> + if (!devnode->registered)
> + return -EIO;
> +
> + switch (cmd) {
> + case CEC_ADAP_G_CAPS: {
I don't like very much handling the ioctl code directly inside a switch.
That makes the code complex. It is usually better to have one function
per each ioctl and use the switch (or some other structure) to call the
function for each ioctl.
> + struct cec_caps caps = {};
> +
> + strlcpy(caps.driver, adap->devnode.parent->driver->name,
> + sizeof(caps.driver));
> + strlcpy(caps.name, adap->name, sizeof(caps.name));
> + caps.available_log_addrs = adap->available_log_addrs;
> + caps.capabilities = adap->capabilities;
> + caps.version = LINUX_VERSION_CODE;
> + if (copy_to_user(parg, &caps, sizeof(caps)))
> + return -EFAULT;
Shouldn't it return an error here if !adap->is_configured?
> + break;
> + }
> +
> + case CEC_TRANSMIT: {
> + struct cec_msg msg = {};
> +
> + if (!(adap->capabilities & CEC_CAP_TRANSMIT))
> + return -ENOTTY;
> + if (copy_from_user(&msg, parg, sizeof(msg)))
> + return -EFAULT;
> + mutex_lock(&adap->lock);
> + if (!adap->is_configured) {
> + err = -ENONET;
> + } else if (cec_is_busy(adap, fh)) {
> + err = -EBUSY;
Better to use gotos here, instead of all those nested ifs for the
error conditions, or to just do:
mutex_unlock()
return errorcode;
I don't like very much to copy_from_user() if it won't use
the data copied. So, maybe we could first test everything
and only then copy the data. The side effect is that it would
copy with the mutex locked. Not sure about the impacts, if any.
Of course, if we change it here, we'll need to do the same
changes for all ioctls.
> + } else {
> + if (block || !msg.reply)
> + fh = NULL;
> + err = cec_transmit_msg_fh(adap, &msg, fh, block);
> + }
> + mutex_unlock(&adap->lock);
> + if (err)
> + return err;
> + if (copy_to_user(parg, &msg, sizeof(msg)))
> + return -EFAULT;
> + break;
> + }
> +
> + case CEC_RECEIVE: {
> + struct cec_msg msg = {};
> +
> + if (copy_from_user(&msg, parg, sizeof(msg)))
> + return -EFAULT;
> + mutex_lock(&adap->lock);
> + if (!adap->is_configured)
> + err = -ENONET;
> + mutex_unlock(&adap->lock);
> + if (err)
> + return err;
> +
> + err = cec_receive_msg(fh, &msg, block);
> + if (err)
> + return err;
> + if (copy_to_user(parg, &msg, sizeof(msg)))
> + return -EFAULT;
> + break;
> + }
> +
> + case CEC_DQEVENT: {
> + struct cec_event_queue *evq = NULL;
> + struct cec_event *ev = NULL;
> + u64 ts = ~0ULL;
> + unsigned i;
> +
> + mutex_lock(&fh->lock);
> + /* Find the oldest event */
> + for (i = 0; i < CEC_NUM_EVENTS; i++) {
> + struct cec_event_queue *q = fh->evqueue + i;
> +
> + if (q->num_events && q->events->ts <= ts) {
> + evq = q;
> + ev = q->events;
> + ts = ev->ts;
> + }
> + }
> + err = -EAGAIN;
> + if (ev) {
> + if (copy_to_user(parg, ev, sizeof(*ev))) {
> + err = -EFAULT;
> + } else {
> + unsigned j;
> +
> + evq->num_events--;
> + fh->events--;
> + /*
> + * Reset lost message counter after returning
> + * this event.
> + */
> + if (ev->event == CEC_EVENT_LOST_MSGS)
> + fh->lost_msgs = 0;
> + for (j = 0; j < evq->num_events; j++)
> + evq->events[j] = evq->events[j + 1];
> + err = 0;
IMHO, it would be better to mass-pass all events to userspace
and just empty the queue here. As mentioned before, I would also
flag the user if there were event overflows and some events got
discarded.
> + }
> + }
> + mutex_unlock(&fh->lock);
> + return err;
> + }
> +
> + case CEC_ADAP_G_PHYS_ADDR: {
> + u16 phys_addr;
> +
> + mutex_lock(&adap->lock);
> + phys_addr = adap->phys_addr;
> + if (copy_to_user(parg, &phys_addr, sizeof(adap->phys_addr)))
> + err = -EFAULT;
> + mutex_unlock(&adap->lock);
> + break;
> + }
> +
> + case CEC_ADAP_S_PHYS_ADDR: {
> + u16 phys_addr;
> +
> + if (!(adap->capabilities & CEC_CAP_PHYS_ADDR))
> + return -ENOTTY;
> + if (copy_from_user(&phys_addr, parg, sizeof(phys_addr)))
> + return -EFAULT;
> +
> + err = cec_phys_addr_validate(phys_addr, NULL, NULL);
> + if (err)
> + return err;
> + mutex_lock(&adap->lock);
> + if (cec_is_busy(adap, fh))
> + err = -EBUSY;
> + else
> + __cec_s_phys_addr(adap, phys_addr, block);
> + mutex_unlock(&adap->lock);
> + break;
> + }
> +
> + case CEC_ADAP_G_LOG_ADDRS: {
> + struct cec_log_addrs log_addrs;
> +
> + mutex_lock(&adap->lock);
> + log_addrs = adap->log_addrs;
> + if (!adap->is_configured)
> + memset(log_addrs.log_addr, CEC_LOG_ADDR_INVALID,
> + sizeof(log_addrs.log_addr));
> + mutex_unlock(&adap->lock);
> +
> + if (copy_to_user(parg, &log_addrs, sizeof(log_addrs)))
> + return -EFAULT;
> + break;
> + }
> +
> + case CEC_ADAP_S_LOG_ADDRS: {
> + struct cec_log_addrs log_addrs;
> +
> + if (!(adap->capabilities & CEC_CAP_LOG_ADDRS))
> + return -ENOTTY;
> + if (copy_from_user(&log_addrs, parg, sizeof(log_addrs)))
> + return -EFAULT;
> + log_addrs.flags = 0;
> + mutex_lock(&adap->lock);
> + if (adap->is_configuring)
> + err = -EBUSY;
> + else if (log_addrs.num_log_addrs && adap->is_configured)
> + err = -EBUSY;
> + else if (cec_is_busy(adap, fh))
> + err = -EBUSY;
> + else
> + err = __cec_s_log_addrs(adap, &log_addrs, block);
> + if (!err)
> + log_addrs = adap->log_addrs;
> + mutex_unlock(&adap->lock);
> + if (!err && copy_to_user(parg, &log_addrs, sizeof(log_addrs)))
> + return -EFAULT;
> + break;
> + }
> +
> + case CEC_G_MODE: {
> + u32 mode = fh->mode_initiator | fh->mode_follower;
> +
> + if (copy_to_user(parg, &mode, sizeof(mode)))
> + return -EFAULT;
> + break;
> + }
> +
> + case CEC_S_MODE: {
> + u32 mode;
> + u8 mode_initiator;
> + u8 mode_follower;
> +
> + if (copy_from_user(&mode, parg, sizeof(mode)))
> + return -EFAULT;
> + if (mode & ~(CEC_MODE_INITIATOR_MSK | CEC_MODE_FOLLOWER_MSK))
> + return -EINVAL;
> +
> + mode_initiator = mode & CEC_MODE_INITIATOR_MSK;
> + mode_follower = mode & CEC_MODE_FOLLOWER_MSK;
> +
> + if (mode_initiator > CEC_MODE_EXCL_INITIATOR ||
> + mode_follower > CEC_MODE_MONITOR_ALL)
> + return -EINVAL;
> +
> + if (mode_follower == CEC_MODE_MONITOR_ALL &&
> + !(adap->capabilities & CEC_CAP_MONITOR_ALL))
> + return -EINVAL;
> +
> + /* Follower modes should always be able to send CEC messages */
> + if ((mode_initiator == CEC_MODE_NO_INITIATOR ||
> + !(adap->capabilities & CEC_CAP_TRANSMIT)) &&
> + mode_follower >= CEC_MODE_FOLLOWER &&
> + mode_follower <= CEC_MODE_EXCL_FOLLOWER_PASSTHRU)
> + return -EINVAL;
> +
> + /* Monitor modes require CEC_MODE_NO_INITIATOR */
> + if (mode_initiator && mode_follower >= CEC_MODE_MONITOR)
> + return -EINVAL;
> +
> + mutex_lock(&adap->lock);
> + /*
> + * You can't become exclusive follower if someone else already
> + * has that job.
> + */
> + if ((mode_follower == CEC_MODE_EXCL_FOLLOWER ||
> + mode_follower == CEC_MODE_EXCL_FOLLOWER_PASSTHRU) &&
> + adap->cec_follower && adap->cec_follower != fh)
> + err = -EBUSY;
> + /*
> + * You can't become exclusive initiator if someone else already
> + * has that job.
> + */
> + if (mode_initiator == CEC_MODE_EXCL_INITIATOR &&
> + adap->cec_initiator && adap->cec_initiator != fh)
> + err = -EBUSY;
> +
> + if (!err) {
> + bool old_mon_all = fh->mode_follower == CEC_MODE_MONITOR_ALL;
> + bool new_mon_all = mode_follower == CEC_MODE_MONITOR_ALL;
> +
> + if (old_mon_all != new_mon_all) {
> + if (new_mon_all)
> + err = cec_monitor_all_cnt_inc(adap);
> + else
> + cec_monitor_all_cnt_dec(adap);
> + }
> + }
> +
> + if (err) {
> + mutex_unlock(&adap->lock);
> + break;
> + }
> +
> + if (fh->mode_follower == CEC_MODE_FOLLOWER)
> + adap->follower_cnt--;
> + if (mode_follower == CEC_MODE_FOLLOWER)
> + adap->follower_cnt++;
> + if (mode_follower == CEC_MODE_EXCL_FOLLOWER ||
> + mode_follower == CEC_MODE_EXCL_FOLLOWER_PASSTHRU) {
> + adap->passthrough =
> + mode_follower == CEC_MODE_EXCL_FOLLOWER_PASSTHRU;
> + adap->cec_follower = fh;
> + } else if (adap->cec_follower == fh) {
> + adap->passthrough = false;
> + adap->cec_follower = NULL;
> + }
> + if (mode_initiator == CEC_MODE_EXCL_INITIATOR)
> + adap->cec_initiator = fh;
> + else if (adap->cec_initiator == fh)
> + adap->cec_initiator = NULL;
> + fh->mode_initiator = mode_initiator;
> + fh->mode_follower = mode_follower;
> + mutex_unlock(&adap->lock);
> + break;
> + }
> +
> + default:
> + return -ENOTTY;
> + }
> + return err;
> +}
> +
> +static int cec_open(struct inode *inode, struct file *filp)
> +{
> + struct cec_devnode *devnode =
> + container_of(inode->i_cdev, struct cec_devnode, cdev);
> + struct cec_adapter *adap = to_cec_adapter(devnode);
> + struct cec_fh *fh = kzalloc(sizeof(*fh), GFP_KERNEL);
> + /*
> + * Initial events that are automatically sent when the cec device is
> + * opened.
> + */
> + struct cec_event ev_state = {
> + .event = CEC_EVENT_STATE_CHANGE,
> + .flags = CEC_EVENT_FL_INITIAL_STATE,
> + };
> + int ret;
> +
> + if (fh == NULL)
> + return -ENOMEM;
> +
> + ret = cec_queue_event_init(fh);
> +
> + if (ret) {
> + kfree(fh);
> + return ret;
> + }
> +
> + INIT_LIST_HEAD(&fh->msgs);
> + INIT_LIST_HEAD(&fh->xfer_list);
> + mutex_init(&fh->lock);
> + init_waitqueue_head(&fh->wait);
> +
> + fh->mode_initiator = CEC_MODE_INITIATOR;
> + fh->adap = adap;
> +
> + /*
> + * Check if the cec device is available. This needs to be done with
> + * the cec_devnode_lock held to prevent an open/unregister race:
> + * without the lock, the device could be unregistered and freed between
> + * the devnode->registered check and get_device() calls, leading to
> + * a crash.
> + */
> + mutex_lock(&cec_devnode_lock);
> + /*
> + * return ENXIO if the cec device has been removed
> + * already or if it is not registered anymore.
> + */
> + if (!devnode->registered) {
> + mutex_unlock(&cec_devnode_lock);
> + cec_queue_event_free(fh);
> + kfree(fh);
> + return -ENXIO;
> + }
> + /* and increase the device refcount */
> + get_device(&devnode->dev);
> + mutex_unlock(&cec_devnode_lock);
> +
> + filp->private_data = fh;
> +
> + mutex_lock(&devnode->fhs_lock);
> + /* Queue up initial state events */
> + ev_state.state_change.phys_addr = adap->phys_addr;
> + ev_state.state_change.log_addr_mask = adap->log_addrs.log_addr_mask;
> + cec_queue_event_fh(fh, &ev_state, 0);
> +
> + list_add(&fh->list, &devnode->fhs);
> + mutex_unlock(&devnode->fhs_lock);
> +
> + return 0;
> +}
> +
> +/* Override for the release function */
> +static int cec_release(struct inode *inode, struct file *filp)
> +{
> + struct cec_devnode *devnode = cec_devnode_data(filp);
> + struct cec_adapter *adap = to_cec_adapter(devnode);
> + struct cec_fh *fh = filp->private_data;
> +
> + mutex_lock(&adap->lock);
> + if (adap->cec_initiator == fh)
> + adap->cec_initiator = NULL;
> + if (adap->cec_follower == fh) {
> + adap->cec_follower = NULL;
> + adap->passthrough = false;
> + }
> + if (fh->mode_follower == CEC_MODE_FOLLOWER)
> + adap->follower_cnt--;
> + if (fh->mode_follower == CEC_MODE_MONITOR_ALL)
> + cec_monitor_all_cnt_dec(adap);
> + mutex_unlock(&adap->lock);
> +
> + mutex_lock(&devnode->fhs_lock);
> + list_del(&fh->list);
> + mutex_unlock(&devnode->fhs_lock);
> +
> + /* Unhook pending transmits from this filehandle. */
> + mutex_lock(&adap->lock);
> + while (!list_empty(&fh->xfer_list)) {
> + struct cec_data *data =
> + list_first_entry(&fh->xfer_list, struct cec_data, xfer_list);
> +
> + data->blocking = false;
> + data->fh = NULL;
> + list_del(&data->xfer_list);
> + }
> + mutex_unlock(&adap->lock);
> + while (!list_empty(&fh->msgs)) {
> + struct cec_msg_entry *entry =
> + list_first_entry(&fh->msgs, struct cec_msg_entry, list);
> +
> + list_del(&entry->list);
> + kfree(entry);
> + }
> + cec_queue_event_free(fh);
> + kfree(fh);
> +
> + /*
> + * decrease the refcount unconditionally since the release()
> + * return value is ignored.
> + */
> + put_device(&devnode->dev);
> + filp->private_data = NULL;
> + return 0;
> +}
> +
> +static const struct file_operations cec_devnode_fops = {
> + .owner = THIS_MODULE,
> + .open = cec_open,
> + .unlocked_ioctl = cec_ioctl,
> + .release = cec_release,
> + .poll = cec_poll,
> + .llseek = no_llseek,
> +};
> +
> +/* Called when the last user of the cec device exits. */
> +static void cec_devnode_release(struct device *cd)
> +{
> + struct cec_devnode *devnode = to_cec_devnode(cd);
> +
> + mutex_lock(&cec_devnode_lock);
> +
> + /* Mark device node number as free */
> + clear_bit(devnode->minor, cec_devnode_nums);
> +
> + mutex_unlock(&cec_devnode_lock);
> + cec_delete_adapter(to_cec_adapter(devnode));
> +}
> +
> +static struct bus_type cec_bus_type = {
> + .name = CEC_NAME,
> +};
> +
> +/**
> + * cec_devnode_register - register a cec device node
> + * @devnode: cec device node structure we want to register
> + *
> + * The registration code assigns minor numbers and registers the new device node
> + * with the kernel. An error is returned if no free minor number can be found,
> + * or if the registration of the device node fails.
> + *
> + * Zero is returned on success.
> + *
> + * Note that if the cec_devnode_register call fails, the release() callback of
> + * the cec_devnode structure is *not* called, so the caller is responsible for
> + * freeing any data.
> + */
This is a matter of taste, but I very much prefer to have the
comments at the header files, and for all functions exported
with EXPORT_SYMBOL_GPL(). I don't mind if you're willing to
document non-exported functions like the one below, provided that
all exported ones are documented, and the CEC header added to
device-driver.tmpl.
> +static int __must_check cec_devnode_register(struct cec_devnode *devnode,
> + struct module *owner)
> +{
> + int minor;
> + int ret;
> +
> + /* Initialization */
> + INIT_LIST_HEAD(&devnode->fhs);
> + mutex_init(&devnode->fhs_lock);
> +
> + /* Part 1: Find a free minor number */
> + mutex_lock(&cec_devnode_lock);
> + minor = find_next_zero_bit(cec_devnode_nums, CEC_NUM_DEVICES, 0);
> + if (minor == CEC_NUM_DEVICES) {
> + mutex_unlock(&cec_devnode_lock);
> + pr_err("could not get a free minor\n");
> + return -ENFILE;
> + }
> +
> + set_bit(minor, cec_devnode_nums);
> + mutex_unlock(&cec_devnode_lock);
> +
> + devnode->minor = minor;
> + devnode->dev.bus = &cec_bus_type;
> + devnode->dev.devt = MKDEV(MAJOR(cec_dev_t), minor);
> + devnode->dev.release = cec_devnode_release;
> + devnode->dev.parent = devnode->parent;
> + dev_set_name(&devnode->dev, "cec%d", devnode->minor);
> + device_initialize(&devnode->dev);
> +
> + /* Part 2: Initialize and register the character device */
> + cdev_init(&devnode->cdev, &cec_devnode_fops);
> + devnode->cdev.kobj.parent = &devnode->dev.kobj;
> + devnode->cdev.owner = owner;
> +
> + ret = cdev_add(&devnode->cdev, devnode->dev.devt, 1);
> + if (ret < 0) {
> + pr_err("%s: cdev_add failed\n", __func__);
> + goto clr_bit;
> + }
> +
> + ret = device_add(&devnode->dev);
> + if (ret)
> + goto cdev_del;
> +
> + devnode->registered = true;
> + return 0;
> +
> +cdev_del:
> + cdev_del(&devnode->cdev);
> +clr_bit:
> + clear_bit(devnode->minor, cec_devnode_nums);
> + put_device(&devnode->dev);
> + return ret;
> +}
Hmm... not sure how you're freeing the memory allocated
for cec_devnode. Drivers can't free it directly, as a file
descriptor may be opened. I would expect to se a kref()
or some similar mechanism to control its lifecycle.
> +
> +/**
> + * cec_devnode_unregister - unregister a cec device node
> + * @devnode: the device node to unregister
> + *
> + * This unregisters the passed device. Future open calls will be met with
> + * errors.
> + *
> + * This function can safely be called if the device node has never been
> + * registered or has already been unregistered.
> + */
> +static void cec_devnode_unregister(struct cec_devnode *devnode)
> +{
> + struct cec_fh *fh;
> +
> + /* Check if devnode was never registered or already unregistered */
> + if (!devnode->registered || devnode->unregistered)
> + return;
> +
> + mutex_lock(&devnode->fhs_lock);
> + list_for_each_entry(fh, &devnode->fhs, list)
> + wake_up_interruptible(&fh->wait);
> + mutex_unlock(&devnode->fhs_lock);
> +
> + devnode->registered = false;
> + devnode->unregistered = true;
> + device_del(&devnode->dev);
> + cdev_del(&devnode->cdev);
> + put_device(&devnode->dev);
> +}
> +
> +struct cec_adapter *cec_allocate_adapter(const struct cec_adap_ops *ops,
> + void *priv, const char *name, u32 caps, u8 available_las,
> + struct device *parent)
> +{
> + struct cec_adapter *adap;
> + int res;
> +
> + if (WARN_ON(!parent))
> + return ERR_PTR(-EINVAL);
> + if (WARN_ON(!caps))
> + return ERR_PTR(-EINVAL);
> + if (WARN_ON(!ops))
> + return ERR_PTR(-EINVAL);
> + if (WARN_ON(!available_las || available_las > CEC_MAX_LOG_ADDRS))
> + return ERR_PTR(-EINVAL);
> + adap = kzalloc(sizeof(*adap), GFP_KERNEL);
> + if (adap == NULL)
> + return ERR_PTR(-ENOMEM);
> + adap->owner = parent->driver->owner;
> + adap->devnode.parent = parent;
> + strlcpy(adap->name, name, sizeof(adap->name));
> + adap->phys_addr = CEC_PHYS_ADDR_INVALID;
> + adap->log_addrs.cec_version = CEC_OP_CEC_VERSION_2_0;
> + adap->log_addrs.vendor_id = CEC_VENDOR_ID_NONE;
> + adap->capabilities = caps;
> + adap->available_log_addrs = available_las;
> + adap->sequence = 0;
> + adap->ops = ops;
> + adap->priv = priv;
> + memset(adap->phys_addrs, 0xff, sizeof(adap->phys_addrs));
> + mutex_init(&adap->lock);
> + INIT_LIST_HEAD(&adap->transmit_queue);
> + INIT_LIST_HEAD(&adap->wait_queue);
> + init_waitqueue_head(&adap->kthread_waitq);
> +
> + adap->kthread = kthread_run(cec_thread_func, adap, "cec-%s", name);
> + if (IS_ERR(adap->kthread)) {
> + pr_err("cec-%s: kernel_thread() failed\n", name);
> + res = PTR_ERR(adap->kthread);
> + kfree(adap);
> + return ERR_PTR(res);
> + }
> +
> + if (!(caps & CEC_CAP_RC))
> + return adap;
> +
> +#if IS_ENABLED(CONFIG_RC_CORE)
> + /* Prepare the RC input device */
> + adap->rc = rc_allocate_device();
> + if (!adap->rc) {
> + pr_err("cec-%s: failed to allocate memory for rc_dev\n",
> + name);
> + kthread_stop(adap->kthread);
> + kfree(adap);
> + return ERR_PTR(-ENOMEM);
> + }
> +
> + snprintf(adap->input_name, sizeof(adap->input_name),
> + "RC for %s", name);
> + snprintf(adap->input_phys, sizeof(adap->input_phys),
> + "%s/input0", name);
> +
> + adap->rc->input_name = adap->input_name;
> + adap->rc->input_phys = adap->input_phys;
> + adap->rc->input_id.bustype = BUS_CEC;
> + adap->rc->input_id.vendor = 0;
> + adap->rc->input_id.product = 0;
> + adap->rc->input_id.version = 1;
> + adap->rc->dev.parent = parent;
> + adap->rc->driver_type = RC_DRIVER_SCANCODE;
> + adap->rc->allowed_protocols = RC_BIT_CEC;
> + adap->rc->priv = adap;
> + adap->rc->map_name = RC_MAP_CEC;
> + adap->rc->timeout = MS_TO_NS(100);
> +#else
> + adap->capabilities &= ~CEC_CAP_RC;
> +#endif
> + return adap;
> +}
> +EXPORT_SYMBOL_GPL(cec_allocate_adapter);
> +
> +int cec_register_adapter(struct cec_adapter *adap)
> +{
> + int res;
> +
> + if (IS_ERR_OR_NULL(adap))
> + return 0;
> +
> +#if IS_ENABLED(CONFIG_RC_CORE)
> + if (adap->capabilities & CEC_CAP_RC) {
> + res = rc_register_device(adap->rc);
> +
> + if (res) {
> + pr_err("cec-%s: failed to prepare input device\n",
> + adap->name);
> + rc_free_device(adap->rc);
> + adap->rc = NULL;
> + return res;
> + }
> + }
> +#endif
> +
> + res = cec_devnode_register(&adap->devnode, adap->owner);
> +#if IS_ENABLED(CONFIG_RC_CORE)
> + if (res) {
> + /* Note: rc_unregister also calls rc_free */
> + rc_unregister_device(adap->rc);
> + adap->rc = NULL;
> + return res;
> + }
> +#endif
> +
> + dev_set_drvdata(&adap->devnode.dev, adap);
> + if (top_cec_dir == NULL)
> + return 0;
> +
> + adap->cec_dir = debugfs_create_dir(dev_name(&adap->devnode.dev), top_cec_dir);
> + if (IS_ERR_OR_NULL(adap->cec_dir)) {
> + pr_warn("cec-%s: Failed to create debugfs dir\n", adap->name);
> + return 0;
> + }
> + adap->status_file = debugfs_create_devm_seqfile(&adap->devnode.dev,
> + "status", adap->cec_dir, cec_status);
> + if (IS_ERR_OR_NULL(adap->status_file)) {
> + pr_warn("cec-%s: Failed to create status file\n", adap->name);
> + debugfs_remove_recursive(adap->cec_dir);
> + adap->cec_dir = NULL;
> + }
Hmm... shouldn't the above check if CONFIG_DEBUG_FS? Also, IMHO,
this should be an optional feature, as people may not want it on
production systems.
> + return 0;
> +}
> +EXPORT_SYMBOL_GPL(cec_register_adapter);
> +
> +void cec_unregister_adapter(struct cec_adapter *adap)
> +{
> + if (IS_ERR_OR_NULL(adap))
> + return;
> +
> +#if IS_ENABLED(CONFIG_RC_CORE)
> + /* Note: rc_unregister also calls rc_free */
> + rc_unregister_device(adap->rc);
> + adap->rc = NULL;
> +#endif
> + debugfs_remove_recursive(adap->cec_dir);
> + cec_devnode_unregister(&adap->devnode);
> +}
> +EXPORT_SYMBOL_GPL(cec_unregister_adapter);
> +
> +void cec_delete_adapter(struct cec_adapter *adap)
> +{
> + if (IS_ERR_OR_NULL(adap))
> + return;
> + mutex_lock(&adap->lock);
> + __cec_s_phys_addr(adap, CEC_PHYS_ADDR_INVALID, false);
> + mutex_unlock(&adap->lock);
> + kthread_stop(adap->kthread);
> + if (adap->kthread_config)
> + kthread_stop(adap->kthread_config);
> +#if IS_ENABLED(CONFIG_RC_CORE)
> + if (adap->rc)
> + rc_free_device(adap->rc);
> +#endif
> + kfree(adap);
> +}
> +EXPORT_SYMBOL_GPL(cec_delete_adapter);
> +
> +/*
> + * Initialise cec for linux
> + */
> +static int __init cec_devnode_init(void)
> +{
> + int ret;
> +
> + pr_info("Linux cec interface: v0.10\n");
> + ret = alloc_chrdev_region(&cec_dev_t, 0, CEC_NUM_DEVICES,
> + CEC_NAME);
> + if (ret < 0) {
> + pr_warn("cec: unable to allocate major\n");
> + return ret;
> + }
> +
> + top_cec_dir = debugfs_create_dir("cec", NULL);
> + if (IS_ERR_OR_NULL(top_cec_dir)) {
> + pr_warn("cec: Failed to create debugfs cec dir\n");
> + top_cec_dir = NULL;
> + }
> +
> + ret = bus_register(&cec_bus_type);
> + if (ret < 0) {
> + unregister_chrdev_region(cec_dev_t, CEC_NUM_DEVICES);
> + pr_warn("cec: bus_register failed\n");
> + return -EIO;
> + }
> +
> + return 0;
> +}
> +
> +static void __exit cec_devnode_exit(void)
> +{
> + debugfs_remove_recursive(top_cec_dir);
> + bus_unregister(&cec_bus_type);
> + unregister_chrdev_region(cec_dev_t, CEC_NUM_DEVICES);
> +}
> +
> +subsys_initcall(cec_devnode_init);
> +module_exit(cec_devnode_exit)
> +
> +MODULE_AUTHOR("Hans Verkuil <hans.verkuil@xxxxxxxxx>");
> +MODULE_DESCRIPTION("Device node registration for cec drivers");
> +MODULE_LICENSE("GPL");
> diff --git a/include/linux/cec-funcs.h b/include/linux/cec-funcs.h
> new file mode 100644
> index 0000000..25c37bb
> --- /dev/null
> +++ b/include/linux/cec-funcs.h
> @@ -0,0 +1,1871 @@
> +/*
> + * cec - HDMI Consumer Electronics Control message functions
> + *
> + * Copyright 2016 Cisco Systems, Inc. and/or its affiliates. All rights reserved.
> + *
> + * This program is free software; you may redistribute it and/or modify
> + * it under the terms of the GNU General Public License as published by
> + * the Free Software Foundation; version 2 of the License.
> + *
> + * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND,
> + * EXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF
> + * MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND
> + * NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT HOLDERS
> + * BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN AN
> + * ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN
> + * CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE
> + * SOFTWARE.
> + */
> +
> +#ifndef _CEC_UAPI_FUNCS_H
> +#define _CEC_UAPI_FUNCS_H
> +
> +#include <linux/cec.h>
> +
> +/* One Touch Play Feature */
> +static inline void cec_msg_active_source(struct cec_msg *msg, __u16 phys_addr)
> +{
> + msg->len = 4;
> + msg->msg[0] |= 0xf; /* broadcast */
> + msg->msg[1] = CEC_MSG_ACTIVE_SOURCE;
> + msg->msg[2] = phys_addr >> 8;
> + msg->msg[3] = phys_addr & 0xff;
> +}
> +
> +static inline void cec_ops_active_source(const struct cec_msg *msg,
> + __u16 *phys_addr)
> +{
> + *phys_addr = (msg->msg[2] << 8) | msg->msg[3];
> +}
> +
> +static inline void cec_msg_image_view_on(struct cec_msg *msg)
> +{
> + msg->len = 2;
> + msg->msg[1] = CEC_MSG_IMAGE_VIEW_ON;
> +}
> +
> +static inline void cec_msg_text_view_on(struct cec_msg *msg)
> +{
> + msg->len = 2;
> + msg->msg[1] = CEC_MSG_TEXT_VIEW_ON;
> +}
> +
> +
> +/* Routing Control Feature */
> +static inline void cec_msg_inactive_source(struct cec_msg *msg,
> + __u16 phys_addr)
> +{
> + msg->len = 4;
> + msg->msg[1] = CEC_MSG_INACTIVE_SOURCE;
> + msg->msg[2] = phys_addr >> 8;
> + msg->msg[3] = phys_addr & 0xff;
> +}
> +
> +static inline void cec_ops_inactive_source(const struct cec_msg *msg,
> + __u16 *phys_addr)
> +{
> + *phys_addr = (msg->msg[2] << 8) | msg->msg[3];
> +}
> +
> +static inline void cec_msg_request_active_source(struct cec_msg *msg,
> + bool reply)
> +{
> + msg->len = 2;
> + msg->msg[0] |= 0xf; /* broadcast */
> + msg->msg[1] = CEC_MSG_REQUEST_ACTIVE_SOURCE;
> + msg->reply = reply ? CEC_MSG_ACTIVE_SOURCE : 0;
> +}
> +
> +static inline void cec_msg_routing_information(struct cec_msg *msg,
> + __u16 phys_addr)
> +{
> + msg->len = 4;
> + msg->msg[0] |= 0xf; /* broadcast */
> + msg->msg[1] = CEC_MSG_ROUTING_INFORMATION;
> + msg->msg[2] = phys_addr >> 8;
> + msg->msg[3] = phys_addr & 0xff;
> +}
> +
> +static inline void cec_ops_routing_information(const struct cec_msg *msg,
> + __u16 *phys_addr)
> +{
> + *phys_addr = (msg->msg[2] << 8) | msg->msg[3];
> +}
> +
> +static inline void cec_msg_routing_change(struct cec_msg *msg,
> + bool reply,
> + __u16 orig_phys_addr,
> + __u16 new_phys_addr)
> +{
> + msg->len = 6;
> + msg->msg[0] |= 0xf; /* broadcast */
> + msg->msg[1] = CEC_MSG_ROUTING_CHANGE;
> + msg->msg[2] = orig_phys_addr >> 8;
> + msg->msg[3] = orig_phys_addr & 0xff;
> + msg->msg[4] = new_phys_addr >> 8;
> + msg->msg[5] = new_phys_addr & 0xff;
> + msg->reply = reply ? CEC_MSG_ROUTING_INFORMATION : 0;
> +}
> +
> +static inline void cec_ops_routing_change(const struct cec_msg *msg,
> + __u16 *orig_phys_addr,
> + __u16 *new_phys_addr)
> +{
> + *orig_phys_addr = (msg->msg[2] << 8) | msg->msg[3];
> + *new_phys_addr = (msg->msg[4] << 8) | msg->msg[5];
> +}
> +
> +static inline void cec_msg_set_stream_path(struct cec_msg *msg, __u16 phys_addr)
> +{
> + msg->len = 4;
> + msg->msg[0] |= 0xf; /* broadcast */
> + msg->msg[1] = CEC_MSG_SET_STREAM_PATH;
> + msg->msg[2] = phys_addr >> 8;
> + msg->msg[3] = phys_addr & 0xff;
> +}
> +
> +static inline void cec_ops_set_stream_path(const struct cec_msg *msg,
> + __u16 *phys_addr)
> +{
> + *phys_addr = (msg->msg[2] << 8) | msg->msg[3];
> +}
> +
> +
> +/* Standby Feature */
> +static inline void cec_msg_standby(struct cec_msg *msg)
> +{
> + msg->len = 2;
> + msg->msg[1] = CEC_MSG_STANDBY;
> +}
> +
> +
> +/* One Touch Record Feature */
> +static inline void cec_msg_record_off(struct cec_msg *msg)
> +{
> + msg->len = 2;
> + msg->msg[1] = CEC_MSG_RECORD_OFF;
> +}
> +
> +struct cec_op_arib_data {
> + __u16 transport_id;
> + __u16 service_id;
> + __u16 orig_network_id;
> +};
> +
> +struct cec_op_atsc_data {
> + __u16 transport_id;
> + __u16 program_number;
> +};
> +
> +struct cec_op_dvb_data {
> + __u16 transport_id;
> + __u16 service_id;
> + __u16 orig_network_id;
> +};
> +
> +struct cec_op_channel_data {
> + __u8 channel_number_fmt;
> + __u16 major;
> + __u16 minor;
> +};
> +
> +struct cec_op_digital_service_id {
> + __u8 service_id_method;
> + __u8 dig_bcast_system;
> + union {
> + struct cec_op_arib_data arib;
> + struct cec_op_atsc_data atsc;
> + struct cec_op_dvb_data dvb;
> + struct cec_op_channel_data channel;
> + };
> +};
> +
> +struct cec_op_record_src {
> + __u8 type;
> + union {
> + struct cec_op_digital_service_id digital;
> + struct {
> + __u8 ana_bcast_type;
> + __u16 ana_freq;
> + __u8 bcast_system;
> + } analog;
> + struct {
> + __u8 plug;
> + } ext_plug;
> + struct {
> + __u16 phys_addr;
> + } ext_phys_addr;
> + };
> +};
Shouldn't the above be using __le or __be annotations (and the code
below using the endiannes functions to read/write the data)?
> +
> +static inline void cec_set_digital_service_id(__u8 *msg,
> + const struct cec_op_digital_service_id *digital)
> +{
> + *msg++ = (digital->service_id_method << 7) | digital->dig_bcast_system;
> + if (digital->service_id_method == CEC_OP_SERVICE_ID_METHOD_BY_CHANNEL) {
> + *msg++ = (digital->channel.channel_number_fmt << 2) |
> + (digital->channel.major >> 8);
> + *msg++ = digital->channel.major && 0xff;
> + *msg++ = digital->channel.minor >> 8;
> + *msg++ = digital->channel.minor & 0xff;
> + *msg++ = 0;
> + *msg++ = 0;
> + return;
> + }
> + switch (digital->dig_bcast_system) {
> + case CEC_OP_DIG_SERVICE_BCAST_SYSTEM_ATSC_GEN:
> + case CEC_OP_DIG_SERVICE_BCAST_SYSTEM_ATSC_CABLE:
> + case CEC_OP_DIG_SERVICE_BCAST_SYSTEM_ATSC_SAT:
> + case CEC_OP_DIG_SERVICE_BCAST_SYSTEM_ATSC_T:
> + *msg++ = digital->atsc.transport_id >> 8;
> + *msg++ = digital->atsc.transport_id & 0xff;
> + *msg++ = digital->atsc.program_number >> 8;
> + *msg++ = digital->atsc.program_number & 0xff;
> + *msg++ = 0;
> + *msg++ = 0;
> + break;
> + default:
> + *msg++ = digital->dvb.transport_id >> 8;
> + *msg++ = digital->dvb.transport_id & 0xff;
> + *msg++ = digital->dvb.service_id >> 8;
> + *msg++ = digital->dvb.service_id & 0xff;
> + *msg++ = digital->dvb.orig_network_id >> 8;
> + *msg++ = digital->dvb.orig_network_id & 0xff;
> + break;
> + }
> +}
> +
> +static inline void cec_get_digital_service_id(const __u8 *msg,
> + struct cec_op_digital_service_id *digital)
> +{
> + digital->service_id_method = msg[0] >> 7;
> + digital->dig_bcast_system = msg[0] & 0x7f;
> + if (digital->service_id_method == CEC_OP_SERVICE_ID_METHOD_BY_CHANNEL) {
> + digital->channel.channel_number_fmt = msg[1] >> 2;
> + digital->channel.major = ((msg[1] & 3) << 6) | msg[2];
> + digital->channel.minor = (msg[3] << 8) | msg[4];
> + return;
> + }
> + digital->dvb.transport_id = (msg[1] << 8) | msg[2];
> + digital->dvb.service_id = (msg[3] << 8) | msg[4];
> + digital->dvb.orig_network_id = (msg[5] << 8) | msg[6];
> +}
> +
> +static inline void cec_msg_record_on_own(struct cec_msg *msg)
> +{
> + msg->len = 3;
> + msg->msg[1] = CEC_MSG_RECORD_ON;
> + msg->msg[2] = CEC_OP_RECORD_SRC_OWN;
> +}
> +
> +static inline void cec_msg_record_on_digital(struct cec_msg *msg,
> + const struct cec_op_digital_service_id *digital)
> +{
> + msg->len = 10;
> + msg->msg[1] = CEC_MSG_RECORD_ON;
> + msg->msg[2] = CEC_OP_RECORD_SRC_DIGITAL;
> + cec_set_digital_service_id(msg->msg + 3, digital);
> +}
> +
> +static inline void cec_msg_record_on_analog(struct cec_msg *msg,
> + __u8 ana_bcast_type,
> + __u16 ana_freq,
> + __u8 bcast_system)
> +{
> + msg->len = 7;
> + msg->msg[1] = CEC_MSG_RECORD_ON;
> + msg->msg[2] = CEC_OP_RECORD_SRC_ANALOG;
> + msg->msg[3] = ana_bcast_type;
> + msg->msg[4] = ana_freq >> 8;
> + msg->msg[5] = ana_freq & 0xff;
> + msg->msg[6] = bcast_system;
> +}
> +
> +static inline void cec_msg_record_on_plug(struct cec_msg *msg,
> + __u8 plug)
> +{
> + msg->len = 4;
> + msg->msg[1] = CEC_MSG_RECORD_ON;
> + msg->msg[2] = CEC_OP_RECORD_SRC_EXT_PLUG;
> + msg->msg[3] = plug;
> +}
> +
> +static inline void cec_msg_record_on_phys_addr(struct cec_msg *msg,
> + __u16 phys_addr)
> +{
> + msg->len = 5;
> + msg->msg[1] = CEC_MSG_RECORD_ON;
> + msg->msg[2] = CEC_OP_RECORD_SRC_EXT_PHYS_ADDR;
> + msg->msg[3] = phys_addr >> 8;
> + msg->msg[4] = phys_addr & 0xff;
> +}
> +
> +static inline void cec_msg_record_on(struct cec_msg *msg,
> + const struct cec_op_record_src *rec_src)
> +{
> + switch (rec_src->type) {
> + case CEC_OP_RECORD_SRC_OWN:
> + cec_msg_record_on_own(msg);
> + break;
> + case CEC_OP_RECORD_SRC_DIGITAL:
> + cec_msg_record_on_digital(msg, &rec_src->digital);
> + break;
> + case CEC_OP_RECORD_SRC_ANALOG:
> + cec_msg_record_on_analog(msg,
> + rec_src->analog.ana_bcast_type,
> + rec_src->analog.ana_freq,
> + rec_src->analog.bcast_system);
> + break;
> + case CEC_OP_RECORD_SRC_EXT_PLUG:
> + cec_msg_record_on_plug(msg, rec_src->ext_plug.plug);
> + break;
> + case CEC_OP_RECORD_SRC_EXT_PHYS_ADDR:
> + cec_msg_record_on_phys_addr(msg,
> + rec_src->ext_phys_addr.phys_addr);
> + break;
> + }
> +}
> +
> +static inline void cec_ops_record_on(const struct cec_msg *msg,
> + struct cec_op_record_src *rec_src)
> +{
> + rec_src->type = msg->msg[2];
> + switch (rec_src->type) {
> + case CEC_OP_RECORD_SRC_OWN:
> + break;
> + case CEC_OP_RECORD_SRC_DIGITAL:
> + cec_get_digital_service_id(msg->msg + 3, &rec_src->digital);
> + break;
> + case CEC_OP_RECORD_SRC_ANALOG:
> + rec_src->analog.ana_bcast_type = msg->msg[3];
> + rec_src->analog.ana_freq =
> + (msg->msg[4] << 8) | msg->msg[5];
> + rec_src->analog.bcast_system = msg->msg[6];
> + break;
> + case CEC_OP_RECORD_SRC_EXT_PLUG:
> + rec_src->ext_plug.plug = msg->msg[3];
> + break;
> + case CEC_OP_RECORD_SRC_EXT_PHYS_ADDR:
> + rec_src->ext_phys_addr.phys_addr =
> + (msg->msg[3] << 8) | msg->msg[4];
> + break;
> + }
> +}
> +
> +static inline void cec_msg_record_status(struct cec_msg *msg, __u8 rec_status)
> +{
> + msg->len = 3;
> + msg->msg[1] = CEC_MSG_RECORD_STATUS;
> + msg->msg[2] = rec_status;
> +}
> +
> +static inline void cec_ops_record_status(const struct cec_msg *msg,
> + __u8 *rec_status)
> +{
> + *rec_status = msg->msg[2];
> +}
> +
> +static inline void cec_msg_record_tv_screen(struct cec_msg *msg,
> + bool reply)
> +{
> + msg->len = 2;
> + msg->msg[1] = CEC_MSG_RECORD_TV_SCREEN;
> + msg->reply = reply ? CEC_MSG_RECORD_ON : 0;
> +}
> +
> +
> +/* Timer Programming Feature */
> +static inline void cec_msg_timer_status(struct cec_msg *msg,
> + __u8 timer_overlap_warning,
> + __u8 media_info,
> + __u8 prog_info,
> + __u8 prog_error,
> + __u8 duration_hr,
> + __u8 duration_min)
> +{
> + msg->len = 3;
> + msg->msg[1] = CEC_MSG_TIMER_STATUS;
> + msg->msg[2] = (timer_overlap_warning << 7) |
> + (media_info << 5) |
> + (prog_info ? 0x10 : 0) |
> + (prog_info ? prog_info : prog_error);
> + if (prog_info == CEC_OP_PROG_INFO_NOT_ENOUGH_SPACE ||
> + prog_info == CEC_OP_PROG_INFO_MIGHT_NOT_BE_ENOUGH_SPACE ||
> + prog_error == CEC_OP_PROG_ERROR_DUPLICATE) {
> + msg->len += 2;
> + msg->msg[3] = ((duration_hr / 10) << 4) | (duration_hr % 10);
> + msg->msg[4] = ((duration_min / 10) << 4) | (duration_min % 10);
> + }
> +}
> +
> +static inline void cec_ops_timer_status(struct cec_msg *msg,
> + __u8 *timer_overlap_warning,
> + __u8 *media_info,
> + __u8 *prog_info,
> + __u8 *prog_error,
> + __u8 *duration_hr,
> + __u8 *duration_min)
> +{
> + *timer_overlap_warning = msg->msg[2] >> 7;
> + *media_info = (msg->msg[2] >> 5) & 3;
> + if (msg->msg[2] & 0x10) {
> + *prog_info = msg->msg[2] & 0xf;
> + *prog_error = 0;
> + } else {
> + *prog_info = 0;
> + *prog_error = msg->msg[2] & 0xf;
> + }
> + if (*prog_info == CEC_OP_PROG_INFO_NOT_ENOUGH_SPACE ||
> + *prog_info == CEC_OP_PROG_INFO_MIGHT_NOT_BE_ENOUGH_SPACE ||
> + *prog_error == CEC_OP_PROG_ERROR_DUPLICATE) {
> + *duration_hr = (msg->msg[3] >> 4) * 10 + (msg->msg[3] & 0xf);
> + *duration_min = (msg->msg[4] >> 4) * 10 + (msg->msg[4] & 0xf);
> + } else {
> + *duration_hr = *duration_min = 0;
> + }
> +}
> +
> +static inline void cec_msg_timer_cleared_status(struct cec_msg *msg,
> + __u8 timer_cleared_status)
> +{
> + msg->len = 3;
> + msg->msg[1] = CEC_MSG_TIMER_CLEARED_STATUS;
> + msg->msg[2] = timer_cleared_status;
> +}
> +
> +static inline void cec_ops_timer_cleared_status(struct cec_msg *msg,
> + __u8 *timer_cleared_status)
> +{
> + *timer_cleared_status = msg->msg[2];
> +}
> +
> +static inline void cec_msg_clear_analogue_timer(struct cec_msg *msg,
> + bool reply,
> + __u8 day,
> + __u8 month,
> + __u8 start_hr,
> + __u8 start_min,
> + __u8 duration_hr,
> + __u8 duration_min,
> + __u8 recording_seq,
> + __u8 ana_bcast_type,
> + __u16 ana_freq,
> + __u8 bcast_system)
> +{
> + msg->len = 13;
> + msg->msg[1] = CEC_MSG_CLEAR_ANALOGUE_TIMER;
> + msg->msg[2] = day;
> + msg->msg[3] = month;
> + /* Hours and minutes are in BCD format */
> + msg->msg[4] = ((start_hr / 10) << 4) | (start_hr % 10);
> + msg->msg[5] = ((start_min / 10) << 4) | (start_min % 10);
> + msg->msg[6] = ((duration_hr / 10) << 4) | (duration_hr % 10);
> + msg->msg[7] = ((duration_min / 10) << 4) | (duration_min % 10);
> + msg->msg[8] = recording_seq;
> + msg->msg[9] = ana_bcast_type;
> + msg->msg[10] = ana_freq >> 8;
> + msg->msg[11] = ana_freq & 0xff;
> + msg->msg[12] = bcast_system;
> + msg->reply = reply ? CEC_MSG_TIMER_CLEARED_STATUS : 0;
> +}
> +
> +static inline void cec_ops_clear_analogue_timer(struct cec_msg *msg,
> + __u8 *day,
> + __u8 *month,
> + __u8 *start_hr,
> + __u8 *start_min,
> + __u8 *duration_hr,
> + __u8 *duration_min,
> + __u8 *recording_seq,
> + __u8 *ana_bcast_type,
> + __u16 *ana_freq,
> + __u8 *bcast_system)
> +{
> + *day = msg->msg[2];
> + *month = msg->msg[3];
> + /* Hours and minutes are in BCD format */
> + *start_hr = (msg->msg[4] >> 4) * 10 + (msg->msg[4] & 0xf);
> + *start_min = (msg->msg[5] >> 4) * 10 + (msg->msg[5] & 0xf);
> + *duration_hr = (msg->msg[6] >> 4) * 10 + (msg->msg[6] & 0xf);
> + *duration_min = (msg->msg[7] >> 4) * 10 + (msg->msg[7] & 0xf);
> + *recording_seq = msg->msg[8];
> + *ana_bcast_type = msg->msg[9];
> + *ana_freq = (msg->msg[10] << 8) | msg->msg[11];
> + *bcast_system = msg->msg[12];
> +}
> +
> +static inline void cec_msg_clear_digital_timer(struct cec_msg *msg,
> + bool reply,
> + __u8 day,
> + __u8 month,
> + __u8 start_hr,
> + __u8 start_min,
> + __u8 duration_hr,
> + __u8 duration_min,
> + __u8 recording_seq,
> + const struct cec_op_digital_service_id *digital)
> +{
> + msg->len = 16;
> + msg->reply = reply ? CEC_MSG_TIMER_CLEARED_STATUS : 0;
> + msg->msg[1] = CEC_MSG_CLEAR_DIGITAL_TIMER;
> + msg->msg[2] = day;
> + msg->msg[3] = month;
> + /* Hours and minutes are in BCD format */
> + msg->msg[4] = ((start_hr / 10) << 4) | (start_hr % 10);
> + msg->msg[5] = ((start_min / 10) << 4) | (start_min % 10);
> + msg->msg[6] = ((duration_hr / 10) << 4) | (duration_hr % 10);
> + msg->msg[7] = ((duration_min / 10) << 4) | (duration_min % 10);
> + msg->msg[8] = recording_seq;
> + cec_set_digital_service_id(msg->msg + 9, digital);
> +}
> +
> +static inline void cec_ops_clear_digital_timer(struct cec_msg *msg,
> + __u8 *day,
> + __u8 *month,
> + __u8 *start_hr,
> + __u8 *start_min,
> + __u8 *duration_hr,
> + __u8 *duration_min,
> + __u8 *recording_seq,
> + struct cec_op_digital_service_id *digital)
> +{
> + *day = msg->msg[2];
> + *month = msg->msg[3];
> + /* Hours and minutes are in BCD format */
> + *start_hr = (msg->msg[4] >> 4) * 10 + (msg->msg[4] & 0xf);
> + *start_min = (msg->msg[5] >> 4) * 10 + (msg->msg[5] & 0xf);
> + *duration_hr = (msg->msg[6] >> 4) * 10 + (msg->msg[6] & 0xf);
> + *duration_min = (msg->msg[7] >> 4) * 10 + (msg->msg[7] & 0xf);
> + *recording_seq = msg->msg[8];
> + cec_get_digital_service_id(msg->msg + 9, digital);
> +}
> +
> +static inline void cec_msg_clear_ext_timer(struct cec_msg *msg,
> + bool reply,
> + __u8 day,
> + __u8 month,
> + __u8 start_hr,
> + __u8 start_min,
> + __u8 duration_hr,
> + __u8 duration_min,
> + __u8 recording_seq,
> + __u8 ext_src_spec,
> + __u8 plug,
> + __u16 phys_addr)
> +{
> + msg->len = 13;
> + msg->msg[1] = CEC_MSG_CLEAR_EXT_TIMER;
> + msg->msg[2] = day;
> + msg->msg[3] = month;
> + /* Hours and minutes are in BCD format */
> + msg->msg[4] = ((start_hr / 10) << 4) | (start_hr % 10);
> + msg->msg[5] = ((start_min / 10) << 4) | (start_min % 10);
> + msg->msg[6] = ((duration_hr / 10) << 4) | (duration_hr % 10);
> + msg->msg[7] = ((duration_min / 10) << 4) | (duration_min % 10);
> + msg->msg[8] = recording_seq;
> + msg->msg[9] = ext_src_spec;
> + msg->msg[10] = plug;
> + msg->msg[11] = phys_addr >> 8;
> + msg->msg[12] = phys_addr & 0xff;
> + msg->reply = reply ? CEC_MSG_TIMER_CLEARED_STATUS : 0;
> +}
> +
> +static inline void cec_ops_clear_ext_timer(struct cec_msg *msg,
> + __u8 *day,
> + __u8 *month,
> + __u8 *start_hr,
> + __u8 *start_min,
> + __u8 *duration_hr,
> + __u8 *duration_min,
> + __u8 *recording_seq,
> + __u8 *ext_src_spec,
> + __u8 *plug,
> + __u16 *phys_addr)
> +{
> + *day = msg->msg[2];
> + *month = msg->msg[3];
> + /* Hours and minutes are in BCD format */
> + *start_hr = (msg->msg[4] >> 4) * 10 + (msg->msg[4] & 0xf);
> + *start_min = (msg->msg[5] >> 4) * 10 + (msg->msg[5] & 0xf);
> + *duration_hr = (msg->msg[6] >> 4) * 10 + (msg->msg[6] & 0xf);
> + *duration_min = (msg->msg[7] >> 4) * 10 + (msg->msg[7] & 0xf);
> + *recording_seq = msg->msg[8];
> + *ext_src_spec = msg->msg[9];
> + *plug = msg->msg[10];
> + *phys_addr = (msg->msg[11] << 8) | msg->msg[12];
> +}
> +
> +static inline void cec_msg_set_analogue_timer(struct cec_msg *msg,
> + bool reply,
> + __u8 day,
> + __u8 month,
> + __u8 start_hr,
> + __u8 start_min,
> + __u8 duration_hr,
> + __u8 duration_min,
> + __u8 recording_seq,
> + __u8 ana_bcast_type,
> + __u16 ana_freq,
> + __u8 bcast_system)
> +{
> + msg->len = 13;
> + msg->msg[1] = CEC_MSG_SET_ANALOGUE_TIMER;
> + msg->msg[2] = day;
> + msg->msg[3] = month;
> + /* Hours and minutes are in BCD format */
> + msg->msg[4] = ((start_hr / 10) << 4) | (start_hr % 10);
> + msg->msg[5] = ((start_min / 10) << 4) | (start_min % 10);
> + msg->msg[6] = ((duration_hr / 10) << 4) | (duration_hr % 10);
> + msg->msg[7] = ((duration_min / 10) << 4) | (duration_min % 10);
> + msg->msg[8] = recording_seq;
> + msg->msg[9] = ana_bcast_type;
> + msg->msg[10] = ana_freq >> 8;
> + msg->msg[11] = ana_freq & 0xff;
> + msg->msg[12] = bcast_system;
> + msg->reply = reply ? CEC_MSG_TIMER_STATUS : 0;
> +}
> +
> +static inline void cec_ops_set_analogue_timer(struct cec_msg *msg,
> + __u8 *day,
> + __u8 *month,
> + __u8 *start_hr,
> + __u8 *start_min,
> + __u8 *duration_hr,
> + __u8 *duration_min,
> + __u8 *recording_seq,
> + __u8 *ana_bcast_type,
> + __u16 *ana_freq,
> + __u8 *bcast_system)
> +{
> + *day = msg->msg[2];
> + *month = msg->msg[3];
> + /* Hours and minutes are in BCD format */
> + *start_hr = (msg->msg[4] >> 4) * 10 + (msg->msg[4] & 0xf);
> + *start_min = (msg->msg[5] >> 4) * 10 + (msg->msg[5] & 0xf);
> + *duration_hr = (msg->msg[6] >> 4) * 10 + (msg->msg[6] & 0xf);
> + *duration_min = (msg->msg[7] >> 4) * 10 + (msg->msg[7] & 0xf);
> + *recording_seq = msg->msg[8];
> + *ana_bcast_type = msg->msg[9];
> + *ana_freq = (msg->msg[10] << 8) | msg->msg[11];
> + *bcast_system = msg->msg[12];
> +}
> +
> +static inline void cec_msg_set_digital_timer(struct cec_msg *msg,
> + bool reply,
> + __u8 day,
> + __u8 month,
> + __u8 start_hr,
> + __u8 start_min,
> + __u8 duration_hr,
> + __u8 duration_min,
> + __u8 recording_seq,
> + const struct cec_op_digital_service_id *digital)
> +{
> + msg->len = 16;
> + msg->reply = reply ? CEC_MSG_TIMER_STATUS : 0;
> + msg->msg[1] = CEC_MSG_SET_DIGITAL_TIMER;
> + msg->msg[2] = day;
> + msg->msg[3] = month;
> + /* Hours and minutes are in BCD format */
> + msg->msg[4] = ((start_hr / 10) << 4) | (start_hr % 10);
> + msg->msg[5] = ((start_min / 10) << 4) | (start_min % 10);
> + msg->msg[6] = ((duration_hr / 10) << 4) | (duration_hr % 10);
> + msg->msg[7] = ((duration_min / 10) << 4) | (duration_min % 10);
> + msg->msg[8] = recording_seq;
> + cec_set_digital_service_id(msg->msg + 9, digital);
> +}
> +
> +static inline void cec_ops_set_digital_timer(struct cec_msg *msg,
> + __u8 *day,
> + __u8 *month,
> + __u8 *start_hr,
> + __u8 *start_min,
> + __u8 *duration_hr,
> + __u8 *duration_min,
> + __u8 *recording_seq,
> + struct cec_op_digital_service_id *digital)
> +{
> + *day = msg->msg[2];
> + *month = msg->msg[3];
> + /* Hours and minutes are in BCD format */
> + *start_hr = (msg->msg[4] >> 4) * 10 + (msg->msg[4] & 0xf);
> + *start_min = (msg->msg[5] >> 4) * 10 + (msg->msg[5] & 0xf);
> + *duration_hr = (msg->msg[6] >> 4) * 10 + (msg->msg[6] & 0xf);
> + *duration_min = (msg->msg[7] >> 4) * 10 + (msg->msg[7] & 0xf);
> + *recording_seq = msg->msg[8];
> + cec_get_digital_service_id(msg->msg + 9, digital);
> +}
> +
> +static inline void cec_msg_set_ext_timer(struct cec_msg *msg,
> + bool reply,
> + __u8 day,
> + __u8 month,
> + __u8 start_hr,
> + __u8 start_min,
> + __u8 duration_hr,
> + __u8 duration_min,
> + __u8 recording_seq,
> + __u8 ext_src_spec,
> + __u8 plug,
> + __u16 phys_addr)
> +{
> + msg->len = 13;
> + msg->msg[1] = CEC_MSG_SET_EXT_TIMER;
> + msg->msg[2] = day;
> + msg->msg[3] = month;
> + /* Hours and minutes are in BCD format */
> + msg->msg[4] = ((start_hr / 10) << 4) | (start_hr % 10);
> + msg->msg[5] = ((start_min / 10) << 4) | (start_min % 10);
> + msg->msg[6] = ((duration_hr / 10) << 4) | (duration_hr % 10);
> + msg->msg[7] = ((duration_min / 10) << 4) | (duration_min % 10);
> + msg->msg[8] = recording_seq;
> + msg->msg[9] = ext_src_spec;
> + msg->msg[10] = plug;
> + msg->msg[11] = phys_addr >> 8;
> + msg->msg[12] = phys_addr & 0xff;
> + msg->reply = reply ? CEC_MSG_TIMER_STATUS : 0;
> +}
> +
> +static inline void cec_ops_set_ext_timer(struct cec_msg *msg,
> + __u8 *day,
> + __u8 *month,
> + __u8 *start_hr,
> + __u8 *start_min,
> + __u8 *duration_hr,
> + __u8 *duration_min,
> + __u8 *recording_seq,
> + __u8 *ext_src_spec,
> + __u8 *plug,
> + __u16 *phys_addr)
> +{
> + *day = msg->msg[2];
> + *month = msg->msg[3];
> + /* Hours and minutes are in BCD format */
> + *start_hr = (msg->msg[4] >> 4) * 10 + (msg->msg[4] & 0xf);
> + *start_min = (msg->msg[5] >> 4) * 10 + (msg->msg[5] & 0xf);
> + *duration_hr = (msg->msg[6] >> 4) * 10 + (msg->msg[6] & 0xf);
> + *duration_min = (msg->msg[7] >> 4) * 10 + (msg->msg[7] & 0xf);
> + *recording_seq = msg->msg[8];
> + *ext_src_spec = msg->msg[9];
> + *plug = msg->msg[10];
> + *phys_addr = (msg->msg[11] << 8) | msg->msg[12];
> +}
> +
> +static inline void cec_msg_set_timer_program_title(struct cec_msg *msg,
> + const char *prog_title)
> +{
> + unsigned len = strlen(prog_title);
> +
> + if (len > 14)
> + len = 14;
> + msg->len = 2 + len;
> + msg->msg[1] = CEC_MSG_SET_TIMER_PROGRAM_TITLE;
> + memcpy(msg->msg + 2, prog_title, len);
> +}
> +
> +static inline void cec_ops_set_timer_program_title(const struct cec_msg *msg,
> + char *prog_title)
> +{
> + unsigned len = msg->len - 2;
> +
> + if (len > 14)
> + len = 14;
> + memcpy(prog_title, msg->msg + 2, len);
> + prog_title[len] = '\0';
> +}
> +
> +/* System Information Feature */
> +static inline void cec_msg_cec_version(struct cec_msg *msg, __u8 cec_version)
> +{
> + msg->len = 3;
> + msg->msg[1] = CEC_MSG_CEC_VERSION;
> + msg->msg[2] = cec_version;
> +}
> +
> +static inline void cec_ops_cec_version(const struct cec_msg *msg,
> + __u8 *cec_version)
> +{
> + *cec_version = msg->msg[2];
> +}
> +
> +static inline void cec_msg_get_cec_version(struct cec_msg *msg,
> + bool reply)
> +{
> + msg->len = 2;
> + msg->msg[1] = CEC_MSG_GET_CEC_VERSION;
> + msg->reply = reply ? CEC_MSG_CEC_VERSION : 0;
> +}
> +
> +static inline void cec_msg_report_physical_addr(struct cec_msg *msg,
> + __u16 phys_addr, __u8 prim_devtype)
> +{
> + msg->len = 5;
> + msg->msg[0] |= 0xf; /* broadcast */
> + msg->msg[1] = CEC_MSG_REPORT_PHYSICAL_ADDR;
> + msg->msg[2] = phys_addr >> 8;
> + msg->msg[3] = phys_addr & 0xff;
> + msg->msg[4] = prim_devtype;
> +}
> +
> +static inline void cec_ops_report_physical_addr(const struct cec_msg *msg,
> + __u16 *phys_addr, __u8 *prim_devtype)
> +{
> + *phys_addr = (msg->msg[2] << 8) | msg->msg[3];
> + *prim_devtype = msg->msg[4];
> +}
> +
> +static inline void cec_msg_give_physical_addr(struct cec_msg *msg,
> + bool reply)
> +{
> + msg->len = 2;
> + msg->msg[1] = CEC_MSG_GIVE_PHYSICAL_ADDR;
> + msg->reply = reply ? CEC_MSG_REPORT_PHYSICAL_ADDR : 0;
> +}
> +
> +static inline void cec_msg_set_menu_language(struct cec_msg *msg,
> + const char *language)
> +{
> + msg->len = 5;
> + msg->msg[0] |= 0xf; /* broadcast */
> + msg->msg[1] = CEC_MSG_SET_MENU_LANGUAGE;
> + memcpy(msg->msg + 2, language, 3);
> +}
> +
> +static inline void cec_ops_set_menu_language(struct cec_msg *msg,
> + char *language)
> +{
> + memcpy(language, msg->msg + 2, 3);
> +}
> +
> +static inline void cec_msg_get_menu_language(struct cec_msg *msg,
> + bool reply)
> +{
> + msg->len = 2;
> + msg->msg[1] = CEC_MSG_GET_MENU_LANGUAGE;
> + msg->reply = reply ? CEC_MSG_SET_MENU_LANGUAGE : 0;
> +}
> +
> +/*
> + * Assumes a single RC Profile byte and a single Device Features byte,
> + * i.e. no extended features are supported by this helper function.
> + *
> + * As of CEC 2.0 no extended features are defined, should those be added
> + * in the future, then this function needs to be adapted or a new function
> + * should be added.
> + */
> +static inline void cec_msg_report_features(struct cec_msg *msg,
> + __u8 cec_version, __u8 all_device_types,
> + __u8 rc_profile, __u8 dev_features)
> +{
> + msg->len = 6;
> + msg->msg[0] |= 0xf; /* broadcast */
> + msg->msg[1] = CEC_MSG_REPORT_FEATURES;
> + msg->msg[2] = cec_version;
> + msg->msg[3] = all_device_types;
> + msg->msg[4] = rc_profile;
> + msg->msg[5] = dev_features;
> +}
> +
> +static inline void cec_ops_report_features(const struct cec_msg *msg,
> + __u8 *cec_version, __u8 *all_device_types,
> + const __u8 **rc_profile, const __u8 **dev_features)
> +{
> + const __u8 *p = &msg->msg[4];
> +
> + *cec_version = msg->msg[2];
> + *all_device_types = msg->msg[3];
> + *rc_profile = p;
> + while (p < &msg->msg[14] && (*p & CEC_OP_FEAT_EXT))
> + p++;
> + if (!(*p & CEC_OP_FEAT_EXT)) {
> + *dev_features = p + 1;
> + while (p < &msg->msg[15] && (*p & CEC_OP_FEAT_EXT))
> + p++;
> + }
> + if (*p & CEC_OP_FEAT_EXT)
> + *rc_profile = *dev_features = NULL;
> +}
> +
> +static inline void cec_msg_give_features(struct cec_msg *msg,
> + bool reply)
> +{
> + msg->len = 2;
> + msg->msg[1] = CEC_MSG_GIVE_FEATURES;
> + msg->reply = reply ? CEC_MSG_REPORT_FEATURES : 0;
> +}
> +
> +/* Deck Control Feature */
> +static inline void cec_msg_deck_control(struct cec_msg *msg,
> + __u8 deck_control_mode)
> +{
> + msg->len = 3;
> + msg->msg[1] = CEC_MSG_DECK_CONTROL;
> + msg->msg[2] = deck_control_mode;
> +}
> +
> +static inline void cec_ops_deck_control(struct cec_msg *msg,
> + __u8 *deck_control_mode)
> +{
> + *deck_control_mode = msg->msg[2];
> +}
> +
> +static inline void cec_msg_deck_status(struct cec_msg *msg,
> + __u8 deck_info)
> +{
> + msg->len = 3;
> + msg->msg[1] = CEC_MSG_DECK_STATUS;
> + msg->msg[2] = deck_info;
> +}
> +
> +static inline void cec_ops_deck_status(struct cec_msg *msg,
> + __u8 *deck_info)
> +{
> + *deck_info = msg->msg[2];
> +}
> +
> +static inline void cec_msg_give_deck_status(struct cec_msg *msg,
> + bool reply,
> + __u8 status_req)
> +{
> + msg->len = 3;
> + msg->msg[1] = CEC_MSG_GIVE_DECK_STATUS;
> + msg->msg[2] = status_req;
> + msg->reply = reply ? CEC_MSG_DECK_STATUS : 0;
> +}
> +
> +static inline void cec_ops_give_deck_status(struct cec_msg *msg,
> + __u8 *status_req)
> +{
> + *status_req = msg->msg[2];
> +}
> +
> +static inline void cec_msg_play(struct cec_msg *msg,
> + __u8 play_mode)
> +{
> + msg->len = 3;
> + msg->msg[1] = CEC_MSG_PLAY;
> + msg->msg[2] = play_mode;
> +}
> +
> +static inline void cec_ops_play(struct cec_msg *msg,
> + __u8 *play_mode)
> +{
> + *play_mode = msg->msg[2];
> +}
> +
> +
> +/* Tuner Control Feature */
> +struct cec_op_tuner_device_info {
> + __u8 rec_flag;
> + __u8 tuner_display_info;
> + bool is_analog;
> + union {
> + struct cec_op_digital_service_id digital;
> + struct {
> + __u8 ana_bcast_type;
> + __u16 ana_freq;
> + __u8 bcast_system;
> + } analog;
> + };
> +};
> +
> +static inline void cec_msg_tuner_device_status_analog(struct cec_msg *msg,
> + __u8 rec_flag,
> + __u8 tuner_display_info,
> + __u8 ana_bcast_type,
> + __u16 ana_freq,
> + __u8 bcast_system)
> +{
> + msg->len = 7;
> + msg->msg[1] = CEC_MSG_TUNER_DEVICE_STATUS;
> + msg->msg[2] = (rec_flag << 7) | tuner_display_info;
> + msg->msg[3] = ana_bcast_type;
> + msg->msg[4] = ana_freq >> 8;
> + msg->msg[5] = ana_freq & 0xff;
> + msg->msg[6] = bcast_system;
> +}
> +
> +static inline void cec_msg_tuner_device_status_digital(struct cec_msg *msg,
> + __u8 rec_flag, __u8 tuner_display_info,
> + const struct cec_op_digital_service_id *digital)
> +{
> + msg->len = 10;
> + msg->msg[1] = CEC_MSG_TUNER_DEVICE_STATUS;
> + msg->msg[2] = (rec_flag << 7) | tuner_display_info;
> + cec_set_digital_service_id(msg->msg + 3, digital);
> +}
> +
> +static inline void cec_msg_tuner_device_status(struct cec_msg *msg,
> + const struct cec_op_tuner_device_info *tuner_dev_info)
> +{
> + if (tuner_dev_info->is_analog)
> + cec_msg_tuner_device_status_analog(msg,
> + tuner_dev_info->rec_flag,
> + tuner_dev_info->tuner_display_info,
> + tuner_dev_info->analog.ana_bcast_type,
> + tuner_dev_info->analog.ana_freq,
> + tuner_dev_info->analog.bcast_system);
> + else
> + cec_msg_tuner_device_status_digital(msg,
> + tuner_dev_info->rec_flag,
> + tuner_dev_info->tuner_display_info,
> + &tuner_dev_info->digital);
> +}
> +
> +static inline void cec_ops_tuner_device_status(struct cec_msg *msg,
> + struct cec_op_tuner_device_info *tuner_dev_info)
> +{
> + tuner_dev_info->is_analog = msg->len < 10;
> + tuner_dev_info->rec_flag = msg->msg[2] >> 7;
> + tuner_dev_info->tuner_display_info = msg->msg[2] & 0x7f;
> + if (tuner_dev_info->is_analog) {
> + tuner_dev_info->analog.ana_bcast_type = msg->msg[3];
> + tuner_dev_info->analog.ana_freq = (msg->msg[4] << 8) | msg->msg[5];
> + tuner_dev_info->analog.bcast_system = msg->msg[6];
> + return;
> + }
> + cec_get_digital_service_id(msg->msg + 3, &tuner_dev_info->digital);
> +}
> +
> +static inline void cec_msg_give_tuner_device_status(struct cec_msg *msg,
> + bool reply,
> + __u8 status_req)
> +{
> + msg->len = 3;
> + msg->msg[1] = CEC_MSG_GIVE_TUNER_DEVICE_STATUS;
> + msg->msg[2] = status_req;
> + msg->reply = reply ? CEC_MSG_TUNER_DEVICE_STATUS : 0;
> +}
> +
> +static inline void cec_ops_give_tuner_device_status(struct cec_msg *msg,
> + __u8 *status_req)
> +{
> + *status_req = msg->msg[2];
> +}
> +
> +static inline void cec_msg_select_analogue_service(struct cec_msg *msg,
> + __u8 ana_bcast_type,
> + __u16 ana_freq,
> + __u8 bcast_system)
> +{
> + msg->len = 6;
> + msg->msg[1] = CEC_MSG_SELECT_ANALOGUE_SERVICE;
> + msg->msg[2] = ana_bcast_type;
> + msg->msg[3] = ana_freq >> 8;
> + msg->msg[4] = ana_freq & 0xff;
> + msg->msg[5] = bcast_system;
> +}
> +
> +static inline void cec_ops_select_analogue_service(struct cec_msg *msg,
> + __u8 *ana_bcast_type,
> + __u16 *ana_freq,
> + __u8 *bcast_system)
> +{
> + *ana_bcast_type = msg->msg[2];
> + *ana_freq = (msg->msg[3] << 8) | msg->msg[4];
> + *bcast_system = msg->msg[5];
> +}
> +
> +static inline void cec_msg_select_digital_service(struct cec_msg *msg,
> + const struct cec_op_digital_service_id *digital)
> +{
> + msg->len = 9;
> + msg->msg[1] = CEC_MSG_SELECT_DIGITAL_SERVICE;
> + cec_set_digital_service_id(msg->msg + 2, digital);
> +}
> +
> +static inline void cec_ops_select_digital_service(struct cec_msg *msg,
> + struct cec_op_digital_service_id *digital)
> +{
> + cec_get_digital_service_id(msg->msg + 2, digital);
> +}
> +
> +static inline void cec_msg_tuner_step_decrement(struct cec_msg *msg)
> +{
> + msg->len = 2;
> + msg->msg[1] = CEC_MSG_TUNER_STEP_DECREMENT;
> +}
> +
> +static inline void cec_msg_tuner_step_increment(struct cec_msg *msg)
> +{
> + msg->len = 2;
> + msg->msg[1] = CEC_MSG_TUNER_STEP_INCREMENT;
> +}
> +
> +
> +/* Vendor Specific Commands Feature */
> +static inline void cec_msg_device_vendor_id(struct cec_msg *msg, __u32 vendor_id)
> +{
> + msg->len = 5;
> + msg->msg[0] |= 0xf; /* broadcast */
> + msg->msg[1] = CEC_MSG_DEVICE_VENDOR_ID;
> + msg->msg[2] = vendor_id >> 16;
> + msg->msg[3] = (vendor_id >> 8) & 0xff;
> + msg->msg[4] = vendor_id & 0xff;
> +}
> +
> +static inline void cec_ops_device_vendor_id(const struct cec_msg *msg,
> + __u32 *vendor_id)
> +{
> + *vendor_id = (msg->msg[2] << 16) | (msg->msg[3] << 8) | msg->msg[4];
> +}
> +
> +static inline void cec_msg_give_device_vendor_id(struct cec_msg *msg,
> + bool reply)
> +{
> + msg->len = 2;
> + msg->msg[1] = CEC_MSG_GIVE_DEVICE_VENDOR_ID;
> + msg->reply = reply ? CEC_MSG_DEVICE_VENDOR_ID : 0;
> +}
> +
> +static inline void cec_msg_vendor_remote_button_up(struct cec_msg *msg)
> +{
> + msg->len = 2;
> + msg->msg[1] = CEC_MSG_VENDOR_REMOTE_BUTTON_UP;
> +}
> +
> +
> +/* OSD Display Feature */
> +static inline void cec_msg_set_osd_string(struct cec_msg *msg,
> + __u8 disp_ctl,
> + const char *osd)
> +{
> + unsigned len = strlen(osd);
> +
> + if (len > 13)
> + len = 13;
> + msg->len = 3 + len;
> + msg->msg[1] = CEC_MSG_SET_OSD_STRING;
> + msg->msg[2] = disp_ctl;
> + memcpy(msg->msg + 3, osd, len);
> +}
> +
> +static inline void cec_ops_set_osd_string(const struct cec_msg *msg,
> + __u8 *disp_ctl,
> + char *osd)
> +{
> + unsigned len = msg->len - 3;
> +
> + *disp_ctl = msg->msg[2];
> + if (len > 13)
> + len = 13;
> + memcpy(osd, msg->msg + 3, len);
> + osd[len] = '\0';
> +}
> +
> +
> +/* Device OSD Transfer Feature */
> +static inline void cec_msg_set_osd_name(struct cec_msg *msg, const char *name)
> +{
> + unsigned len = strlen(name);
> +
> + if (len > 14)
> + len = 14;
> + msg->len = 2 + len;
> + msg->msg[1] = CEC_MSG_SET_OSD_NAME;
> + memcpy(msg->msg + 2, name, len);
> +}
> +
> +static inline void cec_ops_set_osd_name(const struct cec_msg *msg,
> + char *name)
> +{
> + unsigned len = msg->len - 2;
> +
> + if (len > 14)
> + len = 14;
> + memcpy(name, msg->msg + 2, len);
> + name[len] = '\0';
> +}
> +
> +static inline void cec_msg_give_osd_name(struct cec_msg *msg,
> + bool reply)
> +{
> + msg->len = 2;
> + msg->msg[1] = CEC_MSG_GIVE_OSD_NAME;
> + msg->reply = reply ? CEC_MSG_SET_OSD_NAME : 0;
> +}
> +
> +
> +/* Device Menu Control Feature */
> +static inline void cec_msg_menu_status(struct cec_msg *msg,
> + __u8 menu_state)
> +{
> + msg->len = 3;
> + msg->msg[1] = CEC_MSG_MENU_STATUS;
> + msg->msg[2] = menu_state;
> +}
> +
> +static inline void cec_ops_menu_status(struct cec_msg *msg,
> + __u8 *menu_state)
> +{
> + *menu_state = msg->msg[2];
> +}
> +
> +static inline void cec_msg_menu_request(struct cec_msg *msg,
> + bool reply,
> + __u8 menu_req)
> +{
> + msg->len = 3;
> + msg->msg[1] = CEC_MSG_MENU_REQUEST;
> + msg->msg[2] = menu_req;
> + msg->reply = reply ? CEC_MSG_MENU_STATUS : 0;
> +}
> +
> +static inline void cec_ops_menu_request(struct cec_msg *msg,
> + __u8 *menu_req)
> +{
> + *menu_req = msg->msg[2];
> +}
> +
> +struct cec_op_ui_command {
> + __u8 ui_cmd;
> + bool has_opt_arg;
> + union {
> + struct cec_op_channel_data channel_identifier;
> + __u8 ui_broadcast_type;
> + __u8 ui_sound_presentation_control;
> + __u8 play_mode;
> + __u8 ui_function_media;
> + __u8 ui_function_select_av_input;
> + __u8 ui_function_select_audio_input;
> + };
> +};
> +
> +static inline void cec_msg_user_control_pressed(struct cec_msg *msg,
> + const struct cec_op_ui_command *ui_cmd)
> +{
> + msg->len = 3;
> + msg->msg[1] = CEC_MSG_USER_CONTROL_PRESSED;
> + msg->msg[2] = ui_cmd->ui_cmd;
> + if (!ui_cmd->has_opt_arg)
> + return;
> + switch (ui_cmd->ui_cmd) {
> + case 0x56:
> + case 0x57:
> + case 0x60:
> + case 0x68:
> + case 0x69:
> + case 0x6a:
> + /* The optional operand is one byte for all these ui commands */
> + msg->len++;
> + msg->msg[3] = ui_cmd->play_mode;
> + break;
> + case 0x67:
> + msg->len += 4;
> + msg->msg[3] = (ui_cmd->channel_identifier.channel_number_fmt << 2) |
> + (ui_cmd->channel_identifier.major >> 8);
> + msg->msg[4] = ui_cmd->channel_identifier.major && 0xff;
> + msg->msg[5] = ui_cmd->channel_identifier.minor >> 8;
> + msg->msg[6] = ui_cmd->channel_identifier.minor & 0xff;
> + break;
> + }
> +}
> +
> +static inline void cec_ops_user_control_pressed(struct cec_msg *msg,
> + struct cec_op_ui_command *ui_cmd)
> +{
> + ui_cmd->ui_cmd = msg->msg[2];
> + ui_cmd->has_opt_arg = false;
> + if (msg->len == 3)
> + return;
> + switch (ui_cmd->ui_cmd) {
> + case 0x56:
> + case 0x57:
> + case 0x60:
> + case 0x68:
> + case 0x69:
> + case 0x6a:
> + /* The optional operand is one byte for all these ui commands */
> + ui_cmd->play_mode = msg->msg[3];
> + ui_cmd->has_opt_arg = true;
> + break;
> + case 0x67:
> + if (msg->len < 7)
> + break;
> + ui_cmd->has_opt_arg = true;
> + ui_cmd->channel_identifier.channel_number_fmt = msg->msg[3] >> 2;
> + ui_cmd->channel_identifier.major = ((msg->msg[3] & 3) << 6) | msg->msg[4];
> + ui_cmd->channel_identifier.minor = (msg->msg[5] << 8) | msg->msg[6];
> + break;
> + }
> +}
> +
> +static inline void cec_msg_user_control_released(struct cec_msg *msg)
> +{
> + msg->len = 2;
> + msg->msg[1] = CEC_MSG_USER_CONTROL_RELEASED;
> +}
> +
> +/* Remote Control Passthrough Feature */
> +
> +/* Power Status Feature */
> +static inline void cec_msg_report_power_status(struct cec_msg *msg,
> + __u8 pwr_state)
> +{
> + msg->len = 3;
> + msg->msg[1] = CEC_MSG_REPORT_POWER_STATUS;
> + msg->msg[2] = pwr_state;
> +}
> +
> +static inline void cec_ops_report_power_status(const struct cec_msg *msg,
> + __u8 *pwr_state)
> +{
> + *pwr_state = msg->msg[2];
> +}
> +
> +static inline void cec_msg_give_device_power_status(struct cec_msg *msg,
> + bool reply)
> +{
> + msg->len = 2;
> + msg->msg[1] = CEC_MSG_GIVE_DEVICE_POWER_STATUS;
> + msg->reply = reply ? CEC_MSG_REPORT_POWER_STATUS : 0;
> +}
> +
> +/* General Protocol Messages */
> +static inline void cec_msg_feature_abort(struct cec_msg *msg,
> + __u8 abort_msg, __u8 reason)
> +{
> + msg->len = 4;
> + msg->msg[1] = CEC_MSG_FEATURE_ABORT;
> + msg->msg[2] = abort_msg;
> + msg->msg[3] = reason;
> +}
> +
> +static inline void cec_ops_feature_abort(const struct cec_msg *msg,
> + __u8 *abort_msg, __u8 *reason)
> +{
> + *abort_msg = msg->msg[2];
> + *reason = msg->msg[3];
> +}
> +
> +/* This changes the current message into a feature abort message */
> +static inline void cec_msg_reply_feature_abort(struct cec_msg *msg, __u8 reason)
> +{
> + cec_msg_set_reply_to(msg, msg);
> + msg->len = 4;
> + msg->msg[2] = msg->msg[1];
> + msg->msg[3] = reason;
> + msg->msg[1] = CEC_MSG_FEATURE_ABORT;
> +}
> +
> +static inline void cec_msg_abort(struct cec_msg *msg)
> +{
> + msg->len = 2;
> + msg->msg[1] = CEC_MSG_ABORT;
> +}
> +
> +
> +/* System Audio Control Feature */
> +static inline void cec_msg_report_audio_status(struct cec_msg *msg,
> + __u8 aud_mute_status,
> + __u8 aud_vol_status)
> +{
> + msg->len = 3;
> + msg->msg[1] = CEC_MSG_REPORT_AUDIO_STATUS;
> + msg->msg[2] = (aud_mute_status << 7) | (aud_vol_status & 0x7f);
> +}
> +
> +static inline void cec_ops_report_audio_status(const struct cec_msg *msg,
> + __u8 *aud_mute_status,
> + __u8 *aud_vol_status)
> +{
> + *aud_mute_status = msg->msg[2] >> 7;
> + *aud_vol_status = msg->msg[2] & 0x7f;
> +}
> +
> +static inline void cec_msg_give_audio_status(struct cec_msg *msg,
> + bool reply)
> +{
> + msg->len = 2;
> + msg->msg[1] = CEC_MSG_GIVE_AUDIO_STATUS;
> + msg->reply = reply ? CEC_MSG_REPORT_AUDIO_STATUS : 0;
> +}
> +
> +static inline void cec_msg_set_system_audio_mode(struct cec_msg *msg,
> + __u8 sys_aud_status)
> +{
> + msg->len = 3;
> + msg->msg[1] = CEC_MSG_SET_SYSTEM_AUDIO_MODE;
> + msg->msg[2] = sys_aud_status;
> +}
> +
> +static inline void cec_ops_set_system_audio_mode(const struct cec_msg *msg,
> + __u8 *sys_aud_status)
> +{
> + *sys_aud_status = msg->msg[2];
> +}
> +
> +static inline void cec_msg_system_audio_mode_request(struct cec_msg *msg,
> + bool reply,
> + __u16 phys_addr)
> +{
> + msg->len = phys_addr == 0xffff ? 2 : 4;
> + msg->msg[1] = CEC_MSG_SYSTEM_AUDIO_MODE_REQUEST;
> + msg->msg[2] = phys_addr >> 8;
> + msg->msg[3] = phys_addr & 0xff;
> + msg->reply = reply ? CEC_MSG_SET_SYSTEM_AUDIO_MODE : 0;
> +
> +}
> +
> +static inline void cec_ops_system_audio_mode_request(const struct cec_msg *msg,
> + __u16 *phys_addr)
> +{
> + if (msg->len < 4)
> + *phys_addr = 0xffff;
> + else
> + *phys_addr = (msg->msg[2] << 8) | msg->msg[3];
> +}
> +
> +static inline void cec_msg_system_audio_mode_status(struct cec_msg *msg,
> + __u8 sys_aud_status)
> +{
> + msg->len = 3;
> + msg->msg[1] = CEC_MSG_SYSTEM_AUDIO_MODE_STATUS;
> + msg->msg[2] = sys_aud_status;
> +}
> +
> +static inline void cec_ops_system_audio_mode_status(const struct cec_msg *msg,
> + __u8 *sys_aud_status)
> +{
> + *sys_aud_status = msg->msg[2];
> +}
> +
> +static inline void cec_msg_give_system_audio_mode_status(struct cec_msg *msg,
> + bool reply)
> +{
> + msg->len = 2;
> + msg->msg[1] = CEC_MSG_GIVE_SYSTEM_AUDIO_MODE_STATUS;
> + msg->reply = reply ? CEC_MSG_SYSTEM_AUDIO_MODE_STATUS : 0;
> +}
> +
> +static inline void cec_msg_report_short_audio_descriptor(struct cec_msg *msg,
> + __u8 num_descriptors,
> + const __u32 *descriptors)
> +{
> + unsigned i;
> +
> + if (num_descriptors > 4)
> + num_descriptors = 4;
> + msg->len = 2 + num_descriptors * 3;
> + msg->msg[1] = CEC_MSG_REPORT_SHORT_AUDIO_DESCRIPTOR;
> + for (i = 0; i < num_descriptors; i++) {
> + msg->msg[2 + i * 3] = (descriptors[i] >> 16) & 0xff;
> + msg->msg[3 + i * 3] = (descriptors[i] >> 8) & 0xff;
> + msg->msg[4 + i * 3] = descriptors[i] & 0xff;
> + }
> +}
> +
> +static inline void cec_ops_report_short_audio_descriptor(const struct cec_msg *msg,
> + __u8 *num_descriptors,
> + __u32 *descriptors)
> +{
> + unsigned i;
> +
> + *num_descriptors = (msg->len - 2) / 3;
> + if (*num_descriptors > 4)
> + *num_descriptors = 4;
> + for (i = 0; i < *num_descriptors; i++)
> + descriptors[i] = (msg->msg[2 + i * 3] << 16) |
> + (msg->msg[3 + i * 3] << 8) |
> + msg->msg[4 + i * 3];
> +}
> +
> +static inline void cec_msg_request_short_audio_descriptor(struct cec_msg *msg,
> + __u8 num_descriptors,
> + const __u8 *audio_format_id,
> + const __u8 *audio_format_code)
> +{
> + unsigned i;
> +
> + if (num_descriptors > 4)
> + num_descriptors = 4;
> + msg->len = 2 + num_descriptors;
> + msg->msg[1] = CEC_MSG_REQUEST_SHORT_AUDIO_DESCRIPTOR;
> + for (i = 0; i < num_descriptors; i++)
> + msg->msg[2 + i] = (audio_format_id[i] << 6) | (audio_format_code[i] & 0x3f);
> +}
> +
> +static inline void cec_ops_request_short_audio_descriptor(const struct cec_msg *msg,
> + __u8 *num_descriptors,
> + __u8 *audio_format_id,
> + __u8 *audio_format_code)
> +{
> + unsigned i;
> +
> + *num_descriptors = msg->len - 2;
> + if (*num_descriptors > 4)
> + *num_descriptors = 4;
> + for (i = 0; i < *num_descriptors; i++) {
> + audio_format_id[i] = msg->msg[2 + i] >> 6;
> + audio_format_code[i] = msg->msg[2 + i] & 0x3f;
> + }
> +}
> +
> +
> +/* Audio Rate Control Feature */
> +static inline void cec_msg_set_audio_rate(struct cec_msg *msg,
> + __u8 audio_rate)
> +{
> + msg->len = 3;
> + msg->msg[1] = CEC_MSG_SET_AUDIO_RATE;
> + msg->msg[2] = audio_rate;
> +}
> +
> +static inline void cec_ops_set_audio_rate(const struct cec_msg *msg,
> + __u8 *audio_rate)
> +{
> + *audio_rate = msg->msg[2];
> +}
> +
> +
> +/* Audio Return Channel Control Feature */
> +static inline void cec_msg_report_arc_initiated(struct cec_msg *msg)
> +{
> + msg->len = 2;
> + msg->msg[1] = CEC_MSG_REPORT_ARC_INITIATED;
> +}
> +
> +static inline void cec_msg_initiate_arc(struct cec_msg *msg,
> + bool reply)
> +{
> + msg->len = 2;
> + msg->msg[1] = CEC_MSG_INITIATE_ARC;
> + msg->reply = reply ? CEC_MSG_REPORT_ARC_INITIATED : 0;
> +}
> +
> +static inline void cec_msg_request_arc_initiation(struct cec_msg *msg,
> + bool reply)
> +{
> + msg->len = 2;
> + msg->msg[1] = CEC_MSG_REQUEST_ARC_INITIATION;
> + msg->reply = reply ? CEC_MSG_INITIATE_ARC : 0;
> +}
> +
> +static inline void cec_msg_report_arc_terminated(struct cec_msg *msg)
> +{
> + msg->len = 2;
> + msg->msg[1] = CEC_MSG_REPORT_ARC_TERMINATED;
> +}
> +
> +static inline void cec_msg_terminate_arc(struct cec_msg *msg,
> + bool reply)
> +{
> + msg->len = 2;
> + msg->msg[1] = CEC_MSG_TERMINATE_ARC;
> + msg->reply = reply ? CEC_MSG_REPORT_ARC_TERMINATED : 0;
> +}
> +
> +static inline void cec_msg_request_arc_termination(struct cec_msg *msg,
> + bool reply)
> +{
> + msg->len = 2;
> + msg->msg[1] = CEC_MSG_REQUEST_ARC_TERMINATION;
> + msg->reply = reply ? CEC_MSG_TERMINATE_ARC : 0;
> +}
> +
> +
> +/* Dynamic Audio Lipsync Feature */
> +/* Only for CEC 2.0 and up */
> +static inline void cec_msg_report_current_latency(struct cec_msg *msg,
> + __u16 phys_addr,
> + __u8 video_latency,
> + __u8 low_latency_mode,
> + __u8 audio_out_compensated,
> + __u8 audio_out_delay)
> +{
> + msg->len = 7;
> + msg->msg[1] = CEC_MSG_REPORT_CURRENT_LATENCY;
> + msg->msg[2] = phys_addr >> 8;
> + msg->msg[3] = phys_addr & 0xff;
> + msg->msg[4] = video_latency;
> + msg->msg[5] = (low_latency_mode << 2) | audio_out_compensated;
> + msg->msg[6] = audio_out_delay;
> +}
> +
> +static inline void cec_ops_report_current_latency(const struct cec_msg *msg,
> + __u16 *phys_addr,
> + __u8 *video_latency,
> + __u8 *low_latency_mode,
> + __u8 *audio_out_compensated,
> + __u8 *audio_out_delay)
> +{
> + *phys_addr = (msg->msg[2] << 8) | msg->msg[3];
> + *video_latency = msg->msg[4];
> + *low_latency_mode = (msg->msg[5] >> 2) & 1;
> + *audio_out_compensated = msg->msg[5] & 3;
> + *audio_out_delay = msg->msg[6];
> +}
> +
> +static inline void cec_msg_request_current_latency(struct cec_msg *msg,
> + bool reply,
> + __u16 phys_addr)
> +{
> + msg->len = 4;
> + msg->msg[1] = CEC_MSG_REQUEST_CURRENT_LATENCY;
> + msg->msg[2] = phys_addr >> 8;
> + msg->msg[3] = phys_addr & 0xff;
> + msg->reply = reply ? CEC_MSG_REPORT_CURRENT_LATENCY : 0;
> +}
> +
> +static inline void cec_ops_request_current_latency(const struct cec_msg *msg,
> + __u16 *phys_addr)
> +{
> + *phys_addr = (msg->msg[2] << 8) | msg->msg[3];
> +}
> +
> +
> +/* Capability Discovery and Control Feature */
> +static inline void cec_msg_cdc_hec_inquire_state(struct cec_msg *msg,
> + __u16 phys_addr1,
> + __u16 phys_addr2)
> +{
> + msg->len = 9;
> + msg->msg[0] |= 0xf; /* broadcast */
> + msg->msg[1] = CEC_MSG_CDC_MESSAGE;
> + /* msg[2] and msg[3] (phys_addr) are filled in by the CEC framework */
> + msg->msg[4] = CEC_MSG_CDC_HEC_INQUIRE_STATE;
> + msg->msg[5] = phys_addr1 >> 8;
> + msg->msg[6] = phys_addr1 & 0xff;
> + msg->msg[7] = phys_addr2 >> 8;
> + msg->msg[8] = phys_addr2 & 0xff;
> +}
> +
> +static inline void cec_ops_cdc_hec_inquire_state(const struct cec_msg *msg,
> + __u16 *phys_addr,
> + __u16 *phys_addr1,
> + __u16 *phys_addr2)
> +{
> + *phys_addr = (msg->msg[2] << 8) | msg->msg[3];
> + *phys_addr1 = (msg->msg[5] << 8) | msg->msg[6];
> + *phys_addr2 = (msg->msg[7] << 8) | msg->msg[8];
> +}
> +
> +static inline void cec_msg_cdc_hec_report_state(struct cec_msg *msg,
> + __u16 target_phys_addr,
> + __u8 hec_func_state,
> + __u8 host_func_state,
> + __u8 enc_func_state,
> + __u8 cdc_errcode,
> + __u8 has_field,
> + __u16 hec_field)
> +{
> + msg->len = has_field ? 10 : 8;
> + msg->msg[0] |= 0xf; /* broadcast */
> + msg->msg[1] = CEC_MSG_CDC_MESSAGE;
> + /* msg[2] and msg[3] (phys_addr) are filled in by the CEC framework */
> + msg->msg[4] = CEC_MSG_CDC_HEC_REPORT_STATE;
> + msg->msg[5] = target_phys_addr >> 8;
> + msg->msg[6] = target_phys_addr & 0xff;
> + msg->msg[7] = (hec_func_state << 6) |
> + (host_func_state << 4) |
> + (enc_func_state << 2) |
> + cdc_errcode;
> + if (has_field) {
> + msg->msg[8] = hec_field >> 8;
> + msg->msg[9] = hec_field & 0xff;
> + }
> +}
> +
> +static inline void cec_ops_cdc_hec_report_state(const struct cec_msg *msg,
> + __u16 *phys_addr,
> + __u16 *target_phys_addr,
> + __u8 *hec_func_state,
> + __u8 *host_func_state,
> + __u8 *enc_func_state,
> + __u8 *cdc_errcode,
> + __u8 *has_field,
> + __u16 *hec_field)
> +{
> + *phys_addr = (msg->msg[2] << 8) | msg->msg[3];
> + *target_phys_addr = (msg->msg[5] << 8) | msg->msg[6];
> + *hec_func_state = msg->msg[7] >> 6;
> + *host_func_state = (msg->msg[7] >> 4) & 3;
> + *enc_func_state = (msg->msg[7] >> 4) & 3;
> + *cdc_errcode = msg->msg[7] & 3;
> + *has_field = msg->len >= 10;
> + *hec_field = *has_field ? ((msg->msg[8] << 8) | msg->msg[9]) : 0;
> +}
> +
> +static inline void cec_msg_cdc_hec_set_state(struct cec_msg *msg,
> + __u16 phys_addr1,
> + __u16 phys_addr2,
> + __u8 hec_set_state,
> + __u16 phys_addr3,
> + __u16 phys_addr4,
> + __u16 phys_addr5)
> +{
> + msg->len = 10;
> + msg->msg[0] |= 0xf; /* broadcast */
> + msg->msg[1] = CEC_MSG_CDC_MESSAGE;
> + /* msg[2] and msg[3] (phys_addr) are filled in by the CEC framework */
> + msg->msg[4] = CEC_MSG_CDC_HEC_INQUIRE_STATE;
> + msg->msg[5] = phys_addr1 >> 8;
> + msg->msg[6] = phys_addr1 & 0xff;
> + msg->msg[7] = phys_addr2 >> 8;
> + msg->msg[8] = phys_addr2 & 0xff;
> + msg->msg[9] = hec_set_state;
> + if (phys_addr3 != CEC_PHYS_ADDR_INVALID) {
> + msg->msg[msg->len++] = phys_addr3 >> 8;
> + msg->msg[msg->len++] = phys_addr3 & 0xff;
> + if (phys_addr4 != CEC_PHYS_ADDR_INVALID) {
> + msg->msg[msg->len++] = phys_addr4 >> 8;
> + msg->msg[msg->len++] = phys_addr4 & 0xff;
> + if (phys_addr5 != CEC_PHYS_ADDR_INVALID) {
> + msg->msg[msg->len++] = phys_addr5 >> 8;
> + msg->msg[msg->len++] = phys_addr5 & 0xff;
> + }
> + }
> + }
> +}
> +
> +static inline void cec_ops_cdc_hec_set_state(const struct cec_msg *msg,
> + __u16 *phys_addr,
> + __u16 *phys_addr1,
> + __u16 *phys_addr2,
> + __u8 *hec_set_state,
> + __u16 *phys_addr3,
> + __u16 *phys_addr4,
> + __u16 *phys_addr5)
> +{
> + *phys_addr = (msg->msg[2] << 8) | msg->msg[3];
> + *phys_addr1 = (msg->msg[5] << 8) | msg->msg[6];
> + *phys_addr2 = (msg->msg[7] << 8) | msg->msg[8];
> + *hec_set_state = msg->msg[9];
> + *phys_addr3 = *phys_addr4 = *phys_addr5 = CEC_PHYS_ADDR_INVALID;
> + if (msg->len >= 12)
> + *phys_addr3 = (msg->msg[10] << 8) | msg->msg[11];
> + if (msg->len >= 14)
> + *phys_addr4 = (msg->msg[12] << 8) | msg->msg[13];
> + if (msg->len >= 16)
> + *phys_addr5 = (msg->msg[14] << 8) | msg->msg[15];
> +}
> +
> +static inline void cec_msg_cdc_hec_set_state_adjacent(struct cec_msg *msg,
> + __u16 phys_addr1,
> + __u8 hec_set_state)
> +{
> + msg->len = 8;
> + msg->msg[0] |= 0xf; /* broadcast */
> + msg->msg[1] = CEC_MSG_CDC_MESSAGE;
> + /* msg[2] and msg[3] (phys_addr) are filled in by the CEC framework */
> + msg->msg[4] = CEC_MSG_CDC_HEC_SET_STATE_ADJACENT;
> + msg->msg[5] = phys_addr1 >> 8;
> + msg->msg[6] = phys_addr1 & 0xff;
> + msg->msg[7] = hec_set_state;
> +}
> +
> +static inline void cec_ops_cdc_hec_set_state_adjacent(const struct cec_msg *msg,
> + __u16 *phys_addr,
> + __u16 *phys_addr1,
> + __u8 *hec_set_state)
> +{
> + *phys_addr = (msg->msg[2] << 8) | msg->msg[3];
> + *phys_addr1 = (msg->msg[5] << 8) | msg->msg[6];
> + *hec_set_state = msg->msg[7];
> +}
> +
> +static inline void cec_msg_cdc_hec_request_deactivation(struct cec_msg *msg,
> + __u16 phys_addr1,
> + __u16 phys_addr2,
> + __u16 phys_addr3)
> +{
> + msg->len = 11;
> + msg->msg[0] |= 0xf; /* broadcast */
> + msg->msg[1] = CEC_MSG_CDC_MESSAGE;
> + /* msg[2] and msg[3] (phys_addr) are filled in by the CEC framework */
> + msg->msg[4] = CEC_MSG_CDC_HEC_REQUEST_DEACTIVATION;
> + msg->msg[5] = phys_addr1 >> 8;
> + msg->msg[6] = phys_addr1 & 0xff;
> + msg->msg[7] = phys_addr2 >> 8;
> + msg->msg[8] = phys_addr2 & 0xff;
> + msg->msg[9] = phys_addr3 >> 8;
> + msg->msg[10] = phys_addr3 & 0xff;
> +}
> +
> +static inline void cec_ops_cdc_hec_request_deactivation(const struct cec_msg *msg,
> + __u16 *phys_addr,
> + __u16 *phys_addr1,
> + __u16 *phys_addr2,
> + __u16 *phys_addr3)
> +{
> + *phys_addr = (msg->msg[2] << 8) | msg->msg[3];
> + *phys_addr1 = (msg->msg[5] << 8) | msg->msg[6];
> + *phys_addr2 = (msg->msg[7] << 8) | msg->msg[8];
> + *phys_addr3 = (msg->msg[9] << 8) | msg->msg[10];
> +}
> +
> +static inline void cec_msg_cdc_hec_notify_alive(struct cec_msg *msg)
> +{
> + msg->len = 5;
> + msg->msg[0] |= 0xf; /* broadcast */
> + msg->msg[1] = CEC_MSG_CDC_MESSAGE;
> + /* msg[2] and msg[3] (phys_addr) are filled in by the CEC framework */
> + msg->msg[4] = CEC_MSG_CDC_HEC_NOTIFY_ALIVE;
> +}
> +
> +static inline void cec_ops_cdc_hec_notify_alive(const struct cec_msg *msg,
> + __u16 *phys_addr)
> +{
> + *phys_addr = (msg->msg[2] << 8) | msg->msg[3];
> +}
> +
> +static inline void cec_msg_cdc_hec_discover(struct cec_msg *msg)
> +{
> + msg->len = 5;
> + msg->msg[0] |= 0xf; /* broadcast */
> + msg->msg[1] = CEC_MSG_CDC_MESSAGE;
> + /* msg[2] and msg[3] (phys_addr) are filled in by the CEC framework */
> + msg->msg[4] = CEC_MSG_CDC_HEC_DISCOVER;
> +}
> +
> +static inline void cec_ops_cdc_hec_discover(const struct cec_msg *msg,
> + __u16 *phys_addr)
> +{
> + *phys_addr = (msg->msg[2] << 8) | msg->msg[3];
> +}
> +
> +static inline void cec_msg_cdc_hpd_set_state(struct cec_msg *msg,
> + __u8 input_port,
> + __u8 hpd_state)
> +{
> + msg->len = 6;
> + msg->msg[0] |= 0xf; /* broadcast */
> + msg->msg[1] = CEC_MSG_CDC_MESSAGE;
> + /* msg[2] and msg[3] (phys_addr) are filled in by the CEC framework */
> + msg->msg[4] = CEC_MSG_CDC_HPD_SET_STATE;
> + msg->msg[5] = (input_port << 4) | hpd_state;
> +}
> +
> +static inline void cec_ops_cdc_hpd_set_state(const struct cec_msg *msg,
> + __u16 *phys_addr,
> + __u8 *input_port,
> + __u8 *hpd_state)
> +{
> + *phys_addr = (msg->msg[2] << 8) | msg->msg[3];
> + *input_port = msg->msg[5] >> 4;
> + *hpd_state = msg->msg[5] & 0xf;
> +}
> +
> +static inline void cec_msg_cdc_hpd_report_state(struct cec_msg *msg,
> + __u8 hpd_state,
> + __u8 hpd_error)
> +{
> + msg->len = 6;
> + msg->msg[0] |= 0xf; /* broadcast */
> + msg->msg[1] = CEC_MSG_CDC_MESSAGE;
> + /* msg[2] and msg[3] (phys_addr) are filled in by the CEC framework */
> + msg->msg[4] = CEC_MSG_CDC_HPD_REPORT_STATE;
> + msg->msg[5] = (hpd_state << 4) | hpd_error;
> +}
> +
> +static inline void cec_ops_cdc_hpd_report_state(const struct cec_msg *msg,
> + __u16 *phys_addr,
> + __u8 *hpd_state,
> + __u8 *hpd_error)
> +{
> + *phys_addr = (msg->msg[2] << 8) | msg->msg[3];
> + *hpd_state = msg->msg[5] >> 4;
> + *hpd_error = msg->msg[5] & 0xf;
> +}
> +
> +#endif
> diff --git a/include/linux/cec.h b/include/linux/cec.h
> new file mode 100644
> index 0000000..521b07cb
> --- /dev/null
> +++ b/include/linux/cec.h
> @@ -0,0 +1,985 @@
> +/*
> + * cec - HDMI Consumer Electronics Control public header
> + *
> + * Copyright 2016 Cisco Systems, Inc. and/or its affiliates. All rights reserved.
> + *
> + * This program is free software; you may redistribute it and/or modify
> + * it under the terms of the GNU General Public License as published by
> + * the Free Software Foundation; version 2 of the License.
> + *
> + * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND,
> + * EXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF
> + * MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND
> + * NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT HOLDERS
> + * BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN AN
> + * ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN
> + * CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE
> + * SOFTWARE.
> + */
> +
> +#ifndef _CEC_UAPI_H
> +#define _CEC_UAPI_H
Is this UAPI? If so, why it is at include/linux, instead of
include/uapi/linux?
> +
> +#include <linux/types.h>
> +
> +#define CEC_MAX_MSG_SIZE 16
> +
> +/**
> + * struct cec_msg - CEC message structure.
> + * @ts: Timestamp in nanoseconds using CLOCK_MONOTONIC. Set by the
> + * driver. It is set when the message transmission has finished
> + * and it is set when a message was received.
> + * @len: Length in bytes of the message.
> + * @timeout: The timeout (in ms) that is used to timeout CEC_RECEIVE.
> + * Set to 0 if you want to wait forever. This timeout can also be
> + * used with CEC_TRANSMIT as the timeout for waiting for a reply.
> + * If 0, then it will use a 1 second timeout instead of waiting
> + * forever as is done with CEC_RECEIVE.
> + * @sequence: The framework assigns a sequence number to messages that are
> + * sent. This can be used to track replies to previously sent
> + * messages.
> + * @flags: Set to 0.
> + * @rx_status: The message receive status bits. Set by the driver.
> + * @tx_status: The message transmit status bits. Set by the driver.
> + * @msg: The message payload.
> + * @reply: This field is ignored with CEC_RECEIVE and is only used by
> + * CEC_TRANSMIT. If non-zero, then wait for a reply with this
> + * opcode. Set to CEC_MSG_FEATURE_ABORT if you want to wait for
> + * a possible ABORT reply. If there was an error when sending the
> + * msg or FeatureAbort was returned, then reply is set to 0.
> + * If reply is non-zero upon return, then len/msg are set to
> + * the received message.
> + * If reply is zero upon return and status has the
> + * CEC_TX_STATUS_FEATURE_ABORT bit set, then len/msg are set to
> + * the received feature abort message.
> + * If reply is zero upon return and status has the
> + * CEC_TX_STATUS_MAX_RETRIES bit set, then no reply was seen at
> + * all. If reply is non-zero for CEC_TRANSMIT and the message is a
> + * broadcast, then -EINVAL is returned.
> + * if reply is non-zero, then timeout is set to 1000 (the required
> + * maximum response time).
> + * @tx_arb_lost_cnt: The number of 'Arbitration Lost' events. Set by the driver.
> + * @tx_nack_cnt: The number of 'Not Acknowledged' events. Set by the driver.
> + * @tx_low_drive_cnt: The number of 'Low Drive Detected' events. Set by the driver.
> + * @tx_error_cnt: The number of 'Error' events. Set by the driver.
> + */
> +struct cec_msg {
> + __u64 ts;
> + __u32 len;
> + __u32 timeout;
> + __u32 sequence;
> + __u32 flags;
> + __u8 rx_status;
> + __u8 tx_status;
> + __u8 msg[CEC_MAX_MSG_SIZE];
> + __u8 reply;
> + __u8 tx_arb_lost_cnt;
> + __u8 tx_nack_cnt;
> + __u8 tx_low_drive_cnt;
> + __u8 tx_error_cnt;
> +};
> +
> +/**
> + * cec_msg_initiator - return the initiator's logical address.
> + * @msg: the message structure
> + */
> +static inline __u8 cec_msg_initiator(const struct cec_msg *msg)
> +{
> + return msg->msg[0] >> 4;
> +}
> +
> +/**
> + * cec_msg_destination - return the destination's logical address.
> + * @msg: the message structure
> + */
> +static inline __u8 cec_msg_destination(const struct cec_msg *msg)
> +{
> + return msg->msg[0] & 0xf;
> +}
> +
> +/**
> + * cec_msg_opcode - return the opcode of the message, -1 for poll
> + * @msg: the message structure
> + */
> +static inline int cec_msg_opcode(const struct cec_msg *msg)
> +{
> + return msg->len > 1 ? msg->msg[1] : -1;
> +}
> +
> +/**
> + * cec_msg_is_broadcast - return true if this is a broadcast message.
> + * @msg: the message structure
> + */
> +static inline bool cec_msg_is_broadcast(const struct cec_msg *msg)
> +{
> + return (msg->msg[0] & 0xf) == 0xf;
> +}
> +
> +/**
> + * cec_msg_init - initialize the message structure.
> + * @msg: the message structure
> + * @initiator: the logical address of the initiator
> + * @destination:the logical address of the destination (0xf for broadcast)
> + *
> + * The whole structure is zeroed, the len field is set to 1 (i.e. a poll
> + * message) and the initiator and destination are filled in.
> + */
> +static inline void cec_msg_init(struct cec_msg *msg,
> + __u8 initiator, __u8 destination)
> +{
> + memset(msg, 0, sizeof(*msg));
> + msg->msg[0] = (initiator << 4) | destination;
> + msg->len = 1;
> +}
> +
> +/**
> + * cec_msg_set_reply_to - fill in destination/initiator in a reply message.
> + * @msg: the message structure for the reply
> + * @orig: the original message structure
> + *
> + * Set the msg destination to the orig initiator and the msg initiator to the
> + * orig destination. Note that msg and orig may be the same pointer, in which
> + * case the change is done in place.
> + */
> +static inline void cec_msg_set_reply_to(struct cec_msg *msg, struct cec_msg *orig)
> +{
> + /* The destination becomes the initiator and vice versa */
> + msg->msg[0] = (cec_msg_destination(orig) << 4) | cec_msg_initiator(orig);
> + msg->reply = msg->timeout = 0;
> +}
> +
> +/* cec status field */
> +#define CEC_TX_STATUS_OK (1 << 0)
> +#define CEC_TX_STATUS_ARB_LOST (1 << 1)
> +#define CEC_TX_STATUS_NACK (1 << 2)
> +#define CEC_TX_STATUS_LOW_DRIVE (1 << 3)
> +#define CEC_TX_STATUS_ERROR (1 << 4)
> +#define CEC_TX_STATUS_MAX_RETRIES (1 << 5)
> +
> +#define CEC_RX_STATUS_OK (1 << 0)
> +#define CEC_RX_STATUS_TIMEOUT (1 << 1)
> +#define CEC_RX_STATUS_FEATURE_ABORT (1 << 2)
> +
> +static inline bool cec_msg_status_is_ok(const struct cec_msg *msg)
> +{
> + if (msg->tx_status && !(msg->tx_status & CEC_TX_STATUS_OK))
> + return false;
> + if (msg->rx_status && !(msg->rx_status & CEC_RX_STATUS_OK))
> + return false;
> + if (!msg->tx_status && !msg->rx_status)
> + return false;
> + return !(msg->rx_status & CEC_RX_STATUS_FEATURE_ABORT);
> +}
> +
> +#define CEC_LOG_ADDR_INVALID 0xff
> +#define CEC_PHYS_ADDR_INVALID 0xffff
> +
> +/*
> + * The maximum number of logical addresses one device can be assigned to.
> + * The CEC 2.0 spec allows for only 2 logical addresses at the moment. The
> + * Analog Devices CEC hardware supports 3. So let's go wild and go for 4.
> + */
> +#define CEC_MAX_LOG_ADDRS 4
> +
> +/* The logical addresses defined by CEC 2.0 */
> +#define CEC_LOG_ADDR_TV 0
> +#define CEC_LOG_ADDR_RECORD_1 1
> +#define CEC_LOG_ADDR_RECORD_2 2
> +#define CEC_LOG_ADDR_TUNER_1 3
> +#define CEC_LOG_ADDR_PLAYBACK_1 4
> +#define CEC_LOG_ADDR_AUDIOSYSTEM 5
> +#define CEC_LOG_ADDR_TUNER_2 6
> +#define CEC_LOG_ADDR_TUNER_3 7
> +#define CEC_LOG_ADDR_PLAYBACK_2 8
> +#define CEC_LOG_ADDR_RECORD_3 9
> +#define CEC_LOG_ADDR_TUNER_4 10
> +#define CEC_LOG_ADDR_PLAYBACK_3 11
> +#define CEC_LOG_ADDR_BACKUP_1 12
> +#define CEC_LOG_ADDR_BACKUP_2 13
> +#define CEC_LOG_ADDR_SPECIFIC 14
> +#define CEC_LOG_ADDR_UNREGISTERED 15 /* as initiator address */
> +#define CEC_LOG_ADDR_BROADCAST 15 /* ad destination address */
> +
> +/* The logical address types that the CEC device wants to claim */
> +#define CEC_LOG_ADDR_TYPE_TV 0
> +#define CEC_LOG_ADDR_TYPE_RECORD 1
> +#define CEC_LOG_ADDR_TYPE_TUNER 2
> +#define CEC_LOG_ADDR_TYPE_PLAYBACK 3
> +#define CEC_LOG_ADDR_TYPE_AUDIOSYSTEM 4
> +#define CEC_LOG_ADDR_TYPE_SPECIFIC 5
> +#define CEC_LOG_ADDR_TYPE_UNREGISTERED 6
> +/*
> + * Switches should use UNREGISTERED.
> + * Processors should use SPECIFIC.
> + */
> +
> +#define CEC_LOG_ADDR_MASK_TV (1 << CEC_LOG_ADDR_TV)
> +#define CEC_LOG_ADDR_MASK_RECORD ((1 << CEC_LOG_ADDR_RECORD_1) | \
> + (1 << CEC_LOG_ADDR_RECORD_2) | \
> + (1 << CEC_LOG_ADDR_RECORD_3))
> +#define CEC_LOG_ADDR_MASK_TUNER ((1 << CEC_LOG_ADDR_TUNER_1) | \
> + (1 << CEC_LOG_ADDR_TUNER_2) | \
> + (1 << CEC_LOG_ADDR_TUNER_3) | \
> + (1 << CEC_LOG_ADDR_TUNER_4))
> +#define CEC_LOG_ADDR_MASK_PLAYBACK ((1 << CEC_LOG_ADDR_PLAYBACK_1) | \
> + (1 << CEC_LOG_ADDR_PLAYBACK_2) | \
> + (1 << CEC_LOG_ADDR_PLAYBACK_3))
> +#define CEC_LOG_ADDR_MASK_AUDIOSYSTEM (1 << CEC_LOG_ADDR_AUDIOSYSTEM)
> +#define CEC_LOG_ADDR_MASK_BACKUP ((1 << CEC_LOG_ADDR_BACKUP_1) | \
> + (1 << CEC_LOG_ADDR_BACKUP_2))
> +#define CEC_LOG_ADDR_MASK_SPECIFIC (1 << CEC_LOG_ADDR_SPECIFIC)
> +#define CEC_LOG_ADDR_MASK_UNREGISTERED (1 << CEC_LOG_ADDR_UNREGISTERED)
> +
> +static inline bool cec_has_tv(__u16 log_addr_mask)
> +{
> + return log_addr_mask & CEC_LOG_ADDR_MASK_TV;
> +}
> +
> +static inline bool cec_has_record(__u16 log_addr_mask)
> +{
> + return log_addr_mask & CEC_LOG_ADDR_MASK_RECORD;
> +}
> +
> +static inline bool cec_has_tuner(__u16 log_addr_mask)
> +{
> + return log_addr_mask & CEC_LOG_ADDR_MASK_TUNER;
> +}
> +
> +static inline bool cec_has_playback(__u16 log_addr_mask)
> +{
> + return log_addr_mask & CEC_LOG_ADDR_MASK_PLAYBACK;
> +}
> +
> +static inline bool cec_has_audiosystem(__u16 log_addr_mask)
> +{
> + return log_addr_mask & CEC_LOG_ADDR_MASK_AUDIOSYSTEM;
> +}
> +
> +static inline bool cec_has_backup(__u16 log_addr_mask)
> +{
> + return log_addr_mask & CEC_LOG_ADDR_MASK_BACKUP;
> +}
> +
> +static inline bool cec_has_specific(__u16 log_addr_mask)
> +{
> + return log_addr_mask & CEC_LOG_ADDR_MASK_SPECIFIC;
> +}
> +
> +static inline bool cec_is_unregistered(__u16 log_addr_mask)
> +{
> + return log_addr_mask & CEC_LOG_ADDR_MASK_UNREGISTERED;
> +}
> +
> +static inline bool cec_is_unconfigured(__u16 log_addr_mask)
> +{
> + return log_addr_mask == 0;
> +}
> +
> +/*
> + * Use this if there is no vendor ID (CEC_G_VENDOR_ID) or if the vendor ID
> + * should be disabled (CEC_S_VENDOR_ID)
> + */
> +#define CEC_VENDOR_ID_NONE 0xffffffff
> +
> +/* The message handling modes */
> +/* Modes for initiator */
> +#define CEC_MODE_NO_INITIATOR (0x0 << 0)
> +#define CEC_MODE_INITIATOR (0x1 << 0)
> +#define CEC_MODE_EXCL_INITIATOR (0x2 << 0)
> +#define CEC_MODE_INITIATOR_MSK 0x0f
> +
> +/* Modes for follower */
> +#define CEC_MODE_NO_FOLLOWER (0x0 << 4)
> +#define CEC_MODE_FOLLOWER (0x1 << 4)
> +#define CEC_MODE_EXCL_FOLLOWER (0x2 << 4)
> +#define CEC_MODE_EXCL_FOLLOWER_PASSTHRU (0x3 << 4)
> +#define CEC_MODE_MONITOR (0xe << 4)
> +#define CEC_MODE_MONITOR_ALL (0xf << 4)
> +#define CEC_MODE_FOLLOWER_MSK 0xf0
> +
> +/* Userspace has to configure the physical address */
> +#define CEC_CAP_PHYS_ADDR (1 << 0)
> +/* Userspace has to configure the logical addresses */
> +#define CEC_CAP_LOG_ADDRS (1 << 1)
> +/* Userspace can transmit messages (and thus become follower as well) */
> +#define CEC_CAP_TRANSMIT (1 << 2)
> +/*
> + * Passthrough all messages instead of processing them.
> + */
> +#define CEC_CAP_PASSTHROUGH (1 << 3)
> +/* Supports remote control */
> +#define CEC_CAP_RC (1 << 4)
> +/* Hardware can monitor all messages, not just directed and broadcast. */
> +#define CEC_CAP_MONITOR_ALL (1 << 5)
> +
> +/**
> + * struct cec_caps - CEC capabilities structure.
> + * @driver: name of the CEC device driver.
> + * @name: name of the CEC device. @driver + @name must be unique.
> + * @available_log_addrs: number of available logical addresses.
> + * @capabilities: capabilities of the CEC adapter.
> + * @version: version of the CEC adapter framework.
> + * @reserved: Reserved fields, both driver and application must zero this array.
> + */
> +struct cec_caps {
> + char driver[32];
> + char name[32];
> + __u32 available_log_addrs;
> + __u32 capabilities;
> + __u32 version;
> +};
> +
> +/**
> + * struct cec_log_addrs - CEC logical addresses structure.
> + * @log_addr: the claimed logical addresses. Set by the driver.
> + * @log_addr_mask: current logical address mask. Set by the driver.
> + * @cec_version: the CEC version that the adapter should implement. Set by the
> + * caller.
> + * @num_log_addrs: how many logical addresses should be claimed. Set by the
> + * caller.
> + * @vendor_id: the vendor ID of the device. Set by the caller.
> + * @flags: set to 0.
> + * @osd_name: the OSD name of the device. Set by the caller.
> + * @primary_device_type: the primary device type for each logical address.
> + * Set by the caller.
> + * @log_addr_type: the logical address types. Set by the caller.
> + * @all_device_types: CEC 2.0: all device types represented by the logical address.
> + * Set by the caller.
> + * @features: CEC 2.0: The logical address features. Set by the caller.
> + */
> +struct cec_log_addrs {
> + __u8 log_addr[CEC_MAX_LOG_ADDRS];
> + __u16 log_addr_mask;
> + __u8 cec_version;
> + __u8 num_log_addrs;
> + __u32 vendor_id;
> + __u32 flags;
> + char osd_name[15];
> + __u8 primary_device_type[CEC_MAX_LOG_ADDRS];
> + __u8 log_addr_type[CEC_MAX_LOG_ADDRS];
> +
> + /* CEC 2.0 */
> + __u8 all_device_types[CEC_MAX_LOG_ADDRS];
> + __u8 features[CEC_MAX_LOG_ADDRS][12];
> +};
> +
> +/* Events */
> +
> +/* Event that occurs when the adapter state changes */
> +#define CEC_EVENT_STATE_CHANGE 1
Are there any reason why not start with zero?
> +/*
> + * This event is sent when messages are lost because the application
> + * didn't empty the message queue in time
> + */
> +#define CEC_EVENT_LOST_MSGS 2
> +
> +#define CEC_EVENT_FL_INITIAL_STATE (1 << 0)
> +
> +/**
> + * struct cec_event_state_change - used when the CEC adapter changes state.
> + * @phys_addr: the current physical address
> + * @log_addr_mask: the current logical address mask
> + */
> +struct cec_event_state_change {
> + __u16 phys_addr;
> + __u16 log_addr_mask;
> +};
> +
> +/**
> + * struct cec_event_lost_msgs - tells you how many messages were lost due.
> + * @lost_msgs: how many messages were lost.
> + */
> +struct cec_event_lost_msgs {
> + __u32 lost_msgs;
> +};
> +
> +/**
> + * struct cec_event - CEC event structure
> + * @ts: the timestamp of when the event was sent.
> + * @event: the event.
> + * array.
> + * @state_change: the event payload for CEC_EVENT_STATE_CHANGE.
> + * @lost_msgs: the event payload for CEC_EVENT_LOST_MSGS.
> + * @raw: array to pad the union.
> + */
> +struct cec_event {
> + __u64 ts;
> + __u32 event;
> + __u32 flags;
> + union {
> + struct cec_event_state_change state_change;
> + struct cec_event_lost_msgs lost_msgs;
> + __u32 raw[16];
> + };
> +};
> +
> +/* ioctls */
> +
> +/* Adapter capabilities */
> +#define CEC_ADAP_G_CAPS _IOWR('a', 0, struct cec_caps)
> +
> +/*
> + * phys_addr is either 0 (if this is the CEC root device)
> + * or a valid physical address obtained from the sink's EDID
> + * as read by this CEC device (if this is a source device)
> + * or a physical address obtained and modified from a sink
> + * EDID and used for a sink CEC device.
> + * If nothing is connected, then phys_addr is 0xffff.
> + * See HDMI 1.4b, section 8.7 (Physical Address).
> + *
> + * The CEC_ADAP_S_PHYS_ADDR ioctl may not be available if that is handled
> + * internally.
> + */
> +#define CEC_ADAP_G_PHYS_ADDR _IOR ('a', 1, __u16)
> +#define CEC_ADAP_S_PHYS_ADDR _IOW ('a', 2, __u16)
> +
> +/*
> + * Configure the CEC adapter. It sets the device type and which
> + * logical types it will try to claim. It will return which
> + * logical addresses it could actually claim.
> + * An error is returned if the adapter is disabled or if there
> + * is no physical address assigned.
> + */
> +
> +#define CEC_ADAP_G_LOG_ADDRS _IOR ('a', 3, struct cec_log_addrs)
> +#define CEC_ADAP_S_LOG_ADDRS _IOWR('a', 4, struct cec_log_addrs)
> +
> +/* Transmit/receive a CEC command */
> +#define CEC_TRANSMIT _IOWR('a', 5, struct cec_msg)
> +#define CEC_RECEIVE _IOWR('a', 6, struct cec_msg)
> +
> +/* Dequeue CEC events */
> +#define CEC_DQEVENT _IOWR('a', 7, struct cec_event)
> +
> +/*
> + * Get and set the message handling mode for this filehandle.
> + */
> +#define CEC_G_MODE _IOR ('a', 8, __u32)
> +#define CEC_S_MODE _IOW ('a', 9, __u32)
> +
> +/*
> + * The remainder of this header defines all CEC messages and operands.
> + * The format matters since it the cec-ctl utility parses it to generate
> + * code for implementing all these messages.
> + *
> + * Comments ending with 'Feature' group messages for each feature.
> + * If messages are part of multiple features, then the "Has also"
> + * comment is used to list the previously defined messages that are
> + * supported by the feature.
> + *
> + * Before operands are defined a comment is added that gives the
> + * name of the operand and in brackets the variable name of the
> + * corresponding argument in the cec-funcs.h function.
> + */
> +
> +/* Messages */
> +
> +/* One Touch Play Feature */
> +#define CEC_MSG_ACTIVE_SOURCE 0x82
> +#define CEC_MSG_IMAGE_VIEW_ON 0x04
> +#define CEC_MSG_TEXT_VIEW_ON 0x0d
> +
> +
> +/* Routing Control Feature */
> +
> +/*
> + * Has also:
> + * CEC_MSG_ACTIVE_SOURCE
> + */
> +
> +#define CEC_MSG_INACTIVE_SOURCE 0x9d
> +#define CEC_MSG_REQUEST_ACTIVE_SOURCE 0x85
> +#define CEC_MSG_ROUTING_CHANGE 0x80
> +#define CEC_MSG_ROUTING_INFORMATION 0x81
> +#define CEC_MSG_SET_STREAM_PATH 0x86
> +
> +
> +/* Standby Feature */
> +#define CEC_MSG_STANDBY 0x36
> +
> +
> +/* One Touch Record Feature */
> +#define CEC_MSG_RECORD_OFF 0x0b
> +#define CEC_MSG_RECORD_ON 0x09
> +/* Record Source Type Operand (rec_src_type) */
> +#define CEC_OP_RECORD_SRC_OWN 1
> +#define CEC_OP_RECORD_SRC_DIGITAL 2
> +#define CEC_OP_RECORD_SRC_ANALOG 3
> +#define CEC_OP_RECORD_SRC_EXT_PLUG 4
> +#define CEC_OP_RECORD_SRC_EXT_PHYS_ADDR 5
> +/* Service Identification Method Operand (service_id_method) */
> +#define CEC_OP_SERVICE_ID_METHOD_BY_DIG_ID 0
> +#define CEC_OP_SERVICE_ID_METHOD_BY_CHANNEL 1
> +/* Digital Service Broadcast System Operand (dig_bcast_system) */
> +#define CEC_OP_DIG_SERVICE_BCAST_SYSTEM_ARIB_GEN 0x00
> +#define CEC_OP_DIG_SERVICE_BCAST_SYSTEM_ATSC_GEN 0x01
> +#define CEC_OP_DIG_SERVICE_BCAST_SYSTEM_DVB_GEN 0x02
> +#define CEC_OP_DIG_SERVICE_BCAST_SYSTEM_ARIB_BS 0x08
> +#define CEC_OP_DIG_SERVICE_BCAST_SYSTEM_ARIB_CS 0x09
> +#define CEC_OP_DIG_SERVICE_BCAST_SYSTEM_ARIB_T 0x0a
> +#define CEC_OP_DIG_SERVICE_BCAST_SYSTEM_ATSC_CABLE 0x10
> +#define CEC_OP_DIG_SERVICE_BCAST_SYSTEM_ATSC_SAT 0x11
> +#define CEC_OP_DIG_SERVICE_BCAST_SYSTEM_ATSC_T 0x12
> +#define CEC_OP_DIG_SERVICE_BCAST_SYSTEM_DVB_C 0x18
> +#define CEC_OP_DIG_SERVICE_BCAST_SYSTEM_DVB_S 0x19
> +#define CEC_OP_DIG_SERVICE_BCAST_SYSTEM_DVB_S2 0x1a
> +#define CEC_OP_DIG_SERVICE_BCAST_SYSTEM_DVB_T 0x1b
> +/* Analogue Broadcast Type Operand (ana_bcast_type) */
> +#define CEC_OP_ANA_BCAST_TYPE_CABLE 0
> +#define CEC_OP_ANA_BCAST_TYPE_SATELLITE 1
> +#define CEC_OP_ANA_BCAST_TYPE_TERRESTRIAL 2
> +/* Broadcast System Operand (bcast_system) */
> +#define CEC_OP_BCAST_SYSTEM_PAL_BG 0x00
> +#define CEC_OP_BCAST_SYSTEM_SECAM_LQ 0x01 /* SECAM L' */
> +#define CEC_OP_BCAST_SYSTEM_PAL_M 0x02
> +#define CEC_OP_BCAST_SYSTEM_NTSC_M 0x03
> +#define CEC_OP_BCAST_SYSTEM_PAL_I 0x04
> +#define CEC_OP_BCAST_SYSTEM_SECAM_DK 0x05
> +#define CEC_OP_BCAST_SYSTEM_SECAM_BG 0x06
> +#define CEC_OP_BCAST_SYSTEM_SECAM_L 0x07
> +#define CEC_OP_BCAST_SYSTEM_PAL_DK 0x08
> +#define CEC_OP_BCAST_SYSTEM_OTHER 0x1f
> +/* Channel Number Format Operand (channel_number_fmt) */
> +#define CEC_OP_CHANNEL_NUMBER_FMT_1_PART 0x01
> +#define CEC_OP_CHANNEL_NUMBER_FMT_2_PART 0x02
> +
> +#define CEC_MSG_RECORD_STATUS 0x0a
> +/* Record Status Operand (rec_status) */
> +#define CEC_OP_RECORD_STATUS_CUR_SRC 0x01
> +#define CEC_OP_RECORD_STATUS_DIG_SERVICE 0x02
> +#define CEC_OP_RECORD_STATUS_ANA_SERVICE 0x03
> +#define CEC_OP_RECORD_STATUS_EXT_INPUT 0x04
> +#define CEC_OP_RECORD_STATUS_NO_DIG_SERVICE 0x05
> +#define CEC_OP_RECORD_STATUS_NO_ANA_SERVICE 0x06
> +#define CEC_OP_RECORD_STATUS_NO_SERVICE 0x07
> +#define CEC_OP_RECORD_STATUS_INVALID_EXT_PLUG 0x09
> +#define CEC_OP_RECORD_STATUS_INVALID_EXT_PHYS_ADDR 0x0a
> +#define CEC_OP_RECORD_STATUS_UNSUP_CA 0x0b
> +#define CEC_OP_RECORD_STATUS_NO_CA_ENTITLEMENTS 0x0c
> +#define CEC_OP_RECORD_STATUS_CANT_COPY_SRC 0x0d
> +#define CEC_OP_RECORD_STATUS_NO_MORE_COPIES 0x0e
> +#define CEC_OP_RECORD_STATUS_NO_MEDIA 0x10
> +#define CEC_OP_RECORD_STATUS_PLAYING 0x11
> +#define CEC_OP_RECORD_STATUS_ALREADY_RECORDING 0x12
> +#define CEC_OP_RECORD_STATUS_MEDIA_PROT 0x13
> +#define CEC_OP_RECORD_STATUS_NO_SIGNAL 0x14
> +#define CEC_OP_RECORD_STATUS_MEDIA_PROBLEM 0x15
> +#define CEC_OP_RECORD_STATUS_NO_SPACE 0x16
> +#define CEC_OP_RECORD_STATUS_PARENTAL_LOCK 0x17
> +#define CEC_OP_RECORD_STATUS_TERMINATED_OK 0x1a
> +#define CEC_OP_RECORD_STATUS_ALREADY_TERM 0x1b
> +#define CEC_OP_RECORD_STATUS_OTHER 0x1f
> +
> +#define CEC_MSG_RECORD_TV_SCREEN 0x0f
> +
> +
> +/* Timer Programming Feature */
> +#define CEC_MSG_CLEAR_ANALOGUE_TIMER 0x33
> +/* Recording Sequence Operand (recording_seq) */
> +#define CEC_OP_REC_SEQ_SUNDAY 0x01
> +#define CEC_OP_REC_SEQ_MONDAY 0x02
> +#define CEC_OP_REC_SEQ_TUESDAY 0x04
> +#define CEC_OP_REC_SEQ_WEDNESDAY 0x08
> +#define CEC_OP_REC_SEQ_THURSDAY 0x10
> +#define CEC_OP_REC_SEQ_FRIDAY 0x20
> +#define CEC_OP_REC_SEQ_SATERDAY 0x40
> +#define CEC_OP_REC_SEQ_ONCE_ONLY 0x00
> +
> +#define CEC_MSG_CLEAR_DIGITAL_TIMER 0x99
> +
> +#define CEC_MSG_CLEAR_EXT_TIMER 0xa1
> +/* External Source Specifier Operand (ext_src_spec) */
> +#define CEC_OP_EXT_SRC_PLUG 0x04
> +#define CEC_OP_EXT_SRC_PHYS_ADDR 0x05
> +
> +#define CEC_MSG_SET_ANALOGUE_TIMER 0x34
> +#define CEC_MSG_SET_DIGITAL_TIMER 0x97
> +#define CEC_MSG_SET_EXT_TIMER 0xa2
> +
> +#define CEC_MSG_SET_TIMER_PROGRAM_TITLE 0x67
> +#define CEC_MSG_TIMER_CLEARED_STATUS 0x43
> +/* Timer Cleared Status Data Operand (timer_cleared_status) */
> +#define CEC_OP_TIMER_CLR_STAT_RECORDING 0x00
> +#define CEC_OP_TIMER_CLR_STAT_NO_MATCHING 0x01
> +#define CEC_OP_TIMER_CLR_STAT_NO_INFO 0x02
> +#define CEC_OP_TIMER_CLR_STAT_CLEARED 0x80
> +
> +#define CEC_MSG_TIMER_STATUS 0x35
> +/* Timer Overlap Warning Operand (timer_overlap_warning) */
> +#define CEC_OP_TIMER_OVERLAP_WARNING_NO_OVERLAP 0
> +#define CEC_OP_TIMER_OVERLAP_WARNING_OVERLAP 1
> +/* Media Info Operand (media_info) */
> +#define CEC_OP_MEDIA_INFO_UNPROT_MEDIA 0
> +#define CEC_OP_MEDIA_INFO_PROT_MEDIA 1
> +#define CEC_OP_MEDIA_INFO_NO_MEDIA 2
> +/* Programmed Indicator Operand (prog_indicator) */
> +#define CEC_OP_PROG_IND_NOT_PROGRAMMED 0
> +#define CEC_OP_PROG_IND_PROGRAMMED 1
> +/* Programmed Info Operand (prog_info) */
> +#define CEC_OP_PROG_INFO_ENOUGH_SPACE 0x08
> +#define CEC_OP_PROG_INFO_NOT_ENOUGH_SPACE 0x09
> +#define CEC_OP_PROG_INFO_MIGHT_NOT_BE_ENOUGH_SPACE 0x0b
> +#define CEC_OP_PROG_INFO_NONE_AVAILABLE 0x0a
> +/* Not Programmed Error Info Operand (prog_error) */
> +#define CEC_OP_PROG_ERROR_NO_FREE_TIMER 0x01
> +#define CEC_OP_PROG_ERROR_DATE_OUT_OF_RANGE 0x02
> +#define CEC_OP_PROG_ERROR_REC_SEQ_ERROR 0x03
> +#define CEC_OP_PROG_ERROR_INV_EXT_PLUG 0x04
> +#define CEC_OP_PROG_ERROR_INV_EXT_PHYS_ADDR 0x05
> +#define CEC_OP_PROG_ERROR_CA_UNSUPP 0x06
> +#define CEC_OP_PROG_ERROR_INSUF_CA_ENTITLEMENTS 0x07
> +#define CEC_OP_PROG_ERROR_RESOLUTION_UNSUPP 0x08
> +#define CEC_OP_PROG_ERROR_PARENTAL_LOCK 0x09
> +#define CEC_OP_PROG_ERROR_CLOCK_FAILURE 0x0a
> +#define CEC_OP_PROG_ERROR_DUPLICATE 0x0e
> +
> +
> +/* System Information Feature */
> +#define CEC_MSG_CEC_VERSION 0x9e
> +/* CEC Version Operand (cec_version) */
> +#define CEC_OP_CEC_VERSION_1_3A 4
> +#define CEC_OP_CEC_VERSION_1_4 5
> +#define CEC_OP_CEC_VERSION_2_0 6
> +
> +#define CEC_MSG_GET_CEC_VERSION 0x9f
> +#define CEC_MSG_GIVE_PHYSICAL_ADDR 0x83
> +#define CEC_MSG_GET_MENU_LANGUAGE 0x91
> +#define CEC_MSG_REPORT_PHYSICAL_ADDR 0x84
> +/* Primary Device Type Operand (prim_devtype) */
> +#define CEC_OP_PRIM_DEVTYPE_TV 0
> +#define CEC_OP_PRIM_DEVTYPE_RECORD 1
> +#define CEC_OP_PRIM_DEVTYPE_TUNER 3
> +#define CEC_OP_PRIM_DEVTYPE_PLAYBACK 4
> +#define CEC_OP_PRIM_DEVTYPE_AUDIOSYSTEM 5
> +#define CEC_OP_PRIM_DEVTYPE_SWITCH 6
> +#define CEC_OP_PRIM_DEVTYPE_PROCESSOR 7
> +
> +#define CEC_MSG_SET_MENU_LANGUAGE 0x32
> +#define CEC_MSG_REPORT_FEATURES 0xa6 /* HDMI 2.0 */
> +/* All Device Types Operand (all_device_types) */
> +#define CEC_OP_ALL_DEVTYPE_TV 0x80
> +#define CEC_OP_ALL_DEVTYPE_RECORD 0x40
> +#define CEC_OP_ALL_DEVTYPE_TUNER 0x20
> +#define CEC_OP_ALL_DEVTYPE_PLAYBACK 0x10
> +#define CEC_OP_ALL_DEVTYPE_AUDIOSYSTEM 0x08
> +#define CEC_OP_ALL_DEVTYPE_SWITCH 0x04
> +/*
> + * And if you wondering what happened to PROCESSOR devices: those should
> + * be mapped to a SWITCH.
> + */
> +
> +/* Valid for RC Profile and Device Feature operands */
> +#define CEC_OP_FEAT_EXT 0x80 /* Extension bit */
> +/* RC Profile Operand (rc_profile) */
> +#define CEC_OP_FEAT_RC_TV_PROFILE_NONE 0x00
> +#define CEC_OP_FEAT_RC_TV_PROFILE_1 0x02
> +#define CEC_OP_FEAT_RC_TV_PROFILE_2 0x06
> +#define CEC_OP_FEAT_RC_TV_PROFILE_3 0x0a
> +#define CEC_OP_FEAT_RC_TV_PROFILE_4 0x0e
> +#define CEC_OP_FEAT_RC_SRC_HAS_DEV_ROOT_MENU 0x50
> +#define CEC_OP_FEAT_RC_SRC_HAS_DEV_SETUP_MENU 0x48
> +#define CEC_OP_FEAT_RC_SRC_HAS_CONTENTS_MENU 0x44
> +#define CEC_OP_FEAT_RC_SRC_HAS_MEDIA_TOP_MENU 0x42
> +#define CEC_OP_FEAT_RC_SRC_HAS_MEDIA_CONTEXT_MENU 0x41
> +/* Device Feature Operand (dev_features) */
> +#define CEC_OP_FEAT_DEV_HAS_RECORD_TV_SCREEN 0x40
> +#define CEC_OP_FEAT_DEV_HAS_SET_OSD_STRING 0x20
> +#define CEC_OP_FEAT_DEV_HAS_DECK_CONTROL 0x10
> +#define CEC_OP_FEAT_DEV_HAS_SET_AUDIO_RATE 0x08
> +#define CEC_OP_FEAT_DEV_SINK_HAS_ARC_TX 0x04
> +#define CEC_OP_FEAT_DEV_SOURCE_HAS_ARC_RX 0x02
> +
> +#define CEC_MSG_GIVE_FEATURES 0xa5 /* HDMI 2.0 */
> +
> +
> +/* Deck Control Feature */
> +#define CEC_MSG_DECK_CONTROL 0x42
> +/* Deck Control Mode Operand (deck_control_mode) */
> +#define CEC_OP_DECK_CTL_MODE_SKIP_FWD 1
> +#define CEC_OP_DECK_CTL_MODE_SKIP_REV 2
> +#define CEC_OP_DECK_CTL_MODE_STOP 3
> +#define CEC_OP_DECK_CTL_MODE_EJECT 4
> +
> +#define CEC_MSG_DECK_STATUS 0x1b
> +/* Deck Info Operand (deck_info) */
> +#define CEC_OP_DECK_INFO_PLAY 0x11
> +#define CEC_OP_DECK_INFO_RECORD 0x12
> +#define CEC_OP_DECK_INFO_PLAY_REV 0x13
> +#define CEC_OP_DECK_INFO_STILL 0x14
> +#define CEC_OP_DECK_INFO_SLOW 0x15
> +#define CEC_OP_DECK_INFO_SLOW_REV 0x16
> +#define CEC_OP_DECK_INFO_FAST_FWD 0x17
> +#define CEC_OP_DECK_INFO_FAST_REV 0x18
> +#define CEC_OP_DECK_INFO_NO_MEDIA 0x19
> +#define CEC_OP_DECK_INFO_STOP 0x1a
> +#define CEC_OP_DECK_INFO_SKIP_FWD 0x1b
> +#define CEC_OP_DECK_INFO_SKIP_REV 0x1c
> +#define CEC_OP_DECK_INFO_INDEX_SEARCH_FWD 0x1d
> +#define CEC_OP_DECK_INFO_INDEX_SEARCH_REV 0x1e
> +#define CEC_OP_DECK_INFO_OTHER 0x1f
> +
> +#define CEC_MSG_GIVE_DECK_STATUS 0x1a
> +/* Status Request Operand (status_req) */
> +#define CEC_OP_STATUS_REQ_ON 1
> +#define CEC_OP_STATUS_REQ_OFF 2
> +#define CEC_OP_STATUS_REQ_ONCE 3
> +
> +#define CEC_MSG_PLAY 0x41
> +/* Play Mode Operand (play_mode) */
> +#define CEC_OP_PLAY_MODE_PLAY_FWD 0x24
> +#define CEC_OP_PLAY_MODE_PLAY_REV 0x20
> +#define CEC_OP_PLAY_MODE_PLAY_STILL 0x25
> +#define CEC_OP_PLAY_MODE_PLAY_FAST_FWD_MIN 0x05
> +#define CEC_OP_PLAY_MODE_PLAY_FAST_FWD_MED 0x06
> +#define CEC_OP_PLAY_MODE_PLAY_FAST_FWD_MAX 0x07
> +#define CEC_OP_PLAY_MODE_PLAY_FAST_REV_MIN 0x09
> +#define CEC_OP_PLAY_MODE_PLAY_FAST_REV_MED 0x0a
> +#define CEC_OP_PLAY_MODE_PLAY_FAST_REV_MAX 0x0b
> +#define CEC_OP_PLAY_MODE_PLAY_SLOW_FWD_MIN 0x15
> +#define CEC_OP_PLAY_MODE_PLAY_SLOW_FWD_MED 0x16
> +#define CEC_OP_PLAY_MODE_PLAY_SLOW_FWD_MAX 0x17
> +#define CEC_OP_PLAY_MODE_PLAY_SLOW_REV_MIN 0x19
> +#define CEC_OP_PLAY_MODE_PLAY_SLOW_REV_MED 0x1a
> +#define CEC_OP_PLAY_MODE_PLAY_SLOW_REV_MAX 0x1b
> +
> +
> +/* Tuner Control Feature */
> +#define CEC_MSG_GIVE_TUNER_DEVICE_STATUS 0x08
> +#define CEC_MSG_SELECT_ANALOGUE_SERVICE 0x92
> +#define CEC_MSG_SELECT_DIGITAL_SERVICE 0x93
> +#define CEC_MSG_TUNER_DEVICE_STATUS 0x07
> +/* Recording Flag Operand (rec_flag) */
> +#define CEC_OP_REC_FLAG_USED 0
> +#define CEC_OP_REC_FLAG_NOT_USED 1
> +/* Tuner Display Info Operand (tuner_display_info) */
> +#define CEC_OP_TUNER_DISPLAY_INFO_DIGITAL 0
> +#define CEC_OP_TUNER_DISPLAY_INFO_NONE 1
> +#define CEC_OP_TUNER_DISPLAY_INFO_ANALOGUE 2
> +
> +#define CEC_MSG_TUNER_STEP_DECREMENT 0x06
> +#define CEC_MSG_TUNER_STEP_INCREMENT 0x05
> +
> +
> +/* Vendor Specific Commands Feature */
> +
> +/*
> + * Has also:
> + * CEC_MSG_CEC_VERSION
> + * CEC_MSG_GET_CEC_VERSION
> + */
> +#define CEC_MSG_DEVICE_VENDOR_ID 0x87
> +#define CEC_MSG_GIVE_DEVICE_VENDOR_ID 0x8c
> +#define CEC_MSG_VENDOR_COMMAND 0x89
> +#define CEC_MSG_VENDOR_COMMAND_WITH_ID 0xa0
> +#define CEC_MSG_VENDOR_REMOTE_BUTTON_DOWN 0x8a
> +#define CEC_MSG_VENDOR_REMOTE_BUTTON_UP 0x8b
> +
> +
> +/* OSD Display Feature */
> +#define CEC_MSG_SET_OSD_STRING 0x64
> +/* Display Control Operand (disp_ctl) */
> +#define CEC_OP_DISP_CTL_DEFAULT 0x00
> +#define CEC_OP_DISP_CTL_UNTIL_CLEARED 0x40
> +#define CEC_OP_DISP_CTL_CLEAR 0x80
> +
> +
> +/* Device OSD Transfer Feature */
> +#define CEC_MSG_GIVE_OSD_NAME 0x46
> +#define CEC_MSG_SET_OSD_NAME 0x47
> +
> +
> +/* Device Menu Control Feature */
> +#define CEC_MSG_MENU_REQUEST 0x8d
> +/* Menu Request Type Operand (menu_req) */
> +#define CEC_OP_MENU_REQUEST_ACTIVATE 0x00
> +#define CEC_OP_MENU_REQUEST_DEACTIVATE 0x01
> +#define CEC_OP_MENU_REQUEST_QUERY 0x02
> +
> +#define CEC_MSG_MENU_STATUS 0x8e
> +/* Menu State Operand (menu_state) */
> +#define CEC_OP_MENU_STATE_ACTIVATED 0x00
> +#define CEC_OP_MENU_STATE_DEACTIVATED 0x01
> +
> +#define CEC_MSG_USER_CONTROL_PRESSED 0x44
> +/* UI Broadcast Type Operand (ui_bcast_type) */
> +#define CEC_OP_UI_BCAST_TYPE_TOGGLE_ALL 0x00
> +#define CEC_OP_UI_BCAST_TYPE_TOGGLE_DIG_ANA 0x01
> +#define CEC_OP_UI_BCAST_TYPE_ANALOGUE 0x10
> +#define CEC_OP_UI_BCAST_TYPE_ANALOGUE_T 0x20
> +#define CEC_OP_UI_BCAST_TYPE_ANALOGUE_CABLE 0x30
> +#define CEC_OP_UI_BCAST_TYPE_ANALOGUE_SAT 0x40
> +#define CEC_OP_UI_BCAST_TYPE_DIGITAL 0x50
> +#define CEC_OP_UI_BCAST_TYPE_DIGITAL_T 0x60
> +#define CEC_OP_UI_BCAST_TYPE_DIGITAL_CABLE 0x70
> +#define CEC_OP_UI_BCAST_TYPE_DIGITAL_SAT 0x80
> +#define CEC_OP_UI_BCAST_TYPE_DIGITAL_COM_SAT 0x90
> +#define CEC_OP_UI_BCAST_TYPE_DIGITAL_COM_SAT2 0x91
> +#define CEC_OP_UI_BCAST_TYPE_IP 0xa0
> +/* UI Sound Presentation Control Operand (ui_snd_pres_ctl) */
> +#define CEC_OP_UI_SND_PRES_CTL_DUAL_MONO 0x10
> +#define CEC_OP_UI_SND_PRES_CTL_KARAOKE 0x20
> +#define CEC_OP_UI_SND_PRES_CTL_DOWNMIX 0x80
> +#define CEC_OP_UI_SND_PRES_CTL_REVERB 0x90
> +#define CEC_OP_UI_SND_PRES_CTL_EQUALIZER 0xa0
> +#define CEC_OP_UI_SND_PRES_CTL_BASS_UP 0xb1
> +#define CEC_OP_UI_SND_PRES_CTL_BASS_NEUTRAL 0xb2
> +#define CEC_OP_UI_SND_PRES_CTL_BASS_DOWN 0xb3
> +#define CEC_OP_UI_SND_PRES_CTL_TREBLE_UP 0xc1
> +#define CEC_OP_UI_SND_PRES_CTL_TREBLE_NEUTRAL 0xc2
> +#define CEC_OP_UI_SND_PRES_CTL_TREBLE_DOWN 0xc3
> +
> +#define CEC_MSG_USER_CONTROL_RELEASED 0x45
> +
> +
> +/* Remote Control Passthrough Feature */
> +
> +/*
> + * Has also:
> + * CEC_MSG_USER_CONTROL_PRESSED
> + * CEC_MSG_USER_CONTROL_RELEASED
> + */
> +
> +
> +/* Power Status Feature */
> +#define CEC_MSG_GIVE_DEVICE_POWER_STATUS 0x8f
> +#define CEC_MSG_REPORT_POWER_STATUS 0x90
> +/* Power Status Operand (pwr_state) */
> +#define CEC_OP_POWER_STATUS_ON 0
> +#define CEC_OP_POWER_STATUS_STANDBY 1
> +#define CEC_OP_POWER_STATUS_TO_ON 2
> +#define CEC_OP_POWER_STATUS_TO_STANDBY 3
> +
> +
> +/* General Protocol Messages */
> +#define CEC_MSG_FEATURE_ABORT 0x00
> +/* Abort Reason Operand (reason) */
> +#define CEC_OP_ABORT_UNRECOGNIZED_OP 0
> +#define CEC_OP_ABORT_INCORRECT_MODE 1
> +#define CEC_OP_ABORT_NO_SOURCE 2
> +#define CEC_OP_ABORT_INVALID_OP 3
> +#define CEC_OP_ABORT_REFUSED 4
> +#define CEC_OP_ABORT_UNDETERMINED 5
> +
> +#define CEC_MSG_ABORT 0xff
> +
> +
> +/* System Audio Control Feature */
> +
> +/*
> + * Has also:
> + * CEC_MSG_USER_CONTROL_PRESSED
> + * CEC_MSG_USER_CONTROL_RELEASED
> + */
> +#define CEC_MSG_GIVE_AUDIO_STATUS 0x71
> +#define CEC_MSG_GIVE_SYSTEM_AUDIO_MODE_STATUS 0x7d
> +#define CEC_MSG_REPORT_AUDIO_STATUS 0x7a
> +/* Audio Mute Status Operand (aud_mute_status) */
> +#define CEC_OP_AUD_MUTE_STATUS_OFF 0
> +#define CEC_OP_AUD_MUTE_STATUS_ON 1
> +
> +#define CEC_MSG_REPORT_SHORT_AUDIO_DESCRIPTOR 0xa3
> +#define CEC_MSG_REQUEST_SHORT_AUDIO_DESCRIPTOR 0xa4
> +#define CEC_MSG_SET_SYSTEM_AUDIO_MODE 0x72
> +/* System Audio Status Operand (sys_aud_status) */
> +#define CEC_OP_SYS_AUD_STATUS_OFF 0
> +#define CEC_OP_SYS_AUD_STATUS_ON 1
> +
> +#define CEC_MSG_SYSTEM_AUDIO_MODE_REQUEST 0x70
> +#define CEC_MSG_SYSTEM_AUDIO_MODE_STATUS 0x7e
> +/* Audio Format ID Operand (audio_format_id) */
> +#define CEC_OP_AUD_FMT_ID_CEA861 0
> +#define CEC_OP_AUD_FMT_ID_CEA861_CXT 1
> +
> +
> +/* Audio Rate Control Feature */
> +#define CEC_MSG_SET_AUDIO_RATE 0x9a
> +/* Audio Rate Operand (audio_rate) */
> +#define CEC_OP_AUD_RATE_OFF 0
> +#define CEC_OP_AUD_RATE_WIDE_STD 1
> +#define CEC_OP_AUD_RATE_WIDE_FAST 2
> +#define CEC_OP_AUD_RATE_WIDE_SLOW 3
> +#define CEC_OP_AUD_RATE_NARROW_STD 4
> +#define CEC_OP_AUD_RATE_NARROW_FAST 5
> +#define CEC_OP_AUD_RATE_NARROW_SLOW 6
> +
> +
> +/* Audio Return Channel Control Feature */
> +#define CEC_MSG_INITIATE_ARC 0xc0
> +#define CEC_MSG_REPORT_ARC_INITIATED 0xc1
> +#define CEC_MSG_REPORT_ARC_TERMINATED 0xc2
> +#define CEC_MSG_REQUEST_ARC_INITIATION 0xc3
> +#define CEC_MSG_REQUEST_ARC_TERMINATION 0xc4
> +#define CEC_MSG_TERMINATE_ARC 0xc5
> +
> +
> +/* Dynamic Audio Lipsync Feature */
> +/* Only for CEC 2.0 and up */
> +#define CEC_MSG_REQUEST_CURRENT_LATENCY 0xa7
> +#define CEC_MSG_REPORT_CURRENT_LATENCY 0xa8
> +/* Low Latency Mode Operand (low_latency_mode) */
> +#define CEC_OP_LOW_LATENCY_MODE_OFF 0
> +#define CEC_OP_LOW_LATENCY_MODE_ON 1
> +/* Audio Output Compensated Operand (audio_out_compensated) */
> +#define CEC_OP_AUD_OUT_COMPENSATED_NA 0
> +#define CEC_OP_AUD_OUT_COMPENSATED_DELAY 1
> +#define CEC_OP_AUD_OUT_COMPENSATED_NO_DELAY 2
> +#define CEC_OP_AUD_OUT_COMPENSATED_PARTIAL_DELAY 3
> +
> +
> +/* Capability Discovery and Control Feature */
> +#define CEC_MSG_CDC_MESSAGE 0xf8
> +/* Ethernet-over-HDMI: nobody ever does this... */
> +#define CEC_MSG_CDC_HEC_INQUIRE_STATE 0x00
> +#define CEC_MSG_CDC_HEC_REPORT_STATE 0x01
> +/* HEC Functionality State Operand (hec_func_state) */
> +#define CEC_OP_HEC_FUNC_STATE_NOT_SUPPORTED 0
> +#define CEC_OP_HEC_FUNC_STATE_INACTIVE 1
> +#define CEC_OP_HEC_FUNC_STATE_ACTIVE 2
> +#define CEC_OP_HEC_FUNC_STATE_ACTIVATION_FIELD 3
> +/* Host Functionality State Operand (host_func_state) */
> +#define CEC_OP_HOST_FUNC_STATE_NOT_SUPPORTED 0
> +#define CEC_OP_HOST_FUNC_STATE_INACTIVE 1
> +#define CEC_OP_HOST_FUNC_STATE_ACTIVE 2
> +/* ENC Functionality State Operand (enc_func_state) */
> +#define CEC_OP_ENC_FUNC_STATE_EXT_CON_NOT_SUPPORTED 0
> +#define CEC_OP_ENC_FUNC_STATE_EXT_CON_INACTIVE 1
> +#define CEC_OP_ENC_FUNC_STATE_EXT_CON_ACTIVE 2
> +/* CDC Error Code Operand (cdc_errcode) */
> +#define CEC_OP_CDC_ERROR_CODE_NONE 0
> +#define CEC_OP_CDC_ERROR_CODE_CAP_UNSUPPORTED 1
> +#define CEC_OP_CDC_ERROR_CODE_WRONG_STATE 2
> +#define CEC_OP_CDC_ERROR_CODE_OTHER 3
> +/* HEC Support Operand (hec_support) */
> +#define CEC_OP_HEC_SUPPORT_NO 0
> +#define CEC_OP_HEC_SUPPORT_YES 1
> +/* HEC Activation Operand (hec_activation) */
> +#define CEC_OP_HEC_ACTIVATION_ON 0
> +#define CEC_OP_HEC_ACTIVATION_OFF 1
> +
> +#define CEC_MSG_CDC_HEC_SET_STATE_ADJACENT 0x02
> +#define CEC_MSG_CDC_HEC_SET_STATE 0x03
> +/* HEC Set State Operand (hec_set_state) */
> +#define CEC_OP_HEC_SET_STATE_DEACTIVATE 0
> +#define CEC_OP_HEC_SET_STATE_ACTIVATE 1
> +
> +#define CEC_MSG_CDC_HEC_REQUEST_DEACTIVATION 0x04
> +#define CEC_MSG_CDC_HEC_NOTIFY_ALIVE 0x05
> +#define CEC_MSG_CDC_HEC_DISCOVER 0x06
> +/* Hotplug Detect messages */
> +#define CEC_MSG_CDC_HPD_SET_STATE 0x10
> +/* HPD State Operand (hpd_state) */
> +#define CEC_OP_HPD_STATE_CP_EDID_DISABLE 0
> +#define CEC_OP_HPD_STATE_CP_EDID_ENABLE 1
> +#define CEC_OP_HPD_STATE_CP_EDID_DISABLE_ENABLE 2
> +#define CEC_OP_HPD_STATE_EDID_DISABLE 3
> +#define CEC_OP_HPD_STATE_EDID_ENABLE 4
> +#define CEC_OP_HPD_STATE_EDID_DISABLE_ENABLE 5
> +#define CEC_MSG_CDC_HPD_REPORT_STATE 0x11
> +/* HPD Error Code Operand (hpd_error) */
> +#define CEC_OP_HPD_ERROR_NONE 0
> +#define CEC_OP_HPD_ERROR_INITIATOR_NOT_CAPABLE 1
> +#define CEC_OP_HPD_ERROR_INITIATOR_WRONG_STATE 2
> +#define CEC_OP_HPD_ERROR_OTHER 3
> +#define CEC_OP_HPD_ERROR_NONE_NO_VIDEO 4
> +
> +#endif
> diff --git a/include/media/cec-edid.h b/include/media/cec-edid.h
> new file mode 100644
> index 0000000..d6e39ca
> --- /dev/null
> +++ b/include/media/cec-edid.h
> @@ -0,0 +1,103 @@
> +/*
> + * cec-edid - HDMI Consumer Electronics Control & EDID helpers
> + *
> + * Copyright 2016 Cisco Systems, Inc. and/or its affiliates. All rights reserved.
> + *
> + * This program is free software; you may redistribute it and/or modify
> + * it under the terms of the GNU General Public License as published by
> + * the Free Software Foundation; version 2 of the License.
> + *
> + * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND,
> + * EXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF
> + * MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND
> + * NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT HOLDERS
> + * BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN AN
> + * ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN
> + * CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE
> + * SOFTWARE.
> + */
> +
> +#ifndef _MEDIA_CEC_EDID_H
> +#define _MEDIA_CEC_EDID_H
> +
> +#include <linux/types.h>
> +#include <linux/cec.h>
> +
> +#define cec_phys_addr_exp(pa) \
> + ((pa) >> 12), ((pa) >> 8) & 0xf, ((pa) >> 4) & 0xf, (pa) & 0xf
> +
> +/**
> + * cec_get_edid_phys_addr() - find and return the physical address
> + *
> + * @edid: pointer to the EDID data
> + * @size: size in bytes of the EDID data
> + * @offset: If not %NULL then the location of the physical address
> + * bytes in the EDID will be returned here. This is set to 0
> + * if there is no physical address found.
> + *
> + * Return: the physical address or CEC_PHYS_ADDR_INVALID if there is none.
> + */
> +u16 cec_get_edid_phys_addr(const u8 *edid, unsigned size, unsigned *offset);
> +
> +/**
> + * cec_set_edid_phys_addr() - find and set the physical address
> + *
> + * @edid: pointer to the EDID data
> + * @size: size in bytes of the EDID data
> + * @phys_addr: the new physical address
> + *
> + * This function finds the location of the physical address in the EDID
> + * and fills in the given physical address and updates the checksum
> + * at the end of the EDID block. It does nothing if the EDID doesn't
> + * contain a physical address.
> + */
> +void cec_set_edid_phys_addr(u8 *edid, unsigned size, u16 phys_addr);
> +
> +/**
> + * cec_phys_addr_for_input() - calculate the PA for an input
> + *
> + * @phys_addr: the physical address of the parent
> + * @input: the number of the input port, must be between 1 and 15
> + *
> + * This function calculates a new physical address based on the input
> + * port number. For example:
> + *
> + * PA = 0.0.0.0 and input = 2 becomes 2.0.0.0
> + *
> + * PA = 3.0.0.0 and input = 1 becomes 3.1.0.0
> + *
> + * PA = 3.2.1.0 and input = 5 becomes 3.2.1.5
> + *
> + * PA = 3.2.1.3 and input = 5 becomes f.f.f.f since it maxed out the depth.
> + *
> + * Return: the new physical address or CEC_PHYS_ADDR_INVALID.
> + */
> +u16 cec_phys_addr_for_input(u16 phys_addr, u8 input);
> +
> +/**
> + * cec_phys_addr_validate() - validate a physical address from an EDID
> + *
> + * @phys_addr: the physical address to validate
> + * @parent: if not %NULL, then this is filled with the parents PA.
> + * @port: if not %NULL, then this is filled with the input port.
> + *
> + * This validates a physical address as read from an EDID. If the
> + * PA is invalid (such as 1.0.1.0 since '0' is only allowed at the end),
> + * then it will return -EINVAL.
> + *
> + * The parent PA is passed into %parent and the input port is passed into
> + * %port. For example:
> + *
> + * PA = 0.0.0.0: has parent 0.0.0.0 and input port 0.
> + *
> + * PA = 1.0.0.0: has parent 0.0.0.0 and input port 1.
> + *
> + * PA = 3.2.0.0: has parent 3.0.0.0 and input port 2.
> + *
> + * PA = f.f.f.f: has parent f.f.f.f and input port 0.
> + *
> + * Return: 0 if the PA is valid, -EINVAL if not.
> + */
> +int cec_phys_addr_validate(u16 phys_addr, u16 *parent, u16 *port);
> +
> +#endif /* _MEDIA_CEC_EDID_H */
> diff --git a/include/media/cec.h b/include/media/cec.h
> new file mode 100644
> index 0000000..2dcd838
> --- /dev/null
> +++ b/include/media/cec.h
> @@ -0,0 +1,236 @@
> +/*
> + * cec - HDMI Consumer Electronics Control support header
> + *
> + * Copyright 2016 Cisco Systems, Inc. and/or its affiliates. All rights reserved.
> + *
> + * This program is free software; you may redistribute it and/or modify
> + * it under the terms of the GNU General Public License as published by
> + * the Free Software Foundation; version 2 of the License.
> + *
> + * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND,
> + * EXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF
> + * MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND
> + * NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT HOLDERS
> + * BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN AN
> + * ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN
> + * CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE
> + * SOFTWARE.
> + */
> +
> +#ifndef _MEDIA_CEC_H
> +#define _MEDIA_CEC_H
> +
> +#include <linux/poll.h>
> +#include <linux/fs.h>
> +#include <linux/debugfs.h>
> +#include <linux/device.h>
> +#include <linux/cdev.h>
> +#include <linux/kthread.h>
> +#include <linux/timer.h>
> +#include <linux/cec-funcs.h>
> +#include <media/rc-core.h>
> +#include <media/cec-edid.h>
> +
> +/**
> + * struct cec_devnode - cec device node
> + * @dev: cec device
> + * @cdev: cec character device
> + * @parent: parent device
> + * @minor: device node minor number
> + * @registered: the device was correctly registered
> + * @unregistered: the device was unregistered
> + * @fhs_lock: lock to control access to the filehandle list
> + * @fhs: the list of open filehandles (cec_fh)
> + *
> + * This structure represents a cec-related device node.
> + *
> + * The @parent is a physical device. It must be set by core or device drivers
> + * before registering the node.
> + */
> +struct cec_devnode {
> + /* sysfs */
> + struct device dev;
> + struct cdev cdev;
> + struct device *parent;
> +
> + /* device info */
> + int minor;
> + bool registered;
> + bool unregistered;
> + struct mutex fhs_lock;
> + struct list_head fhs;
> +};
> +
> +struct cec_adapter;
> +struct cec_data;
> +
> +struct cec_data {
> + struct list_head list;
> + struct list_head xfer_list;
> + struct cec_adapter *adap;
> + struct cec_msg msg;
> + struct cec_fh *fh;
> + struct delayed_work work;
> + struct completion c;
> + u8 attempts;
> + bool new_initiator;
> + bool blocking;
> + bool completed;
> +};
> +
> +struct cec_msg_entry {
> + struct list_head list;
> + struct cec_msg msg;
> +};
> +
> +#define CEC_NUM_EVENTS CEC_EVENT_LOST_MSGS
> +
> +struct cec_event_queue {
> + unsigned elems;
> + unsigned num_events;
> + struct cec_event *events;
> +};
> +
> +struct cec_fh {
> + struct list_head list;
> + struct list_head xfer_list;
> + struct cec_adapter *adap;
> + u8 mode_initiator;
> + u8 mode_follower;
> +
> + /* Events */
> + wait_queue_head_t wait;
> + unsigned events;
> + struct cec_event_queue evqueue[CEC_NUM_EVENTS];
> + struct mutex lock;
> + struct list_head msgs; /* queued messages */
> + unsigned queued_msgs;
> + unsigned lost_msgs;
> +};
> +
> +#define CEC_SIGNAL_FREE_TIME_RETRY 3
> +#define CEC_SIGNAL_FREE_TIME_NEW_INITIATOR 5
> +#define CEC_SIGNAL_FREE_TIME_NEXT_XFER 7
> +
> +/* The nominal data bit period is 2.4 ms */
> +#define CEC_FREE_TIME_TO_USEC(ft) ((ft) * 2400)
> +
> +struct cec_adap_ops {
> + /* Low-level callbacks */
> + int (*adap_enable)(struct cec_adapter *adap, bool enable);
> + int (*adap_monitor_all_enable)(struct cec_adapter *adap, bool enable);
> + int (*adap_log_addr)(struct cec_adapter *adap, u8 logical_addr);
> + int (*adap_transmit)(struct cec_adapter *adap, u8 attempts,
> + u32 signal_free_time, struct cec_msg *msg);
> + void (*adap_status)(struct cec_adapter *adap, struct seq_file *file);
> +
> + /* High-level CEC message callback */
> + int (*received)(struct cec_adapter *adap, struct cec_msg *msg);
> +};
> +
> +/*
> + * The minimum message length you can receive (excepting poll messages) is 2.
> + * With a transfer rate of at most 36 bytes per second this makes 18 messages
> + * per second worst case.
> + *
> + * We queue at most 10 seconds worth of messages.
> + */
> +#define CEC_MAX_MSG_QUEUE_SZ (18 * 10)
> +
> +struct cec_adapter {
> + struct module *owner;
> + char name[32];
> + struct cec_devnode devnode;
> + struct mutex lock;
> + struct rc_dev *rc;
> +
> + struct list_head transmit_queue;
> + struct list_head wait_queue;
> + struct cec_data *transmitting;
> +
> + struct task_struct *kthread_config;
> + struct completion config_completion;
> +
> + struct task_struct *kthread;
> + wait_queue_head_t kthread_waitq;
> + wait_queue_head_t waitq;
> +
> + const struct cec_adap_ops *ops;
> + void *priv;
> + u32 capabilities;
> + u8 available_log_addrs;
> +
> + u16 phys_addr;
> + bool is_configuring;
> + bool is_configured;
> + u32 monitor_all_cnt;
> + u32 follower_cnt;
> + struct cec_fh *cec_follower;
> + struct cec_fh *cec_initiator;
> + bool passthrough;
> + struct cec_log_addrs log_addrs;
> +
> + struct dentry *cec_dir;
> + struct dentry *status_file;
> +
> + u16 phys_addrs[15];
> + u32 sequence;
> +
> + char input_name[32];
> + char input_phys[32];
> + char input_drv[32];
> +};
> +
> +static inline bool cec_has_log_addr(const struct cec_adapter *adap, u8 log_addr)
> +{
> + return adap->log_addrs.log_addr_mask & (1 << log_addr);
> +}
> +
> +static inline bool cec_is_sink(const struct cec_adapter *adap)
> +{
> + return adap->phys_addr == 0;
> +}
> +
> +#if IS_ENABLED(CONFIG_MEDIA_CEC)
> +struct cec_adapter *cec_allocate_adapter(const struct cec_adap_ops *ops,
> + void *priv, const char *name, u32 caps, u8 available_las,
> + struct device *parent);
> +int cec_register_adapter(struct cec_adapter *adap);
> +void cec_unregister_adapter(struct cec_adapter *adap);
> +void cec_delete_adapter(struct cec_adapter *adap);
> +
> +int cec_s_log_addrs(struct cec_adapter *adap, struct cec_log_addrs *log_addrs,
> + bool block);
> +void cec_s_phys_addr(struct cec_adapter *adap, u16 phys_addr,
> + bool block);
> +int cec_transmit_msg(struct cec_adapter *adap, struct cec_msg *msg,
> + bool block);
> +
> +/* Called by the adapter */
> +void cec_transmit_done(struct cec_adapter *adap, u8 status, u8 arb_lost_cnt,
> + u8 nack_cnt, u8 low_drive_cnt, u8 error_cnt);
> +void cec_received_msg(struct cec_adapter *adap, struct cec_msg *msg);
> +
> +#else
> +
> +static inline int cec_register_adapter(struct cec_adapter *adap)
> +{
> + return 0;
> +}
> +
> +static inline void cec_unregister_adapter(struct cec_adapter *adap)
> +{
> +}
> +
> +static inline void cec_delete_adapter(struct cec_adapter *adap)
> +{
> +}
> +
> +static inline void cec_s_phys_addr(struct cec_adapter *adap, u16 phys_addr,
> + bool block)
> +{
> +}
> +
> +#endif
> +
> +#endif /* _MEDIA_CEC_H */
Thanks,
Mauro
--
To unsubscribe from this list: send the line "unsubscribe linux-media" in
the body of a message to majordomo@xxxxxxxxxxxxxxx
More majordomo info at http://vger.kernel.org/majordomo-info.html
