safesight/edge/plugins/alarm/packet_ring_buffer.h
tian 29d9ef5d0d refactor: 项目结构梳理 - 设备端/管理端对称布局
仓库结构:
  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 分区规则)
2026-08-02 11:39:54 +08:00

37 lines
861 B
C++

#pragma once
#include <cstdint>
#include <deque>
#include <memory>
#include <mutex>
#include <vector>
#include "media/encoded_video_meta.h"
namespace rk3588 {
class PacketRingBuffer {
public:
explicit PacketRingBuffer(int window_sec = 20, int fps_hint = 25);
void Push(std::shared_ptr<EncodedVideoFrameMeta> meta);
std::vector<std::shared_ptr<EncodedVideoFrameMeta>> GetPacketsInRange(int64_t start_pts_ms,
int64_t end_pts_ms) const;
int64_t LatestPtsMs() const;
size_t Size() const;
void Clear();
private:
struct Entry {
int64_t pts_ms = 0;
std::shared_ptr<EncodedVideoFrameMeta> meta;
};
mutable std::mutex mu_;
std::deque<Entry> buf_;
size_t max_packets_ = 0;
int64_t last_pts_ms_ = 0;
};
} // namespace rk3588