#include <C4Network2.h>

Inheritance diagram for C4Network2:

Collaboration diagram for C4Network2:

Classes
class	InitialConnect

Public Types
enum	InitResult { IR_Success , IR_Error , IR_Fatal }

Public Member Functions
	C4Network2 ()

	~C4Network2 () override

bool	isEnabled () const

bool	isLobbyActive () const

bool	isPastLobby () const

bool	isRunning () const

bool	isPaused () const

bool	isPausing () const

bool	isHost () const

bool	isStatusAck () const

bool	isFrozen () const

bool	isJoinAllowed () const

bool	isObservingAllowed () const

class C4GameLobby::MainDlg *	GetLobby () const

const char *	GetPassword () const

bool	isPassworded () const

bool	InitHost (bool fLobby)

InitResult	InitClient (const class C4Network2Reference &Ref, bool fObserver)

InitResult	InitClient (const std::vector< class C4Network2Address > &Addrs, const class C4ClientCore &HostCore, const char *szPassword=nullptr)

bool	DoLobby ()

bool	Start ()

bool	Pause ()

bool	Sync ()

bool	FinalInit ()

bool	RetrieveScenario (char *szScenario)

C4Network2Res::Ref	RetrieveRes (const C4Network2ResCore &Core, int32_t iTimeout, const char *szResName, bool fWaitForCore=false)

void	OnSec1Timer () override

void	Execute ()

void	Clear ()

bool	ToggleAllowJoin ()

bool	ToggleClientListDlg ()

void	AllowJoin (bool fAllow)

void	SetAllowObserve (bool fAllow)

void	SetCtrlMode (int32_t iCtrlMode)

void	SetPassword (const char *szToPassword)

StdStrBuf	QueryClientPassword ()

void	OnConn (C4Network2IOConnection *pConn)

void	OnDisconn (C4Network2IOConnection *pConn)

void	HandlePacket (char cStatus, const C4PacketBase pBasePkt, C4Network2IOConnection pConn)

void	HandleLobbyPacket (char cStatus, const C4PacketBase pBasePkt, C4Network2IOConnection pConn)

bool	HandlePuncherPacket (C4NetpuncherPacket::uptr, C4NetIO::HostAddress::AddressFamily family)

void	OnPuncherConnect (C4NetIO::addr_t addr)

void	OnGameSynchronized ()

void	DrawStatus (C4TargetFacet &cgo)

void	RequestActivate ()

void	DeactivateInactiveClients ()

void	LeagueGameEvaluate (const char szRecordName=nullptr, const BYTE pRecordSHA=nullptr)

void	LeagueSignupDisable ()

bool	LeagueSignupEnable ()

void	InvalidateReference ()

bool	LeaguePlrAuth (C4PlayerInfo *pInfo)

bool	LeaguePlrAuthCheck (C4PlayerInfo *pInfo)

void	LeagueNotifyDisconnect (int32_t iClientID, enum C4LeagueDisconnectReason eReason)

void	LeagueWaitNotBusy ()

void	LeagueSurrender ()

void	LeagueShowError (const char *szMsg)

void	Vote (C4ControlVoteType eType, bool fApprove=true, int32_t iData=0)

void	AddVote (const C4ControlVote &Vote)

C4IDPacket *	GetVote (int32_t iClientID, C4ControlVoteType eType, int32_t iData)

void	EndVote (C4ControlVoteType eType, bool fApprove, int32_t iData)

void	OpenVoteDialog ()

void	OpenSurrenderDialog (C4ControlVoteType eType, int32_t iData)

void	OnVoteDialogClosed ()

void	StartLobbyCountdown (int32_t iCountdownTime)

void	AbortLobbyCountdown ()

bool	isLobbyCountDown ()

size_t	getPendingStreamData () const

bool	isStreaming () const

bool	StartStreaming (C4Record *pRecord)

bool	FinishStreaming ()

bool	StopStreaming ()

C4NetpuncherID::value &	getNetpuncherGameID (C4NetIO::HostAddress::AddressFamily family)

C4NetpuncherID	getNetpuncherGameID () const

StdStrBuf	getNetpuncherAddr () const

Public Attributes
C4Network2IO	NetIO

C4Network2ResList	ResList

C4Network2ClientList	Clients

C4Network2Players	Players

C4Network2Status	Status

Protected Member Functions
bool	InitNetIO (bool fNoClientID, bool fHost)

void	HandleConn (const class C4PacketConn &Pkt, C4Network2IOConnection pConn, C4Network2Client pClient)

bool	CheckConn (const C4ClientCore &CCore, C4Network2IOConnection pConn, C4Network2Client pClient, StdStrBuf *szReply)

bool	HostConnect (const C4ClientCore &CCore, C4Network2IOConnection pConn, StdStrBuf szReply)

bool	Join (C4ClientCore &CCore, C4Network2IOConnection pConn, StdStrBuf szReply)

void	HandleConnRe (const class C4PacketConnRe &Pkt, C4Network2IOConnection pConn, C4Network2Client pClient)

void	HandleStatus (const C4Network2Status &nStatus)

void	HandleStatusAck (const C4Network2Status &nStatus, C4Network2Client *pClient)

void	HandleActivateReq (int32_t iTick, C4Network2Client *pClient)

void	HandleJoinData (const class C4PacketJoinData &rPkt)

void	OnConnect (C4Network2Client pClient, C4Network2IOConnection pConn, const char *szMsg, bool fFirstConnection)

void	OnConnectFail (C4Network2IOConnection *pConn)

void	OnDisconnect (C4Network2Client pClient, C4Network2IOConnection pConn)

void	OnClientConnect (C4Network2Client pClient, C4Network2IOConnection pConn)

void	OnClientDisconnect (C4Network2Client *pClient)

void	SendJoinData (C4Network2Client *pClient)

bool	CreateDynamic (bool fInit)

void	RemoveDynamic ()

bool	PauseGame (bool fAutoContinue)

bool	ChangeGameStatus (C4NetGameState enState, int32_t iTargetCtrlTick, int32_t iCtrlMode=-1)

void	CheckStatusReached (bool fFromFinalInit=false)

void	CheckStatusAck ()

void	OnStatusReached ()

void	OnStatusAck ()

void	UpdateChaseTarget ()

bool	InitLeague (bool *pCancel)

void	DeinitLeague ()

bool	LeagueStart (bool *pCancel)

bool	LeagueUpdate ()

bool	LeagueUpdateProcessReply ()

bool	LeagueEnd (const char szRecordName=nullptr, const BYTE pRecordSHA=nullptr)

bool	StreamIn (bool fFinish)

bool	StreamOut ()

void	InitPuncher ()

bool	Execute (int, pollfd *) override

Protected Attributes
bool	fHost

bool	fAllowJoin {false}

bool	fAllowObserve

C4Network2ResCore	ResDynamic

int32_t	iDynamicTick {-1}

bool	fDynamicNeeded {false}

bool	fStatusAck {false}

bool	fStatusReached {false}

bool	fChasing {false}

class C4GameControlNetwork *	pControl {nullptr}

C4GameLobby::MainDlg *	pLobby {nullptr}

bool	fLobbyRunning {false}

C4GameLobby::Countdown *	pLobbyCountdown {nullptr}

StdCopyStrBuf	MasterServerAddress

int32_t	iNextClientID {0}

uint32_t	iLastChaseTargetUpdate {0}

C4TimeMilliseconds	tLastActivateRequest

uint32_t	iLastReferenceUpdate {0}

uint32_t	iLastLeagueUpdate {0}

uint32_t	iLeagueUpdateDelay

bool	fLeagueEndSent

class C4LeagueClient *	pLeagueClient {nullptr}

StdStrBuf	sPassword

bool	fWrongPassword

bool	fDelayedActivateReq {false}

C4Control	Votes

class C4VoteDialog *	pVoteDialog {nullptr}

bool	fPausedForVote {false}

time_t	iVoteStartTime

time_t	iLastOwnVoting {0}

bool	fStreaming {false}

time_t	iLastStreamAttempt

C4Record *	pStreamedRecord

StdBuf	StreamingBuf

z_stream	StreamCompressor

class C4HTTPClient *	pStreamer

unsigned int	iCurrentStreamAmount

unsigned int	iCurrentStreamPosition

C4NetpuncherID	NetpuncherGameID

StdCopyStrBuf	NetpuncherAddr

Private Member Functions
bool	Execute (int, pollfd *) override

Friends
class	C4Network2IO

Detailed Description

Definition at line 101 of file C4Network2.h.

Member Enumeration Documentation

◆ InitResult

enum C4Network2::InitResult

Enumerator
IR_Success
IR_Error
IR_Fatal

Definition at line 221 of file C4Network2.h.

     {
         IR_Success, IR_Error, IR_Fatal
     };

Constructor & Destructor Documentation

◆ C4Network2()

C4Network2::C4Network2 ( )

Definition at line 126 of file C4Network2.cpp.

         : Clients(&NetIO),
         tLastActivateRequest(C4TimeMilliseconds::NegativeInfinity),
         NetpuncherGameID(C4NetpuncherID())
 {
  
 }

◆ ~C4Network2()

C4Network2::~C4Network2 ( )

override

Definition at line 134 of file C4Network2.cpp.

 {
     Clear();
 }

References Clear().

Here is the call graph for this function:

Member Function Documentation

◆ AbortLobbyCountdown()

void C4Network2::AbortLobbyCountdown ( )

Definition at line 2864 of file C4Network2.cpp.

 {
     // aboert lobby countdown
     if (pLobbyCountdown)
     {
         pLobbyCountdown->Abort();
         delete pLobbyCountdown;
         pLobbyCountdown = nullptr;
     }
 }

References C4GameLobby::Countdown::Abort(), and pLobbyCountdown.

Referenced by C4GameLobby::MainDlg::OnRunBtn(), C4MessageInput::ProcessCommand(), and StartLobbyCountdown().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ AddVote()

void C4Network2::AddVote ( const C4ControlVote & Vote )

Definition at line 2683 of file C4Network2.cpp.

 {
     // Save back timestamp
     if (!Votes.firstPkt())
         iVoteStartTime = time(nullptr);
     // Save vote back
     Votes.Add(CID_Vote, new C4ControlVote(Vote));
     // Set pause mode if this is the host
     if (isHost() && isRunning())
     {
         Pause();
         fPausedForVote = true;
     }
     // Check if the dialog should be opened
     OpenVoteDialog();
 }

References C4Control::Add(), CID_Vote, C4Control::firstPkt(), fPausedForVote, isHost(), isRunning(), iVoteStartTime, OpenVoteDialog(), Pause(), Vote(), and Votes.

Here is the call graph for this function:

◆ AllowJoin()

void C4Network2::AllowJoin ( bool fAllow )

Definition at line 802 of file C4Network2.cpp.

 {
     if (!isHost()) return;
     fAllowJoin = fAllow;
     if (Game.IsRunning)
     {
         ::GraphicsSystem.FlashMessage(LoadResStr(fAllowJoin ? "IDS_NET_RUNTIMEJOINFREE" : "IDS_NET_RUNTIMEJOINBARRED"));
         Config.Network.NoRuntimeJoin = !fAllowJoin;
     }
 }

References Config, fAllowJoin, C4GraphicsSystem::FlashMessage(), Game, GraphicsSystem, isHost(), C4Game::IsRunning, LoadResStr(), C4Config::Network, and C4ConfigNetwork::NoRuntimeJoin.

Referenced by C4Game::InitNetworkHost(), and ToggleAllowJoin().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ ChangeGameStatus()

bool C4Network2::ChangeGameStatus	(	C4NetGameState	enState,
		int32_t	iTargetCtrlTick,
		int32_t	iCtrlMode = `-1`
	)

protected

Definition at line 1817 of file C4Network2.cpp.

 {
     // change game status, announce. Can only be done by host.
     if (!isHost()) return false;
     // set status
     Status.Set(enState, iTargetCtrlTick);
     // update reference
     InvalidateReference();
     // control mode change?
     if (iCtrlMode >= 0) Status.SetCtrlMode(iCtrlMode);
     // log
     LogSilentF("Network: going into status %s (tick %d)", Status.getStateName(), iTargetCtrlTick);
     // set flags
     Clients.ResetReady();
     fStatusReached = fStatusAck = false;
     // send new status to all clients
     Clients.BroadcastMsgToClients(MkC4NetIOPacket(PID_Status, Status));
     // check reach/ack
     CheckStatusReached();
     // ok
     return true;
 }

References C4Network2ClientList::BroadcastMsgToClients(), CheckStatusReached(), Clients, fStatusAck, fStatusReached, C4Network2Status::getStateName(), InvalidateReference(), isHost(), LogSilentF(), MkC4NetIOPacket(), PID_Status, C4Network2ClientList::ResetReady(), C4Network2Status::Set(), C4Network2Status::SetCtrlMode(), and Status.

Referenced by DoLobby(), HandleStatusAck(), OnClientDisconnect(), Pause(), SetCtrlMode(), Start(), and Sync().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ CheckConn()

bool C4Network2::CheckConn	(	const C4ClientCore &	CCore,
		C4Network2IOConnection *	pConn,
		C4Network2Client *	pClient,
		StdStrBuf *	szReply
	)

protected

Definition at line 1317 of file C4Network2.cpp.

 {
     if (!pConn || !pClient) return false;
     // already connected? (shouldn't happen really)
     if (pClient->hasConn(pConn))
         { *szReply = "already connected"; return true; }
     // check core
     if (CCore.getDiffLevel(pClient->getCore()) > C4ClientCoreDL_IDMatch)
         { *szReply = "wrong client core"; return false; }
     // accept
     return true;
 }

References C4ClientCoreDL_IDMatch, C4Network2Client::getCore(), C4ClientCore::getDiffLevel(), and C4Network2Client::hasConn().

Referenced by HandleConn().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ CheckStatusAck()

void C4Network2::CheckStatusAck ( )

protected

Definition at line 1885 of file C4Network2.cpp.

 {
     // host only
     if (!isHost()) return;
     // status must be reached and not yet acknowledged
     if (!fStatusReached || fStatusAck) return;
     // all clients ready?
     if ((fStatusAck = Clients.AllClientsReady()))
     {
         // pause/go: check for sync control that can be executed
         if (Status.getState() == GS_Go || Status.getState() == GS_Pause)
             pControl->ExecSyncControl();
         // broadcast ack
         Clients.BroadcastMsgToClients(MkC4NetIOPacket(PID_StatusAck, Status));
         // handle
         OnStatusAck();
     }
 }

References C4Network2ClientList::AllClientsReady(), C4Network2ClientList::BroadcastMsgToClients(), Clients, C4GameControlNetwork::ExecSyncControl(), fStatusAck, fStatusReached, C4Network2Status::getState(), GS_Go, GS_Pause, isHost(), MkC4NetIOPacket(), OnStatusAck(), pControl, PID_StatusAck, and Status.

Referenced by CheckStatusReached(), HandleStatusAck(), OnClientDisconnect(), and Sync().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ CheckStatusReached()

void C4Network2::CheckStatusReached ( bool fFromFinalInit = false )

protected

Definition at line 1840 of file C4Network2.cpp.

 {
     // already reached?
     if (fStatusReached) return;
     if (Status.getState() == GS_Lobby)
         fStatusReached = fLobbyRunning;
     // game go / pause: control must be initialized and target tick reached
     else if (Status.getState() == GS_Go || Status.getState() == GS_Pause)
     {
         if (Game.IsRunning || fFromFinalInit)
         {
             // Make sure we have reached the tick and the control queue is empty (except for chasing)
             if (::Control.CtrlTickReached(Status.getTargetCtrlTick()) &&
                 (fChasing || !pControl->CtrlReady(::Control.ControlTick)))
                 fStatusReached = true;
             else
             {
                 // run ctrl so the tick can be reached
                 pControl->SetRunning(true, Status.getTargetCtrlTick());
                 Game.HaltCount = 0;
                 Console.UpdateHaltCtrls(!! Game.HaltCount);
             }
         }
     }
     if (!fStatusReached) return;
     // call handler
     OnStatusReached();
     // host?
     if (isHost())
         // all clients ready?
         CheckStatusAck();
     else
     {
         Status.SetTargetTick(::Control.ControlTick);
         // send response to host
         Clients.SendMsgToHost(MkC4NetIOPacket(PID_StatusAck, Status));
         // do delayed activation request
         if (fDelayedActivateReq)
         {
             fDelayedActivateReq = false;
             RequestActivate();
         }
     }
 }

References CheckStatusAck(), Clients, Console, Control, C4GameControl::ControlTick, C4GameControlNetwork::CtrlReady(), C4GameControl::CtrlTickReached(), fChasing, fDelayedActivateReq, fLobbyRunning, fStatusReached, Game, C4Network2Status::getState(), C4Network2Status::getTargetCtrlTick(), GS_Go, GS_Lobby, GS_Pause, C4Game::HaltCount, isHost(), C4Game::IsRunning, MkC4NetIOPacket(), OnStatusReached(), pControl, PID_StatusAck, RequestActivate(), C4Network2ClientList::SendMsgToHost(), C4GameControlNetwork::SetRunning(), C4Network2Status::SetTargetTick(), Status, and C4ConsoleGUI::UpdateHaltCtrls().

Referenced by ChangeGameStatus(), DoLobby(), Execute(), FinalInit(), and HandleStatus().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ Clear()

void C4Network2::Clear ( )

Definition at line 712 of file C4Network2.cpp.

 {
     // stop timer
     Application.Remove(this);
     // stop streaming
     StopStreaming();
     // clear league
     if (pLeagueClient)
     {
         LeagueEnd();
         DeinitLeague();
     }
     // stop lobby countdown
     delete pLobbyCountdown; pLobbyCountdown = nullptr;
     // cancel lobby
     delete pLobby; pLobby = nullptr;
     fLobbyRunning = false;
     // deactivate
     Status.Clear();
     fStatusAck = fStatusReached = true;
     // if control mode is network: change to local
     if (::Control.isNetwork())
         ::Control.ChangeToLocal();
     // clear all player infos
     Players.Clear();
     // remove all clients
     Clients.Clear();
     // close net classes
     NetIO.Clear();
     // clear resources
     ResList.Clear();
     // clear password
     sPassword.Clear();
     // stuff
     fAllowJoin = false;
     iDynamicTick = -1; fDynamicNeeded = false;
     tLastActivateRequest = C4TimeMilliseconds::NegativeInfinity;
     iLastChaseTargetUpdate = iLastReferenceUpdate = iLastLeagueUpdate = 0;
     fDelayedActivateReq = false;
     delete pVoteDialog; pVoteDialog = nullptr;
     fPausedForVote = false;
     iLastOwnVoting = 0;
     NetpuncherGameID = C4NetpuncherID();
     Votes.Clear();
     // don't clear fPasswordNeeded here, it's needed by InitClient
 }

References Application, C4GameControl::ChangeToLocal(), C4Control::Clear(), StdStrBuf::Clear(), C4Network2Status::Clear(), C4Network2ClientList::Clear(), C4Network2IO::Clear(), C4Network2Players::Clear(), C4Network2ResList::Clear(), Clients, Control, DeinitLeague(), fAllowJoin, fDelayedActivateReq, fDynamicNeeded, fLobbyRunning, fPausedForVote, fStatusAck, fStatusReached, iDynamicTick, iLastChaseTargetUpdate, iLastLeagueUpdate, iLastOwnVoting, iLastReferenceUpdate, C4GameControl::isNetwork(), LeagueEnd(), C4TimeMilliseconds::NegativeInfinity, NetIO, NetpuncherGameID, Players, pLeagueClient, pLobby, pLobbyCountdown, pVoteDialog, StdScheduler::Remove(), ResList, sPassword, Status, StopStreaming(), tLastActivateRequest, and Votes.

Referenced by C4Game::Clear(), DoLobby(), FinalInit(), HandleJoinData(), InitHost(), C4MainMenu::MenuCommand(), OnClientDisconnect(), OnDisconn(), and ~C4Network2().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ CreateDynamic()

bool C4Network2::CreateDynamic ( bool fInit )

protected

Definition at line 1770 of file C4Network2.cpp.

 {
     if (!isHost()) return false;
     // remove all existing dynamic data
     RemoveDynamic();
     // log
     Log(LoadResStr("IDS_NET_SAVING"));
     // compose file name
     char szDynamicBase[_MAX_PATH_LEN], szDynamicFilename[_MAX_PATH_LEN];
     sprintf(szDynamicBase, Config.AtNetworkPath("Dyn%s"), GetFilename(Game.ScenarioFilename), _MAX_PATH);
     if (!ResList.FindTempResFileName(szDynamicBase, szDynamicFilename))
         Log(LoadResStr("IDS_NET_SAVE_ERR_CREATEDYNFILE"));
     // save dynamic data
     C4GameSaveNetwork SaveGame(fInit);
     if (!SaveGame.Save(szDynamicFilename) || !SaveGame.Close())
         { Log(LoadResStr("IDS_NET_SAVE_ERR_SAVEDYNFILE")); return false; }
     // add resource
     C4Network2Res::Ref pRes = ResList.AddByFile(szDynamicFilename, true, NRT_Dynamic);
     if (!pRes) { Log(LoadResStr("IDS_NET_SAVE_ERR_ADDDYNDATARES")); return false; }
     // save
     ResDynamic = pRes->getCore();
     iDynamicTick = ::Control.getNextControlTick();
     fDynamicNeeded = false;
     // ok
     return true;
 }

References _MAX_PATH, _MAX_PATH_LEN, C4Network2ResList::AddByFile(), C4Config::AtNetworkPath(), C4GameSave::Close(), Config, Control, fDynamicNeeded, C4Network2ResList::FindTempResFileName(), Game, C4Network2Res::getCore(), GetFilename(), C4GameControl::getNextControlTick(), iDynamicTick, isHost(), LoadResStr(), Log(), NRT_Dynamic, RemoveDynamic(), ResDynamic, ResList, C4GameSave::Save(), C4Game::ScenarioFilename, and sprintf.

Referenced by InitHost(), and OnGameSynchronized().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ DeactivateInactiveClients()

void C4Network2::DeactivateInactiveClients ( )

Definition at line 1971 of file C4Network2.cpp.

 {
     // host only and not in editor
     if (!isHost() || ::Application.isEditor) return;
     // update activity
     Clients.UpdateClientActivity();
     // find clients to deactivate
     for (C4Network2Client *pClient = Clients.GetNextClient(nullptr); pClient; pClient = Clients.GetNextClient(pClient))
         if (!pClient->isLocal() && pClient->isActivated())
             if (pClient->getLastActivity() + C4NetDeactivationDelay < Game.FrameCounter)
                 ::Control.DoInput(CID_ClientUpdate, new C4ControlClientUpdate(pClient->getID(), CUT_Activate, false), CDT_Sync);
 }

