Inheritance diagram for C4PuncherServer:

Collaboration diagram for C4PuncherServer:

Public Types
typedef C4NetpuncherID::value	CID

typedef EndpointAddress	addr_t

Public Member Functions
	C4PuncherServer ()

bool	Init (uint16_t iPort=addr_t::IPPORT_NONE) override

bool	InitBroadcast (addr_t *pBroadcastAddr) override

bool	Close () override

bool	Close (const addr_t &addr) override

bool	CloseBroadcast () override

bool	Execute (int iMaxTime=TO_INF, pollfd *=nullptr) override

bool	Connect (const addr_t &addr) override

bool	Send (const C4NetIOPacket &rPacket) override

virtual bool	Send (const class C4NetIOPacket &rPacket)=0

bool	SendDirect (C4NetIOPacket &&rPacket)

bool	Broadcast (const C4NetIOPacket &rPacket) override

virtual bool	Broadcast (const class C4NetIOPacket &rPacket)=0

bool	SetBroadcast (const addr_t &addr, bool fSet=true) override

C4TimeMilliseconds	GetNextTick (C4TimeMilliseconds tNow) override

bool	GetStatistic (int *pBroadcastRate) override

bool	GetConnStatistic (const addr_t &addr, int pIRate, int pORate, int *pLoss) override

void	ClearStatistic () override

void	SetCallback (CBClass *pnCallback) override

virtual void	UnBlock ()

void	GetFDs (std::vector< struct pollfd > &FDs) override

bool	IsNotify () override

virtual const char *	GetError () const

void	ResetError ()

bool	ExecuteUntil (int iTimeout=-1)

bool	IsSignaled ()

virtual bool	IsLowPriority ()

virtual uint32_t	TimerInterval ()

Static Public Member Functions
static std::vector< HostAddress >	GetLocalAddresses ()

Static Public Attributes
static const int	TO_INF = -1

Protected Types
enum	IPTypeID { IPID_Ping = 0 , IPID_Test = 1 , IPID_Conn = 2 , IPID_ConnOK = 3 , IPID_AddAddr = 7 , IPID_Data = 4 , IPID_Check = 5 , IPID_Close = 6 }

Protected Member Functions
bool	BroadcastDirect (const Packet &rPacket, unsigned int iNr=~0u)

bool	DoLoopbackTest ()

void	ClearMCPackets ()

void	AddPeer (Peer *pPeer)

Peer *	GetPeer (const addr_t &addr)

Peer *	ConnectPeer (const addr_t &PeerAddr, bool fFailCallback)

void	OnShareFree (CStdCSecEx *pCSec) override

void	DoCheck ()

const addr_t &	getMCAddr () const

bool	SetMCLoopback (int fLoopback)

bool	getMCLoopback () const

void	SetReUseAddress (bool fAllow)

bool	InitIPv6Socket (SOCKET socket)

void	SetError (const char *strnError, bool fSockErr=false)

void	Changed ()

Protected Attributes
CStdCSecEx	PeerListCSec

CStdCSec	PeerListAddCSec

CStdCSec	OutCSec

bool	fInit {false}

bool	fMultiCast {false}

uint16_t	iPort

Peer *	pPeerList {nullptr}

bool	fSavePacket {false}

C4NetIOPacket	LastPacket

addr_t	MCLoopbackAddr

bool	fDelayedLoopbackTest {false}

C4TimeMilliseconds	tNextCheck

PacketList	OPackets

unsigned int	iOPacketCounter {0}

int	iBroadcastRate {0}

CStdCSec	StatCSec

CStdCSec	ExecuteCSec

StdCopyStrBuf	Error

Static Protected Attributes
static const unsigned int	iVersion = 2

static const unsigned int	iStdTimeout = 1000

static const unsigned int	iCheckInterval = 1000

static const unsigned int	iMaxOPacketBacklog = 10000

static const unsigned int	iUDPHeaderSize = 8 + 24

Detailed Description

Definition at line 25 of file main.cpp.

Member Typedef Documentation

◆ addr_t

typedef EndpointAddress C4NetIO::addr_t

inherited

Definition at line 213 of file C4NetIO.h.

◆ CID

typedef C4NetpuncherID::value C4PuncherServer::CID

Definition at line 28 of file main.cpp.

Member Enumeration Documentation

◆ IPTypeID

enum C4NetIOUDP::IPTypeID

protectedinherited

Enumerator
IPID_Ping
IPID_Test
IPID_Conn
IPID_ConnOK
IPID_AddAddr
IPID_Data
IPID_Check
IPID_Close

Definition at line 635 of file C4NetIO.h.

     {
         IPID_Ping = 0,
         IPID_Test = 1,
         IPID_Conn = 2,
         IPID_ConnOK = 3,
         IPID_AddAddr = 7,
         IPID_Data = 4,
         IPID_Check = 5,
         IPID_Close = 6
     };

Constructor & Destructor Documentation

◆ C4PuncherServer()

C4PuncherServer::C4PuncherServer ( )

inline

Definition at line 29 of file main.cpp.

                       {
         C4NetIOUDP::SetCallback(this);
         rng = std::bind(std::uniform_int_distribution<CID>(1/*, max*/), std::ref(random_device));
     }

References C4NetIOUDP::SetCallback().

Here is the call graph for this function:

Member Function Documentation

◆ AddPeer()

void C4NetIOUDP::AddPeer ( Peer * pPeer )

protectedinherited

Definition at line 3756 of file C4NetIO.cpp.

 {
     // get locks
     CStdShareLock PeerListLock(&PeerListCSec);
     CStdLock PeerListAddLock(&PeerListAddCSec);
     // add
     pPeer->Next = pPeerList;
     pPeerList = pPeer;
     Changed();
 }

References StdSchedulerProc::Changed(), C4NetIOUDP::Peer::Next, C4NetIOUDP::PeerListAddCSec, C4NetIOUDP::PeerListCSec, and C4NetIOUDP::pPeerList.

Referenced by C4NetIOUDP::ConnectPeer().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ Broadcast() [1/2]

bool C4NetIOUDP::Broadcast ( const C4NetIOPacket & rPacket )

overrideinherited

Definition at line 2745 of file C4NetIO.cpp.

 {
     CStdShareLock PeerListLock(&PeerListCSec);
     // search: any client reachable via multicast?
     Peer *pPeer;
     for (pPeer = pPeerList; pPeer; pPeer = pPeer->Next)
         if (pPeer->Open() && pPeer->MultiCast() && pPeer->doBroadcast())
             break;
     bool fSuccess = true;
     if (pPeer)
     {
         CStdLock OutLock(&OutCSec);
         // send it via multicast: encapsulate packet
         Packet *pPkt = new Packet(rPacket.Duplicate(), iOPacketCounter);
         iOPacketCounter += pPkt->FragmentCnt();
         // add to list
         OPackets.AddPacket(pPkt);
         // send it
         fSuccess &= BroadcastDirect(*pPkt);
     }
     // send to all clients connected via du, too
     for (pPeer = pPeerList; pPeer; pPeer = pPeer->Next)
         if (pPeer->Open() && !pPeer->MultiCast() && pPeer->doBroadcast())
             pPeer->Send(rPacket);
     return true;
 }

References C4NetIOUDP::PacketList::AddPacket(), C4NetIOUDP::BroadcastDirect(), C4NetIOUDP::Peer::doBroadcast(), C4NetIOPacket::Duplicate(), C4NetIOUDP::Packet::FragmentCnt(), C4NetIOUDP::iOPacketCounter, C4NetIOUDP::Peer::MultiCast(), C4NetIOUDP::Peer::Next, C4NetIOUDP::OPackets, C4NetIOUDP::Peer::Open(), C4NetIOUDP::OutCSec, C4NetIOUDP::Packet, C4NetIOUDP::PeerListCSec, C4NetIOUDP::pPeerList, and C4NetIOUDP::Peer::Send().

