tsn_elector.h

Go to the documentation of this file.

/*
 * Copyright (c) 2017 Juniper Networks, Inc. All rights reserved.
 */
 
#ifndef tsn_elector_agent_oper_hpp
#define tsn_elector_agent_oper_hpp
 
#include <cmn/agent_cmn.h>
#include <cmn/agent.h>
#include <oper/agent_route_walker.h>
 
struct TsnElectorState : public DBState {
    TsnElectorState(AgentRouteTable *table, TsnElector *elector);
    virtual ~TsnElectorState();
 
    DBTable::ListenerId inet4_id_;
    AgentRouteTable *inet4_table_;
};
 
class TsnElectorWalker : public AgentRouteWalker {
public:
    TsnElectorWalker(const std::string &name, Agent *agent);
    virtual ~TsnElectorWalker();
 
    void LeaveTsnMastership();
    void AcquireTsnMastership();
    virtual bool RouteWalkNotify(DBTablePartBase *partition, DBEntryBase *e);
 
private:
    bool master_;
    DISALLOW_COPY_AND_ASSIGN(TsnElectorWalker);
};
 
class TsnElector {
public:
    typedef std::vector<std::string> ManagedPhysicalDevicesList;
    TsnElector(Agent *agent);
    virtual ~TsnElector();
 
    void Register();
    void Shutdown();
    void Notify(DBTablePartBase *partition, DBEntryBase *e);
    void RouteNotify(DBTablePartBase *partition, DBEntryBase *e);
    bool IsMaster() const;
    const Agent *agent() const {return agent_;}
    const std::vector<string> &active_tsn_servers() const {
        return active_tsn_servers_;
    }
    const ManagedPhysicalDevicesList &ManagedPhysicalDevices() const;
 
private:
    bool IsTsnNoForwardingEnabled() const;
    TsnElectorWalker *walker() {
        return static_cast<TsnElectorWalker *>(walker_.get());
    }
 
    const Agent *agent_;
    DBTable::ListenerId vrf_listener_id_;
    std::vector<std::string> active_tsn_servers_;
    AgentRouteWalkerPtr walker_;
    DISALLOW_COPY_AND_ASSIGN(TsnElector);
};
 
#endif /* tsn_elector_agent_oper_hpp */