From ded040666efa013fccbe67b26700477359af7d23 Mon Sep 17 00:00:00 2001
From: Tatsuhiro Tsujikawa <tatsuhiro.t@gmail.com>
Date: Sat, 12 Jun 2010 02:54:39 +0000
Subject: 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
---
 src/DHTReplaceNodeTask.cc | 27 +++++++++++++++------------
 1 file changed, 15 insertions(+), 12 deletions(-)

(limited to 'src/DHTReplaceNodeTask.cc')

diff --git a/src/DHTReplaceNodeTask.cc b/src/DHTReplaceNodeTask.cc
index d9c9512f..d9c68bc6 100644
--- a/src/DHTReplaceNodeTask.cc
+++ b/src/DHTReplaceNodeTask.cc
@@ -62,34 +62,37 @@ void DHTReplaceNodeTask::sendMessage()
 {
   SharedHandle<DHTNode> questionableNode = _bucket->getLRUQuestionableNode();
   if(questionableNode.isNull()) {
-    _finished = true;
+    setFinished(true);
   } else {
-    SharedHandle<DHTMessage> m = _factory->createPingMessage(questionableNode);
+    SharedHandle<DHTMessage> m =
+      getMessageFactory()->createPingMessage(questionableNode);
     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 DHTReplaceNodeTask::onReceived(const SharedHandle<DHTMessage>& message)
 {
-  _logger->info("ReplaceNode: Ping reply received from %s.",
-                message->getRemoteNode()->toString().c_str());
-  _finished = true;
+  getLogger()->info("ReplaceNode: Ping reply received from %s.",
+                    message->getRemoteNode()->toString().c_str());
+  setFinished(true);
 }
 
 void DHTReplaceNodeTask::onTimeout(const SharedHandle<DHTNode>& node)
 {
   ++_numRetry;
   if(_numRetry >= MAX_RETRY) {
-    _logger->info("ReplaceNode: Ping failed %u times. Replace %s with %s.",
-                  _numRetry, node->toString().c_str(), _newNode->toString().c_str());
+    getLogger()->info("ReplaceNode: Ping failed %u times. Replace %s with %s.",
+                      _numRetry, node->toString().c_str(),
+                      _newNode->toString().c_str());
     node->markBad();
     _bucket->addNode(_newNode);
-    _finished = true;
+    setFinished(true);
   } else {
-    _logger->info("ReplaceNode: Ping reply timeout from %s. Try once more.",
-                  node->toString().c_str());
+    getLogger()->info("ReplaceNode: Ping reply timeout from %s. Try once more.",
+                      node->toString().c_str());
     sendMessage();
   }
 }
-- 
cgit