#include "cwCommon.h" #include "cwLog.h" #include "cwCommonImpl.h" #include "cwMem.h" #include "cwText.h" #include "cwObject.h" #include "cwAudioFile.h" #include "cwVectOps.h" #include "cwMtx.h" #include "cwDspTypes.h" // real_t, sample_t #include "cwFlow.h" #include "cwFlowTypes.h" #include "cwFlowProc.h" namespace cw { namespace flow { typedef struct library_str { const char* label; class_members_t* members; } library_t; library_t library[] = { { "audio_in", &audio_in::members }, { "audio_out", &audio_out::members }, { "audioFileIn", &audioFileIn::members }, { "audioFileOut", &audioFileOut::members }, { "audio_gain", &audio_gain::members }, { "audio_split", &audio_split::members }, { "audio_duplicate", &audio_duplicate::members }, { "audio_merge", &audio_merge::members }, { "audio_mix", &audio_mix::members }, { "sine_tone", &sine_tone::members }, { "pv_analysis", &pv_analysis::members }, { "pv_synthesis", &pv_synthesis::members }, { "spec_dist", &spec_dist::members }, { "compressor", &compressor::members }, { "limiter", &limiter::members }, { "audio_delay", &audio_delay::members }, { "dc_filter", &dc_filter::members }, { "balance", &balance::members }, { "audio_meter", &audio_meter::members }, { nullptr, nullptr } }; class_members_t* _find_library_record( const char* label ) { for(library_t* l = library; l->label != nullptr; ++l) if( textCompare(l->label,label) == 0) return l->members; return nullptr; } flow_t* _handleToPtr(handle_t h) { return handleToPtr(h); } rc_t _is_var_flag_set( const object_t* var_flags_obj, const char* flag_label, const char* classLabel, const char* varLabel, bool&is_set_flag_ref ) { rc_t rc = kOkRC; is_set_flag_ref = false; if( var_flags_obj != nullptr ) { for(unsigned k=0; kchild_count(); ++k) { const object_t* tag_obj = var_flags_obj->child_ele(k); const char* tag = nullptr; if( tag_obj != nullptr && tag_obj->is_string() && (rc=tag_obj->value(tag))==kOkRC && tag != nullptr ) { if( strcmp(tag,flag_label) == 0 ) is_set_flag_ref = true; } else { rc = cwLogError(kSyntaxErrorRC,"An invalid or non-string value was found in a flow class '%s' variable:'%s' 'flags' field.",classLabel,varLabel); } } } return rc; } rc_t _parse_class_cfg(flow_t* p, const library_t* library, const object_t* classCfg) { rc_t rc = kOkRC; if( !classCfg->is_dict() ) return cwLogError(kSyntaxErrorRC,"The class description dictionary does not have dictionary syntax."); p->classDescN = classCfg->child_count(); p->classDescA = mem::allocZ( p->classDescN ); // for each class description for(unsigned i=0; iclassDescN; ++i) { const object_t* class_obj = classCfg->child_ele(i); const object_t* varD = nullptr; const object_t* presetD = nullptr; class_desc_t* cd = p->classDescA + i; cd->cfg = class_obj->pair_value(); cd->label = class_obj->pair_label(); // get the variable description if((rc = cd->cfg->getv_opt("vars", varD, "presets", presetD )) != kOkRC ) { rc = cwLogError(rc,"Parsing failed while parsing class desc:'%s'", cwStringNullGuard(cd->label) ); goto errLabel; } // parse the preset dictionary if( presetD != nullptr ) { if( !presetD->is_dict() ) { rc = cwLogError(rc,"The preset dictionary is not a dictionary on class desc:'%s'", cwStringNullGuard(cd->label) ); goto errLabel; } // for each preset in the class desc. for(unsigned j=0; jchild_count(); ++j) { const object_t* pair = presetD->child_ele(j); if( !pair->pair_value()->is_dict() ) { rc = cwLogError(kSyntaxErrorRC,"The preset '%s' in class desc '%s' is not a dictionary.", cwStringNullGuard(pair->pair_label()), cwStringNullGuard(cd->label)); goto errLabel; } preset_t* preset = mem::allocZ< preset_t >(); preset->label = pair->pair_label(); preset->cfg = pair->pair_value(); preset->link = cd->presetL; cd->presetL = preset; } } // parse the variable dictionary if( varD != nullptr ) { if( !varD->is_dict() ) { rc = cwLogError(rc,"The value dictionary is not a dictionary on class desc:'%s'", cwStringNullGuard(cd->label) ); goto errLabel; } // get the class member functions if((cd->members = _find_library_record(cd->label)) == nullptr ) { rc = cwLogError(kSyntaxErrorRC,"The '%s' class member function record could not be found..", cd->label ); goto errLabel; } // for each class value description for(unsigned j=0; jchild_count(); ++j) { const object_t* var_obj = varD->child_ele(j); const object_t* var_flags_obj = nullptr; const char* type_str = nullptr; unsigned type_flag = 0; bool srcVarFl = false; bool srcOptFl = false; var_desc_t* vd = mem::allocZ(); vd->label = var_obj->pair_label(); vd->cfg = var_obj->pair_value(); // get the variable description if((rc = vd->cfg->getv("type", type_str, "doc", vd->docText)) != kOkRC ) { rc = cwLogError(rc,"Parsing failed on class:%s variable: '%s'.", cd->label, vd->label ); goto errLabel; } // convert the type string to a numeric type flag if( (type_flag = value_type_label_to_flag( type_str )) == kInvalidTId ) { rc = cwLogError(rc,"Invalid type flag: '%s' class:'%s' value:'%s'.", type_str, cd->label, vd->label ); goto errLabel; } // get the variable description if((rc = vd->cfg->getv_opt("flags", var_flags_obj, "value",vd->val_cfg)) != kOkRC ) { rc = cwLogError(rc,"Parsing optional fields failed on class:%s variable: '%s'.", cd->label, vd->label ); goto errLabel; } // check for 'src' flag if((rc = _is_var_flag_set( var_flags_obj, "src", cd->label, vd->label, srcVarFl )) != kOkRC ) goto errLabel; // check for 'src_opt' flag if((rc = _is_var_flag_set( var_flags_obj, "src_opt", cd->label, vd->label, srcOptFl )) != kOkRC ) goto errLabel; vd->type |= type_flag; if( srcVarFl ) vd->flags |= kSrcVarFl; if( srcOptFl ) vd->flags |= kSrcOptVarFl; vd->link = cd->varDescL; cd->varDescL = vd; } } } errLabel: return rc; } void _connect_vars( variable_t* src_var, variable_t* in_var ) { // connect in_var into src_var's outgoing var chain in_var->connect_link = src_var->connect_link; src_var->connect_link = in_var; assert( src_var->value != nullptr ); in_var->value = src_var->value; in_var->src_var = src_var; } rc_t _setup_input( flow_t* p, instance_t* in_inst, const char* in_var_label, const char* src_label_arg ) { rc_t rc = kOkRC; unsigned src_charN = textLength(src_label_arg); variable_t* src_var = nullptr; instance_t* src_inst = nullptr; variable_t* in_var = nullptr; char sbuf[ src_charN+1 ]; // copy the id into the buf strncpy(sbuf,src_label_arg,src_charN+1); // advance suffix to the '.' char* suffix = sbuf; while( *suffix && *suffix != '.') ++suffix; // if a '.' suffix was found if( *suffix ) { *suffix = 0; ++suffix; } // locate source instance if((rc = instance_find(p, sbuf, src_inst )) != kOkRC ) { rc = cwLogError(kSyntaxErrorRC,"The source instance '%s' was not found.", cwStringNullGuard(sbuf) ); goto errLabel; } // locate source value if((rc = var_find( src_inst, suffix, kAnyChIdx, src_var)) != kOkRC ) { rc = cwLogError(rc,"The source var '%s' was not found on the source instance '%s'.", cwStringNullGuard(suffix), cwStringNullGuard(sbuf)); goto errLabel; } // locate input value if((rc = var_find( in_inst, in_var_label, kAnyChIdx, in_var )) != kOkRC ) { rc = cwLogError(rc,"The input value '%s' was not found on the instance '%s'.", cwStringNullGuard(in_var_label), cwStringNullGuard(in_inst->label)); goto errLabel; } // verify that the src_value type is included in the in_value type flags if( cwIsNotFlag(in_var->varDesc->type, src_var->varDesc->type) ) { rc = cwLogError(kSyntaxErrorRC,"The type flags don't match on input:%s %s source:%s %s .", in_inst->label, in_var_label, src_inst->label, suffix); goto errLabel; } if( src_var->value == nullptr ) { rc = cwLogError(kSyntaxErrorRC,"The source value is null on the connection input:%s %s source:%s %s .", in_inst->label, in_var_label, src_inst->label, suffix); goto errLabel; } _connect_vars( src_var, in_var ); //cwLogInfo("'%s:%s' connected to source '%s:%s' %p.", in_inst->label, in_var_label, src_inst->label, suffix, in_var->value ); errLabel: return rc; } void _destroy_inst( instance_t* inst ) { if( inst == nullptr ) return; if( inst->class_desc->members->destroy != nullptr && inst->userPtr != nullptr ) inst->class_desc->members->destroy( inst ); // destroy the instance variables variable_t* var0 = inst->varL; variable_t* var1 = nullptr; while( var0 != nullptr ) { var1 = var0->var_link; _var_destroy(var0); var0 = var1; } mem::release(inst->varMapA); mem::release(inst); } rc_t _var_map_id_to_index( instance_t* inst, unsigned vid, unsigned chIdx, unsigned& idxRef ); rc_t _create_instance_var_map( instance_t* inst ) { rc_t rc = kOkRC; unsigned max_vid = kInvalidId; unsigned max_chIdx = 0; variable_t* var = inst->varL; //variable_t* v0 = nullptr; // determine the max variable vid and max channel index value among all variables for(; var!=nullptr; var = var->var_link ) { if( var->vid != kInvalidId ) { if( max_vid == kInvalidId || var->vid > max_vid ) max_vid = var->vid; if( var->chIdx != kAnyChIdx && (var->chIdx+1) > max_chIdx ) max_chIdx = (var->chIdx + 1); } } // If there are any variables if( max_vid != kInvalidId ) { // create the variable map array inst->varMapChN = max_chIdx + 1; inst->varMapIdN = max_vid + 1; inst->varMapN = inst->varMapIdN * inst->varMapChN; inst->varMapA = mem::allocZ( inst->varMapN ); // assign each variable to a location in the map for(variable_t* var=inst->varL; var!=nullptr; var=var->var_link) if( var->vid != kInvalidId ) { unsigned idx = kInvalidIdx; if((rc = _var_map_id_to_index( inst, var->vid, var->chIdx, idx )) != kOkRC ) goto errLabel; // verify that there are not multiple variables per map position if( inst->varMapA[ idx ] != nullptr ) { variable_t* v0 = inst->varMapA[idx]; rc = cwLogError(kInvalidStateRC,"The variable '%s' id:%i ch:%i and '%s' id:%i ch:%i share the same variable map position on instance: %s. This is usually cased by duplicate variable id's.", v0->label,v0->vid,v0->chIdx, var->label,var->vid,var->chIdx,inst->label); goto errLabel; } // assign this variable to a map position inst->varMapA[ idx ] = var; if( var->chIdx != kAnyChIdx && var->value == nullptr ) { rc = cwLogError(kInvalidStateRC,"The value of the variable '%s' ch:%i on instance:'%s' has not been set.",var->label,var->chIdx,inst->label); goto errLabel; } } } errLabel: return rc; } void _complete_input_connections( instance_t* inst ) { for(variable_t* var=inst->varL; var!=nullptr; var=var->var_link) if(var->chIdx == kAnyChIdx && is_connected_to_external_proc(var) ) { variable_t* base_src_var = var->src_var; // since 'var' is on the 'any' channel the 'src' var must also be on the 'any' channel assert( base_src_var->chIdx == kAnyChIdx ); //printf("%s %s\n",inst->label,var->label); // for each var channel in the input var for(variable_t* in_var = var->ch_link; in_var != nullptr; in_var=in_var->ch_link) { // locate the matching channel on the 'src' var variable_t* svar = base_src_var; for(; svar!=nullptr; svar=svar->ch_link) if( svar->chIdx == in_var->chIdx ) break; // connect the src->input var _connect_vars( svar==nullptr ? base_src_var : svar, in_var); } } } rc_t _call_value_func_on_all_variables( instance_t* inst ) { rc_t rc = kOkRC; rc_t rc1 = kOkRC; for(unsigned i=0; ivarMapN; ++i) if( inst->varMapA[i] != nullptr && inst->varMapA[i]->vid != kInvalidId ) { variable_t* var = inst->varMapA[i]; if((rc = var->inst->class_desc->members->value( var->inst, var )) != kOkRC ) rc1 = cwLogError(rc,"The proc instance '%s' reported an invalid valid on variable:%s chIdx:%i.", var->inst->label, var->label, var->chIdx ); } return rc1; } rc_t _preset_channelize_vars( instance_t* inst, const char* type_src_label, const char* preset_label, const object_t* preset_cfg ) { rc_t rc = kOkRC; //cwLogInfo("Channelizing '%s' preset %i vars for '%s'.",type_src_label, preset_cfg==nullptr ? 0 : preset_cfg->child_count(), inst->label ); // validate the syntax of the preset record if( !preset_cfg->is_dict() ) { rc = cwLogError(kSyntaxErrorRC,"The preset record '%s' on %s '%s' is not a dictionary.", preset_label, type_src_label, inst->class_desc->label ); goto errLabel; } // for each preset variable for(unsigned i=0; ichild_count(); ++i) { const object_t* value = preset_cfg->child_ele(i)->pair_value(); const char* value_label = preset_cfg->child_ele(i)->pair_label(); variable_t* dummy = nullptr; // verify that a valid value exists if( value == nullptr ) { rc = cwLogError(kSyntaxErrorRC,"Unexpected missig value on %s preset '%s' instance '%s' variable '%s'.", type_src_label, preset_label, inst->label, cwStringNullGuard(value_label) ); goto errLabel; } // if a list of values was given if( value->is_list() ) { for(unsigned chIdx=0; chIdxchild_count(); ++chIdx) if((rc = var_channelize( inst, value_label, chIdx, value->child_ele(chIdx), kInvalidId, dummy )) != kOkRC ) goto errLabel; } else // otherwise a single value was given { if((rc = var_channelize( inst, value_label, kAnyChIdx, value, kInvalidId, dummy )) != kOkRC ) goto errLabel; } } errLabel: if( rc != kOkRC ) rc = cwLogError(rc,"Apply %s preset failed on instance:%s class:%s preset:%s.", type_src_label, inst->label, inst->class_desc->label, preset_label ); return rc; } rc_t _class_preset_channelize_vars( instance_t* inst, const char* preset_label ) { rc_t rc = kOkRC; const preset_t* pr; if( preset_label == nullptr ) return kOkRC; // locate the requestd preset record if((pr = class_preset_find(inst->class_desc, preset_label)) == nullptr ) { rc = cwLogError(kInvalidIdRC,"The preset '%s' could not be found for the instance '%s'.", preset_label, inst->label); goto errLabel; } rc = _preset_channelize_vars( inst, "class", preset_label, pr->cfg); errLabel: return rc; } rc_t _class_apply_presets( instance_t* inst, const object_t* preset_labels ) { rc_t rc = kOkRC; const char* s = nullptr; // if preset_labels is a string if( preset_labels->is_string() && preset_labels->value(s)==kOkRC ) return _class_preset_channelize_vars(inst,s); // if the preset_labels is not a list if( !preset_labels->is_list() ) rc = cwLogError(kSyntaxErrorRC,"The preset list on instance '%s' is neither a list nor a string.",inst->label); else { // preset_labels is a list. // for each label listed in the preset label list for(unsigned i=0; ichild_count(); ++i) { const object_t* label_obj = preset_labels->child_ele(i); // verify that the label is a strng if( !label_obj->is_string() || label_obj->value(s) != kOkRC ) { rc = cwLogError(kSyntaxErrorRC,"The preset list does not contain string on instance '%s'.",inst->label); goto errLabel; } // apply a preset label if((rc = _class_preset_channelize_vars( inst, s)) != kOkRC ) goto errLabel; } } errLabel: return rc; } rc_t _inst_args_channelize_vars( instance_t* inst, const char* arg_label, const object_t* arg_cfg ) { rc_t rc = kOkRC; if( arg_cfg == nullptr ) return rc; return _preset_channelize_vars( inst, "instance", arg_label, arg_cfg ); } typedef struct inst_parse_vars_str { const char* inst_label; const char* inst_clas_label; const object_t* in_dict; const char* arg_label; const object_t* preset_labels; const object_t* arg_cfg; } inst_parse_vars_t; rc_t _parse_instance_cfg( flow_t* p, const object_t* inst_cfg, inst_parse_vars_t& pvars ) { rc_t rc = kOkRC; const object_t* arg_dict = nullptr; // validate the syntax of the inst_cfg pair if( inst_cfg == nullptr || !inst_cfg->is_pair() || inst_cfg->pair_label()==nullptr || inst_cfg->pair_value()==nullptr ) { rc = cwLogError(kSyntaxErrorRC,"The instance cfg. is not a valid pair. No instance label could be parsed."); goto errLabel; } pvars.inst_label = inst_cfg->pair_label(); // verify that the instance label is unique if( instance_find(p,pvars.inst_label) != nullptr ) { rc = cwLogError(kSyntaxErrorRC,"The instance label '%s' has already been used.",pvars.inst_label); goto errLabel; } // get the instance class label if((rc = inst_cfg->pair_value()->getv("class",pvars.inst_clas_label)) != kOkRC ) { rc = cwLogError(kSyntaxErrorRC,"The instance cfg. %s is missing: 'type'.",pvars.inst_label); goto errLabel; } // parse the optional args if((rc = inst_cfg->pair_value()->getv_opt("args", arg_dict, "in", pvars.in_dict, "argLabel", pvars.arg_label, "preset", pvars.preset_labels)) != kOkRC ) { rc = cwLogError(kSyntaxErrorRC,"The instance cfg. '%s' missing: 'type'.",pvars.inst_label); goto errLabel; } // if an argument dict was given in the instanec cfg if( arg_dict != nullptr ) { bool rptErrFl = true; // verify the arg. dict is actually a dict. if( !arg_dict->is_dict() ) { cwLogError(kSyntaxErrorRC,"The instance argument dictionary on instance '%s' is not a dictionary.",pvars.inst_label); goto errLabel; } // if no label was given then try 'default' if( pvars.arg_label == nullptr) { pvars.arg_label = "default"; rptErrFl = false; } // locate the specified argument record if((pvars.arg_cfg = arg_dict->find_child(pvars.arg_label)) == nullptr ) { // if an explicit arg. label was given but it was not found if( rptErrFl ) { rc = cwLogError(kSyntaxErrorRC,"The argument cfg. '%s' was not found on instance cfg. '%s'.",pvars.arg_label,pvars.inst_label); goto errLabel; } // no explicit arg. label was given - make arg_dict the instance arg cfg. pvars.arg_cfg = arg_dict; pvars.arg_label = nullptr; } } errLabel: if( rc != kOkRC ) rc = cwLogError(kSyntaxErrorRC,"Configuration parsing failed on instance: '%s'.", cwStringNullGuard(pvars.inst_label) ); return rc; } rc_t _create_instance( flow_t* p, const object_t* inst_cfg ) { rc_t rc = kOkRC; inst_parse_vars_t pvars = {0}; instance_t* inst = nullptr; class_desc_t* class_desc = nullptr; // parse the instance configuration if((rc = _parse_instance_cfg( p, inst_cfg, pvars )) != kOkRC ) goto errLabel; // locate the class desc if(( class_desc = class_desc_find(p,pvars.inst_clas_label)) == nullptr ) { rc = cwLogError(kSyntaxErrorRC,"The flow class '%s' was not found.",cwStringNullGuard(pvars.inst_clas_label)); goto errLabel; } // instantiate the instance inst = mem::allocZ(); inst->ctx = p; inst->label = pvars.inst_label; inst->inst_cfg = inst_cfg; inst->arg_label = pvars.arg_label; inst->arg_cfg = pvars.arg_cfg; inst->class_desc = class_desc; // Instantiate all the variables in the class description for(var_desc_t* vd=class_desc->varDescL; vd!=nullptr; vd=vd->link) { variable_t* var = nullptr; if((rc = var_create( inst, vd->label, kInvalidId, kAnyChIdx, vd->val_cfg, var )) != kOkRC ) goto errLabel; } // All the variables that can be used by this instance have now been created // and the chIdx of each variable is set to 'any'. // If a 'preset' field was included in the instance cfg then apply the specified class preset if( pvars.preset_labels != nullptr ) if((rc = _class_apply_presets(inst, pvars.preset_labels )) != kOkRC ) goto errLabel; // All the class presets values have now been set and those variables // that were expressed with a list have numeric channel indexes assigned. // Apply the instance preset values. if( pvars.arg_cfg != nullptr ) if((rc = _inst_args_channelize_vars( inst, pvars.arg_label, pvars.arg_cfg )) != kOkRC ) goto errLabel; // All the instance arg values have now been set and those variables // that were expressed with a list have numeric channel indexes assigned. // TODO: Should the 'all' variable be removed for variables that have numeric channel indexes? // connect the variable lists in the instance 'in' dictionary if( pvars.in_dict != nullptr ) { if( !pvars.in_dict->is_dict() ) { cwLogError(kSyntaxErrorRC,"The 'in' dict in instance '%s' is not a valid dictionary.",inst->label); goto errLabel; } // for each input variable in the 'in' set for(unsigned i=0; ichild_count(); ++i) { const object_t* in_pair = pvars.in_dict->child_ele(i); const char* in_var_label = in_pair->pair_label(); const char* src_label = nullptr; const var_desc_t* vd = nullptr; // locate the var desc of the associated variable if((vd = var_desc_find( class_desc, in_var_label)) == nullptr ) { cwLogError(kSyntaxErrorRC,"The value description for the 'in' value '%s' was not found on instance '%s'. Maybe '%s' is not marked as a 'src' attribute in the class variable descripiton.",in_var_label,inst->label,in_var_label); goto errLabel; } // Note that all variable's found by the above call to var_desc_find() should be 'src' variables. //assert( cwIsFlag(vd->flags,kSrcVarFl) ); // if this value is a 'src' value then it must be setup prior to the instance being instantiated //if( cwIsFlag(vd->flags,kSrcVarFl) ) //{ in_pair->pair_value()->value(src_label); // locate the pointer to the referenced output abuf and store it in inst->srcABuf[i] if((rc = _setup_input( p, inst, in_var_label, src_label )) != kOkRC ) { rc = cwLogError(kSyntaxErrorRC,"The 'in' variable at index %i is not valid on instance '%s'.", i, inst->label ); goto errLabel; } //} } } // Complete the instantiation // Call the custom instance create() function. if((rc = class_desc->members->create( inst )) != kOkRC ) { rc = cwLogError(kInvalidArgRC,"Instantiation failed on instance '%s'.", inst->label ); goto errLabel; } // Create the instance->varMap[] lookup array if((rc =_create_instance_var_map( inst )) != kOkRC ) goto errLabel; // _complete_input_connections(inst); // call the 'value()' function to inform the instance of the current value of all of it's variables. if((rc = _call_value_func_on_all_variables( inst )) != kOkRC ) goto errLabel; // insert an instance in the network if( p->network_tail == nullptr ) { p->network_head = inst; p->network_tail = inst; } else { p->network_tail->link = inst; p->network_tail = inst; } errLabel: if( rc != kOkRC ) _destroy_inst(inst); return rc; } rc_t _destroy( flow_t* p) { rc_t rc = kOkRC; if( p == nullptr ) return rc; instance_t* i0=p->network_head; instance_t* i1=nullptr; // destroy the instances while(i0!=nullptr) { i1 = i0->link; _destroy_inst(i0); i0 = i1; } // release the class records for(unsigned i=0; iclassDescN; ++i) { class_desc_t* cd = p->classDescA + i; // release the var desc list var_desc_t* vd0 = cd->varDescL; var_desc_t* vd1 = nullptr; while( vd0 != nullptr ) { vd1 = vd0->link; mem::release(vd0); vd0 = vd1; } // release the preset list preset_t* pr0 = cd->presetL; preset_t* pr1 = nullptr; while( pr0 != nullptr ) { pr1 = pr0->link; mem::release(pr0); pr0 = pr1; } } mem::release(p->classDescA); mem::release(p); return rc; } const object_t* _find_network_preset( flow_t* p, const char* presetLabel ) { const object_t* preset_value = nullptr; if( p->presetCfg != nullptr ) { rc_t rc; if((rc = p->presetCfg->getv_opt( presetLabel, preset_value )) != kOkRC ) cwLogError(rc,"Search for network preset named '%s' failed.", cwStringNullGuard(presetLabel)); } return preset_value; } rc_t _exec_cycle( flow_t* p ) { rc_t rc = kOkRC; for(instance_t* inst = p->network_head; inst!=nullptr; inst=inst->link) if((rc = inst->class_desc->members->exec(inst)) != kOkRC ) break; return rc; } rc_t _get_variable( flow_t* p, const char* inst_label, const char* var_label, unsigned chIdx, instance_t*& instPtrRef, variable_t*& varPtrRef ) { rc_t rc = kOkRC; instance_t* inst = nullptr; variable_t* var = nullptr; varPtrRef = nullptr; instPtrRef = nullptr; // locate the proc instance if((inst = instance_find(p,inst_label)) == nullptr ) { rc = cwLogError(kInvalidIdRC,"Unknown proc instance label '%s'.", cwStringNullGuard(inst_label)); goto errLabel; } // locate the variable if((rc = var_find( inst, var_label, chIdx, var)) != kOkRC ) { rc = cwLogError(kInvalidArgRC,"The variable '%s' could not be found on the proc instance '%s'.",cwStringNullGuard(var_label),cwStringNullGuard(inst_label)); goto errLabel; } instPtrRef = inst; varPtrRef = var; errLabel: return rc; } template< typename T > rc_t _set_variable_value( flow_t* p, const char* inst_label, const char* var_label, unsigned chIdx, T value ) { rc_t rc = kOkRC; instance_t* inst = nullptr; variable_t* var = nullptr; // get the variable if((rc = _get_variable(p,inst_label,var_label,chIdx,inst,var)) != kOkRC ) goto errLabel; // set the variable value if((rc = var_set( inst, var->vid, chIdx, value )) != kOkRC ) { rc = cwLogError(kOpFailRC,"The variable set failed on instance:'%s' variable:'%s'.",cwStringNullGuard(inst_label),cwStringNullGuard(var_label)); goto errLabel; } errLabel: return rc; } template< typename T > rc_t _get_variable_value( flow_t* p, const char* inst_label, const char* var_label, unsigned chIdx, T& valueRef ) { rc_t rc = kOkRC; instance_t* inst = nullptr; variable_t* var = nullptr; // get the variable if((rc = _get_variable(p,inst_label,var_label,chIdx,inst,var)) != kOkRC ) goto errLabel; // get the variable value if((rc = var_get( inst, var->vid, chIdx, valueRef )) != kOkRC ) { rc = cwLogError(kOpFailRC,"The variable get failed on instance:'%s' variable:'%s'.",cwStringNullGuard(inst_label),cwStringNullGuard(var_label)); goto errLabel; } errLabel: return rc; } } } void cw::flow::print_abuf( const abuf_t* abuf ) { printf("Abuf: sr:%7.1f chs:%3i frameN:%4i %p",abuf->srate,abuf->chN,abuf->frameN,abuf->buf); } void cw::flow::print_external_device( const external_device_t* dev ) { printf("Dev: %10s id:%3i type:%3i fl:0x%x : ", cwStringNullGuard(dev->label),dev->ioDevId,dev->typeId,dev->flags); if( dev->typeId == kAudioDevTypeId ) print_abuf(dev->u.a.abuf); printf("\n"); } cw::rc_t cw::flow::create( handle_t& hRef, const object_t& classCfg, const object_t& networkCfg, external_device_t* deviceA, unsigned deviceN ) { rc_t rc = kOkRC; const object_t* network; bool printClassDictFl = false; bool printNetworkFl = false; if(( rc = destroy(hRef)) != kOkRC ) return rc; flow_t* p = mem::allocZ(); p->networkCfg = &networkCfg; // TODO: duplicate cfg? p->deviceA = deviceA; p->deviceN = deviceN; // parse the class description array if((rc = _parse_class_cfg(p,library,&classCfg)) != kOkRC ) { rc = cwLogError(kSyntaxErrorRC,"Error parsing the class description list."); goto errLabel; } // parse the main audio file processor cfg record if((rc = networkCfg.getv("framesPerCycle", p->framesPerCycle, "network", network)) != kOkRC ) { rc = cwLogError(kSyntaxErrorRC,"Error parsing the required flow configuration parameters."); goto errLabel; } // parse the optional args if((rc = networkCfg.getv_opt("maxCycleCount", p->maxCycleCount, "printClassDictFl", printClassDictFl, "printNetworkFl", printNetworkFl, "presets", p->presetCfg)) != kOkRC ) { rc = cwLogError(kSyntaxErrorRC,"Error parsing the optional flow configuration parameters."); goto errLabel; } // print the class dict if( printClassDictFl ) class_dict_print( p ); // build the network for(unsigned i=0; ichild_count(); ++i) { const object_t* inst_cfg = network->child_ele(i); // create the instance if( (rc= _create_instance( p, inst_cfg ) ) != kOkRC ) { rc = cwLogError(rc,"The instantiation at proc index %i is invalid.",i); goto errLabel; } } if( printNetworkFl ) network_print(p); hRef.set(p); errLabel: if( rc != kOkRC ) _destroy(p); return rc; } cw::rc_t cw::flow::destroy( handle_t& hRef ) { rc_t rc = kOkRC; flow_t* p = nullptr;; if( !hRef.isValid() ) return rc; p = _handleToPtr(hRef); _destroy(p); hRef.clear(); return rc; } cw::rc_t cw::flow::exec_cycle( handle_t h ) { return _exec_cycle(_handleToPtr(h)); } cw::rc_t cw::flow::exec( handle_t h ) { rc_t rc = kOkRC; flow_t* p = _handleToPtr(h); while( true ) { rc = _exec_cycle(p); if( rc == kEofRC ) { rc = kOkRC; break; } p->cycleIndex += 1; if( p->maxCycleCount > 0 && p->cycleIndex >= p->maxCycleCount ) break; } return rc; } cw::rc_t cw::flow::apply_preset( handle_t h, const char* presetLabel ) { rc_t rc = kOkRC; flow_t* p = _handleToPtr(h); const object_t* net_preset_value; const object_t* preset_pair; // locate the cfg of the requested preset if((net_preset_value = _find_network_preset(p, presetLabel )) == nullptr ) { rc = cwLogError(kInvalidIdRC,"The network preset '%s' could not be found.", presetLabel ); goto errLabel; } // for each instance in the preset for(unsigned i=0; ichild_count(); ++i) { // get the instance label/value pair if((preset_pair = net_preset_value->child_ele(i)) != nullptr && preset_pair->is_pair() ) { const char* inst_label = preset_pair->pair_label(); const object_t* preset_value_cfg = preset_pair->pair_value(); instance_t* inst; // locate the instance if((inst = instance_find(p,inst_label)) == nullptr ) { rc = cwLogError(kInvalidIdRC,"The network instance '%s' refered to in network preset '%s' could not be found.",inst_label,presetLabel); goto errLabel; } // if the preset value is a string then look it up in the class dictionary if( preset_value_cfg->is_string() ) { const char* class_preset_label; preset_value_cfg->value(class_preset_label); _class_preset_channelize_vars(inst, class_preset_label ); } else // if the preset value is a dict then apply it directly if( preset_value_cfg->is_dict() ) { if((rc = _preset_channelize_vars( inst, "network", presetLabel, preset_value_cfg )) != kOkRC ) { rc = cwLogError(rc,"The preset '%s' application failed on instance '%s'.", presetLabel, inst_label ); goto errLabel; } } else { rc = cwLogError(kSyntaxErrorRC,"The network preset '%s' instance '%s' does not have a string or dictionary value.", presetLabel, inst_label ); goto errLabel; } } else { rc = cwLogError(kSyntaxErrorRC,"The network preset '%s' is malformed.",presetLabel); goto errLabel; } } errLabel: return rc; } cw::rc_t cw::flow::set_variable_value( handle_t h, const char* inst_label, const char* var_label, unsigned chIdx, bool value ) { return _set_variable_value( _handleToPtr(h), inst_label, var_label, chIdx, value ); } cw::rc_t cw::flow::set_variable_value( handle_t h, const char* inst_label, const char* var_label, unsigned chIdx, int value ) { return _set_variable_value( _handleToPtr(h), inst_label, var_label, chIdx, value ); } cw::rc_t cw::flow::set_variable_value( handle_t h, const char* inst_label, const char* var_label, unsigned chIdx, unsigned value ) { return _set_variable_value( _handleToPtr(h), inst_label, var_label, chIdx, value ); } cw::rc_t cw::flow::set_variable_value( handle_t h, const char* inst_label, const char* var_label, unsigned chIdx, float value ) { return _set_variable_value( _handleToPtr(h), inst_label, var_label, chIdx, value ); } cw::rc_t cw::flow::set_variable_value( handle_t h, const char* inst_label, const char* var_label, unsigned chIdx, double value ) { return _set_variable_value( _handleToPtr(h), inst_label, var_label, chIdx, value ); } cw::rc_t cw::flow::get_variable_value( handle_t h, const char* inst_label, const char* var_label, unsigned chIdx, bool& valueRef ) { return _get_variable_value( _handleToPtr(h), inst_label, var_label, chIdx, valueRef ); } cw::rc_t cw::flow::get_variable_value( handle_t h, const char* inst_label, const char* var_label, unsigned chIdx, int& valueRef ) { return _get_variable_value( _handleToPtr(h), inst_label, var_label, chIdx, valueRef ); } cw::rc_t cw::flow::get_variable_value( handle_t h, const char* inst_label, const char* var_label, unsigned chIdx, unsigned& valueRef ) { return _get_variable_value( _handleToPtr(h), inst_label, var_label, chIdx, valueRef ); } cw::rc_t cw::flow::get_variable_value( handle_t h, const char* inst_label, const char* var_label, unsigned chIdx, float& valueRef ) { return _get_variable_value( _handleToPtr(h), inst_label, var_label, chIdx, valueRef ); } cw::rc_t cw::flow::get_variable_value( handle_t h, const char* inst_label, const char* var_label, unsigned chIdx, double& valueRef ) { return _get_variable_value( _handleToPtr(h), inst_label, var_label, chIdx, valueRef ); } void cw::flow::print_class_list( handle_t h ) { flow_t* p = _handleToPtr(h); class_dict_print(p); } void cw::flow::print_network( handle_t h ) { flow_t* p = _handleToPtr(h); for(unsigned i=0; ideviceN; ++i) print_external_device( p->deviceA + i ); network_print(p); } cw::rc_t cw::flow::test( const object_t* class_cfg, const object_t* cfg ) { rc_t rc = kOkRC; handle_t flowH; // create the flow object if((rc = create( flowH, *class_cfg, *cfg)) != kOkRC ) { rc = cwLogError(rc,"Flow object create failed."); goto errLabel; } // run the network if((rc = exec( flowH )) != kOkRC ) rc = cwLogError(rc,"Execution failed."); // destroy the flow object if((rc = destroy(flowH)) != kOkRC ) { rc = cwLogError(rc,"Close the flow object."); goto errLabel; } errLabel: return rc; }