Here is the call graph for this function:

◆ Broadcast() [2/2]

virtual bool C4NetIO::Broadcast ( const class C4NetIOPacket & rPacket )

pure virtualinherited

◆ BroadcastDirect()

bool C4NetIOUDP::BroadcastDirect	(	const Packet &	rPacket,
		unsigned int	iNr = `~0u`
	)

protectedinherited

Definition at line 3660 of file C4NetIO.cpp.

 {
     // only one fragment?
     if (iNr + 1)
         return SendDirect(rPacket.GetFragment(iNr - rPacket.GetNr(), true));
     // send all fragments
     bool fSuccess = true;
     for (unsigned int iFrgm = 0; iFrgm < rPacket.FragmentCnt(); iFrgm++)
         fSuccess &= SendDirect(rPacket.GetFragment(iFrgm, true));
     return fSuccess;
 }

References C4NetIOUDP::Packet::FragmentCnt(), C4NetIOUDP::Packet::GetFragment(), C4NetIOUDP::Packet::GetNr(), and C4NetIOUDP::SendDirect().

Referenced by C4NetIOUDP::Broadcast().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ Changed()

void StdSchedulerProc::Changed ( )

protectedinherited

Definition at line 108 of file StdScheduler.cpp.

 {
     auto s = scheduler;
     if (s)
         s->Changed(this);
 }

References s.

Referenced by C4NetIOTCP::Accept(), C4NetIOTCP::AddConnectWait(), C4NetIOUDP::AddPeer(), C4NetIOTCP::Listen(), and CStdTimerProc::SetDelay().

Here is the caller graph for this function:

◆ ClearMCPackets()

void C4NetIOUDP::ClearMCPackets ( )

protectedinherited

Definition at line 3738 of file C4NetIO.cpp.

 {
     CStdShareLock PeerListLock(&PeerListCSec);
     CStdLock OutLock(&OutCSec);
     // clear packets if no client is present
     if (!pPeerList)
         OPackets.Clear();
     else
     {
         // find minimum acknowledged packet number
         unsigned int iAckNr = pPeerList->GetMCAckPacketCounter();
         for (Peer *pPeer = pPeerList->Next; pPeer; pPeer = pPeer->Next)
             iAckNr = std::min(iAckNr, pPeerList->GetMCAckPacketCounter());
         // clear packets
         OPackets.ClearPackets(iAckNr);
     }
 }

References C4NetIOUDP::PacketList::Clear(), C4NetIOUDP::PacketList::ClearPackets(), C4NetIOUDP::Peer::GetMCAckPacketCounter(), C4NetIOUDP::Peer::Next, C4NetIOUDP::OPackets, C4NetIOUDP::OutCSec, C4NetIOUDP::PeerListCSec, and C4NetIOUDP::pPeerList.

Here is the call graph for this function:

◆ ClearStatistic()

void C4NetIOUDP::ClearStatistic ( )

overridevirtualinherited

Reimplemented from C4NetIOSimpleUDP.

Definition at line 2818 of file C4NetIO.cpp.

 {
     CStdShareLock PeerListLock(&PeerListCSec);
     // clear all peer statistics
     for (Peer *pPeer = pPeerList; pPeer; pPeer = pPeer->Next)
         pPeer->ClearStatistics();
     // broadcast statistics
     CStdLock StatLock(&StatCSec);
     iBroadcastRate = 0;
 }

References C4NetIOUDP::iBroadcastRate, C4NetIOUDP::Peer::Next, C4NetIOUDP::PeerListCSec, C4NetIOUDP::pPeerList, and C4NetIOUDP::StatCSec.

◆ Close() [1/2]

bool C4NetIOUDP::Close ( )

overridevirtualinherited

Reimplemented from C4NetIOSimpleUDP.

Definition at line 2639 of file C4NetIO.cpp.

 {
     // should be initialized
     if (!fInit) return false;
  
     // close all peers
     CStdShareLock PeerListLock(&PeerListCSec);
     for (Peer *pPeer = pPeerList; pPeer; pPeer = pPeer->Next)
         pPeer->Close("owner class closed");
     PeerListLock.Clear();
  
     // deactivate multicast
     if (fMultiCast)
         CloseBroadcast();
  
     // close UDP
     bool fSuccess = C4NetIOSimpleUDP::Close();
  
 #ifdef C4NETIO_DEBUG
     // close log
     CloseDebugLog();
 #endif
  
     // ok
     fInit = false;
     return fSuccess;
 }

References CStdShareLock::Clear(), C4NetIOSimpleUDP::Close(), C4NetIOUDP::CloseBroadcast(), C4NetIOUDP::fInit, C4NetIOUDP::fMultiCast, C4NetIOUDP::Peer::Next, C4NetIOUDP::PeerListCSec, and C4NetIOUDP::pPeerList.

Referenced by C4NetIOUDP::Init(), main(), C4NetIOUDP::Peer::OnConn(), C4NetIOUDP::Peer::OnRecv(), C4NetIOUDP::Peer::OnTimeout(), C4NetIOUDP::Peer::Send(), C4NetIOUDP::~C4NetIOUDP(), and C4NetIOUDP::Peer::~Peer().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ Close() [2/2]

bool C4NetIOUDP::Close ( const addr_t & addr )

overridevirtualinherited

Reimplemented from C4NetIOSimpleUDP.

Definition at line 2723 of file C4NetIO.cpp.

 {
     CStdShareLock PeerListLock(&PeerListCSec);
     // find peer
     Peer *pPeer = GetPeer(addr);
     if (!pPeer) return false;
     // close
     pPeer->Close("closed");
     return true;
 }

References C4NetIOUDP::Peer::Close(), C4NetIOUDP::GetPeer(), and C4NetIOUDP::PeerListCSec.

Here is the call graph for this function:

◆ CloseBroadcast()

bool C4NetIOUDP::CloseBroadcast ( )

overridevirtualinherited

Reimplemented from C4NetIOSimpleUDP.

Definition at line 2667 of file C4NetIO.cpp.

 {
     ResetError();
  
     // multicast not active?
     if (!fMultiCast) return true;
  
     // ok
     fMultiCast = false;
     return C4NetIOSimpleUDP::CloseBroadcast();
 }

References C4NetIOSimpleUDP::CloseBroadcast(), C4NetIOUDP::fMultiCast, and C4NetIO::ResetError().

Referenced by C4NetIOUDP::Close(), and C4NetIOUDP::InitBroadcast().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ Connect()

bool C4NetIOUDP::Connect ( const addr_t & addr )

overridevirtualinherited

Reimplemented from C4NetIOSimpleUDP.

Definition at line 2717 of file C4NetIO.cpp.

 {
     // connect
     return !! ConnectPeer(addr, true);
 }

References C4NetIOUDP::ConnectPeer().

Referenced by main(), and C4NetIOUDP::Peer::OnRecv().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ ConnectPeer()

C4NetIOUDP::Peer * C4NetIOUDP::ConnectPeer	(	const addr_t &	PeerAddr,
		bool	fFailCallback
	)

protectedinherited

Definition at line 3803 of file C4NetIO.cpp.

 {
     CStdShareLock PeerListLock(&PeerListCSec);
     // lock so no new peer can be added after this point
     CStdLock PeerListAddLock(&PeerListAddCSec);
     // recheck: address already known?
     Peer *pnPeer = GetPeer(PeerAddr);
     if (pnPeer) return pnPeer;
     // create new Peer class
     pnPeer = new Peer(PeerAddr, this);
     if (!pnPeer) return nullptr;
     // add peer to list
     AddPeer(pnPeer);
     PeerListAddLock.Clear();
     // send connection request
     if (!pnPeer->Connect(fFailCallback)) { pnPeer->Close("connect failed"); return nullptr; }
     // ok (do not wait for peer)
     return pnPeer;
 }

