EntityList Class Reference

#include "EntityList.h"

Inheritance diagram for EntityList:

Collaboration diagram for EntityList:

Public Types
typedef std::set< uint32 >	character_set

Public Member Functions
	EntityList ()
	~EntityList ()
void	Initialize ()
void	Close ()
void	Process ()
void	Shutdown ()
void	Add (Client *pClient)
void	Remove (Client *pClient)
void	AddPlayer (Client *pClient)
void	RemovePlayer (Client *pClient)
void	AddNPC ()
void	RemoveNPC ()
void	SetService (PyServiceMgr *svc)
void	GetStationGuestList (uint32 stationID, std::vector< Client * > &result) const
bool	HasClients ()
Agent *	GetAgent (uint32 agentID)
Client *	FindClientByName (const char *name) const
Client *	FindClientByCharID (uint32 charID) const
SystemManager *	FindOrBootSystem (uint32 systemID)
bool	IsOnline (uint32 charID)
PyRep *	PyIsOnline (uint32 charID)
uint32	GetNPCCount ()
uint32	GetClientCount () const
uint32	GetPlayerCount () const
uint32	GetSystemCount () const
uint32	GetStationCount () const
uint16	GetClientSeed ()
uint32	GetStamp ()
uint32	GetMinutes ()
void	GetClients (std::vector< Client * > &result) const
void	GetCorpClients (std::vector< Client * > &result, uint32 corpID) const
void	AddStation (uint32 stationID, StationItemRef itemRef)
void	RemoveStation (uint32 stationID)
StationItemRef	GetStationByID (uint32 stationID)
void	RegisterSID (int64 &sessionID)
void	RemoveSID (int64 sessionID)
std::string	GetAnomalyID ()
bool	GetTracking ()
void	SetTracking (bool set=false)
void	ResetStartTime ()
int64	GetStartTime ()
void	GetUpTime (std::string &time)
uint32	GetConnections ()
void	CorpNotify (uint32 corpID, uint8 bCastType, const char *notifyType, const char *idType, PyTuple *payload) const
void	Broadcast (const char *notifyType, const char *idType, PyTuple **payload) const
void	Broadcast (const PyAddress &dest, EVENotificationStream &noti) const
void	Multicast (const char *notifyType, const char *idType, PyTuple **in_payload, NotificationDestination target, uint32 target_id, bool seq=true)
void	Multicast (const char *notifyType, const char *idType, PyTuple **payload, const MulticastTarget &mcset, bool seq=true)
void	Multicast (const character_set &cset, const PyAddress &dest, EVENotificationStream &noti) const
void	Multicast (const character_set &cset, const char *notifyType, const char *idType, PyTuple **payload, bool seq=true) const
void	Unicast (uint32 charID, const char *notifyType, const char *idType, PyTuple **payload, bool seq=true)
void	AddTargMgr (SystemEntity *pSE, TargetManager *pTM)
void	DeleteTargMgr (SystemEntity *pSE)
void	AddProbe (uint32 probeID, ProbeSE *pSE)
void	RemoveProbe (uint32 probeID)
Public Member Functions inherited from Singleton< EntityList >
	Singleton ()
	Primary constructor. More...

Protected Attributes
PyServiceMgr *	m_services
Mutex	mMutex

Private Types
typedef std::map< Client *, int64 >	corpRole

Private Attributes
Timer	m_stampTimer
Timer	m_minuteTimer
Timer	m_targTimer
std::vector< Client * >	m_clients
std::map< uint32, Client * >	m_players
std::set< int64 >	m_sessions
std::map< uint32, SystemManager * >	m_systems
std::map< uint32, StationItemRef >	m_stations
std::vector< std::string >	m_anomIDs
std::map< uint32, Agent * >	m_agents
std::unordered_map < SystemEntity *, TargetManager * >	m_targMgrs
std::map< uint32, ProbeSE * >	m_probes
std::map< uint32, corpRole >	m_corpMembers
bool	m_shipTracking
uint32	m_npcs
uint32	m_stamp
uint32	m_minutes
uint32	m_connections
uint16	m_clientSeedID
int64	m_startTime

Additional Inherited Members
Static Public Member Functions inherited from Singleton< EntityList >
static EntityList &	get ()
Static Protected Attributes inherited from Singleton< EntityList >
static std::shared_ptr < EntityList >	mInstance

Detailed Description

Definition at line 63 of file EntityList.h.

Member Typedef Documentation

typedef std::set<uint32> EntityList::character_set

Definition at line 70 of file EntityList.h.

typedef std::map<Client*, int64> EntityList::corpRole

private

Definition at line 193 of file EntityList.h.

Constructor & Destructor Documentation

EntityList::EntityList

(

)

Definition at line 51 of file EntityList.cpp.

References m_agents, m_clients, m_corpMembers, m_players, m_probes, m_shipTracking, m_stations, m_systems, m_targMgrs, and sConfig.

: m_services( nullptr ),
m_targTimer(0, true),
m_stampTimer(0, true),
m_minuteTimer(0, true),
m_startTime(0),
m_npcs(0),
m_stamp(1000),   /* arbitrary.  start at 1k.  in seconds.  used for destiny and client counters */
m_minutes(0),
m_connections(0),
m_clientSeedID(0)
{
    m_agents.clear();
    m_probes.clear();
    m_clients.clear();
    m_players.clear();
    m_systems.clear();
    m_stations.clear();
    m_targMgrs.clear();
    m_corpMembers.clear();

    m_shipTracking = sConfig.debug.UseShipTracking;
}

EntityList::~EntityList

(

)

Definition at line 75 of file EntityList.cpp.

References sLog.

                        {
    sLog.Green("   ServerShutdown", " Complete.");
}

Member Function Documentation

void EntityList::Add

(

Client *

pClient

)

