Skip to content

Commit 648a19c

Browse files
xengine-qytxengine-qyt
committed
modify:have function for srt init and destory
1 parent 255619c commit 648a19c

File tree

6 files changed

+80
-13
lines changed

6 files changed

+80
-13
lines changed

‎XEngine_Source/XEngine_ModuleHelp/ModuleHelp_Define.h‎

Lines changed: 20 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -54,6 +54,24 @@ extern "C" bool ModuleHelp_JT1078_StringToBCD(LPCXSTR lpszMsgBuffer, XBYTE* pbyS
5454
/* 导出的SRT函数 */
5555
/************************************************************************/
5656
/********************************************************************
57+
函数名称：ModuleHelp_SrtCore_Init
58+
函数功能：初始化SRT服务
59+
返回值
60+
类型：逻辑型
61+
意思：是否成功
62+
备注：
63+
*********************************************************************/
64+
extern "C" bool ModuleHelp_SrtCore_Init();
65+
/********************************************************************
66+
函数名称：ModuleHelp_SrtCore_Destory
67+
函数功能：销毁SRT服务
68+
返回值
69+
类型：逻辑型
70+
意思：是否成功
71+
备注：
72+
*********************************************************************/
73+
extern "C" bool ModuleHelp_SrtCore_Destory();
74+
/********************************************************************
5775
函数名称：ModuleHelp_SrtCore_Start
5876
函数功能：启动SRT
5977
参数.一：nPort
@@ -144,14 +162,14 @@ extern "C" bool ModuleHelp_SrtCore_GetStreamID(XSOCKET hSocket, XCHAR * ptszSMSA
144162
*********************************************************************/
145163
extern "C" bool ModuleHelp_SrtCore_Close(LPCXSTR lpszClientAddr = NULL, XSOCKET hSocket = 0);
146164
/********************************************************************
147-
函数名称：ModuleHelp_SrtCore_Destory
165+
函数名称：ModuleHelp_SrtCore_Stop
148166
函数功能：销毁SRT服务
149167
返回值
150168
类型：逻辑型
151169
意思：是否成功
152170
备注：
153171
*********************************************************************/
154-
extern "C" bool ModuleHelp_SrtCore_Destory();
172+
extern "C" bool ModuleHelp_SrtCore_Stop();
155173
/************************************************************************/
156174
/* 导出的RTSP函数 */
157175
/************************************************************************/

‎XEngine_Source/XEngine_ModuleHelp/ModuleHelp_Srt/ModuleHelp_SrtCore.cpp‎

Lines changed: 35 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -13,20 +13,49 @@
1313
*********************************************************************/
1414
CModuleHelp_SrtCore::CModuleHelp_SrtCore()
1515
{
16+
}
17+
CModuleHelp_SrtCore::~CModuleHelp_SrtCore()
18+
{
19+
}
20+
//////////////////////////////////////////////////////////////////////////
21+
// 公有函数
22+
//////////////////////////////////////////////////////////////////////////
23+
/********************************************************************
24+
函数名称：ModuleHelp_SrtCore_Init
25+
函数功能：初始化SRT服务
26+
返回值
27+
类型：逻辑型
28+
意思：是否成功
29+
备注：
30+
*********************************************************************/
31+
bool CModuleHelp_SrtCore::ModuleHelp_SrtCore_Init()
32+
{
33+
ModuleHelp_IsErrorOccur = false;
34+
1635
#if 1 == _XENGINE_STREAMMEDIA_BUILDSWITCH_SRT
1736
srt_startup();
1837
srt_setloglevel(srt_logging::LogLevel::fatal);
1938
#endif
39+
40+
return true;
2041
}
21-
CModuleHelp_SrtCore::~CModuleHelp_SrtCore()
42+
/********************************************************************
43+
函数名称：ModuleHelp_SrtCore_Destory
44+
函数功能：销毁SRT服务
45+
返回值
46+
类型：逻辑型
47+
意思：是否成功
48+
备注：
49+
*********************************************************************/
50+
bool CModuleHelp_SrtCore::ModuleHelp_SrtCore_Destory()
2251
{
52+
ModuleHelp_IsErrorOccur = false;
53+
2354
#if 1 == _XENGINE_STREAMMEDIA_BUILDSWITCH_SRT
2455
srt_cleanup();
2556
#endif
57+
return true;
2658
}
27-
//////////////////////////////////////////////////////////////////////////
28-
// 公有函数
29-
//////////////////////////////////////////////////////////////////////////
3059
/********************************************************************
3160
函数名称：ModuleHelp_SrtCore_Start
3261
函数功能：启动SRT
@@ -321,14 +350,14 @@ bool CModuleHelp_SrtCore::ModuleHelp_SrtCore_Close(LPCXSTR lpszClientAddr /* = N
321350
return true;
322351
}
323352
/********************************************************************
324-
函数名称：ModuleHelp_SrtCore_Destory
353+
函数名称：ModuleHelp_SrtCore_Stop
325354
函数功能：销毁SRT服务
326355
返回值
327356
类型：逻辑型
328357
意思：是否成功
329358
备注：
330359
*********************************************************************/
331-
bool CModuleHelp_SrtCore::ModuleHelp_SrtCore_Destory()
360+
bool CModuleHelp_SrtCore::ModuleHelp_SrtCore_Stop()
332361
{
333362
ModuleHelp_IsErrorOccur = false;
334363

‎XEngine_Source/XEngine_ModuleHelp/ModuleHelp_Srt/ModuleHelp_SrtCore.h‎

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -25,12 +25,14 @@ class CModuleHelp_SrtCore
2525
CModuleHelp_SrtCore();
2626
~CModuleHelp_SrtCore();
2727
public:
28+
bool ModuleHelp_SrtCore_Init();
29+
bool ModuleHelp_SrtCore_Destory();
2830
bool ModuleHelp_SrtCore_Start(int nPort);
2931
bool ModuleHelp_SrtCore_SetCallback(CALLBACK_NETCORE_SOCKET_NETEVENT_LOGIN fpCallePoll_Login, CALLBACK_NETCORE_SOCKET_NETEVENT_RECV fpCallePoll_Recv, CALLBACK_NETCORE_SOCKET_NETEVENT_LEAVE fpCallePoll_Leave, XPVOID lPLogin = NULL, XPVOID lPRecv = NULL, XPVOID lPLeave = NULL);
3032
bool ModuleHelp_SrtCore_Send(LPCXSTR lpszClientAddr, LPCXSTR lpszMsgBuffer, int nMsgLen);
3133
bool ModuleHelp_SrtCore_GetStreamID(XSOCKET hSocket, XCHAR* ptszSMSAddr, bool* pbPublish);
3234
bool ModuleHelp_SrtCore_Close(LPCXSTR lpszClientAddr = NULL, XSOCKET hSocket = 0);
33-
bool ModuleHelp_SrtCore_Destory();
35+
bool ModuleHelp_SrtCore_Stop();
3436
protected:
3537
bool ModuleHelp_SrtCore_Accept(XSOCKET hSRTSocket);
3638
bool ModuleHelp_SrtCore_Recv(XSOCKET hSocket);

‎XEngine_Source/XEngine_ModuleHelp/XEngine_ModuleHelp.def‎

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -6,12 +6,14 @@ EXPORTS
66
ModuleHelp_JT1078_BCDToString
77
ModuleHelp_JT1078_StringToBCD
88

9+
ModuleHelp_SrtCore_Init
10+
ModuleHelp_SrtCore_Destory
911
ModuleHelp_SrtCore_Start
1012
ModuleHelp_SrtCore_SetCallback
1113
ModuleHelp_SrtCore_Send
1214
ModuleHelp_SrtCore_GetStreamID
1315
ModuleHelp_SrtCore_Close
14-
ModuleHelp_SrtCore_Destory
16+
ModuleHelp_SrtCore_Stop
1517

1618
ModuleHelp_Rtsp_GetSMSAddr
1719
ModuleHelp_Rtsp_CreateClient

‎XEngine_Source/XEngine_ModuleHelp/pch.cpp‎

Lines changed: 10 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -48,6 +48,14 @@ extern "C" bool ModuleHelp_JT1078_StringToBCD(LPCXSTR lpszMsgBuffer, XBYTE * pby
4848
/************************************************************************/
4949
/* 导出的SRT函数 */
5050
/************************************************************************/
51+
extern "C" bool ModuleHelp_SrtCore_Init()
52+
{
53+
return m_SrtCore.ModuleHelp_SrtCore_Init();
54+
}
55+
extern "C" bool ModuleHelp_SrtCore_Destory()
56+
{
57+
return m_SrtCore.ModuleHelp_SrtCore_Destory();
58+
}
5159
extern "C" bool ModuleHelp_SrtCore_Start(int nPort)
5260
{
5361
return m_SrtCore.ModuleHelp_SrtCore_Start(nPort);
@@ -68,9 +76,9 @@ extern "C" bool ModuleHelp_SrtCore_Close(LPCXSTR lpszClientAddr, XSOCKET hSocket
6876
{
6977
return m_SrtCore.ModuleHelp_SrtCore_Close(lpszClientAddr, hSocket);
7078
}
71-
extern "C" bool ModuleHelp_SrtCore_Destory()
79+
extern "C" bool ModuleHelp_SrtCore_Stop()
7280
{
73-
return m_SrtCore.ModuleHelp_SrtCore_Destory();
81+
return m_SrtCore.ModuleHelp_SrtCore_Stop();
7482
}
7583
/************************************************************************/
7684
/* 导出的RTSP函数 */

‎XEngine_Source/XEngine_ServiceApp/XEngine_StreamMediaApp/XEngine_StreamMediaApp.cpp‎

Lines changed: 9 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -418,6 +418,14 @@ int main(int argc, char** argv)
418418
XLOG_PRINT(xhLog, XENGINE_HELPCOMPONENTS_XLOG_IN_LOGLEVEL_INFO, _X("启动服务中,启动JT1078处理线程池成功,线程个数:%d"), st_ServiceConfig.st_XMax.nJT1078Thread);
419419
}
420420
#if 1 == _XENGINE_STREAMMEDIA_BUILDSWITCH_SRT
421+
422+
if (!ModuleHelp_SrtCore_Init())
423+
{
424+
XLOG_PRINT(xhLog, XENGINE_HELPCOMPONENTS_XLOG_IN_LOGLEVEL_ERROR, _X("启动服务中,初始化SRT服务失败,错误：%s"), srt_getlasterror_str());
425+
goto XENGINE_SERVICEAPP_EXIT;
426+
}
427+
XLOG_PRINT(xhLog, XENGINE_HELPCOMPONENTS_XLOG_IN_LOGLEVEL_INFO, _X("启动服务中,初始化SRT服务成功"));
428+
421429
if (st_ServiceConfig.nSrtPort > 0)
422430
{
423431
if (!ModuleHelp_SrtCore_Start(st_ServiceConfig.nSrtPort))
@@ -460,7 +468,7 @@ int main(int argc, char** argv)
460468
XLOG_PRINT(xhLog, XENGINE_HELPCOMPONENTS_XLOG_IN_LOGLEVEL_WARN, _X("启动服务中,SRT协议编译选项被禁用,无法使用SRT协议"));
461469
#endif
462470

463-
#if 1 == _XENGINE_STREAMMEDIA_BUILDSWITCH_SRTP
471+
#if 1 == _XENGINE_STREAMMEDIA_BUILDSWITCH_RTC
464472
if (st_ServiceConfig.st_XPull.st_PullWebRtc.bEnable)
465473
{
466474
if (!ModuleHelp_SRTPCore_Init())

0 commit comments

Comments
 (0)