}
if (createFd())
- connect();
+ doConnect();
}
/// called at the end of Comm::ConnOpener::DelayedConnectRetry event
calls_.sleep_ = false;
if (createFd())
- connect();
+ doConnect();
}
/// Create a socket for the future connection or return false.
/// Make an FD connection attempt.
void
-Comm::ConnOpener::connect()
+Comm::ConnOpener::doConnect()
{
Must(conn_ != NULL);
Must(temporaryFd_ >= 0);
} else {
// send ERROR back to the upper layer.
debugs(5, 5, HERE << conn_ << ": * - ERR tried too many times already.");
- sendAnswer(COMM_ERR_CONNECT, xerrno, "Comm::ConnOpener::connect");
+ sendAnswer(COMM_ERR_CONNECT, xerrno, "Comm::ConnOpener::doConnect");
}
}
}
}
/* Legacy Wrapper for the retry event after COMM_INPROGRESS
- * XXX: As soon as Comm::SetSelect() accepts Async calls we can use a ConnOpener::connect call
+ * XXX: As soon as Comm::SetSelect() accepts Async calls we can use a ConnOpener::doConnect call
*/
void
Comm::ConnOpener::InProgressConnectRetry(int fd, void *data)
// Ew. we are now outside the all AsyncJob protections.
// get back inside by scheduling another call...
typedef NullaryMemFunT<Comm::ConnOpener> Dialer;
- AsyncCall::Pointer call = JobCallback(5, 4, Dialer, cs, Comm::ConnOpener::connect);
+ AsyncCall::Pointer call = JobCallback(5, 4, Dialer, cs, Comm::ConnOpener::doConnect);
ScheduleCallHere(call);
}
delete ptr;
void sendAnswer(comm_err_t errFlag, int xerrno, const char *why);
static void InProgressConnectRetry(int fd, void *data);
static void DelayedConnectRetry(void *data);
- void connect();
+ void doConnect();
void connected();
void lookupLocalAddress();