Definition at line 140 of file EntityList.cpp.

References m_clients, and m_connections.

                                      {
    ++m_connections;
    if (pClient != nullptr)
        m_clients.push_back(pClient);
}

void EntityList::AddNPC ( )

inline

Definition at line 82 of file EntityList.h.

References m_npcs.

{ ++m_npcs; }

void EntityList::AddPlayer

(

Client *

pClient

)

Definition at line 156 of file EntityList.cpp.

References Client::GetCharacterID(), Client::GetCharID(), Client::GetCorporationID(), Client::GetCorpRole(), IsPlayerCorp, Client::IsValidSession(), m_corpMembers, and m_players.

{
    if (pClient != nullptr)
        if (pClient->IsValidSession()) {
            m_players.emplace(pClient->GetCharacterID(), pClient);
            if (IsPlayerCorp(pClient->GetCorporationID())) {
                corpRole role;
                role.emplace(pClient, pClient->GetCorpRole());
                m_corpMembers.emplace(pClient->GetCorporationID(), role);
            }
        } else {
            m_players.emplace(pClient->GetCharID(), pClient);
            // make note about invalid session and failure to add player to corp roles.
            //   this is nbd if player is in npc corp or in player corp with no roles
        }
}

Here is the call graph for this function:

void EntityList::AddProbe ( uint32  probeID, ProbeSE *  pSE  )

inline

Definition at line 160 of file EntityList.h.

References m_probes.

{ m_probes[probeID] = pSE; }

void EntityList::AddStation	(	uint32	stationID,
		StationItemRef	itemRef
	)

Definition at line 302 of file EntityList.cpp.

References m_stations.

                                                                    {
    m_stations[stationID] = itemRef;
}

void EntityList::AddTargMgr ( SystemEntity *  pSE, TargetManager *  pTM  )

inline

Definition at line 154 of file EntityList.h.

References m_targMgrs.

                                                        { m_targMgrs.emplace(pSE, pTM); }

void EntityList::Broadcast	(	const char *	notifyType,
		const char *	idType,
		PyTuple **	payload
	)		const

Todo:

this shit needs removal, after new notification methods are completed

Definition at line 610 of file EntityList.cpp.

References EVENotificationStream::args, PyAddress::bcast_idtype, PyAddress::Broadcast, EVENotificationStream::remoteObject, PyAddress::service, and PyAddress::type.

                                                                                              {
    //build a little notification out of it.
    EVENotificationStream notify;
        notify.remoteObject = 1;
        notify.args = *payload;
    payload = nullptr;    //consumed

    //now sent it to the client
    PyAddress dest;
        dest.type = PyAddress::Broadcast;
        dest.service = notifyType;
        dest.bcast_idtype = idType;
    Broadcast(dest, notify);
}

void EntityList::Broadcast	(	const PyAddress &	dest,
		EVENotificationStream &	noti
	)		const

Definition at line 625 of file EntityList.cpp.

References m_players.

                                                                                   {
    for (auto cur : m_players)
        cur.second->SendNotification(dest, noti);
}

void EntityList::Close

(

)

Definition at line 108 of file EntityList.cpp.

References m_agents, m_clients, m_stations, m_systems, SafeDelete(), and sLog.

{
    if (m_clients.size() > 0) {
        sLog.Yellow("       EntityList", "Cleaning up %u clients, %u systems, %u agents, and %u stations", \
                    m_clients.size(), m_systems.size(), m_agents.size(), m_stations.size());
    } else {
        sLog.Green("       EntityList", "Cleaning up %u clients, %u systems, %u agents, and %u stations", \
                    m_clients.size(), m_systems.size(), m_agents.size(), m_stations.size());
    }

    for (auto cur : m_clients)
        SafeDelete(cur);

    for (auto cur : m_agents)
        SafeDelete(cur.second);

    for (auto cur : m_systems) {
        cur.second->UnloadSystem();
        SafeDelete(cur.second);
    }

    sLog.Warning("       EntityList", "Entity List has been closed." );
}

Here is the call graph for this function:

void EntityList::CorpNotify	(	uint32	corpID,
		uint8	bCastType,
		const char *	notifyType,
		const char *	idType,
		PyTuple *	payload
	)		const

Todo:

this works very well, and will be used as template for other notification methods

Definition at line 432 of file EntityList.cpp.

