java.lang.Object
com.aoindustries.aoserv.master.FailoverHandler
- All Implemented Interfaces:
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 TypeMethodDescriptionstatic 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) 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) int
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
- Specified by:
getSchedule
in interfaceCronJob
-
getThreadPriority
public int getThreadPriority()- Specified by:
getThreadPriority
in interfaceCronJob
-
start
public static void start() -
run
public void run(int minute, int hour, int dayOfMonth, int month, int dayOfWeek, int year) -
requestReplicationDaemonAccess
public static Server.DaemonAccess requestReplicationDaemonAccess(DatabaseConnection conn, RequestSource source, int fileReplication) throws IOException, SQLException - Throws:
IOException
SQLException
-