From 109ffe9a777658936a38d0c146579a67c60a0d17 Mon Sep 17 00:00:00 2001
From: xuxiuxi <xuxiuxi@454eff88-639b-444f-9e54-f578c98de674>
Date: 星期四, 11 五月 2017 17:48:48 +0800
Subject: [PATCH]
---
RtspFace/PipeLine.cpp | 11 ++++++++---
1 files changed, 8 insertions(+), 3 deletions(-)
diff --git a/RtspFace/PipeLine.cpp b/RtspFace/PipeLine.cpp
index 0aabd47..0a5e73e 100644
--- a/RtspFace/PipeLine.cpp
+++ b/RtspFace/PipeLine.cpp
@@ -102,6 +102,11 @@
return false;
}
+bool PipeLine::check_pipe_complete(PipeLineElem* lastRetElem) const
+{
+ return lastRetElem == *elems.rbegin();
+}
+
PipeLineElem* PipeLine::push_elem(const std::string& type)
{
elem_create_func_map_t::iterator iter = elem_create_func_map.find(type);
@@ -137,16 +142,16 @@
PipeDebugger(PipeLine* _pipeLine) :
pipeLine(_pipeLine), retElem(nullptr), pm(nullptr)
{
- //LOG_DEBUG << "pipe line begin";
+ //LOG_DEBUG << "pipe line begin" << std::endl;
}
~PipeDebugger()
{
//bool retOK = (*(pipeLine->elems).rbegin() == retElem);
//if (retOK)
- // LOG_DEBUG << "pipe line end, ret OK";
+ // LOG_DEBUG << "pipe line end, ret OK" << std::endl;
//else
- // LOG_WARN << "pipe line end, ret ERROR";
+ // LOG_WARN << "pipe line end, ret ERROR" << std::endl;
}
};
--
Gitblit v1.8.0