From: Simon Horman <ho...@verge.net.au>
|
> On Tue, Feb 15, 2011 at 05:44:32PM +0900, Sohgo Takeuchi wrote:
>> 
>> From: Ferenc Wagner <wf...@niif.hu>
>> |
>> > Sohgo Takeuchi <so...@sohgo.dyndns.org> writes:
>>
>> I've found that another problem about an IPv6 fwmark of
>> ldirectord. The ldirectord does not handle an output of the
>> ipvsadm command when using an IPv6 fwmark.  I've made a
>> patch. If you are interested in the patch, please try.
> 
> Takeuchi-san, let me know if you want this merged too.

Hi Simon,

Yes please. But, this patch had a bug. I attach a new one.

with best regards,

-- sohgo
diff --git a/ldirectord/ldirectord.in b/ldirectord/ldirectord.in
--- a/ldirectord/ldirectord.in
+++ b/ldirectord/ldirectord.in
@@ -2403,15 +2403,15 @@
 		if (not defined $line) {
 			last;
 		}
-		if ($line =~ /^(\w+)\s+(\d+\.\d+\.\d+\.\d+\:\d+|\[[0-9A-Fa-f:]+\]:\d+|\d+)\s+(\w+)\s+persistent\s+(\d+)\s+mask\s+(.*)/) {
-			$real_service = "$2 ".lc($1);
-			$oldsrv{"$real_service"} = {"real"=>{}, "scheduler"=>$3, "persistent"=>$4, "netmask"=>$5};
-		} elsif ($line =~ /^(\w+)\s+(\d+\.\d+\.\d+\.\d+\:\d+|\[[0-9A-Fa-f:]+\]:\d+|\d+)\s+(\w+)\s+persistent\s+(\d+)/) {
-			$real_service = "$2 ".lc($1);
-			$oldsrv{"$real_service"} = {"real"=>{}, "scheduler"=>$3, "persistent"=>$4};
-		} elsif ($line =~ /^(\w+)\s+(\d+\.\d+\.\d+\.\d+\:\d+|\[[0-9A-Fa-f:]+\]:\d+|\d+)\s+(\w+)/) {
-			$real_service = "$2 ".lc($1);
-			$oldsrv{"$real_service"} = {"real"=>{}, "scheduler"=>$3};
+		if ($line =~ /^(\w+)\s+(\d+\.\d+\.\d+\.\d+\:\d+|\[[0-9A-Fa-f:]+\]:\d+|\d+)( IPv6)?\s+(\w+)\s+persistent\s+(\d+)\s+mask\s+(.*)/) {
+			$real_service = &gen_real_service_str($2, $1, $3);
+			$oldsrv{"$real_service"} = {"real"=>{}, "scheduler"=>$4, "persistent"=>$5, "netmask"=>$6};
+		} elsif ($line =~ /^(\w+)\s+(\d+\.\d+\.\d+\.\d+\:\d+|\[[0-9A-Fa-f:]+\]:\d+|\d+)( IPv6)?\s+(\w+)\s+persistent\s+(\d+)/) {
+			$real_service = &gen_real_service_str($2, $1, $3);
+			$oldsrv{"$real_service"} = {"real"=>{}, "scheduler"=>$4, "persistent"=>$5};
+		} elsif ($line =~ /^(\w+)\s+(\d+\.\d+\.\d+\.\d+\:\d+|\[[0-9A-Fa-f:]+\]:\d+|\d+)( IPv6)?\s+(\w+)/) {
+			$real_service = &gen_real_service_str($2, $1, $3);
+			$oldsrv{"$real_service"} = {"real"=>{}, "scheduler"=>$4};
 		} elsif ($line =~ /^  ->\s+(\d+\.\d+\.\d+\.\d+\:\d+|\[[0-9A-Fa-f:]+\]:\d+)\s+(\w+)\s+(\d+)/) {
 			if (not defined( $real_service)) {
 				&ld_debug(2, "Real server read from ipvsadm " .
@@ -2438,6 +2438,20 @@
 	return(\%oldsrv);
 }
 
+sub gen_real_service_str
+{
+	my ($service_address, $protocol, $v6flag) = @_;
+
+	return "$service_address ".lc($protocol).(defined($v6flag) ? "6" : "");
+}
+
+sub get_real_service_str
+{
+	my ($v) = (@_);
+
+	return &get_virtual($v) . " "  . $v->{protocol} . ($v->{addressfamily} == AF_INET6 ? "6" : "");
+}
+
 sub ld_start
 {
 	my $oldsrv;
@@ -2451,7 +2465,7 @@
 
 	# make sure virtual servers are up to date
 	foreach $nv (@VIRTUAL) {
-		my $real_service = &get_virtual($nv) . " "  . $nv->{protocol};
+		my $real_service = &get_real_service_str($nv);
 
 		if (exists($oldsrv->{"$real_service"})) {
 			# service exists, modify it
@@ -2468,7 +2482,7 @@
 	# make sure real servers are up to date
 	foreach $nv (@VIRTUAL) {
 		my $nreal = $nv->{real};
-		my $ov = $oldsrv->{&get_virtual($nv) . " " . $nv->{protocol}};
+		my $ov = $oldsrv->{&get_real_service_str($nv)};
 		my $or = $ov->{real};
 		my $fallback = fallback_find($nv);
 
@@ -2498,7 +2512,7 @@
 			delete($$or{$k});
 		}
 
-		delete($oldsrv->{&get_virtual($nv) . " " . $nv->{protocol}});
+		delete($oldsrv->{&get_real_service_str($nv)});
 		&fallback_on($nv);
 	}
 
@@ -2511,8 +2525,7 @@
 
 	# remove remaining entries for virtual servers
 	foreach $nv (@OLDVIRTUAL) {
-		if (! defined($oldsrv->{&get_virtual($nv) . " " .
-					$nv->{protocol}})) {
+		if (! defined($oldsrv->{&get_real_service_str($nv)})) {
 			next;
 		}
 		purge_virtual($nv, "start");
@@ -3747,7 +3760,7 @@
 	$virtual_str = &get_virtual($v);
 
 	$oldsrv=&ld_read_ipvsadm();
-	$ov=$oldsrv->{$virtual_str . " " . $v->{"protocol"}};
+	$ov=$oldsrv->{&get_real_service_str($v)};
 	if(!defined($ov)){
 		return;
 	}
@@ -3867,7 +3880,7 @@
 	#if the server exists then restore its weight
 	# otherwise add the server
 	$oldsrv=&ld_read_ipvsadm();
-	$ov=$oldsrv->{&get_virtual($v) . " " . $v->{"protocol"}};
+	$ov=$oldsrv->{&get_real_service_str($v)};
 	if(defined($ov)){
 		$or=$ov->{"real"}->{$rservice};
 	}
_______________________________________________
Please read the documentation before posting - it's available at:
http://www.linuxvirtualserver.org/

LinuxVirtualServer.org mailing list - lvs-users@LinuxVirtualServer.org
Send requests to lvs-users-requ...@linuxvirtualserver.org
or go to http://lists.graemef.net/mailman/listinfo/lvs-users

Reply via email to