Inheritance diagram for MyCBClass:

Collaboration diagram for MyCBClass:

Public Member Functions
virtual bool	OnConn (const C4NetIO::addr_t &addr, const C4NetIO::addr_t &addr2, C4NetIO *pNetIO)

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

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

virtual void	OnError (const char strError, C4NetIO pNetIO)

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)

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 bool	DoScheduleProcs (int iTimeout)

Protected Attributes
int	iNetIOCnt {0}

int	iNetIOCapacity {0}

C4NetIO **	ppNetIO {nullptr}

Detailed Description

Definition at line 40 of file TstC4NetIO.cpp.

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 C4NetIOMan::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`
	)

inherited

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(), C4NetIOMan::iNetIOCapacity, C4NetIOMan::iNetIOCnt, C4NetIOMan::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 ( )

inherited

Definition at line 3982 of file C4NetIO.cpp.

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

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

Referenced by C4NetIOMan::~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() [1/2]

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:

◆ OnConn() [2/2]

virtual bool MyCBClass::OnConn	(	const C4NetIO::addr_t &	addr,
		const C4NetIO::addr_t &	addr2,
		C4NetIO *	pNetIO
	)

inlinevirtual

Definition at line 44 of file TstC4NetIO.cpp.

     {
         cout << "got connection from " << inet_ntoa(addr.sin_addr) << endl;
         tTime = C4TimeMilliseconds::Now();
         iPcks = 0;
  
 #ifdef ASYNC_CONNECT
         if (!fHost)
         {
             DummyData[0] = 0;
             if (!pNetIO->Send(C4NetIOPacket(DummyData, iSize, true, addr)))
                 cout << " Fehler: " << (pNetIO->GetError() ? pNetIO->GetError() : "bla") << endl;
         }
 #endif
         return true;
     }

References DummyData, fHost, C4NetIO::GetError(), iSize, C4TimeMilliseconds::Now(), and C4NetIO::Send().

Here is the call graph for this function:

◆ OnDisconn()

virtual void MyCBClass::OnDisconn	(	const C4NetIO::addr_t &	addr,
		C4NetIO *	pNetIO,
		const char *	szReason
	)

inlinevirtual

Reimplemented from C4NetIO::CBClass.

Definition at line 85 of file TstC4NetIO.cpp.

     {
         cout << "client from " << inet_ntoa(addr.sin_addr) << " disconnected (" << szReason << ")" << endl;
     }

◆ OnError()

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

inlinevirtual

Reimplemented from C4NetIOMan.

Definition at line 89 of file TstC4NetIO.cpp.

     {
         cout << "network error: " << strError << endl;
     };

◆ OnPacket()

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

inlinevirtual

Implements C4NetIO::CBClass.

Definition at line 60 of file TstC4NetIO.cpp.

     {
         C4TimeMilliseconds tNow = C4TimeMilliseconds::Now();
         if (tNow > tTime + 1000)
         {
             cout << iPcks << " packets in " << tNow - tTime << " ms (" << iPcks * 1000 / (tNow - tTime) << " per second, " << (iPcks ? (tNow - tTime) * 1000 / iPcks : -1u) << "us per packet)" << endl;
             tTime = C4TimeMilliseconds::Now();
             iPcks = 0;
         }
         if (!rPacket.getStatus())
         {
             // dummys
             DummyData[0] = 1;
             C4NetIOPacket Dummy(DummyData, iSize, true, rPacket.getAddr());
             for (int i = 0; i < iCnt; i++)
             {
                 if (!pNetIO->Send(Dummy))
                     cout << " Fehler: " << (pNetIO->GetError() ? pNetIO->GetError() : "bla") << endl;
             }
             // pong
             pNetIO->Send(rPacket);
             iPcks++;
         }
         // cout << "got " << rPacket.GetSize() << " bytes of data (" << int(*rPacket.GetData()) << ")" << endl;
     }

References DummyData, C4NetIOPacket::getAddr(), C4NetIO::GetError(), C4NetIOPacket::getStatus(), iCnt, iSize, C4TimeMilliseconds::Now(), and C4NetIO::Send().

Here is the call 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 )

inherited

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 C4NetIOMan::iNetIOCnt, and C4NetIOMan::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}

protectedinherited

Definition at line 964 of file C4NetIO.h.

Referenced by C4NetIOMan::AddIO(), and C4NetIOMan::Clear().

◆ iNetIOCnt

int C4NetIOMan::iNetIOCnt {0}

protectedinherited

Definition at line 964 of file C4NetIO.h.

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

◆ ppNetIO

C4NetIO** C4NetIOMan::ppNetIO {nullptr}

protectedinherited

Definition at line 965 of file C4NetIO.h.

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

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

TstC4NetIO.cpp

Public Member Functions

Protected Member Functions

Protected Attributes

Detailed Description

Member Function Documentation

◆ Add()

◆ Added()

◆ AddIO()

◆ Changed()

◆ Clear()

◆ DoScheduleProcs()

◆ GetNextTick()

◆ getProcCnt()

◆ hasProc()

◆ IsInManualLoop()

◆ OnConn() [1/2]

◆ OnConn() [2/2]

◆ OnDisconn()

◆ OnError()

◆ OnPacket()

◆ Remove()

◆ RemoveIO()

◆ Removing()

◆ ScheduleProcs()

◆ Set()

◆ Start()

◆ StartOnCurrentThread()

◆ Stop()

◆ UnBlock()

Member Data Documentation

◆ iNetIOCapacity

◆ iNetIOCnt

◆ ppNetIO