OverSim
PubSubLobby Member List

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

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
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
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
FAILED enum valueBaseOverlay
failedNode(const TransportAddress &node)PubSubLobbyprotected
findNode(const OverlayKey &key, int numRedundantNodes, int numSiblings, BaseOverlayMessage *msg=NULL)BaseOverlayprotectedvirtual
finishOverlay()PubSubLobbyvirtual
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
handleAppMessage(cMessage *msg)BaseOverlayprotectedvirtual
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
handleHelpCall(PubSubHelpCall *helpMsg)PubSubLobbyprotectedvirtual
handleHelpReleaseMessage(PubSubHelpReleaseMessage *helpRMsg)PubSubLobbyprotected
handleIncomingConnection(TransportAddress address)BaseTcpSupportprotectedvirtual
handleJoin(PubSubJoinCall *joinMsg)PubSubLobbyprotectedvirtual
handleMessage(cMessage *msg)BaseOverlayprotected
handleNodeGracefulLeaveNotification()BaseOverlayprotectedvirtual
handleNodeLeaveNotification()BaseOverlayprotectedvirtual
handleRespCall(PubSubResponsibleNodeCall *respCall)PubSubLobbyprotectedvirtual
handleRpcCall(BaseCallMessage *msg)PubSubLobbyvirtual
handleRpcResponse(BaseResponseMessage *msg, cPolymorphic *context, int rpcId, simtime_t rtt)PubSubLobbyvirtual
BaseOverlay::handleRpcResponse(BaseResponseMessage *msg, const RpcState &rpcState, simtime_t rtt)RpcListenerprotectedvirtual
handleRpcTimeout(BaseCallMessage *msg, const TransportAddress &dest, cPolymorphic *context, int rpcId, const OverlayKey &destKey)PubSubLobbyvirtual
BaseOverlay::handleRpcTimeout(const RpcState &rpcState)RpcListenerprotectedvirtual
handleTakeOverResponse(PubSubTakeOverSubspaceResponse *takeOverResp)PubSubLobbyprotectedvirtual
handleTakeOverTimeout(PubSubTakeOverSubspaceCall *takeOverCall, const TransportAddress &oldNode)PubSubLobbyprotectedvirtual
handleTCPMessage(cMessage *msg)BaseTcpSupportprotected
handleTimerEvent(cMessage *msg)PubSubLobbyvirtual
handleTransportAddressChangedNotification()BaseOverlayprotectedvirtual
handleUDPMessage(BaseOverlayMessage *msg)PubSubLobbyvirtual
hopCountMaxBaseOverlayprotected
hopCountVectorBaseOverlayprotected
INIT enum valueBaseOverlay
initializeOverlay(int stage)PubSubLobbyvirtual
initRpcs()BaseRpcprotected
initVis(cModule *terminal)TopologyVisprotected
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(const OverlayKey &nodeID=OverlayKey::UNSPECIFIED_KEY)BaseOverlay
JOIN enum valueBaseOverlay
joinForeignPartition(const NodeHandle &node)BaseOverlayprotectedvirtual
joinOverlay()BaseOverlayprotectedvirtual
kbrBaseOverlayprotected
local_lookup(const OverlayKey &key, int num, bool safe)BaseOverlayvirtual
localPortBaseOverlayprotected
lookupRpc(LookupCall *call)BaseOverlayprotectedvirtual
lookupsBaseOverlayprotected
LookupSet typedefBaseOverlayprotected
measureAuthBlockBaseOverlayprotected
neighborCacheBaseRpcprotected
neighborSet(int num)BaseOverlayvirtual
nextHopRpc(NextHopCall *call)BaseOverlayprotectedvirtual
NO_EST_CONNECTION enum valueBaseTcpSupport
notificationBoardBaseOverlayprotected
numAppDataForwardedBaseOverlayprotected
numAppLookupForwardedBaseOverlayprotected
numDroppedBaseOverlayprotected
numFailedNodeResponseSentBaseOverlayprotected
numFailedNodeSentBaseOverlayprotected
numFindNodeResponseSentBaseOverlayprotected
numFindNodeSentBaseOverlayprotected
numInitStages() const BaseOverlayprotected
numMaintenanceForwardedBaseOverlayprotected
numPingResponseSentBaseRpcprotected
numPingSentBaseRpcprotected
numPubSubSignalingMessagesPubSubLobbyprotected
numSubspacesPubSubLobbyprotected
operator<<(std::ostream &o, const ChildEntry &entry)PubSubLobbyfriend
overlayBaseRpcprotected
overlayIdBaseOverlayprotected
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
PlayerMap typedefPubSubLobbyprotected
playerMapPubSubLobbyprotected
playerRessourceMapPubSubLobbyprotected
PlayerRessourceMap typedefPubSubLobbyprotected
POSTJOIN enum valueBaseOverlay
PREJOIN enum valueBaseOverlay
providesKbr()BaseOverlayinline
pubSubSignalingMessagesSizePubSubLobbyprotected
READY enum valueBaseOverlay
receiveChangeNotification(int category, const cPolymorphic *details)BaseOverlayprotectedvirtual
recNumRedundantNodesBaseOverlayprotected
recordOverlaySentStats(BaseOverlayMessage *msg)BaseOverlayprotectedvirtual
recordRouteBaseOverlayprotected
recursiveLookupConfigBaseOverlayprotected
REFRESH enum valueBaseOverlay
registerComp(CompType compType, cModule *module)BaseOverlay
rejoinOnFailureBaseOverlayprotected
removeLookup(AbstractLookup *lookup)BaseOverlayprotectedvirtual
replaceResponsibleNode(int subspaceId, NodeHandle respNode)PubSubLobbyprotected
replaceResponsibleNode(PubSubSubspaceId subspaceId, NodeHandle respNode)PubSubLobbyprotected
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
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
sendMessageToUDP(const TransportAddress &dest, cPacket *msg, simtime_t delay=SIMTIME_ZERO)BaseOverlayvirtual
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
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
stateBaseOverlayprotected
States enum nameBaseOverlay
subspacesPubSubLobbyprotected
subspaceSizePubSubLobbyprotected
thisCompTypeBaseRpcprotected
thisNodeBaseRpcprotected
thisTerminalTopologyVisprotected
TopologyVis()TopologyVis
underlayConfiguratorBaseOverlayprotected
useCommonAPIforwardBaseOverlayprotected
waitingForHelpPubSubLobbyprotected
~BaseOverlay()BaseOverlayvirtual
~PubSubLobby()PubSubLobbyvirtual
~RpcListener()RpcListenervirtual