Start line:  
End line:  

Snippet Preview

Snippet HTML Code

Stack Overflow Questions
   * JBoss, Home of Professional Open Source
   * Copyright 2009 Red Hat Inc. and/or its affiliates and other
   * contributors as indicated by the @author tags. All rights reserved.
   * See the copyright.txt 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
  * 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:
 package org.infinispan.loaders.leveldb;
 @Test(groups = "unit", testName = "loaders.leveldb.LevelDBCacheStoreTest")
 public class LevelDBCacheStoreTest extends BaseCacheStoreTest {
 	private LevelDBCacheStore fcs;
 	private String tmpDirectory;
 	protected void setUpTempDir() {
 		 = TestingUtil.tmpDirectory(this);
 	@AfterClass(alwaysRun = true)
 	protected void clearTempDir() {
 		 = new LevelDBCacheStore();
 		cfg.setLocation( + "/data");
 		cfg.setExpiredLocation( + "/expiry");
 		cfg.setPurgeSynchronously(true); // for more accurate unit testing
 		.init(cfggetCache(), getMarshaller());
 		return ;
 	public void testPurgeExpired() throws Exception {
 		long lifespan = 1000;
 		InternalCacheEntry k1 = TestInternalCacheEntryFactory.create("k1",
 		InternalCacheEntry k2 = TestInternalCacheEntryFactory.create("k2",
 		InternalCacheEntry k3 = TestInternalCacheEntryFactory.create("k3",
 		assert .containsKey("k1");
 		assert .containsKey("k2");
 		assert .containsKey("k3");
 		Thread.sleep(lifespan + 100);
 		assert fcs.load("k1") == null;
 		assert fcs.load("k2") == null;
 		assert fcs.load("k3") == null;
 		assert !.containsKey("k1");
 		assert !.containsKey("k2");
 		long lifespan = 1;
 		long idle = 1;
 		InternalCacheEntry se1 = TestInternalCacheEntryFactory.create("k1",
		InternalCacheEntry se2 = TestInternalCacheEntryFactory.create("k2",
		InternalCacheEntry se3 = TestInternalCacheEntryFactory.create("k3",
				"v3", -1, idle);
		InternalCacheEntry se4 = TestInternalCacheEntryFactory.create("k4",
		// Force a purge expired so that expiry tree is updated
		assert se1.isExpired();
		assert .load("k1") == null;
		assert !.containsKey("k1");
		assert .load("k2") != null;
		assert .containsKey("k2");
		assert .load("k2").getValue().equals("v2");
		assert se3.isExpired();
		assert .load("k3") == null;
		assert !.containsKey("k3");
		assert se3.isExpired();
		assert .load("k3") == null;
		assert !.containsKey("k3");
New to GrepCode? Check out our FAQ X