References C4NetIOUDP::AddPeer(), CStdLock::Clear(), C4NetIOUDP::Peer::Close(), C4NetIOUDP::Peer::Connect(), C4NetIOUDP::GetPeer(), C4NetIOUDP::Peer, C4NetIOUDP::PeerListAddCSec, and C4NetIOUDP::PeerListCSec.

Referenced by C4NetIOUDP::Connect().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ DoCheck()

void C4NetIOUDP::DoCheck ( )

protectedinherited

Definition at line 3823 of file C4NetIO.cpp.

 {
     CStdShareLock PeerListLock(&PeerListCSec);
     // mc connection check?
     if (fMultiCast)
     {
         // only if a peer is connected via multicast
         Peer *pPeer;
         for (pPeer = pPeerList; pPeer; pPeer = pPeer->Next)
             if (pPeer->Open() && pPeer->MultiCast())
                 break;
         if (pPeer)
         {
             // set up packet
             CheckPacketHdr Pkt;
             Pkt.StatusByte = uint8_t(IPID_Check | 0x80);
             Pkt.Nr = iOPacketCounter;
             Pkt.AskCount = Pkt.MCAskCount = 0;
             // send it
             SendDirect(C4NetIOPacket(&Pkt, sizeof(Pkt)));
         }
     }
     // peer connection checks
     for (Peer *pPeer = pPeerList; pPeer; pPeer = pPeer->Next)
         if (pPeer->Open())
             pPeer->Check();
  
     // set time for next check
     tNextCheck = C4TimeMilliseconds::Now() + iCheckInterval;
 }

References C4NetIOUDP::CheckPacketHdr::AskCount, C4NetIOUDP::fMultiCast, C4NetIOUDP::iCheckInterval, C4NetIOUDP::iOPacketCounter, C4NetIOUDP::IPID_Check, C4NetIOUDP::CheckPacketHdr::MCAskCount, C4NetIOUDP::Peer::MultiCast(), C4NetIOUDP::Peer::Next, C4TimeMilliseconds::Now(), C4NetIOUDP::PacketHdr::Nr, C4NetIOUDP::Peer::Open(), C4NetIOUDP::PeerListCSec, C4NetIOUDP::pPeerList, C4NetIOUDP::SendDirect(), C4NetIOUDP::PacketHdr::StatusByte, and C4NetIOUDP::tNextCheck.

Referenced by C4NetIOUDP::Peer::Check(), and C4NetIOUDP::Execute().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ DoLoopbackTest()

bool C4NetIOUDP::DoLoopbackTest ( )

protectedinherited

Definition at line 3699 of file C4NetIO.cpp.

 {
     // (try to) enable loopback
     C4NetIOSimpleUDP::SetMCLoopback(true);
     // ensure loopback is activate
     if (!C4NetIOSimpleUDP::getMCLoopback()) return false;
  
     // send test packet
     const PacketHdr TestPacket = { uint8_t(IPID_Test | 0x80), UnsyncedRandom(UINT32_MAX) };
     if (!C4NetIOSimpleUDP::Broadcast(C4NetIOPacket(&TestPacket, sizeof(TestPacket))))
         return false;
  
     // wait for socket to become readable (should happen immediatly, do not expect packet loss)
     fSavePacket = true;
     if (!C4NetIOSimpleUDP::Execute(iStdTimeout))
     {
         fSavePacket = false;
         if (!GetError()) SetError("Multicast disabled: loopback test failed");
         return false;
     }
     fSavePacket = false;
  
     // compare it to the packet that was sent
     if (LastPacket.getSize() != sizeof(TestPacket) ||
         LastPacket.Compare(&TestPacket, sizeof(TestPacket)))
     {
         SetError("Multicast disabled: loopback test failed");
         return false;
     }
  
     // save the loopback addr back
     MCLoopbackAddr = LastPacket.getAddr();
  
     // disable loopback
     C4NetIOSimpleUDP::SetMCLoopback(false);
     // ok
     return true;
 }

References C4NetIOSimpleUDP::Broadcast(), StdBuf::Compare(), C4NetIOSimpleUDP::Execute(), C4NetIOUDP::fSavePacket, C4NetIOPacket::getAddr(), C4NetIO::GetError(), C4NetIOSimpleUDP::getMCLoopback(), StdBuf::getSize(), C4NetIOUDP::IPID_Test, C4NetIOUDP::iStdTimeout, C4NetIOUDP::LastPacket, C4NetIOUDP::MCLoopbackAddr, C4NetIO::SetError(), C4NetIOSimpleUDP::SetMCLoopback(), and UnsyncedRandom().

Referenced by C4NetIOUDP::Execute(), and C4NetIOUDP::InitBroadcast().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ Execute()

bool C4NetIOUDP::Execute	(	int	iMaxTime = `TO_INF`,
		pollfd *	= `nullptr`
	)

overridevirtualinherited

Reimplemented from C4NetIOSimpleUDP.

Definition at line 2679 of file C4NetIO.cpp.

 {
     if (!fInit) { SetError("not yet initialized"); return false; }
  
     CStdLock ExecuteLock(&ExecuteCSec);
     CStdShareLock PeerListLock(&PeerListCSec);
  
     ResetError();
  
     // adjust maximum block time
     C4TimeMilliseconds tNow = C4TimeMilliseconds::Now();
     uint32_t iMaxBlock = std::max(tNow, GetNextTick(tNow)) - tNow;
     if (iMaxTime == TO_INF || iMaxTime > (int) iMaxBlock) iMaxTime = iMaxBlock;
  
     // execute subclass
     if (!C4NetIOSimpleUDP::Execute(iMaxTime))
         return false;
  
     // connection check needed?
     if (tNextCheck <= C4TimeMilliseconds::Now())
         DoCheck();
     // client timeout?
     for (Peer *pPeer = pPeerList; pPeer; pPeer = pPeer->Next)
         if (!pPeer->Closed())
             pPeer->CheckTimeout();
  
     // do a delayed loopback test once the incoming buffer is empty
     if (fDelayedLoopbackTest)
     {
         if (fMultiCast)
             fMultiCast = DoLoopbackTest();
         fDelayedLoopbackTest = false;
     }
  
     // ok
     return true;
 }

References C4NetIOUDP::DoCheck(), C4NetIOUDP::DoLoopbackTest(), C4NetIOSimpleUDP::Execute(), C4NetIOUDP::ExecuteCSec, C4NetIOUDP::fDelayedLoopbackTest, C4NetIOUDP::fInit, C4NetIOUDP::fMultiCast, C4NetIOUDP::GetNextTick(), C4NetIOUDP::Peer::Next, C4TimeMilliseconds::Now(), C4NetIOUDP::PeerListCSec, C4NetIOUDP::pPeerList, C4NetIO::ResetError(), C4NetIO::SetError(), C4NetIOUDP::tNextCheck, and C4NetIO::TO_INF.

Here is the call graph for this function:

◆ ExecuteUntil()

bool StdSchedulerProc::ExecuteUntil ( int iTimeout = -1 )

inherited

Definition at line 33 of file StdScheduler.cpp.

 {
     // Infinite?
     if (iTimeout < 0)
         for (;;)
             if (!Execute())
                 return false;
     // Calculate endpoint
     C4TimeMilliseconds tStopTime = C4TimeMilliseconds::Now() + iTimeout;
     for (;;)
     {
         // Call execute with given timeout
         if (!Execute(std::max(iTimeout, 0)))
             return false;
         // Calculate timeout
         C4TimeMilliseconds tTime = C4TimeMilliseconds::Now();
         if (tTime >= tStopTime)
             break;
         iTimeout = tStopTime - tTime;
     }
     // All ok.
     return true;
 }

References StdSchedulerProc::Execute(), and C4TimeMilliseconds::Now().

Referenced by main().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ GetConnStatistic()

