From: fendo <fendo@bi12info.com>
Date: Wed, 22 May 2013 19:01:18 +0000 (+0200)
Subject: Merge branch 'master' into samesversion
X-Git-Tag: 2.2.1-2sames3.9~4
X-Git-Url: http://git.sameswireless.fr/l2tpns.git/commitdiff_plain/72a615e7e39a3ea0b46d8c4d4704159fc973c60e?hp=-c

Merge branch 'master' into samesversion
---

72a615e7e39a3ea0b46d8c4d4704159fc973c60e
diff --combined l2tpns.c
index 537ea34,c6fe521..77c302c
--- a/l2tpns.c
+++ b/l2tpns.c
@@@ -75,7 -75,7 +75,7 @@@ int cluster_sockfd = -1;	// Intra-clust
  int epollfd = -1;		// event polling
  time_t basetime = 0;		// base clock
  char hostname[MAXHOSTNAME] = "";	// us.
 -static int tunidx;		// ifr_ifindex of tun device
 +int tunidx;				// ifr_ifindex of tun device
  int nlseqnum = 0;		// netlink sequence number
  int min_initok_nlseqnum = 0;	// minimun seq number for messages after init is ok
  static int syslog_log = 0;	// are we logging to syslog
@@@ -92,7 -92,10 +92,7 @@@ uint16_t MSS = 0;		// TCP MS
  struct cli_session_actions *cli_session_actions = NULL;	// Pending session changes requested by CLI
  struct cli_tunnel_actions *cli_tunnel_actions = NULL;	// Pending tunnel changes required by CLI
  
 -union iphash {
 -	sessionidt sess;
 -	union iphash *idx;
 -} ip_hash[256];			// Mapping from IP address to session structures.
 +union iphash ip_hash[256];	// Mapping from IP address to session structures.
  
  struct ipv6radix {
  	sessionidt sess;
@@@ -183,7 -186,6 +183,7 @@@ config_descriptt config_values[] = 
  	CONFIG("disable_sending_hello", disable_sending_hello, BOOL),
  	CONFIG("disable_no_spoof", disable_no_spoof, BOOL),
  	CONFIG("bind_multi_address", bind_multi_address, STRING),
 +	CONFIG("grp_txrate_average_time", grp_txrate_average_time, INT),
  	CONFIG("pppoe_only_equal_svc_name", pppoe_only_equal_svc_name, BOOL),
  	CONFIG("multi_hostname", multi_hostname, STRING),
  	{ NULL, 0, 0, 0 }
@@@ -214,7 -216,6 +214,7 @@@ tunnelt *tunnel = NULL;			// Array of t
  bundlet *bundle = NULL;			// Array of bundle structures.
  fragmentationt *frag = NULL;		// Array of fragmentation structures.
  sessiont *session = NULL;		// Array of session structures.
 +groupsesst *grpsession = NULL;		// Array of groupsesst structures.
  sessionlocalt *sess_local = NULL;	// Array of local per-session counters.
  radiust *radius = NULL;			// Array of radius structures.
  ippoolt *ip_address_pool = NULL;	// Array of dynamic IP addresses.
@@@ -225,6 -226,9 +225,6 @@@ struct Tstats *_statistics = NULL
  struct Tringbuffer *ringbuffer = NULL;
  #endif
  
 -static ssize_t netlink_send(struct nlmsghdr *nh);
 -static void netlink_addattr(struct nlmsghdr *nh, int type, const void *data, int alen);
 -static void cache_ipmap(in_addr_t ip, sessionidt s);
  static void uncache_ipmap(in_addr_t ip);
  static void cache_ipv6map(struct in6_addr ip, int prefixlen, sessionidt s);
  static void free_ip_address(sessionidt s);
@@@ -253,9 -257,8 +253,9 @@@ static clockt now(double *f
  	if (f) *f = t.tv_sec + t.tv_usec / 1000000.0;
  	if (t.tv_sec != time_now)
  	{
 -	    time_now = t.tv_sec;
 -	    time_changed++;
 +		time_now = t.tv_sec;
 +		time_changed++;
 +		grp_time_changed();
  	}
  
  	// Time in milliseconds
@@@ -614,7 -617,7 +614,7 @@@ static void initnetlink(void
  	}
  }
  
 -static ssize_t netlink_send(struct nlmsghdr *nh)
 +ssize_t netlink_send(struct nlmsghdr *nh)
  {
  	struct sockaddr_nl nladdr;
  	struct iovec iov;
@@@ -650,7 -653,7 +650,7 @@@ static ssize_t netlink_recv(void *buf, 
  }
  
  /* adapted from iproute2 */
 -static void netlink_addattr(struct nlmsghdr *nh, int type, const void *data, int alen)
 +void netlink_addattr(struct nlmsghdr *nh, int type, const void *data, int alen)
  {
  	int len = RTA_LENGTH(alen);
  	struct rtattr *rta;
@@@ -1028,7 -1031,7 +1028,7 @@@ sessionidt sessionbyipv6(struct in6_add
  //
  // (It's actually cached in network order)
  //
 -static void cache_ipmap(in_addr_t ip, sessionidt s)
 +void cache_ipmap(in_addr_t ip, sessionidt s)
  {
  	in_addr_t nip = htonl(ip);	// MUST be in network order. I.e. MSB must in be ((char *) (&ip))[0]
  	uint8_t *a = (uint8_t *) &nip;
@@@ -1410,7 -1413,6 +1410,7 @@@ static void update_session_out_stat(ses
  void processipout(uint8_t *buf, int len)
  {
  	sessionidt s;
 +	groupidt g;
  	sessiont *sp;
  	tunnelidt t;
  	in_addr_t ip;
@@@ -1447,31 -1449,7 +1447,31 @@@
  	}
  
  	ip = *(uint32_t *)(buf + 16);
 -	if (!(s = sessionbyip(ip)))
 +	if ((g = grp_groupbyip(ip)))
 +	{
 +		s = grp_getnextsession(g, ip);
 +		if (!s)
 +		{
 +			// Is this a packet for a session that doesn't exist?
 +			static int rate = 0;	// Number of ICMP packets we've sent this second.
 +			static int last = 0;	// Last time we reset the ICMP packet counter 'rate'.
 +
 +			if (last != time_now)
 +			{
 +				last = time_now;
 +				rate = 0;
 +			}
 +
 +			if (rate++ < config->icmp_rate) // Only send a max of icmp_rate per second.
 +			{
 +				LOG(4, 0, 0, "IP: Sending ICMP host unreachable to %s\n", fmtaddr(*(in_addr_t *)(buf + 12), 0));
 +				host_unreachable(*(in_addr_t *)(buf + 12), *(uint16_t *)(buf + 4),
 +					config->bind_address ? config->bind_address : my_address, buf, len);
 +			}
 +			return;
 +		}
 +	}
 +	else if (!(s = sessionbyip(ip)))
  	{
  		// Is this a packet for a session that doesn't exist?
  		static int rate = 0;	// Number of ICMP packets we've sent this second.
@@@ -2102,7 -2080,7 +2102,7 @@@ void sessionshutdown(sessionidt s, cha
  		session[s].die = TIME + 150; // Clean up in 15 seconds
  
  	if (session[s].ip)
 -	{                          // IP allocated, clear and unroute
 +	{	// IP allocated, clear and unroute
  		int r;
  		int routed = 0;
  		for (r = 0; r < MAXROUTE && session[s].route[r].ip; r++)
@@@ -2302,8 -2280,6 +2302,8 @@@ static void sessionclear(sessionidt s
  // kill a session now
  void sessionkill(sessionidt s, char *reason)
  {
 +	groupidt g;
 +
  	CSTAT(sessionkill);
  
  	if (!session[s].opened) // not alive
@@@ -2332,12 -2308,6 +2332,12 @@@
  	}
  
  	LOG(2, s, session[s].tunnel, "Kill session %d (%s): %s\n", s, session[s].user, reason);
 +
 +	if ((g = grp_groupbysession(s)))
 +	{
 +		grp_removesession(g, s);
 +	}
 +
  	sessionclear(s);
  	cluster_send_session(s);
  }
@@@ -3735,7 -3705,7 +3735,7 @@@ static void regular_cleanups(double per
  
  		// No data in ECHO_TIMEOUT seconds, send LCP ECHO
  		if (session[s].ppp.phase >= Establish && (time_now - session[s].last_packet >= config->echo_timeout) &&
 -			(time_now - sess_local[s].last_echo >= ECHO_TIMEOUT))
 +			(time_now - sess_local[s].last_echo >= config->echo_timeout))
  		{
  			uint8_t b[MAXETHER];
  
@@@ -4672,8 -4642,6 +4672,8 @@@ static void initdata(int optdebug, cha
  #endif /* BGP */
  
  	lac_initremotelnsdata();
 +
 +	grp_initdata();
  }
  
  static int assign_ip_address(sessionidt s)
@@@ -5214,9 -5182,6 +5214,9 @@@ int main(int argc, char *argv[]
  			LOG(0, 0, 0, "Can't lock pages: %s\n", strerror(errno));
  	}
  
 +	//LOG(3, 0, 0, "Debug sizeof struct: sessiont %lu, tunnelt %lu, bundlet %lu, groupsesst %lu\n",
 +	//	sizeof(sessiont), sizeof(tunnelt), sizeof(bundlet), sizeof(groupsesst));
 +
  	mainloop();
  
  	/* remove plugins (so cleanup code gets run) */
@@@ -5506,6 -5471,8 +5506,8 @@@ static void update_config(
  				config->nbmultihostname++;
  				if (config->nbmultihostname >= MAX_NBHOSTNAME) break;
  			}
+ 
+ 			shost = n;
  		}
  
  		if (config->nbmultihostname >= 1)
@@@ -5725,7 -5692,6 +5727,7 @@@ int sessionsetup(sessionidt s, tunnelid
  	if (!session[s].bundle || (bundle[session[s].bundle].num_of_links == 1))
  	{
  		int routed = 0;
 +		groupidt g;
  
  		// Add the route for this session.
  		for (r = 0; r < MAXROUTE && session[s].route[r].ip; r++)
@@@ -5748,12 -5714,6 +5750,12 @@@
  		}
  		else
  			cache_ipmap(session[s].ip, s);
 +
 +		if ((g = grp_groupbysession(s)))
 +		{
 +			grp_setgrouproute(g, 1);
 +			cluster_send_groupe(g);
 +		}
  	}
  
  	sess_local[s].lcp_authtype = 0; // RADIUS authentication complete