References Application, C4NetDeactivationDelay, CDT_Sync, CID_ClientUpdate, Clients, Control, CUT_Activate, C4GameControl::DoInput(), C4Game::FrameCounter, Game, C4Network2ClientList::GetNextClient(), C4Application::isEditor, isHost(), and C4Network2ClientList::UpdateClientActivity().

Referenced by Execute().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ DeinitLeague()

void C4Network2::DeinitLeague ( )

protected

Definition at line 2115 of file C4Network2.cpp.

 {
     // league clear
     MasterServerAddress.Clear();
     Game.Parameters.League.Clear();
     Game.Parameters.LeagueAddress.Clear();
     if (pLeagueClient)
     {
         Application.Remove(pLeagueClient);
         delete pLeagueClient; pLeagueClient = nullptr;
     }
 }

References Application, StdStrBuf::Clear(), Game, C4GameParameters::League, C4GameParameters::LeagueAddress, MasterServerAddress, C4Game::Parameters, pLeagueClient, and StdScheduler::Remove().

Referenced by Clear(), InitHost(), LeagueSignupDisable(), LeagueSignupEnable(), LeagueStart(), and LeagueSurrender().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ DoLobby()

bool C4Network2::DoLobby ( )

Definition at line 433 of file C4Network2.cpp.

 {
     // shouldn't do lobby?
     if (!isEnabled() || (!isHost() && !isLobbyActive()))
         return true;
  
     // lobby runs
     fLobbyRunning = true;
     fAllowJoin = true;
     Log(LoadResStr("IDS_NET_LOBBYWAITING"));
  
     // client: lobby status reached, message to host
     if (!isHost())
         CheckStatusReached();
     // host: set lobby mode
     else
         ChangeGameStatus(GS_Lobby, 0);
  
     // determine lobby type
     if (Console.Active)
     {
         // console lobby - update console
         Console.UpdateMenus();
         // init lobby countdown if specified
         if (Game.iLobbyTimeout) StartLobbyCountdown(Game.iLobbyTimeout);
         // do console lobby
         while (isLobbyActive())
             if (!Application.ScheduleProcs())
                 { Clear(); return false; }
     }
     else
     {
         // fullscreen lobby
  
         // init lobby dialog
         pLobby = new C4GameLobby::MainDlg(isHost());
         if (!pLobby->FadeIn(::pGUI)) { delete pLobby; pLobby = nullptr; Clear(); return false; }
  
         // init lobby countdown if specified
         if (Game.iLobbyTimeout) StartLobbyCountdown(Game.iLobbyTimeout);
  
         // while state lobby: keep looping
         while (isLobbyActive() && pLobby && pLobby->IsShown())
             if (!Application.ScheduleProcs())
                 { Clear(); return false; }
  
         // check whether lobby was aborted
         if (pLobby && pLobby->IsAborted()) { delete pLobby; pLobby = nullptr; Clear(); return false; }
  
         // deinit lobby
         if (pLobby && pLobby->IsShown()) pLobby->Close(true);
         delete pLobby; pLobby = nullptr;
  
         // close any other dialogs
         ::pGUI->CloseAllDialogs(false);
     }
  
     // lobby end
     delete pLobbyCountdown; pLobbyCountdown = nullptr;
     fLobbyRunning = false;
     fAllowJoin = !Config.Network.NoRuntimeJoin;
  
     // notify user that the lobby has ended (for people who tasked out)
     Application.NotifyUserIfInactive();
  
     // notify lobby end
     bool fGameGo = isEnabled();
     if (fGameGo) Log(LoadResStr("IDS_PRC_GAMEGO"));;
  
     // disabled?
     return fGameGo;
 }

References C4Window::Active, Application, ChangeGameStatus(), CheckStatusReached(), Clear(), C4GUI::Dialog::Close(), C4GUI::Screen::CloseAllDialogs(), Config, Console, C4GUI::Dialog::FadeIn(), fAllowJoin, fLobbyRunning, Game, GS_Lobby, C4Game::iLobbyTimeout, C4GUI::Dialog::IsAborted(), isEnabled(), isHost(), isLobbyActive(), C4GUI::Dialog::IsShown(), LoadResStr(), Log(), C4Config::Network, C4ConfigNetwork::NoRuntimeJoin, C4AbstractApp::NotifyUserIfInactive(), pGUI, pLobby, pLobbyCountdown, StdScheduler::ScheduleProcs(), StartLobbyCountdown(), and C4Console::UpdateMenus().

Referenced by C4Game::Init(), and C4Game::InitNetworkHost().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ DrawStatus()

void C4Network2::DrawStatus ( C4TargetFacet & cgo )

Definition at line 1084 of file C4Network2.cpp.

 {
     if (!isEnabled()) return;
  
     C4Network2Client *pLocal = Clients.GetLocal();
  
     StdStrBuf Stat;
  
     // local client status
     Stat.AppendFormat("Local: %s %s %s (ID %d)",
                       pLocal->isObserver() ? "Observing" : pLocal->isActivated() ? "Active" : "Inactive", pLocal->isHost() ? "host" : "client",
                       pLocal->getName(), pLocal->getID());
  
     // game status
     Stat.AppendFormat( "|Game Status: %s (tick %d)%s%s",
                        Status.getStateName(), Status.getTargetCtrlTick(),
                        fStatusReached ? " reached" : "", fStatusAck ? " ack" : "");
  
     // available protocols
     C4NetIO *pMsgIO = NetIO.MsgIO(), *pDataIO = NetIO.DataIO();
     if (pMsgIO && pDataIO)
     {
         C4Network2IOProtocol eMsgProt = NetIO.getNetIOProt(pMsgIO),
                                         eDataProt = NetIO.getNetIOProt(pDataIO);
         int32_t iMsgPort = 0, iDataPort = 0;
         switch (eMsgProt)
         {
         case P_TCP: iMsgPort = Config.Network.PortTCP; break;
         case P_UDP: iMsgPort = Config.Network.PortUDP; break;
         case P_NONE: assert(eMsgProt != P_NONE); break;
         }
         switch (eDataProt)
         {
         case P_TCP: iDataPort = Config.Network.PortTCP; break;
         case P_UDP: iDataPort = Config.Network.PortUDP; break;
         case P_NONE: assert(eMsgProt != P_NONE); break;
         }
         Stat.AppendFormat( "|Protocols: %s: %s (%d i%d o%d bc%d)",
                            pMsgIO != pDataIO ? "Msg" : "Msg/Data",
                            NetIO.getNetIOName(pMsgIO), iMsgPort,
                            NetIO.getProtIRate(eMsgProt), NetIO.getProtORate(eMsgProt), NetIO.getProtBCRate(eMsgProt));
         if (pMsgIO != pDataIO)
             Stat.AppendFormat( ", Data: %s (%d i%d o%d bc%d)",
                                NetIO.getNetIOName(pDataIO), iDataPort,
                                NetIO.getProtIRate(eDataProt), NetIO.getProtORate(eDataProt), NetIO.getProtBCRate(eDataProt));
     }
     else
         Stat.Append("|Protocols: none");
  
     // some control statistics
     Stat.AppendFormat( "|Control: %s, Tick %d, Behind %d, Rate %d, PreSend %d, ACT: %d",
                        Status.getCtrlMode() == CNM_Decentral ? "Decentral" : Status.getCtrlMode() == CNM_Central ? "Central" : "Async",
                        ::Control.ControlTick, pControl->GetBehind(::Control.ControlTick),
                        ::Control.ControlRate, pControl->getControlPreSend(), pControl->getAvgControlSendTime());
  
     // Streaming statistics
     if (fStreaming)
         Stat.AppendFormat( "|Streaming: %lu waiting, %u in, %lu out, %lu sent",
                            static_cast<unsigned long>(pStreamedRecord ? pStreamedRecord->GetStreamingBuf().getSize() : 0),
                            pStreamedRecord ? pStreamedRecord->GetStreamingPos() : 0,
                            static_cast<unsigned long>(getPendingStreamData()),
                            static_cast<unsigned long>(iCurrentStreamPosition));
  
     // clients
     Stat.Append("|Clients:");
     for (C4Network2Client *pClient = Clients.GetNextClient(nullptr); pClient; pClient = Clients.GetNextClient(pClient))
     {
         // ignore local
         if (pClient->isLocal()) continue;
         // client status
         const C4ClientCore &Core = pClient->getCore();
         const char *szClientStatus;
         switch (pClient->getStatus())
         {
         case NCS_Joining: szClientStatus = " (joining)"; break;
         case NCS_Chasing: szClientStatus = " (chasing)"; break;
         case NCS_NotReady: szClientStatus = " (!rdy)"; break;
         case NCS_Remove: szClientStatus = " (removed)"; break;
         default: szClientStatus = ""; break;
         }
         Stat.AppendFormat( "|- %s %s %s (ID %d) (wait %d ms, behind %d)%s%s",
                            Core.isObserver() ? "Observing" : Core.isActivated() ? "Active" : "Inactive", Core.isHost() ? "host" : "client",
                            Core.getName(), Core.getID(),
                            pControl->ClientPerfStat(pClient->getID()),
                            ::Control.ControlTick - pControl->ClientNextControl(pClient->getID()),
                            szClientStatus,
                            pClient->isActivated() && !pControl->ClientReady(pClient->getID(), ::Control.ControlTick) ? " (!ctrl)" : "");
         // connections
         if (pClient->isConnected())
         {
             Stat.AppendFormat( "|   Connections: %s: %s (%s p%d l%d)",
                                pClient->getMsgConn() == pClient->getDataConn() ? "Msg/Data" : "Msg",
                                NetIO.getNetIOName(pClient->getMsgConn()->getNetClass()),
                                pClient->getMsgConn()->getPeerAddr().ToString().getData(),
                                pClient->getMsgConn()->getPingTime(),
                                pClient->getMsgConn()->getPacketLoss());
             if (pClient->getMsgConn() != pClient->getDataConn())
                 Stat.AppendFormat( ", Data: %s (%s p%d l%d)",
                                    NetIO.getNetIOName(pClient->getDataConn()->getNetClass()),
                                    pClient->getDataConn()->getPeerAddr().ToString().getData(),
                                    pClient->getDataConn()->getPingTime(),
                                    pClient->getDataConn()->getPacketLoss());
         }
         else
             Stat.Append("|   Not connected");
     }
     if (!Clients.GetNextClient(nullptr))
         Stat.Append("| - none -");
  
     // draw
     pDraw->TextOut(Stat.getData(), ::GraphicsResource.FontRegular, 1.0, cgo.Surface,cgo.X + 20,cgo.Y + 50);
 }

References StdStrBuf::Append(), StdStrBuf::AppendFormat(), C4GameControlNetwork::ClientNextControl(), C4GameControlNetwork::ClientPerfStat(), C4GameControlNetwork::ClientReady(), Clients, CNM_Central, CNM_Decentral, Config, Control, C4GameControl::ControlRate, C4GameControl::ControlTick, C4Network2IO::DataIO(), C4GraphicsResource::FontRegular, fStatusAck, fStatusReached, fStreaming, C4GameControlNetwork::getAvgControlSendTime(), C4GameControlNetwork::GetBehind(), C4GameControlNetwork::getControlPreSend(), C4Network2Status::getCtrlMode(), StdStrBuf::getData(), C4ClientCore::getID(), C4Network2Client::getID(), C4Network2ClientList::GetLocal(), C4ClientCore::getName(), C4Network2Client::getName(), C4Network2IO::getNetIOName(), C4Network2IO::getNetIOProt(), C4Network2ClientList::GetNextClient(), getPendingStreamData(), C4Network2IO::getProtBCRate(), C4Network2IO::getProtIRate(), C4Network2IO::getProtORate(), StdBuf::getSize(), C4Network2Status::getStateName(), C4Record::GetStreamingBuf(), C4Record::GetStreamingPos(), C4Network2Status::getTargetCtrlTick(), GraphicsResource, iCurrentStreamPosition, C4ClientCore::isActivated(), C4Network2Client::isActivated(), isEnabled(), C4ClientCore::isHost(), C4Network2Client::isHost(), C4ClientCore::isObserver(), C4Network2Client::isObserver(), C4Network2IO::MsgIO(), NCS_Chasing, NCS_Joining, NCS_NotReady, NCS_Remove, NetIO, C4Config::Network, P_NONE, P_TCP, P_UDP, pControl, pDraw, C4ConfigNetwork::PortTCP, C4ConfigNetwork::PortUDP, pStreamedRecord, Status, C4Facet::Surface, C4Draw::TextOut(), C4Facet::X, and C4Facet::Y.

Referenced by C4Viewport::Draw().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ EndVote()

void C4Network2::EndVote	(	C4ControlVoteType	eType,
		bool	fApprove,
		int32_t	iData
	)

Definition at line 2712 of file C4Network2.cpp.

 {
     // Remove all vote packets
     C4IDPacket *pPkt; int32_t iOrigin = C4ClientIDUnknown;
     while ((pPkt = GetVote(C4ClientIDAll, eType, iData)))
     {
         if (iOrigin == C4ClientIDUnknown)
             iOrigin = static_cast<C4ControlVote *>(pPkt->getPkt())->getByClient();
         Votes.Delete(pPkt);
     }
     // Reset timestamp
     iVoteStartTime = time(nullptr);
     // Approved own voting? Reset voting block
     if (fApprove && iOrigin == Game.Clients.getLocalID())
         iLastOwnVoting = 0;
     // Dialog open?
     if (pVoteDialog)
         if (pVoteDialog->getVoteType() == eType && pVoteDialog->getVoteData() == iData)
         {
             // close
             delete pVoteDialog;
             pVoteDialog = nullptr;
         }
     // Did we try to kick ourself? Ask if we'd like to surrender
     bool fCancelVote = (eType == VT_Kick && iData == Game.Clients.getLocalID()) || eType == VT_Cancel;
     if (!fApprove && fCancelVote && iOrigin == Game.Clients.getLocalID())
         OpenSurrenderDialog(eType, iData);
     // Check if the dialog should be opened
     OpenVoteDialog();
     // Pause/unpause voting?
     if (fApprove && eType == VT_Pause)
         fPausedForVote = !iData;
     // No voting left? Reset pause.
     if (!Votes.firstPkt())
         if (fPausedForVote)
         {
             Start();
             fPausedForVote = false;
         }
 }

References C4ClientIDAll, C4ClientIDUnknown, C4Game::Clients, C4Control::Delete(), C4Control::firstPkt(), fPausedForVote, Game, C4ClientList::getLocalID(), C4IDPacket::getPkt(), GetVote(), C4VoteDialog::getVoteData(), C4VoteDialog::getVoteType(), iLastOwnVoting, iVoteStartTime, OpenSurrenderDialog(), OpenVoteDialog(), pVoteDialog, Start(), Votes, VT_Cancel, VT_Kick, and VT_Pause.

Here is the call graph for this function:

◆ Execute() [1/2]

void C4Network2::Execute ( )

Definition at line 649 of file C4Network2.cpp.

 {
  
     // client connections
     Clients.DoConnectAttempts();
  
     // status reached?
     CheckStatusReached();
  
     if (isHost())
     {
         // remove dynamic
         if (!ResDynamic.isNull() && ::Control.ControlTick > iDynamicTick)
             RemoveDynamic();
         // Set chase target
         UpdateChaseTarget();
         // check for inactive clients and deactivate them
         DeactivateInactiveClients();
         // reference
         if (!iLastReferenceUpdate || time(nullptr) > (time_t) (iLastReferenceUpdate + C4NetReferenceUpdateInterval))
             if (NetIO.IsReferenceNeeded())
             {
                 // create
                 C4Network2Reference *pRef = new C4Network2Reference();
                 pRef->InitLocal();
                 // set
                 NetIO.SetReference(pRef);
                 iLastReferenceUpdate = time(nullptr);
             }
         // league server reference
         if (!iLastLeagueUpdate || time(nullptr) > (time_t) (iLastLeagueUpdate + iLeagueUpdateDelay))
         {
             LeagueUpdate();
         }
         // league update reply receive
         if (pLeagueClient && fHost && !pLeagueClient->isBusy() && pLeagueClient->getCurrentAction() == C4LA_Update)
         {
             LeagueUpdateProcessReply();
         }
         // voting timeout
         if (Votes.firstPkt() && time(nullptr) > (time_t) (iVoteStartTime + C4NetVotingTimeout))
         {
             C4ControlVote *pVote = static_cast<C4ControlVote *>(Votes.firstPkt()->getPkt());
             ::Control.DoInput(
               CID_VoteEnd,
               new C4ControlVoteEnd(pVote->getType(), false, pVote->getData()),
               CDT_Sync);
             iVoteStartTime = time(nullptr);
         }
         // record streaming
         if (fStreaming)
         {
             StreamIn(false);
             StreamOut();
         }
     }
     else
     {
         // request activate, if neccessary
         if (!tLastActivateRequest.IsInfinite()) RequestActivate();
     }
 }

References C4LA_Update, C4NetReferenceUpdateInterval, C4NetVotingTimeout, CDT_Sync, CheckStatusReached(), CID_VoteEnd, Clients, Control, C4GameControl::ControlTick, DeactivateInactiveClients(), C4Network2ClientList::DoConnectAttempts(), C4GameControl::DoInput(), fHost, C4Control::firstPkt(), fStreaming, C4LeagueClient::getCurrentAction(), C4ControlVote::getData(), C4IDPacket::getPkt(), C4ControlVote::getType(), iDynamicTick, iLastLeagueUpdate, iLastReferenceUpdate, iLeagueUpdateDelay, C4Network2Reference::InitLocal(), C4HTTPClient::isBusy(), isHost(), C4TimeMilliseconds::IsInfinite(), C4Network2ResCore::isNull(), C4Network2IO::IsReferenceNeeded(), iVoteStartTime, LeagueUpdate(), LeagueUpdateProcessReply(), NetIO, pLeagueClient, RemoveDynamic(), RequestActivate(), ResDynamic, C4Network2IO::SetReference(), StreamIn(), StreamOut(), tLastActivateRequest, UpdateChaseTarget(), and Votes.

Referenced by C4Game::Execute(), and OnSec1Timer().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ Execute() [2/2]

bool C4ApplicationSec1Timer::Execute

inlineoverrideprotected

Definition at line 131 of file StdScheduler.h.

     {
         if (CheckAndReset())
             OnSec1Timer();
         return true;
     }

◆ FinalInit()

bool C4Network2::FinalInit ( )

Definition at line 538 of file C4Network2.cpp.

 {
     // check reach
     CheckStatusReached(true);
     // reached, waiting for ack?
     if (fStatusReached && !fStatusAck)
     {
         // wait for go acknowledgement
         Log(LoadResStr("IDS_NET_JOINREADY"));
  
         // any pending keyboard commands should not be routed to cancel the wait dialog - flush the message queue!
         if (!Application.FlushMessages()) return false;
  
         // show box
         C4GUI::Dialog *pDlg = nullptr;
         if (!Application.isEditor)
         {
             // separate dlgs for host/client
             if (isHost())
                 pDlg = new C4Network2StartWaitDlg();
             else
                 pDlg = new C4GUI::MessageDialog(LoadResStr("IDS_NET_WAITFORSTART"), LoadResStr("IDS_NET_CAPTION"),
                                                 C4GUI::MessageDialog::btnAbort, C4GUI::Ico_NetWait, C4GUI::MessageDialog::dsSmall);
             // show it
             if (!pDlg->Show(::pGUI, true)) return false;
         }
  
         // wait for acknowledgement
         while (fStatusReached && !fStatusAck)
         {
             if (pDlg)
             {
                 // execute
                 if (!pDlg->Execute()) { delete pDlg; Clear(); return false; }
                 // aborted?
                 if (pDlg->IsAborted()) { delete pDlg; Clear(); return false; }
             }
             else if (!Application.ScheduleProcs())
                 { Clear(); return false; }
         }
         delete pDlg;
         // log
         Log(LoadResStr("IDS_NET_START"));
     }
     // synchronize
     Game.SyncClearance();
     Game.Synchronize(false);
     // finished
     return isEnabled();
 }

References Application, C4GUI::MessageDialog::btnAbort, CheckStatusReached(), Clear(), C4GUI::MessageDialog::dsSmall, C4GUI::Dialog::Execute(), C4AbstractApp::FlushMessages(), fStatusAck, fStatusReached, Game, C4GUI::Ico_NetWait, C4GUI::Dialog::IsAborted(), C4Application::isEditor, isEnabled(), isHost(), LoadResStr(), Log(), pGUI, StdScheduler::ScheduleProcs(), C4GUI::Dialog::Show(), C4Game::SyncClearance(), and C4Game::Synchronize().

Referenced by C4Game::Init().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ FinishStreaming()

bool C4Network2::FinishStreaming ( )

Definition at line 2903 of file C4Network2.cpp.

 {
     if (!fStreaming) return false;
  
     // Stream
     StreamIn(true);
  
     // Reset record pointer
     pStreamedRecord = nullptr;
  
     // Try to get rid of remaining data immediately
     iLastStreamAttempt = 0;
     StreamOut();
  
     return true;
 }

References fStreaming, iLastStreamAttempt, pStreamedRecord, StreamIn(), and StreamOut().

Here is the call graph for this function:

◆ GetLobby()

class C4GameLobby::MainDlg* C4Network2::GetLobby ( ) const

inline

Definition at line 216 of file C4Network2.h.

216 { return pLobby; } // lobby publication

References pLobby.

Referenced by C4GameLobby::Countdown::Abort(), C4GameLobby::Countdown::Countdown(), C4Network2Players::HandlePlayerInfo(), C4Network2Players::HandlePlayerInfoUpdRequest(), C4GameLobby::LobbyError(), Log(), OnClientConnect(), C4GameLobby::Countdown::OnSec1Timer(), and C4MessageInput::ProcessCommand().

Here is the caller graph for this function:

◆ getNetpuncherAddr()

StdStrBuf C4Network2::getNetpuncherAddr ( ) const

inline

Definition at line 309 of file C4Network2.h.

309 { return NetpuncherAddr; }

C4Network2::NetpuncherAddr

StdCopyStrBuf NetpuncherAddr

Definition: C4Network2.h:198

