sonic-swss/orchagent/mirrororch.h at edb334df8fba86cc73da8376d2815c5f1bba88a7 · stcheng/sonic-swss · GitHub

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
#ifndef SWSS_MIRRORORCH_H
#define SWSS_MIRRORORCH_H

#include "orch.h"
#include "observer.h"
#include "portsorch.h"
#include "neighorch.h"
#include "routeorch.h"
#include "fdborch.h"
#include "policerorch.h"

#include "ipaddress.h"
#include "ipaddresses.h"
#include "ipprefix.h"

#include "table.h"

#include <map>
#include <inttypes.h>

/*
 * Contains session data specified by user in config file
 * and data required for MAC address and port resolution
 */
struct MirrorEntry
{
    bool status;
    IpAddress srcIp;
    IpAddress dstIp;
    uint16_t greType;
    uint8_t dscp;
    uint8_t ttl;
    uint8_t queue;
    string policer;

    struct
    {
        IpPrefix prefix;
        IpAddress nexthop;
    } nexthopInfo;

    struct
    {
        NeighborEntry neighbor;
        MacAddress mac;
        Port port;
        sai_object_id_t portId;
    } neighborInfo;

    sai_object_id_t sessionId;

    int64_t refCount;

    MirrorEntry(const string& platform);
};

struct MirrorSessionUpdate
{
    string name;
    bool active;
};

/* MirrorTable: mirror session name, mirror session data */
typedef map<string, MirrorEntry> MirrorTable;

class MirrorOrch : public Orch, public Observer, public Subject
{
public:
    MirrorOrch(TableConnector appDbConnector, TableConnector confDbConnector,
               PortsOrch *portOrch, RouteOrch *routeOrch, NeighOrch *neighOrch, FdbOrch *fdbOrch, PolicerOrch *policerOrch);

    bool bake() override;
    bool postBake() override;
    void update(SubjectType, void *);
    bool sessionExists(const string&);
    bool getSessionStatus(const string&, bool&);
    bool getSessionOid(const string&, sai_object_id_t&);
    bool increaseRefCount(const string&);
    bool decreaseRefCount(const string&);

private:
    PortsOrch *m_portsOrch;
    RouteOrch *m_routeOrch;
    NeighOrch *m_neighOrch;
    FdbOrch *m_fdbOrch;
    PolicerOrch *m_policerOrch;

    Table m_mirrorTable;

    MirrorTable m_syncdMirrors;
    // session_name -> VLAN | monitor_port_alias | next_hop_ip
    map<string, string> m_recoverySessionMap;

    bool m_freeze = false;

    void createEntry(const string&, const vector<FieldValueTuple>&);
    void deleteEntry(const string&);

    bool activateSession(const string&, MirrorEntry&);
    bool deactivateSession(const string&, MirrorEntry&);
    bool updateSession(const string&, MirrorEntry&);
    bool updateSessionDstMac(const string&, MirrorEntry&);
    bool updateSessionDstPort(const string&, MirrorEntry&);
    bool updateSessionType(const string&, MirrorEntry&);

    /*
     * Store mirror session state in StateDB
     * attr is the field name will be stored, if empty then all fields will be stored
     */
    void setSessionState(const std::string& name, const MirrorEntry& session, const std::string& attr = "");
    bool getNeighborInfo(const string&, MirrorEntry&);

    void updateNextHop(const NextHopUpdate&);
    void updateNeighbor(const NeighborUpdate&);
    void updateFdb(const FdbUpdate&);
    void updateLagMember(const LagMemberUpdate&);
    void updateVlanMember(const VlanMemberUpdate&);

    void doTask(Consumer& consumer);
};

#endif /* SWSS_MIRRORORCH_H */