diff options
Diffstat (limited to 'src/DHTPingTask.h')
| -rw-r--r-- | src/DHTPingTask.h | 71 |
1 files changed, 71 insertions, 0 deletions
diff --git a/src/DHTPingTask.h b/src/DHTPingTask.h new file mode 100644 index 00000000..7e84cbc3 --- /dev/null +++ b/src/DHTPingTask.h @@ -0,0 +1,71 @@ +/* <!-- copyright */ +/* + * aria2 - The high speed download utility + * + * Copyright (C) 2006 Tatsuhiro Tsujikawa + * + * This program is free software; you can redistribute it and/or modify + * it under the terms of the GNU General Public License as published by + * the Free Software Foundation; either version 2 of the License, or + * (at your option) any later version. + * + * This program is distributed in the hope that it will be useful, + * but WITHOUT ANY WARRANTY; without even the implied warranty of + * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the + * GNU General Public License for more details. + * + * You should have received a copy of the GNU General Public License + * along with this program; if not, write to the Free Software + * Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA + * + * In addition, as a special exception, the copyright holders give + * permission to link the code of portions of this program with the + * OpenSSL library under certain conditions as described in each + * individual source file, and distribute linked combinations + * including the two. + * You must obey the GNU General Public License in all respects + * for all of the code used other than OpenSSL. If you modify + * file(s) with this exception, you may extend this exception to your + * version of the file(s), but you are not obligated to do so. If you + * do not wish to do so, delete this exception statement from your + * version. If you delete this exception statement from all source + * files in the program, then also delete it here. + */ +/* copyright --> */ +#ifndef _D_DHT_PING_TASK_H_ +#define _D_DHT_PING_TASK_H_ + +#include "DHTAbstractTask.h" +#include "DHTMessageCallbackListener.h" + +class DHTPingTask:public DHTAbstractTask, public DHTMessageCallbackListener { +protected: + DHTNodeHandle _remoteNode; + + size_t _numMaxRetry; + + size_t _numRetry; + + bool _pingSuccessful; + + time_t _timeout; +public: + DHTPingTask(const DHTNodeHandle& remoteNode, size_t numMaxRetry = 0); + + virtual ~DHTPingTask(); + + virtual void startup(); + + virtual void onReceived(const DHTMessageHandle& message); + + virtual void onTimeout(const DHTNodeHandle& node); + + void setTimeout(time_t timeout) + { + _timeout = timeout; + } + + bool isPingSuccessful() const; +}; + +#endif // _D_DHT_PING_TASK_H_ |