References Corp::Role::Accountant, Notify::Types::AllAnchoring, Notify::Types::AllMaintenanceBill, Notify::Types::AllStrucInvulnerable, Notify::Types::AllStructVulnerable, Notify::Types::AllWarDeclared, Notify::Types::AllWarInvalidated, Notify::Types::AllWarRetracted, Notify::Types::AllWarSurrender, Corp::Role::Auditor, Notify::Types::BillOutOfMoney, Notify::Types::BillPaidChar, Notify::Types::BillPaidCorpAll, Notify::Types::CharBill, Notify::Types::CharLeftCorp, Notify::Types::CharMedal, Notify::Types::ContactAdd, Notify::Types::ContactEdit, Notify::Types::ContainerPassword, Notify::Types::CorpAllBill, Notify::Types::CorpAppAccept, Notify::Types::CorpAppNew, Notify::Types::CorpAppReject, Notify::Types::CorpDividend, Notify::Types::CorpKicked, Notify::Types::CorpLiquidation, Notify::Types::CorpNewCEO, Notify::Types::CorpNews, Notify::Types::CorpOfficeExpiration, Notify::Types::CorpStructLost, Notify::Types::CorpTaxChange, Notify::Types::CorpVote, Notify::Types::CorpVoteCEORevoked, Notify::Types::CorpWarDeclared, Notify::Types::CorpWarFightingLegal, Notify::Types::CorpWarInvalidated, Notify::Types::CorpWarRetracted, Notify::Types::CorpWarSurrender, Notify::Types::FactoryJob, Corp::Role::FactoryManager, Notify::Types::FacWarCorpJoinRequest, Notify::Types::FacWarCorpJoinWithdraw, Notify::Types::FacWarCorpLeaveRequest, Notify::Types::FacWarCorpLeaveWithdraw, Notify::Types::FWAllianceKick, Notify::Types::FWAllianceWarning, Notify::Types::FWCharKick, Notify::Types::FWCharRankGain, Notify::Types::FWCharRankLoss, Notify::Types::FWCharWarning, Notify::Types::FWCorpJoin, Notify::Types::FWCorpKick, Notify::Types::FWCorpLeave, Notify::Types::FWCorpWarning, CorporationDB::HasShares(), IsNPCCorp, Notify::Types::ItemUpdateStation, Notify::Types::ItemUpdateSystem, Corp::Role::JuniorAccountant, m_corpMembers, Notify::Types::MarketOrder, Notify::Types::OrbitalAttacked, Notify::Types::OrbitalReinforced, Notify::Types::OwnershipTransferred, Corp::Role::PersonnelManager, PyDecRef, PyIncRef, PySafeDecRef, Notify::Types::Reimbursement, Notify::Types::SovAllBillLate, Notify::Types::SovAllClaimAquired, Notify::Types::SovAllClaimFail, Notify::Types::SovAllClaimLost, Notify::Types::SovCorpBillLate, Notify::Types::SovCorpClaimAquired, Notify::Types::SovCorpClaimFail, Notify::Types::SovCorpClaimLost, Notify::Types::SovDisruptor, Notify::Types::SovereigntyIHDamage, Notify::Types::SovereigntySBUDamage, Notify::Types::SovereigntyTCUDamage, Notify::Types::StationAggression1, Notify::Types::StationAggression2, Notify::Types::StationConquer, Notify::Types::StationStateChange, Notify::Types::TowerAlert, Notify::Types::TowerResourceAlert, Corp::Role::Trader, Notify::Types::TransactionReversal, and Notify::Types::WalletChange.

{
    // make sure this is player corp (which it really should be, but just in case....)
    if (IsNPCCorp(corpID))
        return;
    std::map<uint32, Client*> cMap;
    std::map<uint32, corpRole>::const_iterator cItr = m_corpMembers.find(corpID);
    if (cItr == m_corpMembers.end()) {
        PySafeDecRef(payload);
        return; // no corp members online now.  nothing to do here.
    }

    // determine who in corp needs to be notified
    using namespace Notify::Types;
    //using namespace Corp::Role;
    // auto doesnt work here...dunno why yet.
    corpRole::const_iterator itr = cItr->second.begin(), end = cItr->second.end();
    switch (bCastType) {
        case CorpNews:
        case CorpNewCEO:
        case CharLeftCorp: {
            // all members?
            while (itr != end) {
                cMap.emplace(itr->first->GetCharacterID(), itr->first);
                ++itr;
            }
        } break;
        case CorpAppNew:
        case CorpAppReject:
        case CorpAppAccept: {
            // who else wants/needs this?
            // PersonnelManager is only role that can view corp applications
            while (itr != end) {
                //if ((itr->second & Corp::Role::Director) == Corp::Role::Director)
                //    cMap.insert(std::make_pair(std::make_pair(itr->first->GetCharacterID(), itr->first)));
                if ((itr->second & Corp::Role::PersonnelManager) == Corp::Role::PersonnelManager)
                    cMap.emplace(itr->first->GetCharacterID(), itr->first);
                ++itr;
            }
        } break;
        case CorpVote: {
            // any member that can vote (has shares)
            //  damn...dunno if i wanna do this one like this....hit db every loop here??  fukin nuts!
            // this is another vote for putting "corp shares" in character.corpData
            //    well, then we'd have to hit db for offine chars.....omg
            CorporationDB mdb;
            while (itr != end) {
                // if (itr->first->GetChar()->HasShares())  // not written, no underlying code yet
                if (mdb.HasShares(itr->first->GetCharacterID(), corpID))
                    cMap.emplace(itr->first->GetCharacterID(), itr->first);
                ++itr;
            }
        } break;

        // unused yet.  (not coded or not understood  ...mostly the latter at this point in corp code)
        case CharMedal:
        case AllMaintenanceBill:
        case AllWarDeclared:
        case AllWarSurrender:
        case AllWarRetracted:
        case AllWarInvalidated:
        case CharBill:
        case CorpAllBill:
        case BillOutOfMoney:
        case BillPaidChar:
        case BillPaidCorpAll:
        case CorpTaxChange:
        case CorpDividend:
        case CorpVoteCEORevoked:
        case CorpWarDeclared:
        case CorpWarFightingLegal:
        case CorpWarSurrender:
        case CorpWarRetracted:
        case CorpWarInvalidated:
        case ContainerPassword:
        case SovAllClaimFail:
        case SovCorpClaimFail:
        case SovAllBillLate:
        case SovCorpBillLate:
        case SovAllClaimLost:
        case SovCorpClaimLost:
        case SovAllClaimAquired:
        case SovCorpClaimAquired:
        case AllAnchoring:
        case AllStructVulnerable:
        case AllStrucInvulnerable:
        case SovDisruptor:
        case CorpStructLost:
        case CorpOfficeExpiration:
        case FWCorpJoin:
        case FWCorpLeave:
        case FWCorpKick:
        case FWCharKick:
        case FWCorpWarning:
        case FWCharWarning:
        case FWCharRankLoss:
        case FWCharRankGain:
        case FWAllianceWarning:
        case FWAllianceKick:
        case TransactionReversal:
        case Reimbursement:
        case TowerAlert:
        case TowerResourceAlert:
        case StationAggression1:
        case StationStateChange:
        case StationConquer:
        case StationAggression2:
        case FacWarCorpJoinRequest:
        case FacWarCorpLeaveRequest:
        case FacWarCorpJoinWithdraw:
        case FacWarCorpLeaveWithdraw:
        case CorpLiquidation:
        case SovereigntyTCUDamage:
        case SovereigntySBUDamage:
        case SovereigntyIHDamage:
        case ContactAdd:
        case ContactEdit:
        case CorpKicked:
        case OrbitalAttacked:
        case OrbitalReinforced:
        case OwnershipTransferred:
            break;

        // internal corp notifications
        case FactoryJob: {      // factory job completion added to calendar
            // who else wants/needs this?
            //  lets start with factory manager, and may have to add later
            while (itr != end) {
                if ((itr->second & Corp::Role::FactoryManager) == Corp::Role::FactoryManager)
                    cMap.emplace(itr->first->GetCharacterID(), itr->first);
                ++itr;
            }
        } break;
        case MarketOrder: {
            // who else wants/needs this?
            //  lets start with traders, and may have to add later
            while (itr != end) {
                if ((itr->second & Corp::Role::Trader) == Corp::Role::Trader)
                    cMap.emplace(itr->first->GetCharacterID(), itr->first);
                ++itr;
            }
        } break;
        case WalletChange: {
            while (itr != end) {
                if ((itr->second & Corp::Role::Accountant) == Corp::Role::Accountant)
                    cMap.emplace(itr->first->GetCharacterID(), itr->first);
                if ((itr->second & Corp::Role::Auditor) == Corp::Role::Auditor)
                    cMap.emplace(itr->first->GetCharacterID(), itr->first);
                // this may need to check if player has access to division changed - will require a LOT more code
                if ((itr->second & Corp::Role::JuniorAccountant) == Corp::Role::JuniorAccountant)
                    cMap.emplace(itr->first->GetCharacterID(), itr->first);
                ++itr;
            }
        } break;
        case ItemUpdateStation: {
            // all members?
            while (itr != end) {
                cMap.emplace(itr->first->GetCharacterID(), itr->first);
                ++itr;
            }
        } break;
        case ItemUpdateSystem: {
            // all members?
            while (itr != end) {
                cMap.emplace(itr->first->GetCharacterID(), itr->first);
                ++itr;
            }
        } break;
    }

    for (auto cur : cMap) {
        PyIncRef(payload);
        cur.second->SendNotification( notifyType, idType, payload, false );   // are any of these sequenced?
    }

    PyDecRef(payload);
}

