aboutsummaryrefslogtreecommitdiff
path: root/src/strategies/low_latency2/queue_strategy.hh
blob: a090e1bda668bb96d37569e933d07f780fa348b9 (plain)
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
#ifndef STRATEGIES_LOW_LATENCY2_QUEUE_STRATEGY_HH_
#define STRATEGIES_LOW_LATENCY2_QUEUE_STRATEGY_HH_

#include "strategies/queue_strategy.hh"
#include "submission.hh"

#include <atomic>
#include <deque>
#include <memory>
#include <mutex>
#include <unordered_map>

namespace low_latency {

class QueueContext;

class LowLatency2QueueStrategy final : public QueueStrategy {
  public:
    static constexpr auto MAX_TRACKED_OBJECTS = 50;

    // Mapping of present_id's to submissions. Grabbed later by the device
    // strategy when we present and actually can associate them to some
    // vkSwapchainKHR.
    std::mutex mutex{};
    std::unordered_map<std::uint64_t, std::deque<std::unique_ptr<Submission>>>
        present_id_submissions{};
    std::deque<std::uint64_t> present_id_ring{};
    std::atomic<bool> is_out_of_band{}; // atomic so we don't need a lock check

  public:
    LowLatency2QueueStrategy(QueueContext& queue);
    virtual ~LowLatency2QueueStrategy();

  public:
    virtual void notify_submit(const VkSubmitInfo& submit,
                               std::unique_ptr<Submission> submission) override;
    virtual void notify_submit(const VkSubmitInfo2& submit,
                               std::unique_ptr<Submission> submission) override;
    virtual void notify_present(const VkPresentInfoKHR& present) override;

  public:
    void notify_out_of_band();
};

} // namespace low_latency

#endif