References NetpuncherAddr.

Referenced by C4Network2Reference::InitLocal(), and InitPuncher().

Here is the caller graph for this function:

◆ getNetpuncherGameID() [1/2]

C4NetpuncherID C4Network2::getNetpuncherGameID ( ) const

inline

Definition at line 308 of file C4Network2.h.

308 { return NetpuncherGameID; };

References NetpuncherGameID.

Referenced by HandlePuncherPacket(), and OnPuncherConnect().

Here is the caller graph for this function:

◆ getNetpuncherGameID() [2/2]

C4NetpuncherID::value & C4Network2::getNetpuncherGameID ( C4NetIO::HostAddress::AddressFamily family )

Definition at line 1005 of file C4Network2.cpp.

 {
     switch (family)
     {
     case C4NetIO::HostAddress::IPv4: return NetpuncherGameID.v4;
     case C4NetIO::HostAddress::IPv6: return NetpuncherGameID.v6;
     case C4NetIO::HostAddress::UnknownFamily: assert(!"Unexpected address family");
     }
     // We need to return a valid reference to satisfy the compiler, even though the code here is unreachable.
     return NetpuncherGameID.v4;
 }

References C4NetIO::HostAddress::IPv4, C4NetIO::HostAddress::IPv6, NetpuncherGameID, C4NetIO::HostAddress::UnknownFamily, C4NetpuncherID::v4, and C4NetpuncherID::v6.

Referenced by C4Network2Reference::InitLocal().

Here is the caller graph for this function:

◆ GetPassword()

const char* C4Network2::GetPassword ( ) const

inline

Definition at line 217 of file C4Network2.h.

217 { return sPassword.getData(); } // Oh noez, now the password is public!

References StdStrBuf::getData(), and sPassword.

Referenced by C4GameOptionButtons::OnBtnPassword(), and C4GameOptionButtons::UpdatePasswordBtn().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ getPendingStreamData()

size_t C4Network2::getPendingStreamData ( ) const

inline

Definition at line 300 of file C4Network2.h.

300 { return StreamingBuf.getSize() - StreamCompressor.avail_out; }

C4Network2::StreamCompressor

z_stream StreamCompressor

Definition: C4Network2.h:191

C4Network2::StreamingBuf

StdBuf StreamingBuf

Definition: C4Network2.h:190

References StdBuf::getSize(), StreamCompressor, and StreamingBuf.

Referenced by DrawStatus(), StreamIn(), and StreamOut().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ GetVote()

C4IDPacket * C4Network2::GetVote	(	int32_t	iClientID,
		C4ControlVoteType	eType,
		int32_t	iData
	)

Definition at line 2700 of file C4Network2.cpp.

 {
     C4ControlVote *pVote;
     for (C4IDPacket *pPkt = Votes.firstPkt(); pPkt; pPkt = Votes.nextPkt(pPkt))
         if (pPkt->getPktType() == CID_Vote)
             if ((pVote = static_cast<C4ControlVote *>(pPkt->getPkt())))
                 if (iClientID == C4ClientIDUnknown || pVote->getByClient() == iClientID)
                     if (pVote->getType() == eType && pVote->getData() == iData)
                         return pPkt;
     return nullptr;
 }

References C4ClientIDUnknown, CID_Vote, C4Control::firstPkt(), C4ControlPacket::getByClient(), C4ControlVote::getData(), C4ControlVote::getType(), C4Control::nextPkt(), and Votes.

Referenced by EndVote(), OpenVoteDialog(), and Vote().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ HandleActivateReq()

void C4Network2::HandleActivateReq	(	int32_t	iTick,
		C4Network2Client *	pClient
	)

protected

Definition at line 1491 of file C4Network2.cpp.

 {
     if (!isHost()) return;
     // not allowed or already activated? ignore
     if (pByClient->isObserver() || pByClient->isActivated()) return;
     // not joined completely yet? ignore
     if (!pByClient->isWaitedFor()) return;
     // check behind limit
     if (isRunning())
     {
         // make a guess how much the client lags.
         int32_t iLagFrames = Clamp(pByClient->getMsgConn()->getPingTime() * Game.FPS / 500, 0, 100);
         if (iTick < Game.FrameCounter - iLagFrames - C4NetMaxBehind4Activation)
             return;
     }
     // activate him
     ::Control.DoInput(CID_ClientUpdate,
                       new C4ControlClientUpdate(pByClient->getID(), CUT_Activate, true),
                       CDT_Sync);
 }

References C4NetMaxBehind4Activation, CDT_Sync, CID_ClientUpdate, Clamp(), Control, CUT_Activate, C4GameControl::DoInput(), C4Game::FPS, C4Game::FrameCounter, Game, C4Network2Client::getID(), C4Network2Client::getMsgConn(), C4Network2IOConnection::getPingTime(), C4Network2Client::isActivated(), isHost(), C4Network2Client::isObserver(), isRunning(), and C4Network2Client::isWaitedFor().

Referenced by HandlePacket().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ HandleConn()

void C4Network2::HandleConn	(	const class C4PacketConn &	Pkt,
		C4Network2IOConnection *	pConn,
		C4Network2Client *	pClient
	)

protected

Definition at line 1220 of file C4Network2.cpp.

 {
     // security
     if (!pConn) return;
  
     // Handles a connect request (packet PID_Conn).
     // Check if this peer should be allowed to connect, make space for the new connection.
  
     // connection is closed?
     if (pConn->isClosed())
         return;
  
     // set up core
     const C4ClientCore &CCore = Pkt.getCCore();
     C4ClientCore NewCCore = CCore;
  
     // accept connection?
     StdStrBuf reply;
     bool fOK = false;
  
     // search client
     if (!pClient && Pkt.getCCore().getID() != C4ClientIDUnknown)
         pClient = Clients.GetClient(Pkt.getCCore());
  
     // check engine version
     bool fWrongPassword = false;
     if (Pkt.getVer() != C4XVER1*100 + C4XVER2)
     {
         reply.Format("wrong engine (%d.%d, I have %d.%d)", Pkt.getVer()/100, Pkt.getVer()%100, C4XVER1, C4XVER2);
         fOK = false;
     }
     else
     {
         if (pClient)
             if (CheckConn(NewCCore, pConn, pClient, &reply))
             {
                 // accept
                 if (!reply) reply = "connection accepted";
                 fOK = true;
             }
         // client: host connection?
         if (!fOK && !isHost() && Status.getState() == GS_Init && !Clients.GetHost())
             if (HostConnect(NewCCore, pConn, &reply))
             {
                 // accept
                 if (!reply) reply = "host connection accepted";
                 fOK = true;
             }
         // host: client join? (NewCCore will be changed by Join()!)
         if (!fOK && isHost() && !pClient)
         {
             // check password
             if (!sPassword.isNull() && !SEqual(Pkt.getPassword(), sPassword.getData()))
             {
                 reply = "wrong password";
                 fWrongPassword = true;
             }
             // accept join
             else if (Join(NewCCore, pConn, &reply))
             {
                 // save core
                 pConn->SetCCore(NewCCore);
                 // accept
                 if (!reply) reply = "join accepted";
                 fOK = true;
             }
         }
     }
  
     // denied? set default reason
     if (!fOK && !reply) reply = "connection denied";
  
     // OK and already half accepted? Skip (double-checked: ok).
     if (fOK && pConn->isHalfAccepted())
         return;
  
     // send answer
     C4PacketConnRe pcr(fOK, fWrongPassword, reply.getData());
     if (!pConn->Send(MkC4NetIOPacket(PID_ConnRe, pcr)))
         return;
  
     // accepted?
     if (fOK)
     {
         // set status
         if (!pConn->isClosed())
             pConn->SetHalfAccepted();
     }
     // denied? close
     else
     {
         // log & close
         LogSilentF("Network: connection by %s (%s) blocked: %s", CCore.getName(), pConn->getPeerAddr().ToString().getData(), reply.getData());
         pConn->Close();
     }
 }

References C4ClientIDUnknown, CheckConn(), Clients, C4Network2IOConnection::Close(), StdStrBuf::Format(), fWrongPassword, C4PacketConn::getCCore(), C4Network2ClientList::GetClient(), StdStrBuf::getData(), C4Network2ClientList::GetHost(), C4ClientCore::getID(), C4ClientCore::getName(), C4PacketConn::getPassword(), C4Network2IOConnection::getPeerAddr(), C4Network2Status::getState(), C4PacketConn::getVer(), GS_Init, HostConnect(), C4Network2IOConnection::isClosed(), C4Network2IOConnection::isHalfAccepted(), isHost(), StdStrBuf::isNull(), Join(), LogSilentF(), MkC4NetIOPacket(), PID_ConnRe, C4Network2IOConnection::Send(), SEqual(), C4Network2IOConnection::SetCCore(), C4Network2IOConnection::SetHalfAccepted(), sPassword, Status, and C4NetIO::EndpointAddress::ToString().

Referenced by HandlePacket().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ HandleConnRe()

void C4Network2::HandleConnRe	(	const class C4PacketConnRe &	Pkt,
		C4Network2IOConnection *	pConn,
		C4Network2Client *	pClient
	)

protected

Definition at line 1385 of file C4Network2.cpp.

 {
     // Handle the connection request reply. After this handling, the connection should
     // be either fully associated with a client (fully accepted) or closed.
     // Note that auto-accepted connection have to processed here once, too, as the
     // client must get associated with the connection. After doing so, the connection
     // auto-accept flag will be reset to mark the connection fully accepted.
  
     // security
     if (!pConn) return;
     if (!pClient) { pConn->Close(); return; }
  
     // negative reply?
     if (!Pkt.isOK())
     {
         // wrong password?
         fWrongPassword = Pkt.isPasswordWrong();
         // show message
         LogSilentF("Network: connection to %s (%s) refused: %s", pClient->getName(), pConn->getPeerAddr().ToString().getData(), Pkt.getMsg());
         // close connection
         pConn->Close();
         return;
     }
  
     // connection is closed?
     if (!pConn->isOpen())
         return;
  
     // already accepted? ignore
     if (pConn->isAccepted() && !pConn->isAutoAccepted()) return;
  
     // first connection?
     bool fFirstConnection = !pClient->isConnected();
  
     // accept connection
     pConn->SetAccepted(); pConn->ResetAutoAccepted();
  
     // add connection
     pConn->SetCCore(pClient->getCore());
     if (pConn->getNetClass() == NetIO.MsgIO()) pClient->SetMsgConn(pConn);
     if (pConn->getNetClass() == NetIO.DataIO()) pClient->SetDataConn(pConn);
  
     // add peer connect address to client address list
     if (!pConn->getConnectAddr().IsNull())
     {
         C4Network2Address Addr(pConn->getConnectAddr(), pConn->getProtocol());
         pClient->AddAddr(Addr, Status.getState() != GS_Init);
     }
  
     // handle
     OnConnect(pClient, pConn, Pkt.getMsg(), fFirstConnection);
 }

Referenced by HandlePacket().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ HandleJoinData()

void C4Network2::HandleJoinData ( const class C4PacketJoinData & rPkt )

protected

Definition at line 1512 of file C4Network2.cpp.

 {
     // init only
     if (Status.getState() != GS_Init)
         { LogSilentF("Network: unexpected join data received!"); return; }
     // get client ID
     if (rPkt.getClientID() == C4ClientIDUnknown)
         { LogSilentF("Network: host didn't set client ID!"); Clear(); return; }
     // set local ID
     ResList.SetLocalID(rPkt.getClientID());
     Game.Parameters.Clients.SetLocalID(rPkt.getClientID());
     // read and validate status
     HandleStatus(rPkt.getStatus());
     if (Status.getState() != GS_Lobby && Status.getState() != GS_Pause && Status.getState() != GS_Go)
         { LogSilentF("Network: join data has bad game status: %s", Status.getStateName()); Clear(); return; }
     // copy scenario parameter defs for lobby display
     ::Game.ScenarioParameterDefs = rPkt.ScenarioParameterDefs;
     // copy parameters
     ::Game.Parameters = rPkt.Parameters;
     // set local client
     C4Client *pLocalClient = Game.Clients.getClientByID(rPkt.getClientID());
     if (!pLocalClient)
         { LogSilentF("Network: Could not find local client in join data!"); Clear(); return; }
     // save back dynamic data
     ResDynamic = rPkt.getDynamicCore();
     iDynamicTick = rPkt.getStartCtrlTick();
     // initialize control
     ::Control.ControlRate = rPkt.Parameters.ControlRate;
     pControl->Init(rPkt.getClientID(), false, rPkt.getStartCtrlTick(), pLocalClient->isActivated(), this);
     pControl->CopyClientList(Game.Parameters.Clients);
     // set local core
     NetIO.SetLocalCCore(pLocalClient->getCore());
     // add the resources to the network resource list
     Game.Parameters.GameRes.InitNetwork(&ResList);
     // load dynamic
     if (!ResList.AddByCore(ResDynamic))
         { LogFatal("Network: can not not retrieve dynamic!"); Clear(); return; }
     // load player resources
     Game.Parameters.PlayerInfos.LoadResources();
     // send additional addresses
     Clients.SendAddresses(nullptr);
 }

References C4Network2ResList::AddByCore(), C4ClientIDUnknown, Clear(), C4GameParameters::Clients, C4Game::Clients, Clients, Control, C4GameControl::ControlRate, C4GameParameters::ControlRate, C4GameControlNetwork::CopyClientList(), Game, C4GameParameters::GameRes, C4ClientList::getClientByID(), C4PacketJoinData::getClientID(), C4Client::getCore(), C4PacketJoinData::getDynamicCore(), C4PacketJoinData::getStartCtrlTick(), C4Network2Status::getState(), C4Network2Status::getStateName(), C4PacketJoinData::getStatus(), GS_Go, GS_Init, GS_Lobby, GS_Pause, HandleStatus(), iDynamicTick, C4GameControlNetwork::Init(), C4GameResList::InitNetwork(), C4Client::isActivated(), C4PlayerInfoList::LoadResources(), LogFatal(), LogSilentF(), NetIO, C4Game::Parameters, C4PacketJoinData::Parameters, pControl, C4GameParameters::PlayerInfos, ResDynamic, ResList, C4Game::ScenarioParameterDefs, C4PacketJoinData::ScenarioParameterDefs, C4Network2ClientList::SendAddresses(), C4Network2IO::SetLocalCCore(), C4Network2ResList::SetLocalID(), C4ClientList::SetLocalID(), and Status.

Referenced by HandlePacket().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ HandleLobbyPacket()

void C4Network2::HandleLobbyPacket	(	char	cStatus,
		const C4PacketBase *	pBasePkt,
		C4Network2IOConnection *	pConn
	)

Definition at line 963 of file C4Network2.cpp.

 {
     // find associated client
     C4Network2Client *pClient = Clients.GetClient(pConn);
     if (!pClient) pClient = Clients.GetClientByID(pConn->getClientID());
     // forward directly to lobby
     if (pLobby) pLobby->HandlePacket(cStatus, pBasePkt, pClient);
 }

References Clients, C4Network2ClientList::GetClient(), C4Network2ClientList::GetClientByID(), C4Network2IOConnection::getClientID(), C4GameLobby::MainDlg::HandlePacket(), and pLobby.

Referenced by C4Network2IO::CallHandlers().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ HandlePacket()

void C4Network2::HandlePacket	(	char	cStatus,
		const C4PacketBase *	pBasePkt,
		C4Network2IOConnection *	pConn
	)

Definition at line 879 of file C4Network2.cpp.

 {
     // find associated client
     C4Network2Client *pClient = Clients.GetClient(pConn);
     if (!pClient) pClient = Clients.GetClientByID(pConn->getClientID());
  
     // local? ignore
     if (pClient && pClient->isLocal()) { pConn->Close(); return; }
  
 #define GETPKT(type, name) \
     assert(pPacket); const type &name = \
      static_cast<const type &>(*pPacket);
  
     switch (cStatus)
     {
     case PID_Conn: // connection request
     {
         if (!pConn->isOpen()) break;
         GETPKT(C4PacketConn, rPkt);
         HandleConn(rPkt, pConn, pClient);
     }
     break;
  
     case PID_ConnRe: // connection request reply
     {
         GETPKT(C4PacketConnRe, rPkt);
         HandleConnRe(rPkt, pConn, pClient);
     }
     break;
  
     case PID_JoinData:
     {
         // host->client only
         if (isHost() || !pClient || !pClient->isHost()) break;
         if (!pConn->isOpen()) break;
         // handle
         GETPKT(C4PacketJoinData, rPkt)
         HandleJoinData(rPkt);
     }
     break;
  
     case PID_Status: // status change
     {
         // by host only
         if (isHost() || !pClient || !pClient->isHost()) break;
         if (!pConn->isOpen()) break;
         // must be initialized
         if (Status.getState() == GS_Init) break;
         // handle
         GETPKT(C4Network2Status, rPkt);
         HandleStatus(rPkt);
     }
     break;
  
     case PID_StatusAck: // status change acknowledgement
     {
         // host->client / client->host only
         if (!pClient) break;
         if (!isHost() && !pClient->isHost()) break;
         // must be initialized
         if (Status.getState() == GS_Init) break;
         // handle
         GETPKT(C4Network2Status, rPkt);
         HandleStatusAck(rPkt, pClient);
     }
     break;
  
     case PID_ClientActReq: // client activation request
     {
         // client->host only
         if (!isHost() || !pClient || pClient->isHost()) break;
         // must be initialized
         if (Status.getState() == GS_Init) break;
         // handle
         GETPKT(C4PacketActivateReq, rPkt)
         HandleActivateReq(rPkt.getTick(), pClient);
     }
     break;
  
     }
  
 #undef GETPKT
 }

References Clients, C4Network2IOConnection::Close(), C4Network2ClientList::GetClient(), C4Network2ClientList::GetClientByID(), C4Network2IOConnection::getClientID(), GETPKT, C4Network2Status::getState(), GS_Init, HandleActivateReq(), HandleConn(), HandleConnRe(), HandleJoinData(), HandleStatus(), HandleStatusAck(), isHost(), C4Network2Client::isHost(), C4Network2Client::isLocal(), C4Network2IOConnection::isOpen(), PID_ClientActReq, PID_Conn, PID_ConnRe, PID_JoinData, PID_Status, PID_StatusAck, and Status.

Referenced by C4Network2IO::CallHandlers().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ HandlePuncherPacket()

bool C4Network2::HandlePuncherPacket	(	C4NetpuncherPacket::uptr	pkt,
		C4NetIO::HostAddress::AddressFamily	family
	)

Definition at line 972 of file C4Network2.cpp.

 {
     // TODO: is this all thread-safe?
     assert(pkt);
 #define GETPKT(c) dynamic_cast<C4NetpuncherPacket##c*>(pkt.get())
     switch (pkt->GetType())
     {
         case PID_Puncher_CReq:
             if (isHost())
             {
                 NetIO.Punch(GETPKT(CReq)->GetAddr());
                 return true;
             }
             else
             {
                 // The IP/Port should be already in the masterserver list, so just keep trying.
                 return Status.getState() == GS_Init;
             }
         case PID_Puncher_AssID:
             if (isHost())
             {
                 getNetpuncherGameID(family) = GETPKT(AssID)->GetID();
                 InvalidateReference();
             }
             else
             {
                 // The netpuncher hands out IDs for everyone, but clients have no use for them.
             }
             return true;
         default: return false;
     }
 }

References getNetpuncherGameID(), GETPKT, C4Network2Status::getState(), GS_Init, InvalidateReference(), isHost(), NetIO, PID_Puncher_AssID, PID_Puncher_CReq, C4Network2IO::Punch(), and Status.

Referenced by C4Network2IO::HandlePuncherPacket().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ HandleStatus()

void C4Network2::HandleStatus ( const C4Network2Status & nStatus )

protected

Definition at line 1438 of file C4Network2.cpp.

 {
     // set
     Status = nStatus;
     // log
     LogSilentF("Network: going into status %s (tick %d)", Status.getStateName(), nStatus.getTargetCtrlTick());
     // reset flags
     fStatusReached = fStatusAck = false;
     // check: reached?
     CheckStatusReached();
 }

References CheckStatusReached(), fStatusAck, fStatusReached, C4Network2Status::getStateName(), C4Network2Status::getTargetCtrlTick(), LogSilentF(), and Status.

Referenced by HandleJoinData(), and HandlePacket().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ HandleStatusAck()

void C4Network2::HandleStatusAck	(	const C4Network2Status &	nStatus,
		C4Network2Client *	pClient
	)

protected

Definition at line 1450 of file C4Network2.cpp.

 {
     // security
     if (!pClient->hasJoinData() || pClient->isRemoved()) return;
     // status doesn't match?
     if (nStatus.getState() != Status.getState() || nStatus.getTargetCtrlTick() < Status.getTargetCtrlTick())
         return;
     // host: wait until all clients are ready
     if (isHost())
     {
         // check: target tick change?
         if (!fStatusAck && nStatus.getTargetCtrlTick() > Status.getTargetCtrlTick())
             // take the new status
             ChangeGameStatus(nStatus.getState(), nStatus.getTargetCtrlTick());
         // already acknowledged? Send another ack
         if (fStatusAck)
             pClient->SendMsg(MkC4NetIOPacket(PID_StatusAck, nStatus));
         // mark as ready (will clear chase-flag)
         pClient->SetStatus(NCS_Ready);
         // check: everyone ready?
         if (!fStatusAck && fStatusReached)
             CheckStatusAck();
     }
     else
     {
         // target tick doesn't match? ignore
         if (nStatus.getTargetCtrlTick() != Status.getTargetCtrlTick())
             return;
         // reached?
         // can be ignored safely otherwise - when the status is reached, we will send
         // status ack on which the host should generate another status ack (see above)
         if (fStatusReached)
         {
             // client: set flags, call handler
             fStatusAck = true; fChasing = false;
             OnStatusAck();
         }
  
     }
 }

References ChangeGameStatus(), CheckStatusAck(), fChasing, fStatusAck, fStatusReached, C4Network2Status::getState(), C4Network2Status::getTargetCtrlTick(), C4Network2Client::hasJoinData(), isHost(), C4Network2Client::isRemoved(), MkC4NetIOPacket(), NCS_Ready, OnStatusAck(), PID_StatusAck, C4Network2Client::SendMsg(), C4Network2Client::SetStatus(), and Status.

Referenced by HandlePacket().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ HostConnect()

bool C4Network2::HostConnect	(	const C4ClientCore &	CCore,
		C4Network2IOConnection *	pConn,
		StdStrBuf *	szReply
	)

