ha_stale_l2_route.h

Go to the documentation of this file.

/*
 * Copyright (c) 2015 Juniper Networks, Inc. All rights reserved.
 */
 
#ifndef SRC_VNSW_AGENT_OVS_TOR_AGENT_OVSDB_CLIENT_HA_STALE_L2_ROUTE_H_
#define SRC_VNSW_AGENT_OVS_TOR_AGENT_OVSDB_CLIENT_HA_STALE_L2_ROUTE_H_
 
#include <base/lifetime.h>
#include <ovsdb_entry.h>
#include <ovsdb_object.h>
#include <ovsdb_client_idl.h>
 
class BridgeRouteEntry;
 
namespace OVSDB {
class HaStaleDevVnEntry;
class HaStaleL2RouteEntry;
class ConnectionStateEntry;
 
class HaStaleL2RouteTable : public OvsdbDBObject {
public:
    HaStaleL2RouteTable(HaStaleDevVnEntry *dev_vn,
                        AgentRouteTable *table);
    virtual ~HaStaleL2RouteTable();
 
    KSyncEntry *Alloc(const KSyncEntry *key, uint32_t index);
    KSyncEntry *DBToKSyncEntry(const DBEntry*);
 
    DBFilterResp OvsdbDBEntryFilter(const DBEntry *entry,
                                    const OvsdbDBEntry *ovsdb_entry);
 
    Agent *agent() const;
    void ManagedDelete();
    virtual void EmptyTable();
    Ip4Address dev_ip() const;
    uint32_t vxlan_id() const;
    const std::string &vn_name() const;
    const std::string &vrf_name() const;
 
    void UpdateParams(HaStaleDevVnEntry *dev_vn);
 
private:
    friend class HaStaleL2RouteEntry;
 
    LifetimeRef<HaStaleL2RouteTable> table_delete_ref_;
    // DevVn entry will not be deleted till we del_ack for it
    HaStaleDevVnEntry *dev_vn_;
    ConnectionStateEntry *state_;
    Ip4Address dev_ip_;
    uint32_t vxlan_id_;
    // take reference to the vrf while exporting route, to assure sanity
    // of vrf pointer even if Add route request fails, due to any reason
    VrfEntryRef vrf_;
    std::string vn_name_;
    DISALLOW_COPY_AND_ASSIGN(HaStaleL2RouteTable);
};
 
class HaStaleL2RouteEntry : public OvsdbDBEntry {
public:
    HaStaleL2RouteEntry(HaStaleL2RouteTable *table,
                          const std::string &mac);
    ~HaStaleL2RouteEntry();
 
    bool Add();
    bool Change();
    bool Delete();
 
    bool Sync(DBEntry*);
    bool IsLess(const KSyncEntry&) const;
    std::string ToString() const {return "Ha Stale L2 Route Entry";}
    KSyncEntry* UnresolvedReference();
 
    const std::string &mac() const;
    uint32_t vxlan_id() const;
    bool IsStale() const;
 
private:
    friend class HaStaleL2RouteTable;
    friend class VrfRouteReflectorTable;
 
    void StaleClearCb();
 
    void StopStaleClearTimer();
 
    void AddEvent();
    void ChangeEvent();
    void DeleteEvent();
 
    std::string mac_;
    uint32_t path_preference_;
    uint32_t vxlan_id_;
    uint64_t time_stamp_;
    Ip4Address sip_;
    Ip4Address dip_;
    bool is_multicast_;
    DISALLOW_COPY_AND_ASSIGN(HaStaleL2RouteEntry);
};
};
 
#endif //SRC_VNSW_AGENT_OVS_TOR_AGENT_OVSDB_CLIENT_HA_STALE_L2_ROUTE_H_