#include <C4NetIO.h>

Inheritance diagram for C4NetIOMan:

Collaboration diagram for C4NetIOMan:

Public Member Functions
	C4NetIOMan ()

	~C4NetIOMan () override

void	Clear ()

void	AddIO (C4NetIO *pNetIO, bool fSetCallback=true)

void	RemoveIO (C4NetIO *pNetIO)

virtual bool	OnConn (const addr_t &AddrPeer, const addr_t &AddrConnect, const addr_t pOwnAddr, C4NetIO pNetIO)

virtual void	OnDisconn (const addr_t &AddrPeer, C4NetIO pNetIO, const char szReason)

virtual void	OnPacket (const class C4NetIOPacket &rPacket, C4NetIO *pNetIO)=0

void	Set (StdSchedulerProc **ppProcs, int iProcCnt)

void	Add (StdSchedulerProc *pProc)

void	Remove (StdSchedulerProc *pProc)

bool	Start ()

void	Stop ()

int	getProcCnt () const

bool	hasProc (StdSchedulerProc *pProc)

bool	IsInManualLoop ()

void	Added (StdSchedulerProc *pProc)

void	Removing (StdSchedulerProc *pProc)

void	Changed (StdSchedulerProc *pProc)

void	StartOnCurrentThread ()

C4TimeMilliseconds	GetNextTick (C4TimeMilliseconds tNow)

bool	ScheduleProcs (int iTimeout=1000/36)

void	UnBlock ()

Protected Member Functions
virtual void	OnError (const char strError, C4NetIO pNetIO)

virtual bool	DoScheduleProcs (int iTimeout)

Protected Attributes
int	iNetIOCnt {0}

int	iNetIOCapacity {0}

C4NetIO **	ppNetIO {nullptr}

Detailed Description

Definition at line 950 of file C4NetIO.h.

Constructor & Destructor Documentation

◆ C4NetIOMan()

C4NetIOMan::C4NetIOMan ( )

Definition at line 3971 of file C4NetIO.cpp.

         : StdSchedulerThread()
  
 {
 }

◆ ~C4NetIOMan()

C4NetIOMan::~C4NetIOMan ( )

override

Definition at line 3977 of file C4NetIO.cpp.

 {
     Clear();
 }

References Clear().

Here is the call graph for this function:

Member Function Documentation

◆ Add()

void StdSchedulerThread::Add ( StdSchedulerProc * pProc )

inherited

Definition at line 183 of file StdScheduler.cpp.

 {
     // Thread is running? Stop it first
     bool fGotThread = fThread;
     if (fGotThread) Stop();
     // Set
     StdScheduler::Add(pProc);
     // Restart
     if (fGotThread) Start();
 }

References StdScheduler::Add(), StdSchedulerThread::Start(), and StdSchedulerThread::Stop().

Referenced by AddIO(), and C4InteractiveThread::AddProc().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ Added()

void StdScheduler::Added ( StdSchedulerProc * pProc )

inherited

Definition at line 281 of file StdSchedulerMac.mm.

 {
     [[SCHAdditions requestAdditionsForScheduler:this] assignAdditionForProc:pProc];
 }

References SCHAdditions::assignAdditionForProc:, and SCHAdditions::requestAdditionsForScheduler:.

Referenced by StdScheduler::Add().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ AddIO()

void C4NetIOMan::AddIO	(	C4NetIO *	pNetIO,
		bool	fSetCallback = `true`
	)

Definition at line 3989 of file C4NetIO.cpp.

 {
     // Set callback
     if (fSetCallback)
         pNetIO->SetCallback(this);
     // Add to i/o list
     if (iNetIOCnt + 1 > iNetIOCapacity)
         EnlargeIO(1);
     ppNetIO[iNetIOCnt++] = pNetIO;
     // Register with scheduler
     Add(pNetIO);
 }

References StdSchedulerThread::Add(), iNetIOCapacity, iNetIOCnt, ppNetIO, and C4NetIO::SetCallback().

Referenced by main().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ Changed()

void StdScheduler::Changed ( StdSchedulerProc * pProc )

inherited

