diff options
Diffstat (limited to 'tests/test-vk-handler.cpp')
| -rw-r--r-- | tests/test-vk-handler.cpp | 340 |
1 files changed, 340 insertions, 0 deletions
diff --git a/tests/test-vk-handler.cpp b/tests/test-vk-handler.cpp new file mode 100644 index 0000000..30941fc --- /dev/null +++ b/tests/test-vk-handler.cpp @@ -0,0 +1,340 @@ +/* + * test_vk_handler.cpp - test vulkan handler + * + * Copyright (c) 2018 Intel Corporation + * + * 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. + * + * Author: Wind Yuan <feng.yuan@intel.com> + */ + +#include "test_common.h" +#include "test_stream.h" + +#include <vulkan/vk_device.h> +#include <vulkan/vk_copy_handler.h> +#include <vulkan/vk_geomap_handler.h> +#include <interface/blender.h> + +using namespace XCam; + +enum VKType { + VKTypeNone = 0, + VKTypeCopy, + VKTypeRemap, + VKTypeBlender +}; + +class VKStream + : public Stream +{ +public: + explicit VKStream (const char *file_name = NULL, uint32_t width = 0, uint32_t height = 0); + virtual ~VKStream () {} + + void set_vk_device (SmartPtr<VKDevice> &device) { + XCAM_ASSERT (device.ptr ()); + _device = device; + } + + virtual XCamReturn create_buf_pool (const VideoBufferInfo &info, uint32_t count); + +private: + SmartPtr<VKDevice> _device; +}; + +typedef std::vector<SmartPtr<VKStream>> VKStreams; + +VKStream::VKStream (const char *file_name, uint32_t width, uint32_t height) + : Stream (file_name, width, height) +{ +} + +XCamReturn +VKStream::create_buf_pool (const VideoBufferInfo &info, uint32_t count) +{ + XCAM_FAIL_RETURN ( + ERROR, _device.ptr(), XCAM_RETURN_ERROR_PARAM, + "vulkan device id NULL, please set device first"); + + SmartPtr<BufferPool> pool = create_vk_buffer_pool (_device); + XCAM_ASSERT (pool.ptr ()); + + if (!pool->set_video_info (info)) { + XCAM_LOG_ERROR ("set video info failed"); + return XCAM_RETURN_ERROR_UNKNOWN; + } + + if (!pool->reserve (count)) { + XCAM_LOG_ERROR ("create buffer pool failed"); + return XCAM_RETURN_ERROR_MEM; + } + + set_buf_pool (pool); + return XCAM_RETURN_NO_ERROR; +} + +static void +calc_hor_flip_table (uint32_t width, uint32_t height, PointFloat2 *&map_table) +{ + XCAM_ASSERT (map_table); + + float lut_size[2] = {8, 8}; + for (uint32_t i = 0; i < height; ++i) { + PointFloat2 *line = &map_table[i * width]; + for (uint32_t j = 0; j < width; j++) { + line[j].x = (width - j) * lut_size[0]; + line[j].y = i * lut_size[1]; + } + } +} + +static void +print_help (const char *arg0) +{ + printf ("Usage:\n" + "%s --type TYPE --input0 input.nv12 --input1 input1.nv12 --output output.nv12 ...\n" + "\t--type processing type, selected from: copy, remap, blend\n" + "\t--input0 input image(NV12)\n" + "\t--input1 input image(NV12)\n" + "\t--output output image(NV12/MP4)\n" + "\t--in-w optional, input width, default: 1280\n" + "\t--in-h optional, input height, default: 800\n" + "\t--out-w optional, output width, default: 1280\n" + "\t--out-h optional, output height, default: 800\n" + "\t--save optional, save file or not, select from [true/false], default: true\n" + "\t--loop optional, how many loops need to run, default: 1\n" + "\t--help usage\n", + arg0); + + printf ("Note:\n" + "Spirv path Setup Env: $" XCAM_VK_SHADER_PATH "\n" + "Generate spirv kernel:\n" + "glslangValidator -V -x -o sample.comp.spv sample.comp.sl\n" + ); +} + +int main (int argc, char **argv) +{ + uint32_t input_width = 1280; + uint32_t input_height = 800; + uint32_t output_width = 1280; + uint32_t output_height = 800; + + VKStreams ins; + VKStreams outs; + VKType type = VKTypeNone; + + int loop = 1; + bool save_output = true; + + const struct option long_opts[] = { + {"type", required_argument, NULL, 't'}, + {"input0", required_argument, NULL, 'i'}, + {"input1", required_argument, NULL, 'j'}, + {"output", required_argument, NULL, 'o'}, + {"in-w", required_argument, NULL, 'w'}, + {"in-h", required_argument, NULL, 'h'}, + {"out-w", required_argument, NULL, 'W'}, + {"out-h", required_argument, NULL, 'H'}, + {"save", required_argument, NULL, 's'}, + {"loop", required_argument, NULL, 'l'}, + {"help", no_argument, NULL, 'e'}, + {NULL, 0, NULL, 0}, + }; + + int opt = -1; + while ((opt = getopt_long (argc, argv, "", long_opts, NULL)) != -1) { + switch (opt) { + case 't': + XCAM_ASSERT (optarg); + if (!strcasecmp (optarg, "copy")) + type = VKTypeCopy; + else if (!strcasecmp (optarg, "remap")) + type = VKTypeRemap; + else if (!strcasecmp (optarg, "blend")) + type = VKTypeBlender; + else { + XCAM_LOG_ERROR ("unknown type:%s", optarg); + print_help (argv[0]); + return -1; + } + break; + case 'i': + XCAM_ASSERT (optarg); + PUSH_STREAM (VKStream, ins, optarg); + break; + case 'j': + XCAM_ASSERT (optarg); + PUSH_STREAM (VKStream, ins, optarg); + break; + case 'o': + XCAM_ASSERT (optarg); + PUSH_STREAM (VKStream, outs, optarg); + break; + case 'w': + input_width = atoi(optarg); + break; + case 'h': + input_height = atoi(optarg); + break; + case 'W': + output_width = atoi(optarg); + break; + case 'H': + output_height = atoi(optarg); + break; + case 's': + save_output = (strcasecmp (optarg, "false") == 0 ? false : true); + break; + case 'l': + loop = atoi(optarg); + break; + case 'e': + print_help (argv[0]); + return 0; + default: + XCAM_LOG_ERROR ("getopt_long return unknown value:%c", opt); + print_help (argv[0]); + return -1; + } + } + + if (optind < argc || argc < 2) { + XCAM_LOG_ERROR ("unknown option %s", argv[optind]); + print_help (argv[0]); + return -1; + } + + if (ins.empty () || outs.empty ()) { + XCAM_LOG_ERROR ("input or output stream is empty"); + print_help (argv[0]); + return -1; + } + + for (uint32_t i = 0; i < ins.size (); ++i) { + printf ("input%d file:\t\t%s\n", i, ins[i]->get_file_name ()); + } + printf ("output file:\t\t%s\n", outs[0]->get_file_name ()); + printf ("input width:\t\t%d\n", input_width); + printf ("input height:\t\t%d\n", input_height); + printf ("output width:\t\t%d\n", output_width); + printf ("output height:\t\t%d\n", output_height); + printf ("save output:\t\t%s\n", save_output ? "true" : "false"); + printf ("loop count:\t\t%d\n", loop); + + SmartPtr<VKDevice> vk_device = VKDevice::default_device (); + XCAM_FAIL_RETURN ( + ERROR, vk_device.ptr(), -1, + "Get default VKDevice failed, please check vulkan environment"); + + VideoBufferInfo in_info; + in_info.init (V4L2_PIX_FMT_NV12, input_width, input_height); + for (uint32_t i = 0; i < ins.size (); ++i) { + ins[i]->set_buf_size (input_width, input_height); + ins[i]->set_vk_device (vk_device); + CHECK (ins[i]->create_buf_pool (in_info, 4), "create buffer pool failed"); + CHECK (ins[i]->open_reader ("rb"), "open input file(%s) failed", ins[i]->get_file_name ()); + } + + VideoBufferInfo out_info; + out_info.init (V4L2_PIX_FMT_NV12, output_width, output_height); + outs[0]->set_buf_size (output_width, output_height); + if (save_output) { + CHECK (outs[0]->estimate_file_format (), "%s: estimate file format failed", outs[0]->get_file_name ()); + CHECK (outs[0]->open_writer ("wb"), "open output file(%s) failed", outs[0]->get_file_name ()); + } + + switch (type) { + case VKTypeCopy: { + SmartPtr<VKCopyHandler> copyer = new VKCopyHandler (vk_device, "vk-copy"); + XCAM_ASSERT (copyer.ptr ()); + + Rect in_area = Rect (0, 0, input_width, input_height); + Rect out_area = Rect (0, 0, output_width, output_height); + XCAM_ASSERT (in_area.width == out_area.width && in_area.height == out_area.height); + copyer->set_copy_area (0, in_area, out_area); + copyer->set_out_video_info (out_info); + + CHECK (ins[0]->read_buf(), "read buffer from file(%s) failed", ins[0]->get_file_name ()); + for (int i = 0; i < loop; ++i) { + CHECK (copyer->copy (ins[0]->get_buf (), outs[0]->get_buf ()), "copy buffer failed"); + if (save_output) + outs[0]->write_buf (); + FPS_CALCULATION (vk-copy, XCAM_OBJ_DUR_FRAME_NUM); + } + break; + } + case VKTypeRemap: { + SmartPtr<VKGeoMapHandler> mapper = new VKGeoMapHandler (vk_device, "vk-remap"); + XCAM_ASSERT (mapper.ptr ()); + mapper->set_output_size (output_width, output_height); + + uint32_t lut_width = XCAM_ALIGN_UP (output_width, 8) / 8; + uint32_t lut_height = XCAM_ALIGN_UP (output_height, 8) / 8; + PointFloat2 *map_table = new PointFloat2[lut_width * lut_height]; + calc_hor_flip_table (lut_width, lut_height, map_table); + mapper->set_lookup_table (map_table, lut_width, lut_height); + delete [] map_table; + + CHECK (ins[0]->read_buf(), "read buffer from file(%s) failed", ins[0]->get_file_name ()); + for (int i = 0; i < loop; ++i) { + CHECK (mapper->remap (ins[0]->get_buf (), outs[0]->get_buf ()), "remap buffer failed"); + if (save_output) + outs[0]->write_buf (); + FPS_CALCULATION (vk-remap, XCAM_OBJ_DUR_FRAME_NUM); + } + break; + } + case VKTypeBlender: { + CHECK_EXP (ins.size () == 2, "Error: blender needs 2 input files."); + SmartPtr<Blender> blender = Blender::create_vk_blender (vk_device); + XCAM_ASSERT (blender.ptr ()); + blender->set_output_size (output_width, output_height); + + Rect area; + area.pos_x = 0; + area.pos_y = 0; + area.width = output_width; + area.height = output_height; + blender->set_merge_window (area); + area.pos_x = 0; + area.pos_y = 0; + area.width = input_width; + area.height = input_height; + blender->set_input_merge_area (area, 0); + area.pos_x = 0; + area.pos_y = 0; + area.width = input_width; + area.height = input_height; + blender->set_input_merge_area (area, 1); + + CHECK (ins[0]->read_buf(), "read buffer from file(%s) failed.", ins[0]->get_file_name ()); + CHECK (ins[1]->read_buf(), "read buffer from file(%s) failed.", ins[1]->get_file_name ()); + for (int i = 0; i < loop; ++i) { + CHECK (blender->blend (ins[0]->get_buf (), ins[1]->get_buf (), outs[0]->get_buf ()), "blend buffer failed"); + if (save_output) + outs[0]->write_buf (); + FPS_CALCULATION (vk-blend, XCAM_OBJ_DUR_FRAME_NUM); + } + break; + } + default: { + XCAM_LOG_ERROR ("unsupported type:%d", type); + print_help (argv[0]); + return -1; + } + } + + return 0; +} |