Fri Oct 27 08:03:09 PDT 2006
- Previous message: [Slony1-commit] By cbbrowne: Fix spelling of "tranaction"
- Next message: [Slony1-commit] By cbbrowne: Remove code that generates listen paths - no longer needed
- Messages sorted by: [ date ] [ thread ] [ subject ] [ author ]
Log Message:
-----------
In 1.2, listen paths are generated automatically, so there is no need
for the altperl scripts to generate them.
Tags:
----
REL_1_2_STABLE
Modified Files:
--------------
slony1-engine/tools/altperl:
slonik_init_cluster.pl (r1.1 -> r1.1.4.1)
-------------- next part --------------
Index: slonik_init_cluster.pl
===================================================================
RCS file: /usr/local/cvsroot/slony1/slony1-engine/tools/altperl/slonik_init_cluster.pl,v
retrieving revision 1.1
retrieving revision 1.1.4.1
diff -Ltools/altperl/slonik_init_cluster.pl -Ltools/altperl/slonik_init_cluster.pl -u -w -r1.1 -r1.1.4.1
--- tools/altperl/slonik_init_cluster.pl
+++ tools/altperl/slonik_init_cluster.pl
@@ -52,11 +52,6 @@
# STORE PATH
print SLONIK "\n# STORE PATH\n";
-my @COST;
-my @VIA;
-my @PATH;
-generate_listen_paths();
-
print SLONIK " echo 'Next: configure paths for each node/origin';\n";
foreach my $nodea (@NODES) {
my $dsna = $DSN[$nodea];
@@ -77,152 +72,9 @@
}
}
-# STORE LISTEN
-print SLONIK "\n# STORE LISTEN\n";
-foreach my $origin (@NODES) {
- my $dsna = $DSN[$origin];
- foreach my $receiver (@NODES) {
- if ($origin != $receiver) {
- my $provider = $VIA[$origin][$receiver];
- print SLONIK " store listen (origin = $origin, receiver = $receiver, provider = $provider);\n";
- }
- }
-}
print SLONIK " echo 'Replication nodes prepared';\n";
print SLONIK " echo 'Please start a slon replication daemon for each node';\n";
close SLONIK;
run_slonik_script($FILE);
-report_on_paths();
-
-sub generate_listen_paths {
- my $infinity = 10000000; # Initial costs are all infinite
- foreach my $node1 (@NODES) {
- foreach my $node2 (@NODES) {
- $COST[$node1][$node2] = $infinity;
- }
- }
-
- # Initialize paths between parents and children, and based on them,
- # generate initial seeding of listener paths, @VIA
-
- foreach my $node1 (@NODES) {
- $COST[$node1][$node1] = 0;
- $VIA[$node1][$node1] = 0;
- foreach my $node2 (@NODES) {
- if ($node2 != $node1) {
- if ((not ($PARENT[$node1] or $PARENT[$node2])) or
- ($PARENT[$node1] and $PARENT[$node1] == $node2) or
- ($PARENT[$node2] and $PARENT[$node2] == $node1)) {
- $PATH[$node1][$node2] = 1;
- $PATH[$node2][$node1] = 1;
- # Set up a cost 1 path between them
- # Parent to child
- $COST[$node1][$node2] = 1;
- $VIA[$node1][$node2] = $node1;
- # Child to parent
- $COST[$node2][$node1] = 1;
- $VIA[$node2][$node1] = $node2;
- }
- }
- }
- }
-
- # Now, update the listener paths...
- # 4 level nested iteration:
- # 1 while not done, do
- # 2 for each node, node1
- # 3 for each node, node2, where node2 <> node1, where we don't
- # yet have a listener path
- # 4 for each node node3 (<> node1 or node2),
- # consider introducing the listener path:
- # node1 to node2 then node2 to node3
- # In concept, it's an O(n^4) algorithm; since the number of nodes, n,
- # is not likely to get particularly large, it's not worth tuning
- # further.
- $didwork = "yes";
- while ($didwork eq "yes") {
- $didwork = "no";
- foreach my $node1 (@NODES) {
- foreach my $node3 (@NODES) {
- if (($VIA[$node3][$node1] == 0) && ($node3 != $node1)) {
- foreach my $node2 (@NODES) {
- if ($PATH[$node1][$node2] && ($VIA[$node2][$node3] != 0) && ($node2 != $node3) && ($node2 != $node1)) {
- # Consider introducing a path from n1 to n2 then n2 to n3
- # as a cheaper alternative to going direct from n1 to n3
- my $oldcost = $COST[$node3][$node1];
- my $newcost = $COST[$node1][$node2] + $COST[$node2][$node3];
- if ($newcost < $oldcost) {
- $didwork = "yes";
- # So we go via node 2
- $VIA[$node3][$node1] = $node2;
- $COST[$node3][$node1] = $newcost;
- $VIA[$node1][$node3] = $node2;
- $COST[$node1][$node3] = $newcost;
- }
- }
- }
- }
- }
- }
- }
-}
-
-sub report_on_paths {
- print "# Configuration Summary:\n";
- print "#\n";
- print "# COST\n";
- print "# ";
- foreach my $node2 (@NODES) {
- printf "| %3d ", $node2;
- }
- print "|\n# ";
- print ("-----+" x (scalar(@NODES) + 1));
- print "\n";
- foreach my $node1 (@NODES) {
- printf "# %3d ", $node1;
- foreach my $node2 (@NODES) {
- if ($COST[$node2][$node1] == $infinity) {
- printf "| inf ";
- } else {
- printf "|%4d ", $COST[$node2][$node1];
- }
- }
- print "|\n";
- }
- print "# \n";
- print "# VIA\n";
- print "# ";
- foreach my $node2 (@NODES) {
- printf "| %3d ", $node2;
- }
- print "|\n# ";
- print ("-----+" x (scalar(@NODES) + 1));
- print "\n";
- foreach my $node1 (@NODES) {
- printf "# %3d ", $node1;
- foreach my $node2 (@NODES) {
- printf "|%4d ", $VIA[$node2][$node1];
- }
- print "|\n";
- }
-
- print "# \n";
- print "# PATHS\n";
- print "# ";
- foreach my $node2 (@NODES) {
- printf "| %3d ", $node2;
- }
- print "|\n# ";
- print ("-----+" x (scalar(@NODES) + 1));
- print "\n";
- foreach my $node1 (@NODES) {
- printf "# %3d ", $node1;
- foreach my $node2 (@NODES) {
- printf "|%4d ", $PATH[$node2][$node1];
- }
- print "|\n";
- }
- print "\n";
-}
- Previous message: [Slony1-commit] By cbbrowne: Fix spelling of "tranaction"
- Next message: [Slony1-commit] By cbbrowne: Remove code that generates listen paths - no longer needed
- Messages sorted by: [ date ] [ thread ] [ subject ] [ author ]
More information about the Slony1-commit mailing list