Definition at line 294 of file StdSchedulerMac.mm.

 {
     [[[SCHAdditions requestAdditionsForScheduler:this] additionForProc:pProc] changed];
 }

References SCHAdditions::additionForProc:, SCHAddition::changed, and SCHAdditions::requestAdditionsForScheduler:.

Here is the call graph for this function:

◆ Clear()

void C4NetIOMan::Clear ( )

Definition at line 3982 of file C4NetIO.cpp.

 {
     delete[] ppNetIO; ppNetIO = nullptr;
     iNetIOCnt = iNetIOCapacity = 0;
     StdSchedulerThread::Clear();
 }

References StdSchedulerThread::Clear(), iNetIOCapacity, iNetIOCnt, and ppNetIO.

Referenced by ~C4NetIOMan().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ DoScheduleProcs()

virtual bool StdScheduler::DoScheduleProcs ( int iTimeout )

protectedvirtualinherited

Reimplemented in C4AbstractApp.

Referenced by C4AbstractApp::DoScheduleProcs(), and StdScheduler::ScheduleProcs().

Here is the caller graph for this function:

◆ GetNextTick()

C4TimeMilliseconds StdScheduler::GetNextTick ( C4TimeMilliseconds tNow )

inherited

Definition at line 120 of file StdScheduler.cpp.

 {
     C4TimeMilliseconds tProcTick = C4TimeMilliseconds::PositiveInfinity;
     for (auto proc : procs)
     {
         tProcTick = std::min(tProcTick, proc->GetNextTick(tNow));
     }
     return tProcTick;
 }

References C4TimeMilliseconds::PositiveInfinity.

Referenced by C4AbstractApp::Run(), and StdScheduler::ScheduleProcs().

Here is the caller graph for this function:

◆ getProcCnt()

int StdScheduler::getProcCnt ( ) const

inlineinherited

Definition at line 245 of file StdScheduler.h.

245 { return procs.size()-1; } // ignore internal NoopNotifyProc

Referenced by C4InteractiveThread::AddProc(), and C4InteractiveThread::RemoveProc().

Here is the caller graph for this function:

◆ hasProc()

bool StdScheduler::hasProc ( StdSchedulerProc * pProc )

inlineinherited

Definition at line 246 of file StdScheduler.h.

246 { return std::find(procs.begin(), procs.end(), pProc) != procs.end(); }

Referenced by C4InteractiveThread::RemoveProc().

Here is the caller graph for this function:

◆ IsInManualLoop()

bool StdScheduler::IsInManualLoop ( )

inlineinherited

Definition at line 247 of file StdScheduler.h.

247 { return isInManualLoop; }

◆ OnConn()

virtual bool C4NetIO::CBClass::OnConn	(	const addr_t &	AddrPeer,
		const addr_t &	AddrConnect,
		const addr_t *	pOwnAddr,
		C4NetIO *	pNetIO
	)

inlinevirtualinherited

Reimplemented in C4Network2IO, and C4NetIO::CBProxy< T >.

Definition at line 221 of file C4NetIO.h.

221 { return true; }

Referenced by C4NetIOTCP::Accept(), and C4NetIOUDP::Peer::OnConn().

Here is the caller graph for this function:

◆ OnDisconn()

virtual void C4NetIO::CBClass::OnDisconn	(	const addr_t &	AddrPeer,
		C4NetIO *	pNetIO,
		const char *	szReason
	)

inlinevirtualinherited

Reimplemented in C4Network2IO, MyCBClass, and C4NetIO::CBProxy< T >.

Definition at line 222 of file C4NetIO.h.

222 { }

Referenced by C4NetIOTCP::Close(), C4NetIOSimpleUDP::Execute(), C4NetIOTCP::Execute(), and C4NetIOUDP::Peer::OnClose().

Here is the caller graph for this function:

◆ OnError()

virtual void C4NetIOMan::OnError	(	const char *	strError,
		C4NetIO *	pNetIO
	)

inlineprotectedvirtual

Reimplemented in MyCBClass.

Definition at line 968 of file C4NetIO.h.

968 { };

◆ OnPacket()

