## Request to pause a sync
elsif ($name =~ /^pause_sync_(.+)/o) {
my $syncname = $1;
- my $msg;
+ my $msg;
## We will not pause if this sync does not exist or it is inactive
if (! exists $self->{sync}{$syncname}) {
$msg = qq{Cannot pause inactive sync "$syncname"};
}
else {
- ## Mark it as paused, stop the kids and controller
+ ## Mark it as paused, stop the kids and controller
$sync->{$syncname}{paused} = 1;
- my $stopsync = "stopsync_$syncname";
- $self->db_notify($maindbh, "kid_$stopsync");
- $self->db_notify($maindbh, "ctl_$stopsync");
- $maindbh->commit();
- $self->glog(qq{Set sync "$syncname" as paused}, LOG_VERBOSE);
+ my $stopsync = "stopsync_$syncname";
+ $self->db_notify($maindbh, "kid_$stopsync");
+ $self->db_notify($maindbh, "ctl_$stopsync");
+ $maindbh->commit();
+ $self->glog(qq{Set sync "$syncname" as paused}, LOG_VERBOSE);
}
if (defined $msg) {
$self->glog($msg, LOG_TERSE);
## Request to resume a sync
elsif ($name =~ /^resume_sync_(.+)/o) {
my $syncname = $1;
- my $msg;
+ my $msg;
## We will not resume if this sync does not exist or it is inactive
if (! exists $self->{sync}{$syncname}) {
$msg = qq{Cannot resume inactive sync "$syncname"};
}
else {
- ## Mark it as resumed, stop the kids
+ ## Mark it as resumed, stop the kids
$sync->{$syncname}{paused} = 0;
- $self->glog(qq{Set sync "$syncname" as resumed}, LOG_VERBOSE);
+ $self->glog(qq{Set sync "$syncname" as resumed}, LOG_VERBOSE);
## MCP will restart the CTL on next loop around
}
if (defined $msg) {
}
else {
- ## reload overrides a pause
- if ($sync->{$syncname}{paused}) {
- $self->glog(qq{Resuming paused sync "$syncname"}, LOG_TERSE);
- $sync->{$syncname}{paused} = 0;
- }
+ ## reload overrides a pause
+ if ($sync->{$syncname}{paused}) {
+ $self->glog(qq{Resuming paused sync "$syncname"}, LOG_TERSE);
+ $sync->{$syncname}{paused} = 0;
+ }
$self->glog(qq{Deactivating sync "$syncname"}, LOG_TERSE);
$self->deactivate_sync($sync->{$syncname});
}
elsif ($self->activate_sync($sync->{$syncname})) {
$sync->{$syncname}{mcp_active} = 1;
- ## Just in case:
- $sync->{$syncname}{paused} = 0;
+ ## Just in case:
+ $sync->{$syncname}{paused} = 0;
$maindbh->do(
'UPDATE sync SET status = ? WHERE name = ?',
undef, 'active', $syncname
## Skip if this sync has not been activated
next if ! $s->{mcp_active};
- ## Skip if this one is paused
- next if $s->{paused};
+ ## Skip if this one is paused
+ next if $s->{paused};
- ## Skip is this one is stalled
+ ## Skip is this one is stalled
next if $s->{status} eq 'stalled';
## If this is not a stayalive, AND is not being kicked, skip it
'Pod::Usage' => '0',
'Sys::Hostname' => '1.11',
'Sys::Syslog' => '0.13',
- 'File::Spec' => '0',
- 'MIME::Base64' => '0',
- 'boolean' => '0',
+ 'File::Spec' => '0',
+ 'MIME::Base64' => '0',
+ 'boolean' => '0',
},
NO_META => 1,
NEEDS_LINKING => 0,
package MY;
sub clean {
- my $string = shift->SUPER::clean(@_);
- $string =~ s{\t}{\tperl t/98-cleanup\.t\n\t};
- $string .= qq{\n\nhtml : \n\t};
+ my $string = shift->SUPER::clean(@_);
+ $string =~ s{\t}{\tperl t/98-cleanup\.t\n\t};
+ $string .= qq{\n\nhtml : \n\t};
$string .= qq{\t\$(NOECHO) pod2html Bucardo.pm > Bucardo.pm.html\n};
$string .= qq{\t\$(NOECHO) pod2html bucardo > bucardo.html\n};
$string .= qq{\t\$(NOECHO) \$(RM_F) pod*.tmp pm_to_blib\n};
$string .= qq{\t\$(NOECHO) \$(PERL) -pi -e "s/<link.*?>//" Bucardo.pm.html bucardo.html\n};
$string .= qq{\t\$(NOECHO) \$(PERL) -pi -e "s~\\`\\`(.+?)''~"\\1"~g" Bucardo.pm.html bucardo.html\n};
$string .= qq{\t\$(NOECHO) \$(ECHO) Created Bucardo.pm.html and bucardo.html\n};
- return $string;
+ return $string;
}
sub blibdirs {
- my $string = shift->SUPER::blibdirs_target(@_);
- $string = qq{INST_SHARE = blib/share\n\n$string};
- $string =~ s{(blibdirs : .+)}{$1 \$(INST_SHARE)\$(DFSEP).exists};
- $string .= qq{\$(INST_SHARE)\$(DFSEP).exists :: Makefile.PL\n};
- $string .= qq{\t\$(NOECHO) \$(MKPATH) \$(INST_SHARE)\n};
- $string .= qq{\t\$(NOECHO) \$(CHMOD) 755 \$(INST_SHARE)\n};
- $string .= qq{\t\$(NOECHO) \$(TOUCH) \$(INST_SHARE)\$(DFSEP).exists\n};
- $string .= qq{\t\$(CP) bucardo.schema \$(INST_SHARE)/bucardo.schema\n};
- $string .= qq{\t-\$(NOECHO) \$(CHMOD) \$(PERM_RW) \$(INST_SHARE)/bucardo.schema\n};
- return $string;
+ my $string = shift->SUPER::blibdirs_target(@_);
+ $string = qq{INST_SHARE = blib/share\n\n$string};
+ $string =~ s{(blibdirs : .+)}{$1 \$(INST_SHARE)\$(DFSEP).exists};
+ $string .= qq{\$(INST_SHARE)\$(DFSEP).exists :: Makefile.PL\n};
+ $string .= qq{\t\$(NOECHO) \$(MKPATH) \$(INST_SHARE)\n};
+ $string .= qq{\t\$(NOECHO) \$(CHMOD) 755 \$(INST_SHARE)\n};
+ $string .= qq{\t\$(NOECHO) \$(TOUCH) \$(INST_SHARE)\$(DFSEP).exists\n};
+ $string .= qq{\t\$(CP) bucardo.schema \$(INST_SHARE)/bucardo.schema\n};
+ $string .= qq{\t-\$(NOECHO) \$(CHMOD) \$(PERM_RW) \$(INST_SHARE)/bucardo.schema\n};
+ return $string;
}
sub install {
- my $string = shift->SUPER::install(@_);
- my $vars = qq{DESTINSTALLSHARE = \$(INSTALL_BASE)/usr/local/share/bucardo\n};
- $vars .= qq{DESTINSTALLSITESHARE = \$(INSTALL_BASE)/usr/local/share/bucardo\n};
- $vars .= qq{DESTINSTALLVENDORSHARE = \$(INSTALL_BASE)/usr/share/bucardo\n};
+ my $string = shift->SUPER::install(@_);
+ my $vars = qq{DESTINSTALLSHARE = \$(INSTALL_BASE)/usr/local/share/bucardo\n};
+ $vars .= qq{DESTINSTALLSITESHARE = \$(INSTALL_BASE)/usr/local/share/bucardo\n};
+ $vars .= qq{DESTINSTALLVENDORSHARE = \$(INSTALL_BASE)/usr/share/bucardo\n};
- if ($ENV{INSTALL_BUCARDODIR}) {
- for my $dir (qw{SCRIPT LIB MAN1DIR MAN3DIR}) {
- $vars .= qq{INSTALLSITE$dir=$ENV{INSTALL_BUCARDODIR}\n};
- }
- for my $dir (qw{SITEARCH ARCHLIB SITESHARE}) {
- $vars .= qq{DESTINSTALL$dir=$ENV{INSTALL_BUCARDODIR}\n};
- }
- }
+ if ($ENV{INSTALL_BUCARDODIR}) {
+ for my $dir (qw{SCRIPT LIB MAN1DIR MAN3DIR}) {
+ $vars .= qq{INSTALLSITE$dir=$ENV{INSTALL_BUCARDODIR}\n};
+ }
+ for my $dir (qw{SITEARCH ARCHLIB SITESHARE}) {
+ $vars .= qq{DESTINSTALL$dir=$ENV{INSTALL_BUCARDODIR}\n};
+ }
+ }
- $string = "\n$vars\n$string";
- $string =~ s{(\t\$\(INST_BIN\) \$\((DESTINSTALL.*?)BIN.+)}{$1\n\t\t\$(INST_SHARE) \$($2SHARE) \\}g;
- return $string;
+ $string = "\n$vars\n$string";
+ $string =~ s{(\t\$\(INST_BIN\) \$\((DESTINSTALL.*?)BIN.+)}{$1\n\t\t\$(INST_SHARE) \$($2SHARE) \\}g;
+ return $string;
}