| 540 | } |
| 541 | |
| 542 | void AbstractCommand::setReadCheckSocket( |
| 543 | const std::shared_ptr<SocketCore>& socket) |
| 544 | { |
| 545 | if (!socket->isOpen()) { |
| 546 | disableReadCheckSocket(); |
| 547 | return; |
| 548 | } |
| 549 | |
| 550 | if (checkSocketIsReadable_) { |
| 551 | if (*readCheckTarget_ != *socket) { |
| 552 | e_->deleteSocketForReadCheck(readCheckTarget_, this); |
| 553 | e_->addSocketForReadCheck(socket, this); |
| 554 | readCheckTarget_ = socket; |
| 555 | } |
| 556 | return; |
| 557 | } |
| 558 | |
| 559 | e_->addSocketForReadCheck(socket, this); |
| 560 | checkSocketIsReadable_ = true; |
| 561 | readCheckTarget_ = socket; |
| 562 | } |
| 563 | |
| 564 | void AbstractCommand::setReadCheckSocketIf( |
| 565 | const std::shared_ptr<SocketCore>& socket, bool pred) |
no test coverage detected