virtual void C4NetIO::CBClass::OnPacket	(	const class C4NetIOPacket &	rPacket,
		C4NetIO *	pNetIO
	)

pure virtualinherited

Implemented in C4Network2IODiscoverClient, C4Network2IODiscover, C4NetIO::CBProxy< T >, and MyCBClass.

Referenced by C4NetIOSimpleUDP::Execute(), and C4NetIOTCP::UnpackPacket().

Here is the caller graph for this function:

◆ Remove()

void StdSchedulerThread::Remove ( StdSchedulerProc * pProc )

inherited

Definition at line 194 of file StdScheduler.cpp.

 {
     // Thread is running? Stop it first
     bool fGotThread = fThread;
     if (fGotThread) Stop();
     // Set
     StdScheduler::Remove(pProc);
     // Restart
     if (fGotThread) Start();
 }

References StdScheduler::Remove(), StdSchedulerThread::Start(), and StdSchedulerThread::Stop().

Referenced by C4InteractiveThread::RemoveProc().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ RemoveIO()

void C4NetIOMan::RemoveIO ( C4NetIO * pNetIO )

Definition at line 4002 of file C4NetIO.cpp.

 {
     // Search
     int i;
     for (i = 0; i < iNetIOCnt; i++)
         if (ppNetIO[i] == pNetIO)
             break;
     // Not found?
     if (i >= iNetIOCnt) return;
     // Remove
     for (i++; i < iNetIOCnt; i++)
         ppNetIO[i-1] = ppNetIO[i];
     iNetIOCnt--;
 }

References iNetIOCnt, and ppNetIO.

◆ Removing()

void StdScheduler::Removing ( StdSchedulerProc * pProc )

inherited

Definition at line 286 of file StdSchedulerMac.mm.

 {
     auto x = [SCHAdditions requestAdditionsForScheduler:this];
     [x removeAdditionForProc:pProc];
     if ([x numberOfAdditions] == 0)
         [SCHAdditions removeAdditions:x];
 }

References SCHAdditions::requestAdditionsForScheduler:.

Referenced by StdScheduler::Remove().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ ScheduleProcs()

bool StdScheduler::ScheduleProcs ( int iTimeout = 1000/36 )

inherited

Definition at line 130 of file StdScheduler.cpp.

 {
     // Needs at least one process to work properly
     if (!procs.size()) return false;
  
     // Get timeout
     C4TimeMilliseconds tNow = C4TimeMilliseconds::Now();
     C4TimeMilliseconds tProcTick = GetNextTick(tNow);
     if (iTimeout == -1 || tNow + iTimeout > tProcTick)
     {
         iTimeout = std::max<decltype(iTimeout)>(tProcTick - tNow, 0);
     }
     
     bool old = isInManualLoop;
     isInManualLoop = true;
     bool res = DoScheduleProcs(iTimeout);
     isInManualLoop = old;
     return res;
 }

References StdScheduler::DoScheduleProcs(), StdScheduler::GetNextTick(), and C4TimeMilliseconds::Now().

Referenced by C4AulDebug::DebugStep(), C4Network2::DoLobby(), C4GUI::Dialog::DoModal(), C4ScenarioListLoader::DoProcessCallback(), C4GUI::Dialog::Execute(), C4Network2::FinalInit(), C4Game::InitNetworkFromAddress(), C4Network2::LeagueEnd(), C4Network2::LeaguePlrAuth(), C4Network2::LeaguePlrAuthCheck(), C4Network2::LeagueStart(), C4Network2::LeagueWaitNotBusy(), C4AulDebug::Listen(), C4Network2::RetrieveRes(), and C4AbstractApp::Run().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ Set()

void StdSchedulerThread::Set	(	StdSchedulerProc **	ppProcs,
		int	iProcCnt
	)

inherited

Definition at line 172 of file StdScheduler.cpp.

 {
     // Thread is running? Stop it first
     bool fGotThread = fThread;
     if (fGotThread) Stop();
     // Set
     StdScheduler::Set(ppProcs, iProcCnt);
     // Restart
     if (fGotThread) Start();
 }

References StdScheduler::Set(), StdSchedulerThread::Start(), and StdSchedulerThread::Stop().

