size_t len;	int sock;#endif // WIN32	struct sockaddr_in6 srcaddr;		if (rtp)		sock = rtpsock;	else		sock = rtcpsock;		len = 0;	RTPIOCTL(sock,FIONREAD,&len);	if (len <= 0)		return 0;	while (len > 0)	{		RTPTime curtime = RTPTime::CurrentTime();		fromlen = sizeof(struct sockaddr_in6);		recvlen = recvfrom(sock,packetbuffer,RTPUDPV6TRANS_MAXPACKSIZE,0,(struct sockaddr *)&srcaddr,&fromlen);		if (recvlen > 0)		{			bool acceptdata;			// got data, process it			if (receivemode == RTPTransmitter::AcceptAll)				acceptdata = true;			else				acceptdata = ShouldAcceptData(srcaddr.sin6_addr,ntohs(srcaddr.sin6_port));						if (acceptdata)			{				RTPRawPacket *pack;				RTPIPv6Address *addr;				uint8_t *datacopy;				addr = RTPNew(GetMemoryManager(),RTPMEM_TYPE_CLASS_RTPADDRESS) RTPIPv6Address(srcaddr.sin6_addr,ntohs(srcaddr.sin6_port));				if (addr == 0)					return ERR_RTP_OUTOFMEM;				datacopy = RTPNew(GetMemoryManager(),(rtp)?RTPMEM_TYPE_BUFFER_RECEIVEDRTPPACKET:RTPMEM_TYPE_BUFFER_RECEIVEDRTCPPACKET) uint8_t[recvlen];				if (datacopy == 0)				{					RTPDelete(addr,GetMemoryManager());					return ERR_RTP_OUTOFMEM;				}				memcpy(datacopy,packetbuffer,recvlen);								pack = RTPNew(GetMemoryManager(),RTPMEM_TYPE_CLASS_RTPRAWPACKET) RTPRawPacket(datacopy,recvlen,addr,curtime,rtp,GetMemoryManager());				if (pack == 0)				{					RTPDelete(addr,GetMemoryManager());					RTPDeleteByteArray(datacopy,GetMemoryManager());					return ERR_RTP_OUTOFMEM;				}				rawpacketlist.push_back(pack);				}		}		len = 0;		RTPIOCTL(sock,FIONREAD,&len);	}	return 0;}int RTPUDPv6Transmitter::ProcessAddAcceptIgnoreEntry(in6_addr ip,uint16_t port){	acceptignoreinfo.GotoElement(ip);	if (acceptignoreinfo.HasCurrentElement()) // An entry for this IP address already exists	{		PortInfo *portinf = acceptignoreinfo.GetCurrentElement();				if (port == 0) // select all ports		{			portinf->all = true;			portinf->portlist.clear();		}		else if (!portinf->all)		{			std::list<uint16_t>::const_iterator it,begin,end;			begin = portinf->portlist.begin();			end = portinf->portlist.end();			for (it = begin ; it != end ; it++)			{				if (*it == port) // already in list					return 0;			}			portinf->portlist.push_front(port);		}	}	else // got to create an entry for this IP address	{		PortInfo *portinf;		int status;				portinf = RTPNew(GetMemoryManager(),RTPMEM_TYPE_CLASS_ACCEPTIGNOREPORTINFO) PortInfo();		if (port == 0) // select all ports			portinf->all = true;		else			portinf->portlist.push_front(port);				status = acceptignoreinfo.AddElement(ip,portinf);		if (status < 0)		{			RTPDelete(portinf,GetMemoryManager());			return status;		}	}	return 0;}void RTPUDPv6Transmitter::ClearAcceptIgnoreInfo(){	acceptignoreinfo.GotoFirstElement();	while (acceptignoreinfo.HasCurrentElement())	{		PortInfo *inf;		inf = acceptignoreinfo.GetCurrentElement();		RTPDelete(inf,GetMemoryManager());		acceptignoreinfo.GotoNextElement();	}	acceptignoreinfo.Clear();}	int RTPUDPv6Transmitter::ProcessDeleteAcceptIgnoreEntry(in6_addr ip,uint16_t port){	acceptignoreinfo.GotoElement(ip);	if (!acceptignoreinfo.HasCurrentElement())		return ERR_RTP_UDPV6TRANS_NOSUCHENTRY;		PortInfo *inf;	inf = acceptignoreinfo.GetCurrentElement();	if (port == 0) // delete all entries	{		inf->all = false;		inf->portlist.clear();	}	else // a specific port was selected	{		if (inf->all) // currently, all ports are selected. Add the one to remove to the list		{			// we have to check if the list doesn't contain the port already			std::list<uint16_t>::const_iterator it,begin,end;			begin = inf->portlist.begin();			end = inf->portlist.end();			for (it = begin ; it != end ; it++)			{				if (*it == port) // already in list: this means we already deleted the entry					return ERR_RTP_UDPV6TRANS_NOSUCHENTRY;			}			inf->portlist.push_front(port);		}		else // check if we can find the port in the list		{			std::list<uint16_t>::iterator it,begin,end;						begin = inf->portlist.begin();			end = inf->portlist.end();			for (it = begin ; it != end ; ++it)			{				if (*it == port) // found it!				{					inf->portlist.erase(it);					return 0;				}			}			// didn't find it			return ERR_RTP_UDPV6TRANS_NOSUCHENTRY;					}	}	return 0;}bool RTPUDPv6Transmitter::ShouldAcceptData(in6_addr srcip,uint16_t srcport){	if (receivemode == RTPTransmitter::AcceptSome)	{		PortInfo *inf;		acceptignoreinfo.GotoElement(srcip);		if (!acceptignoreinfo.HasCurrentElement())			return false;				inf = acceptignoreinfo.GetCurrentElement();		if (!inf->all) // only accept the ones in the list		{			std::list<uint16_t>::const_iterator it,begin,end;			begin = inf->portlist.begin();			end = inf->portlist.end();			for (it = begin ; it != end ; it++)			{				if (*it == srcport)					return true;			}			return false;		}		else // accept all, except the ones in the list		{			std::list<uint16_t>::const_iterator it,begin,end;			begin = inf->portlist.begin();			end = inf->portlist.end();			for (it = begin ; it != end ; it++)			{				if (*it == srcport)					return false;			}			return true;		}	}	else // IgnoreSome	{		PortInfo *inf;		acceptignoreinfo.GotoElement(srcip);		if (!acceptignoreinfo.HasCurrentElement())			return true;				inf = acceptignoreinfo.GetCurrentElement();		if (!inf->all) // ignore the ports in the list		{			std::list<uint16_t>::const_iterator it,begin,end;			begin = inf->portlist.begin();			end = inf->portlist.end();			for (it = begin ; it != end ; it++)			{				if (*it == srcport)					return false;			}			return true;		}		else // ignore all, except the ones in the list		{			std::list<uint16_t>::const_iterator it,begin,end;			begin = inf->portlist.begin();			end = inf->portlist.end();			for (it = begin ; it != end ; it++)			{				if (*it == srcport)					return true;			}			return false;		}	}	return true;}#if (defined(WIN32) || defined(_WIN32_WCE))int RTPUDPv6Transmitter::CreateAbortDescriptors(){	SOCKET listensock;	int size;	struct sockaddr_in6 addr;	listensock = socket(PF_INET6,SOCK_STREAM,0);	if (listensock == RTPSOCKERR)		return ERR_RTP_UDPV6TRANS_CANTCREATEABORTDESCRIPTORS;		memset(&addr,0,sizeof(struct sockaddr_in6));	addr.sin6_family = AF_INET6;	if (bind(listensock,(struct sockaddr *)&addr,sizeof(struct sockaddr_in6)) != 0)	{		RTPCLOSE(listensock);		return ERR_RTP_UDPV6TRANS_CANTCREATEABORTDESCRIPTORS;	}	memset(&addr,0,sizeof(struct sockaddr_in6));	size = sizeof(struct sockaddr_in6);	if (getsockname(listensock,(struct sockaddr*)&addr,&size) != 0)	{		RTPCLOSE(listensock);		return ERR_RTP_UDPV6TRANS_CANTCREATEABORTDESCRIPTORS;	}	unsigned short connectport = ntohs(addr.sin6_port);	abortdesc[0] = socket(PF_INET6,SOCK_STREAM,0);	if (abortdesc[0] == RTPSOCKERR)	{		RTPCLOSE(listensock);		return ERR_RTP_UDPV6TRANS_CANTCREATEABORTDESCRIPTORS;	}	memset(&addr,0,sizeof(struct sockaddr_in6));	addr.sin6_family = AF_INET6;	if (bind(abortdesc[0],(struct sockaddr *)&addr,sizeof(struct sockaddr_in6)) != 0)	{		RTPCLOSE(listensock);		RTPCLOSE(abortdesc[0]);		return ERR_RTP_UDPV6TRANS_CANTCREATEABORTDESCRIPTORS;	}	if (listen(listensock,1) != 0)	{		RTPCLOSE(listensock);		RTPCLOSE(abortdesc[0]);		return ERR_RTP_UDPV6TRANS_CANTCREATEABORTDESCRIPTORS;	}	memset(&addr,0,sizeof(struct sockaddr_in6));	addr.sin6_family = AF_INET6;	addr.sin6_addr = in6addr_loopback;	addr.sin6_port = htons(connectport);		if (connect(abortdesc[0],(struct sockaddr *)&addr,sizeof(struct sockaddr_in6)) != 0)	{		RTPCLOSE(listensock);		RTPCLOSE(abortdesc[0]);		return ERR_RTP_UDPV6TRANS_CANTCREATEABORTDESCRIPTORS;	}	memset(&addr,0,sizeof(struct sockaddr_in6));	size = sizeof(struct sockaddr_in6);	abortdesc[1] = accept(listensock,(struct sockaddr *)&addr,&size);	if (abortdesc[1] == RTPSOCKERR)	{		RTPCLOSE(listensock);		RTPCLOSE(abortdesc[0]);		return ERR_RTP_UDPV6TRANS_CANTCREATEABORTDESCRIPTORS;	}	// okay, got the connection, close the listening socket	RTPCLOSE(listensock);	return 0;}void RTPUDPv6Transmitter::DestroyAbortDescriptors(){	RTPCLOSE(abortdesc[0]);	RTPCLOSE(abortdesc[1]);}#else // in a non winsock environment we can use pipesint RTPUDPv6Transmitter::CreateAbortDescriptors(){	if (pipe(abortdesc) < 0)		return ERR_RTP_UDPV6TRANS_CANTCREATEPIPE;	return 0;}void RTPUDPv6Transmitter::DestroyAbortDescriptors(){	close(abortdesc[0]);	close(abortdesc[1]);}#endif // WIN32int RTPUDPv6Transmitter::CreateLocalIPList(){	 // first try to obtain the list from the network interface info	if (!GetLocalIPList_Interfaces())	{		// If this fails, we'll have to depend on DNS info		GetLocalIPList_DNS();	}	AddLoopbackAddress();	return 0;}#if (defined(WIN32) || defined(_WIN32_WCE))bool RTPUDPv6Transmitter::GetLocalIPList_Interfaces(){	unsigned char buffer[RTPUDPV6TRANS_IFREQBUFSIZE];	DWORD outputsize;	DWORD numaddresses,i;	SOCKET_ADDRESS_LIST *addrlist;	if (WSAIoctl(rtpsock,SIO_ADDRESS_LIST_QUERY,NULL,0,&buffer,RTPUDPV6TRANS_IFREQBUFSIZE,&outputsize,NULL,NULL))		return false;		addrlist = (SOCKET_ADDRESS_LIST *)buffer;	numaddresses = addrlist->iAddressCount;	for (i = 0 ; i < numaddresses ; i++)	{		SOCKET_ADDRESS *sockaddr = &(addrlist->Address[i]);		if (sockaddr->iSockaddrLength == sizeof(struct sockaddr_in6)) // IPv6 address		{			struct sockaddr_in6 *addr = (struct sockaddr_in6 *)sockaddr->lpSockaddr;			localIPs.push_back(addr->sin6_addr);		}	}	if (localIPs.empty())		return false;	return true;}#else#ifdef RTP_SUPPORT_IFADDRSbool RTPUDPv6Transmitter::GetLocalIPList_Interfaces(){	struct ifaddrs *addrs,*tmp;		getifaddrs(&addrs);	tmp = addrs;		while (tmp != 0)	{		if (tmp->ifa_addr != 0 && tmp->ifa_addr->sa_family == AF_INET6)		{			struct sockaddr_in6 *inaddr = (struct sockaddr_in6 *)tmp->ifa_addr;			localIPs.push_back(inaddr->sin6_addr);		}		tmp = tmp->ifa_next;	}		freeifaddrs(addrs);		if (localIPs.empty())		return false;	return true;}#elsebool RTPUDPv6Transmitter::GetLocalIPList_Interfaces(){	return false;}#endif // RTP_SUPPORT_IFADDRS#endif // WIN32void RTPUDPv6Transmitter::GetLocalIPList_DNS(){	int status;	char name[1024];	gethostname(name,1023);	name[1023] = 0;	struct addrinfo hints;	struct addrinfo *res,*tmp;		memset(&hints,0,sizeof(struct addrinfo));	hints.ai_family = AF_INET6;	hints.ai_socktype = 0;	hints.ai_protocol = 0;	if ((status = getaddrinfo(name,0,&hints,&res)) != 0)		return;	tmp = res;	while (tmp != 0)	{		if (tmp->ai_family == AF_INET6)		{			struct sockaddr_in6 *addr = (struct sockaddr_in6 *)(tmp->ai_addr);			localIPs.push_back(addr->sin6_addr);		}		tmp = tmp->ai_next;	}		freeaddrinfo(res);	}void RTPUDPv6Transmitter::AbortWaitInternal(){#if (defined(WIN32) || defined(_WIN32_WCE))	send(abortdesc[1],"*",1,0);#else	write(abortdesc[1],"*",1);#endif // WIN32}void RTPUDPv6Transmitter::AddLoopbackAddress(){	std::list<in6_addr>::const_iterator it;	bool found = false;	for (it = localIPs.begin() ; !found && it != localIPs.end() ; it++)	{		if ((*it) == in6addr_loopback)			found = true;	}	if (!found)		localIPs.push_back(in6addr_loopback);}#ifdef RTPDEBUGvoid RTPUDPv6Transmitter::Dump(){	if (!init)		std::cout << "Not initialized" << std::endl;	else	{		MAINMUTEX_LOCK			if (!created)			std::cout << "Not created" << std::endl;		else		{			char str[48];			in6_addr ip;			uint16_t ip16[8];			std::list<in6_addr>::const_iterator it;			int i,j;						std::cout << "Portbase:                       " << portbase << std::endl;			std::cout << "RTP socket descriptor:          " << rtpsock << std::endl;			std::cout << "RTCP socket descriptor:         " << rtcpsock << std::endl;			ip = bindIP;			for (i = 0,j = 0 ; j < 8 ; j++,i += 2)	{ ip16[j] = (((uint16_t)ip.s6_addr[i])<<8); ip16[j] |= ((uint16_t)ip.s6_addr[i+1]); }			RTP_SNPRINTF(str,48,"%04X:%04X:%04X:%04X:%04X:%04X:%04X:%04X",(int)ip16[0],(int)ip16[1],(int)ip16[2],(int)ip16[3],(int)ip16[4],(int)ip16[5],(int)ip16[6],(int)ip16[7]);			std::cout << "Bind IP address:                " << str << std::endl;			std::Cout << "Multicast interface index:      " << mcastifidx << std::endl;			std::cout << "Local IP addresses:" << std::endl;			for (it = localIPs.begin() ; it != localIPs.end() ; it++)			{				ip = (*it);				for (i = 0,j = 0 ; j < 8 ; j++,i += 2)	{ ip16[j] = (((uint16_t)ip.s6_addr[i])<<8); ip16[j] |= ((uint16_t)ip.s6_addr[i+1]); }				RTP_SNPRINTF(str,48,"%04X:%04X:%04X:%04X:%04X:%04X:%04X:%04X",(int)ip16[0],(int)ip16[1],(int)ip16[2],(int)ip16[3],(int)ip16[4],(int)ip16[5],(int)ip16[6],(int)ip16[7]);				std::cout << "    " << str << std::endl;			}			std::cout << "Multicast TTL:                  " << (int)multicastTTL << std::endl;			std::cout << "Receive mode:                   ";			switch (receivemode)			{			case RTPTransmitter::AcceptAll:				std::cout << "Accept all";				break;			case RTPTransmitter::AcceptSome:				std::cout << "Accept some";				break;			case RTPTransmitter::IgnoreSome:				std::cout << "Ignore some";			}			std::cout << std::endl;			if (receivemode != RTPTransmitter::AcceptAll)			{				acceptignoreinfo.GotoFirstElement();				while(acceptignoreinfo.HasCurrentElement())				{					ip = acceptignoreinfo.GetCurrentKey();					for (i = 0,j = 0 ; j < 8 ; j++,i += 2)	{ ip16[j] = (((uint16_t)ip.s6_addr[i])<<8); ip16[j] |= ((uint16_t)ip.s6_addr[i+1]); }					RTP_SNPRINTF(str,48,"%04X:%04X:%04X:%04X:%04X:%04X:%04X:%04X",(int)ip16[0],(int)ip16[1],(int)ip16[2],(int)ip16[3],(int)ip16[4],(int)ip16[5],(int)ip16[6],(int)ip16[7]);					PortInfo *pinfo = acceptignoreinfo.GetCurrentElement();					std::cout << "    " << str << ": ";					if (pinfo->all)					{						std::cout << "All ports";						if (!pinfo->portlist.empty())							std::cout << ", except ";					}										std::list<uint16_t>::const_iterator it;										for (it = pinfo->portlist.begin() ; it != pinfo->portlist.end() ; )					{						std::cout << (*it);						it++;						if (it != pinfo->portlist.end())							std::cout << ", ";					}					std::cout << std::endl;				}			}						std::cout << "Local host name:                ";			if (localhostname == 0)				std::cout << "Not set";			else				std::cout << localhostname;			std::cout << std::endl;			std::cout << "List of destinations:           ";			destinations.GotoFirstElement();			if (destinations.HasCurrentElement())			{				std::cout << std::endl;				do				{					std::cout << "    " << destinations.GetCurrentElement().GetDestinationString() << std::endl;					destinations.GotoNextElement();				} while (destinations.HasCurrentElement());			}			else				std::cout << "Empty" << std::endl;					std::cout << "Supports multicasting:          " << ((supportsmulticasting)?"Yes":"No") << std::endl;#ifdef RTP_SUPPORT_IPV6MULTICAST			std::cout << "List of multicast groups:       ";			multicastgroups.GotoFirstElement();			if (multicastgroups.HasCurrentElement())			{				std::cout << std::endl;				do				{					ip = multicastgroups.GetCurrentElement();					for (i = 0,j = 0 ; j < 8 ; j++,i += 2)	{ ip16[j] = (((uint16_t)ip.s6_addr[i])<<8); ip16[j] |= ((uint16_t)ip.s6_addr[i+1]); }					RTP_SNPRINTF(str,48,"%04X:%04X:%04X:%04X:%04X:%04X:%04X:%04X",(int)ip16[0],(int)ip16[1],(int)ip16[2],(int)ip16[3],(int)ip16[4],(int)ip16[5],(int)ip16[6],(int)ip16[7]);					std::cout << "    " << str << std::endl;					multicastgroups.GotoNextElement();				} while (multicastgroups.HasCurrentElement());			}			else				std::cout << "Empty" << std::endl;#endif // RTP_SUPPORT_IPV6MULTICAST						std::cout << "Number of raw packets in queue: " << rawpacketlist.size() << std::endl;			std::cout << "Maximum allowed packet size:    " << maxpacksize << std::endl;		}				MAINMUTEX_UNLOCK	}}#endif // RTPDEBUG#endif // RTP_SUPPORT_IPV6