bool C4NetIOUDP::GetConnStatistic	(	const addr_t &	addr,
		int *	pIRate,
		int *	pORate,
		int *	pLoss
	)

overridevirtualinherited

Reimplemented from C4NetIOSimpleUDP.

Definition at line 2805 of file C4NetIO.cpp.

 {
     CStdShareLock PeerListLock(&PeerListCSec);
     // find peer
     Peer *pPeer = GetPeer(addr);
     if (!pPeer || !pPeer->Open()) return false;
     // return statistics
     if (pIRate) *pIRate = pPeer->GetIRate();
     if (pORate) *pORate = pPeer->GetORate();
     if (pLoss) *pLoss = 0;
     return true;
 }

References C4NetIOUDP::Peer::GetIRate(), C4NetIOUDP::Peer::GetORate(), C4NetIOUDP::GetPeer(), C4NetIOUDP::Peer::Open(), and C4NetIOUDP::PeerListCSec.

Here is the call graph for this function:

◆ GetError()

virtual const char* C4NetIO::GetError ( ) const

inlinevirtualinherited

Definition at line 286 of file C4NetIO.h.

286 { return Error.getData(); }

C4NetIO::Error

StdCopyStrBuf Error

Definition: C4NetIO.h:283

StdStrBuf::getData

const char * getData() const

Definition: StdBuf.h:442

References C4NetIO::Error, and StdStrBuf::getData().

Referenced by C4Network2IO::ConnectWithSocket(), C4NetIOUDP::DoLoopbackTest(), C4StartupNetDlg::DoRefresh(), C4Network2IO::Init(), C4NetIOUDP::InitBroadcast(), main(), MyCBClass::OnConn(), C4ChatControl::OnConnectBtn(), MyCBClass::OnPacket(), C4ChatControl::ProcessInput(), and C4Network2IOConnection::Send().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ GetFDs()

void C4NetIOSimpleUDP::GetFDs ( std::vector< struct pollfd > & FDs )

overridevirtualinherited

Reimplemented from StdSchedulerProc.

Definition at line 2252 of file C4NetIO.cpp.

 {
     // add pipe
     pollfd pfd = { Pipe[0], POLLIN, 0 };
     fds.push_back(pfd);
     // add socket
     if (sock != INVALID_SOCKET)
     {
         pollfd pfd = { sock, POLLIN, 0 };
         fds.push_back(pfd);
     }
 }

References INVALID_SOCKET.

◆ GetLocalAddresses()

std::vector< C4NetIO::HostAddress > C4NetIO::GetLocalAddresses ( )

staticinherited

Definition at line 631 of file C4NetIO.cpp.

 {
     std::vector<HostAddress> result;
  
 #ifdef HAVE_WINSOCK
     HostAddress addr;
     const size_t BUFFER_SIZE = 16000;
     PIP_ADAPTER_ADDRESSES addresses = nullptr;
     for (int i = 0; i < 3; ++i)
     {
         addresses = (PIP_ADAPTER_ADDRESSES) realloc(addresses, BUFFER_SIZE * (i+1));
         if (!addresses)
             // allocation failed
             return result;
         ULONG bufsz = BUFFER_SIZE * (i+1);
         DWORD rv = GetAdaptersAddresses(AF_UNSPEC,
             GAA_FLAG_SKIP_ANYCAST|GAA_FLAG_SKIP_MULTICAST|GAA_FLAG_SKIP_DNS_SERVER|GAA_FLAG_SKIP_FRIENDLY_NAME,
             nullptr, addresses, &bufsz);
         if (rv == ERROR_BUFFER_OVERFLOW)
             // too little space, try again
             continue;
         if (rv != NO_ERROR)
         {
             // Something else happened
             free(addresses);
             return result;
         }
         // All okay, add addresses
         for (PIP_ADAPTER_ADDRESSES address = addresses; address; address = address->Next)
         {
             for (PIP_ADAPTER_UNICAST_ADDRESS unicast = address->FirstUnicastAddress; unicast; unicast = unicast->Next)
             {
                 addr.SetHost(unicast->Address.lpSockaddr);
                 if (addr.IsLoopback())
                     continue;
                 result.push_back(addr);
             }
         }
     }
     free(addresses);
 #else
     bool have_ipv6 = false;
  
 #ifdef __linux__
     // Get IPv6 addresses on Linux from procfs which allows filtering deprecated privacy addresses.
     FILE *f = fopen("/proc/net/if_inet6", "r");
     if (f)
     {
         sockaddr_in6 sa6 = sockaddr_in6();
         sa6.sin6_family = AF_INET6;
         auto a6 = sa6.sin6_addr.s6_addr;
         uint8_t if_idx, plen, scope, flags;
         char devname[20];
         while (fscanf(f, "%2hhx%2hhx%2hhx%2hhx%2hhx%2hhx%2hhx%2hhx%2hhx%2hhx%2hhx%2hhx%2hhx%2hhx%2hhx%2hhx %02hhx %02hhx %02hhx %02hhx %20s\n",
                     &a6[0], &a6[1], &a6[2],  &a6[3],  &a6[4],  &a6[5],  &a6[6],  &a6[7],
                     &a6[8], &a6[9], &a6[10], &a6[11], &a6[12], &a6[13], &a6[14], &a6[15],
                     &if_idx, &plen, &scope, &flags, devname) != EOF)
         {
             // Skip loopback and deprecated addresses.
             if (scope == IPV6_ADDR_LOOPBACK || flags & IFA_F_DEPRECATED)
                 continue;
             sa6.sin6_scope_id = scope == IPV6_ADDR_LINKLOCAL ? if_idx : 0;
             result.emplace_back((sockaddr*) &sa6);
         }
         have_ipv6 = result.size() > 0;
         fclose(f);
     }
 #endif
  
     struct ifaddrs* addrs;
     if (getifaddrs(&addrs) < 0)
         return result;
     for (struct ifaddrs* ifaddr = addrs; ifaddr != nullptr; ifaddr = ifaddr->ifa_next)
     {
         struct sockaddr* ad = ifaddr->ifa_addr;
         if (ad == nullptr) continue;
  
         if ((ad->sa_family == AF_INET || (!have_ipv6 && ad->sa_family == AF_INET6)) && (~ifaddr->ifa_flags & IFF_LOOPBACK)) // Choose only non-loopback IPv4/6 devices
         {
             result.emplace_back(ad);
         }
     }
     freeifaddrs(addrs);
 #endif
  
     return result;
 }

References C4NetIO::HostAddress::IsLoopback(), and C4NetIO::HostAddress::SetHost().

Referenced by C4Network2Client::AddLocalAddrs(), and C4NetIOUDP::InitBroadcast().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ getMCAddr()

const addr_t& C4NetIOSimpleUDP::getMCAddr ( ) const

inlineprotectedinherited

Definition at line 573 of file C4NetIO.h.

573 { return MCAddr; }

Referenced by C4NetIOUDP::SendDirect().

Here is the caller graph for this function:

◆ getMCLoopback()

bool C4NetIOSimpleUDP::getMCLoopback ( ) const

inlineprotectedinherited

Definition at line 577 of file C4NetIO.h.

577 { return fMCLoopback; }

Referenced by C4NetIOUDP::DoLoopbackTest(), and C4NetIOUDP::InitBroadcast().

Here is the caller graph for this function:

◆ GetNextTick()

C4TimeMilliseconds C4NetIOUDP::GetNextTick ( C4TimeMilliseconds tNow )

overridevirtualinherited

Reimplemented from StdSchedulerProc.

Definition at line 2783 of file C4NetIO.cpp.

 {
     // maximum time: check interval
     C4TimeMilliseconds tTiming = tNextCheck.IsInfinite() ? tNow : std::max(tNow, tNextCheck);
     
     // client timeouts (e.g. connection timeout)
     CStdShareLock PeerListLock(&PeerListCSec);
     for (Peer *pPeer = pPeerList; pPeer; pPeer = pPeer->Next)
         if (!pPeer->Closed())
             if (!pPeer->GetTimeout().IsInfinite())
                 tTiming = std::min(tTiming, pPeer->GetTimeout());
     // return timing value
     return tTiming;
 }

