/[rserv]/bin/Replicate
This is repository of my old source code which isn't updated any more. Go to git.rot13.org for current projects!
ViewVC logotype

Contents of /bin/Replicate

Parent Directory Parent Directory | Revision Log Revision Log


Revision 1.18 - (show annotations)
Sun Nov 2 21:07:14 2003 UTC (20 years, 4 months ago) by dpavlin
Branch: MAIN
CVS Tags: HEAD
Changes since 1.17: +15 -26 lines
first multi-master version which pass regression tests (that doesn't
mean working; tests might just be too little...)
renamed multiplemaster to simple multimaster

1 #!/usr/bin/perl -w
2 # Replicate
3 # Vadim Mikheev, (c) 2000, PostgreSQL Inc.
4
5 eval '(exit $?0)' && eval 'exec perl -S $0 ${1+"$@"}'
6 & eval 'exec perl -S $0 $argv:q'
7 if 0;
8
9 BEGIN {
10 my $basedir = $0; $basedir =~ s#/[^/]+$##;
11 unshift(@INC, "$basedir/../share");
12 }
13
14 use strict;
15 use IO::File;
16 use Getopt::Long;
17 use RServ;
18
19 $| = 1;
20
21 #my ($debug,$verbose) = (0,0);
22 my ($help,$masterhost,$masterport,$masteruser,$masterpassword,
23 $slavehost,$slaveport,$slaveuser,$slavepassword);
24 my $snapshot = ".__Snapshot";
25 my $multimaster = 0;
26
27 my $result = GetOptions(
28 "debug!" => \$debug, "verbose!" => \$verbose, "help" => \$help,
29 "masterhost=s" => \$masterhost, "masterport=i" => \$masterport,
30 "masteruser=s" => \$masteruser, "masterpassword=s" => \$masterpassword,
31 "slavehost=s" => \$slavehost, "slaveport=i" => \$slaveport,
32 "slaveuser=s" => \$slaveuser, "slavepassword=s" => \$slavepassword,
33 "snapshot=s" => \$snapshot,
34 "multimaster" => \$multimaster,
35 );
36
37 if (defined($help) || (scalar(@ARGV) < 2)) {
38 print "Usage: $0 [options] masterdb slavedb
39 Options:
40 --masterhost=hostname --masterport=port
41 --masteruser=username --masterpassword=string
42 --snapshot=snapshot
43 [--masterserver=master_number]
44 ";
45 exit ((scalar(@ARGV) < 2)? 1:0);
46 }
47
48 $snapshot .= '.' . $$;
49
50 $RServ::quiet = !$verbose;
51 #if ($debug) {
52 #print "## q:$RServ::quiet v:$RServ::verbose d:$RServ::debug\n";
53 # $RServ::quiet = 0;
54 # no warnings 'vars';
55 # $RServ::debug = $debug;
56 #print "## q:$RServ::quiet v:$RServ::verbose d:$RServ::debug\n";
57 #}
58
59 my $master = $ARGV[0] || "master";
60 my $slave = $ARGV[1] || "slave";
61 my $tables = $#ARGV < 2 ? undef : { map {($_, undef)} @ARGV[2..$#ARGV] };
62
63 # first, let's check if a instance is alrealy running
64
65 my $str = $master;
66 $str .= '@'.$masterhost if (defined($masterhost));
67 $str .= ':'.$slave;
68 $str .= '@'.$slavehost if (defined($slavehost));
69 my $fname = "/tmp/.lock_rserv-$str";
70 if (-e $fname) {
71 open(PID,$fname) || die "can't open pid file '$fname'";
72 my $pid = <PID>; chomp($pid);
73 close(PID);
74 open(PS,"ps ax |") || die "can't start ps to check for running rServ with pid $pid\n";
75 my $is_running = 0;
76 while(<PS>) {
77 chomp;
78 $is_running = 1 if (/^\s*$pid\s/);
79 }
80 close(PS);
81 if ($is_running) {
82 print STDERR "rServ [$pid] is already running for $str. Remove $fname to override this.\n";
83 exit(1);
84 } else {
85 print STDERR "found stale pid file, but no running rServ [$pid], overriding.\n";
86 }
87 }
88 open ARQ, ">$fname" || die "Cannot open $fname: $!\n";
89 print ARQ "$$\n";
90 close ARQ;
91
92 $SIG{__DIE__} = \&mydie;
93 sub mydie {
94 unlink $fname;
95 print @_;
96 exit 1;
97 }
98
99 my $minfo = MkInfo($master,$masterhost,$masterport,$masteruser,$masterpassword);
100 my $sinfo = MkInfo($slave,$slavehost,$slaveport,$slaveuser,$slavepassword);
101
102 print "Master connection is $minfo\n" if ($debug);
103 print "Slave connection is $sinfo\n" if ($debug);
104
105 my $mconn = Connect($minfo);
106 my $sconn = Connect($sinfo);
107
108 $slavehost = 'localhost' if (! $slavehost);
109 $masterhost = 'localhost' if (! $masterhost);
110
111 my $slaveId = GetServerId($mconn, $slave, $slavehost);
112
113 die "\n>>>>>>>>>>>>> ERROR: Can't GetServerId for $sinfo\n" if (! defined($slaveId));
114
115 if ($slaveId < 0) {
116 unlink $fname;
117 die "\n>>>>>>>>>>>>> ERROR: GetServerId returned $slaveId < 0\n";
118 }
119 #SyncSync($mconn, $sconn);
120
121 my $masterId = GetServerId($mconn, $master, $masterhost);
122
123 die "\n>>>>>>>>>>>>> ERROR: Can't GetServerId for $sinfo\n" if (! defined($masterId));
124
125 if ($masterId < 0) {
126 unlink $fname;
127 die "\n>>>>>>>>>>>>> ERROR: GetServerId returned $masterId < 0\n";
128 }
129 #SyncSync($sconn, $mconn);
130
131 print "Using snapshot file: $snapshot\n" if ($debug);
132
133 my $outf = new IO::File;
134 open $outf, ">$snapshot";
135 print "\n>>>>>>>>>>>>> Prepare Snapshot\n\n" if ($verbose);
136 print "master id: $masterId slave id: $slaveId\n" if ($debug);
137 #my $res = PrepareSnapshot($mconn, $sconn, $outf, $masterId, $slaveId, $multimaster, $tables);
138 my $res = PrepareSnapshot($mconn, $sconn, $outf, $masterId, $slaveId, $multimaster);
139 close $outf;
140 if ($res < 0) {
141 unlink $fname;
142 die "\n>>>>>>>>>>>>> ERROR\n";
143 }
144 if ($res == 0)
145 {
146 print "\n>>>>>>>>>>>>> DBases are sync-ed\n" if ($verbose);
147 unlink $snapshot unless ($debug);
148 unlink $fname;
149 exit(0);
150 }
151
152 my $inpf = new IO::File;
153 open $inpf, "<$snapshot";
154 print "\n>>>>>>>>>>>>> Apply Snapshot\n\n" if ($verbose);
155 #$res = ApplySnapshot($sconn, $inpf, $multimaster, $tables);
156 $res = ApplySnapshot($sconn, $inpf, $multimaster);
157 close $inpf;
158 if ($res < 0) {
159 unlink $fname;
160 die "\n>>>>>>>>>>>>> ERROR\n";
161 }
162
163 if ($res > 0)
164 {
165 print "Snapshot applied\n" if ($verbose);
166 unlink $snapshot unless ($debug);
167 SyncSync($mconn, $sconn);
168 }
169
170 unlink $fname;
171 exit(0);
172
173 ###########################################################################
174
175 sub SyncSync
176 {
177 ($mconn, $sconn) = @_;
178
179 print "\n>>>>>>>>>>>>> Sync SyncID\n\n" if ($verbose);
180 print "Get last SyncID from Slave DB\n" if ($verbose);
181 my $syncid = GetSyncID($sconn);
182 if ($syncid && $syncid > 0)
183 {
184 print "Last SyncID applied: $syncid\n" if ($verbose);
185 print "Sync SyncID\n" if ($verbose);
186
187 $res = SyncSyncID($mconn, $slaveId, $syncid);
188
189 print "Succeeded\n" if (($res > 0) && ($verbose));
190 }
191 }

  ViewVC Help
Powered by ViewVC 1.1.26