summaryrefslogtreecommitdiff
path: root/src/PeerAbstractCommand.cc
diff options
context:
space:
mode:
authorTatsuhiro Tsujikawa <tatsuhiro.t@gmail.com>2010-01-05 16:01:46 +0000
committerTatsuhiro Tsujikawa <tatsuhiro.t@gmail.com>2010-01-05 16:01:46 +0000
commit4db349c1f32b4a313d12d114137432441633d00a (patch)
tree417451971e264834312cfd8339c79930d680a5d1 /src/PeerAbstractCommand.cc
parent338e8aca09331d3e7fa4e1e8e1f9d10260986772 (diff)
2010-01-06 Tatsuhiro Tsujikawa <t-tujikawa@users.sourceforge.net>
Untabify. Fixed one line in copyright which is longer than 80 columns. * src * test
Diffstat (limited to 'src/PeerAbstractCommand.cc')
-rw-r--r--src/PeerAbstractCommand.cc30
1 files changed, 15 insertions, 15 deletions
diff --git a/src/PeerAbstractCommand.cc b/src/PeerAbstractCommand.cc
index dcb1a320..49ebd97b 100644
--- a/src/PeerAbstractCommand.cc
+++ b/src/PeerAbstractCommand.cc
@@ -16,7 +16,7 @@
*
* You should have received a copy of the GNU General Public License
* along with this program; if not, write to the Free Software
- * Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA
+ * Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA
*
* In addition, as a special exception, the copyright holders give
* permission to link the code of portions of this program with the
@@ -47,9 +47,9 @@
namespace aria2 {
PeerAbstractCommand::PeerAbstractCommand(int32_t cuid,
- const PeerHandle& peer,
- DownloadEngine* e,
- const SocketHandle& s):
+ const PeerHandle& peer,
+ DownloadEngine* e,
+ const SocketHandle& s):
Command(cuid),
e(e),
socket(s),
@@ -74,8 +74,8 @@ PeerAbstractCommand::~PeerAbstractCommand()
bool PeerAbstractCommand::execute()
{
logger->debug("CUID#%d -"
- " socket: read:%d, write:%d, hup:%d, err:%d, noCheck:%d",
- cuid, _readEvent, _writeEvent, _hupEvent, _errorEvent, noCheck);
+ " socket: read:%d, write:%d, hup:%d, err:%d, noCheck:%d",
+ cuid, _readEvent, _writeEvent, _hupEvent, _errorEvent, noCheck);
if(exitBeforeExecute()) {
onAbort();
return true;
@@ -88,8 +88,8 @@ bool PeerAbstractCommand::execute()
checkPoint.reset();
} else if(_errorEvent) {
throw DL_ABORT_EX
- (StringFormat(MSG_NETWORK_PROBLEM,
- socket->getSocketError().c_str()).str());
+ (StringFormat(MSG_NETWORK_PROBLEM,
+ socket->getSocketError().c_str()).str());
}
if(checkPoint.elapsed(timeout)) {
throw DL_ABORT_EX(EX_TIME_OUT);
@@ -103,7 +103,7 @@ bool PeerAbstractCommand::execute()
} catch(RecoverableException& err) {
logger->debug(MSG_TORRENT_DOWNLOAD_ABORTED, err, cuid);
logger->debug(MSG_PEER_BANNED,
- cuid, peer->ipaddr.c_str(), peer->port);
+ cuid, peer->ipaddr.c_str(), peer->port);
onAbort();
return prepareForNextPeer(0);
}
@@ -131,9 +131,9 @@ void PeerAbstractCommand::setReadCheckSocket(const SocketHandle& socket)
} else {
if(checkSocketIsReadable) {
if(readCheckTarget != socket) {
- e->deleteSocketForReadCheck(readCheckTarget, this);
- e->addSocketForReadCheck(socket, this);
- readCheckTarget = socket;
+ e->deleteSocketForReadCheck(readCheckTarget, this);
+ e->addSocketForReadCheck(socket, this);
+ readCheckTarget = socket;
}
} else {
e->addSocketForReadCheck(socket, this);
@@ -159,9 +159,9 @@ void PeerAbstractCommand::setWriteCheckSocket(const SocketHandle& socket)
} else {
if(checkSocketIsWritable) {
if(writeCheckTarget != socket) {
- e->deleteSocketForWriteCheck(writeCheckTarget, this);
- e->addSocketForWriteCheck(socket, this);
- writeCheckTarget = socket;
+ e->deleteSocketForWriteCheck(writeCheckTarget, this);
+ e->addSocketForWriteCheck(socket, this);
+ writeCheckTarget = socket;
}
} else {
e->addSocketForWriteCheck(socket, this);