Matt Ward 4055228bdb Merged BRANCHES/DEV/mward/head_locktry_fix to HEAD:
55423: ALF-20031: LockStore is no longer used as a cache for persistent locks - it only holds Lifetime.EPHEMERAL locks.
   55458: ALF-20031: added repeatable read within transactions to LockStores
   55461: ALF-20031: moved transactional test code into separate test classes to avoid clutter.
   55470: ALF-20031: added test for LockStore reads when no transaction is available.
   55473: Generated LockState.toString() to aid debugging, stack trace clarity etc.
   55481: ALF-20031: added tests for null value behaviour (transactional repeatable reads).
   55663: ALF-20031: (work in progress, broken tests) removing concurrency locks from AbstractLockStore.
   55664: ALF-20031: moved inner Thread classes to anonymous inner classes as there will be more of these coming.
   55675: ALF-20031: fixed AbstractLockStoreTxTest
   55681: ALF-20031: added more test cases to AbstractLockStoreTxTest
   55683: Added missing tests to enterprise.repo.cluster package's BuildSafeTestSuite.
   55684: ALF-20031: Fix HazelcastLockStoreTest to clear lock store backing map in createLockStore() fixture setup.
   55688: Commented LockStore.clear() as a DO NOT USE method.
   55694: ALF-20031: removed LockStore.contains() as this is not required, and was currently unsafe (no repeatable reads).
   55696: ALF-20031: Fix AbstractLockStore.clear(): was not clearing transactionally scoped map.
   55700: ALF-20031: removed concurrency locks from LockServiceImpl.getLockState(NodeRef)
   55712: ALF-20031: removed concurrency lock from LockServiceImpl.lock()
   55716: ALF-20031: removed lockstore locking from LockableAspectInterceptor.
   55718: ALF-20031: renamed method to isEphemeralLock()
   55719: ALF-20031: removed concurrency lock from LockServiceImpl.unlock()
   55728: ALF-20031: added cm:lockLifetime property to content model, and added persistence within lockservice.
   55732: ALF-20031: LockableAspectInterceptor no longer uses ephemeral lockstore for setProperties() handling.
   55753: ALF-20031: upon tx rollback, ephemeral locks are now rolled back to the last known value, rather than always being unlocked.
   55759: ALF-20031: temporary fix, AbstractLockStoreTxTest needs further attention for thread coordination.
   55760: ALF-20091: disabled spawning of new transactions in LockKeeperImpl.refreshAllLocks()
   55767: ALF-20031: changed AbstractLockStore to use getFullyAuthenticatedUser() instead of getRunAsUser().
   55833: ALF-20091: reverted LockKeeperImpl to previous (create new tx) behaviour. Altered test to use separate transactions per lock phase.
   55855: ALF-20031: fixed ReplicationServiceIntegrationTest, LockableAspectInterceptor's handling of cm:lockLifetime.



git-svn-id: https://svn.alfresco.com/repos/alfresco-enterprise/alfresco/HEAD/root@55893 c4b6b30b-aa2e-2d43-bbcb-ca4b014f7261
2013-09-24 12:14:46 +00:00

227 lines
7.7 KiB
Java

