using Ryujinx.Common.Memory; using Ryujinx.Graphics.GAL.Multithreading.Commands.Texture; using Ryujinx.Graphics.GAL.Multithreading.Model; namespace Ryujinx.Graphics.GAL.Multithreading.Resources { /// /// Threaded representation of a texture. /// class ThreadedTexture : ITexture { private readonly ThreadedRenderer _renderer; private readonly TextureCreateInfo _info; public ITexture Base; public int Width => _info.Width; public int Height => _info.Height; public float ScaleFactor { get; } public ThreadedTexture(ThreadedRenderer renderer, TextureCreateInfo info, float scale) { _renderer = renderer; _info = info; ScaleFactor = scale; } private TableRef Ref(T reference) { return new TableRef(_renderer, reference); } public void CopyTo(ITexture destination, int firstLayer, int firstLevel) { _renderer.New().Set(Ref(this), Ref((ThreadedTexture)destination), firstLayer, firstLevel); _renderer.QueueCommand(); } public void CopyTo(ITexture destination, int srcLayer, int dstLayer, int srcLevel, int dstLevel) { _renderer.New().Set(Ref(this), Ref((ThreadedTexture)destination), srcLayer, dstLayer, srcLevel, dstLevel); _renderer.QueueCommand(); } public void CopyTo(ITexture destination, Extents2D srcRegion, Extents2D dstRegion, bool linearFilter) { ThreadedTexture dest = (ThreadedTexture)destination; if (_renderer.IsGpuThread()) { _renderer.New().Set(Ref(this), Ref(dest), srcRegion, dstRegion, linearFilter); _renderer.QueueCommand(); } else { // Scaled copy can happen on another thread for a res scale flush. ThreadedHelpers.SpinUntilNonNull(ref Base); ThreadedHelpers.SpinUntilNonNull(ref dest.Base); Base.CopyTo(dest.Base, srcRegion, dstRegion, linearFilter); } } public ITexture CreateView(TextureCreateInfo info, int firstLayer, int firstLevel) { ThreadedTexture newTex = new(_renderer, info, ScaleFactor); _renderer.New().Set(Ref(this), Ref(newTex), info, firstLayer, firstLevel); _renderer.QueueCommand(); return newTex; } public PinnedSpan GetData() { if (_renderer.IsGpuThread()) { ResultBox> box = new(); _renderer.New().Set(Ref(this), Ref(box)); _renderer.InvokeCommand(); return box.Result; } else { ThreadedHelpers.SpinUntilNonNull(ref Base); return Base.GetData(); } } public PinnedSpan GetData(int layer, int level) { if (_renderer.IsGpuThread()) { ResultBox> box = new(); _renderer.New().Set(Ref(this), Ref(box), layer, level); _renderer.InvokeCommand(); return box.Result; } else { ThreadedHelpers.SpinUntilNonNull(ref Base); return Base.GetData(layer, level); } } public void CopyTo(BufferRange range, int layer, int level, int stride) { _renderer.New().Set(Ref(this), range, layer, level, stride); _renderer.QueueCommand(); } public void SetData(SpanOrArray data) { _renderer.New().Set(Ref(this), Ref(data.ToArray())); _renderer.QueueCommand(); } public void SetData(SpanOrArray data, int layer, int level) { _renderer.New().Set(Ref(this), Ref(data.ToArray()), layer, level); _renderer.QueueCommand(); } public void SetData(SpanOrArray data, int layer, int level, Rectangle region) { _renderer.New().Set(Ref(this), Ref(data.ToArray()), layer, level, region); _renderer.QueueCommand(); } public void SetStorage(BufferRange buffer) { _renderer.New().Set(Ref(this), buffer); _renderer.QueueCommand(); } public void Release() { _renderer.New().Set(Ref(this)); _renderer.QueueCommand(); } } }