protected

Definition at line 1330 of file C4Network2.cpp.

 {
     if (!pConn) return false;
     if (!CCore.isHost()) { *szReply = "not host"; return false; }
     // create client class for host
     // (core is unofficial, see InitClient() -  will be overwritten later in HandleJoinData)
     C4Client *pClient = Game.Clients.Add(CCore);
     if (!pClient) return false;
     // accept
     return true;
 }

References C4ClientList::Add(), C4Game::Clients, Game, and C4ClientCore::isHost().

Referenced by HandleConn().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ InitClient() [1/2]

InitResult C4Network2::InitClient	(	const class C4Network2Reference &	Ref,
		bool	fObserver
	)

Referenced by C4Game::InitNetworkFromReference().

Here is the caller graph for this function:

◆ InitClient() [2/2]

InitResult C4Network2::InitClient	(	const std::vector< class C4Network2Address > &	Addrs,
		const class C4ClientCore &	HostCore,
		const char *	szPassword = `nullptr`
	)

◆ InitHost()

bool C4Network2::InitHost ( bool fLobby )

Definition at line 139 of file C4Network2.cpp.

 {
     if (isEnabled()) Clear();
     // initialize everything
     Status.Set(fLobby ? GS_Lobby : GS_Go, ::Control.ControlTick);
     Status.SetCtrlMode(Config.Network.ControlMode);
     fHost = true;
     fStatusAck = fStatusReached = true;
     fChasing = false;
     fAllowJoin = false;
     iNextClientID = C4ClientIDStart;
     NetpuncherGameID = C4NetpuncherID();
     NetpuncherAddr = ::Config.Network.PuncherAddress;
     // initialize client list
     Clients.Init(&Game.Clients, true);
     // initialize resource list
     if (!ResList.Init(Game.Clients.getLocalID(), &NetIO))
         { LogFatal("Network: failed to initialize resource list!"); Clear(); return false; }
     if (!Game.Parameters.InitNetwork(&ResList))
         return false;
     // create initial dynamic
     if (!CreateDynamic(true))
         return false;
     // initialize net i/o
     if (!InitNetIO(false, true))
         { Clear(); return false; }
     // init network control
     pControl = &::Control.Network;
     pControl->Init(C4ClientIDHost, true, ::Control.getNextControlTick(), true, this);
     // init league
     bool fCancel = true;
     if (!InitLeague(&fCancel) || !LeagueStart(&fCancel))
     {
         // deinit league
         DeinitLeague();
         // user cancelled?
         if (fCancel)
             return false;
         // in console mode, bail out
 #ifdef USE_CONSOLE
         return false;
 #endif
     }
     // allow connect
     NetIO.SetAcceptMode(true);
     // timer
     Application.Add(this);
     // ok
     return true;
 }

References StdScheduler::Add(), Application, C4ClientIDHost, C4ClientIDStart, Clear(), C4Game::Clients, Clients, Config, Control, C4ConfigNetwork::ControlMode, C4GameControl::ControlTick, CreateDynamic(), DeinitLeague(), fAllowJoin, fChasing, fHost, fStatusAck, fStatusReached, Game, C4ClientList::getLocalID(), C4GameControl::getNextControlTick(), GS_Go, GS_Lobby, iNextClientID, C4Network2ClientList::Init(), C4GameControlNetwork::Init(), C4Network2ResList::Init(), InitLeague(), InitNetIO(), C4GameParameters::InitNetwork(), isEnabled(), LeagueStart(), LogFatal(), NetIO, NetpuncherAddr, NetpuncherGameID, C4Config::Network, C4GameControl::Network, C4Game::Parameters, pControl, C4ConfigNetwork::PuncherAddress, ResList, C4Network2Status::Set(), C4Network2IO::SetAcceptMode(), C4Network2Status::SetCtrlMode(), and Status.

Referenced by C4Game::InitNetworkHost().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ InitLeague()

bool C4Network2::InitLeague ( bool * pCancel )

protected

Definition at line 2047 of file C4Network2.cpp.

 {
  
     if (fHost)
     {
  
         // Clear parameters
         MasterServerAddress.Clear();
         Game.Parameters.League.Clear();
         Game.Parameters.LeagueAddress.Clear();
         delete pLeagueClient;
         pLeagueClient = nullptr;
  
         // Not needed?
         if (!Config.Network.MasterServerSignUp && !Config.Network.LeagueServerSignUp)
             return true;
  
         // Save address
         MasterServerAddress = Config.Network.GetLeagueServerAddress();
         if (Config.Network.LeagueServerSignUp)
         {
             Game.Parameters.LeagueAddress = MasterServerAddress;
             // enforce some league rules
             Game.Parameters.EnforceLeagueRules(&Game.C4S);
         }
  
     }
     else
     {
  
         // Get league server from parameters
         MasterServerAddress = Game.Parameters.LeagueAddress;
  
         // Not needed?
         if (!MasterServerAddress.getLength())
             return true;
  
     }
  
     // Init
     pLeagueClient = new C4LeagueClient();
     if (!pLeagueClient->Init() ||
         !pLeagueClient->SetServer(MasterServerAddress.getData()))
     {
         // Log message
         StdStrBuf Message = FormatString(LoadResStr("IDS_NET_ERR_LEAGUEINIT"), pLeagueClient->GetError());
         LogFatal(Message.getData());
         // Clear league
         delete pLeagueClient; pLeagueClient = nullptr;
         if (fHost)
             Game.Parameters.LeagueAddress.Clear();
         // Show message, allow abort
         bool fResult = true;
         if (!Application.isEditor)
             fResult = ::pGUI->ShowMessageModal(Message.getData(), LoadResStr("IDS_NET_ERR_LEAGUE"),
                                                (pCancel ? C4GUI::MessageDialog::btnOK : 0) | C4GUI::MessageDialog::btnAbort,
                                                C4GUI::Ico_Error);
         if (pCancel) *pCancel = fResult;
         return false;
     }
  
     // Add to message loop
     Application.Add(pLeagueClient);
  
     // OK
     return true;
 }

References StdScheduler::Add(), Application, C4GUI::MessageDialog::btnAbort, C4GUI::MessageDialog::btnOK, C4Game::C4S, StdStrBuf::Clear(), Config, C4GameParameters::EnforceLeagueRules(), fHost, FormatString(), Game, StdStrBuf::getData(), C4HTTPClient::GetError(), C4ConfigNetwork::GetLeagueServerAddress(), StdStrBuf::getLength(), C4GUI::Ico_Error, C4HTTPClient::Init(), C4Application::isEditor, C4GameParameters::League, C4GameParameters::LeagueAddress, C4ConfigNetwork::LeagueServerSignUp, LoadResStr(), LogFatal(), MasterServerAddress, C4ConfigNetwork::MasterServerSignUp, C4Config::Network, C4Game::Parameters, pGUI, pLeagueClient, C4HTTPClient::SetServer(), and C4GUI::Screen::ShowMessageModal().

Referenced by InitHost(), and LeagueSignupEnable().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ InitNetIO()

bool C4Network2::InitNetIO	(	bool	fNoClientID,
		bool	fHost
	)

protected

Definition at line 1197 of file C4Network2.cpp.

 {
     // clear
     NetIO.Clear();
     Config.Network.CheckPortsForCollisions();
     // discovery: disable for client
     int16_t iPortDiscovery = fHost ? Config.Network.PortDiscovery : -1;
     int16_t iPortRefServer = fHost ? Config.Network.PortRefServer : -1;
     // init subclass
     if (!NetIO.Init(Config.Network.PortTCP, Config.Network.PortUDP, iPortDiscovery, iPortRefServer, fHost, !!Config.Network.EnableUPnP))
         return false;
     // set core (unset ID if sepecified, has to be set later)
     C4ClientCore Core = Game.Clients.getLocalCore();
     if (fNoClientID) Core.SetID(C4ClientIDUnknown);
     NetIO.SetLocalCCore(Core);
     // safe addresses of local client
     Clients.GetLocal()->AddLocalAddrs(
       NetIO.hasTCP() ? Config.Network.PortTCP : -1,
       NetIO.hasUDP() ? Config.Network.PortUDP : -1);
     // ok
     return true;
 }

References C4Network2Client::AddLocalAddrs(), C4ClientIDUnknown, C4ConfigNetwork::CheckPortsForCollisions(), C4Network2IO::Clear(), C4Game::Clients, Clients, Config, C4ConfigNetwork::EnableUPnP, fHost, Game, C4Network2ClientList::GetLocal(), C4ClientList::getLocalCore(), C4Network2IO::hasTCP(), C4Network2IO::hasUDP(), C4Network2IO::Init(), NetIO, C4Config::Network, C4ConfigNetwork::PortDiscovery, C4ConfigNetwork::PortRefServer, C4ConfigNetwork::PortTCP, C4ConfigNetwork::PortUDP, C4ClientCore::SetID(), and C4Network2IO::SetLocalCCore().

Referenced by InitHost().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ InitPuncher()

void C4Network2::InitPuncher ( )

protected

Definition at line 1044 of file C4Network2.cpp.

 {
     // We have an internet connection, so let's punch the puncher server here in order to open an udp port
     C4NetIO::addr_t PuncherAddr;
     PuncherAddr.SetAddress(getNetpuncherAddr(), C4NetIO::HostAddress::IPv4);
     if (!PuncherAddr.IsNull())
     {
         PuncherAddr.SetDefaultPort(C4NetStdPortPuncher);
         NetIO.InitPuncher(PuncherAddr);
     }
     PuncherAddr.SetAddress(getNetpuncherAddr(), C4NetIO::HostAddress::IPv6);
     if (!PuncherAddr.IsNull())
     {
         PuncherAddr.SetDefaultPort(C4NetStdPortPuncher);
         NetIO.InitPuncher(PuncherAddr);
     }
 }

References C4NetStdPortPuncher, getNetpuncherAddr(), C4Network2IO::InitPuncher(), C4NetIO::HostAddress::IPv4, C4NetIO::HostAddress::IPv6, C4NetIO::EndpointAddress::IsNull(), NetIO, C4NetIO::EndpointAddress::SetAddress(), and C4NetIO::EndpointAddress::SetDefaultPort().

Referenced by LeagueStart().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ InvalidateReference()

void C4Network2::InvalidateReference ( )

Definition at line 2040 of file C4Network2.cpp.

 {
     // Update both local and league reference as soon as possible
     iLastReferenceUpdate = 0;
     iLeagueUpdateDelay = C4NetMinLeagueUpdateInterval;
 }

References C4NetMinLeagueUpdateInterval, iLastReferenceUpdate, and iLeagueUpdateDelay.

Referenced by ChangeGameStatus(), C4Network2Players::HandlePlayerInfo(), HandlePuncherPacket(), C4Network2Players::OnClientPart(), C4GameOptionButtons::OnCommentSet(), C4MessageInput::ProcessCommand(), and SetPassword().

Here is the caller graph for this function:

◆ isEnabled()

bool C4Network2::isEnabled ( ) const

inline

Definition at line 203 of file C4Network2.h.

203 { return Status.isEnabled(); }

C4Network2Status::isEnabled

bool isEnabled() const

Definition: C4Network2.h:86

References C4Network2Status::isEnabled(), and Status.

Referenced by C4Game::Abort(), C4MainMenu::ActivateMain(), C4PlayerInfoList::AddInfo(), C4ChartDialog::C4ChartDialog(), C4Game::CanQuickSave(), DoLobby(), DrawStatus(), C4Game::Evaluate(), C4Viewport::Execute(), C4PlayerList::FileInUse(), FinalInit(), C4Network2Players::HandlePlayerInfo(), C4Network2Players::HandlePlayerInfoUpdRequest(), C4Console::In(), C4Game::Init(), C4Network2Players::Init(), C4Game::InitControl(), C4Game::InitGameFinal(), InitHost(), C4PlayerInfoList::InitLocal(), C4Game::InitPlayers(), C4Game::IsPaused(), C4Network2Players::JoinLocalPlayer(), C4PlayerList::JoinNew(), C4PlayerInfo::LoadFromLocalFile(), C4PlayerInfoList::LocalJoinUnjoinedPlayersInQueue(), C4MainMenu::MenuCommand(), C4Network2Players::OnClientPart(), C4GameSaveSavegame::OnSaving(), C4AbortGameDialog::OnShown(), C4Game::OpenScenario(), C4Game::Pause(), Pause(), C4MessageInput::ProcessCommand(), C4TeamList::RecheckPlayerInfoTeams(), C4PlayerInfoList::RecreatePlayers(), C4Game::ReloadDef(), C4Game::ReloadFile(), C4Game::ReloadParticle(), C4Network2Players::RequestPlayerInfoUpdate(), C4PlayerInfoList::RestoreSavegameInfos(), RetrieveRes(), C4Console::SaveGame(), C4PlayerInfoList::SetAsRestoreInfos(), C4TeamList::SetTeamColors(), C4TeamList::SetTeamDistribution(), Start(), Sync(), C4Game::Synchronize(), C4Game::Unpause(), C4Console::UpdateNetMenu(), C4Console::UpdatePlayerMenu(), C4GameSaveSavegame::WriteDesc(), C4GameSaveRecord::WriteDesc(), and C4GameSave::WriteDescDate().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ isFrozen()

bool C4Network2::isFrozen ( ) const

Definition at line 1805 of file C4Network2.cpp.

 {
     // "frozen" means all clients are garantueed to be in the same tick.
     // This is only the case if the game is not started yet (lobby) or the
     // tick has been ensured (pause) and acknowledged by all joined clients.
     // Note unjoined clients must be ignored here - they can't be faster than
     // the host, anyway.
     if (Status.getState() == GS_Lobby) return true;
     if (Status.getState() == GS_Pause && fStatusAck) return true;
     return false;
 }

References fStatusAck, C4Network2Status::getState(), GS_Lobby, GS_Pause, and Status.

Referenced by C4GameControlNetwork::DecideControlDelivery(), C4GameControlNetwork::DoInput(), C4GameControlNetwork::HandleControlPkt(), and Sync().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ isHost()

bool C4Network2::isHost ( ) const

inline

Definition at line 209 of file C4Network2.h.

209 { return fHost; }

References fHost.

Here is the caller graph for this function:

◆ isJoinAllowed()

bool C4Network2::isJoinAllowed ( ) const

inline

Definition at line 213 of file C4Network2.h.

213 { return fAllowJoin; }

References fAllowJoin.

Referenced by C4Network2Reference::InitLocal().

Here is the caller graph for this function:

◆ isLobbyActive()

bool C4Network2::isLobbyActive ( ) const

inline

Definition at line 204 of file C4Network2.h.

204 { return Status.isLobbyActive(); }

C4Network2Status::isLobbyActive

bool isLobbyActive() const

Definition: C4Network2.h:87

References C4Network2Status::isLobbyActive(), and Status.

Referenced by DoLobby(), C4GraphicsSystem::Execute(), C4Network2Players::HandlePlayerInfoUpdRequest(), C4Game::Init(), C4TeamList::IsTeamVisible(), OnClientConnect(), and C4TeamList::RecheckPlayerInfoTeams().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ isLobbyCountDown()

bool C4Network2::isLobbyCountDown ( )

inline

Definition at line 297 of file C4Network2.h.

297 { return pLobbyCountdown != nullptr; }

References pLobbyCountdown.

Referenced by C4MessageInput::ProcessCommand().

Here is the caller graph for this function:

◆ isObservingAllowed()

bool C4Network2::isObservingAllowed ( ) const

inline

Definition at line 214 of file C4Network2.h.

214 { return fAllowObserve; }

C4Network2::fAllowObserve

bool fAllowObserve

Definition: C4Network2.h:130

References fAllowObserve.

Referenced by C4Network2Reference::InitLocal().

Here is the caller graph for this function:

◆ isPassworded()

bool C4Network2::isPassworded ( ) const

inline

Definition at line 218 of file C4Network2.h.

218 { return !sPassword.isNull(); }

References StdStrBuf::isNull(), and sPassword.

Referenced by C4GameOptionButtons::C4GameOptionButtons(), C4Network2Reference::InitLocal(), and SetPassword().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ isPastLobby()

bool C4Network2::isPastLobby ( ) const

inline

Definition at line 205 of file C4Network2.h.

205 { return Status.isPastLobby(); }

C4Network2Status::isPastLobby

bool isPastLobby() const

Definition: C4Network2.h:88

References C4Network2Status::isPastLobby(), and Status.

Here is the call graph for this function:

◆ isPaused()

bool C4Network2::isPaused ( ) const

inline

Definition at line 207 of file C4Network2.h.

207 { return Status.isPaused() && isStatusAck(); }

C4Network2::isStatusAck

bool isStatusAck() const

Definition: C4Network2.h:210

C4Network2Status::isPaused

bool isPaused() const

Definition: C4Network2.h:89

References C4Network2Status::isPaused(), isStatusAck(), and Status.

Here is the call graph for this function:

◆ isPausing()

bool C4Network2::isPausing ( ) const

inline

Definition at line 208 of file C4Network2.h.

208 { return Status.isPaused() && !fStatusAck; }

References fStatusAck, C4Network2Status::isPaused(), and Status.

Here is the call graph for this function:

◆ isRunning()

bool C4Network2::isRunning ( ) const

inline

Definition at line 206 of file C4Network2.h.

206 { return Status.isRunning() && isStatusAck(); }

C4Network2Status::isRunning

bool isRunning() const

Definition: C4Network2.h:90

References C4Network2Status::isRunning(), isStatusAck(), and Status.

Referenced by AddVote(), HandleActivateReq(), C4Network2Players::HandlePlayerInfo(), C4Game::IsPaused(), and Vote().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ isStatusAck()

bool C4Network2::isStatusAck ( ) const

inline

Definition at line 210 of file C4Network2.h.

210 { return fStatusAck; }

References fStatusAck.

Referenced by isPaused(), and isRunning().

Here is the caller graph for this function:

◆ isStreaming()

bool C4Network2::isStreaming ( ) const

Definition at line 3043 of file C4Network2.cpp.

 {
     // Streaming must be active and there must still be anything to stream
     return fStreaming;
 }

References fStreaming.

◆ Join()

bool C4Network2::Join	(	C4ClientCore &	CCore,
		C4Network2IOConnection *	pConn,
		StdStrBuf *	szReply
	)

protected

Definition at line 1342 of file C4Network2.cpp.

 {
     if (!pConn) return false;
     // security
     if (!isHost()) { *szReply = "not host"; return false; }
     if (!fAllowJoin && !fAllowObserve) { *szReply = "join denied"; return false; }
     if (CCore.getID() != C4ClientIDUnknown) { *szReply = "join with set id not allowed"; return false; }
     // find free client id
     CCore.SetID(iNextClientID++);
     // observer?
     if (!fAllowJoin) CCore.SetObserver(true);
     // deactivate - client will have to ask for activation.
     CCore.SetActivated(false);
     // Name already in use? Find unused one
     if (Clients.GetClient(CCore.getName()))
     {
         char szNameTmpl[256+1], szNewName[256+1];
         SCopy(CCore.getName(), szNameTmpl, 254); SAppend("%d", szNameTmpl, 256);
         int32_t i = 1;
         do
             sprintf(szNewName, szNameTmpl, ++i);
         while (Clients.GetClient(szNewName));
         CCore.SetName(szNewName);
     }
     // join client
     ::Control.DoInput(CID_ClientJoin, new C4ControlClientJoin(CCore), CDT_Direct);
     // get client, set status
     C4Network2Client *pClient = Clients.GetClient(CCore);
     if (pClient) pClient->SetStatus(NCS_Joining);
     // warn if client revision doesn't match our host revision
     if (!SEqualNoCase(CCore.getRevision(), Application.GetRevision()))
     {
         LogF("[!]WARNING! Client %s engine revision (%s) differs from local revision (%s). Client might run out of sync.", CCore.getName(), CCore.getRevision(), Application.GetRevision());
     }
     // ok, client joined.
     return true;
     // Note that the connection isn't fully accepted at this point and won't be
     // associated with the client. The new-created client is waiting for connect.
     // Somewhat ironically, the connection may still timeout (resulting in an instant
     // removal and maybe some funny message sequences).
     // The final client initialization will be done at OnClientConnect.
 }

References Application, C4ClientIDUnknown, CDT_Direct, CID_ClientJoin, Clients, Control, C4GameControl::DoInput(), fAllowJoin, fAllowObserve, C4Network2ClientList::GetClient(), C4ClientCore::getID(), C4ClientCore::getName(), C4Application::GetRevision(), C4ClientCore::getRevision(), iNextClientID, isHost(), LogF(), NCS_Joining, SAppend(), SCopy(), SEqualNoCase(), C4ClientCore::SetActivated(), C4ClientCore::SetID(), C4ClientCore::SetName(), C4ClientCore::SetObserver(), C4Network2Client::SetStatus(), and sprintf.

Referenced by HandleConn().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ LeagueEnd()

bool C4Network2::LeagueEnd	(	const char *	szRecordName = `nullptr`,
		const BYTE *	pRecordSHA = `nullptr`
	)

protected

