diff options
| author | Tatsuhiro Tsujikawa <tatsuhiro.t@gmail.com> | 2010-06-12 02:54:39 +0000 |
|---|---|---|
| committer | Tatsuhiro Tsujikawa <tatsuhiro.t@gmail.com> | 2010-06-12 02:54:39 +0000 |
| commit | ded040666efa013fccbe67b26700477359af7d23 (patch) | |
| tree | 4190d17e6477adc683e65402ba9e0eb63ef64476 /src/DHTPingTask.cc | |
| parent | f7001132bca9edafc15eda43457144773bada37d (diff) | |
2010-06-12 Tatsuhiro Tsujikawa <t-tujikawa@users.sourceforge.net>
Made protected member variable private. Added accessor funcs.
* src/DHTAbstractNodeLookupTask.cc
* src/DHTAbstractNodeLookupTask.h
* src/DHTAbstractTask.h
* src/DHTBucketRefreshTask.cc
* src/DHTNodeLookupTask.cc
* src/DHTNodeLookupTask.h
* src/DHTPeerLookupTask.cc
* src/DHTPeerLookupTask.h
* src/DHTPingTask.cc
* src/DHTPingTask.h
* src/DHTReplaceNodeTask.cc
* src/DHTReplaceNodeTask.h
Diffstat (limited to 'src/DHTPingTask.cc')
| -rw-r--r-- | src/DHTPingTask.cc | 23 |
1 files changed, 14 insertions, 9 deletions
diff --git a/src/DHTPingTask.cc b/src/DHTPingTask.cc index c13e6227..cdae2948 100644 --- a/src/DHTPingTask.cc +++ b/src/DHTPingTask.cc @@ -42,7 +42,8 @@ namespace aria2 { -DHTPingTask::DHTPingTask(const SharedHandle<DHTNode>& remoteNode, size_t numMaxRetry): +DHTPingTask::DHTPingTask +(const SharedHandle<DHTNode>& remoteNode, size_t numMaxRetry): _remoteNode(remoteNode), _numMaxRetry(numMaxRetry), _numRetry(0), @@ -54,16 +55,18 @@ DHTPingTask::~DHTPingTask() {} void DHTPingTask::startup() { - SharedHandle<DHTMessage> m = _factory->createPingMessage(_remoteNode); + SharedHandle<DHTMessage> m = + getMessageFactory()->createPingMessage(_remoteNode); WeakHandle<DHTMessageCallbackListener> listener(this); - SharedHandle<DHTMessageCallback> callback(new DHTMessageCallbackImpl(listener)); - _dispatcher->addMessageToQueue(m, _timeout, callback); + SharedHandle<DHTMessageCallback> callback + (new DHTMessageCallbackImpl(listener)); + getMessageDispatcher()->addMessageToQueue(m, _timeout, callback); } void DHTPingTask::onReceived(const SharedHandle<DHTMessage>& message) { _pingSuccessful = true; - _finished = true; + setFinished(true); } void DHTPingTask::onTimeout(const SharedHandle<DHTNode>& node) @@ -71,12 +74,14 @@ void DHTPingTask::onTimeout(const SharedHandle<DHTNode>& node) ++_numRetry; if(_numRetry >= _numMaxRetry) { _pingSuccessful = false; - _finished = true; + setFinished(true); } else { - SharedHandle<DHTMessage> m = _factory->createPingMessage(_remoteNode); + SharedHandle<DHTMessage> m = + getMessageFactory()->createPingMessage(_remoteNode); WeakHandle<DHTMessageCallbackListener> listener(this); - SharedHandle<DHTMessageCallback> callback(new DHTMessageCallbackImpl(listener)); - _dispatcher->addMessageToQueue(m, _timeout, callback); + SharedHandle<DHTMessageCallback> callback + (new DHTMessageCallbackImpl(listener)); + getMessageDispatcher()->addMessageToQueue(m, _timeout, callback); } } |