diff options
| author | Tatsuhiro Tsujikawa <tatsuhiro.t@gmail.com> | 2015-12-27 18:39:47 +0900 |
|---|---|---|
| committer | Tatsuhiro Tsujikawa <tatsuhiro.t@gmail.com> | 2015-12-27 18:40:08 +0900 |
| commit | b1132d6b10cd3791b9529d7031d723fd0e2d8215 (patch) | |
| tree | 9ce465b42bf09372118335c7c619bb2b41869eaf /src/AbstractHttpServerResponseCommand.cc | |
| parent | 4abad2f64c9ff80144a61c5a9c2bea144852b883 (diff) | |
make clang-format using clang-format-3.6
Diffstat (limited to 'src/AbstractHttpServerResponseCommand.cc')
| -rw-r--r-- | src/AbstractHttpServerResponseCommand.cc | 62 |
1 files changed, 32 insertions, 30 deletions
diff --git a/src/AbstractHttpServerResponseCommand.cc b/src/AbstractHttpServerResponseCommand.cc index 057e74fa..80923ae9 100644 --- a/src/AbstractHttpServerResponseCommand.cc +++ b/src/AbstractHttpServerResponseCommand.cc @@ -47,17 +47,15 @@ namespace aria2 { -AbstractHttpServerResponseCommand::AbstractHttpServerResponseCommand -(cuid_t cuid, - const std::shared_ptr<HttpServer>& httpServer, - DownloadEngine* e, - const std::shared_ptr<SocketCore>& socket) - : Command(cuid), - e_(e), - socket_(socket), - httpServer_(httpServer), - readCheck_(false), - writeCheck_(true) +AbstractHttpServerResponseCommand::AbstractHttpServerResponseCommand( + cuid_t cuid, const std::shared_ptr<HttpServer>& httpServer, + DownloadEngine* e, const std::shared_ptr<SocketCore>& socket) + : Command(cuid), + e_(e), + socket_(socket), + httpServer_(httpServer), + readCheck_(false), + writeCheck_(true) { setStatus(Command::STATUS_ONESHOT_REALTIME); e_->addSocketForWriteCheck(socket_, this); @@ -65,31 +63,33 @@ AbstractHttpServerResponseCommand::AbstractHttpServerResponseCommand AbstractHttpServerResponseCommand::~AbstractHttpServerResponseCommand() { - if(readCheck_) { + if (readCheck_) { e_->deleteSocketForReadCheck(socket_, this); } - if(writeCheck_) { + if (writeCheck_) { e_->deleteSocketForWriteCheck(socket_, this); } } void AbstractHttpServerResponseCommand::updateReadWriteCheck() { - if(httpServer_->wantRead()) { - if(!readCheck_) { + if (httpServer_->wantRead()) { + if (!readCheck_) { readCheck_ = true; e_->addSocketForReadCheck(socket_, this); } - } else if(readCheck_) { + } + else if (readCheck_) { readCheck_ = false; e_->deleteSocketForReadCheck(socket_, this); } - if(httpServer_->wantWrite()) { - if(!writeCheck_) { + if (httpServer_->wantWrite()) { + if (!writeCheck_) { writeCheck_ = true; e_->addSocketForWriteCheck(socket_, this); } - } else if(writeCheck_) { + } + else if (writeCheck_) { writeCheck_ = false; e_->deleteSocketForWriteCheck(socket_, this); } @@ -97,34 +97,36 @@ void AbstractHttpServerResponseCommand::updateReadWriteCheck() bool AbstractHttpServerResponseCommand::execute() { - if(e_->getRequestGroupMan()->downloadFinished() || e_->isHaltRequested()) { + if (e_->getRequestGroupMan()->downloadFinished() || e_->isHaltRequested()) { return true; } try { ssize_t len = httpServer_->sendResponse(); - if(len > 0) { + if (len > 0) { timeoutTimer_ = global::wallclock(); } - } catch(RecoverableException& e) { - A2_LOG_INFO_EX - (fmt("CUID#%" PRId64 - " - Error occurred while transmitting response body.", - getCuid()), - e); + } + catch (RecoverableException& e) { + A2_LOG_INFO_EX(fmt("CUID#%" PRId64 + " - Error occurred while transmitting response body.", + getCuid()), + e); return true; } - if(httpServer_->sendBufferIsEmpty()) { + if (httpServer_->sendBufferIsEmpty()) { A2_LOG_INFO(fmt("CUID#%" PRId64 " - HttpServer: all response transmitted.", getCuid())); afterSend(httpServer_, e_); return true; - } else { + } + else { if (timeoutTimer_.difference(global::wallclock()) >= 30_s) { A2_LOG_INFO(fmt("CUID#%" PRId64 " - HttpServer: Timeout while trasmitting response.", getCuid())); return true; - } else { + } + else { updateReadWriteCheck(); e_->addCommand(std::unique_ptr<Command>(this)); return false; |
