aboutsummaryrefslogtreecommitdiff
path: root/Ryujinx.Audio.Renderer/Server/CommandGenerator.cs
diff options
context:
space:
mode:
authorMary <me@thog.eu>2021-02-26 01:11:56 +0100
committerGitHub <noreply@github.com>2021-02-26 01:11:56 +0100
commitf556c80d0230056335632b60c71f1567e177239e (patch)
tree748aa6be62b93a8e941e25dbd83f39e1dbb37035 /Ryujinx.Audio.Renderer/Server/CommandGenerator.cs
parent1c49089ff00fc87dc4872f135dc6a0d36169a970 (diff)
Haydn: Part 1 (#2007)
* Haydn: Part 1 Based on my reverse of audio 11.0.0. As always, core implementation under LGPLv3 for the same reasons as for Amadeus. This place the bases of a more flexible audio system while making audout & audin accurate. This have the following improvements: - Complete reimplementation of audout and audin. - Audin currently only have a dummy backend. - Dramatically reduce CPU usage by up to 50% in common cases (SoundIO and OpenAL). - Audio Renderer now can output to 5.1 devices when supported. - Audio Renderer init its backend on demand instead of keeping two up all the time. - All backends implementation are now in their own project. - Ryujinx.Audio.Renderer was renamed Ryujinx.Audio and was refactored because of this. As a note, games having issues with OpenAL haven't improved and will not because of OpenAL design (stopping when buffers finish playing causing possible audio "pops" when buffers are very small). * Update for latest hexkyz's edits on Switchbrew * audren: Rollback channel configuration changes * Address gdkchan's comments * Fix typo in OpenAL backend driver * Address last comments * Fix a nit * Address gdkchan's comments
Diffstat (limited to 'Ryujinx.Audio.Renderer/Server/CommandGenerator.cs')
-rw-r--r--Ryujinx.Audio.Renderer/Server/CommandGenerator.cs940
1 files changed, 0 insertions, 940 deletions
diff --git a/Ryujinx.Audio.Renderer/Server/CommandGenerator.cs b/Ryujinx.Audio.Renderer/Server/CommandGenerator.cs
deleted file mode 100644
index 36c438fe..00000000
--- a/Ryujinx.Audio.Renderer/Server/CommandGenerator.cs
+++ /dev/null
@@ -1,940 +0,0 @@
-//
-// Copyright (c) 2019-2021 Ryujinx
-//
-// This program is free software: you can redistribute it and/or modify
-// it under the terms of the GNU Lesser General Public License as published by
-// the Free Software Foundation, either version 3 of the License, or
-// (at your option) any later version.
-//
-// This program is distributed in the hope that it will be useful,
-// but WITHOUT ANY WARRANTY; without even the implied warranty of
-// MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
-// GNU Lesser General Public License for more details.
-//
-// You should have received a copy of the GNU Lesser General Public License
-// along with this program. If not, see <https://www.gnu.org/licenses/>.
-//
-
-using Ryujinx.Audio.Renderer.Common;
-using Ryujinx.Audio.Renderer.Dsp.Command;
-using Ryujinx.Audio.Renderer.Dsp.State;
-using Ryujinx.Audio.Renderer.Parameter;
-using Ryujinx.Audio.Renderer.Server.Effect;
-using Ryujinx.Audio.Renderer.Server.Mix;
-using Ryujinx.Audio.Renderer.Server.Performance;
-using Ryujinx.Audio.Renderer.Server.Sink;
-using Ryujinx.Audio.Renderer.Server.Splitter;
-using Ryujinx.Audio.Renderer.Server.Voice;
-using Ryujinx.Audio.Renderer.Utils;
-using System;
-using System.Diagnostics;
-
-namespace Ryujinx.Audio.Renderer.Server
-{
- public class CommandGenerator
- {
- private CommandBuffer _commandBuffer;
- private RendererSystemContext _rendererContext;
- private VoiceContext _voiceContext;
- private MixContext _mixContext;
- private EffectContext _effectContext;
- private SinkContext _sinkContext;
- private SplitterContext _splitterContext;
- private PerformanceManager _performanceManager;
-
- public CommandGenerator(CommandBuffer commandBuffer, RendererSystemContext rendererContext, VoiceContext voiceContext, MixContext mixContext, EffectContext effectContext, SinkContext sinkContext, SplitterContext splitterContext, PerformanceManager performanceManager)
- {
- _commandBuffer = commandBuffer;
- _rendererContext = rendererContext;
- _voiceContext = voiceContext;
- _mixContext = mixContext;
- _effectContext = effectContext;
- _sinkContext = sinkContext;
- _splitterContext = splitterContext;
- _performanceManager = performanceManager;
-
- _commandBuffer.GenerateClearMixBuffer(RendererConstants.InvalidNodeId);
- }
-
- private void GenerateDataSource(ref VoiceState voiceState, Memory<VoiceUpdateState> dspState, int channelIndex)
- {
- if (voiceState.MixId != RendererConstants.UnusedMixId)
- {
- ref MixState mix = ref _mixContext.GetState(voiceState.MixId);
-
- _commandBuffer.GenerateDepopPrepare(dspState,
- _rendererContext.DepopBuffer,
- mix.BufferCount,
- mix.BufferOffset,
- voiceState.NodeId,
- voiceState.WasPlaying);
- }
- else if (voiceState.SplitterId != RendererConstants.UnusedSplitterId)
- {
- int destinationId = 0;
-
- while (true)
- {
- Span<SplitterDestination> destinationSpan = _splitterContext.GetDestination((int)voiceState.SplitterId, destinationId++);
-
- if (destinationSpan.IsEmpty)
- {
- break;
- }
-
- ref SplitterDestination destination = ref destinationSpan[0];
-
- if (destination.IsConfigured())
- {
- int mixId = destination.DestinationId;
-
- if (mixId < _mixContext.GetCount() && mixId != RendererConstants.UnusedSplitterIdInt)
- {
- ref MixState mix = ref _mixContext.GetState(mixId);
-
- _commandBuffer.GenerateDepopPrepare(dspState,
- _rendererContext.DepopBuffer,
- mix.BufferCount,
- mix.BufferOffset,
- voiceState.NodeId,
- voiceState.WasPlaying);
-
- destination.MarkAsNeedToUpdateInternalState();
- }
- }
- }
- }
-
- if (!voiceState.WasPlaying)
- {
- Debug.Assert(voiceState.SampleFormat != SampleFormat.Adpcm || channelIndex == 0);
-
- if (_rendererContext.BehaviourContext.IsWaveBufferVersion2Supported())
- {
- _commandBuffer.GenerateDataSourceVersion2(ref voiceState,
- dspState,
- (ushort)_rendererContext.MixBufferCount,
- (ushort)channelIndex,
- voiceState.NodeId);
- }
- else
- {
- switch (voiceState.SampleFormat)
- {
- case SampleFormat.PcmInt16:
- _commandBuffer.GeneratePcmInt16DataSourceVersion1(ref voiceState,
- dspState,
- (ushort)_rendererContext.MixBufferCount,
- (ushort)channelIndex,
- voiceState.NodeId);
- break;
- case SampleFormat.PcmFloat:
- _commandBuffer.GeneratePcmFloatDataSourceVersion1(ref voiceState,
- dspState,
- (ushort)_rendererContext.MixBufferCount,
- (ushort)channelIndex,
- voiceState.NodeId);
- break;
- case SampleFormat.Adpcm:
- _commandBuffer.GenerateAdpcmDataSourceVersion1(ref voiceState,
- dspState,
- (ushort)_rendererContext.MixBufferCount,
- voiceState.NodeId);
- break;
- default:
- throw new NotImplementedException($"Unsupported data source {voiceState.SampleFormat}");
- }
- }
- }
- }
-
- private void GenerateBiquadFilterForVoice(ref VoiceState voiceState, Memory<VoiceUpdateState> state, int baseIndex, int bufferOffset, int nodeId)
- {
- for (int i = 0; i < voiceState.BiquadFilters.Length; i++)
- {
- ref BiquadFilterParameter filter = ref voiceState.BiquadFilters[i];
-
- if (filter.Enable)
- {
- Memory<byte> biquadStateRawMemory = SpanMemoryManager<byte>.Cast(state).Slice(VoiceUpdateState.BiquadStateOffset, VoiceUpdateState.BiquadStateSize * RendererConstants.VoiceBiquadFilterCount);
-
- Memory<BiquadFilterState> stateMemory = SpanMemoryManager<BiquadFilterState>.Cast(biquadStateRawMemory);
-
- _commandBuffer.GenerateBiquadFilter(baseIndex,
- ref filter,
- stateMemory.Slice(i, 1),
- bufferOffset,
- bufferOffset,
- !voiceState.BiquadFilterNeedInitialization[i],
- nodeId);
- }
- }
- }
-
- private void GenerateVoiceMix(Span<float> mixVolumes, Span<float> previousMixVolumes, Memory<VoiceUpdateState> state, uint bufferOffset, uint bufferCount, uint bufferIndex, int nodeId)
- {
- if (bufferCount > RendererConstants.VoiceChannelCountMax)
- {
- _commandBuffer.GenerateMixRampGrouped(bufferCount,
- bufferIndex,
- bufferOffset,
- previousMixVolumes,
- mixVolumes,
- state,
- nodeId);
- }
- else
- {
- for (int i = 0; i < bufferCount; i++)
- {
- float previousMixVolume = previousMixVolumes[i];
- float mixVolume = mixVolumes[i];
-
- if (mixVolume != 0.0f || previousMixVolume != 0.0f)
- {
- _commandBuffer.GenerateMixRamp(previousMixVolume,
- mixVolume,
- bufferIndex,
- bufferOffset + (uint)i,
- i,
- state,
- nodeId);
- }
- }
- }
- }
-
- private void GenerateVoice(ref VoiceState voiceState)
- {
- int nodeId = voiceState.NodeId;
- uint channelsCount = voiceState.ChannelsCount;
-
- for (int channelIndex = 0; channelIndex < channelsCount; channelIndex++)
- {
- Memory<VoiceUpdateState> dspStateMemory = _voiceContext.GetUpdateStateForDsp(voiceState.ChannelResourceIds[channelIndex]);
-
- ref VoiceChannelResource channelResource = ref _voiceContext.GetChannelResource(voiceState.ChannelResourceIds[channelIndex]);
-
- PerformanceDetailType dataSourceDetailType = PerformanceDetailType.Adpcm;
-
- if (voiceState.SampleFormat == SampleFormat.PcmInt16)
- {
- dataSourceDetailType = PerformanceDetailType.PcmInt16;
- }
- else if (voiceState.SampleFormat == SampleFormat.PcmFloat)
- {
- dataSourceDetailType = PerformanceDetailType.PcmFloat;
- }
-
- bool performanceInitialized = false;
-
- PerformanceEntryAddresses performanceEntry = new PerformanceEntryAddresses();
-
- if (_performanceManager != null && _performanceManager.IsTargetNodeId(nodeId) && _performanceManager.GetNextEntry(out performanceEntry, dataSourceDetailType, PerformanceEntryType.Voice, nodeId))
- {
- performanceInitialized = true;
-
- GeneratePerformance(ref performanceEntry, PerformanceCommand.Type.Start, nodeId);
- }
-
- GenerateDataSource(ref voiceState, dspStateMemory, channelIndex);
-
- if (performanceInitialized)
- {
- GeneratePerformance(ref performanceEntry, PerformanceCommand.Type.End, nodeId);
- }
-
- if (voiceState.WasPlaying)
- {
- voiceState.PreviousVolume = 0.0f;
- }
- else if (voiceState.HasAnyDestination())
- {
- performanceInitialized = false;
-
- if (_performanceManager != null && _performanceManager.IsTargetNodeId(nodeId) && _performanceManager.GetNextEntry(out performanceEntry, PerformanceDetailType.BiquadFilter, PerformanceEntryType.Voice, nodeId))
- {
- performanceInitialized = true;
-
- GeneratePerformance(ref performanceEntry, PerformanceCommand.Type.Start, nodeId);
- }
-
- GenerateBiquadFilterForVoice(ref voiceState, dspStateMemory, (int)_rendererContext.MixBufferCount, channelIndex, nodeId);
-
- if (performanceInitialized)
- {
- GeneratePerformance(ref performanceEntry, PerformanceCommand.Type.End, nodeId);
- }
-
- performanceInitialized = false;
-
- if (_performanceManager != null && _performanceManager.IsTargetNodeId(nodeId) && _performanceManager.GetNextEntry(out performanceEntry, PerformanceDetailType.VolumeRamp, PerformanceEntryType.Voice, nodeId))
- {
- performanceInitialized = true;
-
- GeneratePerformance(ref performanceEntry, PerformanceCommand.Type.Start, nodeId);
- }
-
- _commandBuffer.GenerateVolumeRamp(voiceState.PreviousVolume,
- voiceState.Volume,
- _rendererContext.MixBufferCount + (uint)channelIndex,
- nodeId);
-
- if (performanceInitialized)
- {
- GeneratePerformance(ref performanceEntry, PerformanceCommand.Type.End, nodeId);
- }
-
- voiceState.PreviousVolume = voiceState.Volume;
-
- if (voiceState.MixId == RendererConstants.UnusedMixId)
- {
- if (voiceState.SplitterId != RendererConstants.UnusedSplitterId)
- {
- int destinationId = channelIndex;
-
- while (true)
- {
- Span<SplitterDestination> destinationSpan = _splitterContext.GetDestination((int)voiceState.SplitterId, destinationId);
-
- if (destinationSpan.IsEmpty)
- {
- break;
- }
-
- ref SplitterDestination destination = ref destinationSpan[0];
-
- destinationId += (int)channelsCount;
-
- if (destination.IsConfigured())
- {
- int mixId = destination.DestinationId;
-
- if (mixId < _mixContext.GetCount() && mixId != RendererConstants.UnusedSplitterIdInt)
- {
- ref MixState mix = ref _mixContext.GetState(mixId);
-
- GenerateVoiceMix(destination.MixBufferVolume,
- destination.PreviousMixBufferVolume,
- dspStateMemory,
- mix.BufferOffset,
- mix.BufferCount,
- _rendererContext.MixBufferCount + (uint)channelIndex,
- nodeId);
-
- destination.MarkAsNeedToUpdateInternalState();
- }
- }
- }
- }
- }
- else
- {
- ref MixState mix = ref _mixContext.GetState(voiceState.MixId);
-
- performanceInitialized = false;
-
- if (_performanceManager != null && _performanceManager.IsTargetNodeId(nodeId) && _performanceManager.GetNextEntry(out performanceEntry, PerformanceDetailType.Mix, PerformanceEntryType.Voice, nodeId))
- {
- performanceInitialized = true;
-
- GeneratePerformance(ref performanceEntry, PerformanceCommand.Type.Start, nodeId);
- }
-
- GenerateVoiceMix(channelResource.Mix.ToSpan(),
- channelResource.PreviousMix.ToSpan(),
- dspStateMemory,
- mix.BufferOffset,
- mix.BufferCount,
- _rendererContext.MixBufferCount + (uint)channelIndex,
- nodeId);
-
- if (performanceInitialized)
- {
- GeneratePerformance(ref performanceEntry, PerformanceCommand.Type.End, nodeId);
- }
-
- channelResource.UpdateState();
- }
-
- for (int i = 0; i < voiceState.BiquadFilterNeedInitialization.Length; i++)
- {
- voiceState.BiquadFilterNeedInitialization[i] = voiceState.BiquadFilters[i].Enable;
- }
- }
- }
- }
-
- public void GenerateVoices()
- {
- for (int i = 0; i < _voiceContext.GetCount(); i++)
- {
- ref VoiceState sortedState = ref _voiceContext.GetSortedState(i);
-
- if (!sortedState.ShouldSkip() && sortedState.UpdateForCommandGeneration(_voiceContext))
- {
- int nodeId = sortedState.NodeId;
-
- PerformanceEntryAddresses performanceEntry = new PerformanceEntryAddresses();
-
- bool performanceInitialized = false;
-
- if (_performanceManager != null && _performanceManager.GetNextEntry(out performanceEntry, PerformanceEntryType.Voice, nodeId))
- {
- performanceInitialized = true;
-
- GeneratePerformance(ref performanceEntry, PerformanceCommand.Type.Start, nodeId);
- }
-
- GenerateVoice(ref sortedState);
-
- if (performanceInitialized)
- {
- GeneratePerformance(ref performanceEntry, PerformanceCommand.Type.End, nodeId);
- }
- }
- }
-
- _splitterContext.UpdateInternalState();
- }
-
- public void GeneratePerformance(ref PerformanceEntryAddresses performanceEntryAddresses, PerformanceCommand.Type type, int nodeId)
- {
- _commandBuffer.GeneratePerformance(ref performanceEntryAddresses, type, nodeId);
- }
-
- private void GenerateBufferMixerEffect(int bufferOffset, BufferMixEffect effect, int nodeId)
- {
- Debug.Assert(effect.Type == EffectType.BufferMix);
-
- if (effect.IsEnabled)
- {
- for (int i = 0; i < effect.Parameter.MixesCount; i++)
- {
- if (effect.Parameter.Volumes[i] != 0.0f)
- {
- _commandBuffer.GenerateMix((uint)bufferOffset + effect.Parameter.Input[i],
- (uint)bufferOffset + effect.Parameter.Output[i],
- nodeId,
- effect.Parameter.Volumes[i]);
- }
- }
- }
- }
-
- private void GenerateAuxEffect(uint bufferOffset, AuxiliaryBufferEffect effect, int nodeId)
- {
- Debug.Assert(effect.Type == EffectType.AuxiliaryBuffer);
-
- if (effect.IsEnabled)
- {
- effect.GetWorkBuffer(0);
- effect.GetWorkBuffer(1);
- }
-
- if (effect.State.SendBufferInfoBase != 0 && effect.State.ReturnBufferInfoBase != 0)
- {
- int i = 0;
- uint writeOffset = 0;
- for (uint channelIndex = effect.Parameter.ChannelCount; channelIndex != 0; channelIndex--)
- {
- uint newUpdateCount = writeOffset + _commandBuffer.CommandList.SampleCount;
-
- uint updateCount;
-
- if ((channelIndex - 1) != 0)
- {
- updateCount = 0;
- }
- else
- {
- updateCount = newUpdateCount;
- }
-
- _commandBuffer.GenerateAuxEffect(bufferOffset,
- effect.Parameter.Input[i],
- effect.Parameter.Output[i],
- ref effect.State,
- effect.IsEnabled,
- effect.Parameter.BufferStorageSize,
- effect.State.SendBufferInfoBase,
- effect.State.ReturnBufferInfoBase,
- updateCount,
- writeOffset,
- nodeId);
-
- writeOffset = newUpdateCount;
-
- i++;
- }
- }
- }
-
- private void GenerateDelayEffect(uint bufferOffset, DelayEffect effect, int nodeId)
- {
- Debug.Assert(effect.Type == EffectType.Delay);
-
- ulong workBuffer = effect.GetWorkBuffer(-1);
-
- _commandBuffer.GenerateDelayEffect(bufferOffset, effect.Parameter, effect.State, effect.IsEnabled, workBuffer, nodeId);
- }
-
- private void GenerateReverbEffect(uint bufferOffset, ReverbEffect effect, int nodeId, bool isLongSizePreDelaySupported)
- {
- Debug.Assert(effect.Type == EffectType.Reverb);
-
- ulong workBuffer = effect.GetWorkBuffer(-1);
-
- _commandBuffer.GenerateReverbEffect(bufferOffset, effect.Parameter, effect.State, effect.IsEnabled, workBuffer, nodeId, isLongSizePreDelaySupported);
- }
-
- private void GenerateReverb3dEffect(uint bufferOffset, Reverb3dEffect effect, int nodeId)
- {
- Debug.Assert(effect.Type == EffectType.Reverb3d);
-
- ulong workBuffer = effect.GetWorkBuffer(-1);
-
- _commandBuffer.GenerateReverb3dEffect(bufferOffset, effect.Parameter, effect.State, effect.IsEnabled, workBuffer, nodeId);
- }
-
- private void GenerateBiquadFilterEffect(uint bufferOffset, BiquadFilterEffect effect, int nodeId)
- {
- Debug.Assert(effect.Type == EffectType.BiquadFilter);
-
- if (effect.IsEnabled)
- {
- bool needInitialization = effect.Parameter.Status == UsageState.Invalid ||
- (effect.Parameter.Status == UsageState.New && !_rendererContext.BehaviourContext.IsBiquadFilterEffectStateClearBugFixed());
-
- BiquadFilterParameter parameter = new BiquadFilterParameter();
-
- parameter.Enable = true;
- effect.Parameter.Denominator.ToSpan().CopyTo(parameter.Denominator.ToSpan());
- effect.Parameter.Numerator.ToSpan().CopyTo(parameter.Numerator.ToSpan());
-
- for (int i = 0; i < effect.Parameter.ChannelCount; i++)
- {
- _commandBuffer.GenerateBiquadFilter((int)bufferOffset, ref parameter, effect.State.Slice(i, 1),
- effect.Parameter.Input[i],
- effect.Parameter.Output[i],
- needInitialization,
- nodeId);
- }
- }
- else
- {
- for (int i = 0; i < effect.Parameter.ChannelCount; i++)
- {
- uint inputBufferIndex = bufferOffset + effect.Parameter.Input[i];
- uint outputBufferIndex = bufferOffset + effect.Parameter.Output[i];
-
- // If the input and output isn't the same, generate a command.
- if (inputBufferIndex != outputBufferIndex)
- {
- _commandBuffer.GenerateCopyMixBuffer(inputBufferIndex, outputBufferIndex, nodeId);
- }
- }
- }
- }
-
- private void GenerateEffect(ref MixState mix, BaseEffect effect)
- {
- int nodeId = mix.NodeId;
-
- bool isFinalMix = mix.MixId == RendererConstants.FinalMixId;
-
- PerformanceEntryAddresses performanceEntry = new PerformanceEntryAddresses();
-
- bool performanceInitialized = false;
-
- if (_performanceManager != null && _performanceManager.GetNextEntry(out performanceEntry, effect.GetPerformanceDetailType(),
- isFinalMix ? PerformanceEntryType.FinalMix : PerformanceEntryType.SubMix, nodeId))
- {
- performanceInitialized = true;
-
- GeneratePerformance(ref performanceEntry, PerformanceCommand.Type.Start, nodeId);
- }
-
- switch (effect.Type)
- {
- case EffectType.BufferMix:
- GenerateBufferMixerEffect((int)mix.BufferOffset, (BufferMixEffect)effect, nodeId);
- break;
- case EffectType.AuxiliaryBuffer:
- GenerateAuxEffect(mix.BufferOffset, (AuxiliaryBufferEffect)effect, nodeId);
- break;
- case EffectType.Delay:
- GenerateDelayEffect(mix.BufferOffset, (DelayEffect)effect, nodeId);
- break;
- case EffectType.Reverb:
- GenerateReverbEffect(mix.BufferOffset, (ReverbEffect)effect, nodeId, mix.IsLongSizePreDelaySupported);
- break;
- case EffectType.Reverb3d:
- GenerateReverb3dEffect(mix.BufferOffset, (Reverb3dEffect)effect, nodeId);
- break;
- case EffectType.BiquadFilter:
- GenerateBiquadFilterEffect(mix.BufferOffset, (BiquadFilterEffect)effect, nodeId);
- break;
- default:
- throw new NotImplementedException($"Unsupported effect type {effect.Type}");
- }
-
- if (performanceInitialized)
- {
- GeneratePerformance(ref performanceEntry, PerformanceCommand.Type.End, nodeId);
- }
-
- effect.UpdateForCommandGeneration();
- }
-
- private void GenerateEffects(ref MixState mix)
- {
- ReadOnlySpan<int> effectProcessingOrderArray = mix.EffectProcessingOrderArray;
-
- Debug.Assert(_effectContext.GetCount() == 0 || !effectProcessingOrderArray.IsEmpty);
-
- for (int i = 0; i < _effectContext.GetCount(); i++)
- {
- int effectOrder = effectProcessingOrderArray[i];
-
- if (effectOrder == RendererConstants.InvalidProcessingOrder)
- {
- break;
- }
-
- // BaseEffect is a class, we don't need to pass it by ref
- BaseEffect effect = _effectContext.GetEffect(effectOrder);
-
- Debug.Assert(effect.Type != EffectType.Invalid);
- Debug.Assert(effect.MixId == mix.MixId);
-
- if (!effect.ShouldSkip())
- {
- GenerateEffect(ref mix, effect);
- }
- }
- }
-
- private void GenerateMix(ref MixState mix)
- {
- if (mix.HasAnyDestination())
- {
- Debug.Assert(mix.DestinationMixId != RendererConstants.UnusedMixId || mix.DestinationSplitterId != RendererConstants.UnusedSplitterId);
-
- if (mix.DestinationMixId == RendererConstants.UnusedMixId)
- {
- if (mix.DestinationSplitterId != RendererConstants.UnusedSplitterId)
- {
- int destinationId = 0;
-
- while (true)
- {
- int destinationIndex = destinationId++;
-
- Span<SplitterDestination> destinationSpan = _splitterContext.GetDestination((int)mix.DestinationSplitterId, destinationIndex);
-
- if (destinationSpan.IsEmpty)
- {
- break;
- }
-
- ref SplitterDestination destination = ref destinationSpan[0];
-
- if (destination.IsConfigured())
- {
- int mixId = destination.DestinationId;
-
- if (mixId < _mixContext.GetCount() && mixId != RendererConstants.UnusedSplitterIdInt)
- {
- ref MixState destinationMix = ref _mixContext.GetState(mixId);
-
- uint inputBufferIndex = mix.BufferOffset + ((uint)destinationIndex % mix.BufferCount);
-
- for (uint bufferDestinationIndex = 0; bufferDestinationIndex < destinationMix.BufferCount; bufferDestinationIndex++)
- {
- float volume = mix.Volume * destination.GetMixVolume((int)bufferDestinationIndex);
-
- if (volume != 0.0f)
- {
- _commandBuffer.GenerateMix(inputBufferIndex,
- destinationMix.BufferOffset + bufferDestinationIndex,
- mix.NodeId,
- volume);
- }
- }
- }
- }
- }
- }
- }
- else
- {
- ref MixState destinationMix = ref _mixContext.GetState(mix.DestinationMixId);
-
- for (uint bufferIndex = 0; bufferIndex < mix.BufferCount; bufferIndex++)
- {
- for (uint bufferDestinationIndex = 0; bufferDestinationIndex < destinationMix.BufferCount; bufferDestinationIndex++)
- {
- float volume = mix.Volume * mix.GetMixBufferVolume((int)bufferIndex, (int)bufferDestinationIndex);
-
- if (volume != 0.0f)
- {
- _commandBuffer.GenerateMix(mix.BufferOffset + bufferIndex,
- destinationMix.BufferOffset + bufferDestinationIndex,
- mix.NodeId,
- volume);
- }
- }
- }
- }
- }
- }
-
- private void GenerateSubMix(ref MixState subMix)
- {
- _commandBuffer.GenerateDepopForMixBuffersCommand(_rendererContext.DepopBuffer,
- subMix.BufferOffset,
- subMix.BufferCount,
- subMix.NodeId,
- subMix.SampleRate);
-
- GenerateEffects(ref subMix);
-
- PerformanceEntryAddresses performanceEntry = new PerformanceEntryAddresses();
-
- int nodeId = subMix.NodeId;
-
- bool performanceInitialized = false;
-
- if (_performanceManager != null && _performanceManager.IsTargetNodeId(nodeId) && _performanceManager.GetNextEntry(out performanceEntry, PerformanceDetailType.Mix, PerformanceEntryType.SubMix, nodeId))
- {
- performanceInitialized = true;
-
- GeneratePerformance(ref performanceEntry, PerformanceCommand.Type.Start, nodeId);
- }
-
- GenerateMix(ref subMix);
-
- if (performanceInitialized)
- {
- GeneratePerformance(ref performanceEntry, PerformanceCommand.Type.End, nodeId);
- }
- }
-
- public void GenerateSubMixes()
- {
- for (int id = 0; id < _mixContext.GetCount(); id++)
- {
- ref MixState sortedState = ref _mixContext.GetSortedState(id);
-
- if (sortedState.IsUsed && sortedState.MixId != RendererConstants.FinalMixId)
- {
- int nodeId = sortedState.NodeId;
-
- PerformanceEntryAddresses performanceEntry = new PerformanceEntryAddresses();
-
- bool performanceInitialized = false;
-
- if (_performanceManager != null && _performanceManager.GetNextEntry(out performanceEntry, PerformanceEntryType.SubMix, nodeId))
- {
- performanceInitialized = true;
-
- GeneratePerformance(ref performanceEntry, PerformanceCommand.Type.Start, nodeId);
- }
-
- GenerateSubMix(ref sortedState);
-
- if (performanceInitialized)
- {
- GeneratePerformance(ref performanceEntry, PerformanceCommand.Type.End, nodeId);
- }
- }
- }
- }
-
- private void GenerateFinalMix()
- {
- ref MixState finalMix = ref _mixContext.GetFinalState();
-
- _commandBuffer.GenerateDepopForMixBuffersCommand(_rendererContext.DepopBuffer,
- finalMix.BufferOffset,
- finalMix.BufferCount,
- finalMix.NodeId,
- finalMix.SampleRate);
-
- GenerateEffects(ref finalMix);
-
- PerformanceEntryAddresses performanceEntry = new PerformanceEntryAddresses();
-
- int nodeId = finalMix.NodeId;
-
- bool performanceInitialized = false;
-
- if (_performanceManager != null && _performanceManager.IsTargetNodeId(nodeId) && _performanceManager.GetNextEntry(out performanceEntry, PerformanceDetailType.Mix, PerformanceEntryType.FinalMix, nodeId))
- {
- performanceInitialized = true;
-
- GeneratePerformance(ref performanceEntry, PerformanceCommand.Type.Start, nodeId);
- }
-
- // Only generate volume command if the volume isn't 100%.
- if (finalMix.Volume != 1.0f)
- {
- for (uint bufferIndex = 0; bufferIndex < finalMix.BufferCount; bufferIndex++)
- {
- bool performanceSubInitialized = false;
-
- if (_performanceManager != null && _performanceManager.IsTargetNodeId(nodeId) && _performanceManager.GetNextEntry(out performanceEntry, PerformanceDetailType.VolumeRamp, PerformanceEntryType.FinalMix, nodeId))
- {
- performanceSubInitialized = true;
-
- GeneratePerformance(ref performanceEntry, PerformanceCommand.Type.Start, nodeId);
- }
-
- _commandBuffer.GenerateVolume(finalMix.Volume,
- finalMix.BufferOffset + bufferIndex,
- nodeId);
-
- if (performanceSubInitialized)
- {
- GeneratePerformance(ref performanceEntry, PerformanceCommand.Type.End, nodeId);
- }
- }
- }
-
- if (performanceInitialized)
- {
- GeneratePerformance(ref performanceEntry, PerformanceCommand.Type.End, nodeId);
- }
- }
-
- public void GenerateFinalMixes()
- {
- int nodeId = _mixContext.GetFinalState().NodeId;
-
- PerformanceEntryAddresses performanceEntry = new PerformanceEntryAddresses();
-
- bool performanceInitialized = false;
-
- if (_performanceManager != null && _performanceManager.GetNextEntry(out performanceEntry, PerformanceEntryType.FinalMix, nodeId))
- {
- performanceInitialized = true;
-
- GeneratePerformance(ref performanceEntry, PerformanceCommand.Type.Start, nodeId);
- }
-
- GenerateFinalMix();
-
- if (performanceInitialized)
- {
- GeneratePerformance(ref performanceEntry, PerformanceCommand.Type.End, nodeId);
- }
- }
-
- private void GenerateCircularBuffer(CircularBufferSink sink, ref MixState finalMix)
- {
- _commandBuffer.GenerateCircularBuffer(finalMix.BufferOffset, sink, RendererConstants.InvalidNodeId);
- }
-
- private void GenerateDevice(DeviceSink sink, ref MixState finalMix)
- {
- if (_commandBuffer.CommandList.SampleRate != 48000 && sink.UpsamplerState == null)
- {
- sink.UpsamplerState = _rendererContext.UpsamplerManager.Allocate();
- }
-
- bool useCustomDownMixingCommand = _rendererContext.ChannelCount == 2 && sink.Parameter.DownMixParameterEnabled;
-
- if (useCustomDownMixingCommand)
- {
- _commandBuffer.GenerateDownMixSurroundToStereo(finalMix.BufferOffset,
- sink.Parameter.Input.ToSpan(),
- sink.Parameter.Input.ToSpan(),
- sink.DownMixCoefficients,
- RendererConstants.InvalidNodeId);
- }
- // NOTE: we do the downmixing at the DSP level as right now the renderer interface doesn't use audout.
- // TODO: Remove this when audout is rewritten.
- else if (_rendererContext.ChannelCount == 2 && sink.Parameter.InputCount == 6)
- {
- _commandBuffer.GenerateDownMixSurroundToStereo(finalMix.BufferOffset,
- sink.Parameter.Input.ToSpan(),
- sink.Parameter.Input.ToSpan(),
- RendererConstants.DefaultSurroundToStereoCoefficients,
- RendererConstants.InvalidNodeId);
- }
-
- CommandList commandList = _commandBuffer.CommandList;
-
- if (sink.UpsamplerState != null)
- {
- _commandBuffer.GenerateUpsample(finalMix.BufferOffset,
- sink.UpsamplerState,
- sink.Parameter.InputCount,
- sink.Parameter.Input.ToSpan(),
- commandList.BufferCount,
- commandList.SampleCount,
- commandList.SampleRate,
- RendererConstants.InvalidNodeId);
- }
-
- _commandBuffer.GenerateDeviceSink(finalMix.BufferOffset,
- sink,
- _rendererContext.SessionId,
- commandList.Buffers,
- RendererConstants.InvalidNodeId);
- }
-
- private void GenerateSink(BaseSink sink, ref MixState finalMix)
- {
- bool performanceInitialized = false;
-
- PerformanceEntryAddresses performanceEntry = new PerformanceEntryAddresses();
-
- if (_performanceManager != null && _performanceManager.GetNextEntry(out performanceEntry, PerformanceEntryType.Sink, sink.NodeId))
- {
- performanceInitialized = true;
-
- GeneratePerformance(ref performanceEntry, PerformanceCommand.Type.Start, sink.NodeId);
- }
-
- if (!sink.ShouldSkip)
- {
- switch (sink.Type)
- {
- case SinkType.CircularBuffer:
- GenerateCircularBuffer((CircularBufferSink)sink, ref finalMix);
- break;
- case SinkType.Device:
- GenerateDevice((DeviceSink)sink, ref finalMix);
- break;
- default:
- throw new NotImplementedException($"Unsupported sink type {sink.Type}");
- }
-
- sink.UpdateForCommandGeneration();
- }
-
- if (performanceInitialized)
- {
- GeneratePerformance(ref performanceEntry, PerformanceCommand.Type.End, sink.NodeId);
- }
- }
-
- public void GenerateSinks()
- {
- ref MixState finalMix = ref _mixContext.GetFinalState();
-
- for (int i = 0; i < _sinkContext.GetCount(); i++)
- {
- // BaseSink is a class, we don't need to pass it by ref
- BaseSink sink = _sinkContext.GetSink(i);
-
- if (sink.IsUsed)
- {
- GenerateSink(sink, ref finalMix);
- }
- }
- }
- }
-}