Definition at line 2340 of file C4Network2.cpp.

 {
     C4RoundResultsPlayers RoundResults;
     StdStrBuf sResultMessage;
     bool fIsError = true;
  
     // Not needed?
     if (!pLeagueClient || !fHost || fLeagueEndSent)
         return true;
  
     // Make sure league client is available
     LeagueWaitNotBusy();
  
     // Try until either aborted or successful
     const int MAX_RETRIES = 10;
     for (int iRetry = 0; iRetry < MAX_RETRIES; iRetry++)
     {
  
         // Do update
         C4Network2Reference Ref;
         Ref.InitLocal();
         if (!pLeagueClient->End(Ref, szRecordName, pRecordSHA))
         {
             // Log message
             sResultMessage = FormatString(LoadResStr("IDS_NET_ERR_LEAGUE_FINISHGAME"), pLeagueClient->GetError());
             Log(sResultMessage.getData());
             // Show message, allow retry
             if (Application.isEditor) break;
             bool fRetry = ::pGUI->ShowMessageModal(sResultMessage.getData(), LoadResStr("IDS_NET_ERR_LEAGUE"),
                                                    C4GUI::MessageDialog::btnRetryAbort, C4GUI::Ico_Error);
             if (fRetry) continue;
             break;
         }
         // Let's wait for response
         StdStrBuf Message = FormatString(LoadResStr("IDS_NET_LEAGUE_SENDRESULT"), pLeagueClient->getServerName());
         Log(Message.getData());
         // Wait for response
         while (pLeagueClient->isBusy())
         {
             // Check if league server has responded
             if (!Application.ScheduleProcs(100))
                 break;
         }
         // Error?
         StdStrBuf LeagueServerMessage;
         if (!pLeagueClient->isSuccess() || !pLeagueClient->GetEndReply(&LeagueServerMessage, &RoundResults))
         {
             const char *pError = pLeagueClient->GetError() ? pLeagueClient->GetError() :
                                  LeagueServerMessage.getLength() ? LeagueServerMessage.getData() :
                                  LoadResStr("IDS_NET_ERR_LEAGUE_EMPTYREPLY");
             sResultMessage.Take(FormatString(LoadResStr("IDS_NET_ERR_LEAGUE_SENDRESULT"), pError));
             if (Application.isEditor) continue;
             // Only retry if we didn't get an answer from the league server
             bool fRetry = !pLeagueClient->isSuccess();
             fRetry = ::pGUI->ShowMessageModal(sResultMessage.getData(), LoadResStr("IDS_NET_ERR_LEAGUE"),
                                               fRetry ? C4GUI::MessageDialog::btnRetryAbort : C4GUI::MessageDialog::btnAbort,
                                               C4GUI::Ico_Error);
             if (fRetry) continue;
         }
         else
         {
             // All OK!
             sResultMessage.Copy(LoadResStr(Game.Parameters.isLeague() ? "IDS_MSG_LEAGUEEVALUATIONSUCCESSFU" : "IDS_MSG_INTERNETGAMEEVALUATED"));
             fIsError = false;
         }
         // Done
         break;
     }
  
     // Show message
     Log(sResultMessage.getData());
  
     // Take round results
     Game.RoundResults.EvaluateLeague(sResultMessage.getData(), !fIsError, RoundResults);
  
     // Send round results to other clients
     C4PacketLeagueRoundResults LeagueUpdatePacket(sResultMessage.getData(), !fIsError, RoundResults);
     Clients.BroadcastMsgToClients(MkC4NetIOPacket(PID_LeagueRoundResults, LeagueUpdatePacket));
  
     // All done
     fLeagueEndSent = true;
     return true;
 }

References Application, C4Network2ClientList::BroadcastMsgToClients(), C4GUI::MessageDialog::btnAbort, C4GUI::MessageDialog::btnRetryAbort, Clients, StdStrBuf::Copy(), C4LeagueClient::End(), C4RoundResults::EvaluateLeague(), fHost, fLeagueEndSent, FormatString(), Game, StdStrBuf::getData(), C4LeagueClient::GetEndReply(), C4HTTPClient::GetError(), StdStrBuf::getLength(), C4HTTPClient::getServerName(), C4GUI::Ico_Error, C4Network2Reference::InitLocal(), C4HTTPClient::isBusy(), C4Application::isEditor, C4GameParameters::isLeague(), C4HTTPClient::isSuccess(), LeagueWaitNotBusy(), LoadResStr(), Log(), MkC4NetIOPacket(), C4Game::Parameters, pGUI, PID_LeagueRoundResults, pLeagueClient, C4Game::RoundResults, StdScheduler::ScheduleProcs(), C4GUI::Screen::ShowMessageModal(), and StdStrBuf::Take().

Referenced by Clear(), LeagueGameEvaluate(), LeagueSignupDisable(), and LeagueStart().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ LeagueGameEvaluate()

void C4Network2::LeagueGameEvaluate	(	const char *	szRecordName = `nullptr`,
		const BYTE *	pRecordSHA = `nullptr`
	)

Definition at line 2009 of file C4Network2.cpp.

 {
     // already off?
     if (!pLeagueClient) return;
     // already evaluated?
     if (fLeagueEndSent) return;
     // end
     LeagueEnd(szRecordName, pRecordSHA);
 }

References fLeagueEndSent, LeagueEnd(), and pLeagueClient.

Referenced by C4Game::Evaluate().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ LeagueNotifyDisconnect()

void C4Network2::LeagueNotifyDisconnect	(	int32_t	iClientID,
		enum C4LeagueDisconnectReason	eReason
	)

Definition at line 2590 of file C4Network2.cpp.

 {
     // league active?
     if (!pLeagueClient || !Game.Parameters.isLeague()) return;
     // only in running game
     if (!Game.IsRunning || Game.GameOver) return;
     // clients send notifications for their own players; host sends for the affected client players
     if (!isHost()) { if (!Clients.GetLocal()) return; iClientID = Clients.GetLocal()->getID(); }
     // clients only need notifications if they have players in the game
     const C4ClientPlayerInfos *pInfos = Game.PlayerInfos.GetInfoByClientID(iClientID);
     if (!pInfos) return;
     int32_t i=0; C4PlayerInfo *pInfo;
     while ((pInfo = pInfos->GetPlayerInfo(i++))) if (pInfo->IsJoined() && !pInfo->IsRemoved()) break;
     if (!pInfo) return;
     // Make sure league client is avilable
     LeagueWaitNotBusy();
     // report the disconnect!
     LogF(LoadResStr("IDS_LEAGUE_LEAGUEREPORTINGUNEXPECTED"), (int) eReason);
     pLeagueClient->ReportDisconnect(*pInfos, eReason);
     // wait for the reply
     LeagueWaitNotBusy();
     // display it
     const char *szMsg;
     StdStrBuf sMessage;
     if (pLeagueClient->GetReportDisconnectReply(&sMessage))
         szMsg = LoadResStr("IDS_MSG_LEAGUEUNEXPECTEDDISCONNEC");
     else
         szMsg = LoadResStr("IDS_ERR_LEAGUEERRORREPORTINGUNEXP");
     LogF(szMsg, sMessage.getData());
 }

References Clients, Game, C4Game::GameOver, StdStrBuf::getData(), C4Network2Client::getID(), C4PlayerInfoList::GetInfoByClientID(), C4Network2ClientList::GetLocal(), C4ClientPlayerInfos::GetPlayerInfo(), C4LeagueClient::GetReportDisconnectReply(), isHost(), C4PlayerInfo::IsJoined(), C4GameParameters::isLeague(), C4PlayerInfo::IsRemoved(), C4Game::IsRunning, LeagueWaitNotBusy(), LoadResStr(), LogF(), C4Game::Parameters, C4Game::PlayerInfos, pLeagueClient, and C4LeagueClient::ReportDisconnect().

Referenced by OnClientDisconnect().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ LeaguePlrAuth()

bool C4Network2::LeaguePlrAuth ( C4PlayerInfo * pInfo )

Definition at line 2424 of file C4Network2.cpp.

 {
  
     // Not possible?
     if (!pLeagueClient)
         return false;
  
     // Make sure league client is avilable
     LeagueWaitNotBusy();
  
     // Official league?
     bool fOfficialLeague = SEqual(pLeagueClient->getServerName(), "league.openclonk.org");
  
     StdStrBuf Account, Password;
     bool fRememberLogin = false;
  
     // Default password from login token if present
     if (Config.Network.GetLeagueLoginData(pLeagueClient->getServerName(), pInfo->GetName(), &Account, &Password))
     {
         fRememberLogin = (Password.getLength()>0);
     }
     else
     {
         Account.Copy(pInfo->GetName());
     }
  
     for (;;)
     {
         // ask for account name and password
         if (!C4LeagueSignupDialog::ShowModal(pInfo->GetName(), Account.getData(), pLeagueClient->getServerName(), &Account, &Password, !fOfficialLeague, false, &fRememberLogin))
             return false;
  
         // safety (modal dlg may have deleted network)
         if (!pLeagueClient) return false;
  
         // Send authentication request
         if (!pLeagueClient->Auth(*pInfo, Account.getData(), Password.getData(), nullptr, nullptr, fRememberLogin))
             return false;
  
         // safety (modal dlg may have deleted network)
         if (!pLeagueClient) return false;
  
         // Wait for a response
         StdStrBuf Message = FormatString(LoadResStr("IDS_MSG_TRYLEAGUESIGNUP"), pInfo->GetName(), Account.getData(), pLeagueClient->getServerName());
         Log(Message.getData());
         // Set up a dialog
         C4GUI::MessageDialog *pDlg = nullptr;
         if (!Application.isEditor)
         {
             // create & show
             pDlg = new C4GUI::MessageDialog(Message.getData(), LoadResStr("IDS_DLG_LEAGUESIGNUP"), C4GUI::MessageDialog::btnAbort, C4GUI::Ico_NetWait, C4GUI::MessageDialog::dsRegular);
             if (!pDlg || !pDlg->Show(::pGUI, true))  return false;
         }
         // Wait for response
         while (pLeagueClient->isBusy())
         {
             // Execute GUI
             if (!Application.ScheduleProcs() ||
                 (pDlg && pDlg->IsAborted()))
             {
                 // Clear up
                 if (pDlg) delete pDlg;
                 return false;
             }
         }
         // Close dialog
         if (pDlg)
         {
             pDlg->Close(true);
             delete pDlg;
         }
  
         // Success?
         StdStrBuf AUID, AccountMaster, LoginToken; bool fUnregistered = false;
         if (pLeagueClient->GetAuthReply(&Message, &AUID, &AccountMaster, &fUnregistered, &LoginToken))
         {
  
             // Set AUID
             pInfo->SetAuthID(AUID.getData());
  
             // Remember login data; set or clear login token
             Config.Network.SetLeagueLoginData(pLeagueClient->getServerName(), pInfo->GetName(), Account.getData(), fRememberLogin ? LoginToken.getData() : "");
  
             // Show welcome message, if any
             bool fSuccess;
             if (Message.getLength())
                 fSuccess = ::pGUI->ShowMessageModal(
                              Message.getData(), LoadResStr("IDS_DLG_LEAGUESIGNUPCONFIRM"),
                              C4GUI::MessageDialog::btnOKAbort, C4GUI::Ico_Ex_League);
             else if (AccountMaster.getLength())
                 fSuccess = ::pGUI->ShowMessageModal(
                              FormatString(LoadResStr("IDS_MSG_LEAGUEPLAYERSIGNUPAS"), pInfo->GetName(), AccountMaster.getData(), pLeagueClient->getServerName()).getData(), LoadResStr("IDS_DLG_LEAGUESIGNUPCONFIRM"),
                              C4GUI::MessageDialog::btnOKAbort, C4GUI::Ico_Ex_League);
             else
                 fSuccess = ::pGUI->ShowMessageModal(
                              FormatString(LoadResStr("IDS_MSG_LEAGUEPLAYERSIGNUP"), pInfo->GetName(), pLeagueClient->getServerName()).getData(), LoadResStr("IDS_DLG_LEAGUESIGNUPCONFIRM"),
                              C4GUI::MessageDialog::btnOKAbort, C4GUI::Ico_Ex_League);
  
             // Approved?
             if (fSuccess)
                 // Done
                 return true;
             else
                 // Sign-up was cancelled by user
                 ::pGUI->ShowMessageModal(FormatString(LoadResStr("IDS_MSG_LEAGUESIGNUPCANCELLED"), pInfo->GetName()).getData(), LoadResStr("IDS_DLG_LEAGUESIGNUP"), C4GUI::MessageDialog::btnOK, C4GUI::Ico_Notify);
  
         }
         else
         {
  
             // Authentification error
             LogF(LoadResStr("IDS_MSG_LEAGUESIGNUPERROR"), Message.getData());
                 ::pGUI->ShowMessageModal(FormatString(LoadResStr("IDS_MSG_LEAGUESERVERMSG"), Message.getData()).getData(), LoadResStr("IDS_DLG_LEAGUESIGNUPFAILED"), C4GUI::MessageDialog::btnOK, C4GUI::Ico_Error);
             // after a league server error message, always fall-through to try again
         }
  
         // Try given account name as default next time
         if (AccountMaster.getLength())
             Account.Take(std::move(AccountMaster));
  
         // safety (modal dlg may have deleted network)
         if (!pLeagueClient) return false;
     }
  
 }

References Application, C4LeagueClient::Auth(), C4GUI::MessageDialog::btnAbort, C4GUI::MessageDialog::btnOK, C4GUI::MessageDialog::btnOKAbort, C4GUI::Dialog::Close(), Config, StdStrBuf::Copy(), C4GUI::MessageDialog::dsRegular, FormatString(), C4LeagueClient::GetAuthReply(), StdStrBuf::getData(), C4ConfigNetwork::GetLeagueLoginData(), StdStrBuf::getLength(), C4PlayerInfo::GetName(), C4HTTPClient::getServerName(), C4GUI::Ico_Error, C4GUI::Ico_Ex_League, C4GUI::Ico_NetWait, C4GUI::Ico_Notify, C4GUI::Dialog::IsAborted(), C4HTTPClient::isBusy(), C4Application::isEditor, LeagueWaitNotBusy(), LoadResStr(), Log(), LogF(), C4Config::Network, pGUI, pLeagueClient, StdScheduler::ScheduleProcs(), SEqual(), C4PlayerInfo::SetAuthID(), C4ConfigNetwork::SetLeagueLoginData(), C4GUI::Dialog::Show(), C4GUI::Screen::ShowMessageModal(), C4LeagueSignupDialog::ShowModal(), and StdStrBuf::Take().

Referenced by C4Network2Players::JoinLocalPlayer().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ LeaguePlrAuthCheck()

bool C4Network2::LeaguePlrAuthCheck ( C4PlayerInfo * pInfo )

Definition at line 2550 of file C4Network2.cpp.

 {
  
     // Not possible?
     if (!pLeagueClient)
         return false;
  
     // Make sure league client is available
     LeagueWaitNotBusy();
  
     // Ask league server to check the code
     if (!pLeagueClient->AuthCheck(*pInfo))
         return false;
  
     // Log
     StdStrBuf Message = FormatString(LoadResStr("IDS_MSG_LEAGUEJOINING"), pInfo->GetName());
     Log(Message.getData());
  
     // Wait for response
     while (pLeagueClient->isBusy())
         if (!Application.ScheduleProcs(100))
             break;
  
     // Check response validity
     if (!pLeagueClient->isSuccess())
     {
         LeagueShowError(pLeagueClient->GetError());
         return false;
     }
  
     // Check if league server approves. pInfo will have league info if this call is successful.
     if (!pLeagueClient->GetAuthCheckReply(&Message, Game.Parameters.League.getData(), pInfo))
     {
         LeagueShowError(FormatString(LoadResStr("IDS_MSG_LEAGUEJOINREFUSED"), pInfo->GetName(), Message.getData()).getData());
         return false;
     }
  
     return true;
 }

References Application, C4LeagueClient::AuthCheck(), FormatString(), Game, C4LeagueClient::GetAuthCheckReply(), StdStrBuf::getData(), C4HTTPClient::GetError(), C4PlayerInfo::GetName(), C4HTTPClient::isBusy(), C4HTTPClient::isSuccess(), C4GameParameters::League, LeagueShowError(), LeagueWaitNotBusy(), LoadResStr(), Log(), C4Game::Parameters, pLeagueClient, and StdScheduler::ScheduleProcs().

Referenced by C4Network2Players::HandlePlayerInfoUpdRequest().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ LeagueShowError()

void C4Network2::LeagueShowError ( const char * szMsg )

Definition at line 2642 of file C4Network2.cpp.

 {
     if (!Application.isEditor)
     {
         ::pGUI->ShowErrorMessage(szMsg);
     }
     else
     {
         LogF(LoadResStr("IDS_LGA_SERVERFAILURE"), szMsg);
     }
 }

References Application, C4Application::isEditor, LoadResStr(), LogF(), pGUI, and C4GUI::Screen::ShowErrorMessage().

Referenced by LeaguePlrAuthCheck().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ LeagueSignupDisable()

void C4Network2::LeagueSignupDisable ( )

Definition at line 2019 of file C4Network2.cpp.

 {
     // already off?
     if (!pLeagueClient) return;
     // no post-disable if league is active
     if (pLeagueClient && Game.Parameters.isLeague()) return;
     // signup end
     LeagueEnd(); DeinitLeague();
 }

References DeinitLeague(), Game, C4GameParameters::isLeague(), LeagueEnd(), C4Game::Parameters, and pLeagueClient.

Referenced by C4GameOptionButtons::OnBtnInternet().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ LeagueSignupEnable()

bool C4Network2::LeagueSignupEnable ( )

Definition at line 2029 of file C4Network2.cpp.

 {
     // already running?
     if (pLeagueClient) return true;
     // Start it!
     if (InitLeague(nullptr) && LeagueStart(nullptr)) return true;
     // Failure :'(
     DeinitLeague();
     return false;
 }

References DeinitLeague(), InitLeague(), LeagueStart(), and pLeagueClient.

Referenced by C4GameOptionButtons::OnBtnInternet().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ LeagueStart()

bool C4Network2::LeagueStart ( bool * pCancel )

protected

Definition at line 2128 of file C4Network2.cpp.

 {
     // Not needed?
     if (!pLeagueClient || !fHost)
         return true;
  
     // Default
     if (pCancel) *pCancel = true;
  
     // Do update
     C4Network2Reference Ref;
     Ref.InitLocal();
     if (!pLeagueClient->Start(Ref))
     {
         // Log message
         StdStrBuf Message = FormatString(LoadResStr("IDS_NET_ERR_LEAGUE_STARTGAME"), pLeagueClient->GetError());
         LogFatal(Message.getData());
         // Show message
         if (!Application.isEditor)
         {
             // Show option to cancel, if possible
             bool fResult = ::pGUI->ShowMessageModal(
                              Message.getData(),
                              LoadResStr("IDS_NET_ERR_LEAGUE"),
                              pCancel ? (C4GUI::MessageDialog::btnOK | C4GUI::MessageDialog::btnAbort) : C4GUI::MessageDialog::btnOK,
                              C4GUI::Ico_Error);
             if (pCancel)
                 *pCancel = !fResult;
         }
         // Failed
         return false;
     }
  
     InitPuncher();
  
     // Let's wait for response
     StdStrBuf Message = FormatString(LoadResStr("IDS_NET_LEAGUE_REGGAME"), pLeagueClient->getServerName());
     Log(Message.getData());
     // Set up a dialog
     C4GUI::MessageDialog *pDlg = nullptr;
     if (!Application.isEditor)
     {
         // create & show
         pDlg = new C4GUI::MessageDialog(Message.getData(), LoadResStr("IDS_NET_LEAGUE_STARTGAME"),
                                         C4GUI::MessageDialog::btnAbort, C4GUI::Ico_NetWait, C4GUI::MessageDialog::dsRegular);
         if (!pDlg || !pDlg->Show(::pGUI, true))  return false;
     }
     // Wait for response
     while (pLeagueClient->isBusy())
     {
         // Execute GUI
         if (!Application.ScheduleProcs() ||
             (pDlg && pDlg->IsAborted()))
         {
             // Clear up
             if (pDlg) delete pDlg;
             return false;
         }
     }
     // Close dialog
     if (pDlg)
     {
         pDlg->Close(true);
         delete pDlg;
     }
     // Error?
     StdStrBuf LeagueServerMessage, League, StreamingAddr;
     int32_t Seed = Game.RandomSeed, MaxPlayersLeague = 0;
     if (!pLeagueClient->isSuccess() ||
         !pLeagueClient->GetStartReply(&LeagueServerMessage, &League, &StreamingAddr, &Seed, &MaxPlayersLeague))
     {
         const char *pError = pLeagueClient->GetError() ? pLeagueClient->GetError() :
                              LeagueServerMessage.getLength() ? LeagueServerMessage.getData() :
                              LoadResStr("IDS_NET_ERR_LEAGUE_EMPTYREPLY");
         StdStrBuf Message = FormatString(LoadResStr("IDS_NET_ERR_LEAGUE_REGGAME"), pError);
         // Log message
         Log(Message.getData());
         // Show message
         if (!Application.isEditor)
         {
             // Show option to cancel, if possible
             bool fResult = ::pGUI->ShowMessageModal(
                              Message.getData(),
                              LoadResStr("IDS_NET_ERR_LEAGUE"),
                              pCancel ? (C4GUI::MessageDialog::btnOK | C4GUI::MessageDialog::btnAbort) : C4GUI::MessageDialog::btnOK,
                              C4GUI::Ico_Error);
             if (pCancel)
                 *pCancel = !fResult;
         }
         // Failed
         return false;
     }
  
     // Show message
     if (LeagueServerMessage.getLength())
     {
         StdStrBuf Message = FormatString(LoadResStr("IDS_MSG_LEAGUEGAMESIGNUP"), pLeagueClient->getServerName(), LeagueServerMessage.getData());
         // Log message
         Log(Message.getData());
         // Show message
         if (!Application.isEditor)
         {
             // Show option to cancel, if possible
             bool fResult = ::pGUI->ShowMessageModal(
                              Message.getData(),
                              LoadResStr("IDS_NET_ERR_LEAGUE"),
                              pCancel ? (C4GUI::MessageDialog::btnOK | C4GUI::MessageDialog::btnAbort) : C4GUI::MessageDialog::btnOK,
                              C4GUI::Ico_Error);
             if (pCancel)
                 *pCancel = !fResult;
             if (!fResult)
             {
                 LeagueEnd(); DeinitLeague();
                 return false;
             }
         }
     }
  
     // Set game parameters for league game
     Game.Parameters.League = League;
     Game.RandomSeed = Seed;
     if (MaxPlayersLeague)
         Game.Parameters.MaxPlayers = MaxPlayersLeague;
     if (!League.getLength())
     {
         Game.Parameters.LeagueAddress.Clear();
         Game.Parameters.StreamAddress.Clear();
     }
     else
     {
         Game.Parameters.StreamAddress = StreamingAddr;
     }
  
     // All ok
     fLeagueEndSent = false;
     return true;
 }

References Application, C4GUI::MessageDialog::btnAbort, C4GUI::MessageDialog::btnOK, StdStrBuf::Clear(), C4GUI::Dialog::Close(), DeinitLeague(), C4GUI::MessageDialog::dsRegular, fHost, fLeagueEndSent, FormatString(), Game, StdStrBuf::getData(), C4HTTPClient::GetError(), StdStrBuf::getLength(), C4HTTPClient::getServerName(), C4LeagueClient::GetStartReply(), C4GUI::Ico_Error, C4GUI::Ico_NetWait, C4Network2Reference::InitLocal(), InitPuncher(), C4GUI::Dialog::IsAborted(), C4HTTPClient::isBusy(), C4Application::isEditor, C4HTTPClient::isSuccess(), C4GameParameters::League, C4GameParameters::LeagueAddress, LeagueEnd(), LoadResStr(), Log(), LogFatal(), C4GameParameters::MaxPlayers, C4Game::Parameters, pGUI, pLeagueClient, C4Game::RandomSeed, StdScheduler::ScheduleProcs(), C4GUI::Dialog::Show(), C4GUI::Screen::ShowMessageModal(), C4LeagueClient::Start(), and C4GameParameters::StreamAddress.

