Implement the following tuner control features: - <Select Analogue Service> - <Give Tuner Device Status> and reply <Tuner Device Status>
Signed-off-by: Jiunn Chang <c0d1n61...@gmail.com> --- utils/cec-follower/cec-follower.h | 1 + utils/cec-follower/cec-tuner.cpp | 89 ++++++++++++++++++++++++++----- 2 files changed, 78 insertions(+), 12 deletions(-) diff --git a/utils/cec-follower/cec-follower.h b/utils/cec-follower/cec-follower.h index 9f5f1be4..9c146be1 100644 --- a/utils/cec-follower/cec-follower.h +++ b/utils/cec-follower/cec-follower.h @@ -51,6 +51,7 @@ struct state { __u64 rc_press_rx_ts; unsigned rc_press_hold_count; unsigned rc_duration_sum; + struct cec_op_tuner_device_info tuner_dev_info; }; struct node { diff --git a/utils/cec-follower/cec-tuner.cpp b/utils/cec-follower/cec-tuner.cpp index 912adcb9..ffd1776f 100644 --- a/utils/cec-follower/cec-tuner.cpp +++ b/utils/cec-follower/cec-tuner.cpp @@ -4,6 +4,7 @@ */ #include <sys/ioctl.h> +#include <stdlib.h> #include "cec-follower.h" @@ -87,6 +88,67 @@ static unsigned int analog_freqs_khz[3][9][3] = } }; +static struct state state; + +static void set_analog_channel_freq(__u16 *ana_freq) +{ + unsigned int ana_freq_khz = (*ana_freq * 625) / 10; + unsigned int current = analog_freqs_khz[state.tuner_dev_info.analog.bcast_system][state.tuner_dev_info.analog.ana_bcast_type][0]; + for (int i = 0; i < 3; i++) { + if (abs(int(ana_freq_khz - analog_freqs_khz[state.tuner_dev_info.analog.bcast_system][state.tuner_dev_info.analog.ana_bcast_type][i])) < + abs(int(ana_freq_khz - current))) { + current = analog_freqs_khz[state.tuner_dev_info.analog.bcast_system][state.tuner_dev_info.analog.ana_bcast_type][i]; + } + } + state.tuner_dev_info.analog.ana_freq = (current * 10) / 625; +} + +static bool set_analog_tuner_dev_info(const struct cec_msg *msg) +{ + state.tuner_dev_info.rec_flag = CEC_OP_REC_FLAG_NOT_USED; + state.tuner_dev_info.tuner_display_info = CEC_OP_TUNER_DISPLAY_INFO_ANALOGUE; + state.tuner_dev_info.is_analog = true; + cec_ops_select_analogue_service(msg, + &state.tuner_dev_info.analog.ana_bcast_type, + &state.tuner_dev_info.analog.ana_freq, + &state.tuner_dev_info.analog.bcast_system); + if (state.tuner_dev_info.analog.ana_bcast_type > 2 || + state.tuner_dev_info.analog.bcast_system > 8) + return false; + set_analog_channel_freq(&state.tuner_dev_info.analog.ana_freq); + return true; +} + +static void reply_feature_abort(struct node *node, struct cec_msg *msg, __u8 reason = CEC_OP_ABORT_UNRECOGNIZED_OP) +{ + unsigned la = cec_msg_initiator(msg); + __u8 opcode = cec_msg_opcode(msg); + __u64 ts_now = get_ts(); + + if (cec_msg_is_broadcast(msg) || cec_msg_initiator(msg) == CEC_LOG_ADDR_UNREGISTERED) + return; + if (reason == CEC_OP_ABORT_UNRECOGNIZED_OP) { + la_info[la].feature_aborted[opcode].count++; + if (la_info[la].feature_aborted[opcode].count == 2) { + /* If the Abort Reason was "Unrecognized opcode", the Initiator should not send + the same message to the same Follower again at that time to avoid saturating + the bus. */ + warn("Received message %s from LA %d (%s) shortly after\n", + opcode2s(msg).c_str(), la, la2s(la)); + warn("replying Feature Abort [Unrecognized Opcode] to the same message.\n"); + } + } + else if (la_info[la].feature_aborted[opcode].count) { + warn("Replying Feature Abort with abort reason different than [Unrecognized Opcode]\n"); + warn("to message that has previously been replied Feature Abort to with [Unrecognized Opcode].\n"); + } + else + la_info[la].feature_aborted[opcode].ts = ts_now; + + cec_msg_reply_feature_abort(msg, reason); + transmit(node, msg); +} + void process_tuner_record_timer_msgs(struct node *node, struct cec_msg &msg, unsigned me) { switch (msg.msg[1]) { @@ -101,21 +163,11 @@ void process_tuner_record_timer_msgs(struct node *node, struct cec_msg &msg, uns */ case CEC_MSG_GIVE_TUNER_DEVICE_STATUS: { - if (!cec_has_tuner(1 << me)) + if (!cec_has_tuner(1 << me) && !cec_has_tv(1 << me)) break; - struct cec_op_tuner_device_info tuner_dev_info = {}; - cec_msg_set_reply_to(&msg, &msg); - tuner_dev_info.rec_flag = CEC_OP_REC_FLAG_NOT_USED; - tuner_dev_info.tuner_display_info = CEC_OP_TUNER_DISPLAY_INFO_NONE; - tuner_dev_info.is_analog = false; - tuner_dev_info.digital.service_id_method = CEC_OP_SERVICE_ID_METHOD_BY_CHANNEL; - tuner_dev_info.digital.dig_bcast_system = CEC_OP_DIG_SERVICE_BCAST_SYSTEM_DVB_C; - tuner_dev_info.digital.channel.channel_number_fmt = CEC_OP_CHANNEL_NUMBER_FMT_1_PART; - tuner_dev_info.digital.channel.minor = 1; - - cec_msg_tuner_device_status(&msg, &tuner_dev_info); + cec_msg_tuner_device_status(&msg, &state.tuner_dev_info); transmit(node, &msg); return; } @@ -124,6 +176,19 @@ void process_tuner_record_timer_msgs(struct node *node, struct cec_msg &msg, uns return; case CEC_MSG_SELECT_ANALOGUE_SERVICE: + if (!cec_has_tuner(1 << me) && !cec_has_tv(1 << me)) + break; + + if (state.tuner_dev_info.rec_flag == CEC_OP_REC_FLAG_USED) { + reply_feature_abort(node, &msg, CEC_OP_ABORT_REFUSED); + return; + } + if (!set_analog_tuner_dev_info(&msg)) { + reply_feature_abort(node, &msg, CEC_OP_ABORT_INVALID_OP); + return; + } + return; + case CEC_MSG_SELECT_DIGITAL_SERVICE: case CEC_MSG_TUNER_STEP_DECREMENT: case CEC_MSG_TUNER_STEP_INCREMENT: -- 2.23.0