/*
* Copyright (C) 2005-2012 Alfresco Software Limited.
*
* This file is part of Alfresco
*
* Alfresco is free software: you can redistribute it and/or modify
* it under the terms of the GNU Lesser General Public License as published by
* the Free Software Foundation, either version 3 of the License, or
* (at your option) any later version.
*
* Alfresco is distributed in the hope that it will be useful,
* but WITHOUT ANY WARRANTY; without even the implied warranty of
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
* GNU Lesser General Public License for more details.
*
* You should have received a copy of the GNU Lesser General Public License
* along with Alfresco. If not, see <http://www.gnu.org/licenses/>.
*/
package org.alfresco.repo.lock.mem;
import java.io.Serializable;
import java.util.Date;
import org.alfresco.service.cmr.lock.LockType;
import org.alfresco.service.cmr.repository.NodeRef;
/**
* Value class describing the lock state of a node. Lock specific properties may
* be added using the {@link #additionalInfo} field - <strong>objects</strong> assigned
* to this field <strong>MUST</strong> implement hashCode and equals methods properly.
*
* @author Matt Ward
*/
public final class LockState implements Serializable
{
private static final long serialVersionUID = 1L;
private final NodeRef nodeRef;
private final LockType lockType;
private final String owner;
private final Date expires;
private final Lifetime lifetime;
private final String additionalInfo;
/**
* Constructor.
*
* @param nodeRef
* @param lockType
* @param owner
* @param secondsToExpire
* @param additionalInfo
*/
private LockState(NodeRef nodeRef, LockType lockType, String owner, Date expires,
Lifetime lifetime, String additionalInfo)
{
this.nodeRef = nodeRef;
this.lockType = lockType;
this.owner = owner;
this.expires = (expires == null ? null : new Date(expires.getTime()));
this.lifetime = lifetime;
this.additionalInfo = additionalInfo;
}
public static LockState createLock(NodeRef nodeRef, LockType lockType, String owner, Date expires,
Lifetime lifetime, String additionalInfo)
{
return new LockState(nodeRef, lockType, owner, expires, lifetime, additionalInfo);
}
public static LockState createWithLockType(LockState lockState, LockType lockType)
{
return new LockState(lockState.getNodeRef(),
lockType,
lockState.getOwner(),
lockState.getExpires(),
lockState.getLifetime(),
lockState.getAdditionalInfo());
}
public static LockState createWithOwner(LockState lockState, String owner)
{
return new LockState(lockState.getNodeRef(),
lockState.getLockType(),
owner,
lockState.getExpires(),
lockState.getLifetime(),
lockState.getAdditionalInfo());
}
public static LockState createWithExpires(LockState lockState, Date expires)
{
return new LockState(lockState.getNodeRef(),
lockState.getLockType(),
lockState.getOwner(),
expires,
lockState.getLifetime(),
lockState.getAdditionalInfo());
}
public static LockState createWithLifetime(LockState lockState, Lifetime lifetime)
{
return new LockState(lockState.getNodeRef(),
lockState.getLockType(),
lockState.getOwner(),
lockState.getExpires(),
lifetime,
lockState.getAdditionalInfo());
}
public static LockState createWithAdditionalInfo(LockState lockState, String additionalInfo)
{
return new LockState(lockState.getNodeRef(),
lockState.getLockType(),
lockState.getOwner(),
lockState.getExpires(),
lockState.getLifetime(),
additionalInfo);
}
public static LockState createUnlocked(NodeRef nodeRef, String additionalInfo)
{
return new LockState(nodeRef, null, null, null, null, additionalInfo);
}
public static LockState createUnlocked(NodeRef nodeRef)
{
return new LockState(nodeRef, null, null, null, null, null);
}
/**
* Returns whether this {@link LockState} is for a lock or whether there is no
* lock defined for the node. If a lock is defined for a node, that does not mean that
* the node <em>is</em> locked - the {@link LockService} must be used to determine that.
*
* @return true if there is a lock defined for the node.
*/
public boolean isLockInfo()
{
return (lockType != null);
}
public NodeRef getNodeRef()
{
return this.nodeRef;
}
public LockType getLockType()
{
return this.lockType;
}
public String getOwner()
{
return this.owner;
}
public Date getExpires()
{
return this.expires;
}
public Lifetime getLifetime()
{
return this.lifetime;
}
public String getAdditionalInfo()
{
return this.additionalInfo;
}
@Override
public int hashCode()
{
final int prime = 31;
int result = 1;
result = prime * result
+ ((this.additionalInfo == null) ? 0 : this.additionalInfo.hashCode());
result = prime * result + ((this.expires == null) ? 0 : this.expires.hashCode());
result = prime * result + ((this.lifetime == null) ? 0 : this.lifetime.hashCode());
result = prime * result + ((this.lockType == null) ? 0 : this.lockType.hashCode());
result = prime * result + ((this.nodeRef == null) ? 0 : this.nodeRef.hashCode());
result = prime * result + ((this.owner == null) ? 0 : this.owner.hashCode());
return result;
}
@Override
public boolean equals(Object obj)
{
if (this == obj) return true;
if (obj == null) return false;
if (getClass() != obj.getClass()) return false;
LockState other = (LockState) obj;
if (this.additionalInfo == null)
{
if (other.additionalInfo != null) return false;
}
else if (!this.additionalInfo.equals(other.additionalInfo)) return false;
if (this.expires == null)
{
if (other.expires != null) return false;
}
else if (!this.expires.equals(other.expires)) return false;
if (this.lifetime != other.lifetime) return false;
if (this.lockType != other.lockType) return false;
if (this.nodeRef == null)
{
if (other.nodeRef != null) return false;
}
else if (!this.nodeRef.equals(other.nodeRef)) return false;
if (this.owner == null)
{
if (other.owner != null) return false;
}
else if (!this.owner.equals(other.owner)) return false;
return true;
}
@Override
public String toString()
{
return "LockState [nodeRef=" + this.nodeRef + ", lockType=" + this.lockType + ", owner="
+ this.owner + ", expires=" + this.expires + ", lifetime=" + this.lifetime
+ ", additionalInfo=" + this.additionalInfo + "]";
}
}