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/DHTBucketRefreshTask.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/DHTBucketRefreshTask.cc')
| -rw-r--r-- | src/DHTBucketRefreshTask.cc | 19 |
1 files changed, 10 insertions, 9 deletions
diff --git a/src/DHTBucketRefreshTask.cc b/src/DHTBucketRefreshTask.cc index 29baec72..3640297d 100644 --- a/src/DHTBucketRefreshTask.cc +++ b/src/DHTBucketRefreshTask.cc @@ -52,7 +52,7 @@ DHTBucketRefreshTask::~DHTBucketRefreshTask() {} void DHTBucketRefreshTask::startup() { std::vector<SharedHandle<DHTBucket> > buckets; - _routingTable->getBuckets(buckets); + getRoutingTable()->getBuckets(buckets); for(std::vector<SharedHandle<DHTBucket> >::iterator i = buckets.begin(), eoi = buckets.end(); i != eoi; ++i) { if(_forceRefresh || (*i)->needsRefresh()) { @@ -60,17 +60,18 @@ void DHTBucketRefreshTask::startup() unsigned char targetID[DHT_ID_LENGTH]; (*i)->getRandomNodeID(targetID); SharedHandle<DHTNodeLookupTask> task(new DHTNodeLookupTask(targetID)); - task->setRoutingTable(_routingTable); - task->setMessageDispatcher(_dispatcher); - task->setMessageFactory(_factory); - task->setTaskQueue(_taskQueue); - task->setLocalNode(_localNode); + task->setRoutingTable(getRoutingTable()); + task->setMessageDispatcher(getMessageDispatcher()); + task->setMessageFactory(getMessageFactory()); + task->setTaskQueue(getTaskQueue()); + task->setLocalNode(getLocalNode()); - _logger->info("Dispating bucket refresh. targetID=%s", util::toHex(targetID, DHT_ID_LENGTH).c_str()); - _taskQueue->addPeriodicTask1(task); + getLogger()->info("Dispating bucket refresh. targetID=%s", + util::toHex(targetID, DHT_ID_LENGTH).c_str()); + getTaskQueue()->addPeriodicTask1(task); } } - _finished = true; + setFinished(true); } void DHTBucketRefreshTask::setForceRefresh(bool forceRefresh) |