blob: b5ba554c4f172abece207ac54c9fcd67b905fd92 [file] [log] [blame]
Alec Mouri16a99402019-07-29 16:37:30 -07001/*
2 * Copyright 2019 The Android Open Source Project
3 *
4 * Licensed under the Apache License, Version 2.0 (the "License");
5 * you may not use this file except in compliance with the License.
6 * You may obtain a copy of the License at
7 *
8 * http://www.apache.org/licenses/LICENSE-2.0
9 *
10 * Unless required by applicable law or agreed to in writing, software
11 * distributed under the License is distributed on an "AS IS" BASIS,
12 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
13 * See the License for the specific language governing permissions and
14 * limitations under the License.
15 */
16
17#pragma once
18
19#include <condition_variable>
20#include <mutex>
21#include <queue>
22#include <thread>
23
24#include <ui/GraphicBuffer.h>
25
26namespace android {
27namespace renderengine {
28namespace gl {
29
30class GLESRenderEngine;
31
32class ImageManager {
33public:
34 struct Barrier {
35 std::mutex mutex;
36 std::condition_variable_any condition;
37 bool isOpen GUARDED_BY(mutex) = false;
38 status_t result GUARDED_BY(mutex) = NO_ERROR;
39 };
40 ImageManager(GLESRenderEngine* engine);
41 ~ImageManager();
42 void cacheAsync(const sp<GraphicBuffer>& buffer, const std::shared_ptr<Barrier>& barrier)
43 EXCLUDES(mMutex);
44 status_t cache(const sp<GraphicBuffer>& buffer);
45 void releaseAsync(uint64_t bufferId, const std::shared_ptr<Barrier>& barrier) EXCLUDES(mMutex);
46
47private:
48 struct QueueEntry {
49 enum class Operation { Delete, Insert };
50
51 Operation op = Operation::Delete;
52 sp<GraphicBuffer> buffer = nullptr;
53 uint64_t bufferId = 0;
54 std::shared_ptr<Barrier> barrier = nullptr;
55 };
56
57 void queueOperation(const QueueEntry&& entry);
58 void threadMain();
59 GLESRenderEngine* const mEngine;
60 std::thread mThread = std::thread([this]() { threadMain(); });
61 std::condition_variable_any mCondition;
62 std::mutex mMutex;
63 std::queue<QueueEntry> mQueue GUARDED_BY(mMutex);
64
65 bool mRunning GUARDED_BY(mMutex) = true;
66};
67
68} // namespace gl
69} // namespace renderengine
70} // namespace android