summaryrefslogtreecommitdiff
path: root/src/DefaultBtMessageDispatcher.cc
diff options
context:
space:
mode:
authorTatsuhiro Tsujikawa <tatsuhiro.t@gmail.com>2013-06-22 01:10:38 +0900
committerTatsuhiro Tsujikawa <tatsuhiro.t@gmail.com>2013-06-22 01:10:38 +0900
commit07d270c87e6f9184aea4ca17eb26e466712e8db2 (patch)
tree2dfbaa2e0d2ad0f38cb73098608f7d67a64320f8 /src/DefaultBtMessageDispatcher.cc
parent126a4bde612eb0e6c48cf2f13ebe3eac45cc71a8 (diff)
Require -std=c++11 and use std::shared_ptr instead of SharedHandle
Diffstat (limited to 'src/DefaultBtMessageDispatcher.cc')
-rw-r--r--src/DefaultBtMessageDispatcher.cc56
1 files changed, 28 insertions, 28 deletions
diff --git a/src/DefaultBtMessageDispatcher.cc b/src/DefaultBtMessageDispatcher.cc
index bc236350..ac7d4d8a 100644
--- a/src/DefaultBtMessageDispatcher.cc
+++ b/src/DefaultBtMessageDispatcher.cc
@@ -73,16 +73,16 @@ DefaultBtMessageDispatcher::~DefaultBtMessageDispatcher()
}
void DefaultBtMessageDispatcher::addMessageToQueue
-(const SharedHandle<BtMessage>& btMessage)
+(const std::shared_ptr<BtMessage>& btMessage)
{
btMessage->onQueued();
messageQueue_.push_back(btMessage);
}
void DefaultBtMessageDispatcher::addMessageToQueue
-(const std::vector<SharedHandle<BtMessage> >& btMessages)
+(const std::vector<std::shared_ptr<BtMessage> >& btMessages)
{
- for(std::vector<SharedHandle<BtMessage> >::const_iterator itr =
+ for(std::vector<std::shared_ptr<BtMessage> >::const_iterator itr =
btMessages.begin(), eoi = btMessages.end(); itr != eoi; ++itr) {
addMessageToQueue(*itr);
}
@@ -90,9 +90,9 @@ void DefaultBtMessageDispatcher::addMessageToQueue
void DefaultBtMessageDispatcher::sendMessagesInternal()
{
- std::vector<SharedHandle<BtMessage> > tempQueue;
+ std::vector<std::shared_ptr<BtMessage> > tempQueue;
while(!messageQueue_.empty()) {
- SharedHandle<BtMessage> msg = messageQueue_.front();
+ std::shared_ptr<BtMessage> msg = messageQueue_.front();
messageQueue_.pop_front();
if(msg->isUploading()) {
if(requestGroupMan_->doesOverallUploadSpeedExceed() ||
@@ -123,7 +123,7 @@ void DefaultBtMessageDispatcher::doCancelSendingPieceAction
{
BtCancelSendingPieceEvent event(index, begin, length);
- std::vector<SharedHandle<BtMessage> > tempQueue
+ std::vector<std::shared_ptr<BtMessage> > tempQueue
(messageQueue_.begin(), messageQueue_.end());
forEachMemFunSH(tempQueue.begin(), tempQueue.end(),
@@ -133,13 +133,13 @@ void DefaultBtMessageDispatcher::doCancelSendingPieceAction
// Cancel sending piece message to peer.
// TODO Is this method really necessary?
void DefaultBtMessageDispatcher::doCancelSendingPieceAction
-(const SharedHandle<Piece>& piece)
+(const std::shared_ptr<Piece>& piece)
{
}
namespace {
void abortOutstandingRequest
-(const RequestSlot& slot, const SharedHandle<Piece>& piece, cuid_t cuid)
+(const RequestSlot& slot, const std::shared_ptr<Piece>& piece, cuid_t cuid)
{
A2_LOG_DEBUG(fmt(MSG_DELETING_REQUEST_SLOT,
cuid,
@@ -163,7 +163,7 @@ struct FindRequestSlotByIndex {
// localhost cancels outstanding download requests to the peer.
void DefaultBtMessageDispatcher::doAbortOutstandingRequestAction
-(const SharedHandle<Piece>& piece) {
+(const std::shared_ptr<Piece>& piece) {
for(std::deque<RequestSlot>::iterator itr = requestSlots_.begin(),
eoi = requestSlots_.end(); itr != eoi; ++itr) {
if((*itr).getIndex() == piece->getIndex()) {
@@ -176,7 +176,7 @@ void DefaultBtMessageDispatcher::doAbortOutstandingRequestAction
BtAbortOutstandingRequestEvent event(piece);
- std::vector<SharedHandle<BtMessage> > tempQueue
+ std::vector<std::shared_ptr<BtMessage> > tempQueue
(messageQueue_.begin(), messageQueue_.end());
forEachMemFunSH(tempQueue.begin(), tempQueue.end(),
&BtMessage::onAbortOutstandingRequestEvent, event);
@@ -186,13 +186,13 @@ namespace {
class ProcessChokedRequestSlot {
private:
cuid_t cuid_;
- SharedHandle<Peer> peer_;
- SharedHandle<PieceStorage> pieceStorage_;
+ std::shared_ptr<Peer> peer_;
+ std::shared_ptr<PieceStorage> pieceStorage_;
public:
ProcessChokedRequestSlot
(cuid_t cuid,
- const SharedHandle<Peer>& peer,
- const SharedHandle<PieceStorage>& pieceStorage)
+ const std::shared_ptr<Peer>& peer,
+ const std::shared_ptr<PieceStorage>& pieceStorage)
: cuid_(cuid),
peer_(peer),
pieceStorage_(pieceStorage)
@@ -206,7 +206,7 @@ public:
static_cast<unsigned long>(slot.getIndex()),
slot.getBegin(),
static_cast<unsigned long>(slot.getBlockIndex())));
- SharedHandle<Piece> piece = pieceStorage_->getPiece(slot.getIndex());
+ std::shared_ptr<Piece> piece = pieceStorage_->getPiece(slot.getIndex());
piece->cancelBlock(slot.getBlockIndex());
}
}
@@ -217,9 +217,9 @@ public:
namespace {
class FindChokedRequestSlot {
private:
- SharedHandle<Peer> peer_;
+ std::shared_ptr<Peer> peer_;
public:
- FindChokedRequestSlot(const SharedHandle<Peer>& peer):
+ FindChokedRequestSlot(const std::shared_ptr<Peer>& peer):
peer_(peer) {}
bool operator()(const RequestSlot& slot) const
@@ -245,7 +245,7 @@ void DefaultBtMessageDispatcher::doChokingAction()
{
BtChokingEvent event;
- std::vector<SharedHandle<BtMessage> > tempQueue
+ std::vector<std::shared_ptr<BtMessage> > tempQueue
(messageQueue_.begin(), messageQueue_.end());
forEachMemFunSH(tempQueue.begin(), tempQueue.end(),
&BtMessage::onChokingEvent, event);
@@ -255,15 +255,15 @@ namespace {
class ProcessStaleRequestSlot {
private:
cuid_t cuid_;
- SharedHandle<Peer> peer_;
- SharedHandle<PieceStorage> pieceStorage_;
+ std::shared_ptr<Peer> peer_;
+ std::shared_ptr<PieceStorage> pieceStorage_;
BtMessageDispatcher* messageDispatcher_;
BtMessageFactory* messageFactory_;
time_t requestTimeout_;
public:
ProcessStaleRequestSlot
- (cuid_t cuid, const SharedHandle<Peer>& peer,
- const SharedHandle<PieceStorage>& pieceStorage,
+ (cuid_t cuid, const std::shared_ptr<Peer>& peer,
+ const std::shared_ptr<PieceStorage>& pieceStorage,
BtMessageDispatcher* dispatcher,
BtMessageFactory* factory,
time_t requestTimeout)
@@ -303,10 +303,10 @@ public:
namespace {
class FindStaleRequestSlot {
private:
- SharedHandle<PieceStorage> pieceStorage_;
+ std::shared_ptr<PieceStorage> pieceStorage_;
time_t requestTimeout_;
public:
- FindStaleRequestSlot(const SharedHandle<PieceStorage>& pieceStorage,
+ FindStaleRequestSlot(const std::shared_ptr<PieceStorage>& pieceStorage,
time_t requestTimeout):
pieceStorage_(pieceStorage),
requestTimeout_(requestTimeout) {}
@@ -411,25 +411,25 @@ size_t DefaultBtMessageDispatcher::countOutstandingUpload()
mem_fun_sh(&BtMessage::isUploading));
}
-void DefaultBtMessageDispatcher::setPeer(const SharedHandle<Peer>& peer)
+void DefaultBtMessageDispatcher::setPeer(const std::shared_ptr<Peer>& peer)
{
peer_ = peer;
}
void DefaultBtMessageDispatcher::setDownloadContext
-(const SharedHandle<DownloadContext>& downloadContext)
+(const std::shared_ptr<DownloadContext>& downloadContext)
{
downloadContext_ = downloadContext;
}
void DefaultBtMessageDispatcher::setPieceStorage
-(const SharedHandle<PieceStorage>& pieceStorage)
+(const std::shared_ptr<PieceStorage>& pieceStorage)
{
pieceStorage_ = pieceStorage;
}
void DefaultBtMessageDispatcher::setPeerStorage
-(const SharedHandle<PeerStorage>& peerStorage)
+(const std::shared_ptr<PeerStorage>& peerStorage)
{
peerStorage_ = peerStorage;
}