2025-05-08 18:01:52 +08:00

801 lines
15 KiB
C
Executable File

// Copyright 2020-2021 Beken
//
// 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 <os/os.h>
#include <os/str.h>
#include <os/mem.h>
#include <components/log.h>
#include <common/bk_include.h>
#include <driver/int.h>
#include <driver/dvp_camera_types.h>
#include <components/video_transfer.h>
#include <driver/lcd.h>
#include "media_core.h"
#include "media_evt.h"
#include "media_app.h"
#include "transfer_act.h"
#include "camera_act.h"
#include "lcd_act.h"
#include "lcd_blend.h"
#include "storage_act.h"
#define TAG "media_app"
#define LOGI(...) BK_LOGW(TAG, ##__VA_ARGS__)
#define LOGW(...) BK_LOGW(TAG, ##__VA_ARGS__)
#define LOGE(...) BK_LOGE(TAG, ##__VA_ARGS__)
#define LOGD(...) BK_LOGD(TAG, ##__VA_ARGS__)
static beken_thread_t media_app_th_hd = NULL;
static beken_queue_t media_app_msg_queue = NULL;
media_debug_t *media_debug = NULL;
media_debug_t *media_debug_cached = NULL;
#if CONFIG_WIFI_ENABLE
extern void rwnxl_set_video_transfer_flag(uint32_t video_transfer_flag);
#else
#define rwnxl_set_video_transfer_flag(...)
#endif
bk_err_t media_send_msg_sync(uint32_t event, uint32_t param)
{
int ret = kGeneralErr;
param_pak_t *param_pak = (param_pak_t *) os_malloc(sizeof(param_pak_t));
media_msg_t msg;
if (param_pak == NULL)
{
LOGE("%s malloc param_pak_t failed\n", __func__);
goto out;
}
ret = rtos_init_semaphore_ex(&param_pak->sem, 1, 0);
if (ret != kNoErr)
{
LOGE("%s init semaphore failed\n", __func__);
goto out;
}
param_pak->param = param;
msg.event = event;
msg.param = (uint32_t)param_pak;
media_send_msg(&msg);
if (event != EVENT_LCD_DEFAULT_CMD)
ret = rtos_get_semaphore(&param_pak->sem, BEKEN_WAIT_FOREVER);
else
ret = rtos_get_semaphore(&param_pak->sem, 4000);
if (ret != kNoErr)
{
LOGE("%s wait semaphore failed\n", __func__);
goto out;
}
ret = param_pak->ret;
out:
if (param_pak)
{
if (param_pak->sem)
{
rtos_deinit_semaphore(&param_pak->sem);
param_pak->sem = NULL;
}
os_free(param_pak);
param_pak = NULL;
}
return ret;
}
bk_err_t media_app_camera_open(media_camera_device_t *device)
{
int ret = BK_FAIL;
if (CAMERA_STATE_DISABLED != get_camera_state())
{
LOGI("%s already opened\n", __func__);
return BK_OK;
}
switch (device->type)
{
case DVP_CAMERA:
ret = media_send_msg_sync(EVENT_CAM_DVP_OPEN_IND, (uint32_t)device);
break;
case UVC_CAMERA:
ret = media_send_msg_sync(EVENT_CAM_UVC_OPEN_IND, (uint32_t)device);
break;
case NET_CAMERA:
ret = media_send_msg_sync(EVENT_CAM_NET_OPEN_IND, (uint32_t)device);
break;
default:
break;
}
LOGI("%s complete\n", __func__);
return ret;
}
bk_err_t media_app_camera_close(camera_type_t type)
{
int ret = BK_FAIL;
if (CAMERA_STATE_ENABLED != get_camera_state())
{
LOGI("%s already closed\n", __func__);
return BK_OK;
}
switch (type)
{
case DVP_CAMERA:
ret = media_send_msg_sync(EVENT_CAM_DVP_CLOSE_IND, 0);
break;
case UVC_CAMERA:
ret = media_send_msg_sync(EVENT_CAM_UVC_CLOSE_IND, 0);
break;
case NET_CAMERA:
ret = media_send_msg_sync(EVENT_CAM_NET_CLOSE_IND, 0);
break;
default:
break;
}
LOGI("%s complete\n", __func__);
return ret;
}
bk_err_t media_app_mailbox_test(void)
{
bk_err_t ret = BK_FAIL;
uint32_t param = 0x88888888;
LOGI("%s +++\n", __func__);
ret = media_send_msg_sync(EVENT_LCD_DEFAULT_CMD, param);
LOGI("%s ---\n", __func__);
return ret;
}
bk_err_t media_app_register_read_frame_callback(pixel_format_t fmt, frame_cb_t cb)
{
bk_err_t ret = BK_OK;
#if (CONFIG_WIFI_TRANSFER)
ret = media_send_msg_sync(EVENT_TRANSFER_OPEN_IND, (uint32_t)cb);
#endif
LOGI("%s complete, %d\n", __func__, ret);
return ret;
}
bk_err_t media_app_transfer_pause(bool pause)
{
int ret = kNoErr;
#if (CONFIG_WIFI_TRANSFER)
ret = media_send_msg_sync(EVENT_TRANSFER_PAUSE_IND, pause);
#endif
return ret;
}
bk_err_t media_app_unregister_read_frame_callback(void)
{
bk_err_t ret = BK_OK;
LOGI("%s\n", __func__);
#if (CONFIG_WIFI_TRANSFER)
if (TRS_STATE_ENABLED != get_transfer_state())
{
LOGI("%s already closed\n", __func__);
return kNoErr;
}
ret = media_send_msg_sync(EVENT_TRANSFER_CLOSE_IND, 0);
#endif
LOGI("%s complete\n", __func__);
return ret;
}
bk_err_t media_app_rtsp_open(video_config_t *config)
{
int ret = BK_FAIL;
if (CAMERA_STATE_DISABLED != get_camera_state())
{
LOGI("%s already opened\n", __func__);
return BK_OK;
}
ret = media_send_msg_sync(EVENT_CAM_RTSP_OPEN_IND, (uint32_t)config);
LOGI("%s complete\n", __func__);
return ret;
}
bk_err_t media_app_rtsp_close()
{
int ret = BK_FAIL;
if (CAMERA_STATE_ENABLED != get_camera_state())
{
LOGI("%s already closed\n", __func__);
return BK_OK;
}
ret = media_send_msg_sync(EVENT_CAM_RTSP_CLOSE_IND, 0);
LOGI("%s complete\n", __func__);
return ret;
}
bk_err_t media_app_lcd_rotate(media_rotate_t rotate)
{
bk_err_t ret;
LOGI("%s\n", __func__);
ret = media_send_msg_sync(EVENT_LCD_ROTATE_ENABLE_IND, rotate);
LOGI("%s complete\n", __func__);
return ret;
}
bk_err_t media_app_lcd_resize(media_ppi_t ppi)
{
bk_err_t ret;
LOGI("%s\n", __func__);
ret = media_send_msg_sync(EVENT_LCD_RESIZE_IND, ppi);
LOGI("%s complete\n", __func__);
return ret;
}
bk_err_t media_app_lcd_display_beken(void *lcd_display)
{
bk_err_t ret;
lcd_display_t *ptr = NULL;
ptr = (lcd_display_t *)os_malloc(sizeof(lcd_display_t));
os_memcpy(ptr, (lcd_display_t *)lcd_display, sizeof(lcd_display_t));
ret = media_send_msg_sync(EVENT_LCD_BEKEN_LOGO_DISPLAY, (uint32_t)ptr);
LOGI("%s complete\n", __func__);
os_free(ptr);
ptr =NULL;
return ret;
}
bk_err_t media_app_lcd_decode(media_decode_mode_t decode_mode)
{
bk_err_t ret = kNoErr;
#if CONFIG_LCD_MEDIA
LOGI("%s\n", __func__);
set_decode_mode(decode_mode);
#endif
LOGI("%s complete\n", __func__);
return ret;
}
uint32_t media_app_get_lcd_devices_num(void)
{
uint32_t num;
num = get_lcd_devices_num();
return num;
}
uint32_t media_app_get_lcd_devices_list(void)
{
uint32_t device_addr;
device_addr = (uint32_t)get_lcd_devices_list();
return device_addr;
}
uint32_t media_app_get_lcd_device_by_id(uint32_t id)
{
uint32_t lcd_device;
lcd_device = (uint32_t)get_lcd_device_by_id(id);
return lcd_device;
}
bk_err_t media_app_get_lcd_status(void)
{
uint32_t lcd_status = 0;
return lcd_status;
}
bk_err_t media_app_get_uvc_camera_status(void)
{
uint32_t camera_status = 0;
return camera_status;
}
bk_err_t media_app_lcd_open(void *lcd_open)
{
int ret = kNoErr;
#if CONFIG_LCD_MEDIA
lcd_open_t *ptr = NULL;
if (LCD_STATE_ENABLED == get_lcd_state())
{
LOGI("%s already opened\n", __func__);
return ret;
}
LOGI("%s \n", __func__);
ptr = (lcd_open_t *)os_malloc(sizeof(lcd_open_t));
if (ptr == NULL) {
LOGE("malloc lcd_open_t failed\r\n");
return kGeneralErr;
}
os_memcpy(ptr, (lcd_open_t *)lcd_open, sizeof(lcd_open_t));
ret = media_send_msg_sync(EVENT_LCD_OPEN_IND, (uint32_t)ptr);
if (ptr) {
os_free(ptr);
ptr =NULL;
}
#endif
LOGI("%s complete\n", __func__);
return ret;
}
bk_err_t media_app_lcd_display_file(char *file_name)
{
int ret;
char *capture_name = NULL;
LOGI("%s, %s\n", __func__, file_name);
if (file_name != NULL)
{
uint32_t len = os_strlen(file_name) + 1;
if (len > 31)
{
len = 31;
}
capture_name = (char *)os_malloc(len);
os_memset(capture_name, 0, len);
os_memcpy(capture_name, file_name, len);
capture_name[len - 1] = '\0';
}
ret = media_send_msg_sync(EVENT_LCD_DISPLAY_FILE_IND, (uint32_t)capture_name);
os_free(capture_name);
LOGI("%s complete\n", __func__);
return ret;
}
bk_err_t media_app_lcd_display(void *lcd_display)
{
bk_err_t ret;
lcd_display_t *ptr = NULL;
ptr = (lcd_display_t *)os_malloc(sizeof(lcd_display_t));
os_memcpy(ptr, (lcd_display_t *)lcd_display, sizeof(lcd_display_t));
ret = media_send_msg_sync(EVENT_LCD_DISPLAY_IND, (uint32_t)ptr);
LOGI("%s complete\n", __func__);
os_free(ptr);
return ret;
}
bk_err_t media_app_lcd_blend_open(bool en)
{
bk_err_t ret = 0;
ret = media_send_msg_sync(EVENT_LCD_BLEND_OPEN_IND, en);
LOGI("%s complete\n", __func__);
return ret;
}
bk_err_t media_app_lcd_blend(void *param)
{
bk_err_t ret;
lcd_blend_msg_t *ptr = NULL;
ptr = (lcd_blend_msg_t *)os_malloc(sizeof(lcd_blend_msg_t));
os_memcpy(ptr, (lcd_blend_msg_t *)param, sizeof(lcd_blend_msg_t));
ret = media_send_msg_sync(EVENT_LCD_BLEND_IND, (uint32_t)ptr);
os_free(ptr);
return ret;
}
bk_err_t media_app_lcd_close(void)
{
bk_err_t ret = BK_OK;
LOGI("%s\n", __func__);
#if CONFIG_LCD_MEDIA
if (LCD_STATE_ENABLED == get_lcd_state() || LCD_STATE_DISPLAY == get_lcd_state())
{
ret = media_send_msg_sync(EVENT_LCD_CLOSE_IND, 0);
}
else
{
LOGI("%s already closed\n", __func__);
return BK_OK;
}
#endif
LOGI("%s complete\n", __func__);
return ret;
}
bk_err_t media_app_lcd_set_backlight(uint8_t level)
{
bk_err_t ret = BK_OK;
LOGI("%s\n", __func__);
#if CONFIG_LCD_MEDIA
if (LCD_STATE_ENABLED != get_lcd_state())
{
LOGI("%s not open\n", __func__);
return kNoErr;
}
ret = media_send_msg_sync(EVENT_LCD_SET_BACKLIGHT_IND, level);
LOGI("%s complete\n", __func__);
#endif
return ret;
}
bk_err_t media_app_send_msg(media_msg_t *msg)
{
bk_err_t ret;
if (media_app_msg_queue)
{
ret = rtos_push_to_queue(&media_app_msg_queue, msg, BEKEN_NO_WAIT);
if (kNoErr != ret)
{
LOGE("%s failed\n", __func__);
return kOverrunErr;
}
return ret;
}
return kNoResourcesErr;
}
bk_err_t media_app_storage_open(void)
{
if (STORAGE_STATE_DISABLED != get_storage_state())
{
LOGI("%s already open\n", __func__);
return BK_OK;
}
int ret = media_send_msg_sync(EVENT_STORAGE_OPEN_IND, 0);
return ret;
}
bk_err_t media_app_storage_close(void)
{
if (STORAGE_STATE_ENABLED != get_storage_state())
{
LOGI("%s already close\n", __func__);
return BK_OK;
}
int ret = media_send_msg_sync(EVENT_STORAGE_CLOSE_IND, 0);
return ret;
}
bk_err_t media_app_capture(char *name)
{
int ret;
char *capture_name = NULL;
LOGI("%s, %s\n", __func__, name);
if (STORAGE_STATE_ENABLED != get_storage_state())
{
LOGE("%s storage task not open\n", __func__);
return BK_FAIL;
}
if (name != NULL)
{
uint32_t len = os_strlen(name) + 1;
if (len > 31)
{
len = 31;
}
capture_name = (char *)os_malloc(len);
os_memset(capture_name, 0, len);
os_memcpy(capture_name, name, len);
capture_name[len - 1] = '\0';
}
ret = media_send_msg_sync(EVENT_STORAGE_CAPTURE_IND, (uint32_t)capture_name);
os_free(capture_name);
LOGI("%s complete\n", __func__);
return ret;
}
bk_err_t media_app_save_start(char *name)
{
int ret;
char *save_name = NULL;
LOGI("%s, %s\n", __func__, name);
if (STORAGE_STATE_ENABLED != get_storage_state())
{
LOGE("%s storage task not open\n", __func__);
return BK_FAIL;
}
if (name != NULL)
{
uint32_t len = os_strlen(name) + 1;
if (len > 31)
{
len = 31;
}
save_name = (char *)os_malloc(len);
os_memset(save_name, 0, len);
os_memcpy(save_name, name, len);
save_name[len - 1] = '\0';
}
ret = media_send_msg_sync(EVENT_STORAGE_SAVE_START_IND, (uint32_t)save_name);
LOGI("%s complete\n", __func__);
return ret;
}
bk_err_t media_app_save_stop(void)
{
int ret;
LOGI("%s\n", __func__);
if (STORAGE_STATE_ENABLED != get_storage_state())
{
LOGE("%s storage task not open\n", __func__);
return BK_FAIL;
}
ret = media_send_msg_sync(EVENT_STORAGE_SAVE_STOP_IND, 0);
LOGI("%s complete\n", __func__);
return ret;
}
static void media_app_message_handle(void)
{
bk_err_t ret = BK_OK;
media_msg_t msg;
while (1)
{
ret = rtos_pop_from_queue(&media_app_msg_queue, &msg, BEKEN_WAIT_FOREVER);
if (kNoErr == ret)
{
switch (msg.event)
{
case EVENT_APP_DVP_OPEN:
break;
case EVENT_APP_EXIT:
goto exit;
break;
default:
break;
}
}
}
exit:
/* delate msg queue */
ret = rtos_deinit_queue(&media_app_msg_queue);
if (ret != kNoErr)
{
LOGE("delate message queue fail\n");
}
media_app_msg_queue = NULL;
LOGE("delate message queue complete\n");
/* delate task */
media_app_th_hd = NULL;
rtos_delete_thread(NULL);
}
bk_err_t media_app_init(void)
{
bk_err_t ret = BK_OK;
if (media_app_msg_queue != NULL)
{
ret = kNoErr;
LOGE("%s, media_app_msg_queue allready init, exit!\n");
goto error;
}
if (media_app_th_hd != NULL)
{
ret = kNoErr;
LOGE("%s, media_app_th_hd allready init, exit!\n");
goto error;
}
/*
ret = rtos_init_queue(&media_app_msg_queue,
"media_app_msg_queue",
sizeof(media_msg_t),
MEDIA_MINOR_MSG_QUEUE_SIZE);
if (ret != kNoErr)
{
LOGE("%s, ceate media minor message queue failed\n");
goto error;
}
*/
if (media_debug == NULL)
{
media_debug = (media_debug_t *)os_malloc(sizeof(media_debug_t));
if (media_debug == NULL)
{
LOGE("malloc media_debug fail\n");
}
}
if (media_debug_cached == NULL)
{
media_debug_cached = (media_debug_t *)os_malloc(sizeof(media_debug_t));
if (media_debug_cached == NULL)
{
LOGE("malloc media_debug_cached fail\n");
}
}
/*
ret = rtos_create_thread(&media_app_th_hd,
BEKEN_DEFAULT_WORKER_PRIORITY,
"media_app_thread",
(beken_thread_function_t)media_app_message_handle,
4096,
NULL);
if (ret != kNoErr)
{
LOGE("create media app thread fail\n");
goto error;
}
*/
LOGI("media app thread startup complete\n");
return kNoErr;
error:
if (media_app_msg_queue)
{
rtos_deinit_queue(&media_app_msg_queue);
media_app_msg_queue = NULL;
}
return ret;
}
bk_err_t media_app_dump_display_frame(void)
{
return media_send_msg_sync(EVENT_LCD_DUMP_DISPLAY_IND, 0);
}
bk_err_t media_app_dump_decoder_frame(void)
{
return media_send_msg_sync(EVENT_LCD_DUMP_DECODER_IND, 0);
}
bk_err_t media_app_dump_jpeg_frame(void)
{
return media_send_msg_sync(EVENT_LCD_DUMP_JPEG_IND, 0);
}
bk_err_t media_app_lcd_step_mode(bool enable)
{
return media_send_msg_sync(EVENT_LCD_STEP_MODE_IND, enable);
}
bk_err_t media_app_lcd_step_trigger(void)
{
return media_send_msg_sync(EVENT_LCD_STEP_TRIGGER_IND, 0);
}
#if CONFIG_VIDEO_AVI
bk_err_t media_app_avi_open(void)
{
return media_send_msg_sync(EVENT_AVI_OPEN_IND, 1);
}
bk_err_t media_app_avi_close(void)
{
return media_send_msg_sync(EVENT_AVI_CLOSE_IND, 0);
}
#endif