|
||||||||||
| PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
| SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD | |||||||||
java.lang.Objectorg.infinispan.remoting.transport.jgroups.JGroupsDistSync
@ThreadSafe public class JGroupsDistSync
A DistributedSync based on JGroups' FLUSH protocol
| Nested Class Summary |
|---|
| Nested classes/interfaces inherited from interface org.infinispan.remoting.transport.DistributedSync |
|---|
DistributedSync.SyncResponse |
| Field Summary | |
|---|---|
static boolean |
trace
|
| Constructor Summary | |
|---|---|
JGroupsDistSync()
|
|
| Method Summary | |
|---|---|
void |
acquireProcessingLock(boolean exclusive,
long timeout,
TimeUnit timeUnit)
Acquires a processing lock. |
void |
acquireSync()
Acquires the sync. |
DistributedSync.SyncResponse |
blockUntilAcquired(long timeout,
TimeUnit timeUnit)
Blocks until the start of a sync - either by the current RPCManager instance or a remote one - is received. |
void |
blockUntilNoJoinsInProgress()
|
DistributedSync.SyncResponse |
blockUntilReleased(long timeout,
TimeUnit timeUnit)
Blocks until an ongoing sync ends. |
void |
releaseProcessingLock(boolean exclusive)
Releases any processing locks that may be held by the current thread. |
void |
releaseSync()
Releases the sync. |
void |
signalJoinCompleted()
|
void |
signalJoinInProgress()
|
| Methods inherited from class java.lang.Object |
|---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
| Field Detail |
|---|
public static final boolean trace
| Constructor Detail |
|---|
public JGroupsDistSync()
| Method Detail |
|---|
public DistributedSync.SyncResponse blockUntilAcquired(long timeout,
TimeUnit timeUnit)
throws TimeoutException
DistributedSync
blockUntilAcquired in interface DistributedSynctimeout - timeout after which to give uptimeUnit - time unit
TimeoutException - if waiting for the sync times out.
public DistributedSync.SyncResponse blockUntilReleased(long timeout,
TimeUnit timeUnit)
throws TimeoutException
DistributedSync
blockUntilReleased in interface DistributedSynctimeout - timeout after which to give uptimeUnit - time unit
TimeoutException - if waiting for an ongoing sync to end times out.public void acquireSync()
DistributedSync
acquireSync in interface DistributedSyncpublic void releaseSync()
DistributedSync
releaseSync in interface DistributedSync
public void acquireProcessingLock(boolean exclusive,
long timeout,
TimeUnit timeUnit)
throws TimeoutException
DistributedSync
acquireProcessingLock in interface DistributedSyncexclusive - whether the lock is exclusivetimeout - timeout after which to give uptimeUnit - time unit
TimeoutException - if waiting for the lock times outpublic void releaseProcessingLock(boolean exclusive)
DistributedSync
releaseProcessingLock in interface DistributedSyncpublic void signalJoinInProgress()
public void signalJoinCompleted()
public void blockUntilNoJoinsInProgress()
throws InterruptedException
InterruptedException
|
||||||||||
| PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
| SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD | |||||||||