Skip to content

Commit 0e8419e

Browse files
committed
fixed:test exist code is incorrect
1 parent 4c08e32 commit 0e8419e

File tree

1 file changed

+18
-19
lines changed

1 file changed

+18
-19
lines changed

XEngine_Source/XEngine_MQServiceApp/XEngine_MQServiceApp.cpp

Lines changed: 18 additions & 19 deletions
Original file line numberDiff line numberDiff line change
@@ -91,18 +91,17 @@ int main(int argc, char** argv)
9191
WSADATA st_WSAData;
9292
WSAStartup(MAKEWORD(2, 2), &st_WSAData);
9393
#endif
94+
int nRet = -1;
9495
LPCXSTR lpszHTTPMime = _X("./XEngine_Config/HttpMime.types");
9596
LPCXSTR lpszHTTPCode = _X("./XEngine_Config/HttpCode.types");
9697
LPCXSTR lpszDBConfig = _X("./XEngine_Config/XEngine_DBConfig.json");
9798

98-
XCHAR tszStringMsg[2048];
9999
HELPCOMPONENTS_XLOG_CONFIGURE st_XLogConfig;
100100
THREADPOOL_PARAMENT** ppSt_ListTCPParam;
101101
THREADPOOL_PARAMENT** ppSt_ListHTTPParam;
102102
THREADPOOL_PARAMENT** ppSt_ListWSParam;
103103
THREADPOOL_PARAMENT** ppSt_ListMQTTParam;
104104

105-
memset(tszStringMsg, '\0', sizeof(tszStringMsg));
106105
memset(&st_XLogConfig, '\0', sizeof(HELPCOMPONENTS_XLOG_CONFIGURE));
107106
memset(&st_ServiceCfg, '\0', sizeof(XENGINE_SERVERCONFIG));
108107

@@ -141,17 +140,20 @@ int main(int argc, char** argv)
141140
signal(SIGABRT, ServiceApp_Stop);
142141
XLOG_PRINT(xhLog, XENGINE_HELPCOMPONENTS_XLOG_IN_LOGLEVEL_INFO, _X("启动服务中,初始化服务器信号管理成功"));
143142

144-
if (!DBModule_MQData_Init((DATABASE_MYSQL_CONNECTINFO*)&st_ServiceCfg.st_XSql))
143+
if (!bIsTest)
145144
{
146-
XLOG_PRINT(xhLog, XENGINE_HELPCOMPONENTS_XLOG_IN_LOGLEVEL_ERROR, _X("启动服务中,初始化消息数据数据库失败,错误:%lX"), DBModule_GetLastError());
147-
goto NETSERVICEEXIT;
148-
}
149-
if (!DBModule_MQUser_Init((DATABASE_MYSQL_CONNECTINFO *)&st_ServiceCfg.st_XSql, MessageQueue_CBTask_TimePublish))
150-
{
151-
XLOG_PRINT(xhLog, XENGINE_HELPCOMPONENTS_XLOG_IN_LOGLEVEL_ERROR, _X("启动服务中,初始化消息用户数据库失败,错误:%lX"), DBModule_GetLastError());
152-
goto NETSERVICEEXIT;
145+
if (!DBModule_MQData_Init((DATABASE_MYSQL_CONNECTINFO*)&st_ServiceCfg.st_XSql))
146+
{
147+
XLOG_PRINT(xhLog, XENGINE_HELPCOMPONENTS_XLOG_IN_LOGLEVEL_ERROR, _X("启动服务中,初始化消息数据数据库失败,错误:%lX"), DBModule_GetLastError());
148+
goto NETSERVICEEXIT;
149+
}
150+
if (!DBModule_MQUser_Init((DATABASE_MYSQL_CONNECTINFO*)&st_ServiceCfg.st_XSql, MessageQueue_CBTask_TimePublish))
151+
{
152+
XLOG_PRINT(xhLog, XENGINE_HELPCOMPONENTS_XLOG_IN_LOGLEVEL_ERROR, _X("启动服务中,初始化消息用户数据库失败,错误:%lX"), DBModule_GetLastError());
153+
goto NETSERVICEEXIT;
154+
}
155+
XLOG_PRINT(xhLog, XENGINE_HELPCOMPONENTS_XLOG_IN_LOGLEVEL_INFO, _X("启动服务中,初始化数据库服务成功"));
153156
}
154-
XLOG_PRINT(xhLog, XENGINE_HELPCOMPONENTS_XLOG_IN_LOGLEVEL_INFO, _X("启动服务中,初始化数据库服务成功"));
155157

156158
if (!SessionModule_Client_Init())
157159
{
@@ -354,26 +356,27 @@ int main(int argc, char** argv)
354356

355357
XLOG_PRINT(xhLog, XENGINE_HELPCOMPONENTS_XLOG_IN_LOGLEVEL_INFO, _X("所有服务成功启动,服务运行中,XEngine版本:%s%s,发行版本次数:%d,当前运行版本:%s。。。"), BaseLib_OperatorVer_XNumberStr(), BaseLib_OperatorVer_XTypeStr(), st_ServiceCfg.st_XVer.pStl_ListStorage->size(), st_ServiceCfg.st_XVer.pStl_ListStorage->front().c_str());
356358

357-
bIsTest = true;
358359
while (bIsRun)
359360
{
360361
if (bIsTest)
361362
{
362-
goto NETSERVICEEXIT;
363+
nRet = 0;
364+
break;
363365
}
364366
std::this_thread::sleep_for(std::chrono::seconds(1));
365367
}
366368
NETSERVICEEXIT:
367369

368370
bIsRun = false;
369-
if (bIsTest)
371+
if (bIsTest && 0 == nRet)
370372
{
371373
XLOG_PRINT(xhLog, XENGINE_HELPCOMPONENTS_XLOG_IN_LOGLEVEL_ERROR, _X("服务启动完毕,测试程序退出..."));
372374
}
373375
else
374376
{
375377
XLOG_PRINT(xhLog, XENGINE_HELPCOMPONENTS_XLOG_IN_LOGLEVEL_ERROR, _X("服务启动失败,服务器退出..."));
376378
}
379+
377380
HelpComponents_Datas_Destory(xhTCPPacket);
378381
HttpProtocol_Server_DestroyEx(xhHTTPPacket);
379382
RfcComponents_WSPacket_DestoryEx(xhWSPacket);
@@ -398,9 +401,5 @@ int main(int argc, char** argv)
398401
WSACleanup();
399402
#endif
400403

401-
if (bIsTest)
402-
{
403-
return -1;
404-
}
405-
return 0;
404+
return nRet;
406405
}

0 commit comments

Comments
 (0)