tian
29d9ef5d0d
仓库结构: edge/ 设备端（原根目录设备端代码整体移入） control/ 管理端（清理后） docs/ 文档（PRD 移入 design/） README.md 根导航（新增） 清理: - control/.brainstorm 临时草稿删除 - control 根级重复文档(API表/PRD_04)并入 docs/design/ - control/plan.md -> docs/implementation/control-plan.md - control/safesightd-linux-arm64 二进制取消版本控制(.gitignore) - edge/transform 模型转换产物归入 models/，onnx/pt 大源文件取消跟踪(.gitignore) - Readme.md(PRD) -> docs/design/PRD_Product_v1.2.md（避开 README 大小写冲突） 更新: - 根 README.md 导航、docs/README.md 文档索引 - deployment.md/检查表路径加 edge/ 前缀 - .gitignore 重写（edge/control 分区规则）
67 lines
1.4 KiB
C
67 lines
1.4 KiB
C
/* SPDX-License-Identifier: Apache-2.0 OR MIT */
|
|
/*
|
|
* Copyright (c) 2017 Rockchip Electronics Co., Ltd.
|
|
*/
|
|
|
|
#include "mpp_mem.h"
|
|
#include "mpp_queue.h"
|
|
|
|
MppQueue* mpp_queue_create(node_destructor func)
|
|
{
|
|
MppQueue *queue = mpp_malloc(MppQueue, 1);
|
|
|
|
queue->list = mpp_list_create(func);
|
|
sem_init(&queue->queue_pending, 0, 0);
|
|
queue->flush_flag = 0;
|
|
|
|
return queue;
|
|
}
|
|
|
|
void mpp_queue_destroy(MppQueue *queue)
|
|
{
|
|
mpp_list_destroy(queue->list);
|
|
mpp_free(queue);
|
|
}
|
|
|
|
rk_s32 mpp_queue_push(MppQueue *queue, void *data, rk_s32 size)
|
|
{
|
|
rk_s32 ret = rk_ok;
|
|
|
|
ret = mpp_list_add_at_tail(queue->list, data, size);
|
|
queue->flush_flag = 0;
|
|
sem_post(&queue->queue_pending);
|
|
|
|
return ret;
|
|
}
|
|
|
|
rk_s32 mpp_queue_pull(MppQueue *queue, void *data, rk_s32 size)
|
|
{
|
|
rk_s32 ret = rk_ok;
|
|
|
|
if (!queue->flush_flag)
|
|
sem_wait(&queue->queue_pending);
|
|
|
|
mpp_mutex_cond_lock(&queue->list->cond_lock);
|
|
if (!mpp_list_size(queue->list)) {
|
|
mpp_mutex_cond_unlock(&queue->list->cond_lock);
|
|
return ret;
|
|
}
|
|
|
|
ret = mpp_list_del_at_head(queue->list, data, size);
|
|
mpp_mutex_cond_unlock(&queue->list->cond_lock);
|
|
|
|
return ret;
|
|
}
|
|
|
|
rk_s32 mpp_queue_flush(MppQueue *queue)
|
|
{
|
|
if (queue->flush_flag)
|
|
return 0;
|
|
|
|
queue->flush_flag = 1;
|
|
sem_post(&queue->queue_pending);
|
|
mpp_list_flush(queue->list);
|
|
|
|
return 0;
|
|
}
|