debugs(54, 3, HERE);
typedef NullaryMemFunT<Forwarder> Dialer;
- AsyncCall::Pointer callback = JobCallback(16, 5, Dialer, this, Forwarder::handleRemoteAck);
+ AsyncCall::Pointer callback = JobCallback(54, 5, Dialer, this, Forwarder::handleRemoteAck);
if (++LastRequestId == 0) // don't use zero value as request->requestId
++LastRequestId;
request->requestId = LastRequestId;
Must(param != NULL);
Forwarder* fwdr = static_cast<Forwarder*>(param);
// use async call to enable job call protection that time events lack
- CallJobHere(16, 5, fwdr, Forwarder, requestTimedOut);
+ CallJobHere(54, 5, fwdr, Forwarder, requestTimedOut);
}
/// called when Coordinator fails to start processing the request [in time]
void
Ipc::Forwarder::handleException(const std::exception& e)
{
- debugs(16, 3, HERE << e.what());
+ debugs(54, 3, HERE << e.what());
mustStop("exception");
}
}
Must(request->requestId == 0);
- AsyncCall::Pointer callback = asyncCall(16, 5, "Mgr::Inquirer::handleRemoteAck",
+ AsyncCall::Pointer callback = asyncCall(54, 5, "Mgr::Inquirer::handleRemoteAck",
HandleAckDialer(this, &Inquirer::handleRemoteAck, NULL));
if (++LastRequestId == 0) // don't use zero value as request->requestId
++LastRequestId;
Must(param != NULL);
Inquirer* cmi = static_cast<Inquirer*>(param);
// use async call to enable job call protection that time events lack
- CallJobHere(16, 5, cmi, Inquirer, requestTimedOut);
+ CallJobHere(54, 5, cmi, Inquirer, requestTimedOut);
}
/// called when the strand failed to respond (or finish responding) in time
comm_import_opened(fd, ipAddr, COMM_NONBLOCKING, Ipc::FdNote(noteId), addr_info);
ipAddr.FreeAddrInfo(addr_info);
} else {
- debugs(16, DBG_CRITICAL, HERE << "ERROR: FD " << fd << ' ' << xstrerror());
+ debugs(54, DBG_CRITICAL, HERE << "ERROR: FD " << fd << ' ' << xstrerror());
::close(fd);
fd = -1;
}
{
debugs(49, 5, HERE << "FD " << aFd);
Must(fd >= 0);
- closer = asyncCall(16, 5, "Snmp::Forwarder::noteCommClosed",
+ closer = asyncCall(49, 5, "Snmp::Forwarder::noteCommClosed",
CommCbMemFunT<Forwarder, CommCloseCbParams>(this, &Forwarder::noteCommClosed));
comm_add_close_handler(fd, closer);
}
fd(ImportFdIntoComm(aRequest.fd, SOCK_DGRAM, IPPROTO_UDP, Ipc::fdnInSnmpSocket))
{
debugs(49, 5, HERE);
- closer = asyncCall(16, 5, "Snmp::Inquirer::noteCommClosed",
+ closer = asyncCall(49, 5, "Snmp::Inquirer::noteCommClosed",
CommCbMemFunT<Inquirer, CommCloseCbParams>(this, &Inquirer::noteCommClosed));
comm_add_close_handler(fd, closer);
}