Autres/Rivendellaudio
1
0
Fork 0
mirror of https://github.com/ElvishArtisan/rivendell.git synced 2026-01-12 07:35:55 +01:00
Code Issues Projects Releases Wiki Activity

2018-06-22 Fred Gleason <fredg@paravelsystems.com>

Browse Source 
* Added GPIO support for HPI devices to the 'Local Audio Adapter'
	switcher/gpio driver.
This commit is contained in:
Fred Gleason
2018-08-23 01:23:59 +00:00
parent 8f2fbcab9f
commit 58fa103f6e
8 changed files with 813 additions and 53 deletions
Download Patch File Download Diff File Expand all files Collapse all files

225
ripcd/local_audio.cpp
View File

@@ -1,8 +1,8 @@
// local_audio.cpp
//
// A Rivendell switcher driver for the BroadcastTools 10x1
// A Rivendell switcher driver for local audio cards.
//
// (C) Copyright 2002-2003,2016 Fred Gleason <fredg@paravelsystems.com>
// (C) Copyright 2002-2018 Fred Gleason <fredg@paravelsystems.com>
//
// This program is free software; you can redistribute it and/or modify
// it under the terms of the GNU General Public License version 2 as
@@ -28,17 +28,40 @@
LocalAudio::LocalAudio(RDMatrix *matrix,QObject *parent)
: Switcher(matrix,parent)
{
bt_poll_timer=NULL;
bt_gpi_values=NULL;
bt_gpo_values=NULL;
//
// Get Matrix Parameters
//
bt_inputs=matrix->inputs();
bt_outputs=matrix->outputs();
bt_card=matrix->card();
bt_gpis=0;
bt_gpos=0;
//
// Interval OneShot
//
bt_gpo_oneshot=new RDOneShot(this);
connect(bt_gpo_oneshot,SIGNAL(timeout(int)),this,SLOT(gpoOneshotData(int)));
InitializeHpi(matrix);
}
LocalAudio::~LocalAudio()
{
if(bt_poll_timer!=NULL) {
delete bt_poll_timer;
}
if(bt_gpi_values!=NULL) {
delete bt_gpi_values;
}
if(bt_gpo_values!=NULL) {
delete bt_gpo_values;
}
}
@@ -75,6 +98,60 @@ bool LocalAudio::secondaryTtyActive()
void LocalAudio::processCommand(RDMacro *cmd)
{
switch(cmd->command()) {
case RDMacro::GO:
if((cmd->argQuantity()!=5)||
((cmd->arg(1).toString().lower()!="i")&&
(cmd->arg(1).toString().lower()!="o"))||
(cmd->arg(2).toInt()<1)||(cmd->arg(3).toInt()>bt_gpos)||
(cmd->arg(2).toInt()>bt_gpos)||
((cmd->arg(3).toInt()!=1)&&(cmd->arg(3).toInt()!=0)&&
(cmd->arg(1).toString().lower()!="i"))||
((cmd->arg(3).toInt()!=1)&&(cmd->arg(3).toInt()!=0)&&
(cmd->arg(3).toInt()!=-1)&&(cmd->arg(1).toString().lower()=="i"))||
(cmd->arg(4).toInt()<0)) {
cmd->acknowledge(false);
emit rmlEcho(cmd);
return;
}
if(cmd->arg(3).toInt()==0) { // Turn OFF
if(cmd->arg(4).toInt()==0) {
if(cmd->arg(1).toString().lower()=="o") {
SetGpo(cmd->arg(2).toInt()-1,false);
emit gpoChanged(matrixNumber(),cmd->arg(2).toInt()-1,false);
}
}
else {
if(cmd->echoRequested()) {
cmd->acknowledge(false);
emit rmlEcho(cmd);
}
return;
}
}
else {
if(cmd->arg(3).toInt()!=-1) {
if(cmd->arg(4).toInt()==0) { // Turn ON
if(cmd->arg(1).toString().lower()=="o") {
SetGpo(cmd->arg(2).toInt()-1,true);
emit gpoChanged(matrixNumber(),cmd->arg(2).toInt()-1,true);
}
}
else { // Pulse
if(cmd->arg(1).toString().lower()=="o") {
SetGpo(cmd->arg(2).toInt()-1,true);
emit gpoChanged(matrixNumber(),cmd->arg(2).toInt()-1,true);
bt_gpo_oneshot->
start(cmd->arg(2).toInt()-1,cmd->arg(4).toInt());
}
}
}
}
if(cmd->echoRequested()) {
cmd->acknowledge(true);
emit rmlEcho(cmd);
}
break;
case RDMacro::ST:
if((cmd->arg(1).toInt()<0)||(cmd->arg(1).toInt()>bt_inputs)||
(cmd->arg(2).toInt()<=0)||(cmd->arg(2).toInt()>bt_outputs)) {
@@ -150,3 +227,147 @@ void LocalAudio::processCommand(RDMacro *cmd)
break;
}
}
void LocalAudio::pollData()
{
#ifdef HPI
if(LogHpi(HPI_Object_GetValue(bt_gpis_param,entity_type_boolean,
bt_gpis,bt_gpi_values,
bt_gpis),__LINE__)==0) {
for(int i=0;i<bt_gpis;i++) {
if((bt_gpi_values[i]=='T')!=bt_gpi_states[i]) {
bt_gpi_states[i]=(bt_gpi_values[i]=='T');
emit gpiChanged(matrixNumber(),i,bt_gpi_states[i]);
}
}
}
#endif // HPI
}
void LocalAudio::gpoOneshotData(int value)
{
SetGpo(value,false);
emit gpoChanged(matrixNumber(),value,false);
}
void LocalAudio::InitializeHpi(RDMatrix *matrix)
{
#ifdef HPI
struct hpi_control_t cntl;
hpi_handle_t block;
size_t value_size=0;
size_t value_items=0;
bt_gpis=0;
bt_gpos=0;
//
// Open Mixer
//
if(HPI_MixerOpen(NULL,bt_card,&bt_mixer)!=0) {
UpdateDb(matrix);
return;
}
memset(&cntl,0,sizeof(cntl));
cntl.wSrcNodeType=HPI_SOURCENODE_ADAPTER;
if(HPI_Object_BlockHandle(bt_mixer,HPI_SOURCENODE_ADAPTER,0,0,0,
"GPIO",&block)!=0) {
UpdateDb(matrix);
return;
}
//
// GPIs Handle
//
if(LogHpi(HPI_Object_ParameterHandle(bt_mixer,block,"Inputs",&bt_gpis_param),__LINE__)!=0) {
UpdateDb(matrix);
return;
}
if(LogHpi(HPI_Object_GetInfo(bt_gpis_param,entity_type_boolean,
entity_role_value,NULL,&value_size,&value_items),
__LINE__)!=0) {
UpdateDb(matrix);
return;
}
bt_gpis=value_items;
bt_gpi_values=new uint8_t[bt_gpis];
if(LogHpi(HPI_Object_GetValue(bt_gpis_param,entity_type_boolean,value_items,bt_gpi_values,value_size),__LINE__)!=0) {
bt_gpis=0;
UpdateDb(matrix);
return;
}
for(int i=0;i<bt_gpis;i++) {
bt_gpi_states.push_back(bt_gpi_values[i]=='T');
}
bt_poll_timer=new QTimer(this);
connect(bt_poll_timer,SIGNAL(timeout()),this,SLOT(pollData()));
bt_poll_timer->start(LOCALAUDIO_POLL_INTERVAL);
//
// GPOs Handle
//
if(LogHpi(HPI_Object_ParameterHandle(bt_mixer,block,"Outputs",&bt_gpos_param),__LINE__)!=0) {
return;
}
if(LogHpi(HPI_Object_GetInfo(bt_gpos_param,entity_type_boolean,
entity_role_value,NULL,&value_size,&value_items),
__LINE__)!=0) {
bt_gpis=0;
UpdateDb(matrix);
return;
}
bt_gpos=value_items;
bt_gpo_values=new uint8_t[bt_gpos];
if(LogHpi(HPI_Object_GetValue(bt_gpos_param,entity_type_boolean,value_items,bt_gpo_values,value_size),__LINE__)!=0) {
bt_gpis=0;
bt_gpos=0;
UpdateDb(matrix);
return;
}
UpdateDb(matrix);
#endif // HPI
}
void LocalAudio::SetGpo(int line,bool state)
{
#ifdef HPI
if(LogHpi(HPI_Object_GetValue(bt_gpos_param,entity_type_boolean,
bt_gpos,bt_gpo_values,
bt_gpos),__LINE__)==0) {
if(state) {
bt_gpo_values[line]='T';
}
else {
bt_gpo_values[line]='F';
}
LogHpi(HPI_Object_SetValue(bt_gpos_param,entity_type_boolean,bt_gpos,
bt_gpo_values,bt_gpos),__LINE__);
}
#endif // HPI
}
void LocalAudio::UpdateDb(RDMatrix *matrix) const
{
matrix->setGpis(bt_gpis);
matrix->setGpos(bt_gpos);
}
#ifdef HPI
hpi_err_t LocalAudio::LogHpi(hpi_err_t err,int lineno)
{
char err_txt[200];
if(err!=0) {
HPI_GetErrorText(err,err_txt);
syslog(LOG_NOTICE,"HPI Error: %s, %s line %d",err_txt,__FILE__,lineno);
}
return err;
}
#endif // HPI