Skip to content

Commit

Permalink
Added a protection for index out of range
Browse files Browse the repository at this point in the history
Signed-off-by: Elad Gershon <egershon@nvidia.com>
  • Loading branch information
egershonNvidia committed Jan 27, 2025
1 parent 5d7ca22 commit f772ea3
Show file tree
Hide file tree
Showing 2 changed files with 12 additions and 1 deletion.
11 changes: 11 additions & 0 deletions plugins/fluentd_telemetry_plugin/src/streamer.py
Original file line number Diff line number Diff line change
Expand Up @@ -95,6 +95,17 @@ def ufm_telemetry_endpoints(self):
xdr_ports_types = self.ufm_telemetry_xdr_ports_types.split(splitter)
intervals = self.streaming_interval.split(splitter)
msg_tags = self.fluentd_msg_tag.split(splitter)

error_message = ""
expected_amount = len(hosts)
for name, array in [("port", ports), ("url", urls), ("interval" ,intervals), ("message_tag_name", msg_tags),\
("xdr_mode", xdr_mode), ("xdr_ports_types", xdr_ports_types)]:
if len(array)!= expected_amount:
error_message += f"setting under ufm-telemetry-endpoint {name} for multi telemetry, expected {len(hosts)} options got {len(array)}."

if len(error_message)>0:
raise Exception(error_message)

endpoints = []
for i, value in enumerate(hosts):
_is_xdr_mode = Utils.convert_str_to_type(xdr_mode[i], 'boolean')
Expand Down

0 comments on commit f772ea3

Please sign in to comment.