sonic-swss/orchagent/bufferorch.h at c97c25c7cccfbbdab505f717685f96ba61059be5 · vivekrnv/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
#ifndef SWSS_BUFFORCH_H
#define SWSS_BUFFORCH_H

#include <string>
#include <map>
#include <unordered_map>
#include "orch.h"
#include "portsorch.h"
#include "redisapi.h"

#define BUFFER_POOL_WATERMARK_STAT_COUNTER_FLEX_COUNTER_GROUP "BUFFER_POOL_WATERMARK_STAT_COUNTER"

const string buffer_size_field_name         = "size";
const string buffer_pool_type_field_name    = "type";
const string buffer_pool_mode_field_name    = "mode";
const string buffer_pool_field_name         = "pool";
const string buffer_pool_mode_dynamic_value = "dynamic";
const string buffer_pool_mode_static_value  = "static";
const string buffer_pool_xoff_field_name    = "xoff";
const string buffer_xon_field_name          = "xon";
const string buffer_xon_offset_field_name   = "xon_offset";
const string buffer_xoff_field_name         = "xoff";
const string buffer_dynamic_th_field_name   = "dynamic_th";
const string buffer_static_th_field_name    = "static_th";
const string buffer_profile_field_name      = "profile";
const string buffer_value_ingress           = "ingress";
const string buffer_value_egress            = "egress";
const string buffer_value_both              = "both";
const string buffer_profile_list_field_name = "profile_list";
const string buffer_headroom_type_field_name= "headroom_type";

class BufferOrch : public Orch
{
public:
    BufferOrch(DBConnector *applDb, DBConnector *confDb, DBConnector *stateDb, vector<string> &tableNames);
    bool isPortReady(const std::string& port_name) const;
    static type_map m_buffer_type_maps;
    void generateBufferPoolWatermarkCounterIdList(void);
    const object_reference_map &getBufferPoolNameOidMap(void);

private:
    typedef task_process_status (BufferOrch::*buffer_table_handler)(KeyOpFieldsValuesTuple &tuple);
    typedef map<string, buffer_table_handler> buffer_table_handler_map;
    typedef pair<string, buffer_table_handler> buffer_handler_pair;

    void doTask() override;
    virtual void doTask(Consumer& consumer);
    void clearBufferPoolWatermarkCounterIdList(const sai_object_id_t object_id);
    void initTableHandlers();
    void initBufferReadyLists(DBConnector *confDb, DBConnector *applDb);
    void initBufferReadyList(Table& table, bool isConfigDb);
    void initFlexCounterGroupTable(void);
    void initBufferConstants();
    task_process_status processBufferPool(KeyOpFieldsValuesTuple &tuple);
    task_process_status processBufferProfile(KeyOpFieldsValuesTuple &tuple);
    task_process_status processQueue(KeyOpFieldsValuesTuple &tuple);
    task_process_status processPriorityGroup(KeyOpFieldsValuesTuple &tuple);
    task_process_status processIngressBufferProfileList(KeyOpFieldsValuesTuple &tuple);
    task_process_status processEgressBufferProfileList(KeyOpFieldsValuesTuple &tuple);

    buffer_table_handler_map m_bufferHandlerMap;
    std::unordered_map<std::string, bool> m_ready_list;
    std::unordered_map<std::string, std::vector<std::string>> m_port_ready_list_ref;

    unique_ptr<DBConnector> m_flexCounterDb;
    unique_ptr<ProducerTable> m_flexCounterGroupTable;
    unique_ptr<ProducerTable> m_flexCounterTable;

    Table m_stateBufferMaximumValueTable;

    unique_ptr<DBConnector> m_countersDb;

    bool m_isBufferPoolWatermarkCounterIdListGenerated = false;

};
#endif /* SWSS_BUFFORCH_H */