bulk_lease_query6.h

Go to the documentation of this file.

// Copyright (C) 2022-2025 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 BULK_LEASE_QUERY6_H
#define BULK_LEASE_QUERY6_H
 
#include <config.h>
 
#include <lease_query_impl.h>
#include <bulk_lease_query.h>
#include <dhcp/option_custom.h>
#include <dhcp/option6_iaaddr.h>
#include <dhcpsrv/subnet_id.h>
 
namespace isc {
namespace lease_query {

class BulkLeaseQuery6;

typedef boost::shared_ptr<BulkLeaseQuery6> BulkLeaseQuery6Ptr;

class BulkLeaseQuery6 : public BulkLeaseQuery {
public:

    BulkLeaseQuery6(BlqQueryPtr query,
                    const BlqPostCb& post,
                    const BlqPushToSendCb& push_to_send,
                    const BlqQueryCompleteCb& query_complete)
        : BulkLeaseQuery(query, post, push_to_send, query_complete),
          query6_(),
          link_addr_(asiolink::IOAddress::IPV6_ZERO_ADDRESS()), links_(),
          start_addr_(asiolink::IOAddress::IPV6_ZERO_ADDRESS()),
          page_size_(10),
          lq_option_(), query_iaaddr_(), query_client_id_(),
          query_relay_id_(), query_remote_id_() {
        init();
    }

    virtual ~BulkLeaseQuery6() {
    }

    static std::string leaseQueryLabel(const BlqMsgPtr& msg);

    virtual void init();

    virtual void start();

    dhcp::Pkt6Ptr getQuery6() const {
        return (query6_);
    }

    const asiolink::IOAddress& getLinkAddress() const {
        return (link_addr_);
    }

    const dhcp::SubnetIDSet& links() const {
        return (links_);
    }

    asiolink::IOAddress getStartAddress() const {
        return (start_addr_);
    }

    size_t getPageSize() const {
        return (page_size_);
    }
 
protected:
    void bulkQueryByIpAddress();

    void bulkQueryByClientId();

    void bulkQueryByRelayId();

    void bulkQueryByRemoteId();

    void bulkQueryByLinkAddress();

    void bulkQueryByRelayIdNext();

    static void doBulkQueryByRelayIdNext(BulkLeaseQuery6Ptr ptr) {
        if (!ptr) {
            // Should not happen.
            return;
        }
        ptr->bulkQueryByRelayIdNext();
    }

    void bulkQueryByRemoteIdNext();

    static void doBulkQueryByRemoteIdNext(BulkLeaseQuery6Ptr ptr) {
        if (!ptr) {
            // Should not happen.
            return;
        }
        ptr->bulkQueryByRemoteIdNext();
    }

    void bulkQueryByLinkAddressNext();

    static void doBulkQueryByLinkAddressNext(BulkLeaseQuery6Ptr ptr) {
        if (!ptr) {
            // Should not happen.
            return;
        }
        ptr->bulkQueryByLinkAddressNext();
    }

    virtual void send(dhcp::Pkt6Ptr response) const;

    virtual void sendReply(dhcp::OptionPtr status);

    dhcp::OptionCustomPtr getLeaseQueryOption() const {
        return (lq_option_);
    }

    dhcp::Option6IAAddrPtr getQueryIpAddress() const {
        return (query_iaaddr_);
    }

    dhcp::DuidPtr getQueryClientId() const {
        return (query_client_id_);
    }

    dhcp::DuidPtr getQueryRelayId() const {
        return (query_relay_id_);
    }

    dhcp::OptionPtr getQueryRemoteId() const {
        return (query_remote_id_);
    }

    dhcp::Pkt6Ptr query6_;

    asiolink::IOAddress link_addr_;

    dhcp::SubnetIDSet links_;

    asiolink::IOAddress start_addr_;

    size_t page_size_;

    dhcp::OptionCustomPtr lq_option_;

    dhcp::Option6IAAddrPtr query_iaaddr_;

    dhcp::DuidPtr query_client_id_;

    dhcp::DuidPtr query_relay_id_;

    dhcp::OptionPtr query_remote_id_;
};
 
} // end of namespace isc::lease_query
} // end of namespace isc
 
#endif // BULK_LEASE_QUERY6_H