diff options
| author | Tatsuhiro Tsujikawa <tatsuhiro.t@gmail.com> | 2015-06-08 02:03:31 +0900 |
|---|---|---|
| committer | Tatsuhiro Tsujikawa <tatsuhiro.t@gmail.com> | 2015-06-09 02:05:34 +0900 |
| commit | 99cd73c0926f0c07d27777fde2f15816e8040030 (patch) | |
| tree | 7c6a077b0590c49029c76686afb9c2ab1d00bb6d /src/PeerInteractionCommand.cc | |
| parent | 2874f6ab095a30a4d297cdc85fa3730bec41b1c2 (diff) | |
Replace timer facility with chrono lib
Diffstat (limited to 'src/PeerInteractionCommand.cc')
| -rw-r--r-- | src/PeerInteractionCommand.cc | 13 |
1 files changed, 7 insertions, 6 deletions
diff --git a/src/PeerInteractionCommand.cc b/src/PeerInteractionCommand.cc index 022cee14..a7deb295 100644 --- a/src/PeerInteractionCommand.cc +++ b/src/PeerInteractionCommand.cc @@ -102,7 +102,8 @@ PeerInteractionCommand::PeerInteractionCommand if(sequence_ == INITIATOR_SEND_HANDSHAKE) { disableReadCheckSocket(); setWriteCheckSocket(getSocket()); - setTimeout(getOption()->getAsInt(PREF_PEER_CONNECTION_TIMEOUT)); + setTimeout(std::chrono::seconds( + getOption()->getAsInt(PREF_PEER_CONNECTION_TIMEOUT))); } int family; @@ -180,8 +181,8 @@ PeerInteractionCommand::PeerInteractionCommand dispatcher->setCuid(cuid); dispatcher->setPeer(getPeer()); dispatcher->setDownloadContext(requestGroup_->getDownloadContext().get()); - dispatcher->setRequestTimeout(getOption()-> - getAsInt(PREF_BT_REQUEST_TIMEOUT)); + dispatcher->setRequestTimeout( + std::chrono::seconds(getOption()->getAsInt(PREF_BT_REQUEST_TIMEOUT))); dispatcher->setBtMessageFactory(factory.get()); dispatcher->setRequestGroupMan (getDownloadEngine()->getRequestGroupMan().get()); @@ -227,7 +228,7 @@ PeerInteractionCommand::PeerInteractionCommand (std::move(extensionMessageFactory)); btInteractive->setExtensionMessageRegistry(std::move(exMsgRegistry)); btInteractive->setKeepAliveInterval - (getOption()->getAsInt(PREF_BT_KEEP_ALIVE_INTERVAL)); + (std::chrono::seconds(getOption()->getAsInt(PREF_BT_KEEP_ALIVE_INTERVAL))); btInteractive->setRequestGroupMan (getDownloadEngine()->getRequestGroupMan().get()); btInteractive->setBtMessageFactory(std::move(factory)); @@ -307,7 +308,7 @@ bool PeerInteractionCommand::executeInternal() { disableWriteCheckSocket(); setReadCheckSocket(getSocket()); //socket->setBlockingMode(); - setTimeout(getOption()->getAsInt(PREF_BT_TIMEOUT)); + setTimeout(std::chrono::seconds(getOption()->getAsInt(PREF_BT_TIMEOUT))); btInteractive_->initiateHandshake(); sequence_ = INITIATOR_WAIT_HANDSHAKE; break; @@ -403,7 +404,7 @@ void PeerInteractionCommand::onFailure(const Exception& err) { requestGroup_->setLastErrorCode(err.getErrorCode()); requestGroup_->setHaltRequested(true); - getDownloadEngine()->setRefreshInterval(0); + getDownloadEngine()->setRefreshInterval(std::chrono::milliseconds(0)); } bool PeerInteractionCommand::exitBeforeExecute() |