LX3JL/xlxd
1
0
Fork 0
mirror of https://github.com/LX3JL/xlxd.git synced 2025-12-06 07:42:01 +01:00
Code Issues Actions Packages Projects Releases Wiki Activity

cudpsocket: add CIp(int af) support

Browse source
This commit is contained in:
SASANO Takayoshi 2021-04-10 17:06:49 +09:00
parent 7ecc62cf42
commit 07f20f7232
1 changed files with 11 additions and 8 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

15
src/cudpsocket.cpp
View file

@ -57,16 +57,18 @@ bool CUdpSocket::Open(uint16 uiPort, int af)
socklen_t ss_len; socklen_t ss_len;
for ( int i = 0; i < UDP_SOCKET_MAX; i++ ) for ( int i = 0; i < UDP_SOCKET_MAX; i++ )
{
m_Ip[i] = CIp(AF_UNSPEC);
m_Socket[i] = -1;
if ( g_Reflector.GetListenIp(i) != CIp(AF_UNSPEC) )
{ {
m_Ip[i] = CIp(g_Reflector.GetListenIp(i), uiPort); m_Ip[i] = CIp(g_Reflector.GetListenIp(i), uiPort);
ss = m_Ip[i].GetSockAddr(ss_len); ss = m_Ip[i].GetSockAddr(ss_len);
m_Socket[i] = ( af != AF_UNSPEC && af != ss->ss_family ) ?
// create socket, avoid two cases:
// 1. address family is specified and not matched
// 2. INADDR_ANY (0.0.0.0) on secondary and later IP address
m_Socket[i] = ( ( af != AF_UNSPEC && af != ss->ss_family ) ||
( i != 0 && g_Reflector.GetListenIp(i) == CIp() ) ) ?
-1 : socket(ss->ss_family, SOCK_DGRAM, 0); -1 : socket(ss->ss_family, SOCK_DGRAM, 0);
}
if ( m_Socket[i] != -1 ) if ( m_Socket[i] != -1 )
{ {
if ( bind(m_Socket[i], (struct sockaddr *)ss, ss_len) == 0 ) if ( bind(m_Socket[i], (struct sockaddr *)ss, ss_len) == 0 )
@ -110,6 +112,7 @@ int CUdpSocket::GetSocket(const CIp &Ip)
ss = m_Ip[i].GetSockAddr(ss_len); ss = m_Ip[i].GetSockAddr(ss_len);
if ( ss_family == ss->ss_family ) if ( ss_family == ss->ss_family )
{ {
// if ss->ss_family == AF_UNSPEC, m_Socket[i] = -1
return m_Socket[i]; return m_Socket[i];
} }
} }