commands.pm

mysql+ha. 实现高可用性 http://code.google.com/p/mysql-master-master/

#-----------------------------------------------------------------
sub SendMonitorCommand {
    my $cmd = shift;
    my @params = @_;
    
    my $ip = $config->{monitor_ip};
    if (!$ip) {
        LogError("Invalid configration! Can't find monitor ip!");
        exit(0);
    }
    
    LogDebug("Sending command '$cmd(" . join(', ', @params) . ")' to $ip");
    my $sock = IO::Socket::INET->new(
        PeerAddr => $ip,
        PeerPort => $config->{bind_port},
        Proto => 'tcp'
    );
    return 0 unless ($sock && $sock->connected);
    
    $sock->send("$cmd:" . join(':', @params) . "\n");
    my $res = <$sock>;
    close($sock);
    
    return $res;
}

#-----------------------------------------------------------------
sub SendAgentCommand {
    my $host = shift;
    my $cmd = shift;
    my @params = @_;
    
    my $status = $servers_status->{$host};
    my $check_status = $checks_status->{$host};
    
    if ($status->{state} =~ /_OFFLINE$/ && !$check_status->{ping}) {
        LogNotice("Daemon: Skipping SendAgentCommand to $host because of $status->{state} status and ping check failed");
        return "OK: Skipped!";
    }
        
    my $ip = $config->{host}->{$host}->{ip};
    if (!$ip) {
        LogError("Invalid configration! Can't find agent ip!");
        exit(0);
    }
    
    LogDebug("Sending command '$cmd(" . join(', ', @params) . ")' to $ip");
    my $sock = IO::Socket::INET->new(
        PeerAddr => $ip,
        PeerPort => $config->{agent_port},
        Proto => 'tcp',
        Timeout => 10
    );
    return 0 unless ($sock && $sock->connected);
    
    $sock->send("$cmd:" . join(':', @params) . "\n");
    my $res = <$sock>;
    close($sock);
    
    return $res;
}


1;