Minki/linux
1
0
Fork 1
mirror of https://github.com/torvalds/linux.git synced 2024-12-30 14:52:05 +00:00
Code Issues Packages Projects Releases Wiki Activity

media: cec-adap.c: drop activate_cnt, use state info instead

Browse Source 
Using an activation counter to decide when the enable or disable the
cec adapter is not the best approach and can lead to race conditions.

Change this to determining the current status of the adapter, and
enable or disable the adapter accordingly.

It now only needs to be called whenever there is a chance that the
state changes, and it can handle enabling/disabling monitoring as
well if needed.

This simplifies the code and it should be a more robust approach as well.

Signed-off-by: Hans Verkuil <hverkuil-cisco@xs4all.nl>
Signed-off-by: Mauro Carvalho Chehab <mchehab@kernel.org>
This commit is contained in:
Hans Verkuil 2022-05-10 10:53:05 +02:00 committed by Mauro Carvalho Chehab
parent e3891b3636
commit f9222f8ca1
2 changed files with 61 additions and 95 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

136
drivers/media/cec/core/cec-adap.c
View File

@ -1574,45 +1574,57 @@ static void cec_claim_log_addrs(struct cec_adapter *adap, bool block)
} }
/* /*
* Helper functions to enable/disable the CEC adapter. * Helper function to enable/disable the CEC adapter.
* *
* These functions are called with adap->lock held. * This function is called with adap->lock held.
*/ */
static int cec_activate_cnt_inc(struct cec_adapter *adap) static int cec_adap_enable(struct cec_adapter *adap)
{ {
int ret; bool enable;
int ret = 0;
if (adap->activate_cnt++) enable = adap->monitor_all_cnt || adap->monitor_pin_cnt ||
adap->log_addrs.num_log_addrs;
if (adap->needs_hpd)
enable = enable && adap->phys_addr != CEC_PHYS_ADDR_INVALID;
if (enable == adap->is_enabled)
return 0; return 0;
/* serialize adap_enable */ /* serialize adap_enable */
mutex_lock(&adap->devnode.lock); mutex_lock(&adap->devnode.lock);
if (enable) {
adap->last_initiator = 0xff; adap->last_initiator = 0xff;
adap->transmit_in_progress = false; adap->transmit_in_progress = false;
ret = call_op(adap, adap_enable, true); ret = adap->ops->adap_enable(adap, true);
if (ret) if (!ret) {
adap->activate_cnt--; /*
mutex_unlock(&adap->devnode.lock); * Enable monitor-all/pin modes if needed. We warn, but
return ret; * continue if this fails as this is not a critical error.
*/
if (adap->monitor_all_cnt)
WARN_ON(call_op(adap, adap_monitor_all_enable, true));
if (adap->monitor_pin_cnt)
WARN_ON(call_op(adap, adap_monitor_pin_enable, true));
} }
} else {
static void cec_activate_cnt_dec(struct cec_adapter *adap) /* Disable monitor-all/pin modes if needed (needs_hpd == 1) */
{ if (adap->monitor_all_cnt)
if (WARN_ON(!adap->activate_cnt)) WARN_ON(call_op(adap, adap_monitor_all_enable, false));
return; if (adap->monitor_pin_cnt)
WARN_ON(call_op(adap, adap_monitor_pin_enable, false));
if (--adap->activate_cnt) WARN_ON(adap->ops->adap_enable(adap, false));
return;
/* serialize adap_enable */
mutex_lock(&adap->devnode.lock);
WARN_ON(call_op(adap, adap_enable, false));
adap->last_initiator = 0xff; adap->last_initiator = 0xff;
adap->transmit_in_progress = false; adap->transmit_in_progress = false;
adap->transmit_in_progress_aborted = false; adap->transmit_in_progress_aborted = false;
if (adap->transmitting) if (adap->transmitting)
cec_data_cancel(adap->transmitting, CEC_TX_STATUS_ABORTED, 0); cec_data_cancel(adap->transmitting, CEC_TX_STATUS_ABORTED, 0);
}
if (!ret)
adap->is_enabled = enable;
wake_up_interruptible(&adap->kthread_waitq);
mutex_unlock(&adap->devnode.lock); mutex_unlock(&adap->devnode.lock);
return ret;
} }
/* Set a new physical address and send an event notifying userspace of this. /* Set a new physical address and send an event notifying userspace of this.
@ -1635,33 +1647,16 @@ void __cec_s_phys_addr(struct cec_adapter *adap, u16 phys_addr, bool block)
adap->phys_addr = CEC_PHYS_ADDR_INVALID; adap->phys_addr = CEC_PHYS_ADDR_INVALID;
cec_post_state_event(adap); cec_post_state_event(adap);
cec_adap_unconfigure(adap); cec_adap_unconfigure(adap);
if (becomes_invalid && adap->needs_hpd) { if (becomes_invalid) {
/* Disable monitor-all/pin modes if needed */ cec_adap_enable(adap);
if (adap->monitor_all_cnt)
WARN_ON(call_op(adap, adap_monitor_all_enable, false));
if (adap->monitor_pin_cnt)
WARN_ON(call_op(adap, adap_monitor_pin_enable, false));
cec_activate_cnt_dec(adap);
wake_up_interruptible(&adap->kthread_waitq);
}
if (becomes_invalid)
return; return;
} }
if (is_invalid && adap->needs_hpd) {
if (cec_activate_cnt_inc(adap))
return;
/*
* Re-enable monitor-all/pin modes if needed. We warn, but
* continue if this fails as this is not a critical error.
*/
if (adap->monitor_all_cnt)
WARN_ON(call_op(adap, adap_monitor_all_enable, true));
if (adap->monitor_pin_cnt)
WARN_ON(call_op(adap, adap_monitor_pin_enable, true));
} }
adap->phys_addr = phys_addr; adap->phys_addr = phys_addr;
if (is_invalid)
cec_adap_enable(adap);
cec_post_state_event(adap); cec_post_state_event(adap);
if (!adap->log_addrs.num_log_addrs) if (!adap->log_addrs.num_log_addrs)
return; return;
@ -1722,6 +1717,7 @@ int __cec_s_log_addrs(struct cec_adapter *adap,
struct cec_log_addrs *log_addrs, bool block) struct cec_log_addrs *log_addrs, bool block)
{ {
u16 type_mask = 0; u16 type_mask = 0;
int err;
int i; int i;
if (adap->devnode.unregistered) if (adap->devnode.unregistered)
@ -1738,8 +1734,7 @@ int __cec_s_log_addrs(struct cec_adapter *adap,
adap->log_addrs.osd_name[0] = '\0'; adap->log_addrs.osd_name[0] = '\0';
adap->log_addrs.vendor_id = CEC_VENDOR_ID_NONE; adap->log_addrs.vendor_id = CEC_VENDOR_ID_NONE;
adap->log_addrs.cec_version = CEC_OP_CEC_VERSION_2_0; adap->log_addrs.cec_version = CEC_OP_CEC_VERSION_2_0;
if (!adap->needs_hpd) cec_adap_enable(adap);
cec_activate_cnt_dec(adap);
return 0; return 0;
} }
@ -1873,17 +1868,12 @@ int __cec_s_log_addrs(struct cec_adapter *adap,
sizeof(log_addrs->features[i])); sizeof(log_addrs->features[i]));
} }
if (!adap->needs_hpd && !adap->is_configuring && !adap->is_configured) {
int ret = cec_activate_cnt_inc(adap);
if (ret)
return ret;
}
log_addrs->log_addr_mask = adap->log_addrs.log_addr_mask; log_addrs->log_addr_mask = adap->log_addrs.log_addr_mask;
adap->log_addrs = *log_addrs; adap->log_addrs = *log_addrs;
if (adap->phys_addr != CEC_PHYS_ADDR_INVALID) err = cec_adap_enable(adap);
if (!err && adap->phys_addr != CEC_PHYS_ADDR_INVALID)
cec_claim_log_addrs(adap, block); cec_claim_log_addrs(adap, block);
return 0; return err;
} }
int cec_s_log_addrs(struct cec_adapter *adap, int cec_s_log_addrs(struct cec_adapter *adap,
@ -2186,22 +2176,11 @@ int cec_monitor_all_cnt_inc(struct cec_adapter *adap)
if (adap->monitor_all_cnt++) if (adap->monitor_all_cnt++)
return 0; return 0;
if (!adap->needs_hpd) { ret = cec_adap_enable(adap);
ret = cec_activate_cnt_inc(adap); if (ret)
if (ret) {
adap->monitor_all_cnt--; adap->monitor_all_cnt--;
return ret; return ret;
} }
}
ret = call_op(adap, adap_monitor_all_enable, true);
if (ret) {
adap->monitor_all_cnt--;
if (!adap->needs_hpd)
cec_activate_cnt_dec(adap);
}
return ret;
}
void cec_monitor_all_cnt_dec(struct cec_adapter *adap) void cec_monitor_all_cnt_dec(struct cec_adapter *adap)
{ {
@ -2210,8 +2189,7 @@ void cec_monitor_all_cnt_dec(struct cec_adapter *adap)
if (--adap->monitor_all_cnt) if (--adap->monitor_all_cnt)
return; return;
WARN_ON(call_op(adap, adap_monitor_all_enable, false)); WARN_ON(call_op(adap, adap_monitor_all_enable, false));
if (!adap->needs_hpd) cec_adap_enable(adap);
cec_activate_cnt_dec(adap);
} }
/* /*
@ -2226,22 +2204,11 @@ int cec_monitor_pin_cnt_inc(struct cec_adapter *adap)
if (adap->monitor_pin_cnt++) if (adap->monitor_pin_cnt++)
return 0; return 0;
if (!adap->needs_hpd) { ret = cec_adap_enable(adap);
ret = cec_activate_cnt_inc(adap); if (ret)
if (ret) {
adap->monitor_pin_cnt--; adap->monitor_pin_cnt--;
return ret; return ret;
} }
}
ret = call_op(adap, adap_monitor_pin_enable, true);
if (ret) {
adap->monitor_pin_cnt--;
if (!adap->needs_hpd)
cec_activate_cnt_dec(adap);
}
return ret;
}
void cec_monitor_pin_cnt_dec(struct cec_adapter *adap) void cec_monitor_pin_cnt_dec(struct cec_adapter *adap)
{ {
@ -2250,8 +2217,7 @@ void cec_monitor_pin_cnt_dec(struct cec_adapter *adap)
if (--adap->monitor_pin_cnt) if (--adap->monitor_pin_cnt)
return; return;
WARN_ON(call_op(adap, adap_monitor_pin_enable, false)); WARN_ON(call_op(adap, adap_monitor_pin_enable, false));
if (!adap->needs_hpd) cec_adap_enable(adap);
cec_activate_cnt_dec(adap);
} }
#ifdef CONFIG_DEBUG_FS #ifdef CONFIG_DEBUG_FS
@ -2265,7 +2231,7 @@ int cec_adap_status(struct seq_file *file, void *priv)
struct cec_data *data; struct cec_data *data;
mutex_lock(&adap->lock); mutex_lock(&adap->lock);
seq_printf(file, "activation count: %u\n", adap->activate_cnt); seq_printf(file, "enabled: %d\n", adap->is_enabled);
seq_printf(file, "configured: %d\n", adap->is_configured); seq_printf(file, "configured: %d\n", adap->is_configured);
seq_printf(file, "configuring: %d\n", adap->is_configuring); seq_printf(file, "configuring: %d\n", adap->is_configuring);
seq_printf(file, "phys_addr: %x.%x.%x.%x\n", seq_printf(file, "phys_addr: %x.%x.%x.%x\n",

4
include/media/cec.h
View File

@ -183,6 +183,7 @@ struct cec_adap_ops {
* @needs_hpd: if true, then the HDMI HotPlug Detect pin must be high * @needs_hpd: if true, then the HDMI HotPlug Detect pin must be high
* in order to transmit or receive CEC messages. This is usually a HW * in order to transmit or receive CEC messages. This is usually a HW
* limitation. * limitation.
* @is_enabled: the CEC adapter is enabled
* @is_configuring: the CEC adapter is configuring (i.e. claiming LAs) * @is_configuring: the CEC adapter is configuring (i.e. claiming LAs)
* @must_reconfigure: while configuring, the PA changed, so reclaim LAs * @must_reconfigure: while configuring, the PA changed, so reclaim LAs
* @is_configured: the CEC adapter is configured (i.e. has claimed LAs) * @is_configured: the CEC adapter is configured (i.e. has claimed LAs)
@ -194,7 +195,6 @@ struct cec_adap_ops {
* Drivers that need this can set this field to true after the * Drivers that need this can set this field to true after the
* cec_allocate_adapter() call. * cec_allocate_adapter() call.
* @last_initiator: the initiator of the last transmitted message. * @last_initiator: the initiator of the last transmitted message.
* @activate_cnt: number of times that CEC is activated
* @monitor_all_cnt: number of filehandles monitoring all msgs * @monitor_all_cnt: number of filehandles monitoring all msgs
* @monitor_pin_cnt: number of filehandles monitoring pin changes * @monitor_pin_cnt: number of filehandles monitoring pin changes
* @follower_cnt: number of filehandles in follower mode * @follower_cnt: number of filehandles in follower mode
@ -243,13 +243,13 @@ struct cec_adapter {
u16 phys_addr; u16 phys_addr;
bool needs_hpd; bool needs_hpd;
bool is_enabled;
bool is_configuring; bool is_configuring;
bool must_reconfigure; bool must_reconfigure;
bool is_configured; bool is_configured;
bool cec_pin_is_high; bool cec_pin_is_high;
bool adap_controls_phys_addr; bool adap_controls_phys_addr;
u8 last_initiator; u8 last_initiator;
u32 activate_cnt;
u32 monitor_all_cnt; u32 monitor_all_cnt;
u32 monitor_pin_cnt; u32 monitor_pin_cnt;
u32 follower_cnt; u32 follower_cnt;