Skip to content

Commit ae3910f

Browse files
authored
Remove lag from csqIfQosGroupStatsTable (#5)
Signed-off-by: Qi Luo <[email protected]>
1 parent 3a8ab6b commit ae3910f

File tree

1 file changed

+0
-44
lines changed

1 file changed

+0
-44
lines changed

src/sonic_ax_impl/mibs/vendor/cisco/ciscoSwitchQosMIB.py

-44
Original file line numberDiff line numberDiff line change
@@ -93,10 +93,6 @@ def update_data(self):
9393
if queue_stat is not None:
9494
self.queue_stat_map[queue_stat_name] = queue_stat
9595

96-
self.lag_name_if_name_map, \
97-
self.if_name_lag_name_map, \
98-
self.oid_lag_name_map = mibs.init_sync_d_lag_tables(self.db_conn)
99-
10096
self.update_stats()
10197

10298
def update_stats(self):
@@ -145,46 +141,6 @@ def update_stats(self):
145141
self.mib_oid_list.append(mib_oid)
146142
self.mib_oid_to_queue_map[mib_oid] = counter_value
147143

148-
# Sort the LAG ports to keep the OID order in the MIB
149-
lag_range = list(self.oid_lag_name_map.keys())
150-
# Update queue counters for LAG
151-
for lag_index in lag_range:
152-
lag_oid_list = []
153-
lag_oid_to_queue_map = {}
154-
# Get counters for each LAG member
155-
for lag_member in self.lag_name_if_name_map[self.oid_lag_name_map[lag_index]]:
156-
lag_member_queues = []
157-
if mibs.get_index(lag_member) not in self.port_queue_list_map:
158-
# LAG member does not has a queues, continue..
159-
continue
160-
lag_member_queues = self.port_queue_list_map[mibs.get_index(lag_member)]
161-
162-
for queue in lag_member_queues:
163-
# Get queue type and statistics
164-
queue_sai_oid = self.port_queues_map[mibs.queue_key(mibs.get_index(lag_member), queue)]
165-
queue_stat_table_name = mibs.queue_table(queue_sai_oid)
166-
queue_type = self.queue_type_map.get(queue_sai_oid)
167-
queue_stat = self.queue_stat_map.get(queue_stat_table_name, {})
168-
169-
# Add supported counters to MIBs list and store counters values
170-
for (counter, counter_type), counter_mib_id in CounterMap.items():
171-
# Only egress queues are supported
172-
mib_oid = (lag_index, int(DirectionTypes.EGRESS), queue + 1, counter_mib_id)
173-
174-
counter_value = 0
175-
if queue_type == counter_type:
176-
counter_value = int(queue_stat.get(counter, 0))
177-
178-
if mib_oid not in lag_oid_list:
179-
lag_oid_list.append(mib_oid)
180-
lag_oid_to_queue_map[mib_oid] = counter_value
181-
else:
182-
lag_oid_to_queue_map[mib_oid] += counter_value
183-
184-
# Append the LAG port counters to the MIB with keeping the OID order
185-
self.mib_oid_list += lag_oid_list
186-
self.mib_oid_to_queue_map.update(lag_oid_to_queue_map)
187-
188144
self.mib_oid_list.sort()
189145

190146
def get_next(self, sub_id):

0 commit comments

Comments
 (0)