References C4TimeMilliseconds::IsInfinite(), C4NetIOUDP::Peer::Next, C4NetIOUDP::PeerListCSec, C4NetIOUDP::pPeerList, and C4NetIOUDP::tNextCheck.

Referenced by C4NetIOUDP::Execute().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ GetPeer()

C4NetIOUDP::Peer * C4NetIOUDP::GetPeer ( const addr_t & addr )

protectedinherited

Definition at line 3793 of file C4NetIO.cpp.

 {
     CStdShareLock PeerListLock(&PeerListCSec);
     for (Peer *pPeer = pPeerList; pPeer; pPeer = pPeer->Next)
         if (!pPeer->Closed())
             if (pPeer->GetAddr() == addr || pPeer->GetAltAddr() == addr)
                 return pPeer;
     return nullptr;
 }

References C4NetIOUDP::Peer::Next, C4NetIOUDP::PeerListCSec, and C4NetIOUDP::pPeerList.

Referenced by C4NetIOUDP::Close(), C4NetIOUDP::ConnectPeer(), C4NetIOUDP::GetConnStatistic(), C4NetIOUDP::Send(), and C4NetIOUDP::SetBroadcast().

Here is the caller graph for this function:

◆ GetStatistic()

bool C4NetIOUDP::GetStatistic ( int * pBroadcastRate )

overridevirtualinherited

Reimplemented from C4NetIOSimpleUDP.

Definition at line 2798 of file C4NetIO.cpp.

 {
     CStdLock StatLock(&StatCSec);
     if (pBroadcastRate) *pBroadcastRate = iBroadcastRate;
     return true;
 }

References C4NetIOUDP::iBroadcastRate, and C4NetIOUDP::StatCSec.

◆ Init()

bool C4NetIOUDP::Init ( uint16_t iPort = addr_t::IPPORT_NONE )

overridevirtualinherited

Reimplemented from C4NetIOSimpleUDP.

Definition at line 2472 of file C4NetIO.cpp.

 {
     // already initialized? close first
     if (fInit) Close();
  
 #ifdef C4NETIO_DEBUG
     // open log
     OpenDebugLog();
 #endif
  
     // Initialize UDP
     if (!C4NetIOSimpleUDP::Init(inPort))
         return false;
     iPort = inPort;
  
     // set callback
     C4NetIOSimpleUDP::SetCallback(CBProxy(this));
  
     // set flags
     fInit = true;
     fMultiCast = false;
  
     tNextCheck = C4TimeMilliseconds::Now() + iCheckInterval;
  
     // ok, that's all for now.
     // call InitBroadcast for more initialization fun
     return true;
 }

References C4NetIOUDP::Close(), C4NetIOUDP::fInit, C4NetIOUDP::fMultiCast, C4NetIOUDP::iCheckInterval, C4NetIOSimpleUDP::Init(), C4NetIOUDP::iPort, C4TimeMilliseconds::Now(), C4NetIOSimpleUDP::SetCallback(), and C4NetIOUDP::tNextCheck.

Referenced by main().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ InitBroadcast()

bool C4NetIOUDP::InitBroadcast ( addr_t * pBroadcastAddr )

overridevirtualinherited

Reimplemented from C4NetIOSimpleUDP.

Definition at line 2501 of file C4NetIO.cpp.

 {
     // no error... yet
     ResetError();
  
     // security
     if (!pBroadcastAddr) return false;
  
     // Init() has to be called first
     if (!fInit) return false;
     // already activated?
     if (fMultiCast) CloseBroadcast();
  
     // set up multicast group information
     C4NetIO::addr_t MCAddr = *pBroadcastAddr;
  
     // broadcast addr valid?
     if (!MCAddr.IsMulticast())
     {
         // port is needed in order to search a mc address automatically
         if (!iPort)
         {
             SetError("broadcast address is not valid");
             return false;
         }
         // Set up address as unicast-prefix-based IPv6 multicast address (RFC 3306).
         sockaddr_in6 saddrgen = sockaddr_in6();
         saddrgen.sin6_family = AF_INET6;
         uint8_t *addrgen = saddrgen.sin6_addr.s6_addr;
         // ff3e ("global multicast based on network prefix") : 64 (length of network prefix)
         static const uint8_t mcast_prefix[4] = { 0xff, 0x3e, 0, 64};
         memcpy(addrgen, mcast_prefix, sizeof(mcast_prefix));
         addrgen += sizeof(mcast_prefix);
         // 64 bit network prefix
         addr_t prefixAddr;
         for (auto& addr : GetLocalAddresses())
             if (addr.GetFamily() == HostAddress::IPv6 && !addr.IsLocal())
             {
                 prefixAddr.SetAddress(addr);
                 break;
             }
         if (prefixAddr.IsNull())
         {
             SetError("no IPv6 unicast address available");
             return false;
         }
         static const size_t network_prefix_size = 8;
         memcpy(addrgen, &static_cast<sockaddr_in6*>(&prefixAddr)->sin6_addr, network_prefix_size);
         addrgen += network_prefix_size;
         // 32 bit group id: search for a free one
         for (int iRetries = 1000; iRetries; iRetries--)
         {
             uint32_t rnd = UnsyncedRandom();
             memcpy(addrgen, &rnd, sizeof(rnd));
             // "high-order bit of the Group ID will be the same value as the T flag"
             addrgen[0] |= 0x80;
             // create new - random - address
             MCAddr.SetAddress((sockaddr*) &saddrgen);
             MCAddr.SetPort(iPort);
             // init broadcast
             if (!C4NetIOSimpleUDP::InitBroadcast(&MCAddr))
                 return false;
             // do the loopback test
             if (!DoLoopbackTest())
             {
                 C4NetIOSimpleUDP::CloseBroadcast();
                 if (!GetError()) SetError("multicast loopback test failed");
                 return false;
             }
             // send a ping packet
             const PacketHdr PingPacket = { IPID_Ping | static_cast<uint8_t>(0x80u), 0 };
             if (!C4NetIOSimpleUDP::Broadcast(C4NetIOPacket(&PingPacket, sizeof(PingPacket))))
             {
                 C4NetIOSimpleUDP::CloseBroadcast();
                 return false;
             }
             bool fSuccess = false;
             for (;;)
             {
                 fSavePacket = true; LastPacket.Clear();
                 // wait for something to happen
                 if (!C4NetIOSimpleUDP::Execute(iStdTimeout))
                 {
                     fSavePacket = false;
                     C4NetIOSimpleUDP::CloseBroadcast();
                     return false;
                 }
                 fSavePacket = false;
                 // Timeout? So expect this address to be unused
                 if (LastPacket.isNull()) { fSuccess = true; break; }
                 // looped back?
                 if (C4NetIOSimpleUDP::getMCLoopback() && LastPacket.getAddr() == MCLoopbackAddr)
                     // ignore this one
                     continue;
                 // otherwise: there must be someone else in this MC group
                 C4NetIOSimpleUDP::CloseBroadcast();
                 break;
             }
             if (fSuccess) break;
             // no success? try again...
         }
  
         // return found address
         *pBroadcastAddr = MCAddr;
     }
     else
     {
         // check: must be same port
         if (MCAddr.GetPort() == iPort)
         {
             SetError("invalid multicast address: wrong port");
             return false;
         }
         // init
         if (!C4NetIOSimpleUDP::InitBroadcast(&MCAddr))
             return false;
         // do loopback test (if not delayed)
         if (!fDelayedLoopbackTest)
             if (!DoLoopbackTest())
             {
                 C4NetIOSimpleUDP::CloseBroadcast();
                 if (!GetError()) SetError("multicast loopback test failed");
                 return false;
             }
     }
  
     // (try to) disable multicast loopback
     C4NetIOSimpleUDP::SetMCLoopback(false);
  
     // set flags
     fMultiCast = true;
     iOPacketCounter = 0;
     iBroadcastRate = 0;
  
     // ok
     return true;
 }

