Skip to content

Commit 221aa9e

Browse files
author
Mykola Faryma
committed
address review comments
Signed-off-by: Mykola Faryma <[email protected]>
1 parent 441c0db commit 221aa9e

3 files changed

Lines changed: 6 additions & 6 deletions

File tree

orchagent/pfcwdorch.cpp

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -477,7 +477,6 @@ void PfcWdSwOrch<DropHandler, ForwardHandler>::registerInWdDb(const Port& port,
477477
// Only register lossless tc counters in database.
478478
string str = counterIdsToStr(c_portStatIds, &sai_serialize_port_stat);
479479
string filteredStr = filterPfcCounters(str, losslessTc);
480-
fieldValues.emplace_back(STATS_MODE_FIELD, STATS_MODE_READ);
481480
fieldValues.emplace_back(PORT_COUNTER_ID_LIST, filteredStr);
482481

483482
m_flexCounterTable->set(key, fieldValues);
@@ -506,7 +505,6 @@ void PfcWdSwOrch<DropHandler, ForwardHandler>::registerInWdDb(const Port& port,
506505
if (!c_queueStatIds.empty())
507506
{
508507
string str = counterIdsToStr(c_queueStatIds, sai_serialize_queue_stat);
509-
queueFieldValues.emplace_back(STATS_MODE_FIELD, STATS_MODE_READ);
510508
queueFieldValues.emplace_back(QUEUE_COUNTER_ID_LIST, str);
511509
}
512510

@@ -652,6 +650,7 @@ PfcWdSwOrch<DropHandler, ForwardHandler>::PfcWdSwOrch(
652650
vector<FieldValueTuple> fieldValues;
653651
fieldValues.emplace_back(QUEUE_PLUGIN_FIELD, detectSha + "," + restoreSha);
654652
fieldValues.emplace_back(POLL_INTERVAL_FIELD, to_string(m_pollInterval));
653+
fieldValues.emplace_back(STATS_MODE_FIELD, STATS_MODE_READ);
655654
m_flexCounterGroupTable->set(PFC_WD_FLEX_COUNTER_GROUP, fieldValues);
656655
}
657656
catch (...)

orchagent/watermarkorch.cpp

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -74,6 +74,10 @@ void WatermarkOrch::doTask(Consumer &consumer)
7474
{
7575
m_telemetryInterval = to_uint<uint32_t>(i.second.c_str());
7676
}
77+
else
78+
{
79+
SWSS_LOG_WARN("Unsupported key: ", i.first.c_str());
80+
}
7781
}
7882
}
7983
}

orchagent/watermarkorch.h

Lines changed: 1 addition & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -7,9 +7,6 @@
77
#include "notificationconsumer.h"
88
#include "timer.h"
99

10-
extern "C" {
11-
#include "sai.h"
12-
}
1310

1411
class WatermarkOrch : public Orch
1512
{
@@ -18,7 +15,7 @@ class WatermarkOrch : public Orch
1815
virtual ~WatermarkOrch(void);
1916

2017
void doTask(Consumer &consumer);
21-
void doTask(NotificationConsumer& consumer);
18+
void doTask(NotificationConsumer &consumer);
2219
void doTask(SelectableTimer &timer);
2320

2421
void init_pg_ids();

0 commit comments

Comments
 (0)