Referenced by InitHost(), and LeagueSignupEnable().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ LeagueSurrender()

void C4Network2::LeagueSurrender ( )

Definition at line 2635 of file C4Network2.cpp.

 {
     // there's currently no functionality to surrender in the league
     // just stop responding so other clients will notify the disconnect
     DeinitLeague();
 }

References DeinitLeague().

Here is the call graph for this function:

◆ LeagueUpdate()

bool C4Network2::LeagueUpdate ( )

protected

Definition at line 2266 of file C4Network2.cpp.

 {
     // Not needed?
     if (!pLeagueClient || !fHost)
         return true;
  
     // League client currently busy?
     if (pLeagueClient->isBusy())
         return true;
  
     // Create reference
     C4Network2Reference Ref;
     Ref.InitLocal();
  
     // Do update
     if (!pLeagueClient->Update(Ref))
     {
         // Log
         LogF(LoadResStr("IDS_NET_ERR_LEAGUE_UPDATEGAME"), pLeagueClient->GetError());
         return false;
     }
  
     // Timing
     iLastLeagueUpdate = time(nullptr);
     iLeagueUpdateDelay = Config.Network.MasterReferencePeriod;
  
     return true;
 }

References Config, fHost, C4HTTPClient::GetError(), iLastLeagueUpdate, iLeagueUpdateDelay, C4Network2Reference::InitLocal(), C4HTTPClient::isBusy(), LoadResStr(), LogF(), C4ConfigNetwork::MasterReferencePeriod, C4Config::Network, pLeagueClient, and C4LeagueClient::Update().

Referenced by Execute().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ LeagueUpdateProcessReply()

bool C4Network2::LeagueUpdateProcessReply ( )

protected

Definition at line 2295 of file C4Network2.cpp.

 {
     // safety: A reply must be present
     assert(pLeagueClient);
     assert(fHost);
     assert(!pLeagueClient->isBusy());
     assert(pLeagueClient->getCurrentAction() == C4LA_Update);
     // check reply success
     C4ClientPlayerInfos PlayerLeagueInfos;
     StdStrBuf LeagueServerMessage;
     bool fSucc = pLeagueClient->isSuccess() && pLeagueClient->GetUpdateReply(&LeagueServerMessage, &PlayerLeagueInfos);
     pLeagueClient->ResetCurrentAction();
     if (!fSucc)
     {
         const char *pError = pLeagueClient->GetError() ? pLeagueClient->GetError() :
                              LeagueServerMessage.getLength() ? LeagueServerMessage.getData() :
                              LoadResStr("IDS_NET_ERR_LEAGUE_EMPTYREPLY");
         StdStrBuf Message = FormatString(LoadResStr("IDS_NET_ERR_LEAGUE_UPDATEGAME"), pError);
         // Show message - no dialog, because it's not really fatal and might happen in the running game
         Log(Message.getData());
         return false;
     }
     // evaluate reply: Transfer data to players
     // Take round results
     C4PlayerInfoList &TargetList = Game.PlayerInfos;
     C4ClientPlayerInfos *pInfos; C4PlayerInfo *pInfo, *pResultInfo;
     for (int iClient = 0; (pInfos = TargetList.GetIndexedInfo(iClient)); iClient++)
         for (int iInfo = 0; (pInfo = pInfos->GetPlayerInfo(iInfo)); iInfo++)
             if ((pResultInfo = PlayerLeagueInfos.GetPlayerInfoByID(pInfo->GetID())))
             {
                 int32_t iLeagueProjectedGain = pResultInfo->GetLeagueProjectedGain();
                 if (iLeagueProjectedGain != pInfo->GetLeagueProjectedGain())
                 {
                     pInfo->SetLeagueProjectedGain(iLeagueProjectedGain);
                     pInfos->SetUpdated();
                 }
             }
     // transfer info update to other clients
     Players.SendUpdatedPlayers();
     // if lobby is open, notify lobby of updated players
     if (pLobby) pLobby->OnPlayersChange();
     // OMFG SUCCESS!
     return true;
 }

References C4LA_Update, fHost, FormatString(), Game, C4LeagueClient::getCurrentAction(), StdStrBuf::getData(), C4HTTPClient::GetError(), C4PlayerInfo::GetID(), C4PlayerInfoList::GetIndexedInfo(), C4PlayerInfo::GetLeagueProjectedGain(), StdStrBuf::getLength(), C4ClientPlayerInfos::GetPlayerInfo(), C4ClientPlayerInfos::GetPlayerInfoByID(), C4LeagueClient::GetUpdateReply(), C4HTTPClient::isBusy(), C4HTTPClient::isSuccess(), LoadResStr(), Log(), C4GameLobby::MainDlg::OnPlayersChange(), C4Game::PlayerInfos, Players, pLeagueClient, pLobby, C4LeagueClient::ResetCurrentAction(), C4Network2Players::SendUpdatedPlayers(), C4PlayerInfo::SetLeagueProjectedGain(), and C4ClientPlayerInfos::SetUpdated().

Referenced by Execute(), and LeagueWaitNotBusy().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ LeagueWaitNotBusy()

void C4Network2::LeagueWaitNotBusy ( )

Definition at line 2621 of file C4Network2.cpp.

 {
     // league client busy?
     if (!pLeagueClient || !pLeagueClient->isBusy()) return;
     // wait for it
     Log(LoadResStr("IDS_LEAGUE_WAITINGFORLASTLEAGUESERVE"));
     while (pLeagueClient->isBusy())
         if (!Application.ScheduleProcs(100))
             break;
     // if last request was an update request, process it
     if (pLeagueClient->getCurrentAction() == C4LA_Update)
         LeagueUpdateProcessReply();
 }

References Application, C4LA_Update, C4LeagueClient::getCurrentAction(), C4HTTPClient::isBusy(), LeagueUpdateProcessReply(), LoadResStr(), Log(), pLeagueClient, and StdScheduler::ScheduleProcs().

Referenced by LeagueEnd(), LeagueNotifyDisconnect(), LeaguePlrAuth(), and LeaguePlrAuthCheck().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ OnClientConnect()

void C4Network2::OnClientConnect	(	C4Network2Client *	pClient,
		C4Network2IOConnection *	pConn
	)

protected

Definition at line 1589 of file C4Network2.cpp.

 {
     // host: new client?
     if (isHost())
     {
         // dynamic available?
         if (!pClient->hasJoinData())
             SendJoinData(pClient);
  
         // notice lobby (doesn't do anything atm?)
         C4GameLobby::MainDlg *pDlg = GetLobby();
         if (isLobbyActive()) pDlg->OnClientConnect(pClient->getClient(), pConn);
  
     }
  
     // discover resources
     ResList.OnClientConnect(pConn);
  
 }

References C4Network2Client::getClient(), GetLobby(), C4Network2Client::hasJoinData(), isHost(), isLobbyActive(), C4GameLobby::MainDlg::OnClientConnect(), C4Network2ResList::OnClientConnect(), ResList, and SendJoinData().

Referenced by OnConnect().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ OnClientDisconnect()

void C4Network2::OnClientDisconnect ( C4Network2Client * pClient )

protected

Definition at line 1609 of file C4Network2.cpp.

 {
     // league: Notify regular client disconnect within the game
     if (pLeagueClient && (isHost() || pClient->isHost())) LeagueNotifyDisconnect(pClient->getID(), C4LDR_ConnectionFailed);
     // host? Remove this client from the game.
     if (isHost())
     {
         // log
         LogSilentF(LoadResStr("IDS_NET_CLIENTDISCONNECTED"), pClient->getName()); // silent, because a duplicate message with disconnect reason will follow
         // remove the client
         Game.Clients.CtrlRemove(pClient->getClient(), LoadResStr("IDS_MSG_DISCONNECTED"));
         // check status ack (disconnected client might be the last that was waited for)
         CheckStatusAck();
         // unreached pause/go? retry setting the state with current control tick
         // (client might be the only one claiming to have the given control)
         if (!fStatusReached)
             if (Status.getState() == GS_Go || Status.getState() == GS_Pause)
                 ChangeGameStatus(Status.getState(), ::Control.ControlTick);
 #ifdef USE_CONSOLE
         // Dedicated server: stop hosting if there is only one client left we're hosting for.
         // TODO: Find a better place to do this.
         if (Game.IsRunning && Clients.Count() <= 3) Application.Quit(); // Off-by-1 error
 #endif // USE_CONSOLE
     }
     // host disconnected? Clear up
     if (!isHost() && pClient->isHost())
     {
         StdStrBuf sMsg; sMsg.Format(LoadResStr("IDS_NET_HOSTDISCONNECTED"), pClient->getName());
         Log(sMsg.getData());
         // host connection lost: clear up everything
         Game.RoundResults.EvaluateNetwork(C4RoundResults::NR_NetError, sMsg.getData());
         Clear();
     }
 }

References Application, C4LDR_ConnectionFailed, ChangeGameStatus(), CheckStatusAck(), Clear(), C4Game::Clients, Clients, Control, C4GameControl::ControlTick, C4Network2ClientList::Count(), C4ClientList::CtrlRemove(), C4RoundResults::EvaluateNetwork(), StdStrBuf::Format(), fStatusReached, Game, C4Network2Client::getClient(), StdStrBuf::getData(), C4Network2Client::getID(), C4Network2Client::getName(), C4Network2Status::getState(), GS_Go, GS_Pause, isHost(), C4Network2Client::isHost(), C4Game::IsRunning, LeagueNotifyDisconnect(), LoadResStr(), Log(), LogSilentF(), C4RoundResults::NR_NetError, pLeagueClient, C4Application::Quit(), C4Game::RoundResults, and Status.

Referenced by OnConnectFail(), and OnDisconnect().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ OnConn()

void C4Network2::OnConn ( C4Network2IOConnection * pConn )

Definition at line 828 of file C4Network2.cpp.

 {
     // Nothing to do atm... New pending connections are managed mainly by C4Network2IO
     // until they are accepted, see PID_Conn/PID_ConnRe handlers in HandlePacket.
  
     // Note this won't get called anymore because of this (see C4Network2IO::OnConn)
 }

Referenced by C4Network2IO::OnThreadEvent().

Here is the caller graph for this function:

◆ OnConnect()

void C4Network2::OnConnect	(	C4Network2Client *	pClient,
		C4Network2IOConnection *	pConn,
		const char *	szMsg,
		bool	fFirstConnection
	)

protected

Definition at line 1555 of file C4Network2.cpp.

 {
     // log
     LogSilentF("Network: %s %s connected (%s/%s) (%s)", pClient->isHost() ? "host" : "client",
                pClient->getName(), pConn->getPeerAddr().ToString().getData(),
                NetIO.getNetIOName(pConn->getNetClass()), szMsg ? szMsg : "");
  
     // first connection for this peer? call special handler
     if (fFirstConnection) OnClientConnect(pClient, pConn);
 }

References StdStrBuf::getData(), C4Network2Client::getName(), C4Network2IOConnection::getNetClass(), C4Network2IO::getNetIOName(), C4Network2IOConnection::getPeerAddr(), C4Network2Client::isHost(), LogSilentF(), NetIO, OnClientConnect(), and C4NetIO::EndpointAddress::ToString().

Referenced by HandleConnRe().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ OnConnectFail()

void C4Network2::OnConnectFail ( C4Network2IOConnection * pConn )

protected

Definition at line 1566 of file C4Network2.cpp.

 {
     LogSilentF("Network: %s connection to %s failed!", NetIO.getNetIOName(pConn->getNetClass()),
                pConn->getPeerAddr().ToString().getData());
  
     // maybe client connection failure
     // (happens if the connection is not fully accepted and the client disconnects.
     //  See C4Network2::Join)
     C4Network2Client *pClient = Clients.GetClientByID(pConn->getClientID());
     if (pClient && !pClient->isConnected())
         OnClientDisconnect(pClient);
 }

References Clients, C4Network2ClientList::GetClientByID(), C4Network2IOConnection::getClientID(), StdStrBuf::getData(), C4Network2IOConnection::getNetClass(), C4Network2IO::getNetIOName(), C4Network2IOConnection::getPeerAddr(), C4Network2Client::isConnected(), LogSilentF(), NetIO, OnClientDisconnect(), and C4NetIO::EndpointAddress::ToString().

Referenced by OnDisconn().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ OnDisconn()

void C4Network2::OnDisconn ( C4Network2IOConnection * pConn )

Definition at line 836 of file C4Network2.cpp.

 {
     // could not establish host connection?
     if (Status.getState() == GS_Init && !isHost())
     {
         if (!NetIO.getConnectionCount())
             Clear();
         return;
     }
  
     // connection failed?
     if (pConn->isFailed())
     {
         // call handler
         OnConnectFail(pConn);
         return;
     }
  
     // search client
     C4Network2Client *pClient = Clients.GetClient(pConn);
     // not found? Search by ID (not associated yet, half-accepted connection)
     if (!pClient) pClient = Clients.GetClientByID(pConn->getClientID());
     // not found? ignore
     if (!pClient) return;
     // remove connection
     pClient->RemoveConn(pConn);
  
     // create post-mortem if needed
     C4PacketPostMortem PostMortem;
     if (pConn->CreatePostMortem(&PostMortem))
     {
         LogSilentF("Network: Sending %d packets for recovery (%d-%d)", PostMortem.getPacketCount(), pConn->getOutPacketCounter() - PostMortem.getPacketCount(), pConn->getOutPacketCounter() - 1);
         // This might fail because of this disconnect
         // (If it's the only host connection. We're toast then anyway.)
         if (!Clients.SendMsgToClient(pConn->getClientID(), MkC4NetIOPacket(PID_PostMortem, PostMortem)))
             assert(isHost() || !Clients.GetHost()->isConnected());
     }
  
     // call handler
     OnDisconnect(pClient, pConn);
  
 }

References Clear(), Clients, C4Network2IOConnection::CreatePostMortem(), C4Network2ClientList::GetClient(), C4Network2ClientList::GetClientByID(), C4Network2IOConnection::getClientID(), C4Network2IO::getConnectionCount(), C4Network2ClientList::GetHost(), C4Network2IOConnection::getOutPacketCounter(), C4PacketPostMortem::getPacketCount(), C4Network2Status::getState(), GS_Init, C4Network2Client::isConnected(), C4Network2IOConnection::isFailed(), isHost(), LogSilentF(), MkC4NetIOPacket(), NetIO, OnConnectFail(), OnDisconnect(), PID_PostMortem, C4Network2Client::RemoveConn(), C4Network2ClientList::SendMsgToClient(), and Status.

Referenced by C4Network2IO::OnThreadEvent().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ OnDisconnect()

void C4Network2::OnDisconnect	(	C4Network2Client *	pClient,
		C4Network2IOConnection *	pConn
	)

protected

Definition at line 1579 of file C4Network2.cpp.

 {
     LogSilentF("Network: %s connection to %s (%s) lost!", NetIO.getNetIOName(pConn->getNetClass()),
                pClient->getName(), pConn->getPeerAddr().ToString().getData());
  
     // connection lost?
     if (!pClient->isConnected())
         OnClientDisconnect(pClient);
 }

References StdStrBuf::getData(), C4Network2Client::getName(), C4Network2IOConnection::getNetClass(), C4Network2IO::getNetIOName(), C4Network2IOConnection::getPeerAddr(), C4Network2Client::isConnected(), LogSilentF(), NetIO, OnClientDisconnect(), and C4NetIO::EndpointAddress::ToString().

Referenced by OnDisconn().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ OnGameSynchronized()

void C4Network2::OnGameSynchronized ( )

Definition at line 1062 of file C4Network2.cpp.

 {
     // savegame needed?
     if (fDynamicNeeded)
     {
         // create dynamic
         bool fSuccess = CreateDynamic(false);
         // check for clients that still need join-data
         C4Network2Client *pClient = nullptr;
         while ((pClient = Clients.GetNextClient(pClient)))
             if (!pClient->hasJoinData())
             {
                 if (fSuccess)
                     // now we can provide join data: send it
                     SendJoinData(pClient);
                 else
                     // join data could not be created: emergency kick
                     Game.Clients.CtrlRemove(pClient->getClient(), LoadResStr("IDS_ERR_ERRORWHILECREATINGJOINDAT"));
             }
     }
 }

References C4Game::Clients, Clients, CreateDynamic(), C4ClientList::CtrlRemove(), fDynamicNeeded, Game, C4Network2Client::getClient(), C4Network2ClientList::GetNextClient(), C4Network2Client::hasJoinData(), LoadResStr(), and SendJoinData().

Referenced by C4Game::Synchronize().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ OnPuncherConnect()

void C4Network2::OnPuncherConnect ( C4NetIO::addr_t addr )

Definition at line 1017 of file C4Network2.cpp.

 {
     // NAT punching is only relevant for IPv4, so convert here to show a proper address.
     auto maybe_v4 = addr.AsIPv4();
     Application.InteractiveThread.ThreadLogS("Adding address from puncher: %s", maybe_v4.ToString().getData());
     // Add for local client
     C4Network2Client *pLocal = Clients.GetLocal();
     if (pLocal)
     {
         pLocal->AddAddrFromPuncher(maybe_v4);
         // Do not ::Network.InvalidateReference(); yet, we're expecting an ID from the netpuncher
     }
     auto family = maybe_v4.GetFamily();
     if (isHost())
     {
         // Host connection: request ID from netpuncher
         NetIO.SendPuncherPacket(C4NetpuncherPacketIDReq(), family);
     }
     else
     {
         // Client connection: request packet from host.
         if (Status.getState() == GS_Init && getNetpuncherGameID(family))
             NetIO.SendPuncherPacket(C4NetpuncherPacketSReq(getNetpuncherGameID(family)), family);
     }
 }

References C4Network2Client::AddAddrFromPuncher(), Application, C4NetIO::EndpointAddress::AsIPv4(), Clients, C4Network2ClientList::GetLocal(), getNetpuncherGameID(), C4Network2Status::getState(), GS_Init, C4Application::InteractiveThread, isHost(), NetIO, C4Network2IO::SendPuncherPacket(), Status, and C4InteractiveThread::ThreadLogS().

Referenced by C4Network2IO::OnConn().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ OnSec1Timer()

void C4Network2::OnSec1Timer ( )

overridevirtual

Implements C4ApplicationSec1Timer.

Definition at line 644 of file C4Network2.cpp.

 {
     Execute();
 }

References Execute().

Here is the call graph for this function:

◆ OnStatusAck()

void C4Network2::OnStatusAck ( )

protected

Definition at line 1914 of file C4Network2.cpp.

 {
     // log it
     LogSilentF("Network: status %s (tick %d) reached", Status.getStateName(), Status.getTargetCtrlTick());
     // pause?
     if (Status.getState() == GS_Pause)
     {
         // set halt-flag (show hold message)
         Console.UpdateHaltCtrls(!!++Game.HaltCount);
     }
     // go?
     if (Status.getState() == GS_Go)
     {
         // set mode
         pControl->SetCtrlMode(static_cast<C4GameControlNetworkMode>(Status.getCtrlMode()));
         // notify player list of reached status - will add some input to the queue
         Players.OnStatusGoReached();
         // start ctrl
         pControl->SetRunning(true);
         // reset halt-flag
         Game.HaltCount = 0;
         Console.UpdateHaltCtrls(!!Game.HaltCount);
     }
 }

References Console, Game, C4Network2Status::getCtrlMode(), C4Network2Status::getState(), C4Network2Status::getStateName(), C4Network2Status::getTargetCtrlTick(), GS_Go, GS_Pause, C4Game::HaltCount, LogSilentF(), C4Network2Players::OnStatusGoReached(), pControl, Players, C4GameControlNetwork::SetCtrlMode(), C4GameControlNetwork::SetRunning(), Status, and C4ConsoleGUI::UpdateHaltCtrls().

Referenced by CheckStatusAck(), and HandleStatusAck().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ OnStatusReached()

void C4Network2::OnStatusReached ( )

protected

Definition at line 1904 of file C4Network2.cpp.

 {
     // stop ctrl, wait for ack
     if (pControl->IsEnabled())
     {
         Console.UpdateHaltCtrls(!!++Game.HaltCount);
         pControl->SetRunning(false);
     }
 }

References Console, Game, C4Game::HaltCount, C4GameControlNetwork::IsEnabled(), pControl, C4GameControlNetwork::SetRunning(), and C4ConsoleGUI::UpdateHaltCtrls().

Referenced by CheckStatusReached().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ OnVoteDialogClosed()

void C4Network2::OnVoteDialogClosed ( )

Definition at line 2798 of file C4Network2.cpp.

 {
     pVoteDialog = nullptr;
 }

References pVoteDialog.

◆ OpenSurrenderDialog()

void C4Network2::OpenSurrenderDialog	(	C4ControlVoteType	eType,
		int32_t	iData
	)

Definition at line 2786 of file C4Network2.cpp.

 {
     if (!pVoteDialog)
     {
         pVoteDialog = new C4VoteDialog(
           LoadResStr("IDS_VOTE_SURRENDERWARNING"), eType, iData, true);
         pVoteDialog->SetDelOnClose();
         pVoteDialog->Show(::pGUI, true);
     }
 }

References LoadResStr(), pGUI, pVoteDialog, C4GUI::Dialog::SetDelOnClose(), and C4GUI::Dialog::Show().

Referenced by EndVote(), and Vote().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ OpenVoteDialog()

void C4Network2::OpenVoteDialog ( )

