/* */ #include "AbstractBtMessage.h" #include "Peer.h" #include "BtContext.h" #include "PieceStorage.h" #include "BtRegistry.h" #include "BtEventListener.h" #include "BtMessageValidator.h" #include "LogFactory.h" #include "Logger.h" namespace aria2 { AbstractBtMessage::AbstractBtMessage():sendingInProgress(false), invalidate(false), uploading(false), cuid(0), btContext(0), pieceStorage(0), peer(0), validator(0), logger(LogFactory::getInstance()) {} AbstractBtMessage::~AbstractBtMessage() {} SharedHandle AbstractBtMessage::getPeer() const { return peer; } void AbstractBtMessage::setPeer(const SharedHandle& peer) { this->peer = peer; } bool AbstractBtMessage::validate(std::deque& errors) { if(validator.get()) { return validator->validate(errors); } else { return true; } } void AbstractBtMessage::handleEvent(const SharedHandle& event) { for(std::deque >::iterator itr = listeners.begin(); itr != listeners.end(); ++itr) { (*itr)->handleEvent(event); } } void AbstractBtMessage::addEventListener(const SharedHandle& listener) { listeners.push_back(listener); } void AbstractBtMessage::setBtMessageValidator(const SharedHandle& validator) { this->validator = validator; } SharedHandle AbstractBtMessage::getBtMessageValidator() const { return validator; } void AbstractBtMessage::setBtContext(const SharedHandle& btContext) { this->btContext = btContext; this->pieceStorage = PIECE_STORAGE(btContext); } SharedHandle AbstractBtMessage::getBtContext() const { return btContext; } void AbstractBtMessage::setBtMessageDispatcher(const WeakHandle& dispatcher) { this->dispatcher = dispatcher; } void AbstractBtMessage::setPeerConnection(const WeakHandle& peerConnection) { this->peerConnection = peerConnection; } void AbstractBtMessage::setBtMessageFactory(const WeakHandle& factory) { this->messageFactory = factory; } void AbstractBtMessage::setBtRequestFactory(const WeakHandle& factory) { this->requestFactory = factory; } } // namespace aria2