11:23 a.m.
Author: areshetnyak
Date: 2010-01-05 12:23:13 -0500 (Tue, 05 Jan 2010)
New Revision: 1300
Added:
jcr/branches/1.12.0-JBCCACHE/exo.jcr.component.core/src/test/java/org/exoplatform/services/jcr/impl/dataflow/persistent/jbosscache/
jcr/branches/1.12.0-JBCCACHE/exo.jcr.component.core/src/test/java/org/exoplatform/services/jcr/impl/dataflow/persistent/jbosscache/TestExoEvictionActionPolicy.java
jcr/branches/1.12.0-JBCCACHE/exo.jcr.component.core/src/test/resources/conf/standalone/test-jbosscache-exo-config.xml
Log:
EXOJCR-333 : The test TestExoEvictionActionPolicy was added.
Added:
jcr/branches/1.12.0-JBCCACHE/exo.jcr.component.core/src/test/java/org/exoplatform/services/jcr/impl/dataflow/persistent/jbosscache/TestExoEvictionActionPolicy.java
===================================================================
---
jcr/branches/1.12.0-JBCCACHE/exo.jcr.component.core/src/test/java/org/exoplatform/services/jcr/impl/dataflow/persistent/jbosscache/TestExoEvictionActionPolicy.java
(rev 0)
+++
jcr/branches/1.12.0-JBCCACHE/exo.jcr.component.core/src/test/java/org/exoplatform/services/jcr/impl/dataflow/persistent/jbosscache/TestExoEvictionActionPolicy.java 2010-01-05
17:23:13 UTC (rev 1300)
@@ -0,0 +1,180 @@
+/*
+ * Copyright (C) 2003-2010 eXo Platform SAS.
+ *
+ * This program is free software; you can redistribute it and/or
+ * modify it under the terms of the GNU Affero General Public License
+ * as published by the Free Software Foundation; either version 3
+ * of the License, or (at your option) any later version.
+ *
+ * This program 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 General Public License for more details.
+ *
+ * You should have received a copy of the GNU General Public License
+ * along with this program; if not, see<http://www.gnu.org/licenses/>;.
+ */
+package org.exoplatform.services.jcr.impl.dataflow.persistent.jbosscache;
+
+import java.io.Serializable;
+
+import org.exoplatform.services.cache.CacheListenerContext;
+import org.exoplatform.services.jcr.JcrImplBaseTest;
+import org.exoplatform.services.jcr.access.AccessControlList;
+import org.exoplatform.services.jcr.datamodel.InternalQName;
+import org.exoplatform.services.jcr.datamodel.QPath;
+import org.exoplatform.services.jcr.impl.Constants;
+import org.exoplatform.services.jcr.impl.dataflow.TransientNodeData;
+import org.exoplatform.services.jcr.impl.dataflow.TransientPropertyData;
+import org.exoplatform.services.jcr.impl.dataflow.TransientValueData;
+import org.exoplatform.services.jcr.util.IdGenerator;
+import org.jboss.cache.Cache;
+import org.jboss.cache.DefaultCacheFactory;
+import org.jboss.cache.Fqn;
+import org.jboss.cache.Node;
+import org.jboss.cache.notifications.annotation.CacheListener;
+import org.jboss.cache.notifications.annotation.NodeEvicted;
+import org.jboss.cache.notifications.event.NodeEvent;
+
+/**
+ * Created by The eXo Platform SAS.
+ *
+ * <br/>Date: 2010
+ *
+ * @author <a href="mailto:alex.reshetnyak@exoplatform.com.ua">Alex
Reshetnyak</a>
+ * @version $Id$
+ */
+@CacheListener
+public class TestExoEvictionActionPolicy
+ extends JcrImplBaseTest
+{
+ protected Cache<Serializable, Object> cache;
+
+ protected Fqn<String> itemsRoot;
+
+ protected Fqn<String> childNodesList;
+
+ protected Fqn<String> childPropsList;
+
+ protected String jbcConfig;
+
+ public void setUp() throws Exception
+ {
+ super.setUp();
+
+ initJBCConfig();
+
+ cache = new DefaultCacheFactory<Serializable,
Object>().createCache(jbcConfig, false);
+
+ cache.create();
+ cache.start();
+
+ Node<Serializable, Object> cacheRoot = cache.getRoot();
+
+ this.itemsRoot = Fqn.fromElements(JBossCacheWorkspaceStorageCache.ITEMS);
+ cacheRoot.addChild(this.itemsRoot).setResident(true);
+
+ this.childNodesList =
Fqn.fromElements(JBossCacheWorkspaceStorageCache.CHILD_NODES_LIST);
+ cacheRoot.addChild(this.childNodesList).setResident(true);
+
+ this.childPropsList =
Fqn.fromElements(JBossCacheWorkspaceStorageCache.CHILD_PROPS_LIST);
+ cacheRoot.addChild(this.childPropsList).setResident(true);
+ }
+
+ protected void initJBCConfig()
+ {
+ jbcConfig =
"src/test/resources/conf/standalone/test-jbosscache-exo-config.xml";
+ }
+
+ public void testEviction() throws Exception
+ {
+
+ String evictionNodeId = IdGenerator.generate();
+
+ TransientNodeData evictionNodeData = new
TransientNodeData(QPath.parse("[]:1[]node:1"), evictionNodeId, 1,
Constants.NT_UNSTRUCTURED, new InternalQName[0], 0,
+ IdGenerator.generate(), new AccessControlList());
+
+ String evictionPropId = IdGenerator.generate();
+
+ TransientPropertyData evictionPropData = new
TransientPropertyData(QPath.makeChildPath(Constants.ROOT_PATH,
InternalQName.parse("[]prop1")), evictionPropId, 1, 1, evictionNodeId, false);
+ String propValue1 = "Property value #1";
+ evictionPropData.setValue(new TransientValueData(propValue1));
+
+ // add nodes who will be eviction
+ // put NodeData
+ cache.put(Fqn.fromRelativeElements(itemsRoot, evictionNodeData.getIdentifier()),
JBossCacheWorkspaceStorageCache.ITEM_DATA, evictionNodeData);
+
+ // put PropertyData
+ cache.put(Fqn.fromRelativeElements(itemsRoot, evictionPropData.getIdentifier()),
JBossCacheWorkspaceStorageCache.ITEM_DATA, evictionPropData);
+
+ // put to CHILD_NODES_LIST
+ cache.put(Fqn.fromRelativeElements(childNodesList,
evictionNodeData.getParentIdentifier(), evictionNodeData.getIdentifier()),
JBossCacheWorkspaceStorageCache.NULL_DATA);
+
+ for (int i = 0 ; i < 10; i++)
+ cache.put(Fqn.fromRelativeElements(childNodesList,
evictionNodeData.getParentIdentifier(), IdGenerator.generate()),
JBossCacheWorkspaceStorageCache.NULL_DATA);
+
+ // put to CHILD_PROPS_LIST
+ cache.put(Fqn.fromRelativeElements(childPropsList,
evictionPropData.getParentIdentifier(), evictionPropData.getIdentifier()),
JBossCacheWorkspaceStorageCache.NULL_DATA);
+
+ for (int i = 0 ; i < 10; i++)
+ cache.put(Fqn.fromRelativeElements(childPropsList,
evictionPropData.getParentIdentifier(), IdGenerator.generate()),
JBossCacheWorkspaceStorageCache.NULL_DATA);
+
+
+ // check for exists
+ assertEquals( 2, cache.getChildrenNames(itemsRoot).size());
+ assertNotNull(cache.getNode(Fqn.fromRelativeElements(itemsRoot,
evictionNodeData.getIdentifier())));
+ assertNotNull(cache.getNode(Fqn.fromRelativeElements(itemsRoot,
evictionPropData.getIdentifier())));
+
+ assertNotNull(cache.getNode(Fqn.fromRelativeElements(childNodesList,
evictionNodeData.getParentIdentifier(), evictionNodeData.getIdentifier())));
+ assertNotNull(cache.getNode(Fqn.fromRelativeElements(childPropsList,
evictionPropData.getParentIdentifier(), evictionPropData.getIdentifier())));
+
+ assertEquals( 11, cache.getChildrenNames(Fqn.fromRelativeElements(childNodesList,
evictionNodeData.getParentIdentifier())).size());
+ assertEquals( 11, cache.getChildrenNames(Fqn.fromRelativeElements(childPropsList,
evictionPropData.getParentIdentifier())).size());
+
+
+ Thread.sleep(10 * 1000);
+
+ cache.addCacheListener(this);
+
+ for (int i = 0 ; i< 50; i++)
+ {
+ TransientNodeData evicNodeData = new
TransientNodeData(QPath.parse("[]:1[]node" + i + ":1"),
IdGenerator.generate(), 1, Constants.NT_UNSTRUCTURED, new InternalQName[0], 0,
+ Constants.ROOT_UUID, new AccessControlList());
+ cache.put(Fqn.fromRelativeElements(itemsRoot, evicNodeData.getIdentifier()),
JBossCacheWorkspaceStorageCache.ITEM_DATA, evicNodeData);
+ }
+
+ Thread.sleep(15 * 1000);
+
+ // check
+ assertNull(cache.getNode(Fqn.fromRelativeElements(itemsRoot,
evictionNodeData.getIdentifier())));
+ assertNull(cache.getNode(Fqn.fromRelativeElements(itemsRoot,
evictionPropData.getIdentifier())));
+
+ assertNull(cache.getNode(Fqn.fromRelativeElements(childNodesList,
evictionNodeData.getParentIdentifier())));
+ assertNull(cache.getNode(Fqn.fromRelativeElements(childPropsList,
evictionPropData.getParentIdentifier())));
+ }
+
+ @NodeEvicted
+ public void createdNodeEvent(NodeEvent ne)
+ {
+ System.out.println("Node evicred: " + ne.getFqn());
+ }
+
+
+ public void testEvictionRecurcive() throws Exception
+ {
+ String parentId = IdGenerator.generate();
+
+ // put to CHILD_PROPS_LIST
+ cache.put(Fqn.fromRelativeElements(childPropsList, parentId,
IdGenerator.generate()), JBossCacheWorkspaceStorageCache.NULL_DATA);
+
+ for (int i = 0 ; i < 10; i++)
+ cache.put(Fqn.fromRelativeElements(childPropsList, parentId,
IdGenerator.generate()), JBossCacheWorkspaceStorageCache.NULL_DATA);
+
+
+ assertEquals( 11, cache.getChildrenNames(Fqn.fromRelativeElements(childPropsList,
parentId)).size());
+
+ cache.evict(Fqn.fromRelativeElements(childPropsList, parentId), true);
+
+ assertNull(cache.getNode(Fqn.fromRelativeElements(childPropsList, parentId)));
+ }
+}
Property changes on:
jcr/branches/1.12.0-JBCCACHE/exo.jcr.component.core/src/test/java/org/exoplatform/services/jcr/impl/dataflow/persistent/jbosscache/TestExoEvictionActionPolicy.java
___________________________________________________________________
Name: svn:keywords
+ Id
Name: svn:eol-style
+ native
Added:
jcr/branches/1.12.0-JBCCACHE/exo.jcr.component.core/src/test/resources/conf/standalone/test-jbosscache-exo-config.xml
===================================================================
---
jcr/branches/1.12.0-JBCCACHE/exo.jcr.component.core/src/test/resources/conf/standalone/test-jbosscache-exo-config.xml
(rev 0)
+++
jcr/branches/1.12.0-JBCCACHE/exo.jcr.component.core/src/test/resources/conf/standalone/test-jbosscache-exo-config.xml 2010-01-05
17:23:13 UTC (rev 1300)
@@ -0,0 +1,24 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<jbosscache xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xmlns="urn:jboss:jbosscache-core:config:3.1">
+
+ <locking useLockStriping="false" concurrencyLevel="50000"
lockParentForChildInsertRemove="false"
lockAcquisitionTimeout="3600000"/>
+
+ <!-- Configure the TransactionManager -->
+ <transaction
transactionManagerLookupClass="org.jboss.cache.transaction.JBossStandaloneJTAManagerLookup"
/>
+
+ <!-- Enable batching -->
+ <invocationBatching enabled="true" />
+
+ <!-- Eviction configuration -->
+ <eviction wakeUpInterval="3000">
+ <default algorithmClass="org.jboss.cache.eviction.LRUAlgorithm">
+ <property name="maxNodes" value="50" />
+ <property name="timeToLiveSeconds" value="20" />
+ </default>
+ <region name="/"
algorithmClass="org.jboss.cache.eviction.LRUAlgorithm"
actionPolicyClass="org.exoplatform.services.jcr.impl.dataflow.persistent.jbosscache.ExoEvictionActionPolicy"
eventQueueSize="1000000">
+ <property name="maxNodes" value="50" />
+ <property name="timeToLiveSeconds" value="20" />
+ </region>
+ </eviction>
+
+</jbosscache>
Property changes on:
jcr/branches/1.12.0-JBCCACHE/exo.jcr.component.core/src/test/resources/conf/standalone/test-jbosscache-exo-config.xml
___________________________________________________________________
Name: svn:eol-style
+ native