diff options
| author | Tatsuhiro Tsujikawa <tatsuhiro.t@gmail.com> | 2008-06-15 16:27:12 +0000 |
|---|---|---|
| committer | Tatsuhiro Tsujikawa <tatsuhiro.t@gmail.com> | 2008-06-15 16:27:12 +0000 |
| commit | e32eb83c9988493f4acbfa48bf03a85201e0462f (patch) | |
| tree | 0f2ed63b8c5a5325be0e4e8d002292fc8d1e99aa /src/PeerInteractionCommand.cc | |
| parent | 2f8e184fe5c8b8264fd0219ba2001be84c148d54 (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.cc | 4 |
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) { |
