mirror of
https://gitee.com/openharmony/graphic_graphic_2d
synced 2025-01-26 13:17:49 +00:00
remove remote buffer client producer
Change-Id: I316f42bf972033159f9c7c9fd44dbc0ac9ea69ae Signed-off-by: luwh0708 <1632083718@qq.com>
This commit is contained in:
luwh0708
parent
8b1daa2a09
commit
17ebb1969b
@ -17,7 +17,6 @@ group("test") {
|
||||
testonly = true
|
||||
|
||||
deps = [
|
||||
"buffer_client_producer:test",
|
||||
"buffer_queue_producer:test",
|
||||
]
|
||||
}
|
||||
|
||||
@ -1,36 +0,0 @@
|
||||
# Copyright (c) 2021 Huawei Device Co., Ltd.
|
||||
# Licensed under the Apache License, Version 2.0 (the "License");
|
||||
# you may not use this file except in compliance with the License.
|
||||
# You may obtain a copy of the License at
|
||||
#
|
||||
# http://www.apache.org/licenses/LICENSE-2.0
|
||||
#
|
||||
# Unless required by applicable law or agreed to in writing, software
|
||||
# distributed under the License is distributed on an "AS IS" BASIS,
|
||||
# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
|
||||
# See the License for the specific language governing permissions and
|
||||
# limitations under the License.
|
||||
|
||||
import("//build/test.gni")
|
||||
|
||||
## UnitTest surface_remote_buffer_client_producer_test {{{
|
||||
ohos_unittest("surface_remote_buffer_client_producer_test") {
|
||||
module_out_path = "graphic_standard/surface"
|
||||
|
||||
sources = [ "remote_buffer_client_producer_test.cpp" ]
|
||||
|
||||
deps = [ "//foundation/graphic/standard/frameworks/surface/test/unittest:surface_test_common" ]
|
||||
|
||||
external_deps = [
|
||||
"ipc:ipc_core",
|
||||
"samgr_L2:samgr_proxy",
|
||||
]
|
||||
}
|
||||
|
||||
## UnitTest surface_remote_buffer_client_producer_test }}}
|
||||
|
||||
group("test") {
|
||||
testonly = true
|
||||
|
||||
deps = [ ":surface_remote_buffer_client_producer_test" ]
|
||||
}
|
||||
@ -1,261 +0,0 @@
|
||||
/*
|
||||
* Copyright (c) 2021 Huawei Device Co., Ltd.
|
||||
* Licensed under the Apache License, Version 2.0 (the "License");
|
||||
* you may not use this file except in compliance with the License.
|
||||
* You may obtain a copy of the License at
|
||||
*
|
||||
* http://www.apache.org/licenses/LICENSE-2.0
|
||||
*
|
||||
* Unless required by applicable law or agreed to in writing, software
|
||||
* distributed under the License is distributed on an "AS IS" BASIS,
|
||||
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
|
||||
* See the License for the specific language governing permissions and
|
||||
* limitations under the License.
|
||||
*/
|
||||
|
||||
#include "remote_buffer_client_producer_test.h"
|
||||
|
||||
#include <vector>
|
||||
|
||||
#include <display_type.h>
|
||||
#include <gtest/gtest.h>
|
||||
#include <iservice_registry.h>
|
||||
#include <surface_type.h>
|
||||
#include <sys/wait.h>
|
||||
#include <unistd.h>
|
||||
|
||||
#include "buffer_client_producer.h"
|
||||
#include "buffer_queue.h"
|
||||
#include "buffer_queue_producer.h"
|
||||
#include "environments.h"
|
||||
|
||||
using namespace OHOS;
|
||||
|
||||
namespace {
|
||||
BufferRequestConfig g_requestConfig = {
|
||||
.width = 1920,
|
||||
.height = 1080,
|
||||
.strideAlignment = 8,
|
||||
.format = PIXEL_FMT_RGBA_8888,
|
||||
.usage = HBM_USE_CPU_READ | HBM_USE_CPU_WRITE | HBM_USE_MEM_DMA,
|
||||
.timeout = 0,
|
||||
};
|
||||
BufferFlushConfig g_flushConfig = {
|
||||
.damage = {
|
||||
.x = 0,
|
||||
.y = 0,
|
||||
.w = 1920,
|
||||
.h = 1080
|
||||
},
|
||||
.timestamp = 0
|
||||
};
|
||||
sptr<IRemoteObject> robj;
|
||||
sptr<IBufferProducer> bp;
|
||||
std::vector<int32_t> deletingBuffers;
|
||||
pid_t pid;
|
||||
int pipeFd[2];
|
||||
|
||||
class BufferConsumerListener: public IBufferConsumerListener {
|
||||
public:
|
||||
BufferConsumerListener()
|
||||
{
|
||||
}
|
||||
|
||||
~BufferConsumerListener()
|
||||
{
|
||||
}
|
||||
|
||||
void OnBufferAvailable()
|
||||
{
|
||||
}
|
||||
};
|
||||
|
||||
class RemoteBufferClientProducerTest : public testing::Test {
|
||||
public:
|
||||
static void SetUpTestCase(void)
|
||||
{
|
||||
pipe(pipeFd);
|
||||
|
||||
pid = fork();
|
||||
if (pid < 0) {
|
||||
exit(1);
|
||||
}
|
||||
|
||||
if (pid == 0) {
|
||||
sptr<BufferQueue> bq = new BufferQueue();
|
||||
ASSERT_NE(bq, nullptr);
|
||||
|
||||
sptr<BufferQueueProducer> bqp = new BufferQueueProducer(bq);
|
||||
ASSERT_NE(bqp, nullptr);
|
||||
|
||||
bq->Init();
|
||||
sptr<IBufferConsumerListener> listener = new BufferConsumerListener();
|
||||
bq->RegisterConsumerListener(listener);
|
||||
|
||||
auto sm = SystemAbilityManagerClient::GetInstance().GetSystemAbilityManager();
|
||||
sm->AddSystemAbility(IPC_QUEUE_SAID, bqp);
|
||||
|
||||
char buf[10] = "start";
|
||||
write(pipeFd[1], buf, sizeof(buf));
|
||||
|
||||
sleep(0);
|
||||
|
||||
read(pipeFd[0], buf, sizeof(buf));
|
||||
|
||||
sm->RemoveSystemAbility(IPC_QUEUE_SAID);
|
||||
|
||||
exit(0);
|
||||
}
|
||||
|
||||
char buf[10];
|
||||
read(pipeFd[0], buf, sizeof(buf));
|
||||
|
||||
auto sm = SystemAbilityManagerClient::GetInstance().GetSystemAbilityManager();
|
||||
robj = sm->GetSystemAbility(IPC_QUEUE_SAID);
|
||||
bp = iface_cast<IBufferProducer>(robj);
|
||||
}
|
||||
static void TearDownTestCase(void)
|
||||
{
|
||||
bp = nullptr;
|
||||
robj = nullptr;
|
||||
|
||||
char buf[10] = "over";
|
||||
write(pipeFd[1], buf, sizeof(buf));
|
||||
|
||||
waitpid(pid, nullptr, 0);
|
||||
}
|
||||
};
|
||||
|
||||
HWTEST_F(RemoteBufferClientProducerTest, IsProxy, testing::ext::TestSize.Level0)
|
||||
{
|
||||
ASSERT_TRUE(robj->IsProxyObject());
|
||||
}
|
||||
|
||||
HWTEST_F(RemoteBufferClientProducerTest, QueueSize, testing::ext::TestSize.Level0)
|
||||
{
|
||||
ASSERT_EQ(bp->GetQueueSize(), (uint32_t)SURFACE_DEFAULT_QUEUE_SIZE);
|
||||
|
||||
SurfaceError ret = bp->SetQueueSize(2);
|
||||
ASSERT_EQ(ret, SURFACE_ERROR_OK);
|
||||
|
||||
ret = bp->SetQueueSize(SURFACE_MAX_QUEUE_SIZE + 1);
|
||||
ASSERT_NE(ret, SURFACE_ERROR_OK);
|
||||
|
||||
ASSERT_EQ(bp->GetQueueSize(), 2u);
|
||||
}
|
||||
|
||||
HWTEST_F(RemoteBufferClientProducerTest, ReqCan, testing::ext::TestSize.Level0)
|
||||
{
|
||||
sptr<SurfaceBuffer> buffer;
|
||||
int32_t releaseFence;
|
||||
int32_t sequence;
|
||||
|
||||
SurfaceError ret = bp->RequestBuffer(sequence, buffer, releaseFence, g_requestConfig, deletingBuffers);
|
||||
ASSERT_EQ(ret, SURFACE_ERROR_OK);
|
||||
ASSERT_NE(buffer, nullptr);
|
||||
|
||||
ret = bp->CancelBuffer(sequence);
|
||||
ASSERT_EQ(ret, SURFACE_ERROR_OK);
|
||||
}
|
||||
|
||||
HWTEST_F(RemoteBufferClientProducerTest, ReqCanCan, testing::ext::TestSize.Level0)
|
||||
{
|
||||
sptr<SurfaceBuffer> buffer;
|
||||
int32_t releaseFence;
|
||||
int32_t sequence;
|
||||
|
||||
SurfaceError ret = bp->RequestBuffer(sequence, buffer, releaseFence, g_requestConfig, deletingBuffers);
|
||||
ASSERT_EQ(ret, SURFACE_ERROR_OK);
|
||||
ASSERT_EQ(buffer, nullptr);
|
||||
|
||||
ret = bp->CancelBuffer(sequence);
|
||||
ASSERT_EQ(ret, SURFACE_ERROR_OK);
|
||||
|
||||
ret = bp->CancelBuffer(sequence);
|
||||
ASSERT_NE(ret, SURFACE_ERROR_OK);
|
||||
}
|
||||
|
||||
HWTEST_F(RemoteBufferClientProducerTest, ReqReqReqCanCan, testing::ext::TestSize.Level0)
|
||||
{
|
||||
sptr<SurfaceBuffer> buffer1;
|
||||
sptr<SurfaceBuffer> buffer2;
|
||||
sptr<SurfaceBuffer> buffer3;
|
||||
int32_t releaseFence;
|
||||
int32_t sequence1;
|
||||
int32_t sequence2;
|
||||
int32_t sequence3;
|
||||
SurfaceError ret;
|
||||
|
||||
ret = bp->RequestBuffer(sequence1, buffer1, releaseFence, g_requestConfig, deletingBuffers);
|
||||
ASSERT_EQ(ret, SURFACE_ERROR_OK);
|
||||
ASSERT_EQ(buffer1, nullptr);
|
||||
|
||||
ret = bp->RequestBuffer(sequence2, buffer2, releaseFence, g_requestConfig, deletingBuffers);
|
||||
ASSERT_EQ(ret, SURFACE_ERROR_OK);
|
||||
ASSERT_NE(buffer2, nullptr);
|
||||
|
||||
ret = bp->RequestBuffer(sequence3, buffer3, releaseFence, g_requestConfig, deletingBuffers);
|
||||
ASSERT_NE(ret, SURFACE_ERROR_OK);
|
||||
ASSERT_EQ(buffer3, nullptr);
|
||||
|
||||
ret = bp->CancelBuffer(sequence1);
|
||||
ASSERT_EQ(ret, SURFACE_ERROR_OK);
|
||||
|
||||
ret = bp->CancelBuffer(sequence2);
|
||||
ASSERT_EQ(ret, SURFACE_ERROR_OK);
|
||||
|
||||
ret = bp->CancelBuffer(sequence3);
|
||||
ASSERT_NE(ret, SURFACE_ERROR_OK);
|
||||
}
|
||||
|
||||
HWTEST_F(RemoteBufferClientProducerTest, SetQueueSizeDeleting, testing::ext::TestSize.Level0)
|
||||
{
|
||||
sptr<SurfaceBuffer> buffer;
|
||||
int32_t releaseFence;
|
||||
int32_t sequence;
|
||||
|
||||
sptr<BufferClientProducer> bcp = static_cast<BufferClientProducer*>(bp.GetRefPtr());
|
||||
|
||||
SurfaceError ret = bp->SetQueueSize(1);
|
||||
ASSERT_EQ(ret, SURFACE_ERROR_OK);
|
||||
|
||||
ret = bp->RequestBuffer(sequence, buffer, releaseFence, g_requestConfig, deletingBuffers);
|
||||
ASSERT_EQ(ret, SURFACE_ERROR_OK);
|
||||
ASSERT_EQ(buffer, nullptr);
|
||||
|
||||
ret = bp->CancelBuffer(sequence);
|
||||
ASSERT_EQ(ret, SURFACE_ERROR_OK);
|
||||
|
||||
ret = bp->SetQueueSize(2);
|
||||
ASSERT_EQ(ret, SURFACE_ERROR_OK);
|
||||
}
|
||||
|
||||
HWTEST_F(RemoteBufferClientProducerTest, ReqFlu, testing::ext::TestSize.Level0)
|
||||
{
|
||||
sptr<SurfaceBuffer> buffer;
|
||||
int32_t releaseFence;
|
||||
int32_t sequence;
|
||||
|
||||
SurfaceError ret = bp->RequestBuffer(sequence, buffer, releaseFence, g_requestConfig, deletingBuffers);
|
||||
ASSERT_EQ(ret, SURFACE_ERROR_OK);
|
||||
|
||||
ret = bp->FlushBuffer(sequence, -1, g_flushConfig);
|
||||
ASSERT_EQ(ret, SURFACE_ERROR_OK);
|
||||
}
|
||||
|
||||
HWTEST_F(RemoteBufferClientProducerTest, ReqFluFlu, testing::ext::TestSize.Level0)
|
||||
{
|
||||
sptr<SurfaceBuffer> buffer;
|
||||
int32_t releaseFence;
|
||||
int32_t sequence;
|
||||
|
||||
SurfaceError ret = bp->RequestBuffer(sequence, buffer, releaseFence, g_requestConfig, deletingBuffers);
|
||||
ASSERT_EQ(ret, SURFACE_ERROR_OK);
|
||||
|
||||
ret = bp->FlushBuffer(sequence, -1, g_flushConfig);
|
||||
ASSERT_EQ(ret, SURFACE_ERROR_OK);
|
||||
|
||||
ret = bp->FlushBuffer(sequence, -1, g_flushConfig);
|
||||
ASSERT_NE(ret, SURFACE_ERROR_OK);
|
||||
}
|
||||
}
|
||||
@ -1,19 +0,0 @@
|
||||
/*
|
||||
* Copyright (c) 2021 Huawei Device Co., Ltd.
|
||||
* Licensed under the Apache License, Version 2.0 (the "License");
|
||||
* you may not use this file except in compliance with the License.
|
||||
* You may obtain a copy of the License at
|
||||
*
|
||||
* http://www.apache.org/licenses/LICENSE-2.0
|
||||
*
|
||||
* Unless required by applicable law or agreed to in writing, software
|
||||
* distributed under the License is distributed on an "AS IS" BASIS,
|
||||
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
|
||||
* See the License for the specific language governing permissions and
|
||||
* limitations under the License.
|
||||
*/
|
||||
|
||||
#ifndef FRAMEWORKS_SURFACE_TEST_UNITTEST_REMOTE_BUFFER_CLIENT_PRODUCER_REMOTE_BUFFER_CLIENT_PRODUCER_TEST_H
|
||||
#define FRAMEWORKS_SURFACE_TEST_UNITTEST_REMOTE_BUFFER_CLIENT_PRODUCER_REMOTE_BUFFER_CLIENT_PRODUCER_TEST_H
|
||||
|
||||
#endif // FRAMEWORKS_SURFACE_TEST_UNITTEST_REMOTE_BUFFER_CLIENT_PRODUCER_REMOTE_BUFFER_CLIENT_PRODUCER_TEST_H
|
||||
Loading…
x
Reference in New Issue
Block a user