/* */ #ifndef _D_DHT_PEER_LOOKUP_TASK_H_ #define _D_DHT_PEER_LOOKUP_TASK_H_ #include "DHTAbstractNodeLookupTask.h" #include "BtContextDecl.h" #include "PeerDecl.h" #include class PeerStorage; typedef SharedHandle PeerStorageHandle; class BtRuntime; typedef SharedHandle BtRuntimeHandle; class DHTPeerLookupTask:public DHTAbstractNodeLookupTask { private: std::map _tokenStorage; Peers _peers; BtContextHandle _ctx; PeerStorageHandle _peerStorage; BtRuntimeHandle _btRuntime; public: DHTPeerLookupTask(const BtContextHandle& btContext); virtual DHTNodes getNodesFromMessage(const DHTMessageHandle& message); virtual void onReceivedInternal(const DHTMessageHandle& message); virtual DHTMessageHandle createMessage(const DHTNodeHandle& remoteNode); virtual void onFinish(); const Peers& getPeers() const; }; #endif // _D_DHT_PEER_LOOKUP_TASK_H_