typedef CommCbMemFunT<HappyConnOpener, CommConnectCbParams> Dialer;
AsyncCall::Pointer callConnect = asyncCall(48, 5, attempt.callbackMethodName,
- Dialer(this, attempt.callbackMethod));
+ Dialer(this, attempt.callbackMethod));
const time_t connTimeout = dest->connectTimeout(fwdStart);
Comm::ConnOpener *cs = new Comm::ConnOpener(dest, callConnect, connTimeout);
if (!dest->getPeer())
class MemBuf;
namespace Ssl {
- class IcapPeerConnector;
+class IcapPeerConnector;
}
namespace Adaptation
// Note: Xaction must be the first parent for object-unaware cbdata to work
-
class Xaction: public Adaptation::Initiate
{
void
Log::TcpLogger::connectDone(const CommConnectCbParams ¶ms)
{
- connWait.finish();
+ connWait.finish();
if (params.flag != Comm::OK) {
const double delay = 0.5; // seconds
typedef CommCbMemFunT<Server, CommConnectCbParams> Dialer;
AsyncCall::Pointer callback = JobCallback(17, 3, Dialer, this, Ftp::Server::connectedForData);
const auto cs = new Comm::ConnOpener(dataConn, callback,
- Config.Timeout.connect);
+ Config.Timeout.connect);
dataConnWait.start(cs, callback);
AsyncJob::Start(cs);
return false; // ConnStateData::processFtpRequest waits handleConnectDone
{
AsyncCall::Pointer callback = asyncCall(5,4,
"TunnelStateData::tunnelEstablishmentDone",
- Http::Tunneler::CbDialer<TunnelStateData>(&TunnelStateData::tunnelEstablishmentDone, this));
+ Http::Tunneler::CbDialer<TunnelStateData>(&TunnelStateData::tunnelEstablishmentDone, this));
const auto tunneler = new Http::Tunneler(conn, request, callback, Config.Timeout.lifetime, al);
#if USE_DELAY_POOLS
tunneler->setDelayId(server.delayId);