Here is the call graph for this function:

void EntityList::DeleteTargMgr ( SystemEntity *  pSE )

inline

Definition at line 157 of file EntityList.h.

References m_targMgrs.

{ m_targMgrs.erase(pSE); }

Client * EntityList::FindClientByCharID

(

uint32

charID

)

const

Definition at line 363 of file EntityList.cpp.

References m_players.

Referenced by Unicast().

{
    std::map<uint32, Client*>::const_iterator itr = m_players.find(charID);
    if (itr != m_players.end())
        return itr->second;
    return nullptr;
}

Here is the caller graph for this function:

Client * EntityList::FindClientByName

(

const char *

name

)

const

Todo:

Note

NOTE: TODO: HACK: the Find* methods below can get very expensive for many players

Definition at line 766 of file EntityList.cpp.

References RefPtr< X >::get(), m_players, and InventoryItem::name().

                                                           {
    for (auto cur : m_players) {
        CharacterRef cRef = cur.second->GetChar();
        if (cRef.get() != nullptr)
            if (strcmp(cRef->name(), name) == 0)
                return cur.second;
    }
    return nullptr;
}

Here is the call graph for this function:

SystemManager * EntityList::FindOrBootSystem

(

uint32

systemID

)

Definition at line 279 of file EntityList.cpp.

References _log, m_services, m_systems, SafeDelete(), and sDataMgr.

Referenced by Multicast().

                                                           {
    if (!sDataMgr.IsSolarSystem(systemID)) {
        _log(SERVER__INIT_ERR, "BootSystem() called with invalid systemID (%u)", systemID);
        return nullptr;
    }

    std::map<uint32, SystemManager*>::iterator itr = m_systems.find(systemID);
    if (itr != m_systems.end())
        return itr->second;

    SystemManager* pSM = new SystemManager(systemID, *m_services);
    if ((pSM == nullptr) or (!pSM->BootSystem())) {
        _log(SERVER__INIT_ERR, "BootSystem() - Booting system %u failed", systemID);
        SafeDelete(pSM);
        return nullptr;
    }

    _log(SERVER__INIT, "BootSystem() - Booted system %u", systemID);
    m_systems[systemID] = pSM;
    return pSM;
}

Here is the call graph for this function:

Here is the caller graph for this function:

Agent * EntityList::GetAgent

(

uint32

agentID

)

Definition at line 310 of file EntityList.cpp.

References m_agents.

                                          {
    std::map<uint32, Agent*>::iterator res = m_agents.find(agentID);
    if (res != m_agents.end())
        return res->second;

    Agent* pAgent = new Agent(agentID);
    if (!pAgent->Load()) {
        delete pAgent;
        return nullptr;
    }
    m_agents[agentID] = pAgent;
    return pAgent;
}

std::string EntityList::GetAnomalyID

(

)

Definition at line 378 of file EntityList.cpp.

References alphaList, MakeRandomInt(), and str2().

{
    // these should be totally unique.  design a way to enforce this
    std::string str1 = "", str2 = "";
    for (uint8 i = 0; i < 3; ++i) {
        str1 += alphaList[MakeRandomInt(0,25)];    //rand() % sizeof(alphaList) - 1
        str2 += std::to_string(MakeRandomInt(0,9));
    }

    std::string res = str1;
    res += "-";
    res += str2;
    // not sure if we need to keep track of these IDs...
    //m_anomIDs.push_back(res);
    return res;
}

