void CheckerComponent::ClearServicesRequestHandler(const Endpoint::Ptr& sender, const RequestMessage& request)
{
- Application::Log(LogDebug, "checker", "Clearing service delegations.");
+ Application::Log(LogInformation, "checker", "Clearing service delegations.");
/* clear the services lists */
m_Services = ServiceQueue();
m_PendingServices.clear();
/* TODO: clear checks we've already sent to the thread pool */
-
- string id;
- if (request.GetID(&id)) {
- ResponseMessage rm;
- rm.SetID(id);
-
- MessagePart result;
- rm.SetResult(result);
- GetEndpointManager()->SendUnicastMessage(m_CheckerEndpoint, sender, rm);
- }
}
EXPORT_COMPONENT(checker, CheckerComponent);
void DelegationComponent::ClearServices(const Endpoint::Ptr& checker)
{
+ RequestMessage request;
+ request.SetMethod("checker::ClearServices");
-}
+ MessagePart params;
+ request.SetParams(params);
-void DelegationComponent::RevokeServiceResponseHandler(Service& service, const Endpoint::Ptr& sender, bool timedOut)
-{
+ GetEndpointManager()->SendUnicastMessage(m_DelegationEndpoint, checker, request);
}
vector<Endpoint::Ptr> DelegationComponent::GetCheckerCandidates(const Service& service) const
Timer::Ptr m_DelegationTimer;
void AssignServiceResponseHandler(Service& service, const Endpoint::Ptr& sender, bool timedOut);
- void RevokeServiceResponseHandler(Service& service, const Endpoint::Ptr& sender, bool timedOut);
void DelegationTimerHandler(void);