Definition at line 2753 of file C4Network2.cpp.

 {
     // Dialog already open?
     if (pVoteDialog) return;
     // No vote available?
     if (!Votes.firstPkt()) return;
     // Can't vote?
     C4ClientPlayerInfos *pPlayerInfos = Game.PlayerInfos.GetInfoByClientID(Game.Clients.getLocalID());
     if (!pPlayerInfos || !pPlayerInfos->GetPlayerCount() || !pPlayerInfos->GetJoinedPlayerCount())
         return;
     // Search a voting we have to vote on
     for (C4IDPacket *pPkt = Votes.firstPkt(); pPkt; pPkt = Votes.nextPkt(pPkt))
     {
         // Already voted on this matter?
         C4ControlVote *pVote = static_cast<C4ControlVote *>(pPkt->getPkt());
         if (!GetVote(::Control.ClientID(), pVote->getType(), pVote->getData()))
         {
             // Compose message
             C4Client *pSrcClient = Game.Clients.getClientByID(pVote->getByClient());
             StdStrBuf Msg; Msg.Format(LoadResStr("IDS_VOTE_WANTSTOALLOW"), pSrcClient ? pSrcClient->getName() : "???", pVote->getDesc().getData());
             Msg.AppendChar('|');
             Msg.Append(pVote->getDescWarning());
  
             // Open dialog
             pVoteDialog = new C4VoteDialog(Msg.getData(), pVote->getType(), pVote->getData(), false);
             pVoteDialog->SetDelOnClose();
             pVoteDialog->Show(::pGUI, true);
  
             break;
         }
     }
 }

References StdStrBuf::Append(), StdStrBuf::AppendChar(), C4GameControl::ClientID(), C4Game::Clients, Control, C4Control::firstPkt(), StdStrBuf::Format(), Game, C4ControlPacket::getByClient(), C4ClientList::getClientByID(), C4ControlVote::getData(), StdStrBuf::getData(), C4ControlVote::getDesc(), C4ControlVote::getDescWarning(), C4PlayerInfoList::GetInfoByClientID(), C4ClientPlayerInfos::GetJoinedPlayerCount(), C4ClientList::getLocalID(), C4Client::getName(), C4ClientPlayerInfos::GetPlayerCount(), C4ControlVote::getType(), GetVote(), LoadResStr(), C4Control::nextPkt(), pGUI, C4Game::PlayerInfos, pVoteDialog, C4GUI::Dialog::SetDelOnClose(), C4GUI::Dialog::Show(), and Votes.

Referenced by AddVote(), and EndVote().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ Pause()

bool C4Network2::Pause ( )

Definition at line 514 of file C4Network2.cpp.

 {
     if (!isEnabled() || !isHost()) return false;
     // change mode: pause
     return ChangeGameStatus(GS_Pause, ::Control.getNextControlTick());
 }

References ChangeGameStatus(), Control, C4GameControl::getNextControlTick(), GS_Pause, isEnabled(), and isHost().

Referenced by AddVote(), C4Game::Pause(), and Vote().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ PauseGame()

bool C4Network2::PauseGame ( bool fAutoContinue )

protected

◆ QueryClientPassword()

StdStrBuf C4Network2::QueryClientPassword ( )

Definition at line 785 of file C4Network2.cpp.

 {
     // ask client for a password; return nothing if user canceled
     StdStrBuf sCaption; sCaption.Copy(LoadResStr("IDS_MSG_ENTERPASSWORD"));
     C4GUI::InputDialog *pInputDlg = new C4GUI::InputDialog(LoadResStr("IDS_MSG_ENTERPASSWORD"), sCaption.getData(), C4GUI::Ico_Ex_Locked, nullptr, false);
     pInputDlg->SetDelOnClose(false);
     if (!::pGUI->ShowModalDlg(pInputDlg, false))
     {
         delete pInputDlg;
         return StdStrBuf();
     }
     // copy to buffer
     StdStrBuf Buf; Buf.Copy(pInputDlg->GetInputText());
     delete pInputDlg;
     return Buf;
 }

References StdStrBuf::Copy(), StdStrBuf::getData(), C4GUI::InputDialog::GetInputText(), C4GUI::Ico_Ex_Locked, LoadResStr(), pGUI, C4GUI::Dialog::SetDelOnClose(), and C4GUI::Screen::ShowModalDlg().

Here is the call graph for this function:

◆ RemoveDynamic()

void C4Network2::RemoveDynamic ( )

protected

Definition at line 1797 of file C4Network2.cpp.

 {
     C4Network2Res::Ref pRes = ResList.getRefRes(ResDynamic.getID());
     if (pRes) pRes->Remove();
     ResDynamic.Clear();
     iDynamicTick = -1;
 }

References C4Network2ResCore::Clear(), C4Network2ResCore::getID(), C4Network2ResList::getRefRes(), iDynamicTick, C4Network2Res::Remove(), ResDynamic, and ResList.

Referenced by CreateDynamic(), and Execute().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ RequestActivate()

void C4Network2::RequestActivate ( )

Definition at line 1939 of file C4Network2.cpp.

 {
     // neither observer nor activated?
     if (Game.Clients.getLocal()->isObserver() || Game.Clients.getLocal()->isActivated())
     {
         tLastActivateRequest = C4TimeMilliseconds::NegativeInfinity;
         return;
     }
     // host? just do it
     if (fHost)
     {
         // activate him
         ::Control.DoInput(CID_ClientUpdate,
                           new C4ControlClientUpdate(C4ClientIDHost, CUT_Activate, true),
                           CDT_Sync);
         return;
     }
     // ensure interval
     if(C4TimeMilliseconds::Now() < tLastActivateRequest + C4NetActivationReqInterval)
         return;
     // status not reached yet? May be chasing, let's delay this.
     if (!fStatusReached)
     {
         fDelayedActivateReq = true;
         return;
     }
     // request
     Clients.SendMsgToHost(MkC4NetIOPacket(PID_ClientActReq, C4PacketActivateReq(Game.FrameCounter)));
     // store time
     tLastActivateRequest = C4TimeMilliseconds::Now();
 }

References C4ClientIDHost, C4NetActivationReqInterval, CDT_Sync, CID_ClientUpdate, C4Game::Clients, Clients, Control, CUT_Activate, C4GameControl::DoInput(), fDelayedActivateReq, fHost, C4Game::FrameCounter, fStatusReached, Game, C4ClientList::getLocal(), C4Client::isActivated(), C4Client::isObserver(), MkC4NetIOPacket(), C4TimeMilliseconds::NegativeInfinity, C4TimeMilliseconds::Now(), PID_ClientActReq, C4Network2ClientList::SendMsgToHost(), and tLastActivateRequest.

Referenced by CheckStatusReached(), Execute(), and C4Network2Players::JoinLocalPlayer().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ RetrieveRes()

C4Network2Res::Ref C4Network2::RetrieveRes	(	const C4Network2ResCore &	Core,
		int32_t	iTimeout,
		const char *	szResName,
		bool	fWaitForCore = `false`
	)

Definition at line 1678 of file C4Network2.cpp.

 {
     C4GUI::ProgressDialog *pDlg = nullptr;
     bool fLog = false;
     int32_t iProcess = -1;
     C4TimeMilliseconds tTimeout = C4TimeMilliseconds::Now() + iTimeoutLen;
     // wait for resource
     while (isEnabled())
     {
         // find resource
         C4Network2Res::Ref pRes = ResList.getRefRes(Core.getID());
         // res not found?
         if (!pRes)
         {
             if (Core.isNull())
             {
                 // should wait for core?
                 if (!fWaitForCore) return nullptr;
             }
             else
             {
                 // start loading
                 pRes = ResList.AddByCore(Core);
             }
         }
         // res found and loaded completely
         else if (!pRes->isLoading())
         {
             // log
             if (fLog) LogF(LoadResStr("IDS_NET_RECEIVED"), szResName, pRes->getCore().getFileName());
             // return
             if (pDlg) delete pDlg;
             return pRes;
         }
  
         // check: progress?
         if (pRes && pRes->getPresentPercent() != iProcess)
         {
             iProcess = pRes->getPresentPercent();
             tTimeout = C4TimeMilliseconds::Now() + iTimeoutLen;
         }
         else
         {
             // if not: check timeout
             if (C4TimeMilliseconds::Now() > tTimeout)
             {
                 LogFatal(FormatString(LoadResStr("IDS_NET_ERR_RESTIMEOUT"), szResName).getData());
                 if (pDlg) delete pDlg;
                 return nullptr;
             }
         }
  
         // log
         if (!fLog)
         {
             LogF(LoadResStr("IDS_NET_WAITFORRES"), szResName);
             fLog = true;
         }
         // show progress dialog
         if (!pDlg && !Console.Active && ::pGUI)
         {
             // create
             pDlg = new C4GUI::ProgressDialog(FormatString(LoadResStr("IDS_NET_WAITFORRES"), szResName).getData(),
                                              LoadResStr("IDS_NET_CAPTION"), 100, 0, C4GUI::Ico_NetWait);
             // show dialog
             if (!pDlg->Show(::pGUI, true)) { delete pDlg; return nullptr; }
         }
  
         // wait
         if (pDlg)
         {
             // set progress bar
             pDlg->SetProgress(iProcess);
             // execute (will do message handling)
             if (!pDlg->Execute())
                 { if (pDlg) delete pDlg; return nullptr; }
             // aborted?
             if (pDlg->IsAborted()) break;
         }
         else
         {
             if (!Application.ScheduleProcs(tTimeout - C4TimeMilliseconds::Now()))
                 { return nullptr; }
         }
  
     }
     // aborted
     delete pDlg;
     return nullptr;
 }

References C4Window::Active, C4Network2ResList::AddByCore(), Application, Console, C4GUI::Dialog::Execute(), FormatString(), C4Network2Res::getCore(), C4Network2ResCore::getFileName(), C4Network2ResCore::getID(), C4Network2Res::getPresentPercent(), C4Network2ResList::getRefRes(), C4GUI::Ico_NetWait, C4GUI::Dialog::IsAborted(), isEnabled(), C4Network2Res::isLoading(), C4Network2ResCore::isNull(), LoadResStr(), LogF(), LogFatal(), C4TimeMilliseconds::Now(), pGUI, ResList, StdScheduler::ScheduleProcs(), C4GUI::ProgressDialog::SetProgress(), and C4GUI::Dialog::Show().

Referenced by C4PlayerInfoList::RecreatePlayers(), C4GameResList::RetrieveFiles(), and RetrieveScenario().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ RetrieveScenario()

bool C4Network2::RetrieveScenario ( char * szScenario )

Definition at line 590 of file C4Network2.cpp.

 {
     // client only
     if (isHost()) return false;
  
     // wait for scenario
     C4Network2Res::Ref pScenario = RetrieveRes(*Game.Parameters.Scenario.getResCore(),
                                    C4NetResRetrieveTimeout, LoadResStr("IDS_NET_RES_SCENARIO"));
     if (!pScenario)
         return false;
  
     // wait for dynamic data
     C4Network2Res::Ref pDynamic = RetrieveRes(ResDynamic, C4NetResRetrieveTimeout, LoadResStr("IDS_NET_RES_DYNAMIC"));
     if (!pDynamic)
         return false;
  
     // create unpacked copy of scenario
     if (!ResList.FindTempResFileName(FormatString("Combined%d.ocs", Game.Clients.getLocalID()).getData(), szScenario) ||
         !C4Group_CopyItem(pScenario->getFile(), szScenario) ||
         !C4Group_UnpackDirectory(szScenario))
         return false;
  
     // create unpacked copy of dynamic data
     char szTempDynamic[_MAX_PATH_LEN];
     if (!ResList.FindTempResFileName(pDynamic->getFile(), szTempDynamic) ||
         !C4Group_CopyItem(pDynamic->getFile(), szTempDynamic) ||
         !C4Group_UnpackDirectory(szTempDynamic))
         return false;
  
     // unpack Material.ocg if materials need to be merged
     StdStrBuf MaterialScenario, MaterialDynamic;
     MaterialScenario.Format("%s" DirSep  C4CFN_Material, szScenario);
     MaterialDynamic.Format("%s" DirSep  C4CFN_Material, szTempDynamic);
     if (FileExists(MaterialScenario.getData()) && FileExists(MaterialDynamic.getData()))
         if (!C4Group_UnpackDirectory(MaterialScenario.getData()) ||
             !C4Group_UnpackDirectory(MaterialDynamic.getData()))
             return false;
  
     // move all dynamic files to scenario
     C4Group ScenGrp;
     if (!ScenGrp.Open(szScenario) ||
         !ScenGrp.Merge(szTempDynamic))
         return false;
     ScenGrp.Close();
  
     // remove dynamic temp file
     EraseDirectory(szTempDynamic);
  
     // remove dynamic - isn't needed any more and will soon be out-of-date
     pDynamic->Remove();
  
     return true;
 }

References _MAX_PATH_LEN, C4CFN_Material, C4Group_CopyItem(), C4Group_UnpackDirectory(), C4NetResRetrieveTimeout, C4Game::Clients, C4Group::Close(), DirSep, EraseDirectory(), FileExists(), C4Network2ResList::FindTempResFileName(), StdStrBuf::Format(), FormatString(), Game, StdStrBuf::getData(), C4Network2Res::getFile(), C4ClientList::getLocalID(), C4GameRes::getResCore(), isHost(), LoadResStr(), C4Group::Merge(), C4Group::Open(), C4Game::Parameters, C4Network2Res::Remove(), ResDynamic, ResList, RetrieveRes(), and C4GameParameters::Scenario.

Referenced by C4Game::Init().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ SendJoinData()

void C4Network2::SendJoinData ( C4Network2Client * pClient )

protected

Definition at line 1644 of file C4Network2.cpp.

 {
     if (pClient->hasJoinData()) return;
     // host only, scenario must be available
     assert(isHost());
     // dynamic available?
     if (ResDynamic.isNull() || iDynamicTick < ::Control.ControlTick)
     {
         fDynamicNeeded = true;
         // add synchronization control (will callback, see C4Game::Synchronize)
         ::Control.DoInput(CID_Synchronize, new C4ControlSynchronize(false, true), CDT_Sync);
         return;
     }
     // save his client ID
     C4PacketJoinData JoinData;
     JoinData.SetClientID(pClient->getID());
     // save status into packet
     JoinData.SetGameStatus(Status);
     // scenario parameter defs for lobby display (localized in host language)
     JoinData.ScenarioParameterDefs = ::Game.ScenarioParameterDefs;
     // parameters
     JoinData.Parameters = Game.Parameters;
     // core join data
     JoinData.SetStartCtrlTick(iDynamicTick);
     JoinData.SetDynamicCore(ResDynamic);
     // send
     pClient->SendMsg(MkC4NetIOPacket(PID_JoinData, JoinData));
     // send addresses
     Clients.SendAddresses(pClient->getMsgConn());
     // flag client (he will have to accept the network status sent next)
     pClient->SetStatus(NCS_Chasing);
     if (!iLastChaseTargetUpdate) iLastChaseTargetUpdate = time(nullptr);
 }

References CDT_Sync, CID_Synchronize, Clients, Control, C4GameControl::ControlTick, C4GameControl::DoInput(), fDynamicNeeded, Game, C4Network2Client::getID(), C4Network2Client::getMsgConn(), C4Network2Client::hasJoinData(), iDynamicTick, iLastChaseTargetUpdate, isHost(), C4Network2ResCore::isNull(), MkC4NetIOPacket(), NCS_Chasing, C4Game::Parameters, C4PacketJoinData::Parameters, PID_JoinData, ResDynamic, C4Game::ScenarioParameterDefs, C4PacketJoinData::ScenarioParameterDefs, C4Network2ClientList::SendAddresses(), C4Network2Client::SendMsg(), C4PacketJoinData::SetClientID(), C4PacketJoinData::SetDynamicCore(), C4PacketJoinData::SetGameStatus(), C4PacketJoinData::SetStartCtrlTick(), C4Network2Client::SetStatus(), and Status.

Referenced by OnClientConnect(), and OnGameSynchronized().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ SetAllowObserve()

void C4Network2::SetAllowObserve ( bool fAllow )

Definition at line 813 of file C4Network2.cpp.

 {
     if (!isHost()) return;
     fAllowObserve = fAllow;
 }

References fAllowObserve, and isHost().

Here is the call graph for this function:

◆ SetCtrlMode()

void C4Network2::SetCtrlMode ( int32_t iCtrlMode )

Definition at line 819 of file C4Network2.cpp.

 {
     if (!isHost()) return;
     // no change?
     if (iCtrlMode == Status.getCtrlMode()) return;
     // change game status
     ChangeGameStatus(Status.getState(), ::Control.ControlTick, iCtrlMode);
 }

References ChangeGameStatus(), Control, C4GameControl::ControlTick, C4Network2Status::getCtrlMode(), C4Network2Status::getState(), isHost(), and Status.

Referenced by C4MessageInput::ProcessCommand().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ SetPassword()

void C4Network2::SetPassword ( const char * szToPassword )

Definition at line 772 of file C4Network2.cpp.

 {
     bool fHadPassword = isPassworded();
     // clear password?
     if (!szToPassword || !*szToPassword)
         sPassword.Clear();
     else
         // no? then set it
         sPassword.Copy(szToPassword);
     // if the has-password-state has changed, the reference is invalidated
     if (fHadPassword != isPassworded()) InvalidateReference();
 }

References StdStrBuf::Clear(), StdStrBuf::Copy(), InvalidateReference(), isPassworded(), and sPassword.

Referenced by C4StartupScenSelDlg::OnClosed(), C4GameOptionButtons::OnPasswordSet(), C4Application::ParseCommandLine(), and C4MessageInput::ProcessCommand().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ Start()

bool C4Network2::Start ( )

Definition at line 506 of file C4Network2.cpp.

 {
     if (!isEnabled() || !isHost()) return false;
     // change mode: go
     ChangeGameStatus(GS_Go, ::Control.ControlTick);
     return true;
 }

References ChangeGameStatus(), Control, C4GameControl::ControlTick, GS_Go, isEnabled(), and isHost().

Referenced by EndVote(), C4Game::InitNetworkHost(), C4GameLobby::Countdown::OnSec1Timer(), C4MessageInput::ProcessCommand(), C4GameLobby::MainDlg::Start(), and C4Game::Unpause().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ StartLobbyCountdown()

void C4Network2::StartLobbyCountdown ( int32_t iCountdownTime )

Definition at line 2856 of file C4Network2.cpp.

 {
     // abort previous
     if (pLobbyCountdown) AbortLobbyCountdown();
     // start new
     pLobbyCountdown = new C4GameLobby::Countdown(iCountdownTime);
 }

References AbortLobbyCountdown(), and pLobbyCountdown.

Referenced by DoLobby(), C4MessageInput::ProcessCommand(), and C4GameLobby::MainDlg::Start().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ StartStreaming()

bool C4Network2::StartStreaming ( C4Record * pRecord )

Definition at line 2877 of file C4Network2.cpp.

 {
     // Save back
     fStreaming = true;
     pStreamedRecord = pRecord;
     iLastStreamAttempt = time(nullptr);
  
     // Initialize compressor
     ZeroMem(&StreamCompressor, sizeof(StreamCompressor));
     if (deflateInit(&StreamCompressor, 9) != Z_OK)
         return false;
  
     // Create stream buffer
     StreamingBuf.New(C4NetStreamingMaxBlockSize);
     StreamCompressor.next_out = reinterpret_cast<BYTE*>(StreamingBuf.getMData());
     StreamCompressor.avail_out = C4NetStreamingMaxBlockSize;
  
     // Initialize HTTP client
     pStreamer = new C4HTTPClient();
     if (!pStreamer->Init())
         return false;
     Application.Add(pStreamer);
  
     return true;
 }

References StdScheduler::Add(), Application, C4NetStreamingMaxBlockSize, fStreaming, StdBuf::getMData(), iLastStreamAttempt, C4HTTPClient::Init(), StdBuf::New(), pStreamedRecord, pStreamer, StreamCompressor, StreamingBuf, and ZeroMem().

Here is the call graph for this function:

◆ StopStreaming()

bool C4Network2::StopStreaming ( )

Definition at line 2920 of file C4Network2.cpp.

 {
     if (!fStreaming) return false;
  
     // Clear
     Application.Remove(pStreamer);
     fStreaming = false;
     pStreamedRecord = nullptr;
     deflateEnd(&StreamCompressor);
     StreamingBuf.Clear();
     delete pStreamer;
     pStreamer = nullptr;
  
     // ... finalization?
     return true;
 }

References Application, StdBuf::Clear(), fStreaming, pStreamedRecord, pStreamer, StdScheduler::Remove(), StreamCompressor, and StreamingBuf.

Referenced by Clear(), and StreamOut().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ StreamIn()

bool C4Network2::StreamIn ( bool fFinish )

protected

Definition at line 2937 of file C4Network2.cpp.

 {
     if (!pStreamedRecord) return false;
  
     // Get data from record
     const StdBuf &Data = pStreamedRecord->GetStreamingBuf();
     if (!fFinish)
         if (!Data.getSize() || !StreamCompressor.avail_out)
             return false;
  
     do
     {
  
         // Compress
         StreamCompressor.next_in = const_cast<BYTE *>(getBufPtr<BYTE>(Data));
         StreamCompressor.avail_in = Data.getSize();
         int ret = deflate(&StreamCompressor, fFinish ? Z_FINISH : Z_NO_FLUSH);
  
         // Anything consumed?
         unsigned int iInAmount = Data.getSize() - StreamCompressor.avail_in;
         if (iInAmount > 0)
             pStreamedRecord->ClearStreamingBuf(iInAmount);
  
         // Done?
         if (!fFinish || ret == Z_STREAM_END)
             break;
  
         // Error while finishing?
         if (ret != Z_OK)
             return false;
  
         // Enlarge buffer, if neccessary
         size_t iPending = getPendingStreamData();
         size_t iGrow = StreamingBuf.getSize();
         StreamingBuf.Grow(iGrow);
         StreamCompressor.avail_out += iGrow;
         StreamCompressor.next_out = getMBufPtr<BYTE>(StreamingBuf, iPending);
  
     }
     while (true);
  
     return true;
 }

References C4Record::ClearStreamingBuf(), getPendingStreamData(), StdBuf::getSize(), C4Record::GetStreamingBuf(), StdBuf::Grow(), pStreamedRecord, StreamCompressor, and StreamingBuf.

Referenced by Execute(), FinishStreaming(), and StreamOut().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ StreamOut()

bool C4Network2::StreamOut ( )

protected

