CncServiceImpl.h

Go to the documentation of this file.

#pragma once
 
#include <grpcpp/grpcpp.h>
 
#include <atomic>
#include <condition_variable>
#include <memory>
#include <shared_mutex>
#include <string>
#include <thread>
 
#include "NetworkManager.h"
#include "Topology.h"
#include "cnc.grpc.pb.h"
 
class CncServiceImpl final : public cnc::rpc::CncService::Service {
   private:
    Topology topology;
    std::unique_ptr<cnc::NetworkManager> networkManager;
 
    // mutex to protect access to data structure for timer based ptp fetching
    std::shared_mutex topologyMutex;
    std::thread ptpTimerThread;
    std::atomic<bool> stopTimer{false};
    std::condition_variable timerCV;
    std::mutex timerMutex;
 
    // helper function to find a node by hostname in the topology
    CncNode_t* FindNode(const std::string& hostName);
 
    // helper function to map internal CncNode_t to cnc::rpc::Node protobuf message
    void MapInterface(const ietfInterface_t& internalIface, cnc::rpc::IetfInterface* protoIface);
 
    void MapPtpNode(const PtpNode_t& internalPtp, cnc::rpc::PtpNode* protoPtp);
 
    void MapLldpNode(const LldpNode_t& internalLldp, cnc::rpc::LldpNode* protoLldp);
 
    void MapPtpPort(const PtpPort_t& internalPort, cnc::rpc::PtpPort* protoPort);
 
    void MapLldpPort(const LldpPort_t& internalPort, cnc::rpc::LldpPort* protoPort);
 
    void ptpBackgroundTask();
 
   public:
    CncServiceImpl(const std::string& inventoryFilePath);
 
    ~CncServiceImpl();
 
    grpc::Status GetNetworkState(grpc::ServerContext* context, const cnc::rpc::EmptyRequest* request,
                                 cnc::rpc::Topology* response) override;
 
    grpc::Status GetAllPtpData(grpc::ServerContext* context, const cnc::rpc::EmptyRequest* request,
                               cnc::rpc::AllPtpDataResponse* response) override;
 
    grpc::Status GetAllLldpData(grpc::ServerContext* context, const cnc::rpc::EmptyRequest* request,
                                cnc::rpc::AllLldpDataResponse* response) override;
 
    grpc::Status GetNodePtpData(grpc::ServerContext* context, const cnc::rpc::NodeRequest* request,
                                cnc::rpc::PtpNode* response) override;
 
    grpc::Status GetNodeLldpData(grpc::ServerContext* context, const cnc::rpc::NodeRequest* request,
                                 cnc::rpc::LldpNode* response) override;
 
    grpc::Status GetInterfacePtpData(grpc::ServerContext* context, const cnc::rpc::InterfaceRequest* request,
                                     cnc::rpc::PtpPort* response) override;
 
    grpc::Status GetInterfaceLldpData(grpc::ServerContext* context, const cnc::rpc::InterfaceRequest* request,
                                      cnc::rpc::LldpPort* response) override;
 
    grpc::Status GetInterfaceGcl(grpc::ServerContext* context, const cnc::rpc::InterfaceRequest* request,
                                 cnc::rpc::GclConfig* response) override;
 
    grpc::Status GetInterfaceAdminGcl(grpc::ServerContext* context, const cnc::rpc::InterfaceRequest* request,
                                      cnc::rpc::AdminGclResponse* response) override;
 
    grpc::Status GetInterfaceOperGcl(grpc::ServerContext* context, const cnc::rpc::InterfaceRequest* request,
                                     cnc::rpc::OperGclResponse* response) override;
 
    grpc::Status SetNodeSchedule(grpc::ServerContext* context, const cnc::rpc::SetNodeScheduleRequest* request,
                                 cnc::rpc::SetNodeScheduleResponse* response);
 
    grpc::Status SetInterfaceSchedule(grpc::ServerContext* context,
                                      const cnc::rpc::SetInterfaceScheduleRequest* request,
                                      cnc::rpc::IetfInterface* response);
 
    grpc::Status GetTopologyGraph(grpc::ServerContext* context, const cnc::rpc::EmptyRequest* request,
                                  cnc::rpc::TopologyGraph* response);
};