Here is the call graph for this function:

uint32 EntityList::GetClientCount ( ) const

inline

Definition at line 106 of file EntityList.h.

References m_clients.

{ return m_clients.size(); }

void EntityList::GetClients

(

std::vector< Client * > &

result

)

const

Definition at line 324 of file EntityList.cpp.

References m_players.

                                                            {
    for (auto cur : m_players)
        result.push_back(cur.second);
}

uint16 EntityList::GetClientSeed ( )

inline

Definition at line 110 of file EntityList.h.

References m_clientSeedID.

{ return ++m_clientSeedID; }

uint32 EntityList::GetConnections ( )

inline

Definition at line 135 of file EntityList.h.

References m_connections.

{ return m_connections; }

void EntityList::GetCorpClients	(	std::vector< Client * > &	result,
		uint32	corpID
	)		const

Definition at line 329 of file EntityList.cpp.

References m_corpMembers.

                                                                               {
    std::map<uint32, corpRole>::const_iterator cItr = m_corpMembers.find(corpID);
    if (cItr == m_corpMembers.end())
        return;

    corpRole::const_iterator itr = cItr->second.begin(), end = cItr->second.end();
    while (itr != end) {
        if (itr->first != nullptr)
            result.push_back(itr->first);
        ++itr;
    }
}

uint32 EntityList::GetMinutes ( )

inline

Definition at line 114 of file EntityList.h.

References m_minutes.

{ return m_minutes; }

uint32 EntityList::GetNPCCount ( )

inline

Definition at line 105 of file EntityList.h.

References m_npcs.

{ return m_npcs; }

uint32 EntityList::GetPlayerCount ( ) const

inline

Definition at line 107 of file EntityList.h.

References m_players.

{ return m_players.size(); }

uint32 EntityList::GetStamp ( )

inline

Definition at line 113 of file EntityList.h.

References m_stamp.

{ return m_stamp; }

int64 EntityList::GetStartTime ( )

inline

Definition at line 133 of file EntityList.h.

References m_startTime.

{ return m_startTime; }

StationItemRef EntityList::GetStationByID

(

uint32

stationID

)

Definition at line 371 of file EntityList.cpp.

References m_stations.

                                                          {
    std::map<uint32, StationItemRef>::iterator res = m_stations.find(stationID);
    if (res != m_stations.end())
        return res->second;
    return StationItemRef(nullptr);
}

uint32 EntityList::GetStationCount ( ) const

inline

Definition at line 109 of file EntityList.h.

References m_stations.

{ return m_stations.size(); }

void EntityList::GetStationGuestList	(	uint32	stationID,
		std::vector< Client * > &	result
	)		const

Definition at line 343 of file EntityList.cpp.

References m_stations.

Referenced by Multicast().

                                                                                       {
    std::map<uint32, StationItemRef>::const_iterator itr = m_stations.find(stationID);
    if (itr != m_stations.end())
        itr->second->GetGuestList(result);
}

Here is the caller graph for this function:

uint32 EntityList::GetSystemCount ( ) const

inline

Definition at line 108 of file EntityList.h.

References m_systems.

{ return m_systems.size(); }

bool EntityList::GetTracking ( )

inline

Definition at line 129 of file EntityList.h.

References m_shipTracking.

{ return m_shipTracking; }

void EntityList::GetUpTime

(

std::string &

time

)

Definition at line 395 of file EntityList.cpp.

References m_stamp, and minutes.

{
    float seconds = m_stamp - 1000;
    float minutes = seconds/60;
    float hours = minutes/60;
    float days = hours/24;
    float weeks = days/7;
    float months = days/30;

    int s(fmod(seconds, 60));
    int m(fmod(minutes, 60));
    int h(fmod(hours, 24));
    int d(fmod(days, 7));
    int w(fmod(weeks, 4));
    int M(fmod(months, 12));

    std::ostringstream uptime;
    if (M) {
        uptime << M << "M" << w << "w" << d << "d" << h << "h" << m << "m" << s << "s";
    } else if (w) {
        uptime << w << "w" << d << "d" << h << "h" << m << "m" << s << "s";
    } else if (d) {
        uptime << d << "d" << h << "h" << m << "m" << s << "s";
    } else if (h) {
        uptime << h << "h" << m << "m" << s << "s";
    } else if (m) {
        uptime << m << "m" << s << "s";
    } else {
        uptime << s << "s";
    }

    //std::shared_ptr<const char*> ret = uptime.str().c_str();
    time = uptime.str();
}

bool EntityList::HasClients ( )

inline

Definition at line 90 of file EntityList.h.

References m_players.

{ return !m_players.empty(); }

void EntityList::Initialize

(

)

Definition at line 79 of file EntityList.cpp.

References GetFileTimeNow(), is_log_enabled, m_clientSeedID, m_minuteTimer, m_stampTimer, m_startTime, m_targTimer, sConfig, ServiceDB::SetClientSeed(), sLog, and Timer::Start().

                            {
    m_startTime = GetFileTimeNow();

    /* start the timers */
    m_targTimer.Start(250);     // testing targeting and scan probes at 4/sec
    m_stampTimer.Start(1000);   // 1hz tic timer
    m_minuteTimer.Start(60000); // does this need to be accurate?

    m_clientSeedID = ServiceDB::SetClientSeed();
    sLog.Green( "       ServerInit", "ClientSeed Initialized." );

    if (is_log_enabled(SERVER__STACKTRACE))
        sConfig.debug.StackTrace = true;

    sLog.Blue("       EntityList", "Entity Manager Initialized.");
}

Here is the call graph for this function:

bool EntityList::IsOnline

(

uint32

charID

)

Definition at line 349 of file EntityList.cpp.

References m_players.

