Skip to content

Commit db56b89

Browse files
committed
improved:send message and user search for rtc
1 parent 551e838 commit db56b89

File tree

1 file changed

+2
-5
lines changed

1 file changed

+2
-5
lines changed

XEngine_Source/XEngine_ServiceApp/XEngine_StreamMediaApp/StreamMedia_PullStream/PullStream_ClientWebRtc.cpp

Lines changed: 2 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -39,11 +39,7 @@ bool PullStream_ClientProtocol_Handle(LPCXSTR lpszClientAddr, XSOCKET hSocket, L
3939
}
4040
else
4141
{
42-
int nPort = 0;
43-
XCHAR tszIPPort[128] = {};
44-
_tcsxcpy(tszIPPort, lpszClientAddr);
45-
BaseLib_OperatorIPAddr_SegAddr(tszIPPort, &nPort);
46-
NetCore_UDPSelect_Send(xhRTCSocket, tszSDBuffer, nSDLen, tszIPPort, nPort);
42+
XEngine_Network_Send(lpszClientAddr, tszSDBuffer, nSDLen, ENUM_XENGINE_STREAMMEDIA_CLIENT_TYPE_PUSH_RTC);
4743
XLOG_PRINT(xhLog, XENGINE_HELPCOMPONENTS_XLOG_IN_LOGLEVEL_INFO, _X("RTC客户端:%s,请求的DTLS握手协议,还需要进一步处理,响应大小:%d"), lpszClientAddr, nSDLen);
4844
}
4945
}
@@ -64,6 +60,7 @@ bool PullStream_ClientProtocol_Handle(LPCXSTR lpszClientAddr, XSOCKET hSocket, L
6460
if (RFCCOMPONENTS_NATCLIENT_PROTOCOL_STUN_ATTR_USERNAME == ppSt_ListAttr[i]->wAttr)
6561
{
6662
memcpy(tszUserStr, ppSt_ListAttr[i]->tszMsgBuffer, ppSt_ListAttr[i]->wLen);
63+
break;
6764
}
6865
}
6966
XCHAR tszICEPass[MAX_PATH] = {};

0 commit comments

Comments
 (0)