netconf.h

Go to the documentation of this file.

// Copyright (C) 2018 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 NETCONF_H
#define NETCONF_H

#ifndef HAVE_SYSREPO
#error "config.h must be included before netconf.h"
#endif

#include <netconf/netconf_cfg_mgr.h>
#include <netconf/control_socket.h>
#include <netconf/http_control_socket.h>
#include <netconf/stdout_control_socket.h>
#include <netconf/unix_control_socket.h>
#ifndef HAVE_PRE_0_7_6_SYSREPO
#include <sysrepo-cpp/Session.hpp>
#else
#include <sysrepo-cpp/Session.h>
#endif
#include <map>

namespace isc {
namespace netconf {

class NetconfAgent;

typedef boost::shared_ptr<NetconfAgent> NetconfAgentPtr;

class NetconfAgent {
public:
    NetconfAgent();

    virtual ~NetconfAgent();

    void initSysrepo();

    void init(NetconfCfgMgrPtr cfg_mgr);

    void clear();

#ifndef HAVE_PRE_0_7_6_SYSREPO
    static int validate(sysrepo::S_Session sess,
                        const CfgServersMapPair& service_pair);
#else
    static int validate(S_Session sess, const CfgServersMapPair& service_pair);
#endif

#ifndef HAVE_PRE_0_7_6_SYSREPO
    static int update(sysrepo::S_Session sess,
                      const CfgServersMapPair& service_pair);
#else
    static int update(S_Session sess, const CfgServersMapPair& service_pair);
#endif

#ifndef HAVE_PRE_0_7_6_SYSREPO
    static void logChanges(sysrepo::S_Session sess, const std::string& model);
#else
    static void logChanges(S_Session sess, const std::string& model);
#endif

    bool cancel_;

protected:
    void keaConfig(const CfgServersMapPair& service_pair);

    bool checkModule(const std::string& module_name) const;

    void checkModules() const;

    void yangConfig(const CfgServersMapPair& service_pair);

    void subscribeConfig(const CfgServersMapPair& service_pair);

#ifndef HAVE_PRE_0_7_6_SYSREPO
    sysrepo::S_Connection conn_;
#else
    S_Connection conn_;
#endif

#ifndef HAVE_PRE_0_7_6_SYSREPO
    sysrepo::S_Session startup_sess_;
#else
    S_Session startup_sess_;
#endif

#ifndef HAVE_PRE_0_7_6_SYSREPO
    sysrepo::S_Session running_sess_;
#else
    S_Session running_sess_;
#endif

    std::map<const std::string, const std::string> modules_;

#ifndef HAVE_PRE_0_7_6_SYSREPO
    std::map<const std::string, sysrepo::S_Subscribe> subscriptions_;
#else
    std::map<const std::string, S_Subscribe> subscriptions_;
#endif
};

} // namespace netconf
} // namespace isc

#endif // NETCONF_H