/* * JBoss, Home of Professional Open Source. * Copyright 2000 - 2008, Red Hat Middleware LLC, and individual contributors * as indicated by the @author tags. See the copyright.txt file in the * distribution for a full listing of individual contributors. * * This 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 2.1 of * the License, or (at your option) any later version. * * This software 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 this software; if not, write to the Free * Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA * 02110-1301 USA, or see the FSF site: http://www.fsf.org. */ package org.jboss.cache; import org.apache.commons.logging.LogFactory; import org.jboss.cache.lock.IdentityLock; import org.jboss.cache.optimistic.DataVersion; import org.jboss.cache.optimistic.DefaultDataVersion; import java.util.Map; /** * VersionedNode extends the {@link org.jboss.cache.UnversionedNode} by adding a {@link org.jboss.cache.optimistic.DataVersion} property. *

* Unlike {@link org.jboss.cache.UnversionedNode}, this node supports {@link #getVersion} and {@link #setVersion(org.jboss.cache.optimistic.DataVersion)} * defined in {@link org.jboss.cache.NodeSPI} *

* Typically used when the cache mode configured is {@link org.jboss.cache.config.Configuration.NodeLockingScheme#OPTIMISTIC} * * @author Manik Surtani (manik AT jboss DOT org) * @since 2.0.0 * @deprecated will be removed along with optimistic and pessimistic locking. */ @Deprecated public class VersionedNode extends PessimisticUnversionedNode { private static final String DATA_VERSION_INTERNAL_KEY = "_JBOSS_INTERNAL_OPTIMISTIC_DATA_VERSION"; private DataVersion version; // make sure this is NOT initialized to anything, even a null! Since the UnversionedNode constructor may set this value based on a data version passed along in the data map. static { log = LogFactory.getLog(VersionedNode.class); } /** * Although this object has a reference to the CacheImpl, the optimistic * node is actually disconnected from the CacheImpl itself. * The parent could be looked up from the TransactionWorkspace. */ private NodeSPI parent; public VersionedNode(Fqn fqn, NodeSPI parent, Map data, CacheSPI cache) { super(fqn.getLastElement(), fqn, data, cache); if (parent == null && !fqn.isRoot()) throw new NullPointerException("parent"); if (version == null) version = DefaultDataVersion.ZERO; this.parent = parent; } /** * Returns the version id of this node. * * @return the version */ @Override public DataVersion getVersion() { return version; } /** * Returns the parent. */ @Override public NodeSPI getParent() { return parent; } /** * Sets the version id of this node. * * @param version */ @Override public void setVersion(DataVersion version) { this.version = version; } /** * Optimistically locked nodes (VersionedNodes) will always use repeatable read. */ @Override protected synchronized void initLock() { if (lock == null) lock = new IdentityLock(lockStrategyFactory, delegate); } @Override public Map getInternalState(boolean onlyInternalState) { Map state = super.getInternalState(onlyInternalState); state.put(DATA_VERSION_INTERNAL_KEY, version); return state; } @Override public void setInternalState(Map state) { if (state != null) { DataVersion dv = (DataVersion) state.remove(DATA_VERSION_INTERNAL_KEY); if (dv != null) version = dv; } super.setInternalState(state); } @Override public VersionedNode copy() { VersionedNode n = new VersionedNode(fqn, getParent(), data, cache); copyInternals(n); n.version = version; return n; } }