ha_impl.h

Go to the documentation of this file.

// Copyright (C) 2018-2026 Internet Systems Consortium, Inc. ("ISC")
//
// This Source Code Form is subject to the terms of the Mozilla Public
// License, v. 2.0. If a copy of the MPL was not distributed with this
// file, You can obtain one at http://mozilla.org/MPL/2.0/.
 
#ifndef HA_IMPL_H
#define HA_IMPL_H
 
#include <ha_config.h>
#include <ha_service.h>
#include <asiolink/io_service.h>
#include <cc/data.h>
#include <dhcpsrv/network_state.h>
#include <hooks/hooks.h>
#include <boost/noncopyable.hpp>
#include <boost/shared_ptr.hpp>
 
 
namespace isc {
namespace ha {

class HAImpl : public boost::noncopyable {
public:

    HAImpl();

    void configure(const data::ConstElementPtr& input_config);

    void startServices(const dhcp::NetworkStatePtr& network_state,
                       const HAServerType& server_type);

    virtual ~HAImpl();

    void stop();

    HAConfigPtr getConfig() const {
        return (config_->get());
    }

    HAConfigPtr getConfig(const std::string& partner_name) const {
        return (config_->get(partner_name));
    }

    void buffer4Receive(hooks::CalloutHandle& callout_handle);

    void subnet4Select(hooks::CalloutHandle& callout_handle);

    void leases4Committed(hooks::CalloutHandle& callout_handle);

    void lease4ServerDecline(hooks::CalloutHandle& callout_handle);

    void lease4Expire(hooks::CalloutHandle& callout_handle);

    void buffer6Receive(hooks::CalloutHandle& callout_handle);
 

    void subnet6Select(hooks::CalloutHandle& callout_handle);

    void leases6Committed(hooks::CalloutHandle& callout_handle);

    void lease6Expire(hooks::CalloutHandle& callout_handle);

    void commandProcessed(hooks::CalloutHandle& callout_handle);

    void heartbeatHandler(hooks::CalloutHandle& callout_handle);

    void synchronizeHandler(hooks::CalloutHandle& callout_handle);

    void scopesHandler(hooks::CalloutHandle& callout_handle);

    void continueHandler(hooks::CalloutHandle& callout_handle);

    void maintenanceNotifyHandler(hooks::CalloutHandle& callout_handle);

    void maintenanceStartHandler(hooks::CalloutHandle& callout_handle);

    void maintenanceCancelHandler(hooks::CalloutHandle& callout_handle);

    void haResetHandler(hooks::CalloutHandle& callout_handle);

    void syncCompleteNotifyHandler(hooks::CalloutHandle& callout_handle);

    HAServicePtr getHAServiceByServerName(const std::string& command_name,
                                          data::ConstElementPtr args) const;

    isc::asiolink::IOServicePtr getIOService() {
        return (io_service_);
    }

    void setIOService(isc::asiolink::IOServicePtr io_service) {
        io_service_ = io_service;
    }
 
protected:

    virtual bool shouldReclaim(const HAServicePtr& service, const dhcp::Lease4Ptr& lease4) const;

    virtual bool shouldReclaim(const HAServicePtr& service, const dhcp::Lease6Ptr& lease6) const;

    isc::asiolink::IOServicePtr io_service_;

    HAConfigMapperPtr config_;

    HAServiceMapperPtr services_;
};

typedef boost::shared_ptr<HAImpl> HAImplPtr;
 
} // end of namespace isc::ha
} // end of namespace isc
 
#endif