diff options
Diffstat (limited to 'src/DHTInteractionCommand.cc')
| -rw-r--r-- | src/DHTInteractionCommand.cc | 28 |
1 files changed, 14 insertions, 14 deletions
diff --git a/src/DHTInteractionCommand.cc b/src/DHTInteractionCommand.cc index 2302cc17..347b8ec9 100644 --- a/src/DHTInteractionCommand.cc +++ b/src/DHTInteractionCommand.cc @@ -54,61 +54,61 @@ namespace aria2 { DHTInteractionCommand::DHTInteractionCommand(cuid_t cuid, DownloadEngine* e): Command(cuid), - _e(e) {} + e_(e) {} DHTInteractionCommand::~DHTInteractionCommand() { - disableReadCheckSocket(_readCheckSocket); + disableReadCheckSocket(readCheckSocket_); } void DHTInteractionCommand::setReadCheckSocket(const SocketHandle& socket) { - _readCheckSocket = socket; - _e->addSocketForReadCheck(socket, this); + readCheckSocket_ = socket; + e_->addSocketForReadCheck(socket, this); } void DHTInteractionCommand::disableReadCheckSocket(const SocketHandle& socket) { - _e->deleteSocketForReadCheck(socket, this); + e_->deleteSocketForReadCheck(socket, this); } bool DHTInteractionCommand::execute() { - if(_e->getRequestGroupMan()->downloadFinished() || _e->isHaltRequested()) { + if(e_->getRequestGroupMan()->downloadFinished() || e_->isHaltRequested()) { return true; } - _taskQueue->executeTask(); + taskQueue_->executeTask(); for(size_t i = 0; i < 20; ++i) { - SharedHandle<DHTMessage> m = _receiver->receiveMessage(); + SharedHandle<DHTMessage> m = receiver_->receiveMessage(); if(m.isNull()) { break; } } - _receiver->handleTimeout(); + receiver_->handleTimeout(); try { - _dispatcher->sendMessages(); + dispatcher_->sendMessages(); } catch(RecoverableException& e) { getLogger()->error(EX_EXCEPTION_CAUGHT, e); } - _e->addCommand(this); + e_->addCommand(this); return false; } void DHTInteractionCommand::setMessageDispatcher(const SharedHandle<DHTMessageDispatcher>& dispatcher) { - _dispatcher = dispatcher; + dispatcher_ = dispatcher; } void DHTInteractionCommand::setMessageReceiver(const SharedHandle<DHTMessageReceiver>& receiver) { - _receiver = receiver; + receiver_ = receiver; } void DHTInteractionCommand::setTaskQueue(const SharedHandle<DHTTaskQueue>& taskQueue) { - _taskQueue = taskQueue; + taskQueue_ = taskQueue; } } // namespace aria2 |
