Skip to content

Commit 3eb72ce

Browse files
committed
modify:Unified sending function
1 parent 01ff3e7 commit 3eb72ce

File tree

1 file changed

+22
-33
lines changed

1 file changed

+22
-33
lines changed

XEngine_Source/XEngine_StorageApp/StorageApp_Network.cpp

Lines changed: 22 additions & 33 deletions
Original file line numberDiff line numberDiff line change
@@ -175,52 +175,41 @@ BOOL XEngine_Net_SendMsg(LPCTSTR lpszClientAddr, LPCTSTR lpszMsgBuffer, int nMsg
175175

176176
if (STORAGE_NETTYPE_HTTPDOWNLOAD == nType)
177177
{
178-
#if ((XENGINE_VERSION_KERNEL >= 7) && (XENGINE_VERSION_MAIN > 18))
179178
bRet = NetCore_TCPXCore_SendEx(xhNetDownload, lpszClientAddr, lpszMsgBuffer, nMsgLen, 0, 10);
180-
#else
181-
bRet = NetCore_TCPXCore_SendEx(xhNetDownload, lpszClientAddr, lpszMsgBuffer, nMsgLen);
182-
#endif
183179
if (bRet && st_ServiceCfg.st_XTime.bHBTime)
184180
{
185181
SocketOpt_HeartBeat_ActiveAddrEx(xhHBDownload, lpszClientAddr);
186182
}
187-
if (!bRet)
188-
{
189-
return FALSE;
190-
}
191183
}
192-
else
184+
else if(STORAGE_NETTYPE_HTTPUPLOADER == nType)
193185
{
194-
if (STORAGE_NETTYPE_HTTPUPLOADER == nType)
195-
{
196-
bRet = NetCore_TCPXCore_SendEx(xhNetUPLoader, lpszClientAddr, lpszMsgBuffer, nMsgLen);
197-
if (bRet && st_ServiceCfg.st_XTime.bHBTime)
198-
{
199-
SocketOpt_HeartBeat_ActiveAddrEx(xhHBUPLoader, lpszClientAddr);
200-
}
201-
}
202-
else if (STORAGE_NETTYPE_HTTPCENTER == nType)
186+
bRet = NetCore_TCPXCore_SendEx(xhNetUPLoader, lpszClientAddr, lpszMsgBuffer, nMsgLen);
187+
if (bRet && st_ServiceCfg.st_XTime.bHBTime)
203188
{
204-
bRet = NetCore_TCPXCore_SendEx(xhNetCenter, lpszClientAddr, lpszMsgBuffer, nMsgLen);
205-
if (bRet && st_ServiceCfg.st_XTime.bHBTime)
206-
{
207-
SocketOpt_HeartBeat_ActiveAddrEx(xhHBCenter, lpszClientAddr);
208-
}
189+
SocketOpt_HeartBeat_ActiveAddrEx(xhHBUPLoader, lpszClientAddr);
209190
}
210-
else if (STORAGE_NETTYPE_TCPP2XP == nType)
191+
}
192+
else if (STORAGE_NETTYPE_HTTPCENTER == nType)
193+
{
194+
bRet = NetCore_TCPXCore_SendEx(xhNetCenter, lpszClientAddr, lpszMsgBuffer, nMsgLen);
195+
if (bRet && st_ServiceCfg.st_XTime.bHBTime)
211196
{
212-
bRet = NetCore_TCPXCore_SendEx(xhNetP2xp, lpszClientAddr, lpszMsgBuffer, nMsgLen);
213-
if (bRet && st_ServiceCfg.st_XTime.bHBTime)
214-
{
215-
SocketOpt_HeartBeat_ActiveAddrEx(xhHBP2xp, lpszClientAddr);
216-
}
197+
SocketOpt_HeartBeat_ActiveAddrEx(xhHBCenter, lpszClientAddr);
217198
}
218-
if (!bRet)
199+
}
200+
else if (STORAGE_NETTYPE_TCPP2XP == nType)
201+
{
202+
bRet = NetCore_TCPXCore_SendEx(xhNetP2xp, lpszClientAddr, lpszMsgBuffer, nMsgLen);
203+
if (bRet && st_ServiceCfg.st_XTime.bHBTime)
219204
{
220-
DWORD dwRet = NetCore_GetLastError();
221-
XLOG_PRINT(xhLog, XENGINE_HELPCOMPONENTS_XLOG_IN_LOGLEVEL_ERROR, _T("客户端:%s,网络类型:%d,发送数据失败,发送大小:%d,错误:%lX,%d"), lpszClientAddr, nType, nMsgLen, dwRet, errno);
222-
return FALSE;
205+
SocketOpt_HeartBeat_ActiveAddrEx(xhHBP2xp, lpszClientAddr);
223206
}
224207
}
208+
if (!bRet)
209+
{
210+
DWORD dwRet = NetCore_GetLastError();
211+
XLOG_PRINT(xhLog, XENGINE_HELPCOMPONENTS_XLOG_IN_LOGLEVEL_ERROR, _T("客户端:%s,网络类型:%d,发送数据失败,发送大小:%d,错误:%lX,%d"), lpszClientAddr, nType, nMsgLen, dwRet, errno);
212+
return FALSE;
213+
}
225214
return TRUE;
226215
}

0 commit comments

Comments
 (0)