calls_.timeout_ = NULL;
}
- // recover what we can from the job
+ // rollback what we can from the job state
if (conn_ != NULL && conn_->isOpen()) {
- // it never reached fully open, so abort the FD
+ // drop any handlers now to save a lot of cycles later
commSetSelect(conn_->fd, COMM_SELECT_WRITE, NULL, NULL, 0);
commSetTimeout(conn_->fd, -1, NULL, NULL);
+ // it never reached fully open, so abort the FD
conn_->close();
}
Comm::Connection::~Connection()
{
close();
- if (getPeer())
- cbdataReferenceDone(_peer);
+ cbdataReferenceDone(_peer);
}
Comm::ConnectionPointer
if (getPeer() == p)
return;
- /* clear any previous ptr */
- if (getPeer())
- cbdataReferenceDone(_peer);
-
- /* set the new one (unless it is NULL */
+ cbdataReferenceDone(_peer);
if (p) {
_peer = cbdataReference(p);
}