summaryrefslogtreecommitdiffstats
path: root/src/video_core/fence_manager.h
blob: 036f3996c31e3c6570c17a96695a5e46758fec04 (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
100
101
// Copyright 2020 yuzu Emulator Project
// Licensed under GPLv2 or any later version
// Refer to the license.txt file included.

#pragma once

#include <algorithm>
#include <array>
#include <queue>
#include <memory>

#include "common/assert.h"
#include "common/common_types.h"
#include "core/core.h"
#include "core/memory.h"
#include "core/settings.h"
#include "video_core/gpu.h"
#include "video_core/memory_manager.h"
#include "video_core/rasterizer_interface.h"

namespace VideoCommon {

class FenceBase {
public:
    FenceBase(GPUVAddr address, u32 payload) : address{address}, payload{payload} {}

    constexpr GPUVAddr GetAddress() const {
        return address;
    }

    constexpr u32 GetPayload() const {
        return payload;
    }

private:
    GPUVAddr address;
    u32 payload;
};

template <typename TFence, typename TTextureCache>
class FenceManager {
public:
    void SignalFence(GPUVAddr addr, u32 value) {
        TryReleasePendingFences();
        TFence new_fence = CreateFence(addr, value);
        QueueFence(new_fence);
        fences.push(new_fence);
        texture_cache.CommitAsyncFlushes();
        rasterizer.FlushCommands();
        rasterizer.SyncGuestHost();
    }

    void WaitPendingFences() {
        while (!fences.empty()) {
            TFence& current_fence = fences.front();
            bool should_wait = texture_cache.ShouldWaitAsyncFlushes();
            if (should_wait) {
                WaitFence(current_fence);
            }
            texture_cache.PopAsyncFlushes();
            auto& gpu{system.GPU()};
            auto& memory_manager{gpu.MemoryManager()};
            memory_manager.Write<u32>(current_fence->GetAddress(), current_fence->GetPayload());
            fences.pop();
        }
    }

protected:
    FenceManager(Core::System& system, VideoCore::RasterizerInterface& rasterizer,
                 TTextureCache& texture_cache)
        : system{system}, rasterizer{rasterizer}, texture_cache{texture_cache} {}

    virtual TFence CreateFence(GPUVAddr addr, u32 value) = 0;
    virtual void QueueFence(TFence& fence) = 0;
    virtual bool IsFenceSignaled(TFence& fence) = 0;
    virtual void WaitFence(TFence& fence) = 0;

    Core::System& system;
    VideoCore::RasterizerInterface& rasterizer;
    TTextureCache& texture_cache;

private:
    void TryReleasePendingFences() {
        while (!fences.empty()) {
            TFence& current_fence = fences.front();
            bool should_wait = texture_cache.ShouldWaitAsyncFlushes();
            if (should_wait && !IsFenceSignaled(current_fence)) {
                return;
            }
            texture_cache.PopAsyncFlushes();
            auto& gpu{system.GPU()};
            auto& memory_manager{gpu.MemoryManager()};
            memory_manager.Write<u32>(current_fence->GetAddress(), current_fence->GetPayload());
            fences.pop();
        }
    }

    std::queue<TFence> fences;
};

} // namespace VideoCommon