Autres/Rivendellaudio
1
0
Fork 0
mirror of https://github.com/ElvishArtisan/rivendell.git synced 2025-10-31 06:03:51 +01:00
Code Issues Projects Releases Wiki Activity

Reformatted rdcatchd/local_macros.cpp

Browse Source
This commit is contained in:
Fred Gleason
2016-03-29 14:20:26 -04:00
parent 465f6ad79d
commit 49fdde859d
1 changed files with 112 additions and 112 deletions
Download Patch File Download Diff File Expand all files Collapse all files

224
rdcatchd/local_macros.cpp
View File

@@ -36,131 +36,131 @@ void MainObject::RunLocalMacros(RDMacro *rml)
QDateTime dt;
switch(rml->command()) {
case RDMacro::EX:
cart=new RDCart(rml->arg(0).toUInt());
if(cart->exists()) {
if(ExecuteMacroCart(cart)) {
if(rml->echoRequested()) {
rml->acknowledge(true);
catch_ripc->sendRml(rml);
}
delete cart;
return;
}
}
else {
if(rml->echoRequested()) {
rml->acknowledge(false);
catch_ripc->sendRml(rml);
}
case RDMacro::EX:
cart=new RDCart(rml->arg(0).toUInt());
if(cart->exists()) {
if(ExecuteMacroCart(cart)) {
if(rml->echoRequested()) {
rml->acknowledge(true);
catch_ripc->sendRml(rml);
}
delete cart;
return;
break;
}
}
else {
if(rml->echoRequested()) {
rml->acknowledge(false);
catch_ripc->sendRml(rml);
}
}
delete cart;
return;
break;
case RDMacro::RS:
//
// Validate Parameters
//
if(rml->argQuantity()!=4) {
if(rml->echoRequested()) {
rml->acknowledge(false);
catch_ripc->sendRml(rml);
}
return;
}
chan=rml->arg(0).toInt();
cartnum=rml->arg(1).toUInt();
cutnum=rml->arg(2).toUInt();
len=rml->arg(3).toUInt();
if((chan<=0)||(chan>MAX_DECKS)||(cartnum>999999)||(cutnum>999)
||len==0) {
if(rml->echoRequested()) {
rml->acknowledge(false);
catch_ripc->sendRml(rml);
}
return;
}
cut=new RDCut(cartnum,cutnum);
deck=new RDDeck(catch_config->stationName(),chan);
if((!cut->exists())||(!deck->isActive())) {
delete cut;
delete deck;
if(rml->echoRequested()) {
rml->acknowledge(false);
catch_ripc->sendRml(rml);
}
return;
}
delete cut;
delete deck;
if(catch_record_deck_status[chan-1]!=RDDeck::Idle) {
if(catch_record_aborting[chan-1]&&
(catch_record_pending_cartnum[chan-1]==0)) {
// Cache Event
catch_record_pending_cartnum[chan-1]=cartnum;
catch_record_pending_cutnum[chan-1]=cutnum;
catch_record_pending_maxlen[chan-1]=len;
if(rml->echoRequested()) {
rml->acknowledge(true);
catch_ripc->sendRml(rml);
}
return;
}
else {
LogLine(RDConfig::LogWarning,QString().
sprintf("unable to handle RS macro for deck %d: device busy",
chan));
if(rml->echoRequested()) {
rml->acknowledge(false);
catch_ripc->sendRml(rml);
}
return;
}
}
//
// Create Event
//
StartRmlRecording(chan,cartnum,cutnum,len);
case RDMacro::RS:
//
// Validate Parameters
//
if(rml->argQuantity()!=4) {
if(rml->echoRequested()) {
rml->acknowledge(false);
catch_ripc->sendRml(rml);
}
return;
}
chan=rml->arg(0).toInt();
cartnum=rml->arg(1).toUInt();
cutnum=rml->arg(2).toUInt();
len=rml->arg(3).toUInt();
if((chan<=0)||(chan>MAX_DECKS)||(cartnum>999999)||(cutnum>999)
||len==0) {
if(rml->echoRequested()) {
rml->acknowledge(false);
catch_ripc->sendRml(rml);
}
return;
}
cut=new RDCut(cartnum,cutnum);
deck=new RDDeck(catch_config->stationName(),chan);
if((!cut->exists())||(!deck->isActive())) {
delete cut;
delete deck;
if(rml->echoRequested()) {
rml->acknowledge(false);
catch_ripc->sendRml(rml);
}
return;
}
delete cut;
delete deck;
if(catch_record_deck_status[chan-1]!=RDDeck::Idle) {
if(catch_record_aborting[chan-1]&&
(catch_record_pending_cartnum[chan-1]==0)) {
// Cache Event
catch_record_pending_cartnum[chan-1]=cartnum;
catch_record_pending_cutnum[chan-1]=cutnum;
catch_record_pending_maxlen[chan-1]=len;
if(rml->echoRequested()) {
rml->acknowledge(true);
catch_ripc->sendRml(rml);
}
break;
case RDMacro::RR:
if(rml->argQuantity()!=1) {
if(rml->echoRequested()) {
rml->acknowledge(false);
catch_ripc->sendRml(rml);
}
return;
}
chan=rml->arg(0).toInt();
if((chan>0)&&(chan<(MAX_DECKS+1))) {
switch(catch_record_deck_status[chan-1]) {
case RDDeck::Recording:
catch_record_aborting[chan-1]=true;
catch_cae->stopRecord(catch_record_card[chan-1],
catch_record_stream[chan-1]);
break;
case RDDeck::Waiting:
startTimerData(catch_record_id[chan-1]);
break;
default:
break;
}
}
return;
}
else {
LogLine(RDConfig::LogWarning,QString().
sprintf("unable to handle RS macro for deck %d: device busy",
chan));
if(rml->echoRequested()) {
rml->acknowledge(true);
rml->acknowledge(false);
catch_ripc->sendRml(rml);
}
break;
return;
}
}
//
// Create Event
//
StartRmlRecording(chan,cartnum,cutnum,len);
if(rml->echoRequested()) {
rml->acknowledge(true);
catch_ripc->sendRml(rml);
}
break;
case RDMacro::RR:
if(rml->argQuantity()!=1) {
if(rml->echoRequested()) {
rml->acknowledge(false);
catch_ripc->sendRml(rml);
}
return;
}
chan=rml->arg(0).toInt();
if((chan>0)&&(chan<(MAX_DECKS+1))) {
switch(catch_record_deck_status[chan-1]) {
case RDDeck::Recording:
catch_record_aborting[chan-1]=true;
catch_cae->stopRecord(catch_record_card[chan-1],
catch_record_stream[chan-1]);
break;
case RDDeck::Waiting:
startTimerData(catch_record_id[chan-1]);
break;
default:
break;
}
}
if(rml->echoRequested()) {
rml->acknowledge(true);
catch_ripc->sendRml(rml);
}
break;
default:
break;
}
}