Module com.aoindustries.aoserv.master

Package com.aoindustries.aoserv.master

Class FailoverHandler

java.lang.Object

com.aoindustries.aoserv.master.FailoverHandler

All Implemented Interfaces:

CronJob

public final class FailoverHandler
extends Object
implements CronJob

The FailoverHandler handles all the accesses to the failover tables.

Author:

AO Industries, Inc.

Nested Class Summary

Nested classes/interfaces inherited from interface com.aoapps.cron.CronJob

CronJob.Executor, CronJob.ScheduleMode

Method Summary

Modifier and Type	Method	Description
static int	addFileReplicationLog(DatabaseConnection conn, RequestSource source, InvalidateList invalidateList, int fileReplication, long startTime, long endTime, int scanned, int updated, long bytes, boolean isSuccessful)
static int	getBackupPartitionForFileReplication(DatabaseConnection conn, int fileReplication)
static Tuple2<Long,String>	getFileReplicationActivity(DatabaseConnection conn, RequestSource source, int fileReplication)
static void	getFileReplicationLogs(DatabaseConnection conn, RequestSource source, StreamableOutput out, int fileReplication, int maxRows)
static int	getFromHostForFileReplication(DatabaseConnection conn, int fileReplication)
Schedule	getSchedule()
int	getThreadPriority()
static Server.DaemonAccess	requestReplicationDaemonAccess(DatabaseConnection conn, RequestSource source, int fileReplication)
void	run(int minute, int hour, int dayOfMonth, int month, int dayOfWeek, int year)
static void	setFileReplicationBitRate(DatabaseConnection conn, RequestSource source, InvalidateList invalidateList, int fileReplication, Long bitRate)
static void	setFileReplicationSchedules(DatabaseConnection conn, RequestSource source, InvalidateList invalidateList, int fileReplication, List<Short> hours, List<Short> minutes)
static void	setFileReplicationSettings(DatabaseConnection conn, RequestSource source, InvalidateList invalidateList, int fileReplication, List<String> paths, List<Boolean> backupEnableds, List<Boolean> requireds)
static void	start()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface com.aoapps.cron.CronJob

getExecutor, getName, getScheduleMode

Method Details

addFileReplicationLog

public static int addFileReplicationLog(DatabaseConnection conn,
 RequestSource source,
 InvalidateList invalidateList,
 int fileReplication,
 long startTime,
 long endTime,
 int scanned,
 int updated,
 long bytes,
 boolean isSuccessful)
                                 throws IOException,
SQLException

Throws:

IOException

SQLException

setFileReplicationBitRate

public static void setFileReplicationBitRate(DatabaseConnection conn,
 RequestSource source,
 InvalidateList invalidateList,
 int fileReplication,
 Long bitRate)
                                      throws IOException,
SQLException

Throws:

IOException

SQLException

setFileReplicationSchedules

public static void setFileReplicationSchedules(DatabaseConnection conn,
 RequestSource source,
 InvalidateList invalidateList,
 int fileReplication,
 List<Short> hours,
 List<Short> minutes)
                                        throws IOException,
SQLException

Throws:

IOException

SQLException

setFileReplicationSettings

public static void setFileReplicationSettings(DatabaseConnection conn,
 RequestSource source,
 InvalidateList invalidateList,
 int fileReplication,
 List<String> paths,
 List<Boolean> backupEnableds,
 List<Boolean> requireds)
                                       throws IOException,
SQLException

Throws:

IOException

SQLException

getFromHostForFileReplication

public static int getFromHostForFileReplication(DatabaseConnection conn,
 int fileReplication)
                                         throws IOException,
SQLException

Throws:

IOException

SQLException

getBackupPartitionForFileReplication

public static int getBackupPartitionForFileReplication(DatabaseConnection conn,
 int fileReplication)
                                                throws IOException,
SQLException

Throws:

IOException

SQLException

getFileReplicationLogs

public static void getFileReplicationLogs(DatabaseConnection conn,
 RequestSource source,
 StreamableOutput out,
 int fileReplication,
 int maxRows)
                                   throws IOException,
SQLException

Throws:

IOException

SQLException

getFileReplicationActivity

public static Tuple2<Long,String> getFileReplicationActivity(DatabaseConnection conn,
 RequestSource source,
 int fileReplication)
                                                      throws IOException,
SQLException

Throws:

IOException

SQLException

getSchedule

public Schedule getSchedule()

Specified by:

getSchedule in interface CronJob

getThreadPriority

public int getThreadPriority()

Specified by:

getThreadPriority in interface CronJob

start

public static void start()

run

public void run(int minute,
 int hour,
 int dayOfMonth,
 int month,
 int dayOfWeek,
 int year)

Specified by:

run in interface CronJob

requestReplicationDaemonAccess

public static Server.DaemonAccess requestReplicationDaemonAccess(DatabaseConnection conn,
 RequestSource source,
 int fileReplication)
                                                          throws IOException,
SQLException

Throws:

IOException

SQLException