diff --git a/server/WebApi.cpp b/server/WebApi.cpp index 30a6c559..988b55b5 100755 --- a/server/WebApi.cpp +++ b/server/WebApi.cpp @@ -1590,12 +1590,14 @@ void installWebApi() { auto record_path = Recorder::getRecordPath(Recorder::type_mp4, tuple, allArgs["customized_path"]); auto period = allArgs["period"]; record_path = record_path + period + "/"; + + bool recording = false; auto name = allArgs["name"]; if (!name.empty()) { + // 删除指定文件 record_path += name; - } - bool recording = false; - { + } else { + // 删除文件夹,先判断该流是否正在录制中 auto src = MediaSource::find(allArgs["vhost"], allArgs["app"], allArgs["stream"]); if (src && src->isRecording(Recorder::type_mp4)) { recording = true; diff --git a/src/Rtsp/RtspSplitter.cpp b/src/Rtsp/RtspSplitter.cpp index 06e9f8c3..33e6e694 100644 --- a/src/Rtsp/RtspSplitter.cpp +++ b/src/Rtsp/RtspSplitter.cpp @@ -10,8 +10,9 @@ #include #include "RtspSplitter.h" -#include "Util/logger.h" #include "Util/util.h" +#include "Util/logger.h" +#include "Common/macros.h" using namespace std; using namespace toolkit; @@ -64,7 +65,18 @@ ssize_t RtspSplitter::onRecvHeader(const char *data, size_t len) { if (len == 4 && !memcmp(data, "\r\n\r\n", 4)) { return 0; } - _parser.parse(data, len); + try { + _parser.parse(data, len); + } catch (mediakit::AssertFailedException &ex){ + if (!_enableRecvRtp) { + // 还在握手中,直接中断握手 + throw; + } + // 握手已经结束,如果rtsp server存在发送缓存溢出的bug,那么rtsp信令可能跟rtp混在一起 + // 这种情况下,rtsp信令解析异常不中断链接,只丢弃这个包 + WarnL << ex.what(); + return 0; + } auto ret = getContentLength(_parser); if (ret == 0) { onWholeRtspPacket(_parser);