|
Pull Up Method public available() : int from class io.atomix.core.semaphore.impl.DefaultDistributedSemaphoreService to public available() : int from class io.atomix.core.semaphore.impl.AbstractAtomicSemaphoreService |
From |
To |
|
Pull Up Method private release(sessionId long, releasePermits int) : void from class io.atomix.core.semaphore.impl.DefaultDistributedSemaphoreService to private release(sessionId long, releasePermits int) : void from class io.atomix.core.semaphore.impl.AbstractAtomicSemaphoreService |
From |
To |
|
Pull Up Method public increase(permits int) : int from class io.atomix.core.semaphore.impl.DefaultDistributedSemaphoreService to public increase(permits int) : int from class io.atomix.core.semaphore.impl.AbstractAtomicSemaphoreService |
From |
To |
|
Pull Up Method private success(sessionId SessionId, operationId long, acquirePermits int, version long) : void from class io.atomix.core.semaphore.impl.DefaultDistributedSemaphoreService to private success(sessionId SessionId, operationId long, acquirePermits int, version long) : void from class io.atomix.core.semaphore.impl.AbstractAtomicSemaphoreService |
From |
To |
|
Pull Up Method public drain() : int from class io.atomix.core.semaphore.impl.DefaultDistributedSemaphoreService to public drain() : int from class io.atomix.core.semaphore.impl.AbstractAtomicSemaphoreService |
From |
To |
|
Pull Up Method public backup(output BackupOutput) : void from class io.atomix.core.semaphore.impl.DefaultDistributedSemaphoreService to public backup(output BackupOutput) : void from class io.atomix.core.semaphore.impl.AbstractAtomicSemaphoreService |
From |
To |
|
Pull Up Method public queueStatus() : QueueStatus from class io.atomix.core.semaphore.impl.DefaultDistributedSemaphoreService to public queueStatus() : QueueStatus from class io.atomix.core.semaphore.impl.AbstractAtomicSemaphoreService |
From |
To |
|
Pull Up Method private fail(sessionId SessionId, operationId long) : void from class io.atomix.core.semaphore.impl.DefaultDistributedSemaphoreService to private fail(sessionId SessionId, operationId long) : void from class io.atomix.core.semaphore.impl.AbstractAtomicSemaphoreService |
From |
To |
|
Pull Up Method private decreaseAvailable(permits int) : int from class io.atomix.core.semaphore.impl.DefaultDistributedSemaphoreService to private decreaseAvailable(permits int) : int from class io.atomix.core.semaphore.impl.AbstractAtomicSemaphoreService |
From |
To |
|
Pull Up Method public serializer() : Serializer from class io.atomix.core.semaphore.impl.DefaultDistributedSemaphoreService to public serializer() : Serializer from class io.atomix.core.semaphore.impl.AbstractAtomicSemaphoreService |
From |
To |
|
Pull Up Method private increaseAvailable(permits int) : int from class io.atomix.core.semaphore.impl.DefaultDistributedSemaphoreService to private increaseAvailable(permits int) : int from class io.atomix.core.semaphore.impl.AbstractAtomicSemaphoreService |
From |
To |
|
Pull Up Method public onClose(session Session) : void from class io.atomix.core.semaphore.impl.DefaultDistributedSemaphoreService to public onClose(session Session) : void from class io.atomix.core.semaphore.impl.AbstractAtomicSemaphoreService |
From |
To |
|
Pull Up Method public onExpire(session Session) : void from class io.atomix.core.semaphore.impl.DefaultDistributedSemaphoreService to public onExpire(session Session) : void from class io.atomix.core.semaphore.impl.AbstractAtomicSemaphoreService |
From |
To |
|
Pull Up Method public release(permits int) : void from class io.atomix.core.semaphore.impl.DefaultDistributedSemaphoreService to public release(permits int) : void from class io.atomix.core.semaphore.impl.AbstractAtomicSemaphoreService |
From |
To |
|
Pull Up Method public acquire(id long, permits int, timeout long) : void from class io.atomix.core.semaphore.impl.DefaultDistributedSemaphoreService to public acquire(id long, permits int, timeout long) : void from class io.atomix.core.semaphore.impl.AbstractAtomicSemaphoreService |
From |
To |
|
Pull Up Method private acquire(sessionId SessionId, operationId long, acquirePermits int, version long) : void from class io.atomix.core.semaphore.impl.DefaultDistributedSemaphoreService to private acquire(sessionId SessionId, operationId long, acquirePermits int, version long) : void from class io.atomix.core.semaphore.impl.AbstractAtomicSemaphoreService |
From |
To |
|
Pull Up Method private releaseSession(session Session) : void from class io.atomix.core.semaphore.impl.DefaultDistributedSemaphoreService to private releaseSession(session Session) : void from class io.atomix.core.semaphore.impl.AbstractAtomicSemaphoreService |
From |
To |
|
Pull Up Method public restore(input BackupInput) : void from class io.atomix.core.semaphore.impl.DefaultDistributedSemaphoreService to public restore(input BackupInput) : void from class io.atomix.core.semaphore.impl.AbstractAtomicSemaphoreService |
From |
To |
|
Pull Up Method public holderStatus() : Map<Long,Integer> from class io.atomix.core.semaphore.impl.DefaultDistributedSemaphoreService to public holderStatus() : Map<Long,Integer> from class io.atomix.core.semaphore.impl.AbstractAtomicSemaphoreService |
From |
To |
|
Pull Up Method public reduce(permits int) : int from class io.atomix.core.semaphore.impl.DefaultDistributedSemaphoreService to public reduce(permits int) : int from class io.atomix.core.semaphore.impl.AbstractAtomicSemaphoreService |
From |
To |
|
Pull Up Method private checkAndNotifyWaiters() : void from class io.atomix.core.semaphore.impl.DefaultDistributedSemaphoreService to private checkAndNotifyWaiters() : void from class io.atomix.core.semaphore.impl.AbstractAtomicSemaphoreService |
From |
To |
|
Pull Up Attribute private waiterQueue : LinkedList<Waiter> from class io.atomix.core.semaphore.impl.DefaultDistributedSemaphoreService to private waiterQueue : LinkedList<Waiter> from class io.atomix.core.semaphore.impl.AbstractAtomicSemaphoreService |
From |
To |
|
Pull Up Attribute private SERIALIZER : Serializer from class io.atomix.core.semaphore.impl.DefaultDistributedSemaphoreService to private SERIALIZER : Serializer from class io.atomix.core.semaphore.impl.AbstractAtomicSemaphoreService |
From |
To |
|
Pull Up Attribute private available : int from class io.atomix.core.semaphore.impl.DefaultDistributedSemaphoreService to private available : int from class io.atomix.core.semaphore.impl.AbstractAtomicSemaphoreService |
From |
To |
|
Pull Up Attribute private holders : Map<Long,Integer> from class io.atomix.core.semaphore.impl.DefaultDistributedSemaphoreService to private holders : Map<Long,Integer> from class io.atomix.core.semaphore.impl.AbstractAtomicSemaphoreService |
From |
To |
|
Pull Up Attribute private timers : Map<Long,Scheduled> from class io.atomix.core.semaphore.impl.DefaultDistributedSemaphoreService to private timers : Map<Long,Scheduled> from class io.atomix.core.semaphore.impl.AbstractAtomicSemaphoreService |
From |
To |
|
Change Return Type int to void in method protected reducePermits(reduction int) : void in class io.atomix.core.semaphore.impl.BlockingDistributedSemaphore |
From |
To |
|
Change Return Type Version to void in method public acquire(permits int) : void in class io.atomix.core.semaphore.impl.BlockingDistributedSemaphore |
From |
To |
|
Change Return Type CompletableFuture<Optional<Version>> to CompletableFuture<Boolean> in method public tryAcquire(timeout Duration) : CompletableFuture<Boolean> in class io.atomix.core.semaphore.AsyncDistributedSemaphore |
From |
To |
|
Change Return Type CompletableFuture<Optional<Version>> to CompletableFuture<Boolean> in method public tryAcquire(permits int, timeout Duration) : CompletableFuture<Boolean> in class io.atomix.core.semaphore.AsyncDistributedSemaphore |
From |
To |
|
Change Return Type Optional<Version> to boolean in method public tryAcquire() : boolean in class io.atomix.core.semaphore.impl.BlockingDistributedSemaphore |
From |
To |
|
Change Return Type int to void in method public acquireUninterruptibly(permits int) : void in class io.atomix.core.semaphore.impl.BlockingDistributedSemaphore |
From |
To |
|
Change Return Type DistributedSemaphoreServiceConfig to AtomicSemaphoreServiceConfig in method public setInitialCapacity(permits int) : AtomicSemaphoreServiceConfig in class io.atomix.core.semaphore.impl.AtomicSemaphoreServiceConfig |
From |
To |
|
Change Return Type Optional<Version> to boolean in method public tryAcquire(permits int) : boolean in class io.atomix.core.semaphore.impl.BlockingDistributedSemaphore |
From |
To |
|
Change Return Type CompletableFuture<Optional<Version>> to CompletableFuture<Boolean> in method public tryAcquire(permits int) : CompletableFuture<Boolean> in class io.atomix.core.semaphore.AsyncDistributedSemaphore |
From |
To |
|
Change Return Type CompletableFuture<Optional<Version>> to CompletableFuture<Boolean> in method public tryAcquire() : CompletableFuture<Boolean> in class io.atomix.core.semaphore.AsyncDistributedSemaphore |
From |
To |
|
Change Return Type Optional<Version> to boolean in method public tryAcquire(timeout Duration) : boolean in class io.atomix.core.semaphore.impl.BlockingDistributedSemaphore |
From |
To |
|
Change Return Type CompletableFuture<Version> to CompletableFuture<Void> in method public acquire(permits int) : CompletableFuture<Void> in class io.atomix.core.semaphore.AsyncDistributedSemaphore |
From |
To |
|
Change Return Type DistributedSemaphore to AtomicSemaphore in method public sync(operationTimeout Duration) : AtomicSemaphore in class io.atomix.core.semaphore.impl.AtomicSemaphoreProxy |
From |
To |
|
Change Return Type Optional<Version> to boolean in method public tryAcquire(permits int, timeout Duration) : boolean in class io.atomix.core.semaphore.impl.BlockingDistributedSemaphore |
From |
To |
|
Change Return Type CompletableFuture<Version> to CompletableFuture<Void> in method public acquire() : CompletableFuture<Void> in class io.atomix.core.semaphore.AsyncDistributedSemaphore |
From |
To |
|
Change Variable Type semaphore100 : AsyncDistributedSemaphore to semaphore100 : AsyncAtomicSemaphore in method public testInit() : void in class io.atomix.core.semaphore.SemaphoreTest |
From |
To |
|
Change Variable Type semaphore : AsyncDistributedSemaphore to semaphore : AsyncAtomicSemaphore in method public testAcquireRelease() : void in class io.atomix.core.semaphore.SemaphoreTest |
From |
To |
|
Change Variable Type proxy : ProxyClient<DistributedSemaphoreService> to proxy : ProxyClient<AtomicSemaphoreService> in method public buildAsync() : CompletableFuture<DistributedSemaphore> in class io.atomix.core.semaphore.impl.DefaultDistributedSemaphoreBuilder |
From |
To |
|
Change Variable Type semaphore : AsyncDistributedSemaphore to semaphore : AsyncAtomicSemaphore in method public testIncreaseReduceDrain() : void in class io.atomix.core.semaphore.SemaphoreTest |
From |
To |
|
Change Variable Type semaphore : DistributedSemaphore to semaphore : AtomicSemaphore in method public testInterrupt() : void in class io.atomix.core.semaphore.SemaphoreTest |
From |
To |
|
Change Variable Type semaphore : AsyncDistributedSemaphore to semaphore : AsyncAtomicSemaphore in method public testQueueStatus() : void in class io.atomix.core.semaphore.RaftSemaphoreTest |
From |
To |
|
Change Variable Type semaphore2 : DistributedSemaphoreProxy to semaphore2 : AtomicSemaphoreProxy in method public testReleaseSession() : void in class io.atomix.core.semaphore.SemaphoreTest |
From |
To |
|
Change Variable Type semaphoreNoInit : AsyncDistributedSemaphore to semaphoreNoInit : AsyncAtomicSemaphore in method public testInit() : void in class io.atomix.core.semaphore.SemaphoreTest |
From |
To |
|
Change Variable Type semaphore0 : AsyncDistributedSemaphore to semaphore0 : AsyncAtomicSemaphore in method public testInit() : void in class io.atomix.core.semaphore.SemaphoreTest |
From |
To |
|
Change Variable Type semaphore2 : DistributedSemaphoreProxy to semaphore2 : AtomicSemaphoreProxy in method public testHolderStatus() : void in class io.atomix.core.semaphore.SemaphoreTest |
From |
To |
|
Change Variable Type semaphore : DistributedSemaphore to semaphore : AtomicSemaphore in method public testBlockTimeout() : void in class io.atomix.core.semaphore.SemaphoreTest |
From |
To |
|
Change Variable Type semaphore : AsyncDistributedSemaphore to semaphore : AsyncAtomicSemaphore in method public testTimeout() : void in class io.atomix.core.semaphore.SemaphoreTest |
From |
To |
|
Change Variable Type semaphore : AsyncDistributedSemaphore to semaphore : AsyncAtomicSemaphore in method public testExpire() : void in class io.atomix.core.semaphore.SemaphoreTest |
From |
To |
|
Change Variable Type semaphore : DistributedSemaphoreProxy to semaphore : AtomicSemaphoreProxy in method public testReleaseSession() : void in class io.atomix.core.semaphore.SemaphoreTest |
From |
To |
|
Change Variable Type semaphore2 : DistributedSemaphore to semaphore2 : AtomicSemaphore in method public testBlockTimeout() : void in class io.atomix.core.semaphore.SemaphoreTest |
From |
To |
|
Change Variable Type semaphore : AsyncDistributedSemaphore to semaphore : AsyncAtomicSemaphore in method public testOverflow() : void in class io.atomix.core.semaphore.SemaphoreTest |
From |
To |
|
Change Variable Type semaphore2 : DistributedSemaphore to semaphore2 : AtomicSemaphore in method public testInterrupt() : void in class io.atomix.core.semaphore.SemaphoreTest |
From |
To |
|
Change Variable Type semaphore : DistributedSemaphore to semaphore : AtomicSemaphore in method public testBlocking() : void in class io.atomix.core.semaphore.SemaphoreTest |
From |
To |
|
Change Variable Type semaphore : DistributedSemaphoreProxy to semaphore : AtomicSemaphoreProxy in method public testHolderStatus() : void in class io.atomix.core.semaphore.SemaphoreTest |
From |
To |
|
Change Variable Type semaphore2 : DistributedSemaphore to semaphore2 : AtomicSemaphore in method public testBlocking() : void in class io.atomix.core.semaphore.SemaphoreTest |
From |
To |
|
Change Variable Type semaphore : AsyncDistributedSemaphore to semaphore : AsyncAtomicSemaphore in method public testQueue() : void in class io.atomix.core.semaphore.SemaphoreTest |
From |
To |