mirror of
https://github.com/asterisk/asterisk.git
synced 2025-11-20 00:30:20 +00:00
fff17a25dd
Now that these files are in the tree, they should prefer the tree's local copy of all Asterisk headers over any that may be installed. git-svn-id: https://origsvn.digium.com/svn/asterisk/trunk@254931 65c4cc65-6c06-0410-ace0-fbb531ad65f3
113 lines
2.7 KiB
C
113 lines
2.7 KiB
C
/*
|
|
* Copyright (C) 2004-2005 by Objective Systems, Inc.
|
|
*
|
|
* This software is furnished under an open source license and may be
|
|
* used and copied only in accordance with the terms of this license.
|
|
* The text of the license may generally be found in the root
|
|
* directory of this installation in the COPYING file. It
|
|
* can also be viewed online at the following URL:
|
|
*
|
|
* http://www.obj-sys.com/open/license.html
|
|
*
|
|
* Any redistributions of this file including modified versions must
|
|
* maintain this copyright notice.
|
|
*
|
|
*****************************************************************************/
|
|
|
|
#include "asterisk.h"
|
|
#include "asterisk/lock.h"
|
|
|
|
#include "ooports.h"
|
|
#include "ooh323ep.h"
|
|
#include "ootrace.h"
|
|
|
|
/** Global endpoint structure */
|
|
extern OOH323EndPoint gH323ep;
|
|
extern ast_mutex_t bindPortLock;
|
|
|
|
/* Get the next port of type TCP/UDP/RTP */
|
|
int ooGetNextPort (OOH323PortType type)
|
|
{
|
|
if(type==OOTCP)
|
|
{
|
|
if(gH323ep.tcpPorts.current <= gH323ep.tcpPorts.max)
|
|
return gH323ep.tcpPorts.current++;
|
|
else
|
|
{
|
|
gH323ep.tcpPorts.current = gH323ep.tcpPorts.start;
|
|
return gH323ep.tcpPorts.current++;
|
|
}
|
|
}
|
|
if(type==OOUDP)
|
|
{
|
|
if(gH323ep.udpPorts.current <= gH323ep.udpPorts.max)
|
|
return gH323ep.udpPorts.current++;
|
|
else
|
|
{
|
|
gH323ep.udpPorts.current = gH323ep.udpPorts.start;
|
|
return gH323ep.udpPorts.current++;
|
|
}
|
|
}
|
|
if(type==OORTP)
|
|
{
|
|
if(gH323ep.rtpPorts.current <= gH323ep.rtpPorts.max)
|
|
return gH323ep.rtpPorts.current++;
|
|
else
|
|
{
|
|
gH323ep.rtpPorts.current = gH323ep.rtpPorts.start;
|
|
return gH323ep.rtpPorts.current++;
|
|
}
|
|
}
|
|
return OO_FAILED;
|
|
}
|
|
|
|
int ooBindPort (OOH323PortType type, OOSOCKET socket, char *ip)
|
|
{
|
|
int initialPort, bindPort, ret;
|
|
OOIPADDR ipAddrs;
|
|
|
|
ast_mutex_lock(&bindPortLock);
|
|
|
|
initialPort = ooGetNextPort (type);
|
|
bindPort = initialPort;
|
|
|
|
ret= ooSocketStrToAddr (ip, &ipAddrs);
|
|
|
|
while(1)
|
|
{
|
|
if((ret=ooSocketBind(socket, ipAddrs, bindPort))==0)
|
|
{
|
|
ast_mutex_unlock(&bindPortLock);
|
|
return bindPort;
|
|
}
|
|
else
|
|
{
|
|
bindPort = ooGetNextPort (type);
|
|
if (bindPort == initialPort) { ast_mutex_unlock(&bindPortLock); return OO_FAILED; }
|
|
}
|
|
}
|
|
}
|
|
|
|
#ifdef _WIN32
|
|
int ooBindOSAllocatedPort(OOSOCKET socket, char *ip)
|
|
{
|
|
OOIPADDR ipAddrs;
|
|
int size, ret;
|
|
struct sockaddr_in name;
|
|
size = sizeof(struct sockaddr_in);
|
|
ret= ooSocketStrToAddr (ip, &ipAddrs);
|
|
if((ret=ooSocketBind(socket, ipAddrs,
|
|
0))==ASN_OK)
|
|
{
|
|
ret = ooSocketGetSockName(socket, &name, &size);
|
|
if(ret == ASN_OK)
|
|
{
|
|
return name.sin_port;
|
|
|
|
}
|
|
}
|
|
|
|
return OO_FAILED;
|
|
}
|
|
#endif
|