[libteam]: Reimplement Warm-Reboot procedure

src/libteam/0007-Skip-setting-the-same-hwaddr-to-lag-port-to-avoid-di.patch

@@ -10,10 +10,10 @@ Signed-off-by: Jipan Yang <jipan.yang@alibaba-inc.com>
  1 file changed, 10 insertions(+), 1 deletion(-)
 
 diff --git a/teamd/teamd.c b/teamd/teamd.c
-index 225b8c8..e28aa7d 100644
+index c987333..0f8993e 100644
 --- a/teamd/teamd.c
 +++ b/teamd/teamd.c
-@@ -866,7 +866,16 @@ static int teamd_set_hwaddr(struct teamd_context *ctx)
+@@ -828,7 +828,16 @@ static int teamd_set_hwaddr(struct teamd_context *ctx)
  		err = -EINVAL;
  		goto free_hwaddr;
  	}

src/libteam/0010-teamd-lacp-update-port-state-according-to-partners-sy.patch

@@ -29,10 +29,10 @@ Date:   Tue Apr 16 12:18:12 2019 -0700
     Signed-off-by: Jiri Pirko <jiri@mellanox.com>
 
 diff --git a/teamd/teamd_runner_lacp.c b/teamd/teamd_runner_lacp.c
-index dae9086..5fa026a 100644
+index 81324de..813b604 100644
 --- a/teamd/teamd_runner_lacp.c
 +++ b/teamd/teamd_runner_lacp.c
-@@ -361,7 +361,8 @@ static int lacp_port_should_be_enabled(struct lacp_port *lacp_port)
+@@ -356,7 +356,8 @@ static int lacp_port_should_be_enabled(struct lacp_port *lacp_port)
  	struct lacp *lacp = lacp_port->lacp;
 
  	if (lacp_port_selected(lacp_port) &&
@@ -42,7 +42,7 @@ index dae9086..5fa026a 100644
  		return true;
  	return false;
  }
-@@ -371,7 +372,8 @@ static int lacp_port_should_be_disabled(struct lacp_port *lacp_port)
+@@ -366,7 +367,8 @@ static int lacp_port_should_be_disabled(struct lacp_port *lacp_port)
  	struct lacp *lacp = lacp_port->lacp;
 
  	if (!lacp_port_selected(lacp_port) ||
@@ -52,7 +52,7 @@ index dae9086..5fa026a 100644
  		return true;
  	return false;
  }
-@@ -966,9 +968,14 @@ static void lacp_port_actor_update(struct lacp_port *lacp_port)
+@@ -936,9 +938,14 @@ static void lacp_port_actor_update(struct lacp_port *lacp_port)
  		state |= INFO_STATE_LACP_ACTIVITY;
  	if (lacp_port->lacp->cfg.fast_rate)
  		state |= INFO_STATE_LACP_TIMEOUT;

src/libteam/0011-libteam-resynchronize-ifinfo-after-lost-RTNLGRP_LINK-.patch

@@ -185,7 +185,7 @@ index 72155ae..5c32a9c 100644
  	if (ret < 0)
  		err(th, "get_ifinfo_list: check_call_change_handers failed");
 diff --git a/libteam/libteam.c b/libteam/libteam.c