Definition at line 2981 of file C4Network2.cpp.

 {
     // Streamer busy?
     if (!pStreamer || pStreamer->isBusy())
         return false;
  
     // Streamer done?
     if (pStreamer->isSuccess())
     {
  
         // Move new data to front of buffer
         if (getPendingStreamData() != iCurrentStreamAmount)
             StreamingBuf.Move(iCurrentStreamAmount, getPendingStreamData() - iCurrentStreamAmount);
  
         // Free buffer space
         StreamCompressor.next_out -= iCurrentStreamAmount;
         StreamCompressor.avail_out += iCurrentStreamAmount;
  
         // Advance stream
         iCurrentStreamPosition += iCurrentStreamAmount;
  
         // Get input
         StreamIn(false);
     }
  
     // Clear streamer
     pStreamer->Clear();
  
     // Record is still running?
     if (pStreamedRecord)
     {
  
         // Enough available to send?
         if (getPendingStreamData() < C4NetStreamingMinBlockSize)
             return false;
  
         // Overflow protection
         if (iLastStreamAttempt && iLastStreamAttempt + C4NetStreamingInterval >= time(nullptr))
             return false;
  
     }
     // All data finished?
     else if (!getPendingStreamData())
     {
         // Then we're done.
         StopStreaming();
         return false;
     }
  
     // Set stream address
     StdStrBuf StreamAddr;
     StreamAddr.Copy(Game.Parameters.StreamAddress);
     StreamAddr.AppendFormat("pos=%d&end=%d", iCurrentStreamPosition, !pStreamedRecord);
     pStreamer->SetServer(StreamAddr.getData());
  
     // Send data
     size_t iStreamAmount = getPendingStreamData();
     iCurrentStreamAmount = iStreamAmount;
     iLastStreamAttempt = time(nullptr);
     return  pStreamer->Query(StdBuf(StreamingBuf.getData(), iStreamAmount), false);
 }

References StdStrBuf::AppendFormat(), C4NetStreamingInterval, C4NetStreamingMinBlockSize, C4HTTPClient::Clear(), StdStrBuf::Copy(), Game, StdBuf::getData(), StdStrBuf::getData(), getPendingStreamData(), iCurrentStreamAmount, iCurrentStreamPosition, iLastStreamAttempt, C4HTTPClient::isBusy(), C4HTTPClient::isSuccess(), StdBuf::Move(), C4Game::Parameters, pStreamedRecord, pStreamer, C4HTTPClient::Query(), C4HTTPClient::SetServer(), StopStreaming(), C4GameParameters::StreamAddress, StreamCompressor, StreamIn(), and StreamingBuf.

Referenced by Execute(), and FinishStreaming().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ Sync()

bool C4Network2::Sync ( )

Definition at line 521 of file C4Network2.cpp.

 {
     // host only
     if (!isEnabled() || !isHost()) return false;
     // already syncing the network?
     if (!fStatusAck)
     {
         // maybe we are already sync?
         if (fStatusReached) CheckStatusAck();
         return true;
     }
     // already sync?
     if (isFrozen()) return true;
     // ok, so let's do a sync: change in the same state we are already in
     return ChangeGameStatus(Status.getState(), ::Control.getNextControlTick());
 }

References ChangeGameStatus(), CheckStatusAck(), Control, fStatusAck, fStatusReached, C4GameControl::getNextControlTick(), C4Network2Status::getState(), isEnabled(), isFrozen(), isHost(), and Status.

Referenced by C4GameControlNetwork::DoInput().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ ToggleAllowJoin()

bool C4Network2::ToggleAllowJoin ( )

Definition at line 759 of file C4Network2.cpp.

 {
     // just toggle
     AllowJoin(!fAllowJoin);
     return true; // toggled
 }

References AllowJoin(), and fAllowJoin.

Referenced by C4Game::InitKeyboard().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ ToggleClientListDlg()

bool C4Network2::ToggleClientListDlg ( )

Definition at line 766 of file C4Network2.cpp.

 {
     C4Network2ClientListDlg::Toggle();
     return true;
 }

References C4Network2ClientListDlg::Toggle().

Referenced by C4Game::InitKeyboard().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ UpdateChaseTarget()

void C4Network2::UpdateChaseTarget ( )

protected

Definition at line 1984 of file C4Network2.cpp.

 {
     // no chasing clients?
     C4Network2Client *pClient;
     for (pClient = Clients.GetNextClient(nullptr); pClient; pClient = Clients.GetNextClient(pClient))
         if (pClient->isChasing())
             break;
     if (!pClient)
     {
         iLastChaseTargetUpdate = 0;
         return;
     }
     // not time for an update?
     if (!iLastChaseTargetUpdate || long(iLastChaseTargetUpdate + C4NetChaseTargetUpdateInterval) > time(nullptr))
         return;
     // copy status, set current tick
     C4Network2Status ChaseTarget = Status;
     ChaseTarget.SetTargetTick(::Control.ControlTick);
     // send to everyone involved
     for (pClient = Clients.GetNextClient(nullptr); pClient; pClient = Clients.GetNextClient(pClient))
         if (pClient->isChasing())
             pClient->SendMsg(MkC4NetIOPacket(PID_Status, ChaseTarget));
     iLastChaseTargetUpdate = time(nullptr);
 }

References C4NetChaseTargetUpdateInterval, Clients, Control, C4GameControl::ControlTick, C4Network2ClientList::GetNextClient(), iLastChaseTargetUpdate, C4Network2Client::isChasing(), MkC4NetIOPacket(), PID_Status, C4Network2Client::SendMsg(), C4Network2Status::SetTargetTick(), and Status.

Referenced by Execute().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ Vote()

void C4Network2::Vote	(	C4ControlVoteType	eType,
		bool	fApprove = `true`,
		int32_t	iData = `0`
	)

Definition at line 2654 of file C4Network2.cpp.

 {
     // Original vote?
     if (!GetVote(C4ClientIDUnknown, eType, iData))
     {
         // Too fast?
         if (time(nullptr) < (time_t) (iLastOwnVoting + C4NetMinVotingInterval))
         {
             Log(LoadResStr("IDS_TEXT_YOUCANONLYSTARTONEVOTINGE"));
             if ((eType == VT_Kick && iData == Game.Clients.getLocalID()) || eType == VT_Cancel)
                 OpenSurrenderDialog(eType, iData);
             return;
         }
         // Save timestamp
         iLastOwnVoting = time(nullptr);
     }
     // Already voted? Ignore
     if (GetVote(::Control.ClientID(), eType, iData))
         return;
     // Set pause mode if this is the host
     if (isHost() && isRunning())
     {
         Pause();
         fPausedForVote = true;
     }
     // send vote control
     ::Control.DoInput(CID_Vote, new C4ControlVote(eType, fApprove, iData), CDT_Direct);
 }

References C4ClientIDUnknown, C4NetMinVotingInterval, CDT_Direct, CID_Vote, C4GameControl::ClientID(), C4Game::Clients, Control, C4GameControl::DoInput(), fPausedForVote, Game, C4ClientList::getLocalID(), GetVote(), iLastOwnVoting, isHost(), isRunning(), LoadResStr(), Log(), OpenSurrenderDialog(), Pause(), VT_Cancel, and VT_Kick.

Referenced by C4Game::Abort(), AddVote(), C4MainMenu::MenuCommand(), C4Game::Pause(), C4MessageInput::ProcessCommand(), and C4Game::Unpause().

Here is the call graph for this function:

Here is the caller graph for this function:

Friends And Related Function Documentation

◆ C4Network2IO

friend class C4Network2IO

friend

Definition at line 103 of file C4Network2.h.

Member Data Documentation

◆ Clients

C4Network2ClientList C4Network2::Clients

Definition at line 116 of file C4Network2.h.

Referenced by C4GameLobby::Countdown::Abort(), C4MainMenu::ActivateHost(), C4Network2Stats::C4Network2Stats(), C4GameControlNetwork::CalcPerformance(), C4Network2IO::CallHandlers(), ChangeGameStatus(), C4GameControlNetwork::CheckCompleteCtrl(), CheckStatusAck(), CheckStatusReached(), Clear(), C4GameLobby::Countdown::Countdown(), DeactivateInactiveClients(), C4Network2Client::DoConnectAttempt(), C4GameControlNetwork::DoInput(), DrawStatus(), C4GameControlNetwork::ExecSyncControl(), C4Viewport::Execute(), Execute(), C4Network2Stats::ExecuteSecond(), HandleConn(), HandleJoinData(), HandleLobbyPacket(), HandlePacket(), C4Network2Players::HandlePacket(), C4GameControlNetwork::Init(), InitHost(), InitNetIO(), Join(), C4Network2Players::JoinLocalPlayer(), LeagueEnd(), LeagueNotifyDisconnect(), OnClientDisconnect(), OnConnectFail(), OnDisconn(), OnGameSynchronized(), OnPuncherConnect(), C4GameLobby::Countdown::OnSec1Timer(), C4GameControlNetwork::PackCompleteCtrl(), C4MessageInput::ProcessCommand(), RequestActivate(), C4Network2Players::RequestPlayerInfoUpdate(), SendJoinData(), C4GameControlNetwork::SetCtrlMode(), UpdateChaseTarget(), C4Console::UpdateNetMenu(), C4GameSave::WriteDescNetworkClients(), and C4Network2Stats::~C4Network2Stats().

◆ fAllowJoin

bool C4Network2::fAllowJoin {false}

protected

Definition at line 130 of file C4Network2.h.

Referenced by AllowJoin(), Clear(), DoLobby(), InitHost(), isJoinAllowed(), Join(), and ToggleAllowJoin().

◆ fAllowObserve

bool C4Network2::fAllowObserve

protected

Definition at line 130 of file C4Network2.h.

Referenced by isObservingAllowed(), Join(), and SetAllowObserve().

◆ fChasing

bool C4Network2::fChasing {false}

protected

Definition at line 141 of file C4Network2.h.

Referenced by CheckStatusReached(), HandleStatusAck(), and InitHost().

◆ fDelayedActivateReq

bool C4Network2::fDelayedActivateReq {false}

protected

Definition at line 178 of file C4Network2.h.

Referenced by CheckStatusReached(), Clear(), and RequestActivate().

◆ fDynamicNeeded

bool C4Network2::fDynamicNeeded {false}

protected

Definition at line 137 of file C4Network2.h.

Referenced by Clear(), CreateDynamic(), OnGameSynchronized(), and SendJoinData().

◆ fHost

bool C4Network2::fHost

protected

Definition at line 127 of file C4Network2.h.

Referenced by Execute(), InitHost(), InitLeague(), InitNetIO(), isHost(), LeagueEnd(), LeagueStart(), LeagueUpdate(), LeagueUpdateProcessReply(), and RequestActivate().

◆ fLeagueEndSent

bool C4Network2::fLeagueEndSent

protected

Definition at line 166 of file C4Network2.h.

Referenced by LeagueEnd(), LeagueGameEvaluate(), and LeagueStart().

◆ fLobbyRunning

bool C4Network2::fLobbyRunning {false}

protected

Definition at line 148 of file C4Network2.h.

Referenced by CheckStatusReached(), Clear(), and DoLobby().

◆ fPausedForVote

bool C4Network2::fPausedForVote {false}

protected

Definition at line 183 of file C4Network2.h.

Referenced by AddVote(), Clear(), EndVote(), and Vote().

◆ fStatusAck

bool C4Network2::fStatusAck {false}

protected

Definition at line 140 of file C4Network2.h.

Referenced by ChangeGameStatus(), CheckStatusAck(), Clear(), DrawStatus(), FinalInit(), HandleStatus(), HandleStatusAck(), InitHost(), isFrozen(), isPausing(), isStatusAck(), and Sync().

◆ fStatusReached

bool C4Network2::fStatusReached {false}

protected

Definition at line 140 of file C4Network2.h.

Referenced by ChangeGameStatus(), CheckStatusAck(), CheckStatusReached(), Clear(), DrawStatus(), FinalInit(), HandleStatus(), HandleStatusAck(), InitHost(), OnClientDisconnect(), RequestActivate(), and Sync().

◆ fStreaming

bool C4Network2::fStreaming {false}

protected

Definition at line 187 of file C4Network2.h.

Referenced by DrawStatus(), Execute(), FinishStreaming(), isStreaming(), StartStreaming(), and StopStreaming().

◆ fWrongPassword

bool C4Network2::fWrongPassword

protected

Definition at line 175 of file C4Network2.h.

Referenced by HandleConn(), and HandleConnRe().

◆ iCurrentStreamAmount

unsigned int C4Network2::iCurrentStreamAmount

protected

Definition at line 194 of file C4Network2.h.

Referenced by StreamOut().

◆ iCurrentStreamPosition

unsigned int C4Network2::iCurrentStreamPosition

protected

Definition at line 194 of file C4Network2.h.

Referenced by DrawStatus(), and StreamOut().

◆ iDynamicTick

int32_t C4Network2::iDynamicTick {-1}

protected

Definition at line 136 of file C4Network2.h.

Referenced by Clear(), CreateDynamic(), Execute(), HandleJoinData(), RemoveDynamic(), and SendJoinData().

◆ iLastChaseTargetUpdate

uint32_t C4Network2::iLastChaseTargetUpdate {0}

protected

Definition at line 158 of file C4Network2.h.

Referenced by Clear(), SendJoinData(), and UpdateChaseTarget().

◆ iLastLeagueUpdate

uint32_t C4Network2::iLastLeagueUpdate {0}

protected

Definition at line 165 of file C4Network2.h.

Referenced by Clear(), Execute(), and LeagueUpdate().

◆ iLastOwnVoting

time_t C4Network2::iLastOwnVoting {0}

protected

Definition at line 184 of file C4Network2.h.

Referenced by Clear(), EndVote(), and Vote().

◆ iLastReferenceUpdate

uint32_t C4Network2::iLastReferenceUpdate {0}

protected

Definition at line 164 of file C4Network2.h.

Referenced by Clear(), Execute(), and InvalidateReference().

◆ iLastStreamAttempt

time_t C4Network2::iLastStreamAttempt

protected

Definition at line 188 of file C4Network2.h.

Referenced by FinishStreaming(), StartStreaming(), and StreamOut().

◆ iLeagueUpdateDelay

uint32_t C4Network2::iLeagueUpdateDelay

protected

Definition at line 165 of file C4Network2.h.

Referenced by Execute(), InvalidateReference(), and LeagueUpdate().

◆ iNextClientID

int32_t C4Network2::iNextClientID {0}

protected

Definition at line 155 of file C4Network2.h.

Referenced by InitHost(), and Join().

◆ iVoteStartTime

time_t C4Network2::iVoteStartTime

protected

Definition at line 184 of file C4Network2.h.

Referenced by AddVote(), EndVote(), and Execute().

◆ MasterServerAddress

StdCopyStrBuf C4Network2::MasterServerAddress

protected

Definition at line 152 of file C4Network2.h.

Referenced by DeinitLeague(), and InitLeague().

◆ NetIO

C4Network2IO C4Network2::NetIO

Definition at line 110 of file C4Network2.h.

Referenced by Clear(), DrawStatus(), Execute(), C4Network2Stats::ExecuteSecond(), HandleConnRe(), HandleJoinData(), HandlePuncherPacket(), InitHost(), InitNetIO(), InitPuncher(), OnConnect(), OnConnectFail(), OnDisconn(), OnDisconnect(), OnPuncherConnect(), and C4Network2ClientDlg::UpdateText().

◆ NetpuncherAddr

StdCopyStrBuf C4Network2::NetpuncherAddr

protected

Definition at line 198 of file C4Network2.h.

Referenced by getNetpuncherAddr(), and InitHost().

◆ NetpuncherGameID

C4NetpuncherID C4Network2::NetpuncherGameID

protected

Definition at line 197 of file C4Network2.h.

Referenced by Clear(), getNetpuncherGameID(), and InitHost().

◆ pControl

class C4GameControlNetwork* C4Network2::pControl {nullptr}

protected

Definition at line 144 of file C4Network2.h.

Referenced by CheckStatusAck(), CheckStatusReached(), DrawStatus(), HandleJoinData(), InitHost(), OnStatusAck(), and OnStatusReached().

◆ Players

C4Network2Players C4Network2::Players

Definition at line 119 of file C4Network2.h.

Referenced by C4Network2IO::CallHandlers(), Clear(), C4PlayerInfoList::DoPlayerInfoUpdate(), C4Game::InitNetworkFromReference(), C4Game::InitNetworkHost(), C4PlayerList::JoinNew(), LeagueUpdateProcessReply(), C4GameLobby::MainDlg::OnClientAddPlayer(), C4GameLobby::MainDlg::OnMessage(), OnStatusAck(), C4MessageInput::ProcessCommand(), C4TeamList::SetTeamColors(), and C4TeamList::SetTeamDistribution().

◆ pLeagueClient

class C4LeagueClient* C4Network2::pLeagueClient {nullptr}

protected

Definition at line 169 of file C4Network2.h.

Referenced by Clear(), DeinitLeague(), Execute(), InitLeague(), LeagueEnd(), LeagueGameEvaluate(), LeagueNotifyDisconnect(), LeaguePlrAuth(), LeaguePlrAuthCheck(), LeagueSignupDisable(), LeagueSignupEnable(), LeagueStart(), LeagueUpdate(), LeagueUpdateProcessReply(), LeagueWaitNotBusy(), and OnClientDisconnect().

◆ pLobby

C4GameLobby::MainDlg* C4Network2::pLobby {nullptr}

protected

Definition at line 147 of file C4Network2.h.

Referenced by Clear(), DoLobby(), GetLobby(), HandleLobbyPacket(), and LeagueUpdateProcessReply().

◆ pLobbyCountdown

C4GameLobby::Countdown* C4Network2::pLobbyCountdown {nullptr}

protected

Definition at line 149 of file C4Network2.h.

Referenced by AbortLobbyCountdown(), Clear(), DoLobby(), isLobbyCountDown(), and StartLobbyCountdown().

◆ pStreamedRecord

C4Record* C4Network2::pStreamedRecord

protected

Definition at line 189 of file C4Network2.h.

Referenced by DrawStatus(), FinishStreaming(), StartStreaming(), StopStreaming(), StreamIn(), and StreamOut().

◆ pStreamer

class C4HTTPClient* C4Network2::pStreamer

protected

Definition at line 193 of file C4Network2.h.

Referenced by StartStreaming(), StopStreaming(), and StreamOut().

◆ pVoteDialog

class C4VoteDialog* C4Network2::pVoteDialog {nullptr}

protected

Definition at line 182 of file C4Network2.h.

Referenced by Clear(), EndVote(), OnVoteDialogClosed(), OpenSurrenderDialog(), and OpenVoteDialog().

◆ ResDynamic

C4Network2ResCore C4Network2::ResDynamic

protected

Definition at line 133 of file C4Network2.h.

Referenced by CreateDynamic(), Execute(), HandleJoinData(), RemoveDynamic(), RetrieveScenario(), and SendJoinData().

◆ ResList

C4Network2ResList C4Network2::ResList

Definition at line 113 of file C4Network2.h.

Referenced by C4Network2IO::CallHandlers(), Clear(), CreateDynamic(), C4Network2IO::Execute(), HandleJoinData(), InitHost(), C4PlayerInfo::LoadFromLocalFile(), C4PlayerInfo::LoadResource(), OnClientConnect(), C4ControlJoinPlayer::PreExecute(), C4ControlJoinPlayer::PreRec(), C4MessageInput::ProcessCommand(), RemoveDynamic(), RetrieveRes(), RetrieveScenario(), C4Player::Save(), and C4Network2ResDlg::Update().

◆ sPassword

StdStrBuf C4Network2::sPassword

protected

Definition at line 172 of file C4Network2.h.

Referenced by Clear(), GetPassword(), HandleConn(), isPassworded(), and SetPassword().

◆ Status

C4Network2Status C4Network2::Status

◆ StreamCompressor

z_stream C4Network2::StreamCompressor

protected

Definition at line 191 of file C4Network2.h.

Referenced by getPendingStreamData(), StartStreaming(), StopStreaming(), StreamIn(), and StreamOut().

◆ StreamingBuf

StdBuf C4Network2::StreamingBuf

protected

Definition at line 190 of file C4Network2.h.

Referenced by getPendingStreamData(), StartStreaming(), StopStreaming(), StreamIn(), and StreamOut().

◆ tLastActivateRequest

C4TimeMilliseconds C4Network2::tLastActivateRequest

protected

Definition at line 161 of file C4Network2.h.

Referenced by Clear(), Execute(), and RequestActivate().

◆ Votes

C4Control C4Network2::Votes

protected

Definition at line 181 of file C4Network2.h.

Referenced by AddVote(), Clear(), EndVote(), Execute(), GetVote(), and OpenVoteDialog().

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

Classes

Public Types

Public Member Functions

Public Attributes

Protected Member Functions

Protected Attributes

Private Member Functions

Friends

Detailed Description

Member Enumeration Documentation

◆ InitResult

Constructor & Destructor Documentation

◆ C4Network2()

◆ ~C4Network2()

Member Function Documentation

◆ AbortLobbyCountdown()

◆ AddVote()

◆ AllowJoin()

◆ ChangeGameStatus()

◆ CheckConn()

◆ CheckStatusAck()

◆ CheckStatusReached()

◆ Clear()

◆ CreateDynamic()

◆ DeactivateInactiveClients()

◆ DeinitLeague()

◆ DoLobby()

◆ DrawStatus()

◆ EndVote()

◆ Execute() [1/2]

◆ Execute() [2/2]

◆ FinalInit()

◆ FinishStreaming()

◆ GetLobby()

◆ getNetpuncherAddr()

◆ getNetpuncherGameID() [1/2]

◆ getNetpuncherGameID() [2/2]

◆ GetPassword()

◆ getPendingStreamData()

◆ GetVote()

◆ HandleActivateReq()

◆ HandleConn()

◆ HandleConnRe()

◆ HandleJoinData()

◆ HandleLobbyPacket()

◆ HandlePacket()

◆ HandlePuncherPacket()

◆ HandleStatus()

◆ HandleStatusAck()

◆ HostConnect()

◆ InitClient() [1/2]

◆ InitClient() [2/2]

◆ InitHost()

◆ InitLeague()

◆ InitNetIO()

◆ InitPuncher()

◆ InvalidateReference()

◆ isEnabled()

◆ isFrozen()

◆ isHost()

◆ isJoinAllowed()

◆ isLobbyActive()

◆ isLobbyCountDown()

◆ isObservingAllowed()

◆ isPassworded()

◆ isPastLobby()

◆ isPaused()

◆ isPausing()

◆ isRunning()

◆ isStatusAck()

◆ isStreaming()

◆ Join()

◆ LeagueEnd()

◆ LeagueGameEvaluate()

◆ LeagueNotifyDisconnect()

◆ LeaguePlrAuth()

◆ LeaguePlrAuthCheck()

◆ LeagueShowError()

◆ LeagueSignupDisable()

◆ LeagueSignupEnable()