diff options
| author | Tatsuhiro Tsujikawa <tatsuhiro.t@gmail.com> | 2011-01-08 17:32:16 +0900 |
|---|---|---|
| committer | Tatsuhiro Tsujikawa <tatsuhiro.t@gmail.com> | 2011-01-09 18:34:06 +0900 |
| commit | ce2d401dce35b94c15120a4cac441a4614658e3d (patch) | |
| tree | d45875f961f3dcfdb5c7ad96419ef15886fd983e /src/PeerReceiveHandshakeCommand.cc | |
| parent | c48db2cdf3c194a979bb90e856914225b8ad02ca (diff) | |
Eliminated SocketCore::peekData from MSEHandshake.
Diffstat (limited to 'src/PeerReceiveHandshakeCommand.cc')
| -rw-r--r-- | src/PeerReceiveHandshakeCommand.cc | 7 |
1 files changed, 6 insertions, 1 deletions
diff --git a/src/PeerReceiveHandshakeCommand.cc b/src/PeerReceiveHandshakeCommand.cc index bddf352f..5af632a5 100644 --- a/src/PeerReceiveHandshakeCommand.cc +++ b/src/PeerReceiveHandshakeCommand.cc @@ -67,7 +67,12 @@ PeerReceiveHandshakeCommand::PeerReceiveHandshakeCommand : PeerAbstractCommand(cuid, peer, e, s), peerConnection_(peerConnection) { - if(!peerConnection_) { + if(peerConnection_) { + if(peerConnection_->getBufferLength() > 0) { + setStatus(Command::STATUS_ONESHOT_REALTIME); + getDownloadEngine()->setNoWait(true); + } + } else { peerConnection_.reset(new PeerConnection(cuid, getPeer(), getSocket())); } } |