public abstract class AbstractBackupRole extends Object implements BackupRole
Modifier and Type | Field and Description |
---|---|
protected BackupManager |
mBackupManager
Backup Manager.
|
protected BackupTracker |
mBackupTracker
Used to track backup status.
|
protected io.atomix.catalyst.concurrent.ThreadContext |
mCatalystContext
Catalyst context used for sending/receiving messages.
|
protected long |
mCatalystRequestTimeout |
protected ExecutorService |
mExecutorService
The executor service.
|
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 and Description |
---|
AbstractBackupRole(CoreMasterContext masterContext)
Creates a BackupMaster.
|
Modifier and Type | Method and Description |
---|---|
void |
close() |
protected void |
sendMessageBlocking(io.atomix.catalyst.transport.Connection 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.
|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
getRoleServices
backup, getBackupStatus
protected final long mCatalystRequestTimeout
protected final UfsManager mUfsManager
protected ScheduledExecutorService mTaskScheduler
protected ExecutorService mExecutorService
protected io.atomix.catalyst.concurrent.ThreadContext mCatalystContext
protected JournalSystem mJournalSystem
protected BackupManager mBackupManager
protected UserState mServerUserState
protected BackupTracker mBackupTracker
protected boolean mRoleClosed
public AbstractBackupRole(CoreMasterContext masterContext)
masterContext
- master contextprotected void sendMessageBlocking(io.atomix.catalyst.transport.Connection connection, Object message) throws IOException
IOException
protected AlluxioURI takeBackup(BackupPRequest request, AtomicLong entryCounter) throws IOException
request
- the backup requestentryCounter
- counter to receive written entry countIOException
public void close() throws IOException
close
in interface Closeable
close
in interface AutoCloseable
IOException
Copyright © 2023. All Rights Reserved.