summaryrefslogtreecommitdiff
path: root/src/AbstractHttpServerResponseCommand.cc
diff options
context:
space:
mode:
authorTatsuhiro Tsujikawa <tatsuhiro.t@gmail.com>2015-12-27 18:39:47 +0900
committerTatsuhiro Tsujikawa <tatsuhiro.t@gmail.com>2015-12-27 18:40:08 +0900
commitb1132d6b10cd3791b9529d7031d723fd0e2d8215 (patch)
tree9ce465b42bf09372118335c7c619bb2b41869eaf /src/AbstractHttpServerResponseCommand.cc
parent4abad2f64c9ff80144a61c5a9c2bea144852b883 (diff)
make clang-format using clang-format-3.6
Diffstat (limited to 'src/AbstractHttpServerResponseCommand.cc')
-rw-r--r--src/AbstractHttpServerResponseCommand.cc62
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;