summaryrefslogtreecommitdiff
path: root/src/PeerInteractionCommand.cc
diff options
context:
space:
mode:
authorTatsuhiro Tsujikawa <tatsuhiro.t@gmail.com>2008-06-15 16:27:12 +0000
committerTatsuhiro Tsujikawa <tatsuhiro.t@gmail.com>2008-06-15 16:27:12 +0000
commite32eb83c9988493f4acbfa48bf03a85201e0462f (patch)
tree0f2ed63b8c5a5325be0e4e8d002292fc8d1e99aa /src/PeerInteractionCommand.cc
parent2f8e184fe5c8b8264fd0219ba2001be84c148d54 (diff)
2008-06-16 Tatsuhiro Tsujikawa <tujikawa at rednoah dot com>
Added writable test for Socket when the sending message is in progress. Usually the sending message is piece message. Without wriable check, upload latency is dropped to more than 1sec. * src/PeerInteractionCommand.cc
Diffstat (limited to 'src/PeerInteractionCommand.cc')
-rw-r--r--src/PeerInteractionCommand.cc4
1 files changed, 4 insertions, 0 deletions
diff --git a/src/PeerInteractionCommand.cc b/src/PeerInteractionCommand.cc
index fda2f195..d1e5fa5c 100644
--- a/src/PeerInteractionCommand.cc
+++ b/src/PeerInteractionCommand.cc
@@ -222,6 +222,7 @@ bool PeerInteractionCommand::executeInternal() {
break;
}
case WIRED:
+ disableWriteCheckSocket();
btInteractive->doInteractionProcessing();
if(btInteractive->countReceivedMessageInIteration() > 0) {
updateKeepAlive();
@@ -242,6 +243,9 @@ bool PeerInteractionCommand::executeInternal() {
} else {
disableReadCheckSocket();
}
+ if(btInteractive->isSendingMessageInProgress()) {
+ setWriteCheckSocket(socket);
+ }
break;
}
if(btInteractive->countPendingMessage() > 0) {