{
    if (m_players.find(charID) == m_players.end())
        return false;
    return true;
}

void EntityList::Multicast	(	const char *	notifyType,
		const char *	idType,
		PyTuple **	in_payload,
		NotificationDestination	target,
		uint32	target_id,
		bool	seq = true
	)

Definition at line 640 of file EntityList.cpp.

References FindOrBootSystem(), SystemManager::GetClientList(), GetStationGuestList(), m_corpMembers, NOTIF_DEST__CORPORATION, NOTIF_DEST__LOCATION, PyDecRef, PyIncRef, sDataMgr, sLog, and EvE::traceStack().

{
    PyTuple* payload = *in_payload;
    in_payload = nullptr;

    std::vector<Client*> cVec;
    cVec.clear();
    switch( target ) {
        case NOTIF_DEST__LOCATION: {
            if (sDataMgr.IsStation(targID)) {
                GetStationGuestList(targID, cVec);
            } else if (sDataMgr.IsSolarSystem(targID)) {
                SystemManager* pSysMgr = FindOrBootSystem(targID);
                if (pSysMgr == nullptr)
                    break;
                pSysMgr->GetClientList(cVec);
            } else {
                sLog.Error("EntityList::Multicast 1", "DEST__LOCATION - location %u is neither station nor system", targID);
                EvE::traceStack();
            }
        } break;
        case NOTIF_DEST__CORPORATION: {
            std::map<uint32, corpRole>::const_iterator cItr = m_corpMembers.find(targID);
            if (cItr == m_corpMembers.end())
                break;
            corpRole::const_iterator itr = cItr->second.begin();
            while (itr != cItr->second.end()) {
                cVec.push_back(itr->first);
                ++itr;
            }
        } break;
    };

    for (auto cur : cVec) {
        PyIncRef(payload);
        cur->SendNotification( notifyType, idType, &payload, seq );
    }

    PyDecRef( payload );
}

Here is the call graph for this function:

void EntityList::Multicast	(	const char *	notifyType,
		const char *	idType,
		PyTuple **	payload,
		const MulticastTarget &	mcset,
		bool	seq = true
	)

Definition at line 682 of file EntityList.cpp.

References MulticastTarget::characters, MulticastTarget::corporations, FindOrBootSystem(), SystemManager::GetClientList(), GetStationGuestList(), MulticastTarget::locations, m_corpMembers, m_players, PyDecRef, PyIncRef, sDataMgr, sLog, and EvE::traceStack().

{
    // consume payload
    PyTuple* payload = *in_payload;
    in_payload = nullptr;

    if (!mcset.characters.empty())
        for (auto cur : mcset.characters) {
            std::map<uint32, Client*>::iterator itr = m_players.find(cur);
            if ( itr != m_players.end()) {
                PyIncRef(payload);
                itr->second->SendNotification( notifyType, idType, &payload, seq );
            }
        }

    if (!mcset.locations.empty()) {
        SystemManager* pSysMgr(nullptr);
        std::vector<Client*> cVec;
        cVec.clear();
        for (auto cur : mcset.locations) {
            if (sDataMgr.IsStation(cur)) {
                GetStationGuestList(cur, cVec);
            } else if (sDataMgr.IsSolarSystem(cur)) {
                pSysMgr = FindOrBootSystem(cur);
                if (pSysMgr == nullptr)
                    continue;
                pSysMgr->GetClientList(cVec);
            } else {
                sLog.Error("EntityList::Multicast 2", "location %u is neither station nor system", cur);
                EvE::traceStack();
            }
        }
        for (auto cur : cVec) {
            PyIncRef(payload);
            cur->SendNotification( notifyType, idType, &payload, seq );
        }
    }

    // this will need list of interested parties from corp.  update this call to use CorpNotify() where possible.
    if (!mcset.corporations.empty()) {
        sLog.Error("EntityList::Multicast 2", "Corporation MulticastTarget called.");
        EvE::traceStack();
        for (auto cur : mcset.corporations) {
            std::map<uint32, corpRole>::const_iterator cItr = m_corpMembers.find(cur);
            if (cItr == m_corpMembers.end())
                continue;
            corpRole::const_iterator itr = cItr->second.begin();
            while (itr != cItr->second.end()) {
                PyIncRef(payload);
                itr->first->SendNotification( notifyType, idType, &payload, seq );
                ++itr;
            }
        }
    }

    PyDecRef( payload );
}

Here is the call graph for this function:

void EntityList::Multicast	(	const character_set &	cset,
		const PyAddress &	dest,
		EVENotificationStream &	noti
	)		const

Definition at line 630 of file EntityList.cpp.

References m_players.

                                                                                                              {
    std::map<uint32, Client*>::const_iterator itr = m_players.begin();
    for (auto cur : cset) {
        itr = m_players.find(cur);
        if (itr != m_players.end())
            itr->second->SendNotification(dest, noti);
    }
}

void EntityList::Multicast	(	const character_set &	cset,
		const char *	notifyType,
		const char *	idType,
		PyTuple **	payload,
		bool	seq = true
	)		const

Definition at line 740 of file EntityList.cpp.

References m_players, PyDecRef, and PyIncRef.

{
    // consume payload
    PyTuple* payload = *in_payload;
    in_payload = nullptr;

    std::map<uint32, Client*>::const_iterator itr = m_players.begin();
    for (auto cur : cset) {
        itr = m_players.find(cur);
        if (itr != m_players.end()) {
            PyIncRef(payload);
            itr->second->SendNotification(notifyType, idType, &payload, seq);
        }
    }
    PyDecRef( payload );
}

void EntityList::Process

(

)

Todo:

test for adding OpenMP here to enable MP per system.

Definition at line 188 of file EntityList.cpp.