References C4NetIOSimpleUDP::Broadcast(), C4NetIOPacket::Clear(), C4NetIOSimpleUDP::CloseBroadcast(), C4NetIOUDP::CloseBroadcast(), C4NetIOUDP::DoLoopbackTest(), C4NetIOSimpleUDP::Execute(), C4NetIOUDP::fDelayedLoopbackTest, C4NetIOUDP::fInit, C4NetIOUDP::fMultiCast, C4NetIOUDP::fSavePacket, C4NetIOPacket::getAddr(), C4NetIO::GetError(), C4NetIO::GetLocalAddresses(), C4NetIOSimpleUDP::getMCLoopback(), C4NetIO::EndpointAddress::GetPort(), C4NetIOUDP::iBroadcastRate, C4NetIOSimpleUDP::InitBroadcast(), C4NetIOUDP::iOPacketCounter, C4NetIOUDP::IPID_Ping, C4NetIOUDP::iPort, C4NetIO::HostAddress::IPv6, C4NetIO::HostAddress::IsMulticast(), StdBuf::isNull(), C4NetIO::EndpointAddress::IsNull(), C4NetIOUDP::iStdTimeout, C4NetIOUDP::LastPacket, C4NetIOUDP::MCLoopbackAddr, C4NetIO::ResetError(), C4NetIO::EndpointAddress::SetAddress(), C4NetIO::SetError(), C4NetIOSimpleUDP::SetMCLoopback(), C4NetIO::EndpointAddress::SetPort(), and UnsyncedRandom().

Referenced by main().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ InitIPv6Socket()

bool C4NetIO::InitIPv6Socket ( SOCKET socket )

protectedinherited

Definition at line 730 of file C4NetIO.cpp.

 {
     int opt = 0;
     if (setsockopt(socket, IPPROTO_IPV6, IPV6_V6ONLY, reinterpret_cast<char*>(&opt), sizeof(opt)) == SOCKET_ERROR)
     {
         SetError("could not enable dual-stack socket", true);
         return false;
     }
  
 #ifdef IPV6_ADDR_PREFERENCES
     // Prefer stable addresses. This should prevent issues with address
     // deprecation while a match is running. No error handling - if the call
     // fails, we just take any address.
     opt = IPV6_PREFER_SRC_PUBLIC;
     setsockopt(socket, IPPROTO_IPV6, IPV6_ADDR_PREFERENCES, reinterpret_cast<char*>(&opt), sizeof(opt));
 #endif
  
     return true;
 }

References C4NetIO::SetError(), and SOCKET_ERROR.

Referenced by C4NetIOTCP::CreateSocket(), C4NetIOSimpleUDP::Init(), and C4NetIOTCP::Listen().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ IsLowPriority()

virtual bool StdSchedulerProc::IsLowPriority ( )

inlinevirtualinherited

Definition at line 82 of file StdScheduler.h.

82 { return false; }

◆ IsNotify()

bool C4NetIO::IsNotify ( )

inlineoverridevirtualinherited

Reimplemented from StdSchedulerProc.

Definition at line 260 of file C4NetIO.h.

260 { return true; }

◆ IsSignaled()

bool StdSchedulerProc::IsSignaled ( )

inherited

◆ OnShareFree()

void C4NetIOUDP::OnShareFree ( CStdCSecEx * pCSec )

overrideprotectedvirtualinherited

Implements CStdCSecExCallback.

Definition at line 3767 of file C4NetIO.cpp.

 {
     if (pCSec == &PeerListCSec)
     {
         Peer *pPeer = pPeerList, *pLast = nullptr;
         while (pPeer)
         {
             // delete?
             if (pPeer->Closed())
             {
                 // unlink
                 Peer *pDelete = pPeer;
                 (pLast ? pLast->Next : pPeerList) = pPeer = pPeer->Next;
                 // delete
                 delete pDelete;
             }
             else
             {
                 // next peer
                 pLast = pPeer;
                 pPeer = pPeer->Next;
             }
         }
     }
 }

References C4NetIOUDP::Peer::Closed(), C4NetIOUDP::Peer::Next, C4NetIOUDP::PeerListCSec, and C4NetIOUDP::pPeerList.

Here is the call graph for this function:

◆ ResetError()

void C4NetIO::ResetError ( )

inlineinherited

Definition at line 287 of file C4NetIO.h.

287 { Error.Clear(); }

StdStrBuf::Clear

void Clear()

Definition: StdBuf.h:466

References StdStrBuf::Clear(), and C4NetIO::Error.

Referenced by C4NetIO::C4NetIO(), C4NetIOTCP::Close(), C4NetIOSimpleUDP::Close(), C4NetIOUDP::CloseBroadcast(), C4Network2IO::ConnectWithSocket(), C4NetIOSimpleUDP::Execute(), C4NetIOUDP::Execute(), C4NetIOSimpleUDP::Init(), C4NetIOSimpleUDP::InitBroadcast(), C4NetIOUDP::InitBroadcast(), C4NetIOSimpleUDP::Send(), and C4Network2IOConnection::Send().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ Send() [1/2]

bool C4NetIOUDP::Send ( const C4NetIOPacket & rPacket )

overrideinherited

Definition at line 2734 of file C4NetIO.cpp.

 {
     // find Peer class for given address
     CStdShareLock PeerListLock(&PeerListCSec);
     Peer *pPeer = GetPeer(rPacket.getAddr());
     // not found?
     if (!pPeer) return false;
     // send the packet
     return pPeer->Send(rPacket);
 }

References C4NetIOPacket::getAddr(), C4NetIOUDP::GetPeer(), C4NetIOUDP::PeerListCSec, and C4NetIOUDP::Peer::Send().

Here is the call graph for this function:

◆ Send() [2/2]

virtual bool C4NetIO::Send ( const class C4NetIOPacket & rPacket )

pure virtualinherited

Referenced by main(), MyCBClass::OnConn(), MyCBClass::OnPacket(), C4Network2IOConnection::Send(), and C4Network2IO::SendPuncherPacket().

Here is the caller graph for this function:

◆ SendDirect()

bool C4NetIOUDP::SendDirect ( C4NetIOPacket && rPacket )

inherited

Definition at line 3672 of file C4NetIO.cpp.

 {
     addr_t toaddr = rPacket.getAddr();
     // packet meant to be broadcasted?
     if (rPacket.getStatus() & 0x80)
     {
         // set addr
         toaddr = C4NetIOSimpleUDP::getMCAddr();
         // statistics
         CStdLock StatLock(&StatCSec);
         iBroadcastRate += rPacket.getSize() + iUDPHeaderSize;
     }
  
     // debug
 #ifdef C4NETIO_DEBUG
     { C4NetIOPacket Pkt2 = rPacket; Pkt2.SetAddr(toaddr); DebugLogPkt(true, Pkt2); }
 #endif
  
 #ifdef C4NETIO_SIMULATE_PACKETLOSS
     if ((rPacket.getStatus() & 0x7F) != IPID_Test)
         if (UnsyncedRandom(100) < C4NETIO_SIMULATE_PACKETLOSS) return true;
 #endif
  
     // send it
     return C4NetIOSimpleUDP::Send(C4NetIOPacket(rPacket.getRef(), toaddr));
 }

References C4NetIOSimpleUDP::getMCAddr(), C4NetIOUDP::iBroadcastRate, C4NetIOUDP::IPID_Test, C4NetIOUDP::iUDPHeaderSize, C4NetIOSimpleUDP::Send(), C4NetIOPacket::SetAddr(), C4NetIOUDP::StatCSec, and UnsyncedRandom().

