package/mpp
1
0
Fork 0
mirror of https://github.com/nyanmisaka/mpp.git synced 2025-10-05 17:16:50 +08:00
Code Issues Actions Packages Projects Releases Wiki Activity
Files
94b4f98b455da024e0dd260c511154dd653aa5bb
mpp/test/mpp_buffer_test.c
ChenHengming 94b4f98b45 [test]: add buffer pointer verification to mpp_buffer_test 
git-svn-id: https://10.10.10.66:8443/svn/MediaProcessPlatform/trunk/mpp@1018 6e48237b-75ef-9749-8fc9-41990f28c85a
2016-07-14 09:15:11 +00:00

287 lines
8.4 KiB
C
Raw Blame History

/*
* Copyright 2015 Rockchip Electronics 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.
*/
#define MODULE_TAG "mpp_buffer_test"
#include <string.h>
#if defined(_WIN32)
#include "vld.h"
#endif
#include "mpp_log.h"
#include "mpp_env.h"
#include "mpp_buffer.h"
#include "mpp_allocator.h"
#define MPP_BUFFER_TEST_DEBUG_FLAG (0xf)
#define MPP_BUFFER_TEST_SIZE (SZ_1K*4)
#define MPP_BUFFER_TEST_COMMIT_COUNT 10
#define MPP_BUFFER_TEST_NORMAL_COUNT 10
int main()
{
MPP_RET ret = MPP_OK;
MppAllocator allocator = NULL;
MppAllocatorApi *api = NULL;
MppBufferInfo commit;
MppBufferGroup group = NULL;
MppBuffer commit_buffer[MPP_BUFFER_TEST_COMMIT_COUNT];
void *commit_ptr[MPP_BUFFER_TEST_COMMIT_COUNT];
MppBuffer normal_buffer[MPP_BUFFER_TEST_NORMAL_COUNT];
MppBuffer legacy_buffer = NULL;
size_t size = MPP_BUFFER_TEST_SIZE;
RK_S32 count = MPP_BUFFER_TEST_COMMIT_COUNT;
RK_S32 i;
RK_U32 debug = 0;
mpp_env_set_u32("mpp_buffer_debug", MPP_BUFFER_TEST_DEBUG_FLAG);
mpp_env_get_u32("mpp_buffer_debug", &debug, 0);
mpp_log("mpp_buffer_test start with debug 0x%x\n", debug);
memset(commit_ptr, 0, sizeof(commit_ptr));
memset(commit_buffer, 0, sizeof(commit_buffer));
memset(normal_buffer, 0, sizeof(normal_buffer));
ret = mpp_buffer_group_get_external(&group, MPP_BUFFER_TYPE_NORMAL);
if (MPP_OK != ret) {
mpp_err("mpp_buffer_test mpp_buffer_group_get failed\n");
goto MPP_BUFFER_failed;
}
mpp_log("mpp_buffer_test commit mode with unused status start\n");
commit.type = MPP_BUFFER_TYPE_NORMAL;
commit.size = size;
for (i = 0; i < count; i++) {
commit_ptr[i] = malloc(size);
if (NULL == commit_ptr[i]) {
mpp_err("mpp_buffer_test malloc failed\n");
goto MPP_BUFFER_failed;
}
commit.ptr = commit_ptr[i];
ret = mpp_buffer_commit(group, &commit);
if (MPP_OK != ret) {
mpp_err("mpp_buffer_test mpp_buffer_commit failed\n");
goto MPP_BUFFER_failed;
}
}
for (i = 0; i < count; i++) {
ret = mpp_buffer_get(group, &commit_buffer[i], size);
if (MPP_OK != ret) {
mpp_err("mpp_buffer_test mpp_buffer_get commit mode failed\n");
goto MPP_BUFFER_failed;
}
}
for (i = 0; i < count; i++) {
if (commit_buffer[i]) {
ret = mpp_buffer_put(commit_buffer[i]);
if (MPP_OK != ret) {
mpp_err("mpp_buffer_test mpp_buffer_put commit mode failed\n");
goto MPP_BUFFER_failed;
}
commit_buffer[i] = NULL;
}
}
for (i = 0; i < count; i++) {
if (commit_ptr[i]) {
free(commit_ptr[i]);
commit_ptr[i] = NULL;
}
}
mpp_buffer_group_put(group);
mpp_log("mpp_buffer_test commit mode with unused status success\n");
mpp_log("mpp_buffer_test commit mode with used status start\n");
ret = mpp_allocator_get(&allocator, &api, MPP_BUFFER_TYPE_ION);
if (MPP_OK != ret) {
mpp_err("mpp_buffer_test mpp_allocator_get ion failed\n");
goto MPP_BUFFER_failed;
}
commit.type = MPP_BUFFER_TYPE_ION;
commit.size = size;
for (i = 0; i < count; i++) {
ret = api->alloc(allocator, &commit);
if (ret) {
mpp_err("mpp_buffer_test mpp_allocator_alloc failed\n");
goto MPP_BUFFER_failed;
}
mpp_log("allocator get ptr %p with fd %d\n", commit.ptr, commit.fd);
/*
* NOTE: commit buffer info will be directly return within new MppBuffer
* This mode allow input group is NULL
*/
ret = mpp_buffer_import(&commit_buffer[i], &commit);
if (MPP_OK != ret) {
mpp_err("mpp_buffer_test mpp_buffer_commit failed\n");
goto MPP_BUFFER_failed;
}
/*
* test imported buffer
*/
{
void *ptr = mpp_buffer_get_ptr(commit_buffer[i]);
if (NULL == ptr) {
mpp_err("mpp_buffer_test mpp_buffer_get_ptr failed\n");
goto MPP_BUFFER_failed;
}
mpp_log("get ptr %p from fd %d\n", ptr, mpp_buffer_get_fd(commit_buffer[i]));
memset(ptr, 0, mpp_buffer_get_size(commit_buffer[i]));
}
}
for (i = 0; i < count; i++) {
if (commit_buffer[i]) {
ret = mpp_buffer_info_get(commit_buffer[i], &commit);
if (MPP_OK != ret) {
mpp_err("mpp_buffer_test mpp_buffer_info_get failed\n");
goto MPP_BUFFER_failed;
}
ret = mpp_buffer_put(commit_buffer[i]);
if (MPP_OK != ret) {
mpp_err("mpp_buffer_test mpp_buffer_put commit mode failed\n");
goto MPP_BUFFER_failed;
}
commit_buffer[i] = NULL;
/* NOTE: buffer info from allocator need to be free directly */
ret = api->free(allocator, &commit);
if (MPP_OK != ret) {
mpp_err("mpp_buffer_test api->free failed\n");
goto MPP_BUFFER_failed;
}
}
}
ret = mpp_allocator_put(&allocator);
if (MPP_OK != ret) {
mpp_err("mpp_buffer_test mpp_allocator_put failed\n");
goto MPP_BUFFER_failed;
}
mpp_log("mpp_buffer_test commit mode with used status success\n");
mpp_log("mpp_buffer_test normal mode start\n");
ret = mpp_buffer_group_get_internal(&group, MPP_BUFFER_TYPE_ION);
if (MPP_OK != ret) {
mpp_err("mpp_buffer_test mpp_buffer_group_get failed\n");
goto MPP_BUFFER_failed;
}
count = MPP_BUFFER_TEST_NORMAL_COUNT;
mpp_buffer_group_limit_config(group, 0, count);
for (i = 0; i < count; i++) {
ret = mpp_buffer_get(group, &normal_buffer[i], (i + 1) * SZ_1K);
if (MPP_OK != ret) {
mpp_err("mpp_buffer_test mpp_buffer_get mode normal failed\n");
goto MPP_BUFFER_failed;
}
}
for (i = 0; i < count; i++) {
if (normal_buffer[i]) {
ret = mpp_buffer_put(normal_buffer[i]);
if (MPP_OK != ret) {
mpp_err("mpp_buffer_test mpp_buffer_get mode normal failed\n");
goto MPP_BUFFER_failed;
}
normal_buffer[i] = NULL;
}
}
mpp_log("mpp_buffer_test normal mode success\n");
if (group) {
mpp_buffer_group_put(group);
group = NULL;
}
mpp_log("mpp_buffer_test success\n");
ret = mpp_buffer_get(NULL, &legacy_buffer, MPP_BUFFER_TEST_SIZE);
if (MPP_OK != ret) {
mpp_log("mpp_buffer_test mpp_buffer_get legacy buffer failed\n");
goto MPP_BUFFER_failed;
}
ret = mpp_buffer_put(legacy_buffer);
if (MPP_OK != ret) {
mpp_log("mpp_buffer_test mpp_buffer_put legacy buffer failed\n");
goto MPP_BUFFER_failed;
}
return ret;
MPP_BUFFER_failed:
for (i = 0; i < MPP_BUFFER_TEST_COMMIT_COUNT; i++) {
if (commit_buffer[i])
mpp_buffer_put(commit_buffer[i]);
}
for (i = 0; i < MPP_BUFFER_TEST_COMMIT_COUNT; i++) {
if (commit_ptr[i]) {
free(commit_ptr[i]);
commit_ptr[i] = NULL;
}
}
for (i = 0; i < MPP_BUFFER_TEST_NORMAL_COUNT; i++) {
if (normal_buffer[i])
mpp_buffer_put(normal_buffer[i]);
}
if (group) {
mpp_buffer_group_put(group);
group = NULL;
}
if (legacy_buffer) {
mpp_buffer_put(legacy_buffer);
legacy_buffer = NULL;
}
if (allocator) {
mpp_allocator_put(&allocator);
}
mpp_assert(NULL == allocator);
mpp_log("mpp_buffer_test failed\n");
return ret;
}
Reference in New Issue View Git Blame Copy Permalink