Here is the call graph for this function:

◆ Start()

bool StdSchedulerThread::Start ( )

inherited

Definition at line 205 of file StdScheduler.cpp.

 {
     // already running? stop
     if (fThread) Stop();
     // begin thread
     fRunThreadRun = true;
 #ifdef HAVE_WINTHREAD
     iThread = _beginthread(_ThreadFunc, 0, this);
     fThread = (iThread != -1);
 #elif defined(HAVE_PTHREAD)
     fThread = !pthread_create(&Thread, nullptr, _ThreadFunc, this);
 #endif
     // success?
     return fThread;
 }

References StdSchedulerThread::Stop().

Referenced by StdSchedulerThread::Add(), C4InteractiveThread::AddProc(), main(), StdSchedulerThread::Remove(), and StdSchedulerThread::Set().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ StartOnCurrentThread()

void StdScheduler::StartOnCurrentThread ( )

inherited

Definition at line 276 of file StdSchedulerMac.mm.

 {
     [[SCHAdditions requestAdditionsForScheduler:this] start];
 }

References SCHAdditions::requestAdditionsForScheduler:, and SCHAdditions::start.

Here is the call graph for this function:

◆ Stop()

void StdSchedulerThread::Stop ( )

inherited

Definition at line 221 of file StdScheduler.cpp.

 {
     // Not running?
     if (!fThread) return;
     // Set flag
     fRunThreadRun = false;
     // Unblock
     UnBlock();
 #ifdef HAVE_WINTHREAD
     // Wait for thread to terminate itself
     HANDLE hThread = reinterpret_cast<HANDLE>(iThread);
     if (WaitForSingleObject(hThread, 10000) == WAIT_TIMEOUT)
         // ... or kill it in case it refuses to do so
         TerminateThread(hThread, -1);
 #elif defined(HAVE_PTHREAD)
     // wait for thread to terminate itself
     // (without security - let's trust these unwashed hackers for once)
     pthread_join(Thread, nullptr);
 #endif
     fThread = false;
     // ok
     return;
 }

References StdScheduler::UnBlock().

Referenced by StdSchedulerThread::Add(), StdSchedulerThread::Clear(), main(), StdSchedulerThread::Remove(), C4InteractiveThread::RemoveProc(), StdSchedulerThread::Set(), and StdSchedulerThread::Start().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ UnBlock()

void StdScheduler::UnBlock ( )

inherited

Definition at line 150 of file StdScheduler.cpp.

 {
     Unblocker.Notify();
 }

Referenced by StdSchedulerThread::Stop().

Here is the caller graph for this function:

Member Data Documentation

◆ iNetIOCapacity

int C4NetIOMan::iNetIOCapacity {0}

protected

Definition at line 964 of file C4NetIO.h.

Referenced by AddIO(), and Clear().

◆ iNetIOCnt

int C4NetIOMan::iNetIOCnt {0}

protected

Definition at line 964 of file C4NetIO.h.

Referenced by AddIO(), Clear(), and RemoveIO().

◆ ppNetIO

C4NetIO** C4NetIOMan::ppNetIO {nullptr}

protected

Definition at line 965 of file C4NetIO.h.

Referenced by AddIO(), Clear(), and RemoveIO().

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

Public Member Functions

Protected Member Functions

Protected Attributes

Detailed Description

Constructor & Destructor Documentation

◆ C4NetIOMan()

◆ ~C4NetIOMan()

Member Function Documentation

◆ Add()

◆ Added()

◆ AddIO()

◆ Changed()

◆ Clear()

◆ DoScheduleProcs()

◆ GetNextTick()

◆ getProcCnt()

◆ hasProc()

◆ IsInManualLoop()

◆ OnConn()

◆ OnDisconn()

◆ OnError()

◆ OnPacket()

◆ Remove()

◆ RemoveIO()

◆ Removing()

◆ ScheduleProcs()

◆ Set()

◆ Start()

◆ StartOnCurrentThread()

◆ Stop()

◆ UnBlock()

Member Data Documentation

◆ iNetIOCapacity

◆ iNetIOCnt

◆ ppNetIO