-index ac187aa..d5f22cd 100644
+index 106e5cf..afe05cb 100644
 --- a/libteam/libteam.c
 +++ b/libteam/libteam.c
 @@ -236,6 +236,10 @@ int check_call_change_handlers(struct team_handle *th,

src/libteam/0012-teamd-do-not-process-lacpdu-before-the-port-ifinfo-i.patch

@@ -28,19 +28,20 @@ Signed-off-by: Jiri Pirko <jiri@mellanox.com>
  1 file changed, 3 insertions(+)
 
 diff --git a/teamd/teamd_runner_lacp.c b/teamd/teamd_runner_lacp.c
-index 78f05dd..c8ae541 100644
+index 813b604..d6e5840 100644
 --- a/teamd/teamd_runner_lacp.c
 +++ b/teamd/teamd_runner_lacp.c
-@@ -1132,6 +1132,9 @@ static int lacpdu_process(struct lacp_port *lacp_port, struct lacpdu* lacpdu)
- {
- 	int err;
+@@ -1102,6 +1102,9 @@ static int lacpdu_recv(struct lacp_port *lacp_port)
+ 	if (err <= 0)
+ 		return err;
 
 +	if (!teamd_port_present(lacp_port->ctx, lacp_port->tdport))
 +		return 0;
 +
- 	if (!lacpdu_check(lacpdu)) {
+ 	if (!lacpdu_check(&lacpdu)) {
  		teamd_log_warn("malformed LACP PDU came.");
  		return 0;
+
 -- 
 2.7.4
 

src/libteam/0013-teamd-lacp-port-admin-down-recv-not-processing.patch

@@ -1,22 +1,23 @@
 diff --git a/teamd/teamd_runner_lacp.c b/teamd/teamd_runner_lacp.c
-index 4a3fe6b..19592c5 100644
+index d6e5840..2144334 100644
 --- a/teamd/teamd_runner_lacp.c
 +++ b/teamd/teamd_runner_lacp.c
-@@ -1182,12 +1182,17 @@ static int lacpdu_recv(struct lacp_port *lacp_port)
+@@ -1096,6 +1096,7 @@ static int lacpdu_recv(struct lacp_port *lacp_port)
  	struct lacpdu lacpdu;
  	struct sockaddr_ll ll_from;
  	int err;
-+        bool admin_state;
++	bool admin_state;
 
  	err = teamd_recvfrom(lacp_port->sock, &lacpdu, sizeof(lacpdu), 0,
  			     (struct sockaddr *) &ll_from, sizeof(ll_from));
- 	if (err <= 0)
- 		return err;
+@@ -1105,6 +1106,10 @@ static int lacpdu_recv(struct lacp_port *lacp_port)
+ 	if (!teamd_port_present(lacp_port->ctx, lacp_port->tdport))
+ 		return 0;
 
 +	admin_state = team_get_ifinfo_admin_state(lacp_port->ctx->ifinfo);
 +	if (!admin_state)
 +		return 0;
 +
- 	return lacpdu_process(lacp_port, &lacpdu);
- }
-
+ 	if (!lacpdu_check(&lacpdu)) {
+ 		teamd_log_warn("malformed LACP PDU came.");
+ 		return 0;

src/libteam/0014-Send-LACP-PDU-immediately-if-our-state-changed.patch

@@ -8,10 +8,10 @@ Subject: [PATCH] Send LACP PDU immediately if our state changed
  1 file changed, 4 insertions(+), 4 deletions(-)
 
 diff --git a/teamd/teamd_runner_lacp.c b/teamd/teamd_runner_lacp.c
-index 19592c5..a505284 100644
+index 2144334..0930b22 100644
 --- a/teamd/teamd_runner_lacp.c
 +++ b/teamd/teamd_runner_lacp.c
-@@ -1049,8 +1049,7 @@ static int lacp_port_set_state(struct lacp_port *lacp_port,
+@@ -1012,8 +1012,7 @@ static int lacp_port_set_state(struct lacp_port *lacp_port,
  		return err;
 
  	lacp_port_actor_update(lacp_port);
@@ -21,16 +21,16 @@ index 19592c5..a505284 100644
  	return lacpdu_send(lacp_port);
  }
 
-@@ -1160,9 +1159,10 @@ static int lacpdu_process(struct lacp_port *lacp_port, struct lacpdu* lacpdu)
+@@ -1131,9 +1130,10 @@ static int lacpdu_recv(struct lacp_port *lacp_port)
  	if (err)
  		return err;
 
 +	lacp_port_actor_update(lacp_port);
 +
  	/* Check if the other side has correct info about us */
 -	if (!lacp_port->periodic_on &&
--	    memcmp(&lacpdu->partner, &lacp_port->actor,
-+	if (memcmp(&lacpdu->partner, &lacp_port->actor,
+-	    memcmp(&lacpdu.partner, &lacp_port->actor,
++	if (memcmp(&lacpdu.partner, &lacp_port->actor,
  		   sizeof(struct lacpdu_info))) {
  		err = lacpdu_send(lacp_port);
  		if (err)