summaryrefslogtreecommitdiff
path: root/src/DefaultPieceStorage.cc
diff options
context:
space:
mode:
authorTatsuhiro Tsujikawa <tatsuhiro.t@gmail.com>2012-09-28 23:27:46 +0900
committerTatsuhiro Tsujikawa <tatsuhiro.t@gmail.com>2012-09-28 23:27:46 +0900
commit3258614033aaf8288dc4b14275c72a1bb3b65a7e (patch)
tree4a877d5d2920570d9436403e94dcf0c6345401aa /src/DefaultPieceStorage.cc
parent1c57a3ff9f5021a40aca1fec2583f6245f3a4581 (diff)
Removed *Handle typedef
Diffstat (limited to 'src/DefaultPieceStorage.cc')
-rw-r--r--src/DefaultPieceStorage.cc16
1 files changed, 8 insertions, 8 deletions
diff --git a/src/DefaultPieceStorage.cc b/src/DefaultPieceStorage.cc
index a59a20a1..de179bad 100644
--- a/src/DefaultPieceStorage.cc
+++ b/src/DefaultPieceStorage.cc
@@ -613,25 +613,25 @@ void DefaultPieceStorage::initStorage()
{
if(downloadContext_->getFileEntries().size() == 1) {
A2_LOG_DEBUG("Instantiating DirectDiskAdaptor");
- DirectDiskAdaptorHandle directDiskAdaptor(new DirectDiskAdaptor());
+ DirectDiskAdaptor* directDiskAdaptor(new DirectDiskAdaptor());
directDiskAdaptor->setTotalLength(downloadContext_->getTotalLength());
directDiskAdaptor->setFileEntries
(downloadContext_->getFileEntries().begin(),
downloadContext_->getFileEntries().end());
- DiskWriterHandle writer =
+ SharedHandle<DiskWriter> writer =
diskWriterFactory_->newDiskWriter(directDiskAdaptor->getFilePath());
directDiskAdaptor->setDiskWriter(writer);
- diskAdaptor_ = directDiskAdaptor;
+ diskAdaptor_.reset(directDiskAdaptor);
} else {
A2_LOG_DEBUG("Instantiating MultiDiskAdaptor");
- MultiDiskAdaptorHandle multiDiskAdaptor(new MultiDiskAdaptor());
+ MultiDiskAdaptor* multiDiskAdaptor(new MultiDiskAdaptor());
multiDiskAdaptor->setFileEntries(downloadContext_->getFileEntries().begin(),
downloadContext_->getFileEntries().end());
multiDiskAdaptor->setPieceLength(downloadContext_->getPieceLength());
multiDiskAdaptor->setMaxOpenFiles
(option_->getAsInt(PREF_BT_MAX_OPEN_FILES));
- diskAdaptor_ = multiDiskAdaptor;
+ diskAdaptor_.reset(multiDiskAdaptor);
}
if(option_->get(PREF_FILE_ALLOCATION) == V_FALLOC) {
diskAdaptor_->setFileAllocationMethod(DiskAdaptor::FILE_ALLOC_FALLOC);
@@ -657,7 +657,7 @@ const unsigned char* DefaultPieceStorage::getBitfield()
return bitfieldMan_->getBitfield();
}
-DiskAdaptorHandle DefaultPieceStorage::getDiskAdaptor() {
+SharedHandle<DiskAdaptor> DefaultPieceStorage::getDiskAdaptor() {
return diskAdaptor_;
}
@@ -741,7 +741,7 @@ void DefaultPieceStorage::markPiecesDone(int64_t length)
if(r > 0) {
SharedHandle<Piece> p
(new Piece(numPiece, bitfieldMan_->getBlockLength(numPiece)));
-
+
for(size_t i = 0; i < r; ++i) {
p->completeBlock(i);
}
@@ -780,7 +780,7 @@ void DefaultPieceStorage::getInFlightPieces
}
void DefaultPieceStorage::setDiskWriterFactory
-(const DiskWriterFactoryHandle& diskWriterFactory)
+(const SharedHandle<DiskWriterFactory>& diskWriterFactory)
{
diskWriterFactory_ = diskWriterFactory;
}