Referenced by C4NetIOUDP::BroadcastDirect(), C4NetIOUDP::Peer::Close(), C4NetIOUDP::DoCheck(), C4NetIOUDP::Peer::DoCheck(), C4NetIOUDP::Peer::DoConn(), C4NetIOUDP::Peer::OnRecv(), C4NetIOUDP::Peer::Send(), and C4NetIOUDP::Peer::SendDirect().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ SetBroadcast()

bool C4NetIOUDP::SetBroadcast	(	const addr_t &	addr,
		bool	fSet = `true`
	)

overridevirtualinherited

Reimplemented from C4NetIOSimpleUDP.

Definition at line 2772 of file C4NetIO.cpp.

 {
     CStdShareLock PeerListLock(&PeerListCSec);
     // find peer
     Peer *pPeer = GetPeer(addr);
     if (!pPeer) return false;
     // set flag
     pPeer->SetBroadcast(fSet);
     return true;
 }

References C4NetIOUDP::GetPeer(), C4NetIOUDP::PeerListCSec, and C4NetIOUDP::Peer::SetBroadcast().

Here is the call graph for this function:

◆ SetCallback()

void C4NetIOUDP::SetCallback ( CBClass * pnCallback )

inlineoverridevirtualinherited

Reimplemented from C4NetIOSimpleUDP.

Definition at line 937 of file C4NetIO.h.

937 { pCB = pnCallback; };

Referenced by C4PuncherServer().

Here is the caller graph for this function:

◆ SetError()

void C4NetIO::SetError	(	const char *	strnError,
		bool	fSockErr = `false`
	)

protectedinherited

Definition at line 750 of file C4NetIO.cpp.

 {
     fSockErr &= HaveSocketError();
     if (fSockErr)
         Error.Format("%s (%s)", strnError, GetSocketErrorMsg());
     else
         Error.Copy(strnError);
 }

References StdStrBuf::Copy(), C4NetIO::Error, StdStrBuf::Format(), GetSocketErrorMsg(), and HaveSocketError().

Referenced by C4NetIOTCP::Accept(), C4NetIOTCP::Bind(), C4NetIOSimpleUDP::CloseBroadcast(), C4NetIOTCP::Connect(), C4Network2IRCClient::Connect(), C4NetIOTCP::CreateSocket(), C4NetIOUDP::DoLoopbackTest(), C4NetIOSimpleUDP::Execute(), C4NetIOUDP::Execute(), C4NetIOTCP::Execute(), C4NetIOTCP::Init(), C4NetIOSimpleUDP::Init(), C4NetIOSimpleUDP::InitBroadcast(), C4NetIOUDP::InitBroadcast(), C4NetIO::InitIPv6Socket(), C4Network2IRCClient::Join(), C4NetIOTCP::Listen(), C4NetIOSimpleUDP::Send(), C4Network2IRCClient::Send(), C4NetIOTCP::UnBlock(), and C4NetIOSimpleUDP::UnBlock().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ SetMCLoopback()

bool C4NetIOSimpleUDP::SetMCLoopback ( int fLoopback )

protectedinherited

Definition at line 2290 of file C4NetIO.cpp.

 {
     // enable/disable MC loopback
     setsockopt(sock, IPPROTO_IPV6, IPV6_MULTICAST_LOOP, reinterpret_cast<char *>(&fLoopback), sizeof fLoopback);
     // read result
     socklen_t iSize = sizeof(fLoopback);
     if (getsockopt(sock, IPPROTO_IPV6, IPV6_MULTICAST_LOOP, reinterpret_cast<char *>(&fLoopback), &iSize) == SOCKET_ERROR)
         return false;
     fMCLoopback = !! fLoopback;
     return true;
 }

References iSize, and SOCKET_ERROR.

Referenced by C4NetIOUDP::DoLoopbackTest(), C4Network2IODiscover::Init(), C4Network2IODiscoverClient::Init(), C4NetIOSimpleUDP::InitBroadcast(), and C4NetIOUDP::InitBroadcast().

Here is the caller graph for this function:

◆ SetReUseAddress()

void C4NetIOSimpleUDP::SetReUseAddress ( bool fAllow )

protectedinherited

Definition at line 2302 of file C4NetIO.cpp.

 {
     fAllowReUse = fAllow;
 }

Referenced by C4Network2IODiscover::Init(), and C4Network2IODiscoverClient::Init().

Here is the caller graph for this function:

◆ TimerInterval()

virtual uint32_t StdSchedulerProc::TimerInterval ( )

inlinevirtualinherited

Reimplemented in CStdTimerProc.

Definition at line 84 of file StdScheduler.h.

84 { return 0; }

◆ UnBlock()

void C4NetIOSimpleUDP::UnBlock ( )

virtualinherited

Definition at line 2243 of file C4NetIO.cpp.

 {
     // write one character to the pipe, this will unblock everything that
     // waits for the FD set returned by GetFDs.
     char c = 42;
     if (write(Pipe[1], &c, 1) == -1)
         SetError("write failed");
 }

References C4NetIO::SetError().

Here is the call graph for this function:

Member Data Documentation

◆ Error

StdCopyStrBuf C4NetIO::Error

protectedinherited

Definition at line 283 of file C4NetIO.h.

Referenced by C4NetIO::GetError(), C4NetIO::ResetError(), and C4NetIO::SetError().

◆ ExecuteCSec

CStdCSec C4NetIOUDP::ExecuteCSec

protectedinherited

Definition at line 925 of file C4NetIO.h.

Referenced by C4NetIOUDP::Execute().

◆ fDelayedLoopbackTest

bool C4NetIOUDP::fDelayedLoopbackTest {false}

protectedinherited

Definition at line 890 of file C4NetIO.h.

Referenced by C4NetIOUDP::Execute(), and C4NetIOUDP::InitBroadcast().

◆ fInit

bool C4NetIOUDP::fInit {false}

protectedinherited

Definition at line 877 of file C4NetIO.h.

Referenced by C4NetIOUDP::Close(), C4NetIOUDP::Execute(), C4NetIOUDP::Init(), and C4NetIOUDP::InitBroadcast().

◆ fMultiCast

bool C4NetIOUDP::fMultiCast {false}

protectedinherited

Definition at line 878 of file C4NetIO.h.

Referenced by C4NetIOUDP::Close(), C4NetIOUDP::CloseBroadcast(), C4NetIOUDP::Peer::Connect(), C4NetIOUDP::DoCheck(), C4NetIOUDP::Execute(), C4NetIOUDP::Init(), C4NetIOUDP::InitBroadcast(), C4NetIOUDP::Peer::OnRecv(), and C4NetIOUDP::Peer::OnTimeout().

◆ fSavePacket

bool C4NetIOUDP::fSavePacket {false}

protectedinherited

Definition at line 885 of file C4NetIO.h.

Referenced by C4NetIOUDP::DoLoopbackTest(), and C4NetIOUDP::InitBroadcast().

◆ iBroadcastRate

int C4NetIOUDP::iBroadcastRate {0}

protectedinherited

Definition at line 900 of file C4NetIO.h.

Referenced by C4NetIOUDP::ClearStatistic(), C4NetIOUDP::GetStatistic(), C4NetIOUDP::InitBroadcast(), and C4NetIOUDP::SendDirect().

◆ iCheckInterval

const unsigned int C4NetIOUDP::iCheckInterval = 1000

staticprotectedinherited

Definition at line 656 of file C4NetIO.h.

Referenced by C4NetIOUDP::DoCheck(), and C4NetIOUDP::Init().

◆ iMaxOPacketBacklog

const unsigned int C4NetIOUDP::iMaxOPacketBacklog = 10000

staticprotectedinherited

Definition at line 658 of file C4NetIO.h.

◆ iOPacketCounter

