alluxio.master.backup

Class AbstractBackupRole

java.lang.Object

alluxio.master.backup.AbstractBackupRole

All Implemented Interfaces:

BackupOps, BackupRole, Closeable, AutoCloseable

Direct Known Subclasses:

BackupLeaderRole, BackupWorkerRole

public abstract class AbstractBackupRole
extends Object
implements BackupRole

Abstract backup role implementation. It provides common infrastructure for leader/worker backup roles.

Field Summary

Fields

Modifier and Type	Field and Description
protected BackupManager	mBackupManager Backup Manager.
protected BackupTracker	mBackupTracker Used to track backup status.
protected long	mCatalystRequestTimeout
protected ExecutorService	mExecutorService The executor service.
protected GrpcMessagingContext	mGrpcMessagingContext Catalyst context used for sending/receiving messages.
protected JournalSystem	mJournalSystem Journal system.
protected boolean	mRoleClosed Whether the role is active.
protected UserState	mServerUserState User information for server.
protected ScheduledExecutorService	mTaskScheduler Task scheduler.
protected UfsManager	mUfsManager The manager of all ufs.

Constructor Summary

Constructors

Constructor and Description
AbstractBackupRole(CoreMasterContext masterContext) Creates a BackupMaster.

Method Summary

Modifier and Type	Method and Description
void	close()
protected void	sendMessageBlocking(GrpcMessagingConnection connection, Object message) Used to send message via connection and wait until response is received.
protected AlluxioURI	takeBackup(BackupPRequest request, AtomicLong entryCounter) Takes a backup on local master.

Methods inherited from class java.lang.Object

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

Methods inherited from interface alluxio.master.backup.BackupRole

getRoleServices

Methods inherited from interface alluxio.master.backup.BackupOps

backup, getBackupStatus

Field Detail

mCatalystRequestTimeout

protected final long mCatalystRequestTimeout

mUfsManager

protected final UfsManager mUfsManager

The manager of all ufs.

mTaskScheduler

protected ScheduledExecutorService mTaskScheduler

Task scheduler.

mExecutorService

protected ExecutorService mExecutorService

The executor service.

mGrpcMessagingContext

protected GrpcMessagingContext mGrpcMessagingContext

Catalyst context used for sending/receiving messages.

mJournalSystem

protected JournalSystem mJournalSystem

Journal system.

mBackupManager

protected BackupManager mBackupManager

Backup Manager.

mServerUserState

protected UserState mServerUserState

User information for server.

mBackupTracker

protected BackupTracker mBackupTracker

Used to track backup status.

mRoleClosed

protected boolean mRoleClosed

Whether the role is active.

Constructor Detail

AbstractBackupRole

public AbstractBackupRole(CoreMasterContext masterContext)

Creates a BackupMaster.

Parameters:

masterContext - master context

Method Detail

sendMessageBlocking

protected void sendMessageBlocking(GrpcMessagingConnection connection,
                                   Object message)
                            throws IOException

Used to send message via connection and wait until response is received. Response is discarded since backup messages are one-way.

Throws:

IOException

takeBackup

protected AlluxioURI takeBackup(BackupPRequest request,
                                AtomicLong entryCounter)
                         throws IOException

Takes a backup on local master. Note: Master state must have been suspended or locked before calling this.

Parameters:

request - the backup request

entryCounter - counter to receive written entry count

Returns:

URI of the backup

Throws:

IOException

close

public void close()
           throws IOException

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

Throws:

IOException