Skip to content

Connect to teamd before adding the lag to STATE_DB #3984

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

Merged
prsunny merged 16 commits into from
Mar 17, 2026
Merged

Connect to teamd before adding the lag to STATE_DB #3984

Show file tree
Hide file tree
Changes from 4 commits
Commits
Show all changes
16 commits
Select commit Hold shift + click to select a range
f9abf24
Connect to teamd before adding the lag to STATE_DB
saiarcot895 Aug 26, 2025
3dc6420
Merge branch 'master' into fix-teamdsyncd-race-condition
saiarcot895 Nov 10, 2025
f9cae00
Bug and style fixes
saiarcot895 Nov 11, 2025
8c48f08
Merge branch 'fix-teamdsyncd-race-condition' of github.com:saiarcot89…
saiarcot895 Nov 11, 2025
17ad529
Merge branch 'master' into fix-teamdsyncd-race-condition
saiarcot895 Dec 3, 2025
fc730f9
Merge branch 'master' into fix-teamdsyncd-race-condition
prsunny Dec 8, 2025
425500a
Merge branch 'master' into fix-teamdsyncd-race-condition
saiarcot895 Jan 15, 2026
a880c61
Merge branch 'master' into fix-teamdsyncd-race-condition
saiarcot895 Jan 27, 2026
295afa2
Merge commit 'f39134cbb25b6cf27358437a88de6c55c6dc16a1' into fix-team…
saiarcot895 Jan 29, 2026
7e84155
Add some mock tests for teamsyncd
saiarcot895 Feb 3, 2026
1304a59
Merge branch 'fix-teamdsyncd-race-condition' of github.com:saiarcot89…
saiarcot895 Feb 3, 2026
0abb535
Add more tests
saiarcot895 Feb 5, 2026
d6b1810
Merge branch 'master' into fix-teamdsyncd-race-condition
judyjoseph Feb 28, 2026
2e3f35c
Merge branch 'master' into fix-teamdsyncd-race-condition
judyjoseph Mar 4, 2026
1edff3c
Fix Trixie build error
saiarcot895 Mar 5, 2026
ca35fd3
Merge branch 'master' into fix-teamdsyncd-race-condition
judyjoseph Mar 17, 2026
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
2 changes: 1 addition & 1 deletion teamsyncd/Makefile.am
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -12,7 +12,7 @@ teamsyncd_SOURCES = teamsyncd.cpp teamsync.cpp

teamsyncd_CFLAGS = $(DBGFLAGS) $(AM_CFLAGS) $(CFLAGS_COMMON) $(CFLAGS_ASAN)
teamsyncd_CPPFLAGS = $(DBGFLAGS) $(AM_CFLAGS) $(CFLAGS_COMMON) $(CFLAGS_ASAN)
teamsyncd_LDADD = $(LDFLAGS_ASAN) -lnl-3 -lnl-route-3 -lhiredis -lswsscommon -lteam
teamsyncd_LDADD = $(LDFLAGS_ASAN) -lnl-3 -lnl-route-3 -lhiredis -lswsscommon -lteam -lteamdctl

if GCOV_ENABLED
teamsyncd_SOURCES += ../gcovpreload/gcovpreload.cpp
Expand Down
44 changes: 39 additions & 5 deletions teamsyncd/teamsync.cpp
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -12,6 +12,8 @@
#include "warm_restart.h"
#include "teamsync.h"

#include <team.h>
#include <teamdctl.h>
Comment on lines +15 to +16
Copy link

Copilot AI Nov 10, 2025

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Maintainability: These includes are already present in teamsync.h (lines 12-13), which is included on line 13. The duplicate includes are redundant and should be removed.

Suggested change
#include <team.h>
#include <teamdctl.h>

Copilot uses AI. Check for mistakes.
Copy link
Copy Markdown
Contributor Author

@saiarcot895 saiarcot895 Nov 11, 2025

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

This is a stylistic choice to explicitly include what I'm using in this file, so that if the header files change, this file doesn't require changing.

#include <unistd.h>

using namespace std;
Expand Down Expand Up @@ -279,19 +281,51 @@ TeamSync::TeamPortSync::TeamPortSync(const string &lagName, int ifindex,
"Unable to register port change event");
}

struct teamdctl *m_teamdctl = teamdctl_alloc();
Copy link
Copy Markdown
Contributor

@judyjoseph judyjoseph Nov 18, 2025

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

If teamd exits, shouldn't we get netlink for interface down, as we registered earlier for netlink events in teamsyncd ?

netlink.registerGroup(RTNLGRP_LINK);

Copy link
Copy Markdown
Contributor Author

@saiarcot895 saiarcot895 Nov 22, 2025

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

We will, but by the time we get the netlink event, portsorch may have already started processing the port channel interface creation.

if (!m_teamdctl)
{
team_free(m_team);
m_team = NULL;
throw system_error(make_error_code(errc::address_not_available),
"Unable to allocate teamdctl socket");
}

err = teamdctl_connect(m_teamdctl, lagName.c_str(), nullptr, "usock");
if (err)
{
team_free(m_team);
m_team = NULL;
teamdctl_free(m_teamdctl);
throw system_error(make_error_code(errc::connection_refused),
"Unable to connect to teamd");
}

char *response;
err = teamdctl_config_get_raw_direct(m_teamdctl, &response);
Copy link

Copilot AI Nov 10, 2025

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Bug: Memory leak - the response pointer returned by teamdctl_config_get_raw_direct is not freed. According to libteamdctl documentation, the response needs to be freed using teamdctl_config_get_raw_direct_free(response) or free(response) to prevent memory leaks.

Copilot uses AI. Check for mistakes.
Copy link
Copy Markdown
Contributor Author

@saiarcot895 saiarcot895 Nov 11, 2025

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

https://github.com/jpirko/libteam/blob/master/libteamdctl/libteamdctl.c#L521-L532

if (err)
{
team_free(m_team);
m_team = NULL;
teamdctl_disconnect(m_teamdctl);
teamdctl_free(m_teamdctl);
throw system_error(make_error_code(errc::io_error),
"Unable to get config from teamd (to prove that it is running and alive)");
}

teamdctl_disconnect(m_teamdctl);
teamdctl_free(m_teamdctl);

break;
}
catch (const system_error& e)
{
SWSS_LOG_WARN("Failed to initialize team handler. LAG=%s error=%d:%s, attempt=%d",
lagName.c_str(), e.code().value(), e.what(), count);

if (++count == max_retries)
{
throw;
}
else
{
SWSS_LOG_WARN("Failed to initialize team handler. LAG=%s error=%d:%s, attempt=%d",
lagName.c_str(), e.code().value(), e.what(), count);
}

sleep(1);
}
Expand Down
Loading