unsigned int C4NetIOUDP::iOPacketCounter {0}

protectedinherited

Definition at line 897 of file C4NetIO.h.

Referenced by C4NetIOUDP::Broadcast(), C4NetIOUDP::DoCheck(), C4NetIOUDP::Peer::DoCheck(), C4NetIOUDP::Peer::DoConn(), C4NetIOUDP::InitBroadcast(), C4NetIOUDP::Peer::OnRecv(), and C4NetIOUDP::Peer::Send().

◆ iPort

uint16_t C4NetIOUDP::iPort

protectedinherited

Definition at line 879 of file C4NetIO.h.

Referenced by C4NetIOUDP::Init(), and C4NetIOUDP::InitBroadcast().

◆ iStdTimeout

const unsigned int C4NetIOUDP::iStdTimeout = 1000

staticprotectedinherited

Definition at line 655 of file C4NetIO.h.

Referenced by C4NetIOUDP::Peer::DoConn(), C4NetIOUDP::DoLoopbackTest(), and C4NetIOUDP::InitBroadcast().

◆ iUDPHeaderSize

const unsigned int C4NetIOUDP::iUDPHeaderSize = 8 + 24

staticprotectedinherited

Definition at line 660 of file C4NetIO.h.

Referenced by C4NetIOUDP::Peer::OnRecv(), C4NetIOUDP::SendDirect(), and C4NetIOUDP::Peer::SendDirect().

◆ iVersion

const unsigned int C4NetIOUDP::iVersion = 2

staticprotectedinherited

Definition at line 653 of file C4NetIO.h.

◆ LastPacket

C4NetIOPacket C4NetIOUDP::LastPacket

protectedinherited

Definition at line 886 of file C4NetIO.h.

Referenced by C4NetIOUDP::DoLoopbackTest(), and C4NetIOUDP::InitBroadcast().

◆ MCLoopbackAddr

addr_t C4NetIOUDP::MCLoopbackAddr

protectedinherited

Definition at line 889 of file C4NetIO.h.

Referenced by C4NetIOUDP::DoLoopbackTest(), and C4NetIOUDP::InitBroadcast().

◆ OPackets

PacketList C4NetIOUDP::OPackets

protectedinherited

Definition at line 896 of file C4NetIO.h.

Referenced by C4NetIOUDP::Broadcast(), C4NetIOUDP::ClearMCPackets(), C4NetIOUDP::Peer::OnRecv(), and C4NetIOUDP::Peer::Send().

◆ OutCSec

CStdCSec C4NetIOUDP::OutCSec

protectedinherited

Definition at line 874 of file C4NetIO.h.

Referenced by C4NetIOUDP::Broadcast(), C4NetIOUDP::ClearMCPackets(), C4NetIOUDP::Peer::OnRecv(), and C4NetIOUDP::Peer::Send().

◆ PeerListAddCSec

CStdCSec C4NetIOUDP::PeerListAddCSec

protectedinherited

Definition at line 873 of file C4NetIO.h.

Referenced by C4NetIOUDP::AddPeer(), and C4NetIOUDP::ConnectPeer().

◆ PeerListCSec

CStdCSecEx C4NetIOUDP::PeerListCSec

protectedinherited

Definition at line 872 of file C4NetIO.h.

Referenced by C4NetIOUDP::AddPeer(), C4NetIOUDP::Broadcast(), C4NetIOUDP::ClearMCPackets(), C4NetIOUDP::ClearStatistic(), C4NetIOUDP::Close(), C4NetIOUDP::ConnectPeer(), C4NetIOUDP::DoCheck(), C4NetIOUDP::Execute(), C4NetIOUDP::GetConnStatistic(), C4NetIOUDP::GetNextTick(), C4NetIOUDP::GetPeer(), C4NetIOUDP::OnShareFree(), C4NetIOUDP::Send(), and C4NetIOUDP::SetBroadcast().

◆ pPeerList

Peer* C4NetIOUDP::pPeerList {nullptr}

protectedinherited

Definition at line 882 of file C4NetIO.h.

Referenced by C4NetIOUDP::AddPeer(), C4NetIOUDP::Broadcast(), C4NetIOUDP::ClearMCPackets(), C4NetIOUDP::ClearStatistic(), C4NetIOUDP::Close(), C4NetIOUDP::DoCheck(), C4NetIOUDP::Execute(), C4NetIOUDP::GetNextTick(), C4NetIOUDP::GetPeer(), and C4NetIOUDP::OnShareFree().

◆ StatCSec

CStdCSec C4NetIOUDP::StatCSec

protectedinherited

Definition at line 901 of file C4NetIO.h.

Referenced by C4NetIOUDP::ClearStatistic(), C4NetIOUDP::Peer::ClearStatistics(), C4NetIOUDP::Peer::DoCheck(), C4NetIOUDP::GetStatistic(), C4NetIOUDP::Peer::OnRecv(), C4NetIOUDP::SendDirect(), and C4NetIOUDP::Peer::SendDirect().

◆ tNextCheck

C4TimeMilliseconds C4NetIOUDP::tNextCheck

protectedinherited

Definition at line 893 of file C4NetIO.h.

Referenced by C4NetIOUDP::DoCheck(), C4NetIOUDP::Execute(), C4NetIOUDP::GetNextTick(), and C4NetIOUDP::Init().

◆ TO_INF

const int C4NetIO::TO_INF = -1

staticinherited

Definition at line 66 of file C4NetIO.h.

Referenced by C4NetIOUDP::Execute(), C4NetIOTCP::Execute(), C4NetIOUDP::Peer::OnConn(), C4NetIOUDP::Peer::OnTimeout(), and C4NetIOUDP::Peer::SetTimeout().

The documentation for this class was generated from the following file:

main.cpp

Public Types

Public Member Functions

Static Public Member Functions

Static Public Attributes

Protected Types

Protected Member Functions

Protected Attributes

Static Protected Attributes

Detailed Description

Member Typedef Documentation

◆ addr_t

◆ CID

Member Enumeration Documentation

◆ IPTypeID

Constructor & Destructor Documentation

◆ C4PuncherServer()

Member Function Documentation

◆ AddPeer()

◆ Broadcast() [1/2]

◆ Broadcast() [2/2]

◆ BroadcastDirect()

◆ Changed()

◆ ClearMCPackets()

◆ ClearStatistic()

◆ Close() [1/2]

◆ Close() [2/2]

◆ CloseBroadcast()

◆ Connect()

◆ ConnectPeer()

◆ DoCheck()

◆ DoLoopbackTest()

◆ Execute()

◆ ExecuteUntil()

◆ GetConnStatistic()

◆ GetError()

◆ GetFDs()

◆ GetLocalAddresses()

◆ getMCAddr()

◆ getMCLoopback()

◆ GetNextTick()

◆ GetPeer()

◆ GetStatistic()

◆ Init()

◆ InitBroadcast()

◆ InitIPv6Socket()

◆ IsLowPriority()

◆ IsNotify()

◆ IsSignaled()

◆ OnShareFree()

◆ ResetError()

◆ Send() [1/2]

◆ Send() [2/2]

◆ SendDirect()

◆ SetBroadcast()

◆ SetCallback()

◆ SetError()

◆ SetMCLoopback()

◆ SetReUseAddress()

◆ TimerInterval()

◆ UnBlock()

Member Data Documentation

◆ Error

◆ ExecuteCSec

◆ fDelayedLoopbackTest

◆ fInit

◆ fMultiCast

◆ fSavePacket

◆ iBroadcastRate

◆ iCheckInterval

◆ iMaxOPacketBacklog

◆ iOPacketCounter

◆ iPort

◆ iStdTimeout

◆ iUDPHeaderSize

◆ iVersion

◆ LastPacket

◆ MCLoopbackAddr

◆ OPackets

◆ OutCSec

◆ PeerListAddCSec