cml/libcw
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

cwIoFlowCtl.h/cpp : Now recognizers kEofRC as a signal to stop the program.

Browse Source 
Added is_executable() and is_exec_complete().
This commit is contained in:
kevin 2024-07-01 10:35:24 -04:00
parent 71917afabd
commit 49af6c41b7
2 changed files with 54 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

55
cwIoFlowCtl.cpp
View File

@ -79,6 +79,8 @@ namespace cw
unsigned pgm_idx; // current program index unsigned pgm_idx; // current program index
flow::handle_t flowH; // flow::handle_t flowH; //
char* proj_dir; // current project directory char* proj_dir; // current project directory
bool done_fl;
} io_flow_ctl_t; } io_flow_ctl_t;
io_flow_ctl_t* _handleToPtr( handle_t h ) io_flow_ctl_t* _handleToPtr( handle_t h )
@ -423,6 +425,13 @@ namespace cw
unsigned midiBufMsgCnt = 0; unsigned midiBufMsgCnt = 0;
const midi::ch_msg_t* midiBuf = midiDeviceBuffer(p->ioH,midiBufMsgCnt); const midi::ch_msg_t* midiBuf = midiDeviceBuffer(p->ioH,midiBufMsgCnt);
if( p->done_fl )
{
rc = cwLogError(kInvalidStateRC,"Cannot execute an already completed program.");
goto errLabel;
}
// Give each MIDI input device a pointer to the incoming MIDI msgs // Give each MIDI input device a pointer to the incoming MIDI msgs
for(unsigned i=0; i<p->deviceN; ++i) for(unsigned i=0; i<p->deviceN; ++i)
if( p->deviceA[i].typeId == flow::kMidiDevTypeId && cwIsFlag(p->deviceA[i].flags,flow::kInFl) ) if( p->deviceA[i].typeId == flow::kMidiDevTypeId && cwIsFlag(p->deviceA[i].flags,flow::kInFl) )
@ -469,7 +478,14 @@ namespace cw
// update the flow network - this will generate audio into the output audio buffers // update the flow network - this will generate audio into the output audio buffers
flow::exec_cycle(p->flowH); if((rc = flow::exec_cycle(p->flowH)) != kOkRC )
{
if( rc == kEofRC )
{
p->done_fl = true;
rc = kOkRC;
}
}
// if there are empty output (playback) buffers // if there are empty output (playback) buffers
@ -632,6 +648,7 @@ cw::rc_t cw::io_flow_ctl::program_load( handle_t h, unsigned pgm_idx )
} }
p->pgm_idx = pgm_idx; p->pgm_idx = pgm_idx;
p->done_fl = false;
errLabel: errLabel:
return rc; return rc;
@ -679,10 +696,24 @@ cw::rc_t cw::io_flow_ctl::exec_nrt( handle_t h )
goto errLabel; goto errLabel;
} }
if( p->done_fl )
{
rc = cwLogError(kInvalidStateRC,"Cannot execute an already completed program.");
goto errLabel;
}
if((rc = exec( p->flowH )) != kOkRC ) if((rc = exec( p->flowH )) != kOkRC )
{ {
rc = cwLogError(rc,"%s execution failed.", cwStringNullGuard(p->pgmA[p->pgm_idx].label)); if(rc == kEofRC )
goto errLabel; {
p->done_fl = true;
rc = kOkRC;
}
else
{
rc = cwLogError(rc,"%s execution failed.", cwStringNullGuard(p->pgmA[p->pgm_idx].label));
goto errLabel;
}
} }
errLabel: errLabel:
@ -713,7 +744,7 @@ cw::rc_t cw::io_flow_ctl::exec( handle_t h, const io::msg_t& msg )
{ {
case io::kAudioTId: case io::kAudioTId:
if( msg.u.audio != nullptr ) if( msg.u.audio != nullptr )
_audio_callback(p,*msg.u.audio); rc = _audio_callback(p,*msg.u.audio);
break; break;
default: default:
@ -724,6 +755,22 @@ cw::rc_t cw::io_flow_ctl::exec( handle_t h, const io::msg_t& msg )
return rc; return rc;
} }
bool cw::io_flow_ctl::is_executable( handle_t h )
{
io_flow_ctl_t* p = _handleToPtr(h);
// A program must be loaded and execution cannot be complete
return p->pgm_idx != kInvalidIdx && p->done_fl==false;
}
bool cw::io_flow_ctl::is_exec_complete( handle_t h )
{
io_flow_ctl_t* p = _handleToPtr(h);
return p->done_fl;
}
void cw::io_flow_ctl::report( handle_t h ) void cw::io_flow_ctl::report( handle_t h )
{ {
io_flow_ctl_t* p = _handleToPtr(h); io_flow_ctl_t* p = _handleToPtr(h);

3
cwIoFlowCtl.h
View File

@ -39,6 +39,9 @@ namespace cw
// Handle an incoming IO msg. // Handle an incoming IO msg.
rc_t exec( handle_t h, const io::msg_t& msg ); rc_t exec( handle_t h, const io::msg_t& msg );
bool is_executable( handle_t h );
bool is_exec_complete( handle_t h );
void report( handle_t h ); void report( handle_t h );
void print_network( handle_t h ); void print_network( handle_t h );