OverSim
PubSubMMOG Member List

This is the complete list of members for PubSubMMOG, including all inherited members.

allowOldMoveMessagesPubSubMMOGprotected
AOIWidthPubSubMMOGprotected
backupSubspacesPubSubMMOGprotected
BaseOverlay()BaseOverlay
BaseRpc()BaseRpc
bindAndListenTcp(int port)BaseTcpSupportprotected
bindToPort(int port)BaseOverlayprotected
BOOTSTRAP enum valueBaseOverlay
bootstrapListBaseOverlayprotected
BSET enum valueBaseOverlay
bytesAppDataForwardedBaseOverlayprotected
bytesAppLookupForwardedBaseOverlayprotected
bytesDroppedBaseOverlayprotected
bytesFailedNodeResponseSentBaseOverlayprotected
bytesFailedNodeSentBaseOverlayprotected
bytesFindNodeResponseSentBaseOverlayprotected
bytesFindNodeSentBaseOverlayprotected
bytesMaintenanceForwardedBaseOverlayprotected
bytesPingResponseSentBaseRpcprotected
bytesPingSentBaseRpcprotected
callDeliver(BaseOverlayMessage *msg, const OverlayKey &destKey)BaseOverlayprotected
callForward(const OverlayKey &key, BaseRouteMessage *msg, const NodeHandle &nextHopNode)BaseOverlayprotected
callUpdate(const NodeHandle &node, bool joined)BaseOverlayprotected
cancelAllRpcs()BaseRpcprotected
cancelRpcMessage(uint32_t nonce)BaseRpcprotected
childPingTimerPubSubMMOGprotected
closeTcpConnection(TransportAddress address)BaseTcpSupportprotected
collectPerHopDelayBaseOverlayprotected
CONNECTION_RESET enum valueBaseTcpSupport
CONNECTION_SUCC_ClOSED enum valueBaseTcpSupport
countFailedNodeCall(const FailedNodeCall *call)BaseOverlayprotected
countFindNodeCall(const FindNodeCall *call)BaseOverlayprotected
createLookup(RoutingType routingType=DEFAULT_ROUTING, const BaseOverlayMessage *msg=NULL, const cPacket *findNodeExt=NULL, bool appLookup=false)BaseOverlayprotectedvirtual
creationTimeBaseOverlayprotected
cryptoModuleBaseRpcprotected
currentRegionXPubSubMMOGprotected
currentRegionYPubSubMMOGprotected
debugOutputBaseOverlayprotected
defaultRoutingTypeBaseOverlayprotected
delayVectorBaseOverlayprotected
deleteOverlayNeighborArrow(const NodeHandle &neighbor)TopologyVis
DISCOVERY enum valueBaseOverlay
distance(const OverlayKey &x, const OverlayKey &y, bool useAlternative=false) const BaseOverlayvirtual
drawOverlayTopologyBaseOverlayprotected
dropFindNodeAttackBaseOverlayprotected
dropRouteMessageAttackBaseOverlayprotected
establishTcpConnection(TransportAddress address)BaseTcpSupportprotected
estimateMeanDistance()BaseOverlayvirtual
estimateOverlaySize()BaseOverlayvirtual
EvCode enum nameBaseTcpSupport
eventDeliveryTimerPubSubMMOGprotected
FAILED enum valueBaseOverlay
findNode(const OverlayKey &key, int numRedundantNodes, int numSiblings, BaseOverlayMessage *msg=NULL)BaseOverlayprotectedvirtual
finishOverlay()PubSubMMOGvirtual
finishRpcs()BaseRpcprotected
getBitsPerDigit()BaseOverlayinlinevirtual
getBootstrapList() const BaseOverlayinline
getCompModule(CompType compType)BaseOverlay
getCompRpcGate(CompType compType)BaseOverlay
getCreationTime()BaseOverlayinline
getMaxNumRedundantNodes()BaseOverlayvirtual
getMaxNumSiblings()BaseOverlayvirtual
getMeasureAuthBlock()BaseOverlayinline
getState()BaseOverlayinline
getTcpOut()BaseTcpSupportinlineprotected
getThisCompType()BaseOverlayprotectedvirtual
getThisNode()BaseRpcinline
getUdpTimeout()BaseRpcinline
globalNodeListBaseOverlayprotected
globalParametersBaseOverlayprotected
globalStatisticsBaseRpcprotected
handleAdoptChildCall(PubSubAdoptChildCall *adoptCall)PubSubMMOGprotected
handleAdoptChildResponse(PubSubAdoptChildResponse *adoptResp)PubSubMMOGprotected
handleAppMessage(cMessage *msg)PubSubMMOGvirtual
handleBackupCall(PubSubBackupCall *backupCall)PubSubMMOGprotected
handleBackupCallTimeout(PubSubBackupCall *backupCall, const TransportAddress &oldNode)PubSubMMOGprotected
handleBackupResponse(PubSubBackupResponse *backupResp)PubSubMMOGprotected
handleBaseOverlayMessage(BaseOverlayMessage *msg, const OverlayKey &destKey=OverlayKey::UNSPECIFIED_KEY)BaseOverlayprotected
handleConnectionEvent(EvCode code, TransportAddress address)BaseTcpSupportprotectedvirtual
handleDataReceived(TransportAddress address, cPacket *msg, bool urgent)BaseTcpSupportprotectedvirtual
handleFailedNode(const TransportAddress &failed)BaseOverlayprotectedvirtual
handleHelpResponse(PubSubHelpResponse *helpResp)PubSubMMOGprotected
handleIncomingConnection(TransportAddress address)BaseTcpSupportprotectedvirtual
handleIntermediateBackup(PubSubBackupIntermediateMessage *backupMsg)PubSubMMOGprotected
handleIntermediateCall(PubSubIntermediateCall *intermediateCall)PubSubMMOGprotected
handleIntermediateResponse(PubSubIntermediateResponse *intermediateResp)PubSubMMOGprotected
handleJoinResponse(PubSubJoinResponse *joinResp)PubSubMMOGprotected
handleMessage(cMessage *msg)BaseOverlayprotected
handleMove(GameAPIPositionMessage *posMsg)PubSubMMOGprotected
handleMoveListMessage(PubSubMoveListMessage *moveMsg)PubSubMMOGprotected
handleMoveMessage(PubSubMoveMessage *moveMsg)PubSubMMOGprotected
handleNodeGracefulLeaveNotification()BaseOverlayprotectedvirtual
handleNodeLeaveNotification()BaseOverlayprotectedvirtual
handleNodeLeftMessage(PubSubNodeLeftMessage *leftMsg)PubSubMMOGprotected
handleParentTimeout(PubSubTimer *timer)PubSubMMOGprotected
handlePingCall(PubSubPingCall *hearbeatCall)PubSubMMOGprotected
handlePingCallTimeout(PubSubPingCall *pingCall, const TransportAddress &oldNode)PubSubMMOGprotected
handlePingResponse(PubSubPingResponse *pingResp)PubSubMMOGprotected
handleReleaseIntermediate(PubSubReleaseIntermediateMessage *releaseMsg)PubSubMMOGprotected
handleReplacementMessage(PubSubReplacementMessage *replaceMsg)PubSubMMOGprotected
handleResponsibleNodeResponse(PubSubResponsibleNodeResponse *subResp)PubSubMMOGprotected
handleRpcCall(BaseCallMessage *msg)PubSubMMOGvirtual
handleRpcResponse(BaseResponseMessage *msg, cPolymorphic *context, int rpcId, simtime_t rtt)PubSubMMOGvirtual
BaseOverlay::handleRpcResponse(BaseResponseMessage *msg, const RpcState &rpcState, simtime_t rtt)RpcListenerprotectedvirtual
handleRpcTimeout(BaseCallMessage *msg, const TransportAddress &dest, cPolymorphic *context, int rpcId, const OverlayKey &destKey)PubSubMMOGvirtual
BaseOverlay::handleRpcTimeout(const RpcState &rpcState)RpcListenerprotectedvirtual
handleSubscriptionBackup(PubSubBackupSubscriptionMessage *backupMsg)PubSubMMOGprotected
handleSubscriptionCall(PubSubSubscriptionCall *subCall)PubSubMMOGprotected
handleSubscriptionCallTimeout(PubSubSubscriptionCall *subscriptionCall, const TransportAddress &oldNode)PubSubMMOGprotected
handleSubscriptionResponse(PubSubSubscriptionResponse *subResp)PubSubMMOGprotected
handleTakeOver(PubSubTakeOverSubspaceCall *toCall)PubSubMMOGprotected
handleTCPMessage(cMessage *msg)BaseTcpSupportprotected
handleTimerEvent(cMessage *msg)PubSubMMOGvirtual
handleTransportAddressChangedNotification()BaseOverlayprotectedvirtual
handleUDPMessage(BaseOverlayMessage *msg)PubSubMMOGvirtual
handleUnsubscribeBackup(PubSubBackupUnsubscribeMessage *backupMsg)PubSubMMOGprotected
handleUnsubscriptionMessage(PubSubUnsubscriptionMessage *unsMsg)PubSubMMOGprotected
heartbeatTimerPubSubMMOGprotected
hopCountMaxBaseOverlayprotected
hopCountVectorBaseOverlayprotected
INIT enum valueBaseOverlay
initializeOverlay(int stage)PubSubMMOGvirtual
initRpcs()BaseRpcprotected
initVis(cModule *terminal)TopologyVisprotected
intermediateSubspacesPubSubMMOGprotected
internalHandleMessage(cMessage *msg)BaseRpcprotected
internalHandleRpcCall(BaseCallMessage *msg)BaseOverlayprotectedvirtual
internalHandleRpcMessage(BaseRpcMessage *msg)BaseRpcprotectedvirtual
internalHandleRpcResponse(BaseResponseMessage *msg, cPolymorphic *context, int rpcId, simtime_t rtt)BaseOverlayprotectedvirtual
internalHandleRpcTimeout(BaseCallMessage *msg, const TransportAddress &dest, cPolymorphic *context, int rpcId, const OverlayKey &destKey)BaseOverlayprotectedvirtual
internalSendRouteRpc(BaseRpcMessage *message, const OverlayKey &destKey, const std::vector< TransportAddress > &sourceRoute, RoutingType routingType)BaseOverlayprotectedvirtual
invalidNodesAttackBaseOverlayprotected
isAlreadyConnected(TransportAddress address)BaseTcpSupportprotected
isInSimpleMultiOverlayHost()BaseOverlay
isMalicious()BaseOverlay
isSiblingAttackBaseOverlayprotected
isSiblingFor(const NodeHandle &node, const OverlayKey &key, int numSiblings, bool *err)BaseOverlayvirtual
iterativeLookupConfigBaseOverlayprotected
JOIN enum valueBaseOverlay
join(const OverlayKey &nodeID=OverlayKey::UNSPECIFIED_KEY)BaseOverlay
joinForeignPartition(const NodeHandle &node)BaseOverlayprotectedvirtual
joinOverlay()BaseOverlayprotectedvirtual
joinTimerPubSubMMOGprotected
kbrBaseOverlayprotected
lobbyServerPubSubMMOGprotected
local_lookup(const OverlayKey &key, int num, bool safe)BaseOverlayvirtual
localPortBaseOverlayprotected
lookupRpc(LookupCall *call)BaseOverlayprotectedvirtual
lookupsBaseOverlayprotected
LookupSet typedefBaseOverlayprotected
lostMovementListsPubSubMMOGprotected
maxChildrenPubSubMMOGprotected
maxMoveDelayPubSubMMOGprotected
measureAuthBlockBaseOverlayprotected
moveListMessagesSizePubSubMMOGprotected
movementRatePubSubMMOGprotected
moveMessagesSizePubSubMMOGprotected
neighborCacheBaseRpcprotected
neighborSet(int num)BaseOverlayvirtual
nextHopRpc(NextHopCall *call)BaseOverlayprotectedvirtual
NO_EST_CONNECTION enum valueBaseTcpSupport
notificationBoardBaseOverlayprotected
numAppDataForwardedBaseOverlayprotected
numAppLookupForwardedBaseOverlayprotected
numDroppedBaseOverlayprotected
numEventsCorrectTimeslotPubSubMMOGprotected
numEventsWrongTimeslotPubSubMMOGprotected
numFailedNodeResponseSentBaseOverlayprotected
numFailedNodeSentBaseOverlayprotected
numFindNodeResponseSentBaseOverlayprotected
numFindNodeSentBaseOverlayprotected
numInitStages() const BaseOverlayprotected
numMaintenanceForwardedBaseOverlayprotected
numMoveListMessagesPubSubMMOGprotected
numMoveMessagesPubSubMMOGprotected
numPingResponseSentBaseRpcprotected
numPingSentBaseRpcprotected
numPubSubSignalingMessagesPubSubMMOGprotected
numSubspacesPubSubMMOGprotected
overlayBaseRpcprotected
overlayIdBaseOverlayprotected
parentTimeoutPubSubMMOGprotected
PEER_CLOSED enum valueBaseTcpSupport
PEER_REFUSED enum valueBaseTcpSupport
PEER_TIMEDOUT enum valueBaseTcpSupport
pingNode(const TransportAddress &dest, simtime_t timeout=-1, int retries=0, cPolymorphic *context=NULL, const char *caption="PING", RpcListener *rpcListener=NULL, int rpcId=-1, TransportType transportType=INVALID_TRANSPORT)BaseRpcprotected
pingResponse(PingResponse *pingResponse, cPolymorphic *context, int rpcId, simtime_t rtt)BaseRpcprotectedvirtual
pingTimeout(PingCall *pingCall, const TransportAddress &dest, cPolymorphic *context, int rpcId)BaseRpcprotectedvirtual
POSTJOIN enum valueBaseOverlay
PREJOIN enum valueBaseOverlay
providesKbr()BaseOverlayinline
publishEvents()PubSubMMOGprotected
pubSubSignalingMessagesSizePubSubMMOGprotected
READY enum valueBaseOverlay
receiveChangeNotification(int category, const cPolymorphic *details)PubSubMMOGvirtual
receivedMovementListsPubSubMMOGprotected
recNumRedundantNodesBaseOverlayprotected
recordOverlaySentStats(BaseOverlayMessage *msg)BaseOverlayprotectedvirtual
recordRouteBaseOverlayprotected
recursiveLookupConfigBaseOverlayprotected
REFRESH enum valueBaseOverlay
registerComp(CompType compType, cModule *module)BaseOverlay
rejoinOnFailureBaseOverlayprotected
removeLookup(AbstractLookup *lookup)BaseOverlayprotectedvirtual
respMoveListMessagesSizePubSubMMOGprotected
responsibleSubspacesPubSubMMOGprotected
restoreContextBaseOverlayprotected
route(const OverlayKey &key, CompType destComp, CompType srcComp, cPacket *msg, const std::vector< TransportAddress > &sourceRoute=TransportAddress::UNSPECIFIED_NODES, RoutingType routingType=DEFAULT_ROUTING)BaseOverlayprotectedvirtual
routeMsgAcksBaseOverlayprotected
RSET enum valueBaseOverlay
sendHearbeatToChildren()PubSubMMOGprotected
sendInternalRpcCall(CompType destComp, BaseCallMessage *msg, cPolymorphic *context=NULL, simtime_t timeout=-1, int retries=0, int rpcId=-1, RpcListener *rpcListener=NULL)BaseRpcinlineprotected
sendMessageToAllComp(cMessage *msg, CompType srcComp)BaseOverlay
sendMessageToChildren(PubSubSubspaceResponsible &subspace, BaseOverlayMessage *toIntermediates, BaseOverlayMessage *toBackup, BaseOverlayMessage *toPlayers)PubSubMMOGprotected
sendMessageToUDP(const TransportAddress &dest, cPacket *msg, simtime_t delay=SIMTIME_ZERO)BaseOverlayvirtual
sendPingToChildren()PubSubMMOGprotected
sendRouteRpcCall(CompType destComp, const TransportAddress &dest, const OverlayKey &destKey, BaseCallMessage *msg, cPolymorphic *context=NULL, RoutingType routingType=DEFAULT_ROUTING, simtime_t timeout=-1, int retries=0, int rpcId=-1, RpcListener *rpcListener=NULL)BaseRpcinlineprotected
sendRouteRpcCall(CompType destComp, const OverlayKey &destKey, BaseCallMessage *msg, cPolymorphic *context=NULL, RoutingType routingType=DEFAULT_ROUTING, simtime_t timeout=-1, int retries=0, int rpcId=-1, RpcListener *rpcListener=NULL)BaseRpcinlineprotected
sendRouteRpcCall(CompType destComp, const TransportAddress &dest, BaseCallMessage *msg, cPolymorphic *context=NULL, RoutingType routingType=DEFAULT_ROUTING, simtime_t timeout=-1, int retries=0, int rpcId=-1, RpcListener *rpcListener=NULL)BaseRpcinlineprotected
sendRpcResponse(TransportType transportType, CompType destComp, const TransportAddress &dest, const OverlayKey &destKey, BaseCallMessage *call, BaseResponseMessage *response)BaseRpcprotected
sendRpcResponse(BaseCallMessage *call, BaseResponseMessage *response)BaseRpcprotected
sendRpcResponseToLastHopBaseOverlayprotected
sendTcpData(cPacket *msg, TransportAddress address)BaseTcpSupportprotected
sendToKey(const OverlayKey &key, BaseOverlayMessage *message, int numSiblings=1, const std::vector< TransportAddress > &sourceRoute=TransportAddress::UNSPECIFIED_NODES, RoutingType routingType=DEFAULT_ROUTING)BaseOverlay
sendUdpRpcCall(const TransportAddress &dest, BaseCallMessage *msg, cPolymorphic *context=NULL, simtime_t timeout=-1, int retries=0, int rpcId=-1, RpcListener *rpcListener=NULL)BaseRpcinlineprotected
setBootstrapedIcon()PubSubMMOGprotected
setOverlayReady(bool ready)BaseOverlayprotected
setTcpOut(cGate *gate)BaseTcpSupportinlineprotected
showOverlayNeighborArrow(const NodeHandle &neighbor, bool flush=true, const char *displayString=NULL)TopologyVis
SHUTDOWN enum valueBaseOverlay
singleHopDelaysBaseOverlayprotected
socketDataArrived(int connId, void *yourPtr, cPacket *msg, bool urgent)BaseTcpSupportvirtual
socketEstablished(int connId, void *yourPtr)BaseTcpSupportvirtual
socketFailure(int connId, void *yourPtr, int code)BaseTcpSupportvirtual
socketPeerClosed(int connId, void *yourPtr)BaseTcpSupportvirtual
socketStatusArrived(int connId, void *yourPtr, TCPStatusInfo *status)BaseTcpSupportinlinevirtual
startTimer(PubSubTimer *timer)PubSubMMOGprotected
stateBaseOverlayprotected
States enum nameBaseOverlay
subscribedSubspacesPubSubMMOGprotected
subspaceSizePubSubMMOGprotected
takeOverNewSubspace(PubSubSubspaceId subspaceId)PubSubMMOGprotected
takeOverSubspace(PubSubSubspaceResponsible &subspaceId, bool isNew)PubSubMMOGprotected
thisCompTypeBaseRpcprotected
thisNodeBaseRpcprotected
thisTerminalTopologyVisprotected
TopologyVis()TopologyVis
underlayConfiguratorBaseOverlayprotected
unsubscribeChild(const NodeHandle &node, PubSubSubspaceResponsible &subspace)PubSubMMOGprotected
useCommonAPIforwardBaseOverlayprotected
~BaseOverlay()BaseOverlayvirtual
~PubSubMMOG()PubSubMMOGvirtual
~RpcListener()RpcListenervirtual