| 158 | } |
| 159 | |
| 160 | void PeerAbstractCommand::setWriteCheckSocket( |
| 161 | const std::shared_ptr<SocketCore>& socket) |
| 162 | { |
| 163 | if (!socket->isOpen()) { |
| 164 | disableWriteCheckSocket(); |
| 165 | } |
| 166 | else { |
| 167 | if (checkSocketIsWritable_) { |
| 168 | if (*writeCheckTarget_ != *socket) { |
| 169 | e_->deleteSocketForWriteCheck(writeCheckTarget_, this); |
| 170 | e_->addSocketForWriteCheck(socket, this); |
| 171 | writeCheckTarget_ = socket; |
| 172 | } |
| 173 | } |
| 174 | else { |
| 175 | e_->addSocketForWriteCheck(socket, this); |
| 176 | checkSocketIsWritable_ = true; |
| 177 | writeCheckTarget_ = socket; |
| 178 | } |
| 179 | } |
| 180 | } |
| 181 | |
| 182 | void PeerAbstractCommand::setNoCheck(bool check) { noCheck_ = check; } |
| 183 |
nothing calls this directly
no test coverage detected