inteligr8/alfresco-community-repo
1
0
Fork 0
mirror of https://github.com/Alfresco/alfresco-community-repo.git synced 2025-10-08 14:51:49 +00:00
Code Issues Packages Projects Releases Wiki Activity

Merged 5.0.N (5.0.3) to 5.1.N (5.1.0)

Browse Source 
112260: MNT-14526 : JobLockService add getLock with refresh callback variant


git-svn-id: https://svn.alfresco.com/repos/alfresco-enterprise/alfresco/BRANCHES/DEV/5.1.N/root@112342 c4b6b30b-aa2e-2d43-bbcb-ca4b014f7261
This commit is contained in:
Alan Davis
2015-09-18 08:24:19 +00:00
parent 2b57d094ec
commit 612a9de0fa
3 changed files with 170 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

128
source/test-java/org/alfresco/repo/lock/JobLockServiceTest.java
View File

@@ -29,6 +29,8 @@ import org.alfresco.service.namespace.QName;
import org.alfresco.service.transaction.TransactionService;
import org.alfresco.test_category.OwnJVMTestsCategory;
import org.alfresco.util.ApplicationContextHelper;
import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
import org.junit.experimental.categories.Category;
import org.springframework.context.ApplicationContext;
@@ -48,6 +50,8 @@ public class JobLockServiceTest extends TestCase
{
public static final String NAMESPACE = "http://www.alfresco.org/test/JobLockServiceTest";
private static final Log logger = LogFactory.getLog(JobLockServiceTest.class);
private ApplicationContext ctx = ApplicationContextHelper.getApplicationContext();
private TransactionService transactionService;
@@ -460,4 +464,128 @@ public class JobLockServiceTest extends TestCase
assertEquals("Lock callback timer was not terminated", checkedCount, checked[0]);
assertEquals("Lock callback timer was not terminated", releasedCount, released[0]);
}
public void testGetLockWithCallbackNullLock() { runGetLockWithCallback(0); }
public void testGetLockWithCallbackNullCallback() { runGetLockWithCallback(1); }
public void testGetLockWithCallbackShortTTL() { runGetLockWithCallback(2); }
public void testGetLockWithCallbackLocked() { runGetLockWithCallback(3); }
public void testGetLockWithCallbackNormal() { runGetLockWithCallback(4); }
public void runGetLockWithCallback(int t)
{
logger.debug("runGetLockWithCallback "+t+
"\n----------------------------------------"+
"\n"+Thread.currentThread().getStackTrace()[2].getMethodName()+
"\n----------------------------------------");
String token = null;
String tokenB = null;
try
{
QName lockName = t==0 ? null : lockA;
TestCallback callback = t==1 ? null : new TestCallback();
long timeToLive = t==2 ? 1 : 50;
if (t==3)
{
long ttlLongerThanDefaultRetry = 300;
tokenB = jobLockService.getLock(lockA, ttlLongerThanDefaultRetry);
}
token = jobLockService.getLock(lockName, timeToLive, callback);
if (t<4) fail("expected getLock to fail");
if (callback == null) throw new IllegalStateException();
assertEquals(false,callback.released);
assertEquals(0,callback.isActiveCount);
Thread.sleep(40);
assertEquals(false,callback.released);
assertEquals(1,callback.isActiveCount);
callback.isActive = false;
Thread.sleep(40);
assertEquals(true,callback.released);
assertEquals(2,callback.isActiveCount);
}
catch (IllegalArgumentException e)
{
switch (t)
{
case 0: logger.debug("null lock => exception as expected: "+e); break;
case 1: logger.debug("null callback => exception as expected: "+e); break;
case 2: logger.debug("short ttl => exception as expected: "+e); break;
default: fail("exception not expected: "+e); break;
}
}
catch (LockAcquisitionException e)
{
switch (t)
{
case 3: logger.debug("already locked => exception as expected: "+e); break;
default: fail("exception not expected: "+e); break;
}
}
catch (Exception e)
{
fail("exception not expected: "+e);
}
finally
{
if (token != null)
{
logger.debug("token should have been released");
if (jobLockService.releaseLockVerify(token, lockA))
{
fail("token not released");
}
}
if (tokenB != null)
{
logger.debug("tokenB should be released");
jobLockService.releaseLockVerify(tokenB, lockA);
}
try
{
logger.debug("lock should have been released so check can acquire");
String tokenC = jobLockService.getLock(lockA, 50);
jobLockService.releaseLock(tokenC, lockA);
}
catch (LockAcquisitionException e)
{
fail("lock not released");
}
logger.debug("runGetLockWithCallback\n----------------------------------------");
}
}
private class TestCallback implements JobLockRefreshCallback
{
public volatile long isActiveCount;
public volatile boolean released;
public volatile boolean isActive = true;
@Override
public boolean isActive()
{
isActiveCount++;
logger.debug("TestCallback.isActive => "+isActive+" ("+isActiveCount+")");
return isActive;
}
@Override
public void lockReleased()
{
logger.debug("TestCallback.lockReleased");
released = true;
}
}
}