From 8ece1bcf75056d8006e2d56721d1a6498e7d273c Mon Sep 17 00:00:00 2001
From: admin <zzjincn@163.com>
Date: 星期二, 29 四月 2025 15:09:55 +0800
Subject: [PATCH] 写入redis处理加上失效ttl
---
main.cpp | 4 +++-
1 files changed, 3 insertions(+), 1 deletions(-)
diff --git a/main.cpp b/main.cpp
index 2b70e22..037b6db 100644
--- a/main.cpp
+++ b/main.cpp
@@ -9,6 +9,7 @@
#include <future>
#include <json/json.h>
#include "affine.h"
+#include <hiredis.h>
#include "PreProcessFn.h"
using namespace std;
@@ -36,6 +37,7 @@
long skipN = stol(ipcNode["skipN"].asString());
ppf.skipN = skipN;
std::string push_type = ipcNode["push_type"].asString();
+ std::string video_size = ipcNode["video_size"].asString();
std::string fps = ipcNode["fps"].asString();
std::string toRtmp = ipcNode["toRtmp"].asString();
std::string interval = ipcNode["interval"].asString();
@@ -50,7 +52,7 @@
pushVideoTasks.push_back(std::async(std::launch::async, &PreProcessFn::fnPushVideoInRabbitMQ, &ppf, std::ref(queMatVec2[i]), ipccode));
}
else if (push_type == "stream") {
- pushVideoTasks.push_back(std::async(std::launch::async, &PreProcessFn::fnPushVideoToUrl, &ppf, std::ref(queMatVec2[i]),toRtmp,fps, ipccode));
+ pushVideoTasks.push_back(std::async(std::launch::async, &PreProcessFn::fnPushVideoToUrl, &ppf, std::ref(queMatVec2[i]),toRtmp,fps,video_size, ipccode));
}
}
--
Gitblit v1.8.0