 |
The Open Master Hearing Aid (openMHA)
openMHA
Open community platform for hearing aid algorithm research
|
|
The Open Master Hearing Aid (openMHA)
openMHA
Open community platform for hearing aid algorithm research
|
Template class for thread safe configuration. More...
Inherited by MHAPlugin::plugin_t< matlab_wrapper_rt_cfg_t >, MHAPlugin::plugin_t< fftfb_plug_t >, MHAPlugin::plugin_t< fftfbpow_t >, MHAPlugin::plugin_t< spec_fader_t >, MHAPlugin::plugin_t< doasvm_feature_extraction_config >, MHAPlugin::plugin_t< wave2spec_t >, MHAPlugin::plugin_t< acwriter_t >, MHAPlugin::plugin_t< lpc_config >, MHAPlugin::plugin_t< MHASignal::async_rmslevel_t >, MHAPlugin::plugin_t< adaptive_feedback_canceller_config >, MHAPlugin::plugin_t< steerbf_config >, MHAPlugin::plugin_t< doasvm_classification_config >, MHAPlugin::plugin_t< MHAWindow::fun_t >, MHAPlugin::plugin_t< acPooling_wave_config >, MHAPlugin::plugin_t< Ci_auralization_cis_cfg >, MHAPlugin::plugin_t< sine_cfg_t >, MHAPlugin::plugin_t< MHA_AC::spectrum_t >, MHAPlugin::plugin_t< rt_nlms_t >, MHAPlugin::plugin_t< level_matching_config_t >, MHAPlugin::plugin_t< scaler_t >, MHAPlugin::plugin_t< hilbert_shifter_t >, MHAPlugin::plugin_t< MHASignal::waveform_t >, MHAPlugin::plugin_t< delaysum_wave_t >, MHAPlugin::plugin_t< combc_t >, MHAPlugin::plugin_t< Ci_simulation_cis_cfg >, MHAPlugin::plugin_t< overlapadd_t >, MHAPlugin::plugin_t< fshift_config_t >, MHAPlugin::plugin_t< db_t >, MHAPlugin::plugin_t< fftfilter_t >, MHAPlugin::plugin_t< dc_t >, MHAPlugin::plugin_t< int >, MHAPlugin::plugin_t< cfg_t >, MHAPlugin::plugin_t< Ci_auralization_ace_cfg >, MHAPlugin::plugin_t< smooth_cepstrum_t >, MHAPlugin::plugin_t< UNIT >, MHAPlugin::plugin_t< MHAFilter::partitioned_convolution_t >, MHAPlugin::plugin_t< route::process_t >, MHAPlugin::plugin_t< lpc_bl_predictor_config >, MHAPlugin::plugin_t< dbasync_t >, MHAPlugin::plugin_t< cpuload_cfg_t >, MHAPlugin::plugin_t< noise_psd_estimator_t >, MHAPlugin::plugin_t< gtfb_simple_rt_t >, MHAPlugin::plugin_t< gtfb_simd_cfg_t >, MHAPlugin::plugin_t< ac2wave_t >, MHAPlugin::plugin_t< Ci_simulation_ace_cfg >, MHAPlugin::plugin_t< MHA_AC::waveform_t >, MHAPlugin::plugin_t< mhachain::plugs_t >, MHAPlugin::plugin_t< gsc_adaptive_stage >, MHAPlugin::plugin_t< char >, MHAPlugin::plugin_t< smoothspec_wrap_t >, MHAPlugin::plugin_t< prediction_error_config >, MHAPlugin::plugin_t< lpc_burglattice_config >, MHAPlugin::plugin_t< gtfb_analyzer_cfg_t >, MHAPlugin::plugin_t< adm_rtconfig_t >, MHAPlugin::plugin_t< example5_t >, MHAPlugin::plugin_t< cohflt_t >, MHAPlugin::plugin_t< acConcat_wave_config >, MHAPlugin::plugin_t< ac2xdf_rt_t >, MHAPlugin::plugin_t< Set_rms_cfg >, MHAPlugin::plugin_t< wavwriter_t >, MHAPlugin::plugin_t< spec2wave_t >, MHAPlugin::plugin_t< rohConfig >, MHAPlugin::plugin_t< delaysum_t >, MHAPlugin::plugin_t< MHASignal::delay_t >, MHAPlugin::plugin_t< acSteer_config >, MHAPlugin::plugin_t< resampling_t >, MHAPlugin::plugin_t< trigger2lsl_rt_t >, MHAPlugin::plugin_t< plingploing_t >, MHAPlugin::plugin_t< analysepath_t >, MHAPlugin::plugin_t< acTransform_wave_config >, MHAPlugin::plugin_t< Get_rms_cfg >, MHAPlugin::plugin_t< runtime_cfg_t >, addsndfile::addsndfile_if_t [private], audiometerbackend::audiometer_if_t [private], calibrator_t [private], and dc_simple::dc_if_t.
Public Member Functions | |
| config_t () | |
| ~config_t () | |
Protected Member Functions | |
| runtime_cfg_t * | poll_config () |
| Receive the latest run time configuration. More... | |
| runtime_cfg_t * | peek_config () const |
| Receive the latest run time configuration without changing the configuration pointer. More... | |
| void | push_config (runtime_cfg_t *ncfg) |
| Push a new run time configuration into the configuration fifo. More... | |
| void | cleanup_unused_cfg () |
| To be called by the push_config() for housekeeping. More... | |
| void | remove_all_cfg () |
| To be called on Plugin destruction, will delete all runtime configuration list nodes and objects regardless of their in_use flag. More... | |
Protected Attributes | |
| runtime_cfg_t * | cfg |
| Pointer to the runtime configuration currently used by the signal processing thread. More... | |
Private Attributes | |
| std::atomic< MHAPlugin::cfg_node_t< runtime_cfg_t > * > | cfg_root |
| Start of a singly linked list of runtime configuration objects. More... | |
| MHAPlugin::cfg_node_t< runtime_cfg_t > * | cfg_node_current |
| Pointer to the currently used plugin runtime configurations. More... | |
Template class for thread safe configuration.
This template class provides a mechanism for the handling of thread safe configuration which is required for run time configuration changes of the openMHA plugins.
The template parameter runtime_cfg_t is the run time configuration class of the openMHA plugin. The constructor of that class should transform the MHAParser variables into derived runtime configuration. The constructor should fail if the configuration is invalid by any reason.
A new runtime configuration is provided by the function push_config(). In the processing thread, the actual configuration can be received by a call of poll_config().
To ensure lock-free thread safety, we use C++ atomics and rely on the C++ memory model. We only use store-release and load-acquire operations by using C++ atomics with the default memory ordering. The semantics of these are:
The store-release operation atomically writes to an atomic variable, while the load-acquire operation atomically reads from an atomic variable.
The C++ memory model guarantees that all previous writes to memory performed by the thread doing the store-release are visible to other threads when they see the new value in the shared atomic variable when that value is read by the other thread with a load-acquire operation.
An important precondition of this synchronization scheme is that there is only ever one audio thread and one configuration thread per plugin, i.e. there is only one thread doing the push_config and one thread doing the poll_config for each instance of config_t.
For more details on atomics, refer to the C++11 or later documentation, or to these conference talks by Sutter:
| MHAPlugin::config_t< runtime_cfg_t >::config_t |
| MHAPlugin::config_t< runtime_cfg_t >::~config_t |
|
protected |
Receive the latest run time configuration.
This function stores the latest run time configuration into the protected class member variable ‘cfg’. If no configuration exists, then an exception will be thrown. If no changes occured, then the value of ‘cfg’ will be untouched.
This function should be only called from the processing thread.
Should be called at the start of each process() callback to get the latest runtime configuration.
When this function finds newer run time configurations, it returns the newest and ensures the older run time configurations have their not_in_use flag set to true.
| MHA_Error | if the resulting runtime configuration is NULL. This usually means that no push_config has occured. |
|
protected |
Receive the latest run time configuration without changing the configuration pointer.
This function retrieves the latest run time configuration. Returns a pointer to the latest runtime configuration without updating the data member cfg. For use in the configuration thread when creation of a new runtime configuration object needs access to the previously created runtime configuration object. Should normally not be used because it introduces synchronization requirements between configuration thread and signal processing thread.
|
protected |
Push a new run time configuration into the configuration fifo.
Should be called only by the configuration thread when a new runtime configuration object has been constructed in response to configuration changes, or during execution of the prepare() method to ensure that there is a valid runtime configuration for the signal processing which can start after prepare() returns.
For housekeeping, this method will also delete any runtime configuration objects that have previously been passed to push_config() if they are no longer needed.
| ncfg | A pointer to the new runtime configuration object. This object must have been created on the heap by the configuration thread with operator new. By passing the pointer to this method, client code gives up ownership. The object will be deleted in a future invocation of push_config, or on destruction of this config_t instance. |
|
protected |
To be called by the push_config() for housekeeping.
Will delete any no longer used runtime configuration objects.
|
protected |
To be called on Plugin destruction, will delete all runtime configuration list nodes and objects regardless of their in_use flag.
|
protected |
Pointer to the runtime configuration currently used by the signal processing thread.
Should be used to access the current runtime configuration during signal processing. This pointer is updated as a side effect of calling poll_config() on this object.
|
private |
Start of a singly linked list of runtime configuration objects.
cfg_root points to the oldest still existing node of that list. After object creation this pointer is updated by the configuration thread and then read by the signal processing thread. To ensure proper order of memory accesses for this transfer between threads, it needs to be atomic, this ensures that the start of the singly linked list of runtime configurations will be properly visible to the signal processing on startup.
|
private |
Pointer to the currently used plugin runtime configurations.
Used as a hint for poll_config where to start looking for the newest node. This optimization allows poll_config to scale better with the number of nodes not yet cleaned up by push_config. Does not need to be atomic because it is only used within the signal processing thread.
