aboutsummaryrefslogtreecommitdiff
path: root/src/Ryujinx.Graphics.Host1x/SyncptIncrManager.cs
blob: a5ee1198c218e446be91a4c88821e889b4f26d3e (plain) (blame)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
using Ryujinx.Graphics.Device;
using System.Collections.Generic;

namespace Ryujinx.Graphics.Host1x
{
    class SyncptIncrManager
    {
        private readonly ISynchronizationManager _syncMgr;

        private readonly struct SyncptIncr
        {
            public uint Id { get; }
            public ClassId ClassId { get; }
            public uint SyncptId { get; }
            public bool Done { get; }

            public SyncptIncr(uint id, ClassId classId, uint syncptId, bool done = false)
            {
                Id = id;
                ClassId = classId;
                SyncptId = syncptId;
                Done = done;
            }
        }

        private readonly List<SyncptIncr> _incrs = new();

        private uint _currentId;

        public SyncptIncrManager(ISynchronizationManager syncMgr)
        {
            _syncMgr = syncMgr;
        }

        public void Increment(uint id)
        {
            lock (_incrs)
            {
                _incrs.Add(new SyncptIncr(0, 0, id, true));

                IncrementAllDone();
            }
        }

        public uint IncrementWhenDone(ClassId classId, uint id)
        {
            lock (_incrs)
            {
                uint handle = _currentId++;

                _incrs.Add(new SyncptIncr(handle, classId, id));

                return handle;
            }
        }

        public void SignalDone(uint handle)
        {
            lock (_incrs)
            {
                // Set pending increment with the given handle to "done".
                for (int i = 0; i < _incrs.Count; i++)
                {
                    SyncptIncr incr = _incrs[i];

                    if (_incrs[i].Id == handle)
                    {
                        _incrs[i] = new SyncptIncr(incr.Id, incr.ClassId, incr.SyncptId, true);

                        break;
                    }
                }

                IncrementAllDone();
            }
        }

        private void IncrementAllDone()
        {
            lock (_incrs)
            {
                // Increment all sequential pending increments that are already done.
                int doneCount = 0;

                for (; doneCount < _incrs.Count; doneCount++)
                {
                    if (!_incrs[doneCount].Done)
                    {
                        break;
                    }

                    _syncMgr.IncrementSyncpoint(_incrs[doneCount].SyncptId);
                }

                _incrs.RemoveRange(0, doneCount);
            }
        }
    }
}