1 /*
2 * Copyright (C) 2024 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 #define LOG_TAG "TestServer"
18
19 #include <android-base/stringprintf.h>
20 #include <binder/IInterface.h>
21 #include <binder/IPCThreadState.h>
22 #include <binder/IServiceManager.h>
23 #include <binder/ProcessState.h>
24 #include <binder/Status.h>
25 #include <gui/BufferQueue.h>
26 #include <gui/IConsumerListener.h>
27 #include <gui/IGraphicBufferConsumer.h>
28 #include <gui/IGraphicBufferProducer.h>
29 #include <gui/view/Surface.h>
30 #include <libgui_test_server/BnTestServer.h>
31 #include <log/log.h>
32 #include <utils/Errors.h>
33
34 #include <cstdint>
35 #include <cstdlib>
36 #include <memory>
37 #include <mutex>
38 #include <vector>
39
40 #include <fcntl.h>
41 #include <unistd.h>
42
43 #include "TestServer.h"
44
45 namespace android {
46
47 namespace {
48 class TestConsumerListener : public BnConsumerListener {
onFrameAvailable(const BufferItem &)49 virtual void onFrameAvailable(const BufferItem&) override {}
onBuffersReleased()50 virtual void onBuffersReleased() override {}
onSidebandStreamChanged()51 virtual void onSidebandStreamChanged() override {}
52 };
53
54 class TestServiceImpl : public libgui_test_server::BnTestServer {
55 public:
TestServiceImpl(const char * name)56 TestServiceImpl(const char* name) : mName(name) {}
57
createProducer(view::Surface * out)58 virtual binder::Status createProducer(view::Surface* out) override {
59 std::lock_guard<std::mutex> lock(mMutex);
60
61 BufferQueueHolder bq;
62 BufferQueue::createBufferQueue(&bq.producer, &bq.consumer);
63 sp<TestConsumerListener> listener = sp<TestConsumerListener>::make();
64 bq.consumer->consumerConnect(listener, /*controlledByApp*/ true);
65
66 uint64_t id = 0;
67 bq.producer->getUniqueId(&id);
68 std::string name = base::StringPrintf("%s-%" PRIu64, mName, id);
69
70 out->name = String16(name.c_str());
71 out->graphicBufferProducer = bq.producer;
72 mBqs.push_back(std::move(bq));
73
74 return binder::Status::ok();
75 }
76
killNow()77 virtual binder::Status killNow() override {
78 ALOGE("LibGUI Test Service %s dying in response to killNow", mName);
79 _exit(0);
80 // Not reached:
81 return binder::Status::ok();
82 }
83
84 private:
85 std::mutex mMutex;
86 const char* mName;
87
88 struct BufferQueueHolder {
89 sp<IGraphicBufferProducer> producer;
90 sp<IGraphicBufferConsumer> consumer;
91 };
92
93 std::vector<BufferQueueHolder> mBqs;
94 };
95 } // namespace
96
TestServerMain(const char * name)97 int TestServerMain(const char* name) {
98 ProcessState::self()->startThreadPool();
99
100 sp<TestServiceImpl> testService = sp<TestServiceImpl>::make(name);
101 ALOGE("service");
102 sp<IServiceManager> serviceManager(defaultServiceManager());
103 LOG_ALWAYS_FATAL_IF(OK != serviceManager->addService(String16(name), testService));
104
105 ALOGD("LibGUI Test Service %s STARTED", name);
106
107 IPCThreadState::self()->joinThreadPool();
108
109 ALOGW("LibGUI Test Service %s DIED", name);
110
111 return 0;
112 }
113
114 } // namespace android