OverSim
DHTTestApp Member List

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

activeNetwInitPhaseDHTTestAppprivate
BaseApp()BaseApp
BaseRpc()BaseRpc
bindAndListenTcp(int port)BaseTcpSupportprotected
bindToPort(int port)BaseAppprotectedvirtual
bytesOverlayReceivedBaseAppprotected
bytesOverlaySentBaseAppprotected
bytesPingResponseSentBaseRpcprotected
bytesPingSentBaseRpcprotected
bytesUdpReceivedBaseAppprotected
bytesUdpSentBaseAppprotected
callLocalLookup(const OverlayKey &key, int num, bool safe)BaseAppinlineprotected
callNeighborSet(int num)BaseAppinlineprotected
callRoute(const OverlayKey &key, cPacket *msg, const TransportAddress &hint=TransportAddress::UNSPECIFIED_NODE, RoutingType routingType=DEFAULT_ROUTING)BaseAppinlineprotected
callRoute(const OverlayKey &key, cPacket *msg, const std::vector< TransportAddress > &sourceRoute, RoutingType routingType=DEFAULT_ROUTING)BaseAppprotected
cancelAllRpcs()BaseRpcprotected
cancelRpcMessage(uint32_t nonce)BaseRpcprotected
closeTcpConnection(TransportAddress address)BaseTcpSupportprotected
CONNECTION_RESET enum valueBaseTcpSupport
CONNECTION_SUCC_ClOSED enum valueBaseTcpSupport
creationTimeBaseAppprotected
cryptoModuleBaseRpcprotected
debugOutputDHTTestAppprivate
deliver(OverlayKey &key, cMessage *msg)BaseAppprotectedvirtual
deviationDHTTestAppprivate
DHTTestApp()DHTTestApp
DHTTESTAPP_VALUE_LENDHTTestAppprivatestatic
dhttestget_timerDHTTestAppprivate
dhttestmod_timerDHTTestAppprivate
dhttestput_timerDHTTestAppprivate
establishTcpConnection(TransportAddress address)BaseTcpSupportprotected
EvCode enum nameBaseTcpSupport
finish()BaseAppprotected
finishApp()DHTTestAppprivate
finishRpcs()BaseRpcprotected
forward(OverlayKey *key, cPacket **msg, NodeHandle *nextHopNode)BaseAppprotectedvirtual
generateRandomValue()DHTTestAppprivate
getRandomKey()DHTTestAppprivate
getTcpOut()BaseTcpSupportinlineprotected
getThisCompType()BaseAppprotectedvirtual
getThisNode()BaseRpcinline
getUdpTimeout()BaseRpcinline
globalDhtTestMapDHTTestAppprivate
globalNodeListDHTTestAppprivate
globalStatisticsDHTTestAppprivate
handleConnectionEvent(EvCode code, TransportAddress address)BaseTcpSupportprotectedvirtual
handleDataReceived(TransportAddress address, cPacket *msg, bool urgent)BaseTcpSupportprotectedvirtual
handleGetResponse(DHTgetCAPIResponse *msg, DHTStatsContext *context)DHTTestAppprivatevirtual
handleIncomingConnection(TransportAddress address)BaseTcpSupportprotectedvirtual
handleLowerMessage(cMessage *msg)BaseAppprotectedvirtual
handleMessage(cMessage *msg)BaseAppprotected
handleNodeGracefulLeaveNotification()BaseAppprotectedvirtual
handleNodeLeaveNotification()DHTTestAppprivatevirtual
handlePutResponse(DHTputCAPIResponse *msg, DHTStatsContext *context)DHTTestAppprivatevirtual
handleReadyMessage(CompReadyMessage *msg)BaseAppprotectedvirtual
handleRpcCall(BaseCallMessage *msg)BaseRpcprotectedvirtual
handleRpcResponse(BaseResponseMessage *msg, const RpcState &state, simtime_t rtt)DHTTestAppprivate
BaseApp::handleRpcResponse(BaseResponseMessage *msg, cPolymorphic *context, int rpcId, simtime_t rtt)RpcListenerprotectedvirtual
handleRpcTimeout(BaseCallMessage *msg, const TransportAddress &dest, cPolymorphic *context, int rpcId, const OverlayKey &destKey)RpcListenerprotectedvirtual
handleRpcTimeout(const RpcState &rpcState)RpcListenerprotectedvirtual
handleTCPMessage(cMessage *msg)BaseTcpSupportprotected
handleTimerEvent(cMessage *msg)DHTTestAppprivatevirtual
handleTraceMessage(cMessage *msg)DHTTestAppprivatevirtual
handleTransportAddressChangedNotification()BaseAppprotectedvirtual
handleUDPMessage(cMessage *msg)BaseAppprotectedvirtual
handleUpperMessage(cMessage *msg)BaseAppprotectedvirtual
initialize(int stage)BaseAppprotected
initializeApp(int stage)DHTTestAppprivate
initRpcs()BaseRpcprotected
internalHandleMessage(cMessage *msg)BaseRpcprotected
internalHandleRpcCall(BaseCallMessage *msg)BaseAppprotectedvirtual
internalHandleRpcMessage(BaseRpcMessage *msg)BaseRpcprotectedvirtual
internalHandleRpcResponse(BaseResponseMessage *msg, cPolymorphic *context, int rpcId, simtime_t rtt)BaseAppprotectedvirtual
internalHandleRpcTimeout(BaseCallMessage *msg, const TransportAddress &dest, cPolymorphic *context, int rpcId, const OverlayKey &destKey)BaseRpcprotectedvirtual
internalSendRouteRpc(BaseRpcMessage *message, const OverlayKey &destKey, const std::vector< TransportAddress > &sourceRoute, RoutingType routingType)BaseAppprotectedvirtual
isAlreadyConnected(TransportAddress address)BaseTcpSupportprotected
isSiblingFor(const NodeHandle &node, const OverlayKey &key, int numSiblings, bool *err)BaseAppinlineprotected
meanDHTTestAppprivate
neighborCacheBaseRpcprotected
NO_EST_CONNECTION enum valueBaseTcpSupport
nodeIsLeavingSoonDHTTestAppprivate
notificationBoardBaseAppprotected
numGetErrorDHTTestAppprivate
numGetSentDHTTestAppprivate
numGetSuccessDHTTestAppprivate
numInitStages() const BaseAppprotected
numOverlayReceivedBaseAppprotected
numOverlaySentBaseAppprotected
numPingResponseSentBaseRpcprotected
numPingSentBaseRpcprotected
numPutErrorDHTTestAppprivate
numPutSentDHTTestAppprivate
numPutSuccessDHTTestAppprivate
numSentDHTTestAppprivate
numUdpReceivedBaseAppprotected
numUdpSentBaseAppprotected
overlayBaseRpcprotected
p2pnsTrafficDHTTestAppprivate
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
receiveChangeNotification(int category, const cPolymorphic *details)BaseAppprotectedvirtual
sendInternalRpcCall(CompType destComp, BaseCallMessage *msg, cPolymorphic *context=NULL, simtime_t timeout=-1, int retries=0, int rpcId=-1, RpcListener *rpcListener=NULL)BaseRpcinlineprotected
sendMessageToLowerTier(cPacket *msg)BaseAppprotected
sendMessageToUDP(const TransportAddress &destAddr, cPacket *msg, simtime_t delay=SIMTIME_ZERO)BaseAppprotectedvirtual
sendReadyMessage(bool ready=true, const OverlayKey &nodeId=OverlayKey::UNSPECIFIED_KEY)BaseAppprotected
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
sendTcpData(cPacket *msg, TransportAddress address)BaseTcpSupportprotected
sendUdpRpcCall(const TransportAddress &dest, BaseCallMessage *msg, cPolymorphic *context=NULL, simtime_t timeout=-1, int retries=0, int rpcId=-1, RpcListener *rpcListener=NULL)BaseRpcinlineprotected
setTcpOut(cGate *gate)BaseTcpSupportinlineprotected
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
thisCompTypeBaseRpcprotected
thisNodeBaseRpcprotected
ttlDHTTestAppprivate
underlayConfiguratorDHTTestAppprivate
update(const NodeHandle &node, bool joined)BaseAppprotectedvirtual
~BaseApp()BaseAppvirtual
~DHTTestApp()DHTTestAppvirtual
~RpcListener()RpcListenervirtual