References Timer::Check(), Profile::entityS, GetTimeUSeconds(), m_clients, m_minutes, m_minuteTimer, m_players, m_probes, m_stamp, m_stampTimer, m_systems, m_targMgrs, m_targTimer, MapDB::ManipulateTimeData(), SafeDelete(), sBubbleMgr, sCivMgr, sConfig, sConsole, sLog, sMissionDataMgr, sMktMgr, sProfiler, and sWHMgr.

                         {
    Client* pClient(nullptr);
    std::vector<Client*>::iterator citr = m_clients.begin();
    while (citr != m_clients.end()) {
        if ((*citr)->ProcessNet()) {
            ++citr;
        } else {
            pClient = *citr;
            citr = m_clients.erase(citr);
            SafeDelete(pClient);
        }
    }

    if (m_targTimer.Check()) {
        std::unordered_map<SystemEntity*, TargetManager*>::iterator titr = m_targMgrs.begin();
        while (titr != m_targMgrs.end()) {
            if (titr->second->Process()) {
                ++titr;
            } else {
                titr = m_targMgrs.erase(titr);
            }
        }
        std::map<uint32, ProbeSE*>::iterator pitr = m_probes.begin();
        while (pitr != m_probes.end()) {
            if (pitr->second->ProcessTic()) {
                ++pitr;
            } else {
                pitr = m_probes.erase(pitr);
            }
        }
    }

    /* check for 1Hz timer tic */
    if (m_stampTimer.Check()) {
        double profileStartTime = GetTimeUSeconds();

        ++m_stamp;

        for (auto cur : m_players)
            if (cur.second->IsValidSession())   // verify client is constructed before calling ProcessClient() on it
                cur.second->ProcessClient();

    // this wont work....possibility of removing systems, therefore invalidating the iterator.
    // bad things can happen if this is running parallel on MP
    //#pragma omp parallel  // starts a new team
        std::map<uint32, SystemManager*>::iterator itr = m_systems.begin();
        while (itr != m_systems.end()) {
            if (itr->second == nullptr) { /* this shouldnt happen.  log error to make note */
                sLog.Error(" EntityList::Proc", "Deleting System %u", itr->first);
                itr = m_systems.erase(itr);
                continue;
            } else if (!itr->second->ProcessTic()) {    /* Process each loaded system */
                itr->second->UnloadSystem();
                SafeDelete(itr->second);
                itr = m_systems.erase(itr);
                continue;
            }
            ++itr;
        }

        // these need 1Hz tics
        sCivMgr.Process();
        sBubbleMgr.Process();

        // these minute tics do not need to be precise
        if (m_minuteTimer.Check()) {
            ++m_minutes;
            sMissionDataMgr.Process();  // 1m

            if (m_minutes % 5 == 0) { // ~5m
                sWHMgr.Process();
                // write something to tic corps vote cases.
                for (auto cur : m_systems)
                    cur.second->UpdateData();   // update active system timers and dynamic data every 5m
            }
            if (m_minutes % 15 == 0) { // ~15m
                //sMktBotMgr.Process();  // 15m to 30m
                sConsole.UpdateStatus();
            }
            if (m_minutes % 60 == 0) { // ~1h
                MapDB::ManipulateTimeData();
                sMktMgr.Process();  // not used - does nothing at this time
            }
        }

        if (sConfig.debug.UseProfiling)
            sProfiler.AddTime(Profile::entityS, GetTimeUSeconds() - profileStartTime);
    }
}

Here is the call graph for this function:

PyRep * EntityList::PyIsOnline

(

uint32

charID

)

Definition at line 356 of file EntityList.cpp.

References m_players, and PyStatic.

{
    if (m_players.find(charID) == m_players.end())
        return PyStatic.NewFalse();
    return PyStatic.NewTrue();
}

void EntityList::RegisterSID

(

int64 &

sessionID

)

Todo:

this needs more work. hacked for now...

Definition at line 777 of file EntityList.cpp.

References m_sessions.

                                             {
    /*  this whole method is just made up...eventually it will return a unique long long */
    /* max for int64 = 9223372036854775807 */
    std::set<int64>::iterator cur = m_sessions.find(sessionID);
    std::pair<std::_Rb_tree_const_iterator<int64>, bool > test;
    if (cur == m_sessions.end())
        test = m_sessions.insert(sessionID);
    if (test.second)
        return;
}

void EntityList::Remove

(

Client *

pClient

)

Definition at line 146 of file EntityList.cpp.

References m_clients.

                                       {
    /* note:  will get expensive for many clients  */
    std::vector<Client*>::iterator itr = m_clients.begin();
    for (; itr != m_clients.end(); ++itr)
        if ((*itr) == pClient) {
            m_clients.erase(itr);
            return;
        }
}

void EntityList::RemoveNPC ( )

inline

Definition at line 83 of file EntityList.h.

References m_npcs.

{ --m_npcs; }

void EntityList::RemovePlayer

(

Client *

pClient

)

Definition at line 173 of file EntityList.cpp.

References Client::GetCharacterID(), Client::GetCharID(), Client::GetCorporationID(), Client::IsValidSession(), m_corpMembers, and m_players.

{
    if (pClient != nullptr)
        if (pClient->IsValidSession()) {
            m_players.erase(pClient->GetCharacterID());
            // remove player from corp map, if applicable
            std::map<uint32, corpRole>::iterator itr = m_corpMembers.find(pClient->GetCorporationID());
            if (itr != m_corpMembers.end())
                itr->second.erase(pClient);
        } else {
            m_players.erase(pClient->GetCharID());
        }
}

Here is the call graph for this function:

void EntityList::RemoveProbe ( uint32  probeID )

inline

Definition at line 162 of file EntityList.h.

References m_probes.

{ m_probes.erase(probeID); }

void EntityList::RemoveSID

(

int64

sessionID

)

Definition at line 788 of file EntityList.cpp.

