Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

[Namespace]: Fix SNMP AgentX socket connection timeout when using Namespace.get_all() #140

Merged
merged 9 commits into from
Jul 11, 2020
Merged

[Namespace]: Fix SNMP AgentX socket connection timeout when using Namespace.get_all() #140

Changes from 1 commit
Commits
Show all changes
9 commits
Select commit Hold shift + click to select a range
16f36d8
[Namespace]: Remove key exists check in dbs_get_all
SuvarnaMeenakshi Jul 10, 2020
af7d4f4
Fix as per review comment.
SuvarnaMeenakshi Jul 10, 2020
7cfc43d
Minor fix.
SuvarnaMeenakshi Jul 10, 2020
e264498
Connect to all required namespace dbs during init and periodic
SuvarnaMeenakshi Jul 10, 2020
a10f55f
Change test_mibs to use generic wrapper function added.
SuvarnaMeenakshi Jul 10, 2020
2fd0960
Fix review comment.
SuvarnaMeenakshi Jul 11, 2020
7e9eb50
Fix as per review comment.
SuvarnaMeenakshi Jul 11, 2020
9c4efd6
Remove whitespace.
SuvarnaMeenakshi Jul 11, 2020
fbba260
Fix review comment. Avoid modifying mutable object kwargs,
SuvarnaMeenakshi Jul 11, 2020
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
14 changes: 9 additions & 5 deletions src/sonic_ax_impl/mibs/__init__.py
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -552,12 +552,16 @@ def dbs_get_all(dbs, db_name, _hash, *args, **kwargs):
db get_all function executed on global and all namespace DBs.
"""
result = {}
Namespace.connect_all_dbs(dbs, db_name)
if len(dbs) == 1:
return dbs[0].get_all(db_name, _hash, *args, **kwargs)
for db_conn in dbs:
db_conn.connect(db_name)
if(db_conn.exists(db_name, _hash)):
ns_result = db_conn.get_all(db_name, _hash, *args, **kwargs)
if ns_result is not None:
result.update(ns_result)
# If there are multiple namespaces, _hash might not be
# present in all namespace, ignore if not present in a
# specfic namespace.
ns_result = db_conn.get_all(db_name, _hash, blocking=False)
if ns_result is not None:
result.update(ns_result)
return result

@staticmethod
Expand Down