X-Git-Url: http://git.sameswireless.fr/l2tpns.git/blobdiff_plain/07e1df5b92a099b3b390822d0f594b175226dc01..ac381e055bf6c0016b5e0246cf30378209f11233:/l2tpns.c

diff --git a/l2tpns.c b/l2tpns.c
index 1c50a3e..5947561 100644
--- a/l2tpns.c
+++ b/l2tpns.c
@@ -163,6 +163,7 @@ config_descriptt config_values[] = {
 	CONFIG("icmp_rate", icmp_rate, INT),
 	CONFIG("packet_limit", max_packets, INT),
 	CONFIG("cluster_address", cluster_address, IPv4),
+	CONFIG("cluster_port", cluster_port, INT),
 	CONFIG("cluster_interface", cluster_interface, STRING),
 	CONFIG("cluster_mcast_ttl", cluster_mcast_ttl, INT),
 	CONFIG("cluster_hb_interval", cluster_hb_interval, INT),
@@ -2715,7 +2716,14 @@ void processudp(uint8_t *buf, int len, struct sockaddr_in *addr, uint16_t indexu
 					result = 2; // general error
 					error = 3; // reserved field non-zero
 					msg = 0;
-					continue; // next
+					if (n == 0)
+					{
+						// if continue a infinity loop is created.
+						LOG(1, s, t, "It's infinite loop protection %02X\n", *b);
+						return;
+					}
+					else
+						continue; // next
 				}
 				b += 2;
 				if (*(uint16_t *) (b))
@@ -2725,7 +2733,14 @@ void processudp(uint8_t *buf, int len, struct sockaddr_in *addr, uint16_t indexu
 					result = 2; // general error
 					error = 6; // generic vendor-specific error
 					msg = "unsupported vendor-specific";
-					continue; // next
+					if (n == 0)
+					{
+						// if continue a infinity loop is created.
+						LOG(1, s, t, "It's infinite loop protection %02X\n", *b);
+						return;
+					}
+					else
+						continue; // next
 				}
 				b += 2;
 				mtype = ntohs(*(uint16_t *) (b));
@@ -5628,6 +5643,7 @@ static void update_config()
 	memcpy(config->old_plugins, config->plugins, sizeof(config->plugins));
 	if (!config->multi_read_count) config->multi_read_count = 10;
 	if (!config->cluster_address) config->cluster_address = inet_addr(DEFAULT_MCAST_ADDR);
+	if (!config->cluster_port) config->cluster_port = CLUSTERPORT;
 	if (!*config->cluster_interface)
 		strncpy(config->cluster_interface, DEFAULT_MCAST_INTERFACE, sizeof(config->cluster_interface) - 1);