Skip to content

Commit 2ceca68

Browse files
committed
fixed:P2XPProtocol_Packet_WLan not export
Now supports getting all address lists under wlan WLANLIST AND LANLIST merge
1 parent 0a12e98 commit 2ceca68

File tree

3 files changed

+38
-8
lines changed

3 files changed

+38
-8
lines changed

XEngine_Source/XEngine_P2XPComponents/XEngine_P2XPProtocol/XEngine_P2XPProtocol.def

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -11,5 +11,6 @@ EXPORTS
1111

1212
P2XPProtocol_Packet_Common
1313
P2XPProtocol_Packet_Lan
14+
P2XPProtocol_Packet_WLan
1415
P2XPProtocol_Packet_User
1516
P2XPProtocol_Packet_Connect

XEngine_Source/XEngine_StorageApp/StorageApp_P2XPNet.cpp

Lines changed: 31 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -127,7 +127,31 @@ BOOL XEngine_Task_TCPP2xp(XENGINE_PROTOCOLHDR* pSt_ProtocolHdr, LPCTSTR lpszClie
127127
}
128128
else
129129
{
130+
//公网下所有列表
131+
int nListCount = 0;
132+
TCHAR** ppszClientList;
133+
list<XENGINE_P2XPPEER_PROTOCOL> stl_ListClient;
134+
if (P2XPPeer_Manage_GetLList(tszPubAddr, &ppszClientList, &nListCount))
135+
{
136+
for (int i = 0; i < nListCount; i++)
137+
{
138+
int nLanCount = 0;
139+
XENGINE_P2XPPEER_PROTOCOL** ppSt_ListClients;
130140

141+
if (P2XPPeer_Manage_GetLan(tszPubAddr, ppszClientList[i], &ppSt_ListClients, &nLanCount))
142+
{
143+
for (int j = 0; j < nLanCount; j++)
144+
{
145+
stl_ListClient.push_back(*ppSt_ListClients[j]);
146+
}
147+
BaseLib_OperatorMemory_Free((XPPPMEM)&ppSt_ListClients, nLanCount);
148+
}
149+
}
150+
BaseLib_OperatorMemory_Free((XPPPMEM)&ppszClientList, nListCount);
151+
}
152+
P2XPProtocol_Packet_WLan(pSt_ProtocolHdr, &stl_ListClient, tszSDBuffer, &nSDLen);
153+
XEngine_Net_SendMsg(lpszClientAddr, tszSDBuffer, nSDLen, STORAGE_NETTYPE_TCPP2XP);
154+
XLOG_PRINT(xhLog, XENGINE_HELPCOMPONENTS_XLOG_IN_LOGLEVEL_INFO, _T("客户端:%s,请求同步局域网列表成功,公有地址:%s,私有地址:%s"), lpszClientAddr, tszPubAddr, tszPriAddr);
131155
}
132156
}
133157
else if (XENGINE_COMMUNICATION_PROTOCOL_OPERATOR_CODE_P2XP_REQCONNECT == pSt_ProtocolHdr->unOperatorCode)
@@ -192,6 +216,13 @@ BOOL XEngine_Task_TCPP2xp(XENGINE_PROTOCOLHDR* pSt_ProtocolHdr, LPCTSTR lpszClie
192216
XEngine_Net_SendMsg(lpszClientAddr, tszSDBuffer, nSDLen, STORAGE_NETTYPE_TCPP2XP);
193217
XLOG_PRINT(xhLog, XENGINE_HELPCOMPONENTS_XLOG_IN_LOGLEVEL_INFO, _T("客户端:%s,请求查询用户:%s 成功"), lpszClientAddr, tszUserName);
194218
}
219+
else if (XENGINE_COMMUNICATION_PROTOCOL_OPERATOR_CODE_STORAGE_REQQUERY == pSt_ProtocolHdr->unOperatorCode)
220+
{
221+
TCHAR tszFileHash[MAX_PATH];
222+
memset(tszFileHash, '\0', MAX_PATH);
223+
224+
XStorageProtocol_Core_REQQueryFile(lpszMsgBuffer, NULL, NULL, NULL, tszFileHash);
225+
}
195226
else
196227
{
197228
XLOG_PRINT(xhLog, XENGINE_HELPCOMPONENTS_XLOG_IN_LOGLEVEL_WARN, _T("客户端:%s,请求了一条未知的子协议:%lX"), lpszClientAddr, pSt_ProtocolHdr->unOperatorCode);

XEngine_Source/XStorage_Protocol.h

Lines changed: 6 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -14,17 +14,15 @@
1414
// 协议定义
1515
//////////////////////////////////////////////////////////////////////////
1616
//存储服务
17-
#define XENGINE_COMMUNICATION_PROTOCOL_OPERATOR_CODE_STORAGE_REQQUERY 0x4001 //查询请求
18-
#define XENGINE_COMMUNICATION_PROTOCOL_OPERATOR_CODE_STORAGE_REPQUERY 0x4002 //
17+
#define XENGINE_COMMUNICATION_PROTOCOL_OPERATOR_CODE_STORAGE_REQQUERY 0x4001 //查询请求
18+
#define XENGINE_COMMUNICATION_PROTOCOL_OPERATOR_CODE_STORAGE_REPQUERY 0x4002 //查询回复
1919
//P2XP协议
2020
#define XENGINE_COMMUNICATION_PROTOCOL_OPERATOR_CODE_P2XP_REQLANLIST 0x6001 //同步列表协议,同步本地局域网IP中的客户端
2121
#define XENGINE_COMMUNICATION_PROTOCOL_OPERATOR_CODE_P2XP_REPLANLIST 0x6002 //同步列表回复确认协议
22-
#define XENGINE_COMMUNICATION_PROTOCOL_OPERATOR_CODE_P2XP_REQWLANLIST 0x6003 //同步列表协议,同步同一外网IP中局域网
23-
#define XENGINE_COMMUNICATION_PROTOCOL_OPERATOR_CODE_P2XP_REPWLANLIST 0x6004 //同步万维网IP确认协议
24-
#define XENGINE_COMMUNICATION_PROTOCOL_OPERATOR_CODE_P2XP_REQCONNECT 0x6005 //请求用户连接到网络服务
25-
#define XENGINE_COMMUNICATION_PROTOCOL_OPERATOR_CODE_P2XP_REPCONNECT 0x6006 //确认连接协议
26-
#define XENGINE_COMMUNICATION_PROTOCOL_OPERATOR_CODE_P2XP_REQUSERQUERY 0x6007 //用户查询
27-
#define XENGINE_COMMUNICATION_PROTOCOL_OPERATOR_CODE_P2XP_REPUSERQUERY 0x6008 //用户查询确认
22+
#define XENGINE_COMMUNICATION_PROTOCOL_OPERATOR_CODE_P2XP_REQCONNECT 0x6003 //请求用户连接到网络服务
23+
#define XENGINE_COMMUNICATION_PROTOCOL_OPERATOR_CODE_P2XP_REPCONNECT 0x6004 //确认连接协议
24+
#define XENGINE_COMMUNICATION_PROTOCOL_OPERATOR_CODE_P2XP_REQUSERQUERY 0x6005 //用户查询
25+
#define XENGINE_COMMUNICATION_PROTOCOL_OPERATOR_CODE_P2XP_REPUSERQUERY 0x6006 //用户查询确认
2826
//////////////////////////////////////////////////////////////////////////
2927
// 协议结构体
3028
//////////////////////////////////////////////////////////////////////////

0 commit comments

Comments
 (0)