diff options
Diffstat (limited to 'src/PeerAbstractCommand.cc')
| -rw-r--r-- | src/PeerAbstractCommand.cc | 16 |
1 files changed, 8 insertions, 8 deletions
diff --git a/src/PeerAbstractCommand.cc b/src/PeerAbstractCommand.cc index eab501ad..fe663b7e 100644 --- a/src/PeerAbstractCommand.cc +++ b/src/PeerAbstractCommand.cc @@ -88,7 +88,7 @@ void PeerAbstractCommand::onAbort(Exception* ex) { void PeerAbstractCommand::disableReadCheckSocket() { if(checkSocketIsReadable) { - e->deleteSocketForReadCheck(readCheckTarget, getUuid()); + e->deleteSocketForReadCheck(readCheckTarget, this); checkSocketIsReadable = false; readCheckTarget = SocketHandle(); } @@ -100,12 +100,12 @@ void PeerAbstractCommand::setReadCheckSocket(const SocketHandle& socket) { } else { if(checkSocketIsReadable) { if(readCheckTarget != socket) { - e->deleteSocketForReadCheck(readCheckTarget, getUuid()); - e->addSocketForReadCheck(socket, getUuid()); + e->deleteSocketForReadCheck(readCheckTarget, this); + e->addSocketForReadCheck(socket, this); readCheckTarget = socket; } } else { - e->addSocketForReadCheck(socket, getUuid()); + e->addSocketForReadCheck(socket, this); checkSocketIsReadable = true; readCheckTarget = socket; } @@ -114,7 +114,7 @@ void PeerAbstractCommand::setReadCheckSocket(const SocketHandle& socket) { void PeerAbstractCommand::disableWriteCheckSocket() { if(checkSocketIsWritable) { - e->deleteSocketForWriteCheck(writeCheckTarget, getUuid()); + e->deleteSocketForWriteCheck(writeCheckTarget, this); checkSocketIsWritable = false; writeCheckTarget = SocketHandle(); } @@ -126,12 +126,12 @@ void PeerAbstractCommand::setWriteCheckSocket(const SocketHandle& socket) { } else { if(checkSocketIsWritable) { if(writeCheckTarget != socket) { - e->deleteSocketForWriteCheck(writeCheckTarget, getUuid()); - e->addSocketForWriteCheck(socket, getUuid()); + e->deleteSocketForWriteCheck(writeCheckTarget, this); + e->addSocketForWriteCheck(socket, this); writeCheckTarget = socket; } } else { - e->addSocketForWriteCheck(socket, getUuid()); + e->addSocketForWriteCheck(socket, this); checkSocketIsWritable = true; writeCheckTarget = socket; } |