References m_sessions.

                                             {
    m_sessions.erase(sessionID);
}

void EntityList::RemoveStation

(

uint32

stationID

)

Definition at line 306 of file EntityList.cpp.

References m_stations.

                                               {
    m_stations.erase(stationID);
}

void EntityList::ResetStartTime ( )

inline

Definition at line 132 of file EntityList.h.

References GetFileTimeNow(), and m_startTime.

{ m_startTime = GetFileTimeNow(); }

Here is the call graph for this function:

void EntityList::SetService ( PyServiceMgr *  svc )

inline

Definition at line 84 of file EntityList.h.

References m_services.

Referenced by PyServiceMgr::PyServiceMgr().

{ m_services = svc; }

Here is the caller graph for this function:

void EntityList::SetTracking ( bool  set = false )

inline

Definition at line 130 of file EntityList.h.

References m_shipTracking.

{ m_shipTracking = set; }

void EntityList::Shutdown

(

)

Todo:

finish this.... halt server called from admin client. (gm command ingame) call d'tor on all connected clients server run loop will exit after control is returned from this function, which will clean up remaining items.

Definition at line 96 of file EntityList.cpp.

References m_clients, and SafeDelete().

                          {
    for (auto cur : m_clients)
        SafeDelete(cur);

    m_clients.clear();
}

Here is the call graph for this function:

void EntityList::Unicast	(	uint32	charID,
		const char *	notifyType,
		const char *	idType,
		PyTuple **	payload,
		bool	seq = true
	)

Definition at line 757 of file EntityList.cpp.

References FindClientByCharID(), and Client::SendNotification().

                                                                                                               {
    Client* pClient = FindClientByCharID(charID);
    if (pClient != nullptr)
        pClient->SendNotification( notifyType, idType, payload, seq );
}

Here is the call graph for this function:

Member Data Documentation

std::map<uint32, Agent*> EntityList::m_agents

private

Definition at line 185 of file EntityList.h.

Referenced by Close(), EntityList(), and GetAgent().

std::vector<std::string> EntityList::m_anomIDs

private

Definition at line 184 of file EntityList.h.

std::vector<Client*> EntityList::m_clients

private

Definition at line 177 of file EntityList.h.

Referenced by Add(), Close(), EntityList(), GetClientCount(), Process(), Remove(), and Shutdown().

uint16 EntityList::m_clientSeedID

private

Definition at line 202 of file EntityList.h.

Referenced by GetClientSeed(), and Initialize().

uint32 EntityList::m_connections

private

Definition at line 201 of file EntityList.h.

Referenced by Add(), and GetConnections().

std::map<uint32, corpRole> EntityList::m_corpMembers

private

Definition at line 194 of file EntityList.h.

Referenced by AddPlayer(), CorpNotify(), EntityList(), GetCorpClients(), Multicast(), and RemovePlayer().

uint32 EntityList::m_minutes

private

Definition at line 200 of file EntityList.h.

Referenced by GetMinutes(), and Process().

Timer EntityList::m_minuteTimer

private

Definition at line 172 of file EntityList.h.

Referenced by Initialize(), and Process().

uint32 EntityList::m_npcs

private

Definition at line 198 of file EntityList.h.

Referenced by AddNPC(), GetNPCCount(), and RemoveNPC().

std::map<uint32, Client*> EntityList::m_players

private

Definition at line 180 of file EntityList.h.

Referenced by AddPlayer(), Broadcast(), EntityList(), FindClientByCharID(), FindClientByName(), GetClients(), GetPlayerCount(), HasClients(), IsOnline(), Multicast(), Process(), PyIsOnline(), and RemovePlayer().

std::map<uint32, ProbeSE*> EntityList::m_probes

private

Definition at line 190 of file EntityList.h.

Referenced by AddProbe(), EntityList(), Process(), and RemoveProbe().

PyServiceMgr* EntityList::m_services

protected

Definition at line 166 of file EntityList.h.

Referenced by FindOrBootSystem(), and SetService().

std::set<int64> EntityList::m_sessions

private

Definition at line 181 of file EntityList.h.

Referenced by RegisterSID(), and RemoveSID().

bool EntityList::m_shipTracking

private

Definition at line 196 of file EntityList.h.

Referenced by EntityList(), GetTracking(), and SetTracking().

uint32 EntityList::m_stamp

private

Definition at line 199 of file EntityList.h.

Referenced by GetStamp(), GetUpTime(), and Process().

Timer EntityList::m_stampTimer

private

Definition at line 171 of file EntityList.h.

Referenced by Initialize(), and Process().

int64 EntityList::m_startTime

private

Definition at line 204 of file EntityList.h.

Referenced by GetStartTime(), Initialize(), and ResetStartTime().

std::map<uint32, StationItemRef> EntityList::m_stations

private

Definition at line 183 of file EntityList.h.

Referenced by AddStation(), Close(), EntityList(), GetStationByID(), GetStationCount(), GetStationGuestList(), and RemoveStation().

std::map<uint32, SystemManager*> EntityList::m_systems

private

Definition at line 182 of file EntityList.h.

Referenced by Close(), EntityList(), FindOrBootSystem(), GetSystemCount(), and Process().

std::unordered_map<SystemEntity*, TargetManager*> EntityList::m_targMgrs

private

Definition at line 188 of file EntityList.h.

Referenced by AddTargMgr(), DeleteTargMgr(), EntityList(), and Process().

Timer EntityList::m_targTimer

private

Definition at line 173 of file EntityList.h.

Referenced by Initialize(), and Process().

Mutex EntityList::mMutex

protected

Definition at line 168 of file EntityList.h.

---

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

• /backups/local/src/eve/EvEmu_Crucible/src/eve-server/EntityList.h
• /backups/local/src/eve/EvEmu_Crucible/src/eve-server/EntityList.cpp