summaryrefslogtreecommitdiff
path: root/src/WebSocketInteractionCommand.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/WebSocketInteractionCommand.cc
parent4abad2f64c9ff80144a61c5a9c2bea144852b883 (diff)
make clang-format using clang-format-3.6
Diffstat (limited to 'src/WebSocketInteractionCommand.cc')
-rw-r--r--src/WebSocketInteractionCommand.cc45
1 files changed, 23 insertions, 22 deletions
diff --git a/src/WebSocketInteractionCommand.cc b/src/WebSocketInteractionCommand.cc
index 270726ad..b1ae6217 100644
--- a/src/WebSocketInteractionCommand.cc
+++ b/src/WebSocketInteractionCommand.cc
@@ -48,16 +48,14 @@ namespace aria2 {
namespace rpc {
-WebSocketInteractionCommand::WebSocketInteractionCommand
-(cuid_t cuid,
- const std::shared_ptr<WebSocketSession>& wsSession,
- DownloadEngine* e,
- const std::shared_ptr<SocketCore>& socket)
- : Command(cuid),
- e_(e),
- socket_(socket),
- writeCheck_(false),
- wsSession_(wsSession)
+WebSocketInteractionCommand::WebSocketInteractionCommand(
+ cuid_t cuid, const std::shared_ptr<WebSocketSession>& wsSession,
+ DownloadEngine* e, const std::shared_ptr<SocketCore>& socket)
+ : Command(cuid),
+ e_(e),
+ socket_(socket),
+ writeCheck_(false),
+ wsSession_(wsSession)
{
e_->getWebSocketSessionMan()->addSession(wsSession_);
e_->addSocketForReadCheck(socket_, this);
@@ -66,7 +64,7 @@ WebSocketInteractionCommand::WebSocketInteractionCommand
WebSocketInteractionCommand::~WebSocketInteractionCommand()
{
e_->deleteSocketForReadCheck(socket_, this);
- if(writeCheck_) {
+ if (writeCheck_) {
e_->deleteSocketForWriteCheck(socket_, this);
}
e_->getWebSocketSessionMan()->removeSession(wsSession_);
@@ -74,12 +72,13 @@ WebSocketInteractionCommand::~WebSocketInteractionCommand()
void WebSocketInteractionCommand::updateWriteCheck()
{
- if(socket_->wantWrite() || wsSession_->wantWrite()) {
- if(!writeCheck_) {
+ if (socket_->wantWrite() || wsSession_->wantWrite()) {
+ if (!writeCheck_) {
writeCheck_ = true;
e_->addSocketForWriteCheck(socket_, this);
}
- } else if(writeCheck_) {
+ }
+ else if (writeCheck_) {
writeCheck_ = false;
e_->deleteSocketForWriteCheck(socket_, this);
}
@@ -87,20 +86,22 @@ void WebSocketInteractionCommand::updateWriteCheck()
bool WebSocketInteractionCommand::execute()
{
- if(e_->isHaltRequested()) {
+ if (e_->isHaltRequested()) {
return true;
}
- if(wsSession_->onReadEvent() == -1 || wsSession_->onWriteEvent() == -1) {
- if(wsSession_->closeSent() || wsSession_->closeReceived()) {
- A2_LOG_INFO(fmt("CUID#%" PRId64 " - WebSocket session terminated.",
- getCuid()));
- } else {
+ if (wsSession_->onReadEvent() == -1 || wsSession_->onWriteEvent() == -1) {
+ if (wsSession_->closeSent() || wsSession_->closeReceived()) {
+ A2_LOG_INFO(
+ fmt("CUID#%" PRId64 " - WebSocket session terminated.", getCuid()));
+ }
+ else {
A2_LOG_INFO(fmt("CUID#%" PRId64 " - WebSocket session terminated"
- " (Possibly due to EOF).", getCuid()));
+ " (Possibly due to EOF).",
+ getCuid()));
}
return true;
}
- if(wsSession_->finish()) {
+ if (wsSession_->finish()) {
return true;
}
updateWriteCheck();