/* */ #ifndef D_EVENT_H #define D_EVENT_H #include "common.h" #include #include #include #include #include "a2netcompat.h" #include "Command.h" #ifdef ENABLE_ASYNC_DNS # include "AsyncNameResolver.h" #endif // ENABLE_ASYNC_DNS namespace aria2 { template class Event { public: virtual ~Event() = default; virtual void processEvents(int events) = 0; virtual int getEvents() const = 0; virtual void addSelf(SocketEntry* socketEntry) const = 0; virtual void removeSelf(SocketEntry* socketEntry) const = 0; }; template class CommandEvent : public Event { private: Command* command_; int events_; public: CommandEvent(Command* command, int events) : command_(command), events_(events) { } Command* getCommand() const { return command_; } void addEvents(int events) { events_ |= events; } void removeEvents(int events) { events_ &= (~events); } bool eventsEmpty() const { return events_ == 0; } bool operator==(const CommandEvent& commandEvent) const { return command_ == commandEvent.command_; } virtual int getEvents() const { return events_; } virtual void processEvents(int events) { if ((events_ & events) || ((EventPoll::IEV_ERROR | EventPoll::IEV_HUP) & events)) { command_->setStatusActive(); } if (EventPoll::IEV_READ & events) { command_->readEventReceived(); } if (EventPoll::IEV_WRITE & events) { command_->writeEventReceived(); } if (EventPoll::IEV_ERROR & events) { command_->errorEventReceived(); } if (EventPoll::IEV_HUP & events) { command_->hupEventReceived(); } } virtual void addSelf(SocketEntry* socketEntry) const { socketEntry->addCommandEvent(*this); } virtual void removeSelf(SocketEntry* socketEntry) const { socketEntry->removeCommandEvent(*this); } }; #ifdef ENABLE_ASYNC_DNS template class ADNSEvent : public Event { private: std::shared_ptr resolver_; Command* command_; sock_t socket_; int events_; public: ADNSEvent(const std::shared_ptr& resolver, Command* command, sock_t socket, int events) : resolver_(resolver), command_(command), socket_(socket), events_(events) { } bool operator==(const ADNSEvent& event) const { return *resolver_ == *event.resolver_; } virtual int getEvents() const { return events_; } virtual void processEvents(int events) { ares_socket_t readfd; ares_socket_t writefd; if (events & (EventPoll::IEV_READ | EventPoll::IEV_ERROR | EventPoll::IEV_HUP)) { readfd = socket_; } else { readfd = ARES_SOCKET_BAD; } if (events & (EventPoll::IEV_WRITE | EventPoll::IEV_ERROR | EventPoll::IEV_HUP)) { writefd = socket_; } else { writefd = ARES_SOCKET_BAD; } resolver_->process(readfd, writefd); command_->setStatusActive(); } virtual void addSelf(SocketEntry* socketEntry) const { socketEntry->addADNSEvent(*this); } virtual void removeSelf(SocketEntry* socketEntry) const { socketEntry->removeADNSEvent(*this); } }; #else // !ENABLE_ASYNC_DNS template class ADNSEvent : public Event { }; #endif // !ENABLE_ASYNC_DNS template class SocketEntry { protected: sock_t socket_; std::deque commandEvents_; #ifdef ENABLE_ASYNC_DNS std::deque adnsEvents_; #endif // ENABLE_ASYNC_DNS public: SocketEntry(sock_t socket) : socket_(socket) {} SocketEntry(const SocketEntry&) = delete; SocketEntry(SocketEntry&&) = default; bool operator==(const SocketEntry& entry) const { return socket_ == entry.socket_; } bool operator<(const SocketEntry& entry) const { return socket_ < entry.socket_; } void addCommandEvent(const CommandEvent& cev) { typename std::deque::iterator i = std::find(commandEvents_.begin(), commandEvents_.end(), cev); if (i == commandEvents_.end()) { commandEvents_.push_back(cev); } else { (*i).addEvents(cev.getEvents()); } } void removeCommandEvent(const CommandEvent& cev) { typename std::deque::iterator i = std::find(commandEvents_.begin(), commandEvents_.end(), cev); if (i == commandEvents_.end()) { // not found } else { (*i).removeEvents(cev.getEvents()); if ((*i).eventsEmpty()) { commandEvents_.erase(i); } } } #ifdef ENABLE_ASYNC_DNS void addADNSEvent(const ADNSEvent& aev) { typename std::deque::iterator i = std::find(adnsEvents_.begin(), adnsEvents_.end(), aev); if (i == adnsEvents_.end()) { adnsEvents_.push_back(aev); } } void removeADNSEvent(const ADNSEvent& aev) { typename std::deque::iterator i = std::find(adnsEvents_.begin(), adnsEvents_.end(), aev); if (i == adnsEvents_.end()) { // not found } else { adnsEvents_.erase(i); } } #endif // ENABLE_ASYNC_DNS sock_t getSocket() const { return socket_; } void setSocket(sock_t socket) { socket_ = socket; } bool eventEmpty() const { #ifdef ENABLE_ASYNC_DNS return commandEvents_.empty() && adnsEvents_.empty(); #else // !ENABLE_ASYNC_DNS return commandEvents_.empty(); #endif // !ENABLE_ASYNC_DNS) } void processEvents(int events) { using namespace std::placeholders; std::for_each(commandEvents_.begin(), commandEvents_.end(), std::bind(&CommandEvent::processEvents, _1, events)); #ifdef ENABLE_ASYNC_DNS std::for_each(adnsEvents_.begin(), adnsEvents_.end(), std::bind(&ADNSEvent::processEvents, _1, events)); #endif // ENABLE_ASYNC_DNS } }; #ifdef ENABLE_ASYNC_DNS template class AsyncNameResolverEntry { private: std::shared_ptr nameResolver_; Command* command_; size_t socketsSize_; sock_t sockets_[ARES_GETSOCK_MAXNUM]; public: AsyncNameResolverEntry(std::shared_ptr nameResolver, Command* command) : nameResolver_(std::move(nameResolver)), command_(command), socketsSize_(0) { } AsyncNameResolverEntry(const AsyncNameResolverEntry&) = delete; AsyncNameResolverEntry(AsyncNameResolverEntry&&) = default; bool operator==(const AsyncNameResolverEntry& entry) { return *nameResolver_ == *entry.nameResolver_ && command_ == entry.command_; } bool operator<(const AsyncNameResolverEntry& entry) { return nameResolver_.get() < entry.nameResolver_.get() || (nameResolver_.get() == entry.nameResolver_.get() && command_ < entry.command_); } void addSocketEvents(EventPoll* e) { socketsSize_ = 0; int mask = nameResolver_->getsock(sockets_); if (mask == 0) { return; } size_t i; for (i = 0; i < ARES_GETSOCK_MAXNUM; ++i) { int events = 0; if (ARES_GETSOCK_READABLE(mask, i)) { events |= EventPoll::IEV_READ; } if (ARES_GETSOCK_WRITABLE(mask, i)) { events |= EventPoll::IEV_WRITE; } if (events == 0) { // assume no further sockets are returned. break; } e->addEvents(sockets_[i], command_, events, nameResolver_); } socketsSize_ = i; } void removeSocketEvents(EventPoll* e) { for (size_t i = 0; i < socketsSize_; ++i) { e->deleteEvents(sockets_[i], command_, nameResolver_); } } // Calls AsyncNameResolver::process(ARES_SOCKET_BAD, // ARES_SOCKET_BAD). void processTimeout() { nameResolver_->process(ARES_SOCKET_BAD, ARES_SOCKET_BAD); } }; #else // !ENABLE_ASYNC_DNS template class AsyncNameResolverEntry { }; #endif // !ENABLE_ASYNC_DNS } // namespace aria2 #endif // D_EVENT_H